Add subscriptions and change version to 0.9.0

Author: pierre-josselin

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@faubourg-numerique/ngsi-ld",
-  "version": "0.8.0",
+  "version": "0.9.0",
   "description": "",
   "main": "dist/index.js",
   "scripts": {

package.json

@@ -1,6 +1,7 @@
 import axios, { AxiosInstance, AxiosRequestConfig } from "axios";
 
 import { Entity } from "./Entity";
+import { Subscription } from "./Subscription";
 
 export class ContextBroker {
     private client: AxiosInstance;
@@ -16,11 +17,6 @@ export class ContextBroker {
         this.contextBrokerMaxLimit = contextBrokerMaxLimit;
     }
 
-    async findEntity(id: string) {
-        const response = await this.client.get(`/entities/${encodeURIComponent(id)}`);
-        return new Entity(response.data);
-    }
-
     async findEntities({ type, query }: { type?: string, query?: string }) {
         const config: AxiosRequestConfig = {
             params: {
@@ -46,6 +42,11 @@ export class ContextBroker {
         return entities;
     }
 
+    async findEntity(id: string) {
+        const response = await this.client.get(`/entities/${encodeURIComponent(id)}`);
+        return new Entity(response.data);
+    }
+
     async insertEntity(entity: Entity) {
         await this.client.post("/entities", entity.toObject());
     }
@@ -57,4 +58,40 @@ export class ContextBroker {
     async deleteEntity(entity: Entity) {
         await this.client.delete(`/entities/${encodeURIComponent(entity.getId())}`);
     }
+
+    async findSubscriptions() {
+        const config: AxiosRequestConfig = {
+            params: {
+                limit: this.contextBrokerMaxLimit,
+                offset: 0
+            }
+        };
+        const subscriptions: Subscription[] = [];
+        while (true) {
+            const response = await this.client.get("/subscriptions", config);
+            subscriptions.push(...response.data.map((subscription: any) => new Subscription(subscription)));
+
+            if (response.data.length && response.data.length === this.contextBrokerMaxLimit) {
+                config.params.offset += response.data.length;
+                continue;
+            }
+
+            break;
+        }
+
+        return subscriptions;
+    }
+
+    async findSubscription(id: string) {
+        const response = await this.client.get(`/subscriptions/${encodeURIComponent(id)}`);
+        return new Subscription(response.data);
+    }
+
+    async insertSubscription(subscription: Subscription) {
+        await this.client.post("/subscriptions", subscription.toObject());
+    }
+
+    async deleteSubscription(subscription: Subscription) {
+        await this.client.delete(`/subscriptions/${encodeURIComponent(subscription.getId())}`);
+    }
 }

src/ContextBroker.ts

@@ -0,0 +1,21 @@
+export class Subscription {
+    private data: any = {
+        id: ""
+    };
+
+    constructor(data: any) {
+        Object.assign(this.data, data);
+    }
+
+    getId(): string {
+        return this.data.id;
+    }
+
+    setId(id: string) {
+        this.data.id = id;
+    }
+
+    toObject() {
+        return this.data;
+    }
+}

src/Subscription.ts

@@ -1,2 +1,3 @@
 export * from "./ContextBroker";
 export * from "./Entity";
+export * from "./Subscription";