[CSAPI] Add system query parameter to DataStreams and ControlStreams collection endpoints (#324)

Author: earocorn

sensorhub-service-consys/src/main/java/org/sensorhub/impl/service/consys/obs/DataStreamHandler.java

@@ -141,6 +141,16 @@ protected void buildFilter(final ResourceRef parent, final Map<String, String[]>
         {
             builder.withObservedProperties(obsProps);
         }
+
+        // system param
+        var sysIDs = parseResourceIdsOrUids("system", queryParams, idEncoders.getSystemIdEncoder());
+        if (sysIDs != null && !sysIDs.isEmpty())
+        {
+            if (sysIDs.isUids())
+                builder.withSystems().withUniqueIDs(sysIDs.getUids()).includeMembers(true).done();
+            else
+                builder.withSystems().withInternalIDs(sysIDs.getBigIds()).includeMembers(true).done();
+        }
     }
 
 

sensorhub-service-consys/src/main/java/org/sensorhub/impl/service/consys/task/CommandStreamHandler.java

@@ -126,6 +126,16 @@ protected void buildFilter(final ResourceRef parent, final Map<String, String[]>
                 .withInternalIDs(foiIDs)
                 .done();
         }*/
+
+        // system param
+        var sysIDs = parseResourceIdsOrUids("system", queryParams, idEncoders.getSystemIdEncoder());
+        if (sysIDs != null && !sysIDs.isEmpty())
+        {
+            if (sysIDs.isUids())
+                builder.withSystems().withUniqueIDs(sysIDs.getUids()).includeMembers(true).done();
+            else
+                builder.withSystems().withInternalIDs(sysIDs.getBigIds()).includeMembers(true).done();
+        }
     }