feat:endorser sumbit transaction

Signed-off-by: tipusinghaw <[email protected]> Signed-off-by: KulkarniShashank <[email protected]>
credebl · Sep 11, 2024 · 24db899 · 24db899
1 parent 8514b05
commit 24db899
Show file tree

Hide file tree

Showing 4 changed files with 37 additions and 7 deletions.
diff --git a/apps/agent-service/src/agent-service.controller.ts b/apps/agent-service/src/agent-service.controller.ts
@@ -116,4 +116,8 @@ export class AgentServiceController {
   async signTransaction(payload: { url: string, apiKey: string, signEndorsementPayload:string }): Promise<object> {
     return this.agentServiceService.signTransaction(payload.url, payload.apiKey, payload.signEndorsementPayload);
   }
+  @MessagePattern({ cmd: 'agent-submit-transaction' })
+  async submitTransaction(payload: { url: string, apiKey: string, submitEndorsementPayload:string }): Promise<object> {
+    return this.agentServiceService.sumbitTransaction(payload.url, payload.apiKey, payload.submitEndorsementPayload);
+  }
 }
diff --git a/apps/api-gateway/src/ecosystem/ecosystem.controller.ts b/apps/api-gateway/src/ecosystem/ecosystem.controller.ts
@@ -159,7 +159,7 @@ export class EcosystemController {
   @Post('/:orgId/transaction/schema')
   @ApiOperation({ summary: 'Request new schema', description: 'Request new schema' })
   @ApiResponse({ status: 201, description: 'Success', type: ApiResponseDto })
-  @UseGuards(AuthGuard('jwt'))
+  // @UseGuards(AuthGuard('jwt'))
   @ApiBearerAuth()
   async requestSchemaTransaction(@Body() requestSchemaPayload: RequestSchemaDto, @Param('orgId') orgId: number, @Res() res: Response): Promise<Response> {
     await this.ecosystemService.schemaEndorsementRequest(requestSchemaPayload, orgId);
@@ -173,7 +173,7 @@ export class EcosystemController {
   @Post('transaction/sign/:endorsementId')
   @ApiOperation({ summary: 'Sign transaction', description: 'Sign transaction' })
   @ApiResponse({ status: 201, description: 'Success', type: ApiResponseDto })
-  @UseGuards(AuthGuard('jwt'))
+  // @UseGuards(AuthGuard('jwt'))
   @ApiBearerAuth()
   async SignEndorsementRequests(@Param('endorsementId') endorsementId: string, @Res() res: Response): Promise<Response> {
     await this.ecosystemService.signTransaction(endorsementId);
@@ -184,6 +184,19 @@ export class EcosystemController {
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
 
+  @Post('transaction/sumbit/:endorsementId')
+  @ApiOperation({ summary: 'Sumbit transaction', description: 'Sumbit transaction' })
+  @ApiResponse({ status: 201, description: 'Success', type: ApiResponseDto })
+  // @UseGuards(AuthGuard('jwt'))
+  @ApiBearerAuth()
+  async SumbitEndorsementRequests(@Param('endorsementId') endorsementId: string, @Res() res: Response): Promise<Response> {
+    await this.ecosystemService.submitTransaction(endorsementId);
+    const finalResponse: IResponseType = {
+      statusCode: HttpStatus.CREATED,
+      message: ResponseMessages.ecosystem.success.sign
+    };
+    return res.status(HttpStatus.CREATED).json(finalResponse);
+  }
   /**
    * 
    * @param bulkInvitationDto 

diff --git a/apps/ecosystem/interfaces/ecosystem.interfaces.ts b/apps/ecosystem/interfaces/ecosystem.interfaces.ts
@@ -49,3 +49,16 @@ export interface SignedTransactionMessage {
     signedTransaction: string;
   };
 }
+
+export interface EndorsementTransactionPayload {
+  id: string;
+  endorserDid: string;
+  authorDid: string;
+  requestPayload: string;
+  responsePayload: string;
+  status: string;
+  ecosystemOrgId: string;
+  ecosystemOrgs?: {
+    orgId: string;
+  };
+}
diff --git a/apps/ecosystem/src/ecosystem.service.ts b/apps/ecosystem/src/ecosystem.service.ts
@@ -103,14 +103,14 @@ export class EcosystemService {
     try {
       const { orgId, status, invitationId } = acceptRejectInvitation;
       const invitation = await this.ecosystemRepository.getEcosystemInvitationById(invitationId);
-      
+
       if (!invitation) {
         throw new NotFoundException(ResponseMessages.ecosystem.error.invitationNotFound);
       }
 
       const updatedInvitation = await this.updateEcosystemInvitation(invitationId, orgId, status);
       if (!updatedInvitation) {
-         throw new NotFoundException(ResponseMessages.ecosystem.error.invitationNotUpdate);
+        throw new NotFoundException(ResponseMessages.ecosystem.error.invitationNotUpdate);
       }
 
       if (status === Invitation.REJECTED) {
@@ -124,13 +124,13 @@ export class EcosystemService {
         throw new NotFoundException(ResponseMessages.ecosystem.error.orgsNotUpdate);
       }
       return ResponseMessages.ecosystem.success.invitationAccept;
-    
+
     } catch (error) {
       this.logger.error(`acceptRejectInvitations: ${error}`);
       throw new RpcException(error.response ? error.response : error);
     }
   }
-  
+
   async updatedEcosystemOrgs(orgId: string, ecosystemId: string, ecosystemRoleId: string): Promise<object> {
     try {
       const data = {
@@ -153,7 +153,7 @@ export class EcosystemService {
    */
   async updateEcosystemInvitation(invitationId: string, orgId: string, status: string): Promise<object> {
     try {
-   
+
       const data = {
         status,
         orgId: String(orgId)