Add sharding manager

src/sharding/Shard.js

@@ -1,48 +1,11 @@
 const childProcess = require('child_process');
 const path = require('path');
-const crypto = require('crypto');
 
 class Shard {
   constructor(manager, id) {
     this.manager = manager;
     this.id = id;
-    this.process = childProcess.fork(path.resolve(this.manager.file), [id, this.manager.shards.size], { silent: true });
-    this.waitingForResponse = new Map();
-    this.process.on('message', m => {
-      if (m && m.type && m.id) {
-        if (this.waitingForResponse.get(m.id)) {
-          const resp = this.waitingForResponse.get(m.id);
-          resp.resolve(m.data);
-          this.waitingForResponse.delete(m.id);
-        } else {
-          const reply = data => {
-            this.send(m.id);
-          }
-        }
-      }
-    });
-  }
-
-  send(type, timeout = 60000, data = {}) {
-    const id = crypto.randomBytes(16).toString('hex');
-    this._send(id, type, timeout, data);
-  }
-
-  _send(id, type, timeout, data) {
-    return new Promise((resolve, reject) => {
-      this.process.send({
-        type,
-        id,
-        data,
-      });
-      this.waitingForResponse.set(id, {
-        resolve,
-      });
-      setTimeout(() => {
-        reject(new Error('did not receive response'));
-        this.waitingForResponse.delete(id);
-      }, timeout);
-    });
+    this.process = childProcess.fork(path.resolve(this.manager.file), [id, this.manager.shards.size]);
   }
 }
 

src/sharding/ShardListener.js

@@ -1,28 +0,0 @@
-const crypto = require('crypto');
-
-class ShardListener {
-  constructor() {
-    this.waitingForResponse = new Map();
-    this.process = process;
-  }
-
-  send(type, timeout = 60000, data = {}) {
-    return new Promise((resolve, reject) => {
-      const id = crypto.randomBytes(16).toString('hex');
-      this.process.send({
-        type,
-        id,
-        data,
-      });
-      this.waitingForResponse.set(id, {
-        resolve,
-      });
-      setTimeout(() => {
-        reject(new Error('did not receive response'));
-        this.waitingForResponse.delete(id);
-      }, timeout);
-    });
-  }
-}
-
-module.exports = ShardListener;

src/sharding/ShardingManager.js

@@ -3,7 +3,6 @@ const path = require('path');
 const EventEmitter = require('events').EventEmitter;
 const Collection = require('../util/Collection');
 const Shard = require('./Shard');
-const crypto = require('crypto');
 
 class ShardingManager extends EventEmitter {
   constructor(file, totalShards) {