galactic-bot/Manager.js

82 lines
2.1 KiB
JavaScript
Raw Normal View History

2020-04-13 23:29:08 +02:00
const { EventEmitter } = require('events');
2021-06-06 10:46:41 +02:00
// eslint-disable-next-line no-unused-vars
2020-08-14 16:13:39 +02:00
const { inspect } = require('util');
2020-04-08 16:27:34 +02:00
2020-04-08 18:08:46 +02:00
const ShardManager = require('./middleware/ShardManager.js');
2020-04-13 22:38:10 +02:00
const Logger = require('./middleware/logger/Logger.js');
2020-04-08 16:01:31 +02:00
class Manager extends EventEmitter {
2020-04-08 16:27:34 +02:00
constructor(options) {
2020-04-09 16:30:52 +02:00
super();
this.shardManager = new ShardManager('./structure/client/DiscordClient.js', options);
2020-04-14 08:41:42 +02:00
this.logger = new Logger(this);
2020-04-08 16:27:34 +02:00
this._built = false;
2020-08-14 16:13:39 +02:00
this.readyAt = null;
this.shardManager.on('message', this._handleMessage.bind(this));
// this.on('built', () => {
// this.shardManager.broadcast({ _built: true });
// });
2020-04-13 23:29:08 +02:00
2020-04-08 16:27:34 +02:00
}
2020-04-13 23:29:08 +02:00
_handleMessage(shard, message) {
2020-04-14 17:05:27 +02:00
2020-08-14 16:13:39 +02:00
if (message._mEval) return this.eval(shard, message);
if (message._logger) return this.logger._handleMessage(shard, message);
if (message._webhook) return undefined; //todo
}
2020-04-08 16:27:34 +02:00
async build() {
await this.shardManager.spawn();
2020-04-09 16:30:52 +02:00
2020-04-08 16:27:34 +02:00
this._built = true;
this.emit('built');
2020-08-14 16:13:39 +02:00
this.readyAt = Date.now();
2020-04-08 16:27:34 +02:00
}
2020-04-08 16:01:31 +02:00
2020-08-14 16:13:39 +02:00
/**
*
*
* @param {*} shard The shard from which the eval came and to which it will be returned
* @param {*} script The script to be executed
* @memberof Manager
* @private
*/
async eval(shard, { script }) {
this.logger.write('info', `Incoming manager eval from shard ${shard.id}:\n${script}`);
let result = null,
error = null;
try {
// eslint-disable-next-line no-eval
result = eval(script);
if (result instanceof Promise) result = await result;
//if(typeof result !== 'string') result = inspect(result);
} catch (err) {
error = err.stack || err;
}
return shard.send({
_evalResult: true,
script,
result,
error
});
}
get uptime() {
return this.readyAt !== null ? Date.now() - this.readyAt : 0;
}
2020-04-08 16:01:31 +02:00
}
module.exports = Manager;