forked from bhavanishankar/matisse
-
Notifications
You must be signed in to change notification settings - Fork 0
/
dbinteraction.js
135 lines (118 loc) · 4.87 KB
/
dbinteraction.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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
// global shell with references to most of the models we need
iShell = {};
/**
* Module for db interactions
*/
(function() {
var Nohm = require('nohm').Nohm;
var BoardModel = require(__dirname + '/models/BoardModel.js');
var ShapesModel = require(__dirname + '/models/ShapesModel.js');
var UserModel = require(__dirname + '/models/UserModel.js');
var redis = require("redis");
var redisClient = redis.createClient(); //go thru redis readme for anyother config other than default: localhost 6379
var fs = require('fs');
redisClient.select(4);
Nohm.setPrefix('matisse'); //setting up app prefix for redis
Nohm.setClient(redisClient);
iShell['bm'] = BoardModel, iShell['sm'] = ShapesModel, iShell['um'] = UserModel;
Nohm.logError = function (err) {
if (err) {
console.log("===============Nohm Error=======================");
console.log(err);
console.log("======================================");
}
};
function CommandRunner() {
}
(function(){
var self = this;
var knownCommands = {};
this.process = function(rawChunk) {
var chunk = rawChunk.toString(), chunks, argV;
//lets trim off the last '\n'
chunk = chunk.substring(0, chunk.length - 1 );
chunks = chunk.toString().split(":");
argV = chunk.substring(chunks[0].length + 1);
processCommand(chunks[0], argV, chunk);
};
function processCommand(cmd, arg, chunk) {
var command = knownCommands[cmd];
if (command && command != null ) {
command.call(this, arg);
} else {
console.log("Can not find any command for "+ chunk);
}
};
this.initialize = function() {
knownCommands['getShapes'] = getShapes;
knownCommands['getBoard'] = getBoard;
knownCommands['getUsers'] = getUsers;
knownCommands['writeShapes'] = writeShapes;
knownCommands['eval'] = evalArgs;
knownCommands['help'] = getHelp;
knownCommands['gods'] = function() { // show gods
redisClient.smembers('matisse:gods', redis.print);
};
knownCommands['god'] = function(name) { // add god
redisClient.sadd('matisse:gods', name, knownCommands['gods']);
};
knownCommands['ungod'] = function(name) { // remove god
redisClient.srem('matisse:gods', name, knownCommands['gods']);
};
getHelp();
};
function showAll(model, criteria) {
model.find(criteria,
function(err, ids) {
console.log('Found: ' + ids.length);
ids.forEach(function(id) {
model.load(id, function(err, props) {
console.log(props);
});
});
});
}
function getShapes(boardUrl) {
showAll(ShapesModel, {board_url: "boards/" + boardUrl});
}
function getBoard(boardUrl) {
showAll(BoardModel, {url: boardUrl});
}
function getUsers() {
showAll(UserModel);
}
function writeShapes(cmdArgs) {
var splits = cmdArgs.split(' '), boardUrl = splits[0], fileName = splits[1], log_stream, originalStdOutWrite;
log_stream = fs.createWriteStream("./"+fileName);
log_stream.once('open', function() {
stream_initialized = true;
originalStdOutWrite = process.stdout.write;
process.stdout.write = (function(write) {
return function(string, encoding, fd) {
if (stream_initialized) {
log_stream.write(string);
} else {
write.apply(process.stdout, arguments)
}
}
})(process.stdout.write)
getShapes(boardUrl);
setTimeout(function(){process.stdout.write = originalStdOutWrite}, 3000);
});
}
function getHelp() {
console.log('known commands are')
console.log(knownCommands);
console.log('type command:arg and hit enter for example to get the board use getBoard:hqgwkirg');
}
function evalArgs(argV) {
eval(argV);
}
}).call(CommandRunner.prototype);
var stdin = process.openStdin();
var cmdRunner = new CommandRunner();
cmdRunner.initialize();
stdin.on('data', function(chunk) {
cmdRunner.process(chunk);
});
}).call(this);