mirror of
https://github.com/clusterio/clusterio.git
synced 2026-11-12 07:04:52 +09:00
62 lines
2.3 KiB
JavaScript
62 lines
2.3 KiB
JavaScript
/**
|
|
* @module
|
|
*/
|
|
"use strict";
|
|
const libPlugin = require("@clusterio/lib/plugin");
|
|
const libLuaTools = require("@clusterio/lib/lua_tools");
|
|
|
|
/**
|
|
* Splits string into array of strings with max of a certain length
|
|
* @param {Number} chunkSize - Max length of each chunk
|
|
* @param {String} string - String to split into chunks
|
|
* @returns {String[]} Chunks
|
|
*/
|
|
function chunkify(chunkSize, string) {
|
|
return string.match(new RegExp(`.{1,${chunkSize}}`, "g"));
|
|
}
|
|
|
|
class InstancePlugin extends libPlugin.BaseInstancePlugin {
|
|
async init() {
|
|
// Handle IPC from scenario script
|
|
this.instance.server.on("ipc-inventory_sync_upload", content => this.handleUpload(content)
|
|
.catch(err => this.logger.error(`Error handling ipc-inventory_sync_upload:\n${err.stack}`)));
|
|
this.instance.server.on("ipc-inventory_sync_download", content => this.handleDownload(content)
|
|
.catch(err => this.logger.error(`Error handling ipc-inventory_sync_download:\n${err.stack}`)));
|
|
}
|
|
|
|
async handleUpload(player) {
|
|
this.logger.verbose(`Uploading ${player.name} (${JSON.stringify(player).length / 1000}kB)`);
|
|
this.info.messages.upload.send(this.instance, {
|
|
instance_id: this.instance.id,
|
|
instance_name: this.instance.name,
|
|
player_name: player.name,
|
|
inventory: player,
|
|
});
|
|
}
|
|
|
|
async handleDownload(player) {
|
|
this.logger.verbose(`Downloading ${player.player_name}`);
|
|
|
|
// Retrieves inventory data. If the master is offline it waits until it comes back online.
|
|
let response = await this.info.messages.download.send(this.instance, {
|
|
player_name: player.player_name,
|
|
});
|
|
if (response.new_player) {
|
|
await this.sendRcon(`/sc inventory_sync.welcome_new_player('${response.player_name}')`);
|
|
} else if (response.inventory) {
|
|
const chunkSize = this.instance.config.get("inventory_sync.rcon_chunk_size");
|
|
const chunks = chunkify(chunkSize, JSON.stringify(response.inventory));
|
|
this.logger.verbose(`Sending inventory for ${player.player_name} in ${chunks.length} chunks`);
|
|
for (let i = 0; i < chunks.length; i++) {
|
|
// this.logger.verbose(`Sending chunk ${i+1} of ${chunks.length}`)
|
|
await this.sendRcon(`/sc inventory_sync.download_inventory('${response.player_name}',` +
|
|
`'${libLuaTools.escapeString(chunks[i])}', ${i + 1}, ${chunks.length})`);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
InstancePlugin,
|
|
};
|