feat: Issuance and Verification Out-of-Band Functionality

apps/agent-service/src/agent-service.controller.ts

@@ -1,7 +1,7 @@
 import { Controller } from '@nestjs/common';
 import { MessagePattern } from '@nestjs/microservices';
 import { AgentServiceService } from './agent-service.service';
-import { GetCredDefAgentRedirection, GetSchemaAgentRedirection, IAgentSpinupDto, IIssuanceCreateOffer, ITenantCredDef, ITenantDto, ITenantSchema } from './interface/agent-service.interface';
+import { GetCredDefAgentRedirection, GetSchemaAgentRedirection, IAgentSpinupDto, IIssuanceCreateOffer, ITenantCredDef, ITenantDto, ITenantSchema, OutOfBandCredentialOffer } from './interface/agent-service.interface';
 import { IConnectionDetails, IUserRequestInterface } from './interface/agent-service.interface';
 import { ISendProofRequestPayload } from './interface/agent-service.interface';
 import { user } from '@prisma/client';
@@ -124,4 +124,9 @@ export class AgentServiceController {
   async submitTransaction(payload: { url: string, apiKey: string, submitEndorsementPayload:object }): Promise<object> {
     return this.agentServiceService.sumbitTransaction(payload.url, payload.apiKey, payload.submitEndorsementPayload);
   }
+
+  @MessagePattern({ cmd: 'agent-out-of-band-credential-offer' })
+  async outOfBandCredentialOffer(payload: { outOfBandIssuancePayload: OutOfBandCredentialOffer, url: string, apiKey: string }): Promise<object> {
+    return this.agentServiceService.outOfBandCredentialOffer(payload.outOfBandIssuancePayload, payload.url, payload.apiKey);
+  }
 }

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

@@ -16,7 +16,7 @@ import * as dotenv from 'dotenv';
 import * as fs from 'fs';
 import { catchError, map } from 'rxjs/operators';
 dotenv.config();
-import { GetCredDefAgentRedirection, IAgentSpinupDto, IStoreOrgAgentDetails, ITenantCredDef, ITenantDto, ITenantSchema, IWalletProvision, ISendProofRequestPayload, IIssuanceCreateOffer } from './interface/agent-service.interface';
+import { GetCredDefAgentRedirection, IAgentSpinupDto, IStoreOrgAgentDetails, ITenantCredDef, ITenantDto, ITenantSchema, IWalletProvision, ISendProofRequestPayload, IIssuanceCreateOffer, OutOfBandCredentialOffer } from './interface/agent-service.interface';
 import { AgentType, OrgAgentType } from '@credebl/enum/enum';
 import { IConnectionDetails, IUserRequestInterface } from './interface/agent-service.interface';
 import { AgentServiceRepository } from './repositories/agent-service.repository';
@@ -133,7 +133,7 @@ export class AgentServiceService {
 
       agentSpinupDto.agentType = agentSpinupDto.agentType ? agentSpinupDto.agentType : 1;
       agentSpinupDto.tenant = agentSpinupDto.tenant ? agentSpinupDto.tenant : false;
-      agentSpinupDto.ledgerId = !agentSpinupDto.ledgerId || 0 === agentSpinupDto.ledgerId.length ? [1] : agentSpinupDto.ledgerId;
+      agentSpinupDto.ledgerId = !agentSpinupDto.ledgerId || 0 === agentSpinupDto.ledgerId.length ? [3] : agentSpinupDto.ledgerId;
 
 
       const platformConfig: platform_config = await this.agentServiceRepository.getPlatformConfigDetails();
@@ -338,10 +338,11 @@ export class AgentServiceService {
 
 
       const agentDidWriteUrl = `${payload.agentEndPoint}${CommonConstants.URL_AGENT_WRITE_DID}`;
-      const { seed } = payload;
+      const { seed, ledgerId } = payload;
       const { apiKey } = payload;
       const writeDid = 'write-did';
-      const agentDid = await this._retryAgentSpinup(agentDidWriteUrl, apiKey, writeDid, seed);
+      const ledgerDetails: ledgers[] = await this.agentServiceRepository.getGenesisUrl(ledgerId);
+      const agentDid = await this._retryAgentSpinup(agentDidWriteUrl, apiKey, writeDid, seed, ledgerDetails[0].indyNamespace);
       if (agentDid) {
 
         const getDidMethodUrl = `${payload.agentEndPoint}${CommonConstants.URL_AGENT_GET_DIDS}`;
@@ -388,14 +389,14 @@ export class AgentServiceService {
     }
   }
 
-  async _retryAgentSpinup(agentUrl: string, apiKey: string, agentApiState: string, seed?: string): Promise<object> {
+  async _retryAgentSpinup(agentUrl: string, apiKey: string, agentApiState: string, seed?: string, indyNamespace?: string): Promise<object> {
     return retry(
       async () => {
 
         if ('write-did' === agentApiState) {
 
           const agentDid = await this.commonService
-            .httpPost(agentUrl, { seed }, { headers: { 'x-api-key': apiKey } })
+            .httpPost(agentUrl, { seed, method: indyNamespace }, { headers: { 'x-api-key': apiKey } })
             .then(async response => response);
           return agentDid;
         } else if ('get-did-doc' === agentApiState) {
@@ -486,7 +487,7 @@ export class AgentServiceService {
   async _createTenant(payload: ITenantDto, user: IUserRequestInterface): Promise<void> {
     try {
 
-      payload.ledgerId = !payload.ledgerId || 0 === payload.ledgerId.length ? [1] : payload.ledgerId;
+      payload.ledgerId = !payload.ledgerId || 0 === payload.ledgerId.length ? [3] : payload.ledgerId;
 
       const ledgerDetails: ledgers[] = await this.agentServiceRepository.getGenesisUrl(payload.ledgerId);
       const sharedAgentSpinUpResponse = new Promise(async (resolve, _reject) => {
@@ -943,5 +944,16 @@ export class AgentServiceService {
     }
   }
 
+  async outOfBandCredentialOffer(outOfBandIssuancePayload: OutOfBandCredentialOffer, url: string, apiKey: string): Promise<object> {
+    try {
+      const sendOutOfbandCredentialOffer = await this.commonService
+        .httpPost(url, outOfBandIssuancePayload, { headers: { 'x-api-key': apiKey } })
+        .then(async response => response);
+      return sendOutOfbandCredentialOffer;
+    } catch (error) {
+      this.logger.error(`Error in out-of-band credential in agent service : ${JSON.stringify(error)}`);
+      throw new RpcException(error);
+    }
+  }
 }
 

apps/agent-service/src/interface/agent-service.interface.ts

@@ -14,6 +14,15 @@ export interface IAgentSpinupDto {
     tenant?: boolean;
 }
 
+export interface OutOfBandCredentialOffer {
+    emailId: string;
+    attributes: IAttributes[];
+    credentialDefinitionId: string;
+    comment: string;
+    protocolVersion?: string;
+    orgId: number;
+}
+
 export interface ITenantDto {
     label: string;
     seed: string;

apps/agent-service/src/main.ts

@@ -28,7 +28,7 @@ async function bootstrap(): Promise<void> {
     seed: process.env.PLATFORM_SEED,
     orgId: parseInt(process.env.PLATFORM_ID),
     tenant: true,
-    ledgerId: [1, 2]
+    ledgerId: [1, 2, 3, 4]
   };
 
   const agentService = app.get(AgentServiceService);

apps/api-gateway/src/issuance/dtos/issuance.dto.ts

@@ -1,7 +1,12 @@
-import { IsArray, IsNotEmpty, IsOptional, IsString } from 'class-validator';
+import { IsArray, IsNotEmpty, IsOptional, IsString, IsEmail } from 'class-validator';
 import { ApiProperty } from '@nestjs/swagger';
 
-interface attribute {
+interface CredentialOffer {
+    emailId: string;
+    attributes: Attribute[];
+}
+
+interface Attribute {
     name: string;
     value: string;
 }
@@ -11,7 +16,7 @@ export class IssueCredentialDto {
     @ApiProperty({ example: [{ 'value': 'string', 'name': 'string' }] })
     @IsNotEmpty({ message: 'Please provide valid attributes' })
     @IsArray({ message: 'attributes should be array' })
-    attributes: attribute[];
+    attributes: Attribute[];
 
     @ApiProperty({ example: 'string' })
     @IsNotEmpty({ message: 'Please provide valid credentialDefinitionId' })
@@ -98,3 +103,43 @@ export class CredentialAttributes {
     value: string;
 }
 
+export class OutOfBandCredentialDto {
+
+    @ApiProperty({ example: [{ 'emailId': 'abc@example.com', 'attribute': [{ 'value': 'string', 'name': 'string' }] }] })
+    @IsNotEmpty({ message: 'Please provide valid attributes' })
+    @IsArray({ message: 'attributes should be array' })
+    @IsOptional()
+    credentialOffer: CredentialOffer[];
+
+    @ApiProperty({ example: 'awqx@getnada.com' })
+    @IsEmail()
+    @IsNotEmpty({ message: 'Please provide valid email' })
+    @IsString({ message: 'email should be string' })
+    @IsOptional()
+    emailId: string;
+
+    @ApiProperty({ example: [{ 'value': 'string', 'name': 'string' }] })
+    @IsNotEmpty({ message: 'Please provide valid attributes' })
+    @IsArray({ message: 'attributes should be array' })
+    @IsOptional()
+    attributes: Attribute[];
+
+    @ApiProperty({ example: 'string' })
+    @IsNotEmpty({ message: 'Please provide valid credential definition id' })
+    @IsString({ message: 'credential definition id should be string' })
+    credentialDefinitionId: string;
+
+    @ApiProperty({ example: 'string' })
+    @IsNotEmpty({ message: 'Please provide valid comment' })
+    @IsString({ message: 'comment should be string' })
+    @IsOptional()
+    comment: string;
+
+    @ApiProperty({ example: 'v1' })
+    @IsOptional()
+    @IsNotEmpty({ message: 'Please provide valid protocol version' })
+    @IsString({ message: 'protocol version should be string' })
+    protocolVersion?: string;
+
+    orgId: number;
+}

apps/api-gateway/src/issuance/issuance.controller.ts

@@ -33,7 +33,7 @@ import { CommonService } from '@credebl/common/common.service';
 import { Response } from 'express';
 import IResponseType from '@credebl/common/interfaces/response.interface';
 import { IssuanceService } from './issuance.service';
-import { IssuanceDto, IssueCredentialDto } from './dtos/issuance.dto';
+import { IssuanceDto, IssueCredentialDto, OutOfBandCredentialDto } from './dtos/issuance.dto';
 import { IUserRequest } from '@credebl/user-request/user-request.interface';
 import { User } from '../authz/decorators/user.decorator';
 import { ResponseMessages } from '@credebl/common/response-messages';
@@ -57,6 +57,19 @@ export class IssuanceController {
   ) { }
   private readonly logger = new Logger('IssuanceController');
 
+  @Get('/issuance/oob/qr/:base64Image')
+  @ApiOperation({ summary: 'Out-Of-Band issuance QR', description: 'Out-Of-Band issuance QR' })
+  @ApiResponse({ status: 200, description: 'Success', type: ApiResponseDto })
+  @ApiExcludeEndpoint()
+  async getOgPofile(@Param('base64Image') base64Image: string, @Res() res: Response): Promise<Response> {
+
+    const base64Data = base64Image.replace(/^data:image\/\w+;base64,/, '');
+
+    const imageBuffer = Buffer.from(base64Data, 'base64');
+    res.setHeader('Content-Type', 'image/png'); 
+    return res.send(imageBuffer);
+  }
+
   /**
     * Description: Get all issued credentials
     * @param user
@@ -183,6 +196,42 @@ export class IssuanceController {
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
 
+  /**
+   * Description: credential issuance out-of-band
+   * @param user 
+   * @param outOfBandCredentialDto 
+   * @param orgId 
+   * @param res 
+   * @returns 
+   */
+  @Post('/orgs/:orgId/credentials/oob')
+  // @UseGuards(AuthGuard('jwt'))
+  @ApiOperation({
+    summary: `Create out-of-band credential offer`,
+    description: `Create out-of-band credential offer`
+  })
+  @ApiResponse({ status: 201, description: 'Success', type: ApiResponseDto })
+  // @ApiBearerAuth()
+  // @UseGuards(AuthGuard('jwt'), OrgRolesGuard)
+  // @Roles(OrgRoles.OWNER, OrgRoles.ADMIN, OrgRoles.ISSUER)
+  async outOfBandCredentialOffer(
+    @User() user: IUserRequest,
+    @Body() outOfBandCredentialDto: OutOfBandCredentialDto,
+    @Param('orgId') orgId: number,
+    @Res() res: Response
+  ): Promise<Response> {
+
+    outOfBandCredentialDto.orgId = orgId;
+    const getCredentialDetails = await this.issueCredentialService.outOfBandCredentialOffer(user, outOfBandCredentialDto);
+
+    const finalResponse: IResponseType = {
+      statusCode: HttpStatus.OK,
+      message: ResponseMessages.issuance.success.fetch,
+      data: getCredentialDetails.response
+    };
+    return res.status(HttpStatus.OK).json(finalResponse);
+  }
+
   /**
   * Description: webhook Save issued credential details
   * @param user
@@ -209,5 +258,4 @@ export class IssuanceController {
     return res.status(HttpStatus.CREATED).json(finalResponse);
 
   }
-
 }

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

@@ -2,7 +2,7 @@ import { Injectable, Inject } from '@nestjs/common';
 import { ClientProxy } from '@nestjs/microservices';
 import { BaseService } from 'libs/service/base.service';
 import { IUserRequest } from '@credebl/user-request/user-request.interface';
-import { IssuanceDto, IssueCredentialDto } from './dtos/issuance.dto';
+import { IssuanceDto, IssueCredentialDto, OutOfBandCredentialDto } from './dtos/issuance.dto';
 
 @Injectable()
 export class IssuanceService extends BaseService {
@@ -50,4 +50,10 @@ export class IssuanceService extends BaseService {
         return this.sendNats(this.issuanceProxy, 'webhook-get-issue-credential', payload);
     }
 
+    outOfBandCredentialOffer(user: IUserRequest, outOfBandCredentialDto: OutOfBandCredentialDto): Promise<{
+        response: object;
+    }> {
+        const payload = { user, outOfBandCredentialDto };
+        return this.sendNats(this.issuanceProxy, 'out-of-band-credential-offer', payload);
+    }
 }

apps/api-gateway/src/organization/organization.controller.ts

@@ -41,6 +41,19 @@ export class OrganizationController {
     private readonly commonService: CommonService
   ) { }
 
+  @Get('/profile/:orgId')
+  @ApiOperation({ summary: 'Organization Profile', description: 'Update an organization' })
+  @ApiResponse({ status: 200, description: 'Success', type: ApiResponseDto })
+  async getOgPofile(@Param('orgId') orgId: number, @Res() res: Response): Promise<Response> {
+    const orgProfile = await this.organizationService.getOgPofile(orgId);
+
+    const base64Data = orgProfile.response["logoUrl"].replace(/^data:image\/\w+;base64,/, '');
+
+    const imageBuffer = Buffer.from(base64Data, 'base64');
+    res.setHeader('Content-Type', 'image/png'); 
+    return res.send(imageBuffer);
+  }
+
   /**
  * 
  * @param user 

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

@@ -134,4 +134,12 @@ export class OrganizationService extends BaseService {
 
     return this.sendNats(this.serviceProxy, 'fetch-organization-user', payload);
   }
+
+  async getOgPofile(
+    orgId: number
+  ): Promise<{ response: object }> {
+    const payload = { orgId };
+
+    return this.sendNats(this.serviceProxy, 'fetch-organization-profile', payload);
+  }
 }

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

@@ -1,4 +1,4 @@
-import { IsArray, IsEmail, IsNotEmpty, IsObject, IsOptional, IsString, MaxLength } from 'class-validator';
+import { IsArray, IsNotEmpty, IsObject, IsOptional, IsString, MaxLength } from 'class-validator';
 import { toLowerCase, trim } from '@credebl/common/cast.helper';
 import { ApiProperty } from '@nestjs/swagger';
 import { Transform } from 'class-transformer';
@@ -85,15 +85,10 @@ export class OutOfBandRequestProof {
     @IsNotEmpty({ message: 'please provide valid attributes' })
     attributes: ProofRequestAttribute[];
 
-    @ApiProperty({ example: 'string' })
-    @IsNotEmpty({ message: 'Please provide valid emailId' })
-    @Transform(({ value }) => trim(value))
-    @Transform(({ value }) => toLowerCase(value))
-    @IsNotEmpty({ message: 'Email is required.' })
-    @MaxLength(256, { message: 'Email must be at most 256 character.' })
-    @IsEmail()
-    emailId: string;
-
+    @ApiProperty()
+    @IsString({ each: true, message: 'Each emailId in the array should be a string' })
+    emailId: string | string[];
+
     @ApiProperty()
     @IsOptional()
     comment: string;