trigger for starting realtime monitoring in analyticsService

Cumulocity-IoT · Feb 27, 2024 · 601cf04 · 601cf04
1 parent 52c8268
commit 601cf04
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 13 deletions.
diff --git a/analytics-ui/src/manage/extension-grid.component.ts b/analytics-ui/src/manage/extension-grid.component.ts
@@ -1,4 +1,4 @@
-import { Component, OnDestroy, OnInit } from '@angular/core';
+import { Component, OnInit } from '@angular/core';
 import { IManagedObject } from '@c8y/client';
 import { WizardConfig, WizardModalService } from '@c8y/ngx-components';
 import { ModalOptions } from 'ngx-bootstrap/modal';
@@ -11,12 +11,11 @@ import { AnalyticsService } from '../shared';
   templateUrl: './extension-grid.component.html',
   styleUrls: ['./extension-grid.component.css']
 })
-export class ExtensionGridComponent implements OnInit, OnDestroy {
+export class ExtensionGridComponent implements OnInit {
   loading: boolean = false;
   restarting$: Subject<boolean>;
   loadingError: boolean = false;
   reload$: BehaviorSubject<boolean> = new BehaviorSubject(false);
-  subscription: any;
   extensions$: Observable<IManagedObject[]>;
   listClass: string;
   rescue: boolean = false;
@@ -47,7 +46,6 @@ export class ExtensionGridComponent implements OnInit, OnDestroy {
     );
 
     this.reload$.next(false);
-    this.initializeMonitoringService();
   }
 
   loadExtensions() {
@@ -77,13 +75,4 @@ export class ExtensionGridComponent implements OnInit, OnDestroy {
     });
   }
 
-  private async initializeMonitoringService(): Promise<void> {
-    this.subscription =
-      await this.analyticsService.subscribeMonitoringChannel();
-  }
-
-  ngOnDestroy(): void {
-    console.log('Stop subscription');
-    this.analyticsService.unsubscribeFromMonitoringChannel(this.subscription);
-  }
 }
diff --git a/analytics-ui/src/shared/analytics.service.ts b/analytics-ui/src/shared/analytics.service.ts
@@ -60,6 +60,7 @@ export class AnalyticsService {
     private applicationService: ApplicationService
   ) {
     this.realtime = new Realtime(this.fetchClient);
+    this.subscribeMonitoringChannel();
   }
 
   getExtensions(): Promise<IResultList<IManagedObject>> {