Fix for #277

Cumulocity-IoT · Oct 31, 2024 · 6e1a67c · 6e1a67c
1 parent 7033d89
commit 6e1a67c
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 7 deletions.
diff --git a/dynamic-mapping-ui/src/shared/connector-configuration.service.ts b/dynamic-mapping-ui/src/shared/connector-configuration.service.ts
@@ -59,9 +59,11 @@ export class ConnectorConfigurationService {
     );
     this.startConnectorConfigurations();
     this.sharedConnectorConfigurations$ = this.connectorConfigurations$.pipe(
-      // tap(() => console.log('Further up I')),
-      shareReplay(1),
+      tap(() => console.log('Further up I')),
+      // shareReplay(1),
+      // tap(() => console.log('Further up II')),
       switchMap((configurations: ConnectorConfiguration[]) => {
+        // console.log('Further up III');
         return combineLatest([
           from([configurations]),
           from(this.getConnectorStatus())
@@ -80,7 +82,8 @@ export class ConnectorConfigurationService {
             }));
           })
         );
-      })
+      }),
+      shareReplay(1)
     );
   }
 
@@ -107,7 +110,9 @@ export class ConnectorConfigurationService {
       this.connectorConfigurations$ = merge(
         from(this.getConnectorConfigurations()),
         this.triggerConfigurations$.pipe(
-          switchMap(() => from(this.getConnectorConfigurations()))
+          switchMap(() => {
+            return from(this.getConnectorConfigurations());
+          })
         )
       ).pipe(
         // tap(() => console.log('Something happened')),

diff --git a/dynamic-mapping-ui/src/shared/connector-status.service.ts b/dynamic-mapping-ui/src/shared/connector-status.service.ts
@@ -70,12 +70,12 @@ export class ConnectorStatusService {
   private statusLogs$: Observable<ConnectorStatusEvent[]>;
 
   getStatusLogs(): Observable<ConnectorStatusEvent[]> {
-    console.log('Calling: getStatusLogs');
+    // console.log('Calling: getStatusLogs');
     return this.statusLogs$;
   }
 
   async startConnectorStatusLogs() {
-    console.log('Calling: startConnectorStatusLogs');
+    // console.log('Calling: startConnectorStatusLogs');
     if (!this.statusLogs$) {
       await this.initConnectorLogsRealtime();
     }
@@ -99,7 +99,7 @@ export class ConnectorStatusService {
     //   this._agentId
     // );
     const filteredConnectorStatus$ = this.triggerLogs$.pipe(
-      tap((x) => console.log('TriggerLogs In', x)),
+      // tap((x) => console.log('TriggerLogs In', x)),
       switchMap((x) => {
         const filter = {
           pageSize: 5,