feat(core): long running operation recovery

src/core/agent/records/notificationRecord.ts

@@ -1,6 +1,6 @@
 import { BaseRecord, Tags } from "../../storage/storage.types";
 import { NotificationRoute } from "../agent.types";
-import { LinkedGroupRequest } from "./notificationRecord.types";
+import { LinkedRequest } from "./notificationRecord.types";
 import { randomSalt } from "../services/utils";
 
 interface NotificationRecordStorageProps {
@@ -13,7 +13,7 @@ interface NotificationRecordStorageProps {
   multisigId?: string;
   connectionId: string;
   credentialId?: string;
-  linkedGroupRequest?: LinkedGroupRequest;
+  linkedRequest?: LinkedRequest;
   groupReplied?: boolean,
   initiatorAid?: string,
   groupInitiator?: boolean,
@@ -25,7 +25,7 @@ class NotificationRecord extends BaseRecord {
   read!: boolean;
   multisigId?: string;
   connectionId!: string;
-  linkedGroupRequest!: LinkedGroupRequest;
+  linkedRequest!: LinkedRequest;
   credentialId?: string;
   groupReplied?: boolean;
   initiatorAid?: string;
@@ -45,7 +45,7 @@ class NotificationRecord extends BaseRecord {
       this.multisigId = props.multisigId;
       this.connectionId = props.connectionId;
       this._tags = props.tags ?? {};
-      this.linkedGroupRequest = props.linkedGroupRequest ?? { accepted: false };
+      this.linkedRequest = props.linkedRequest ?? { accepted: false };
       this.credentialId = props.credentialId;
       this.groupReplied = props.groupReplied;
       this.initiatorAid = props.initiatorAid;

src/core/agent/records/notificationRecord.types.ts

@@ -1,6 +1,6 @@
 import { Notification } from "../services/credentialService.types";
 
-interface LinkedGroupRequest {
+interface LinkedRequest {
   accepted: boolean;
   current?: string;
   previous?: string;
@@ -12,4 +12,4 @@ interface NotificationAttempts {
   notification: Notification;
 }
 
-export type { LinkedGroupRequest, NotificationAttempts };
+export type { LinkedRequest, NotificationAttempts };

src/core/agent/records/operationPendingRecord.type.ts

@@ -1,6 +1,7 @@
 export enum OperationPendingRecordType {
   Witness = "witness",
   Group = "group",
+  Done = "done",
   Oobi = "oobi",
   ExchangeReceiveCredential = "exchange.receivecredential",
   ExchangeOfferCredential = "exchange.offercredential",

src/core/agent/services/identifierService.ts

@@ -498,24 +498,30 @@ class IdentifierService extends AgentService {
         continue;
       }
 
+      let recordType = OperationPendingRecordType.Witness;
+
       const op: Operation = await this.props.signifyClient
         .operations()
         .get(`witness.${identifier.prefix}`)
         .catch(async (error) => {
           const status = error.message.split(" - ")[1];
+
           if (/404/gi.test(status)) {
+            recordType = OperationPendingRecordType.Done
             return await this.props.signifyClient
               .operations()
               .get(`done.${identifier.prefix}`);
           }
+
           throw error;
         });
+
       const isPending = !op.done;
 
       if (isPending) {
         const pendingOperation = await this.operationPendingStorage.save({
           id: op.name,
-          recordType: OperationPendingRecordType.Witness,
+          recordType,
         });
         this.props.eventEmitter.emit<OperationAddedEvent>({
           type: EventTypes.OperationAdded,