All files / Nodejs/test loadTest.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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
var leo = require("../index.js");
var moment = require("moment");
 
describe("local", function() {
  it("Should be retrieve a nicely formatted workflow", function(done) {
    this.timeout(60000);
    var stream = leo.load("TestBot", "gti.test", {
      debug: true,
      records: 3000,
      time: {
        milliseconds: 100
      },
      chunk: {
        debug: true,
        records: 20,
        time: {
          milliseconds: 500
        }
      }
    });
    var cnt = 10;
    for (let i = 0; i < cnt; i++) {
      stream.write({
        now: moment().format(),
        index: i,
        number: Math.round(Math.random() * 10000)
      });
    }
    setTimeout(function() {
 
      stream.write({
        now: moment().format(),
        index: cnt,
        number: Math.round(Math.random() * 10000)
      });
 
      stream.end(err => {
        console.log("done writting events");
        done();
      });
    }, 700);
 
  });
});