Prepare v1.0.2

packages/host/src/lib/cpm-connector.ts

@@ -619,10 +619,12 @@ export class CPMConnector extends TypedEmitter<Events> {
         headers: http.OutgoingHttpHeaders | Record<string, string> = {}
     ): http.ClientRequest {
         //@TODO: Disconnecting/error handling
-        this.logger.info("make HTTP Req to CPM", `${this.cpmUrl}/api/v1/cpm/${this.cpmId}/api/v1/${reqPath}`);
+        const url = `http://scramjet-space/api/v1/cpm/${this.cpmId}/api/v1/${reqPath}`;
+
+        this.logger.info("make HTTP Req to CPM", url);
 
         return http.request(
-            `http://scramjet-space/api/v1/cpm/${this.cpmId}/api/v1/${reqPath}`,
+            url,
             { method, agent: this.verserClient.verserAgent, headers }
         );
     }

packages/host/src/lib/host.ts

@@ -740,22 +740,20 @@ export class Host implements IComponent {
         const clientRequest = this.cpmConnector?.makeHttpRequestToCpm(req.method!, url, req.headers);
 
         if (clientRequest) {
-            clientRequest.on("socket", (socket) => {
-                clientRequest.on("response", (response: IncomingMessage) => {
-                    response.on("end", () => {
-                        this.logger.info("Space response ended", url, response.statusCode);
-                    });
-
-                    res.writeHead(response.statusCode!, response.statusMessage || "", response.headers);
-
-                    socket.pipe(res.socket!);
-                }).on("error", (error) => {
-                    this.logger.error("Error requesting CPM", error);
+            clientRequest.on("response", (response: IncomingMessage) => {
+                response.on("end", () => {
+                    this.logger.info("Space response ended", url, response.statusCode);
                 });
 
-                clientRequest.flushHeaders();
-                req.socket.pipe(socket);
+                res.writeHead(response.statusCode!, response.statusMessage || "", response.headers);
+
+                response.pipe(res);
+            }).on("error", (error) => {
+                this.logger.error("Error requesting CPM", error);
             });
+
+            clientRequest.flushHeaders();
+            req.pipe(clientRequest);
         } else {
             res.statusCode = 404;
             res.end();

packages/host/src/lib/serviceDiscovery/sd-adapter.ts

@@ -79,7 +79,6 @@ export class ServiceDiscovery {
      * Returns topic with given configuration, if not exists creates new one.
      *
      * @param {DataType} config Topic configuration.
-     * @param {string} [localProvider] Provider identifier. It not set topic will be considered as external.
      * @returns added topic data.
      */
     createTopicIfNotExist(config: DataType) {
@@ -94,6 +93,7 @@ export class ServiceDiscovery {
                 throw new Error("Content-type mismatch");
             }
             this.logger.debug("Topic routed:", config);
+
             return topic;
         }
 

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

@@ -69,6 +69,12 @@ class TopicRouter {
 
         const topic = this.serviceDiscovery.createTopicIfNotExist({ topic: topicId, contentType });
 
+        await this.serviceDiscovery.update({
+            contentType,
+            topicName: topicId.toString(),
+            status: "add"
+        });
+
         return {
             opStatus: ReasonPhrases.OK,
             id: topic.id(),

packages/types/src/messages/sth-topic.ts

@@ -12,6 +12,7 @@ export type AddSTHTopicEventData = BaseSTHTopicEventData & {
 } & (
     { requires: string; provides?: never }
     | { provides: string; requires?: never }
+    | { requires?: never; provides?: never }
 );
 
 export type RemoveSTHTopicEventData = BaseSTHTopicEventData & {