Simplify identity deletion process handling on second device by republishing events

packages/app-runtime/src/AppConfig.ts

@@ -52,12 +52,6 @@ export function createAppConfig(...configs: AppConfigOverwrite[]): AppConfig {
                 location: "onboardingChangeReceived",
                 enabled: true
             },
-            datawalletSynchronized: {
-                name: "datawalletSynchronized",
-                displayName: "Datawallet Synchronized Module",
-                location: "datawalletSynchronized",
-                enabled: true
-            },
             identityDeletionProcessStatusChanged: {
                 name: "identityDeletionProcessStatusChanged",
                 displayName: "Identity Deletion Process Status Changed Module",

packages/app-runtime/src/AppRuntime.ts

@@ -15,7 +15,6 @@ import {
     AppLaunchModule,
     AppRuntimeModuleConfiguration,
     AppSyncModule,
-    DatawalletSynchronizedModule,
     IAppRuntimeModuleConstructor,
     IdentityDeletionProcessStatusChangedModule,
     MailReceivedModule,
@@ -264,7 +263,6 @@ export class AppRuntime extends Runtime<AppConfig> {
         pushNotification: PushNotificationModule,
         mailReceived: MailReceivedModule,
         onboardingChangeReceived: OnboardingChangeReceivedModule,
-        datawalletSynchronized: DatawalletSynchronizedModule,
         identityDeletionProcessStatusChanged: IdentityDeletionProcessStatusChangedModule,
         messageReceived: MessageReceivedModule,
         relationshipChanged: RelationshipChangedModule,

packages/app-runtime/src/modules/runtimeEvents/IdentityDeletionProcessStatusChangedModule.ts

@@ -1,6 +1,8 @@
 import { CoreDate } from "@nmshd/core-types";
 import { IdentityDeletionProcessStatus, IdentityDeletionProcessStatusChangedEvent } from "@nmshd/runtime";
 import { AppRuntimeError } from "../../AppRuntimeError";
+import { LocalAccountDeletionDateChangedEvent } from "../../events";
+import { LocalAccountMapper } from "../../multiAccount/data/LocalAccountMapper";
 import { AppRuntimeModule, AppRuntimeModuleConfiguration } from "../AppRuntimeModule";
 
 export interface IdentityDeletionProcessStatusChangedModuleConfig extends AppRuntimeModuleConfiguration {}
@@ -19,25 +21,44 @@ export class IdentityDeletionProcessStatusChangedModule extends AppRuntimeModule
     private async handleIdentityDeletionProcessStatusChanged(event: IdentityDeletionProcessStatusChangedEvent) {
         const identityDeletionProcess = event.data;
 
+        if (!identityDeletionProcess) {
+            const services = await this.runtime.getServices(event.eventTargetAddress);
+            const identityDeletionProcesses = await services.transportServices.identityDeletionProcesses.getIdentityDeletionProcesses();
+
+            const approvedIdentityDeletionProcess = identityDeletionProcesses.value.filter((idp) => idp.status === IdentityDeletionProcessStatus.Approved).at(0);
+            const deletionDate = approvedIdentityDeletionProcess?.gracePeriodEndsAt ? CoreDate.from(approvedIdentityDeletionProcess.gracePeriodEndsAt) : undefined;
+
+            await this.updateLocalAccountDeletionDate(event.eventTargetAddress, deletionDate, true);
+            return;
+        }
+
         switch (identityDeletionProcess.status) {
             case IdentityDeletionProcessStatus.Approved:
-                await this.runtime.multiAccountController.updateLocalAccountDeletionDate(event.eventTargetAddress, CoreDate.from(identityDeletionProcess.gracePeriodEndsAt!));
+                await this.updateLocalAccountDeletionDate(event.eventTargetAddress, CoreDate.from(identityDeletionProcess.gracePeriodEndsAt!));
                 break;
 
             case IdentityDeletionProcessStatus.Cancelled:
-                const account = await this.runtime.multiAccountController.getAccountByAddress(event.eventTargetAddress);
-                const previousDeletionDate = account.deletionDate;
-
-                if (!previousDeletionDate) break;
-
-                await this.runtime.multiAccountController.updateLocalAccountDeletionDate(event.eventTargetAddress, undefined);
+                await this.updateLocalAccountDeletionDate(event.eventTargetAddress, undefined);
                 break;
 
             default:
                 break;
         }
     }
 
+    private async updateLocalAccountDeletionDate(eventTargetAddress: string, deletionDate: CoreDate | undefined, publishEvent = false) {
+        const account = await this.runtime.multiAccountController.getAccountByAddress(eventTargetAddress);
+        const previousDeletionDate = account.deletionDate;
+
+        if (!deletionDate && !previousDeletionDate) return;
+        if (deletionDate && previousDeletionDate && deletionDate.equals(previousDeletionDate)) return;
+
+        const localAccount = await this.runtime.multiAccountController.updateLocalAccountDeletionDate(eventTargetAddress, deletionDate);
+
+        if (!publishEvent) return;
+        this.runtime.eventBus.publish(new LocalAccountDeletionDateChangedEvent(eventTargetAddress, LocalAccountMapper.toLocalAccountDTO(localAccount)));
+    }
+
     public override stop(): Promise<void> | void {
         this.unsubscribeFromAllEvents();
     }

packages/app-runtime/src/modules/runtimeEvents/index.ts

@@ -1,4 +1,3 @@
-export * from "./DatawalletSynchronizedModule";
 export * from "./IdentityDeletionProcessStatusChangedModule";
 export * from "./MessageReceivedModule";
 export * from "./RelationshipChangedModule";

packages/app-runtime/src/multiAccount/MultiAccountController.ts

@@ -251,7 +251,7 @@ export class MultiAccountController {
         await this._localAccounts.update(oldAccount, renamedAccount);
     }
 
-    public async updateLocalAccountDeletionDate(address: string, deletionDate?: CoreDate): Promise<void> {
+    public async updateLocalAccountDeletionDate(address: string, deletionDate?: CoreDate): Promise<LocalAccount> {
         const oldAccount = await this._localAccounts.findOne({ address });
 
         if (!oldAccount) {
@@ -265,6 +265,8 @@ export class MultiAccountController {
 
         const cachedAccount = this.sessionStorage.findSession(address)?.account;
         if (cachedAccount) cachedAccount.deletionDate = deletionDate?.toString();
+
+        return account;
     }
 
     public async updateLastAccessedAt(accountId: string): Promise<void> {

packages/app-runtime/test/lib/TestUtil.ts

@@ -1,7 +1,7 @@
 /* eslint-disable jest/no-standalone-expect */
 import { ILoggerFactory } from "@js-soft/logging-abstractions";
 import { SimpleLoggerFactory } from "@js-soft/simple-logger";
-import { EventBus, Result, sleep, SubscriptionTarget } from "@js-soft/ts-utils";
+import { EventBus, Result, sleep } from "@js-soft/ts-utils";
 import { ArbitraryMessageContent, ArbitraryRelationshipCreationContent, ArbitraryRelationshipTemplateContent } from "@nmshd/content";
 import { CoreDate } from "@nmshd/core-types";
 import {
@@ -81,46 +81,6 @@ export class TestUtil {
         TransportLoggerFactory.init(this.oldLogger);
     }
 
-    public static async awaitEvent<TEvent>(
-        runtime: AppRuntime,
-        subscriptionTarget: SubscriptionTarget<TEvent>,
-        timeout?: number,
-        assertionFunction?: (t: TEvent) => boolean
-    ): Promise<TEvent> {
-        const eventBus = runtime.eventBus;
-        let subscriptionId: number;
-
-        const eventPromise = new Promise<TEvent>((resolve) => {
-            subscriptionId = eventBus.subscribe(subscriptionTarget, (event: TEvent) => {
-                if (assertionFunction && !assertionFunction(event)) return;
-
-                resolve(event);
-            });
-        });
-        if (!timeout) {
-            return await eventPromise.finally(() => eventBus.unsubscribe(subscriptionId));
-        }
-
-        let timeoutId: NodeJS.Timeout;
-        const timeoutPromise = new Promise<TEvent>((_resolve, reject) => {
-            timeoutId = setTimeout(
-                () => reject(new Error(`timeout exceeded for waiting for event ${typeof subscriptionTarget === "string" ? subscriptionTarget : subscriptionTarget.name}`)),
-                timeout
-            );
-        });
-
-        return await Promise.race([eventPromise, timeoutPromise]).finally(() => {
-            eventBus.unsubscribe(subscriptionId);
-            clearTimeout(timeoutId);
-        });
-    }
-
-    public static async expectEvent<T>(runtime: AppRuntime, subscriptionTarget: SubscriptionTarget<T>, timeoutInMS = 1000): Promise<T> {
-        const eventInstance: T = await this.awaitEvent(runtime, subscriptionTarget, timeoutInMS);
-        expect(eventInstance, "Event received").toBeDefined();
-        return eventInstance;
-    }
-
     public static expectThrows(method: Function | Promise<any>, errorMessageRegexp: RegExp | string): void {
         let error: Error | undefined;
         try {
@@ -292,7 +252,7 @@ export class TestUtil {
             expiresAt: CoreDate.utc().add({ minutes: 5 }).toString(),
             filename: "Test.bin",
             mimetype: "application/json",
-            title: "Test",
+            title: "aFileName",
             content: fileContent
         });
         return file.value;