diff --git a/server/components/PM2Listener.js b/server/components/PM2Listener.js index 26fa022..7a22406 100644 --- a/server/components/PM2Listener.js +++ b/server/components/PM2Listener.js @@ -246,6 +246,14 @@ PM2Listener.prototype._doByProcessId = function(host, pm_id, action) { return this._logger.info("PM2Listener", "Invalid host", host, "not in", Object.keys(this._pm2List)); } + if ( + action === 'restartProcessId' + || action === 'reloadProcessId' + || action === 'softReloadProcessId' + ) { + pm_id = { id: pm_id }; + } + this._logger.info("PM2Listener", host, pm_id, action); this._pm2List[host].rpc[action](pm_id, function(error) { diff --git a/test/unit/server/components/PM2ListenerTest.js b/test/unit/server/components/PM2ListenerTest.js index 5f22c2f..9c4b3c1 100644 --- a/test/unit/server/components/PM2ListenerTest.js +++ b/test/unit/server/components/PM2ListenerTest.js @@ -262,7 +262,7 @@ module.exports = { this._listener.restartProcess(host, pm_id); this._listener._pm2List[host].rpc.restartProcessId.callCount.should.equal(1); - this._listener._pm2List[host].rpc.restartProcessId.getCall(0).args[0].should.equal(pm_id); + this._listener._pm2List[host].rpc.restartProcessId.getCall(0).args[0].id.should.equal(pm_id); test.done(); }, @@ -370,7 +370,7 @@ module.exports = { this._listener.reloadProcess(host, pm_id); this._listener._pm2List[host].rpc.reloadProcessId.callCount.should.equal(1); - this._listener._pm2List[host].rpc.reloadProcessId.getCall(0).args[0].should.equal(pm_id); + this._listener._pm2List[host].rpc.reloadProcessId.getCall(0).args[0].id.should.equal(pm_id); test.done(); }, @@ -389,7 +389,7 @@ module.exports = { this._listener.reloadProcess(host, pm_id); this._listener._pm2List[host].rpc.softReloadProcessId.callCount.should.equal(1); - this._listener._pm2List[host].rpc.softReloadProcessId.getCall(0).args[0].should.equal(pm_id); + this._listener._pm2List[host].rpc.softReloadProcessId.getCall(0).args[0].id.should.equal(pm_id); test.done(); },