pubsub suffix changes

rdkcentral · Oct 15, 2024 · 7ced300 · 7ced300
1 parent 9e70488
commit 7ced300
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/src/App.js b/src/App.js
@@ -386,6 +386,7 @@ export default class App extends Base {
       console.log('Response of Initialization :: ', res);
       if (res != undefined) {
         const action = res[0].discovery.navigateTo.action;
+        console.log('2458 action >>>>..',action)
         if (action == 'search') {
           let query = res[0].discovery.navigateTo.data.query;
           let lifecycle_validationString;
@@ -394,7 +395,14 @@ export default class App extends Base {
           if (lifecycle_validationString == true) {
             process.env.LIFECYCLE_VALIDATION = 'true';
           }
+          console.log('2458 query.params >>>>..',query.params)
+          if (query.params.pubSubPublishSuffix) {
+            process.env.PUBSUB_PUBLISH_TOPIC_SUFFIX = query.params.pubSubPublishSuffix;
+          }
 
+          if (query.params.pubSubSubscribeSuffix) {
+            process.env.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX = query.params.pubSubSubscribeSuffix;
+          }
           process.env.APP_TYPE = query.params.appType ? query.params.appType.toLowerCase() : CONSTANTS.FIREBOLT_CONST;
 
           try {

diff --git a/src/pubSubClient.js b/src/pubSubClient.js
@@ -22,8 +22,8 @@ class PubSubClient {
   constructor() {
     this.ws = null;
     this.url = process.env.PUB_SUB_URL ? process.env.PUB_SUB_URL : 'ws://localhost:8080';
-    this.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX = '_FCS';
-    this.PUBSUB_PUBLISH_TOPIC_SUFFIX = '_FCA';
+    this.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX = process.env.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX ? process.env.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX : '_FCS';
+    this.PUBSUB_PUBLISH_TOPIC_SUFFIX = process.env.PUBSUB_PUBLISH_TOPIC_SUFFIX ? process.env.PUBSUB_PUBLISH_TOPIC_SUFFIX : '_FCA';
   }
 
   // Initializes a WS connection
@@ -49,6 +49,8 @@ class PubSubClient {
       console.warn(`WARNING: No pubsub_uuid query parameter or MAC address found. Using default value: ${pubSubTopic}`);
     }
 
+    console.log('2458 subscribe >>>>..',this.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX)
+    console.log('2458 publish >>>>..',this.PUBSUB_PUBLISH_TOPIC_SUFFIX)
     process.env.PUBSUB_SUBSCRIBE_TOPIC = pubSubTopic + '_' + appId + this.PUBSUB_SUBSCRIBE_TOPIC_SUFFIX;
     process.env.PUBSUB_PUBLISH_TOPIC = pubSubTopic + '_' + appId + this.PUBSUB_PUBLISH_TOPIC_SUFFIX;