aperx/factorio-clusterio
1
0 Fork 0
mirror of https://github.com/clusterio/clusterio.git synced 2026-11-14 23:24:52 +09:00
Code Issues Packages Projects Releases Wiki Activity

!info to see servername (issue #101)

Browse Source
This commit is contained in:
Danielv123 committed 2018-05-21 00:00:42 +02:00
1 parent 165cfffecb
commit e73c5055af
1 file changed
+46 -26
Download Patch File Download Diff File Expand all files Collapse all files
sharedPlugins/globalChat/index.js
+46 -26
View File
@@ -1,11 +1,14 @@
const needle = require("needle");
module.exports = class remoteCommands {
constructor(mergedConfig, messageInterface, extras){
this.messageInterface = messageInterface;
this.config = mergedConfig;
this.socket = extras.socket;
console.log(mergedConfig)
this.instances = {};
this.socket.emit("registerChatReciever");
this.socket.on("gameChat", data => {
this.socket.on("gameChat", async data => {
if(data.instanceID && data.instanceID != this.config.unique.toString()){
if(data.data.includes("[CHAT]") && (data.data.toLowerCase().includes("/shout") || data.data.toLowerCase().includes("!shout"))){
let words = data.data.trim().split(" ");
@@ -13,38 +16,55 @@ module.exports = class remoteCommands {
words.shift();
words.shift();
let message = words.join(" ").replace(/[";]/g, " ").replace(/[']/g,"").replace("/shout ", "").replace("!shout", "");
let instance = this.instances[data.instanceID];
if (!instance) {
let me = this; //to pass 'this' down to the callback
require('needle').get(this.config.masterIP + '/api/slaves', function (err, response) {
if(err || response.statusCode != 200) {
console.log("Unable to get JSON master/api/slaves, master might be unaccessible");
} else if (response && response.body) {
if(Buffer.isBuffer(response.body)) {console.log(response.body.toString("utf-8")); throw new Error();}
try {
for (let index in response.body)
me.instances[index] = response.body[index]["instanceName"];
} catch (e){
console.log(e);
return null;
}
instance = me.instances[data.instanceID]
if (!instance)
instance = data.instanceID; //somehow the master doesn't know the instance
me.messageInterface("/silent-command game.print('[" + instance + "] " + message +"')");
}
});
} else {
this.messageInterface("/silent-command game.print('[" + instance + "] " + message + "')");
}
let instance = await this.getInstanceName(data.instanceID);
this.messageInterface("/silent-command game.print('[" + instance + "] " + message + "')");
}
}
});
}
factorioOutput(data){
async factorioOutput(data){
try{
this.socket.emit("gameChat", {
instanceID: this.config.unique.toString(),
data,
});
if(data.includes("[CHAT]") && data.includes("!info")){
let infoMessage = [
"=== Server info ===",
"Name: "+await this.getInstanceName(this.config.unique)+" ("+this.config.unique+")",
];
infoMessage.forEach((line, i) => {
setTimeout(()=>this.messageInterface("/silent-command game.print('"+line+"')"),i*200);
});
}
}catch(e){console.log(e)}
}
getInstanceName(instanceID){
return new Promise((resolve, reject) => {
let instance = this.instances[instanceID];
if(!instance){
needle.get(this.config.masterIP+":"+this.config.masterPort+ '/api/slaves', (err, response) => {
if(err || response.statusCode != 200) {
console.log("Unable to get JSON master/api/slaves, master might be unaccessible");
} else if (response && response.body) {
if(Buffer.isBuffer(response.body)) {console.log(response.body.toString("utf-8")); throw new Error();}
try {
for (let index in response.body)
this.instances[index] = response.body[index].instanceName;
} catch (e){
console.log(e);
return null;
}
instance = this.instances[instanceID]
if (!instance) instance = instanceID; //somehow the master doesn't know the instance
resolve(instance);
}
});
} else {
resolve(instance);
}
});
}
}