errorlog/module.js at master · scaledrop/errorlog · GitHub

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
exports.updateData = function (obj, callback) {
	var collection = obj.db.collection();
	var rec = 0;
	function update() {
		collection.update(obj.query, obj.data, {upsert:true}, function (err, result) {
	    	if (err && rec < 2){
	    	 	obj.db.connect(function () {
					collection = obj.db.collection();
					outputResponse();
				});
	    	} else {
	    	 	if(typeof callback == 'function') {
	    	 		callback(result);
	    	 	}
	    	}
	    });
	}

	outputResponse = function () {
		rec++;
		update();
	};
	outputResponse();
}

exports.getData = function (obj, callback) {
	var collection = obj.db.collection();
	if(typeof obj.collection == 'string') {
		collection = obj.db.otherCollection(obj.collection);
	};

	var rec = 0;
    outputResponse = function () {
    	rec++;
    	var response = [];
		let sortObj = obj.sort ? obj.sort : {};

		let pageSize = obj.pagesize ? obj.pagesize : 10;
		let pageNumObj = obj.pageno ? obj.pageno : 1;
		let skipObj = pageSize ? (pageNumObj - 1) * pageSize : '';
		console.log("pageSize", pageSize);
		collection.find(obj.query).skip(skipObj).limit(pageSize).sort(sortObj).forEach(function(result) {
    		if(result) {
    			response.push(result);
    		}
		}, function(err) {
			if(err && rec < 2){
				obj.db.connect(function () {
					collection = obj.db.collection();
					outputResponse();
				});
			}else{
		        if(typeof callback == 'function') {
	    	 		callback(response);
	    	 	}
			}
		})
    }
    outputResponse();
}

exports.removeData = function(obj, callback) {
	var collection = obj.db.collection();
	var rec = 0;
	function remove() {
		collection.remove(obj.query, function (err, result) {
        	if (err && rec < 2){
        		obj.db.connect(function () {
					collection = obj.db.collection();
					outputResponse();
				});
        	}else{
        		if(typeof callback == 'function') {
	    	 		callback(result);
	    	 	}
        	}
        });
	}

	outputResponse = function () {
		rec++;
		remove();
	};
	outputResponse();
}

exports.saveData = function(obj, callback) {
	var collection = obj.db.collection();
	if(typeof obj.collection == 'string') {
		collection = obj.db.otherCollection(obj.collection);
	};
	collection.save(obj.data, function (err, result) {
		if (err && rec < 2){
    	 	obj.db.connect(function () {
				collection = obj.db.collection();
				outputResponse();
			});
    	} else {
    	 	if(typeof callback == 'function') {
    	 		callback(result);
    	 	}
    	}
	})
}
exports.aggregate = (obj, callback) => {
	var collection = obj.db.collection();
	if(typeof obj.collection == 'string') {
		collection = obj.db.otherCollection(obj.collection);
	};
	collection.aggregate(obj.query).toArray(function(err, result){
		if (err && rec < 2){
    	 	obj.db.connect(function () {
				collection = obj.db.collection();
				outputResponse();
			});
    	} else {
    	 	if(typeof callback == 'function') {
    	 		callback(result);
    	 	}
    	}
	});
}