feat(core): linking of ipex flows to contacts

src/core/agent/agent.types.ts

@@ -16,7 +16,6 @@ interface ConnectionHistoryItem {
  type: ConnectionHistoryType;
  credentialType?: string;
  timestamp: string;
- linkedIpexMessages?: IpexMessageDetails[];
 }
 
 enum MiscRecordId {

src/core/agent/records/ipexMessageRecord.ts

@@ -4,15 +4,17 @@ import { IpexMessage } from "../agent.types";
 interface IpexMessageProps {
  id: string;
  content: IpexMessage;
+ isUpdate?: boolean;
  createdAt?: Date;
  connectionId: string;
 }
 
 class IpexMessageRecord extends BaseRecord {
  content!: IpexMessage;
  connectionId!: string;
+ isUpdate?: boolean;
 
- static readonly type = "IpexMessagMetadataRecord";
+ static readonly type = "IpexMessageRecord";
  readonly type = IpexMessageRecord.type;
 
  constructor(props: IpexMessageProps) {
@@ -22,6 +24,7 @@ class IpexMessageRecord extends BaseRecord {
  this.id = props.id;
  this.content = props.content;
  this.connectionId = props.connectionId;
+ this.isUpdate = props.isUpdate ?? false;
  this.createdAt = props.createdAt ?? new Date();
  }
  }
@@ -30,7 +33,6 @@ class IpexMessageRecord extends BaseRecord {
  return {
  ...this._tags,
  connectionId: this.connectionId,
- id: this.id,
  };
  }
 }

src/core/agent/services/connection.types.ts

@@ -8,7 +8,7 @@ interface KeriaContact {
 
 enum ConnectionHistoryType {
  CREDENTIAL_ISSUANCE,
- CREDENTIAL_PRESENT,
+ CREDENTIAL_REQUEST_PRESENT,
  CREDENTIAL_UPDATE,
 }
 

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

@@ -685,6 +685,7 @@ describe("Connection service of agent", () => {
  },
  },
  connectionId,
+ isUpdate: true,
  createdAt: date3,
  },
  ]);
@@ -698,7 +699,7 @@ describe("Connection service of agent", () => {
  credentialType: "IIW 2024 Demo Day Attendee",
  },
  {
- type: ConnectionHistoryType.CREDENTIAL_PRESENT,
+ type: ConnectionHistoryType.CREDENTIAL_REQUEST_PRESENT,
  timestamp: date2.toISOString(),
  credentialType: "IIW 2024 Demo Day Attendee",
  },

src/core/agent/services/connectionService.ts

@@ -11,8 +11,6 @@ import {
  AgentServicesProps,
  OobiScan,
  KeriConnectionType,
- IpexMessageDetails,
- NotificationRoute,
  ExchangeRoute,
 } from "../agent.types";
 import { AgentService } from "./agentService";
@@ -310,45 +308,38 @@ class ConnectionService extends AgentService {
  await this.credentialStorage.getCredentialMetadataByConnectionId(
  connectionId
  );
- const credentialStatistics: {
- [key: string]: { name: string; count: number };
- } = {};
+ const credentialTypes: { [key: string]: string } = {};
  credentialRecords.forEach((record) => {
- if (!credentialStatistics[record.id.replace("metadata:", "")]) {
- credentialStatistics[record.id.replace("metadata:", "")] = {
- name: record.credentialType,
- count: 0,
- };
+ if (!credentialTypes[record.id.replace("metadata:", "")]) {
+ credentialTypes[record.id.replace("metadata:", "")] =
+ record.credentialType;
  }
  });
 
- const linkedIpexMessages = await this.getLinkedIPEXMessageByConnectionId(
- connectionId
- );
+ const linkedIpexMessages =
+ await this.ipexMessageStorage.getIpexMessageMetadataByConnectionId(
+ connectionId
+ );
 
  const requestMessages = linkedIpexMessages
  .sort((a, b) => a.createdAt.getTime() - b.createdAt.getTime())
  .map((messageRecord) => {
- const credentialStatistic =
- credentialStatistics[messageRecord.content.exn.e.acdc.d];
+ const credentialType =
+ credentialTypes[messageRecord.content.exn.e.acdc.d];
  let historyType: ConnectionHistoryType;
  const route = messageRecord.content.exn.r;
- if (
- route === ExchangeRoute.IpexGrant &&
- credentialStatistic.count === 0
- ) {
+ if (route === ExchangeRoute.IpexGrant && !messageRecord.isUpdate) {
  historyType = ConnectionHistoryType.CREDENTIAL_ISSUANCE;
  } else if (route === ExchangeRoute.IpexApply) {
- historyType = ConnectionHistoryType.CREDENTIAL_PRESENT;
+ historyType = ConnectionHistoryType.CREDENTIAL_REQUEST_PRESENT;
  } else {
  historyType = ConnectionHistoryType.CREDENTIAL_UPDATE;
  }
- credentialStatistic.count++;
 
  return {
  type: historyType,
  timestamp: messageRecord.createdAt.toISOString(),
- credentialType: credentialStatistic.name,
+ credentialType,
  };
  });
  return requestMessages.reverse();
@@ -424,16 +415,6 @@ class ConnectionService extends AgentService {
  };
  });
  }
-
- private async getLinkedIPEXMessageByConnectionId(
- connectionId: string
- ): Promise<IpexMessageDetails[]> {
- const messages =
- await this.ipexMessageStorage.getIpexMessageMetadataByConnectionId(
- connectionId
- );
- return messages;
- }
 }
 
 export { ConnectionService };

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

@@ -236,7 +236,6 @@ describe("Ipex communication service of agent", () => {
  connectionId: "i",
  })
  );
- expect(ipexMessageRecordStorage.createIpexMessageRecord).toBeCalledTimes(1);
  expect(operationPendingStorage.save).toBeCalledWith({
  id: "opName",
  recordType: OperationPendingRecordType.ExchangeReceiveCredential,

src/core/agent/services/ipexCommunicationService.ts

@@ -105,7 +105,6 @@ class IpexCommunicationService extends AgentService {
  schema.title,
  connectionId
  );
- await this.createLinkedIpexMessageRecord(exn.exn.i, exn);
 
  this.props.eventService.emit<AcdcStateChangedEvent>({
  type: AcdcEventTypes.AcdcStateChanged,
@@ -345,12 +344,14 @@ class IpexCommunicationService extends AgentService {
 
  async createLinkedIpexMessageRecord(
  connectionId: string,
- message: IpexMessage
+ message: IpexMessage,
+ isUpdate = false
  ): Promise<void> {
  await this.ipexMessageStorage.createIpexMessageRecord({
  id: uuidv4(),
  content: message,
  connectionId,
+ isUpdate,
  });
  }
 }

src/core/agent/services/signifyNotificationService.ts

@@ -168,6 +168,20 @@ class SignifyNotificationService extends AgentService {
  if (notif.r) {
  return;
  }
+ if (notif.a.r === NotificationRoute.ExnIpexApply) {
+ const existingNotficationRecord = await this.notificationStorage.findById(
+ notif.i
+ );
+ if (!existingNotficationRecord) {
+ const exchange = await this.props.signifyClient
+ .exchanges()
+ .get(notif.a.d);
+ await Agent.agent.ipexCommunications.createLinkedIpexMessageRecord(
+ exchange.exn.i,
+ exchange
+ );
+ }
+ }
  if (notif.a.r === NotificationRoute.ExnIpexGrant) {
  const exchange = await this.props.signifyClient
  .exchanges()
@@ -208,6 +222,12 @@ class SignifyNotificationService extends AgentService {
  );
  await this.markNotification(notif.i);
  return;
+ } else {
+ await Agent.agent.ipexCommunications.createLinkedIpexMessageRecord(
+ exchange.exn.i,
+ exchange,
+ true
+ );
  }
  }
  if (notif.a.r === NotificationRoute.MultiSigRpy) {