-
Notifications
You must be signed in to change notification settings - Fork 2
/
checks.js
89 lines (82 loc) · 2.22 KB
/
checks.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
var db = require("./db.js");
exports.actives = function(callback) {
db.query("SELECT * FROM `checks` WHERE `active`", function(err, results) {
if(err) {
process.nextTick(function() {
callback(err);
});
return;
}
process.nextTick(function() {
callback(null, results);
});
});
};
var daemon = require("./daemon.js");
exports.list = function(options, callback) {
console.log(db.query("SELECT * FROM `checks` WHERE `number` = ?", [
options.number
], function(err, results) {
if(err) {
process.nextTick(function() {
callback(err);
});
return;
}
process.nextTick(function() {
callback(null, results);
});
}).sql);
};
exports.get = function(options, callback) {
console.log(db.query("SELECT * FROM `checks` WHERE `id` = ? AND `number` = ?", [
options.id, options.number
], function(err, results) {
if(err) {
process.nextTick(function() {
callback(err);
});
return;
}
process.nextTick(function() {
callback(null, results);
});
}).sql);
};
exports.set = function(options, callback) {
db.query("UPDATE `checks` SET ? WHERE `id` = ?", [
options, options.id
], function(err, results) {
if (err) {
process.nextTick(function() {
callback(err);
});
return;
}
process.nextTick(function() {
callback(null, results);
});
daemon.update(options);
return;
});
};
exports.create = function(options, callback) {
db.query("INSERT INTO `checks` SET ?", options, function(err, results) {
if (err) {
process.nextTick(function() {
callback(err);
});
return;
}
exports.get({
number: options.number,
id: results.insertId
}, function(err, results){
daemon.update(results.pop());
});
process.nextTick(function() {
callback(null, {id: results.insertId});
});
return;
});
};