Skip to content

Commit be49bde

Browse files
committed
added available config command
+ command tests
1 parent 746369a commit be49bde

File tree

3 files changed

+11
-4
lines changed

3 files changed

+11
-4
lines changed

index.js

+1
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,7 @@ const socketInputActions = function(input) {
128128
case 'restart-command': this.restart(input.payload); break;
129129
case 'config-command': this._socketServer.emit(ioEvts.outputs.config(this.currentPimpConfig)); break;
130130
case 'links-command': this._socketServer.emit(ioEvts.outputs.usefulLinks(this.usefulLinks)); break;
131+
case 'available-plugins-command': this._socketServer.emit(ioEvts.outputs.availablePlugins('TODO plugin list')); break;
131132

132133
default:
133134
console.log('pmpEngine received unknown command ' + input);

socket-serving/ioEvts.js

+4-2
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,16 @@ module.exports = {
66
stopCmd: function() { return { type:'input', subType:'stop-command' }},
77
restartCmd: function(config) { return { type:'input', subType:'restart-command', payload:config }},
88
getConfigCmd: function() { return { type:'input', subType:'config-command' }},
9-
getUsefulLinks: function() { return { type:'input', subType:'links-command' }}
9+
getUsefulLinks: function() { return { type:'input', subType:'links-command' }},
10+
getAvailablePlugins: function() { return { type:'input', subType:'available-plugins-command' }}
1011
},
1112
outputs: {
1213
engineStatusLog: function(status) { return { type:'output', subType:'status', payload:status }},
1314
log: function(log) { return { type:'output', subType:'log', payload:log }},
1415
error: function(error) { return { type:'output', subType:'error', payload:error }},
1516
config: function(config) { return { type:'output', subType:'config', payload:config }},
16-
usefulLinks: function(linksObject) { return { type:'output', subType:'links', payload:linksObject }}
17+
usefulLinks: function(linksObject) { return { type:'output', subType:'links', payload:linksObject }},
18+
availablePlugins: function(pluginsArray) { return { type:'output', subType:'plugins', payload:pluginsArray } }
1719
},
1820
utils: {
1921
disconnect: 'disconnect',

test/socket-server.spec.js

+6-2
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,8 @@ class SocketTestClient {
3939
case 'stop': cmdEvt = ioEvt.inputs.stopCmd(); break;
4040
case 'restart': cmdEvt = ioEvt.inputs.restartCmd(); break;
4141
case 'config': cmdEvt = ioEvt.inputs.getConfigCmd(); break;
42+
case 'links': cmdEvt = ioEvt.inputs.getUsefulLinks(); break;
43+
case 'plugins': cmdEvt = ioEvt.inputs.getAvailablePlugins(); break;
4244
}
4345
this._socket.emit('input', cmdEvt);
4446
}
@@ -78,12 +80,14 @@ describe('SocketServer testing', function() {
7880
this.sandbox.restore();
7981
});
8082

81-
it('SocketServer receiving valid input commands [start, stop, restart, getConfig]', function(done){
83+
it('SocketServer receiving valid input commands [start, stop, restart, getConfig, links, plugins]', function(done){
8284
let inputGenerator = function * () {
8385
yield { fire:'start', receive:'start-command' };
8486
yield { fire:'stop', receive:'stop-command' };
8587
yield { fire:'restart', receive:'restart-command' };
86-
return { fire:'config', receive:'config-command' };
88+
yield { fire:'config', receive:'config-command' };
89+
yield { fire:'links', receive:'links-command' };
90+
return { fire:'plugins', receive:'available-plugins-command' };
8791
}
8892
let inputSequence = inputGenerator();
8993
let iteration = inputSequence.next();

0 commit comments

Comments
 (0)