Remove log and update tests
authorJeroen van der Heijden <jeroen@transceptor.technology>
Wed, 29 Jul 2020 14:02:32 +0000 (16:02 +0200)
committerJeroen van der Heijden <jeroen@transceptor.technology>
Wed, 29 Jul 2020 14:02:32 +0000 (16:02 +0200)
itest/test_tags.py
src/siri/net/bserver.c

index f1d86dcc3aca410bbd6ca6ff9e048daa7b5d6aab..47980c75949c798c7b0c0da903c05bab0cc40fa0 100644 (file)
@@ -174,6 +174,20 @@ class TestTags(TestBase):
             alter series 'variance', 'pvariance' untag `OTHER`
         ''')
 
+        await self.client0.query('''
+            alter series `ALL` where type == float tag `F`
+        ''')
+
+        await self.client0.query('''
+            alter series `ALL` tag `I`
+        ''')
+
+        await asyncio.sleep(3.0)
+
+        await self.client0.query('''
+            alter series `ALL` where type != integer untag `I`
+        ''')
+
         await self.client1.connect()
         await self.client2.connect()
 
@@ -185,6 +199,8 @@ class TestTags(TestBase):
             self.assertEqual(tags, [
                 ["ALL", 13],
                 ["EMPTY", 0],
+                ["F", 5],
+                ["I", 7],
                 ["OTHER", 5],
                 ["SERIES", 4],
                 ["SERIES_FLOAT", 2],
@@ -207,6 +223,8 @@ class TestTags(TestBase):
             self.assertEqual(tags, [
                 ["ALL", 9],
                 ["EMPTY", 0],
+                ["F", 5],
+                ["I", 4],
                 ["OTHER", 4],
                 ["SERIES", 3],
                 ["SERIES_FLOAT", 2],
@@ -233,7 +251,10 @@ class TestTags(TestBase):
                 list tags name, series
             ''')
             tags = sorted(res['tags'])
-            self.assertEqual(tags, [])
+            self.assertEqual(tags, [
+                ["F", 5],
+                ["I", 4],
+            ])
 
         self.client2.close()
         self.client1.close()
index 1a7744a4da8397641481ae67bd3f03247ec5ff1d..f5b66daac30ee2db0ff40f46d3cfedcad2f2d504 100644 (file)
@@ -952,8 +952,6 @@ static void on_empty_tags(sirinet_stream_t * client, sirinet_pkg_t * pkg)
     sirinet_pkg_t * package = NULL;
     siridb_t * siridb = client->siridb;
 
-    LOGC("on empty tags...");
-
     if (~siridb->server->flags & SERVER_FLAG_RUNNING)
     {
         log_error("Cannot tag series because of having status %d",