Merge pull request #1055 from scramjetorg/fix/topic-remove

cli topic create connection
scramjetorg · Mar 14, 2024 · 789eda4 · 789eda4
2 parents c6c24ea + d4053b9
commit 789eda4
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 1 deletion.
diff --git a/packages/host/src/lib/serviceDiscovery/sd-adapter.ts b/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;
         }
 

diff --git a/packages/host/src/lib/serviceDiscovery/topicRouter.ts b/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(),

diff --git a/packages/types/src/messages/sth-topic.ts b/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 & {