feat(deviceManagerEngine): free devices after engine deletion

lib/modules/device/DeviceService.ts

@@ -80,6 +80,43 @@ export class DeviceService extends DigitalTwinService {
         await this.attachEngine(engineId, deviceId, request);
       },
     );
+
+    /**
+     * On deletion of a tenant, remove association for all of
+     * its formerly linked devices in the admin index.
+     */
+    this.app.hook.register(
+      "multi-tenancy/tenant:afterDelete",
+      async (request) => {
+        const { group, name } = request.input.args;
+        const tenantIndex = `tenant-${group}-${name}`;
+        const devices = [];
+
+        let result = await this.sdk.document.search(
+          this.config.adminIndex,
+          "devices",
+          {
+            _source: false,
+            query: { bool: { must: { term: { engineId: tenantIndex } } } },
+          },
+          {
+            scroll: "2s",
+            size: 100,
+          },
+        );
+        while (result !== null) {
+          devices.push(...result.hits);
+          result = await result.next();
+        }
+        void this.sdk.document.mUpdate(
+          this.config.adminIndex,
+          "devices",
+          devices.map((device) => {
+            return { _id: device._id, body: { assetId: null, engineId: null } };
+          }),
+        );
+      },
+    );
   }
 
   /**

lib/modules/plugin/DeviceManagerEngine.ts

@@ -327,15 +327,14 @@ export class DeviceManagerEngine extends AbstractEngine<DeviceManagerPlugin> {
       InternalCollection.DEVICES,
       InternalCollection.MEASURES,
     ];
-
     await Promise.all(
       collections.map(async (collection) => {
         if (await this.sdk.collection.exists(index, collection)) {
           await this.sdk.collection.delete(index, collection);
         }
       }),
     );
-
+    await this.detachDevicesFromAdminIndex(index);
     return {
       collections,
     };
@@ -654,4 +653,40 @@ export class DeviceManagerEngine extends AbstractEngine<DeviceManagerPlugin> {
 
     return result.hits.map((elt) => elt._source);
   }
+
+  /**
+   * Detach all devices of an index in the admin index
+   *
+   * @param engineId The target engine Id
+   * @returns {any}
+   */
+  private async detachDevicesFromAdminIndex(engineId: string) {
+    const devices = [];
+
+    let result = await this.sdk.document.search(
+      this.adminIndex,
+      "devices",
+      {
+        _source: false,
+        query: { bool: { must: { term: { engineId } } } },
+      },
+      {
+        scroll: "2s",
+        size: 100,
+      },
+    );
+    while (result !== null) {
+      devices.push(...result.hits);
+      result = await result.next();
+    }
+    if (devices.length > 0) {
+      void this.sdk.document.mUpdate(
+        this.adminIndex,
+        "devices",
+        devices.map((device) => {
+          return { _id: device._id, body: { assetId: null, engineId: null } };
+        }),
+      );
+    }
+  }
 }