Add receiving system active notifications

sebilm · Dec 22, 2023 · 5ef23da · 5ef23da
1 parent 01358d0
commit 5ef23da
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 2 deletions.
diff --git a/build/main.js b/build/main.js
diff --git a/build/main.js.map b/build/main.js.map
diff --git a/build/myuplinkRepository.js b/build/myuplinkRepository.js
diff --git a/build/myuplinkRepository.js.map b/build/myuplinkRepository.js.map
diff --git a/src/main.ts b/src/main.ts
@@ -254,6 +254,9 @@ class Myuplink extends utils.Adapter {
             system.devices?.forEach(async (dev: SystemDevice) => {
                 await this.setSystemDevice(dev, systemPath, accessToken);
             });
+
+            const notifications = await this.myUplinkRepository?.getActiveNotifications(system.systemId, accessToken);
+            await createStringStateAsync(this, `${systemPath}.rawActiveNotifications`, 'Received raw JSON of active notifications', JSON.stringify(notifications, null, ''));
         }
     }
 

diff --git a/src/myuplinkRepository.ts b/src/myuplinkRepository.ts
@@ -1,4 +1,5 @@
 import axios, { AxiosError } from 'axios';
+import { AlarmsPaged } from './models/AlarmsPaged';
 import { PagedSystemResult } from './models/PagedSystemResult';
 import { ParameterData } from './models/ParameterData';
 
@@ -30,6 +31,10 @@ export class MyUplinkRepository {
         return await this.getFromMyUplink<ParameterData[]>(`/v3/devices/${deviceId}/points`, accessToken);
     }
 
+    async getActiveNotifications(systemId: string, accessToken: string): Promise<AlarmsPaged> {
+        return await this.getFromMyUplink<AlarmsPaged>(`/v2/systems/${systemId}/notifications/active?itemsPerPage=100`, accessToken);
+    }
+
     private async getFromMyUplink<T>(suburl: string, accessToken: string): Promise<T> {
         const lang = this.options.language;
         this.log.debug(`GET ${suburl} (lang: ${lang})`);