diff --git a/lib/server/server.js b/lib/server/server.js index cb32323..cfae48a 100644 --- a/lib/server/server.js +++ b/lib/server/server.js @@ -88,7 +88,7 @@ class RpcServer extends Base { } get listenPorts() { - return [this.publishPort]; + return [ this.publishPort ]; } get logger() { @@ -188,7 +188,7 @@ class RpcServer extends Base { this._handleUncaughtError(); }, }); - Promise.all(this._servers.map(server => awaitFirst(server, ['listening', 'error']))) + Promise.all(this._servers.map(server => awaitFirst(server, [ 'listening', 'error' ]))) .then(() => { this.emit('listening'); this.ready(true); @@ -254,7 +254,7 @@ class RpcServer extends Base { this._connections.set(key, conn); conn.on('request', req => { this._handleRequest(req, conn).catch(err => { - const { packetId, packetType, className, options, meta, ctx } = req + const { packetId, packetType, className, options, meta, ctx } = req; const { targetAppName, methodName, serverSignature, interfaceName, methodArgSigs, requestProps } = req.data; err.req = { packetId, packetType, className, options, meta, ctx, data: { targetAppName, methodName, serverSignature, interfaceName, methodArgSigs, requestProps } }; this.emit('error', err);