Topic class and tests

Author: Eryk Solecki

packages/host/package.json

@@ -11,8 +11,7 @@
     "cloc": "cloc src --fullpath --include-lang TypeScript --not-match-d \"(node_modules|test|dist|bdd)\" --by-percent cm",
     "test": "npm run test:jest",
     "test:ava": "ava",
-    "test:jest": "jest",
-    "test:jest-watch": "jest --watch",
+    "test:jest": "jest --verbose",
     "prebuild": "yarn savehash",
     "savehash": "node ../../scripts/hash-to-file.js ./src/"
   },
@@ -43,7 +42,7 @@
     "@scramjet/types": "^0.33.4",
     "@types/find-package-json": "^1.2.3",
     "@types/jest": "^29.4.4",
-    "@types/node": "15.12.5",
+    "@types/node": "^18.15.11",
     "ava": "^3.15.0",
     "jest": "^29.5.0",
     "ts-jest": "^29.0.5",

packages/host/src/lib/host.ts

@@ -966,12 +966,8 @@ export class Host implements IComponent {
             this.logger.trace("CSIControlled ended", `Exit code: ${code}`);
 
             if (csic.provides && csic.provides !== "") {
-                csic.getOutputStream()!.unpipe(this.serviceDiscovery.getData(
-                    {
-                        topic: new TopicName(csic.provides),
-                        contentType: ""
-                    }
-                ) as Writable);
+                const topic = this.serviceDiscovery.topicsController.get(new TopicName(csic.provides));
+                if (topic) csic.getOutputStream()!.unpipe(topic);
             }
 
             csic.logger.unpipe(this.logger);

packages/host/src/lib/serviceDiscovery/StreamHandler.ts

@@ -0,0 +1,10 @@
+export type ContentType = "text/x-ndjson" | "application/x-ndjson" | "text/plain" | "application/octet-stream"
+
+export const isContentType = (contentType: string): contentType is ContentType => {
+    return [
+        "text/x-ndjson",
+        "application/x-ndjson",
+        "text/plain",
+        "application/octet-stream"
+    ].includes(contentType);
+}