fix integration test

Signed-off-by: Matthias Wahl <mwahl@wayfair.com>

tremor-cli/tests/integration/window_empty_windows/assert.yaml

@@ -2,20 +2,4 @@ status: 0
 name: emit empty windows
 asserts:
   - source: out.log
-    contains:
-      - |
-        ["my_window",1,"SNOT",false,[1,2,3],[{}]]
-      - |
-        ["my_window",1,"BADGER",false,[4,5,6],[{}]]
-      - |
-        ["my_window",1,"SNOT",true,[7,8,9],[{}]]
-      - |
-        ["my_window",2,"BADGER",true,[],[{},{}]]
-      - |
-        ["my_window",0,"SNOT",false,null,[]]
-      - |
-        ["my_window",0,"BADGER",false,null,[]]
-      - |
-        ["my_window",0,"SNOT",true,null,[]]
-      - |
-        ["my_window",0,"BADGER",true,null,[]]
+    equals_file: expected.json

tremor-cli/tests/integration/window_empty_windows/config.yaml

@@ -3,19 +3,20 @@ onramp:
     type: file
     config:
       source: in.json
-      sleep_on_done: 2000
-      close_on_done: true
 offramp:
   - id: out
     type: file
     config:
       file: out.log
+  - id: exit
+    type: exit
 
 binding:
   - id: bind
     links:
       "/onramp/in/{i}/out": ["/pipeline/main/{i}/in"]
-      "/pipeline/main/{i}/out": ["/offramp/out/{i}/out"]
+      "/pipeline/main/{i}/out": ["/offramp/out/{i}/in"]
+      "/pipeline/main/{i}/err": ["/offramp/exit/{i}/in"]
 mapping:
   /binding/bind/01:
     i: "01"

tremor-cli/tests/integration/window_empty_windows/expected.json

@@ -0,0 +1,8 @@
+["my_window",1,"SNOT",false,[1,2,3],[{}]]
+["my_window",1,"BADGER",false,[4,5,6],[{}]]
+["my_window",1,"SNOT",true,[7,8,9],[{}]]
+["my_window",2,"BADGER",true,[],[{},{}]]
+["my_window",0,"SNOT",false,null,[]]
+["my_window",0,"BADGER",false,null,[]]
+["my_window",0,"SNOT",true,null,[]]
+["my_window",0,"BADGER",true,null,[]]

tremor-cli/tests/integration/window_empty_windows/main.trickle

@@ -1,4 +1,5 @@
 use std::string;
+use std::record;
 
 define tumbling window my_window
 with
@@ -11,6 +12,28 @@ with
   emit_empty_windows = true
 end;
 
+# expect 4 empty window events
+define script handle_exit_condition
+script
+    use std::type;
+    let state = match [state, event[1]] of
+      case %(null, 0) => {"count": 1}
+      case %(_, 0) => {"count": state.count + 1}
+      default => state
+    end;
+
+    match state of
+      case %{ count == 5 } =>
+        emit {"exit": 0} => "err"
+      case %{ present count } when state.count > 5 =>
+        drop
+      default =>
+        emit event => "out"
+    end
+end;
+
+create script handle_exit_condition;
+
 select
   [
     window,
@@ -22,4 +45,7 @@ select
   ]
 from in[my_window, my_other_window]
 group by set(event.name, not event.bool)
-into out;
+into handle_exit_condition;
+
+select event from handle_exit_condition/out into out;
+select event from handle_exit_condition/err into err;