All files / Nodejs/test reportStartEndNumbersTest.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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
var leo = require("../index.js");
var moment = require("moment");
 
describe("local", function () {
	it("Should be Report numbers and lag", function (done) {
		this.timeout(60000);
		var id = "ckz_report";
		var queue = "ckz_report_queue_write"
 
		var start = Date.now();
		var started = start;
		//leo.bot.start({
		//	id: id
		//}).then(() => {
		//	setTimeout(() => {
 
		leo.bot.checkpoint(id, "system:dw.mysql", {
			eid: moment().format(),
			records: 100,
			started_timestamp: started,
			ended_timestamp: moment.now(),
			source_timestamp: started,
			type: 'write'
		}, () => {
			console.log("Calling End")
			//leo.bot.end(null, () => {
			done();
			//});
		});
 
		// leo.bot.checkpoint(id, queue, {
		// 	eid: "" + Date.now(),
		// 	source_timestamp: start,
		// 	started_timestamp: start,
		// 	ended_timestamp: Date.now(),
		// 	records: 100,
		// 	type: "write",
		// 	//force: true
		// }, () => {
		// 	console.log("Calling End")
		// 	leo.bot.end(null, () => {
		// 		done();
		// 	});
		// });
		//	}, 1);
		//});
	});
});