feat(ssi): crud proof events

Signed-off-by: Berend Sliedrecht <berend@animo.id>

apps/shared/src/events/proofEvents.ts

+import type { BaseEventInput } from './baseEvents.js';
+import type {
+  AnonCredsPredicateType,
+  AnonCredsProofRequestRestriction,
+} from '@aries-framework/anoncreds';
+
+import { JsonTransformer, ProofExchangeRecord } from '@aries-framework/core';
+
+import { BaseEvent } from './baseEvents.js';
+
+export type EventAnonCredsProofsGetAllInput = BaseEventInput;
+export class EventAnonCredsProofsGetAll extends BaseEvent<
+  Array<ProofExchangeRecord>
+> {
+  public static token = 'anoncreds.proofs.getAll';
+
+  public get instance() {
+    return this.data.map((d) =>
+      JsonTransformer.fromJSON(d, ProofExchangeRecord),
+    );
+  }
+
+  public static fromEvent(e: EventAnonCredsProofsGetAll) {
+    return new EventAnonCredsProofsGetAll(
+      e.data,
+      e.tenantId,
+      e.id,
+      e.type,
+      e.timestamp,
+    );
+  }
+}
+
+export type EventAnonCredsProofsGetByIdInput = BaseEventInput<{
+  proofRecordId: string;
+}>;
+export class EventAnonCredsProofsGetById extends BaseEvent<ProofExchangeRecord | null> {
+  public static token = 'anoncreds.proofs.getById';
+
+  public get instance() {
+    return JsonTransformer.fromJSON(this.data, ProofExchangeRecord);
+  }
+
+  public static fromEvent(e: EventAnonCredsProofsGetById) {
+    return new EventAnonCredsProofsGetById(
+      e.data,
+      e.tenantId,
+      e.id,
+      e.type,
+      e.timestamp,
+    );
+  }
+}
+
+export type EventDidcommAnonCredsProofsRequestInput = BaseEventInput<{
+  connectionId: string;
+  name: string;
+  requestedAttributes: {
+    [groupName: string]: {
+      names: Array<string>;
+      restrictions?: Array<AnonCredsProofRequestRestriction>;
+    };
+  };
+  requestedPredicates: {
+    [groupName: string]: {
+      name: string;
+      predicateType: AnonCredsPredicateType;
+      predicateValue: number;
+      restrictions?: Array<AnonCredsProofRequestRestriction>;
+    };
+  };
+}>;
+export class EventDidcommAnonCredsProofsRequest extends BaseEvent<ProofExchangeRecord> {
+  public static token = 'didcomm.anoncreds.proofs.request';
+
+  public get instance() {
+    return JsonTransformer.fromJSON(this.data, ProofExchangeRecord);
+  }
+
+  public static fromEvent(e: EventDidcommAnonCredsProofsRequest) {
+    return new EventDidcommAnonCredsProofsRequest(
+      e.data,
+      e.tenantId,
+      e.id,
+      e.type,
+      e.timestamp,
+    );
+  }
+}
+
+export type EventAnonCredsProofsDeleteByIdInput = BaseEventInput<{
+  proofRecordId: string;
+}>;
+export class EventAnonCredsProofsDeleteById extends BaseEvent {
+  public static token = 'anoncreds.proofs.deleteById';
+
+  public static fromEvent(e: EventDidcommAnonCredsProofsRequest) {
+    return new EventDidcommAnonCredsProofsRequest(
+      e.data,
+      e.tenantId,
+      e.id,
+      e.type,
+      e.timestamp,
+    );
+  }
+}

apps/shared/src/index.ts

@@ -12,6 +12,7 @@ export * from './events/credentialDefinitionEvents.js';
 export * from './events/credentialEvents.js';
 export * from './events/credentialOfferEvents.js';
 export * from './events/credentialRequestEvents.js';
+export * from './events/proofEvents.js';
 
 export * from './dto/pagination-params.dto.js';
 export * from './dto/multitenancy-params.dto.js';

apps/ssi-abstraction/src/agent/agent.service.ts

@@ -6,7 +6,9 @@ import type { OnApplicationShutdown } from '@nestjs/common';
 import {
   AnonCredsCredentialFormatService,
   AnonCredsModule,
+  AnonCredsProofFormatService,
   LegacyIndyCredentialFormatService,
+  LegacyIndyProofFormatService,
 } from '@aries-framework/anoncreds';
 import { AnonCredsRsModule } from '@aries-framework/anoncreds-rs';
 import { AskarModule } from '@aries-framework/askar';
@@ -23,7 +25,9 @@ import {
   LogLevel,
   PeerDidRegistrar,
   PeerDidResolver,
+  ProofsModule,
   V2CredentialProtocol,
+  V2ProofProtocol,
   WebDidResolver,
 } from '@aries-framework/core';
 import {
@@ -90,13 +94,14 @@ export class AgentService implements OnApplicationShutdown {
   }
 
   public get modules() {
-    const { autoAcceptConnection, autoAcceptCredential } =
+    const { autoAcceptConnection, autoAcceptCredential, autoAcceptProof } =
       this.configService.get('agent');
 
     return {
       connections: new ConnectionsModule({
         autoAcceptConnections: autoAcceptConnection,
       }),
+
       credentials: new CredentialsModule({
         autoAcceptCredentials: autoAcceptCredential,
         credentialProtocols: [
@@ -109,6 +114,18 @@ export class AgentService implements OnApplicationShutdown {
         ],
       }),
 
+      proofs: new ProofsModule({
+        autoAcceptProofs: autoAcceptProof,
+        proofProtocols: [
+          new V2ProofProtocol({
+            proofFormats: [
+              new AnonCredsProofFormatService(),
+              new LegacyIndyProofFormatService(),
+            ],
+          }),
+        ],
+      }),
+
       anoncredsRs: new AnonCredsRsModule({ anoncreds }),
       anoncreds: new AnonCredsModule({
         registries: [new IndyVdrAnonCredsRegistry()],

apps/ssi-abstraction/src/agent/anoncredsProofs/anoncredsProofs.controller.ts

+import { Controller } from '@nestjs/common';
+import { MessagePattern } from '@nestjs/microservices';
+import {
+  EventAnonCredsProofsDeleteById,
+  EventAnonCredsProofsDeleteByIdInput,
+  EventAnonCredsProofsGetAll,
+  EventAnonCredsProofsGetAllInput,
+  EventAnonCredsProofsGetById,
+  EventAnonCredsProofsGetByIdInput,
+  EventDidcommAnonCredsProofsRequest,
+  EventDidcommAnonCredsProofsRequestInput,
+} from '@ocm/shared';
+
+import { AnonCredsProofsService } from './anoncredsProofs.service.js';
+
+@Controller('anoncredsProofs')
+export class AnonCredsProofsController {
+  public constructor(private proofsService: AnonCredsProofsService) {}
+
+  @MessagePattern(EventAnonCredsProofsGetAll.token)
+  public async getAll(
+    options: EventAnonCredsProofsGetAllInput,
+  ): Promise<EventAnonCredsProofsGetAll> {
+    return new EventAnonCredsProofsGetAll(
+      await this.proofsService.getAll(options),
+      options.tenantId,
+    );
+  }
+
+  @MessagePattern(EventAnonCredsProofsGetById.token)
+  public async getById(
+    options: EventAnonCredsProofsGetByIdInput,
+  ): Promise<EventAnonCredsProofsGetById> {
+    return new EventAnonCredsProofsGetById(
+      await this.proofsService.getById(options),
+      options.tenantId,
+    );
+  }
+
+  @MessagePattern(EventAnonCredsProofsDeleteById.token)
+  public async deleteById(
+    options: EventAnonCredsProofsDeleteByIdInput,
+  ): Promise<EventAnonCredsProofsDeleteById> {
+    return new EventAnonCredsProofsDeleteById(
+      await this.proofsService.deleteById(options),
+      options.tenantId,
+    );
+  }
+
+  @MessagePattern(EventDidcommAnonCredsProofsRequest.token)
+  public async request(
+    options: EventDidcommAnonCredsProofsRequestInput,
+  ): Promise<EventDidcommAnonCredsProofsRequest> {
+    return new EventDidcommAnonCredsProofsRequest(
+      await this.proofsService.request(options),
+      options.tenantId,
+    );
+  }
+}

apps/ssi-abstraction/src/agent/anoncredsProofs/anoncredsProofs.module.ts

+import { Module } from '@nestjs/common';
+
+import { AgentModule } from '../agent.module.js';
+
+import { AnonCredsProofsController } from './anoncredsProofs.controller.js';
+import { AnonCredsProofsService } from './anoncredsProofs.service.js';
+
+@Module({
+  imports: [AgentModule],
+  providers: [AnonCredsProofsService],
+  controllers: [AnonCredsProofsController],
+})
+export class AnonCredsProofsModule {}

apps/ssi-abstraction/src/agent/anoncredsProofs/anoncredsProofs.service.ts

+import type {
+  EventAnonCredsProofsDeleteById,
+  EventAnonCredsProofsDeleteByIdInput,
+  EventAnonCredsProofsGetAll,
+  EventAnonCredsProofsGetAllInput,
+  EventAnonCredsProofsGetById,
+  EventAnonCredsProofsGetByIdInput,
+  EventDidcommAnonCredsProofsRequest,
+  EventDidcommAnonCredsProofsRequestInput,
+} from '@ocm/shared';
+
+import { Injectable } from '@nestjs/common';
+
+import { WithTenantService } from '../withTenantService.js';
+
+@Injectable()
+export class AnonCredsProofsService {
+  public constructor(private withTenantService: WithTenantService) {}
+
+  public async getAll({
+    tenantId,
+  }: EventAnonCredsProofsGetAllInput): Promise<
+    EventAnonCredsProofsGetAll['data']
+  > {
+    return this.withTenantService.invoke(tenantId, (t) => t.proofs.getAll());
+  }
+
+  public async getById({
+    tenantId,
+    proofRecordId,
+  }: EventAnonCredsProofsGetByIdInput): Promise<
+    EventAnonCredsProofsGetById['data']
+  > {
+    return this.withTenantService.invoke(tenantId, (t) =>
+      t.proofs.getById(proofRecordId),
+    );
+  }
+
+  public async deleteById({
+    tenantId,
+    proofRecordId,
+  }: EventAnonCredsProofsDeleteByIdInput): Promise<
+    EventAnonCredsProofsDeleteById['data']
+  > {
+    return this.withTenantService.invoke(tenantId, async (t) => {
+      await t.proofs.deleteById(proofRecordId);
+      return {};
+    });
+  }
+
+  public async request({
+    tenantId,
+    connectionId,
+    name,
+    requestedAttributes,
+    requestedPredicates,
+  }: EventDidcommAnonCredsProofsRequestInput): Promise<
+    EventDidcommAnonCredsProofsRequest['data']
+  > {
+    const transformedPredicates = Object.entries(requestedPredicates).reduce(
+      (prev, [key, value]) => ({
+        ...prev,
+        [key]: {
+          name: value.name,
+          restrictions: value.restrictions,
+          p_type: value.predicateType,
+          p_value: value.predicateValue,
+        },
+      }),
+      {},
+    );
+
+    return this.withTenantService.invoke(tenantId, (t) =>
+      t.proofs.requestProof({
+        connectionId,
+        protocolVersion: 'v2',
+        proofFormats: {
+          anoncreds: {
+            name,
+            version: '1.0',
+            requested_attributes: requestedAttributes,
+            requested_predicates: transformedPredicates,
+          },
+        },
+      }),
+    );
+  }
+}