feat(core): linking of ipex flows to contacts

src/core/agent/services/ipexCommunicationService.test.ts

@@ -184,11 +184,12 @@ const agentServicesProps = {
  eventService,
 };
 
+const resolveOobiMock = jest.fn();
 jest.mock("../../../core/agent/agent", () => ({
  Agent: {
  agent: {
  connections: {
- resolveOobi: jest.fn(),
+ resolveOobi: () => resolveOobiMock(),
  },
  signifyNotifications: {
  deleteNotificationRecordById: (id: string) =>
@@ -631,6 +632,7 @@ describe("Ipex communication service of agent", () => {
  schemaGetMock.mockRejectedValueOnce(
  new Error("request - 404 - SignifyClient message")
  );
+ resolveOobiMock.mockResolvedValueOnce({ done: false });
  await ipexCommunicationService.createLinkedIpexMessageRecord(
  grantIpexMessageMock,
  ConnectionHistoryType.CREDENTIAL_ISSUANCE
@@ -642,6 +644,25 @@ describe("Ipex communication service of agent", () => {
  connectionId: grantIpexMessageMock.exn.i,
  historyType: ConnectionHistoryType.CREDENTIAL_ISSUANCE,
  });
+
+ schemaGetMock.mockRejectedValueOnce(
+ new Error("request - 404 - SignifyClient message")
+ );
+ resolveOobiMock.mockResolvedValueOnce({ done: true });
+ schemaGetMock.mockResolvedValueOnce(schemaMock);
+ await ipexCommunicationService.createLinkedIpexMessageRecord(
+ grantIpexMessageMock,
+ ConnectionHistoryType.CREDENTIAL_ISSUANCE
+ );
+ expect(ipexMessageRecordStorage.createIpexMessageRecord).toBeCalledWith({
+ id: grantIpexMessageMock.exn.d,
+ credentialType: schemaMock.title,
+ content: grantIpexMessageMock,
+ connectionId: grantIpexMessageMock.exn.i,
+ historyType: ConnectionHistoryType.CREDENTIAL_ISSUANCE,
+ });
+ expect(schemaGetMock).toBeCalledTimes(4);
+ expect(resolveOobiMock).toBeCalledTimes(2);
  });
 
  test("Should throw error if schemas.get has an unexpected error", async () => {

src/core/agent/services/ipexCommunicationService.ts

@@ -343,38 +343,33 @@ class IpexCommunicationService extends AgentService {
  });
  }
 
+ private async getSchema(schemaSaid: string) {
+ try {
+ const schema = await this.props.signifyClient.schemas().get(schemaSaid);
+ return schema;
+ } catch (error) {
+ const errorStack = (error as Error).stack as string;
+ const status = errorStack.split("-")[1];
+ if (/404/gi.test(status) && /SignifyClient/gi.test(errorStack)) {
+ const oobi = await Agent.agent.connections.resolveOobi(
+ `${ConfigurationService.env.keri.credentials.testServer.urlInt}/oobi/${schemaSaid}`
+ );
+ if (oobi.done) {
+ await this.getSchema(schemaSaid);
+ }
+ return undefined;
+ } else {
+ throw error;
+ }
+ }
+ }
+
  async createLinkedIpexMessageRecord(
  message: IpexMessage,
  historyType: ConnectionHistoryType
  ): Promise<void> {
  const schemaSaid = message.exn.e.acdc.s;
- const allSchemaSaids = Object.keys(message.exn.e.acdc?.e || {}).map(
- // Chained schemas
- (key) => message.exn.e.acdc.e?.[key]?.s
- );
- allSchemaSaids.push(schemaSaid);
- await Promise.all(
- allSchemaSaids.map(
- async (schemaSaid) =>
- await Agent.agent.connections.resolveOobi(
- `${ConfigurationService.env.keri.credentials.testServer.urlInt}/oobi/${schemaSaid}`,
- true
- )
- )
- );
-
- const schema = await this.props.signifyClient
- .schemas()
- .get(schemaSaid)
- .catch((error) => {
- const errorStack = (error as Error).stack as string;
- const status = errorStack.split("-")[1];
- if (/404/gi.test(status) && /SignifyClient/gi.test(errorStack)) {
- return undefined;
- } else {
- throw error;
- }
- });
+ const schema = await this.getSchema(schemaSaid);
 
  await this.ipexMessageStorage.createIpexMessageRecord({
  id: message.exn.d,

src/core/agent/services/signifyNotificationService.test.ts

@@ -588,8 +588,7 @@ describe("Signify notification service of agent", () => {
  m: "",
  },
  };
- admitMock.mockResolvedValue([{}, ["sigs"], "end"]);
- getCredentialMock.mockResolvedValue(acdcMock);
+ getCredentialMock.mockRejectedValueOnce(new Error());
  identifierStorage.getIdentifierMetadata = jest.fn().mockResolvedValue({
  signifyName: "signifyName",
  });
@@ -621,7 +620,8 @@ describe("Signify notification service of agent", () => {
  m: "",
  },
  };
- getCredentialMock.mockRejectedValueOnce(new Error());
+ admitMock.mockResolvedValue([{}, ["sigs"], "end"]);
+ getCredentialMock.mockResolvedValue(acdcMock);
  identifierStorage.getIdentifierMetadata = jest.fn().mockResolvedValue({
  signifyName: "signifyName",
  });

src/core/agent/services/signifyNotificationService.ts

@@ -232,14 +232,14 @@ class SignifyNotificationService extends AgentService {
  ]);
  await Agent.agent.ipexCommunications.createLinkedIpexMessageRecord(
  exchange,
- ConnectionHistoryType.CREDENTIAL_ISSUANCE
+ ConnectionHistoryType.CREDENTIAL_UPDATE
  );
  await this.markNotification(notif.i);
  return;
  } else {
  await Agent.agent.ipexCommunications.createLinkedIpexMessageRecord(
  exchange,
- ConnectionHistoryType.CREDENTIAL_UPDATE
+ ConnectionHistoryType.CREDENTIAL_ISSUANCE
  );
  }
  }