archive-gh-me/pm2
1
0
Fork 0
mirror of https://github.com/Unitech/pm2.git synced 2025-12-08 20:35:53 +00:00
Code Issues Projects Releases Wiki Activity

refactor files a bit

Browse Source
This commit is contained in:
Unitech 2015-07-14 19:17:46 +02:00
parent d70465f3e4
commit 397bc7146c
5 changed files with 104 additions and 105 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

94
lib/Interactor/CustomActions.js
View File

@ -1,94 +0,0 @@
var debug = require('debug')('interface:driver'); // Interface
var nssocket = require('nssocket');
var Url = require('url');
var Cipher = require('./Cipher.js');
var pm2 = require('../..');
var PushInteractor = require('./PushInteractor');
var Conf = require('../Configuration.js');
var Password = require('./Password.js');
var CustomActions = module.exports = {
/**
* Method to trigger custom actions (axm actions)
*/
axmCustomActions : function() {
var self = this;
this.socket.data('trigger:action', function(raw_msg) {
var msg = {};
if (process.env.NODE_ENV && (process.env.NODE_ENV == 'test' ||
process.env.NODE_ENV == 'local_test'))
msg = raw_msg;
else
msg = Cipher.decipherMessage(raw_msg, self.conf.SECRET_KEY);
if (!msg) return console.error('Error while receiving message! #axmCustomActions');
console.log('New remote action %s triggered for process %s', msg.action_name, msg.process_id);
self.ipm2.rpc.msgProcess({
id : msg.process_id,
msg : msg.action_name,
opts: msg.opts || null
}, function(err, data) {
if (err) {
return self.socket.send('trigger:action:failure', {
success : false,
err : err,
id : msg.process_id,
action_name : msg.action_name
});
}
console.log('[REVERSE INTERACTOR] Message received from AXM for proc_id : %s and action name %s',
msg.process_id, msg.action_name);
return self.socket.send('trigger:action:success', {
success : true,
id : msg.process_id,
action_name : msg.action_name
});
});
});
this.socket.data('trigger:scoped_action', function(raw_msg) {
var msg = {};
if (process.env.NODE_ENV && (process.env.NODE_ENV == 'test' ||
process.env.NODE_ENV == 'local_test'))
msg = raw_msg;
else
msg = Cipher.decipherMessage(raw_msg, self.conf.SECRET_KEY);
if (!msg) return console.error('Error while receiving message! #axmCustomActions');
console.log('New SCOPED action %s triggered for process %s', msg.action_name, msg.process.pm_id);
self.ipm2.rpc.msgProcess({
id : msg.process.pm_id,
action_name : msg.action_name,
msg : msg.action_name,
opts : msg.opts || {},
uuid : msg.uuid
}, function(err, data) {
if (err) {
return self.socket.send('trigger:action:failure', {
success : false,
err : err,
id : msg.process.pm_id,
action_name : msg.action_name
});
}
console.log('[REVERSE INTERACTOR] Message received from AXM for proc_id : %s and action name %s',
msg.process_id, msg.action_name);
return self.socket.send('trigger:action:success', {
success : true,
id : msg.process.pm_id,
action_name : msg.action_name
});
});
});
}
};

93
lib/Interactor/RemoteActions/CustomActions.js
View File

@ -0,0 +1,93 @@
var debug = require('debug')('interface:driver'); // Interface
var nssocket = require('nssocket');
var Url = require('url');
var Cipher = require('../Cipher.js');
var pm2 = require('../../..');
var PushInteractor = require('../PushInteractor');
var Conf = require('../../Configuration.js');
var Password = require('../Password.js');
var CustomActions = module.exports = {
/**
* Method to trigger custom actions (axm actions)
*/
axmCustomActions : function() {
var self = this;
this.socket.data('trigger:action', function(raw_msg) {
var msg = {};
if (process.env.NODE_ENV && (process.env.NODE_ENV == 'test' ||
process.env.NODE_ENV == 'local_test'))
msg = raw_msg;
else
msg = Cipher.decipherMessage(raw_msg, self.conf.SECRET_KEY);
if (!msg) return console.error('Error while receiving message! #axmCustomActions');
console.log('New remote action %s triggered for process %s', msg.action_name, msg.process_id);
self.ipm2.rpc.msgProcess({
id : msg.process_id,
msg : msg.action_name,
opts: msg.opts || null
}, function(err, data) {
if (err) {
return self.socket.send('trigger:action:failure', {
success : false,
err : err,
id : msg.process_id,
action_name : msg.action_name
});
}
console.log('[REVERSE INTERACTOR] Message received from AXM for proc_id : %s and action name %s',
msg.process_id, msg.action_name);
return self.socket.send('trigger:action:success', {
success : true,
id : msg.process_id,
action_name : msg.action_name
});
});
});
this.socket.data('trigger:scoped_action', function(raw_msg) {
var msg = {};
if (process.env.NODE_ENV && (process.env.NODE_ENV == 'test' ||
process.env.NODE_ENV == 'local_test'))
msg = raw_msg;
else
msg = Cipher.decipherMessage(raw_msg, self.conf.SECRET_KEY);
if (!msg) return console.error('Error while receiving message! #axmCustomActions');
console.log('New SCOPED action %s triggered for process %s', msg.action_name, msg.process.pm_id);
self.ipm2.rpc.msgProcess({
id : msg.process.pm_id,
action_name : msg.action_name,
msg : msg.action_name,
opts : msg.opts || {},
uuid : msg.uuid
}, function(err, data) {
if (err) {
return self.socket.send('trigger:action:failure', {
success : false,
err : err,
id : msg.process.pm_id,
action_name : msg.action_name
});
}
console.log('[REVERSE INTERACTOR] Message received from AXM for proc_id : %s and action name %s',
msg.process_id, msg.action_name);
return self.socket.send('trigger:action:success', {
success : true,
id : msg.process.pm_id,
action_name : msg.action_name
});
});
});
}
};

15
lib/Interactor/Pm2Actions.js → lib/Interactor/RemoteActions/Pm2Actions.js
View File

@ -1,12 +1,13 @@
var debug = require('debug')('interface:driver'); // Interface
var nssocket = require('nssocket');
var Url = require('url');
var Cipher = require('./Cipher.js');
var pm2 = require('../..');
var PushInteractor = require('./PushInteractor');
var Conf = require('../Configuration.js');
var Password = require('./Password.js');
var Cipher = require('../Cipher.js');
var pm2 = require('../../..');
var PushInteractor = require('../PushInteractor');
var Conf = require('../../Configuration.js');
var Password = require('../Password.js');
/**
* Allowed remote PM2 methods
@ -35,7 +36,6 @@ var PM2_REMOTE_METHOD_ALLOWED = {
'ping' : { password_required : true, lock : false }
};
var Pm2Actions = module.exports = {
/**
* Methods to trigger PM2 actions from remote
@ -215,7 +215,6 @@ var Pm2Actions = module.exports = {
});
});
/**
* Compact event in Push Interactor *pipe*
*/
@ -284,6 +283,8 @@ var Pm2Actions = module.exports = {
process.env.fork_params = JSON.stringify({ action : method_name, opts : parameters});
console.log(__dirname);
var app = fork(__dirname + '/ScopedExecution.js', [], {
silent : true
});

2
lib/Interactor/ScopedExecution.js → lib/Interactor/RemoteActions/ScopedExecution.js
View File

@ -1,5 +1,5 @@
var pm2 = require('../..');
var pm2 = require('../../..');
var params = JSON.parse(process.env.fork_params);

5
lib/Interactor/ReverseInteractor.js
View File

@ -129,8 +129,7 @@ var ReverseInteract = {
}
};
util._extend(ReverseInteract, require('./Pm2Actions.js'));
util._extend(ReverseInteract, require('./CustomActions.js'));
util._extend(ReverseInteract, require('./RemoteActions/Pm2Actions.js'));
util._extend(ReverseInteract, require('./RemoteActions/CustomActions.js'));
module.exports = ReverseInteract;