galactic-bot/Manager.js

47 lines
1.2 KiB
JavaScript

const { EventEmitter } = require('events');
const ShardManager = require('./middleware/ShardManager.js');
const StorageManager = require('./storage/StorageManager.js');
const Logger = require('./middleware/logger/Logger.js');
class Manager extends EventEmitter {
constructor(options) {
super();
this.shardManager = new ShardManager('./structure/client/DiscordClient.js', options);
this.logger = new Logger(this);
this.storageManager = new StorageManager(this, options.storage);
this._built = false;
this.shardManager.on('message', this._handleMessage.bind(this));
// this.on('built', () => {
// this.shardManager.broadcast({ _built: true });
// });
}
_handleMessage(shard, message) {
if(message._logger) return this.logger._handleMessage(shard, message);
if(message._storage) return this.storageManager._handleStorageRequest(shard, message);
if(message._webhook) return undefined; //todo
}
async build() {
await this.storageManager.initialize();
await this.shardManager.spawn();
this._built = true;
this.emit('built');
}
}
module.exports = Manager;