feat: Add support to select multiple connections while sending proof request

.env.demo

@@ -135,4 +135,7 @@ ELK_LOG=true // ELK flag
 LOG_LEVEL=debug // ELK log level
 ELK_LOG_PATH = "http://localhost:9200/" // ELK log path
 ELK_USERNAME=elastic // ELK user username
-ELK_PASSWORD=xxxxxx // ELK user password
+ELK_PASSWORD=xxxxxx // ELK user password
+ORGANIZATION=credebl
+CONTEXT=platform
+APP=api

.env.sample

@@ -162,3 +162,6 @@ LOG_LEVEL=debug // ELK log level
 ELK_LOG_PATH = "http://localhost:9200/" // ELK log path
 ELK_USERNAME=elastic // ELK user username
 ELK_PASSWORD=xxxxxx // ELK user password
+ORGANIZATION=credebl
+CONTEXT=platform
+APP=api

apps/api-gateway/src/verification/dto/request-proof.dto.ts

@@ -1,4 +1,4 @@
-import { ArrayNotEmpty, IsArray, IsBoolean, IsEmail, IsEnum, IsNotEmpty, IsNumberString, IsObject, IsOptional, IsString, ValidateIf, ValidateNested, IsUUID, ArrayUnique, ArrayMaxSize } from 'class-validator';
+import { ArrayNotEmpty, IsArray, IsBoolean, IsEmail, IsEnum, IsNotEmpty, IsNumberString, IsObject, IsOptional, IsString, ValidateIf, ValidateNested, IsUUID, ArrayUnique, ArrayMaxSize, ArrayMinSize, Matches } from 'class-validator';
 import { trim } from '@credebl/common/cast.helper';
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 import { Transform, Type } from 'class-transformer';
@@ -7,7 +7,6 @@ import { IProofFormats } from '../interfaces/verification.interface';
 import { ProofRequestType } from '../enum/verification.enum';
 
 export class ProofRequestAttribute {
-
     @ValidateIf((obj) => obj.attributeNames === undefined)
     @IsNotEmpty()
     @IsString()
@@ -23,15 +22,18 @@ export class ProofRequestAttribute {
     @ApiPropertyOptional()
     @IsString()
     @IsOptional()
+    @IsNotEmpty({ message: 'schemaId is required.' })
     schemaId?: string;
 
     @ApiPropertyOptional()
+    @ValidateIf((obj) => obj.value !== undefined)
     @IsString()
     @IsOptional()
     @IsNotEmpty({ message: 'condition is required.' })
     condition?: string;
 
     @ApiPropertyOptional()
+    @ValidateIf((obj) => obj.condition !== undefined)
     @IsOptional()
     @IsNotEmpty({ message: 'value is required.' })
     @IsNumberString({}, { message: 'Value must be a number' })
@@ -40,6 +42,11 @@ export class ProofRequestAttribute {
     @ApiPropertyOptional()
     @IsString()
     @IsOptional()
+    @IsNotEmpty({ message: 'credDefId is required.' })
+    @Matches(
+      /^[a-zA-Z0-9]{21,22}:[a-zA-Z0-9]+:[a-zA-Z0-9]+:[0-9]+:[a-zA-Z0-9\s]+$/,
+      { message: 'credDefId is it not a valid unqualified credDef' }
+  )
     credDefId?: string;
 }
 
@@ -54,7 +61,7 @@ class ProofPayload {
     @IsString({ message: 'parentThreadId must be in string' })
     @IsNotEmpty({ message: 'please provide valid parentThreadId' })
     @IsOptional()
-    parentThreadId: string;
+    parentThreadId?: string;
 
     @ApiPropertyOptional()
     @IsBoolean({ message: 'willConfirm must be in boolean' })
@@ -138,12 +145,12 @@ export class ProofRequestPresentationDefinition {
   @IsOptional()
   name: string;
 
-  @ApiProperty({type: () =>  [InputDescriptors]})
-  @IsNotEmpty({ message: 'inputDescriptors is required.' })
+  @ApiProperty({type: () => [InputDescriptors]})
   @IsArray({ message: 'inputDescriptors must be an array' })
-  @IsObject({ each: true })
+  @IsNotEmpty({ message: 'inputDescriptors is required.' })
+  @ArrayMinSize(1)
+  @ValidateNested({each:true})
   @Type(() => InputDescriptors)
-  @ValidateNested()
   // eslint-disable-next-line camelcase
   input_descriptors:InputDescriptors[];
 }
@@ -162,7 +169,7 @@ export class ProofRequestAttributeDto {
     type: () => [ProofRequestAttribute]
 })
 @IsArray({ message: 'attributes must be in array' })
-@ValidateNested()
+@ValidateNested({ each: true })
 @IsObject({ each: true })
 @IsNotEmpty({ message: 'please provide valid attributes' })
 @Type(() => ProofRequestAttribute)
@@ -192,12 +199,16 @@ export class IndyDto {
 }
 
 export class RequestProofDto extends ProofPayload {
-    @ApiProperty()
-    @IsString()
-    @Transform(({ value }) => trim(value))
-    @IsUUID()
-    @IsNotEmpty({ message: 'connectionId is required.' })
-    connectionId: string;
+  @ApiProperty({
+    example: ['32f54163-7166-48f1-93d8-ff217bdb0653']
+  })  
+
+    @IsNotEmpty({ each: true, message: 'connectionId array elements must not be empty.' })
+    @IsArray({ message: 'connectionId must be an array.' })
+    @ArrayMinSize(1, { message: 'connectionId must contain at least 1 element.' })
+    @ArrayMaxSize(10, { message: 'connectionId can contain at most 10 elements.' })
+    @IsUUID('all', { each: true, message: 'Each connectionId must be a valid UUID.' })
+    connectionId:string[];
 
     @ApiProperty({
       'example': 
@@ -227,7 +238,8 @@ export class RequestProofDto extends ProofPayload {
         'example': 
             {
                 id: '32f54163-7166-48f1-93d8-ff217bdb0653',
-                inputDescriptors: [
+                // eslint-disable-next-line camelcase
+                input_descriptors: [
                     {
                       'id': 'healthcare_input_1',
                       'name': 'Medical History',
@@ -265,7 +277,7 @@ export class RequestProofDto extends ProofPayload {
 
     orgId: string;
 
-    @ApiPropertyOptional()
+    @ApiPropertyOptional({enum:AutoAccept})
     @IsString({ message: 'auto accept proof must be in string' })
     @IsNotEmpty({ message: 'please provide valid auto accept proof' })
     @IsOptional()

apps/api-gateway/src/verification/verification.service.ts

@@ -8,7 +8,6 @@ import { IProofPresentationDetails, IProofPresentationList, IVerificationRecords
 import { IPresentation, IProofRequest, IProofRequestSearchCriteria } from './interfaces/verification.interface';
 import { IProofPresentation } from './interfaces/verification.interface';
 // To do make a similar interface in API-gateway
-import { IRequestProof } from 'apps/verification/src/interfaces/verification.interface';
 import { user } from '@prisma/client';
 import { NATSClient } from '@credebl/common/NATSClient';
 
@@ -49,25 +48,7 @@ export class VerificationService extends BaseService {
      * @returns Requested proof presentation details
      */
     sendProofRequest(requestProofDto: RequestProofDto, user: IUserRequest): Promise<IProofRequest> {
-        const requestProof: IRequestProof = {
-          orgId: requestProofDto.orgId,
-          type: requestProofDto.type,
-          comment: requestProofDto.comment,
-          autoAcceptProof: requestProofDto.autoAcceptProof,
-          connectionId: requestProofDto.connectionId,
-          goalCode: requestProofDto.goalCode,
-          parentThreadId: requestProofDto.parentThreadId,
-          protocolVersion: requestProofDto.protocolVersion,
-          willConfirm: requestProofDto.willConfirm
-        };
-        if (requestProofDto.proofFormats) {
-          requestProof.attributes = requestProofDto.proofFormats.indy.attributes;
-        }
-        if (requestProofDto.presentationDefinition) {
-          requestProof.presentationDefinition = requestProofDto.presentationDefinition;
-        }
-
-        const payload = { requestProof, user };
+      const payload = { requestProofDto, user };
         return this.natsClient.sendNatsMessage(this.verificationServiceProxy, 'send-proof-request', payload);
     }
 

apps/verification/src/interfaces/verification.interface.ts

@@ -31,6 +31,37 @@ export interface IRequestProof {
     willConfirm?: boolean;
 }
 
+export interface IProofRequestData {
+    goalCode?: string;
+    parentThreadId?: string;
+    willConfirm?: boolean;
+    protocolVersion?: string;
+    proofFormats?:IProofFormat;
+    orgId: string;
+    connectionId?: string | string[];
+    attributes?: IProofRequestAttribute[];
+    type: ProofRequestType;
+    presentationDefinition?:IProofRequestPresentationDefinition;
+    comment: string;
+    autoAcceptProof: AutoAccept;
+}
+export interface IProofFormat {
+    indy: Indy;
+}
+
+export interface Indy {
+    attributes: IProofAttributesData[];
+}
+
+export interface IProofAttributesData {
+    attributeName: string;
+    attributeNames?: string[];
+    condition: string;
+    value: string;
+    credDefId: string;
+    schemaId: string;
+}
+
 export interface IGetAllProofPresentations {
     url: string;
     apiKey: string;

apps/verification/src/verification.controller.ts

@@ -1,7 +1,7 @@
 import { Controller } from '@nestjs/common';
 import { VerificationService } from './verification.service';
 import { MessagePattern } from '@nestjs/microservices';
-import { IProofPresentation, IProofPresentationData, IProofRequests, IRequestProof, ISendProofRequestPayload } from './interfaces/verification.interface';
+import { IProofPresentation, IProofPresentationData, IProofRequestData, IProofRequests, ISendProofRequestPayload } from './interfaces/verification.interface';
 import { IUserRequest } from '@credebl/user-request/user-request.interface';
 import { presentations, user } from '@prisma/client';
 import { IProofPresentationDetails, IProofPresentationList, IVerificationRecords } from '@credebl/common/interfaces/verification.interface';
@@ -44,8 +44,8 @@ export class VerificationController {
    * @returns Requested proof presentation details
    */
   @MessagePattern({ cmd: 'send-proof-request' })
-  async sendProofRequest(payload: { requestProof: IRequestProof, user: IUserRequest }): Promise<string> {
-    return this.verificationService.sendProofRequest(payload.requestProof);
+  async sendProofRequest(payload: { requestProofDto: IProofRequestData, user: IUserRequest }): Promise<string[]> {
+    return this.verificationService.sendProofRequest(payload.requestProofDto);
   }
 
     /**