All files / Nodejs/test aaaaTest.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
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
const leo = require("../index.js");
 
const ls = leo.streams;
 
describe("Streams", function() {
	it("Should support through commands", function(done) {
		console.log("HOWDY");
		let initialStream = ls.through((obj, done) => {
			console.log("INITIAL GOT ", obj);
			done(null, obj);
		});
 
		let secondStream = ls.through((obj, done) => {
			console.log("SECOND GOT ", obj);
			done(null, obj);
		});
 
 
		let writeStream = ls.writeWrapped({
			cmdFlush: (obj, done) => {
				console.log("GOT FLUSH COMMAND", obj);
				done(null);
			},
			cmd: (obj, done) => {
				console.log("GOT A DIFFERENT COMMAND", obj);
				done(null);
			}
		}, (obj, done) => {
			console.log("WRITE GOT ", obj);
			done(null, obj);
		});
 
 
		ls.pipe(initialStream, ls.log("initial"), secondStream, ls.log("second"), writeStream, (err) => {
			console.log("ALL DONE", err);
			done();
		});
 
		initialStream.write({
			HOWDY: 'steve'
		});
		initialStream.write({
			__cmd: 'flush'
		});
		initialStream.write({
			__cmd: 'random'
		});
		initialStream.end();
	});
 
 
 
	it.only("should cause chunk eventstream to flush early", function(done) {
		let initialStream = ls.through((obj, done) => {
			console.log("INITIAL GOT ", obj);
			done(null, obj);
		});
 
		ls.pipe(initialStream, ls.toLeo("testbot"), ls.log("before cmd"), ls.cmd({
			checkpoint: (obj, done) => {
				console.log("Got checkpoint", obj);
				done(null);
			}
		}), ls.devnull("afterCmd"), (err) => {
			done(err);
		});
		initialStream.write({
			id: 'testbot',
			event: 'test',
			payload: {
				Hi: 'steve',
			},
			correlation_id: {
				source: 'sommesource',
				start: 'howdy'
			}
		});
		initialStream.write({
			id: 'testbot',
			event: 'test',
			payload: {
				Hi: 'steve',
			},
			correlation_id: {
				source: 'sommesource',
				start: 'howdy2'
			}
		});
		initialStream.write({
			__cmd: 'flush'
		});
		setTimeout(() => {
			initialStream.end();
		}, 1000);
	});
});