forked from amgnet-weeia/aws-sqs-sample
-
Notifications
You must be signed in to change notification settings - Fork 0
/
sqsconsole.js
30 lines (28 loc) · 901 Bytes
/
sqsconsole.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
var readline = require('readline');
module.exports = function(sqsCommands){
var _this = this;
_this.sqsCommands = sqsCommands;
_this.rl = readline.createInterface(process.stdin, process.stdout);
_this.rl.setPrompt('sqs> ');
_this.rl.prompt();
_this.rl.on('line', function(line) {
line = line.trim();
if(line.length > 0){
var splitted_line = line.split(" ", 1);
splitted_line[1] = line.substr(splitted_line[0].length+1, line.length).trim();
console.log(splitted_line.join(", "));
_this.sqsCommands.execCommand(splitted_line[0], splitted_line[1], function(err, data){
if(err) {
console.log("'" + splitted_line[0] + "' command error: " + err);
}
else {
console.log("'" + splitted_line[0] + "' command executed: " + JSON.stringify(data));
}
_this.rl.prompt();
});
}
_this.rl.prompt();
}).on('close',function(){
process.exit(0);
});
}