fix(tests): Fix receive function test (#66)

Author: eduarduseldorf

examples/data/program-test-6.json

@@ -1,12 +1,12 @@
-{   "title": "RSI",
+{   "title": "Bollinger Bands",
     "description": "This program is generated by the compiler, it represents the bollinger bands operator",
     "date": "now",
     "apiVersion": "v1",
     "author": "Eduardo",
     "entryOperator": "754",
-    "output": { "37": [ "o1", "o2" ] },
+    "output": { "37": [ "o2", "o1", "o3" ] },
     "operators": [
-      { "id": "37", "type": "Output", "numPorts": 2 },
+      { "id": "37", "type": "Output", "numPorts": 3 },
       { "id": "495", "type": "Minus" },
       { "id": "861", "type": "Plus" },
       { "id": "996", "type": "Scale", "value": 2 },
@@ -16,8 +16,9 @@
       { "id": "754", "type": "Input", "numPorts": 1 }
     ],
     "connections": [
-      { "from": "495", "to": "37", "fromPort": "o1", "toPort": "i2" },
-      { "from": "861", "to": "37", "fromPort": "o1", "toPort": "i1" },
+      { "from": "510", "to": "37", "fromPort": "o1", "toPort": "i3" },
+      { "from": "495", "to": "37", "fromPort": "o1", "toPort": "i1" },
+      { "from": "861", "to": "37", "fromPort": "o1", "toPort": "i2" },
       { "from": "996", "to": "495", "fromPort": "o1", "toPort": "i2" },
       { "from": "510", "to": "495", "fromPort": "o1", "toPort": "i1" },
       { "from": "996", "to": "861", "fromPort": "o1", "toPort": "i2" },

libs/api/test/test_bollinger_bands_generated.cpp

@@ -27,8 +27,13 @@ TEST_CASE("read  pipeline test bollinger_bands") {
     int end = 10000;
     int o1 = 0;
     int o2 = 0;
+    int o3 = 0;
+    int firstdown = 0;
+    int firstma = 0;
+    int firstup = 0;
     int lastdown = -1;
     int lastup = -1;
+    int lastma = -1;
     v.push_back(start);
     for (int i = start + 1; i < end; i++) {
       int random_value = rand();
@@ -50,21 +55,42 @@ TEST_CASE("read  pipeline test bollinger_bands") {
         if (output.find("37")->second.count("o1") > 0) {
           for (int j = 0; j < output.find("37")->second.find("o1")->second.size(); j++) {
             int now = output.find("37")->second.find("o1")->second.at(j).time;
-            if (lastup >= 0) REQUIRE(now - 1 == lastup);
+            if (lastup >= 0)
+              REQUIRE(now - 1 == lastup);
+            else
+              firstup = now;
             lastup = now;
             o1++;
           }
         }
         if (output.find("37")->second.count("o2") > 0) {
           for (int j = 0; j < output.find("37")->second.find("o2")->second.size(); j++) {
             int now = output.find("37")->second.find("o2")->second.at(j).time;
-            if (lastdown >= 0) REQUIRE(now - 1 == lastdown);
+            if (lastdown >= 0)
+              REQUIRE(now - 1 == lastdown);
+            else
+              firstdown = now;
             lastdown = now;
             o2++;
           }
         }
+        if (output.find("37")->second.count("o3") > 0) {
+          for (int j = 0; j < output.find("37")->second.find("o3")->second.size(); j++) {
+            int now = output.find("37")->second.find("o3")->second.at(j).time;
+            if (lastma >= 0)
+              REQUIRE(now - 1 == lastma);
+            else
+              firstma = now;
+            lastma = now;
+            o3++;
+          }
+        }
       }
     }
     REQUIRE(o1 == o2);
+    REQUIRE(o3 == o2);
+    REQUIRE(o1 > 0);
+    REQUIRE(firstup == firstdown);
+    REQUIRE(firstup == firstma);
   }
 }