handle message ack

Author: maycon-mello

integration-tests/delegation-offer.test.ts

@@ -262,9 +262,8 @@ describe('Credential Distribution', () => {
       ].sort(),
     );
 
-    // Chain starts with the holder's own delegated credential.
-    expect(delegationDetails.delegationChain[0].id).toBe(storedCredential.id);
-    expect(delegationDetails.delegationChain[0].rootCredentialId).toBe(rootCredential.id);
+    expect(delegationDetails.delegationChain[1].id).toBe(storedCredential.id);
+    expect(delegationDetails.delegationChain[1].rootCredentialId).toBe(rootCredential.id);
 
     // Verify the holder's stored offer was advanced to 'accepted'.
     const holderStoredOffer = await holderWallet.wallet.getDocumentById(
@@ -279,5 +278,16 @@ describe('Credential Distribution', () => {
     expect(ackMessage.from).toBe(holderWallet.did);
     expect(ackMessage.body.delegationOfferId).toBe(acceptedOffer.id);
     expect(ackMessage.body.status).toBe('OK');
+
+    await handleMessage(ackMessage, {
+      wallet: issuerWallet.wallet,
+      messageProvider: issuerWallet.messageProvider,
+    });
+
+    const delegationOfferDoc = await issuerWallet.wallet.getDocumentById(
+      acceptedOffer.id,
+    );
+
+    expect(delegationOfferDoc.status).toBe('accepted');
   }, 60_000);
 });

packages/core/src/delegation/delegation-offer.ts

@@ -462,10 +462,37 @@ export const ISSUE_CREDENTIAL_HANDLER = {
   },
 };
 
+export const DELEGATION_ACK_HANDLER = {
+  check: function (message) {
+    return message.type === ACK && message.body?.goal_code === GOAL_CODE;
+  },
+  handle: async function (message, {wallet}) {
+    const offerId = message.body.delegationOfferId;
+
+    const storedOffer = await wallet.getDocumentById(offerId);
+    if (!storedOffer) {
+      logger.debug(
+        `DELEGATION_ACK_HANDLER: no stored offer found for ${offerId}`,
+      );
+      return;
+    }
+
+    storedOffer.status = 'accepted';
+    storedOffer.updatedAt = new Date().toISOString();
+
+    await wallet.updateDocument(storedOffer);
+
+    logger.debug(
+      `DELEGATION_ACK_HANDLER: delegation offer ${offerId} marked as accepted`,
+    );
+  },
+};
+
 export const messageHandlers = [
   INVITATION_HANDLER,
   DELEGATION_REQUEST_HANDLER,
   ISSUE_CREDENTIAL_HANDLER,
+  DELEGATION_ACK_HANDLER,
 ];
 
 export async function handleMessage(