add test for substream lists

tests/automatic/common/cpp/src/testing.cpp

@@ -16,6 +16,7 @@ void T_AssertEq(const T& expected, const T& got) {
 }
 
 void M_AssertTrue(bool value, std::string name) {
+    std::cout<<"asserting "<<name<<std::endl;
     if (!value) {
         std::cerr << "Assert failed: " << name << "\n"
                   << "Expected:\t'" << "1" << "'\n"

tests/automatic/consumer/consumer_api/check_linux.sh

@@ -15,7 +15,7 @@ Cleanup() {
     nomad run nginx_kill.nmd  && nomad stop -yes -purge nginx_kill
     nomad stop discovery
     nomad stop broker
-	echo "db.dropDatabase()" | mongo ${database_name}
+#	echo "db.dropDatabase()" | mongo ${database_name}
 	rm -f 1_1 1
 }
 
@@ -31,6 +31,17 @@ do
 	echo 'db.data_default.insert({"_id":'$i',"size":6,"name":"'$i'","lastchange":1,"source":"none","buf_id":0,"meta":{"test":10}})' | mongo ${database_name}
 done
 
+for i in `seq 1 5`;
+do
+	echo 'db.data_stream1.insert({"_id":'$i',"size":6,"name":"'1$i'","lastchange":1,"source":"none","buf_id":0,"meta":{"test":10}})' | mongo ${database_name}
+done
+
+for i in `seq 1 5`;
+do
+	echo 'db.data_stream2.insert({"_id":'$i',"size":6,"name":"'2$i'","lastchange":1,"source":"none","buf_id":0,"meta":{"test":10}})' | mongo ${database_name}
+done
+
+
 echo hello1 > 1
 
 

tests/automatic/consumer/consumer_api/consumer_api.cpp

@@ -122,6 +122,28 @@ void TestSingle(const std::unique_ptr<asapo::DataBroker>& broker, const std::str
     images = broker->QueryImages("bla", &err);
     M_AssertTrue(err != nullptr, "query5");
     M_AssertTrue(images.size() == 0, "size of query answer 5");
+
+
+//streams
+
+    err = broker->GetNext(&fi, group_id,"stream1", nullptr);
+    if (err) {
+        std::cout << err->Explain() << std::endl;
+    }
+
+    M_AssertTrue(err == nullptr, "GetNext stream1 no error");
+    M_AssertTrue(fi.name == "11", "GetNext stream1 filename");
+
+    err = broker->GetNext(&fi, group_id,"stream2", nullptr);
+    M_AssertTrue(err == nullptr, "GetNext stream2 no error");
+    M_AssertTrue(fi.name == "21", "GetNext stream2 filename");
+
+    auto substreams = broker->GetSubstreamList(&err);
+    M_AssertTrue(err == nullptr, "GetSubstreamList no error");
+    M_AssertTrue(substreams.size() == 3, "substreams.size");
+    M_AssertTrue(substreams[0] == "default", "substreams.name1");
+    M_AssertTrue(substreams[1] == "stream1", "substreams.name2");
+    M_AssertTrue(substreams[2] == "stream2", "substreams.name3");
 }