feat:Decline endorsement request by lead

apps/api-gateway/src/ecosystem/dtos/decline-endorsement-transaction.dto.ts

@@ -0,0 +1,6 @@
+export class DeclienEndorsementTransactionDto {
+    ecosystemId: string;
+    orgId: string;
+    endorsementId: string;
+
+}

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

@@ -31,6 +31,7 @@ import { GetAllEcosystemMembersDto } from './dtos/get-members.dto';
 import { GetAllEndorsementsDto } from './dtos/get-all-endorsements.dto';
 import { CreateEcosystemDto } from './dtos/create-ecosystem-dto';
 
+
 @UseFilters(CustomExceptionFilter)
 @Controller('ecosystem')
 @ApiTags('ecosystem')
@@ -396,6 +397,7 @@ export class EcosystemController {
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
 
+
   @Put('/:ecosystemId/:orgId')
   @ApiOperation({ summary: 'Edit ecosystem', description: 'Edit existing ecosystem' })
   @ApiResponse({ status: 200, description: 'Success', type: ApiResponseDto })
@@ -416,6 +418,37 @@ export class EcosystemController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
+
+   /**
+   *
+   * @param declineEndorsementTransactionRequest
+   *
+   * @param res
+   * @returns  endorsement transaction status
+   */
+   @Put('/:ecosystemId/:orgId/transactions/:endorsementId')
+   @ApiOperation({
+     summary: 'Decline Endorsement Request By Lead',
+     description: 'Decline Endorsement Request By Lead'
+   })
+   @UseGuards(AuthGuard('jwt'), EcosystemRolesGuard, OrgRolesGuard)
+   @ApiBearerAuth()
+   @EcosystemsRoles(EcosystemRoles.ECOSYSTEM_LEAD)
+   @Roles(OrgRoles.OWNER, OrgRoles.ADMIN)
+   async declineEndorsementRequestByLead(
+     @Param('ecosystemId') ecosystemId: string,
+     @Param('orgId') orgId: string,
+     @Param('endorsementId') endorsementId: string,
+     @Res() res: Response
+   ): Promise<object> {
+     await this.ecosystemService.declineEndorsementRequestByLead(ecosystemId, orgId, endorsementId);
+     const finalResponse: IResponseType = {
+       statusCode: HttpStatus.OK,
+       message: ResponseMessages.ecosystem.success.DeclineEndorsementTransaction
+     };
+     return res.status(HttpStatus.OK).json(finalResponse);
+   }
+
 
   @Delete('/:ecosystemId/:orgId/invitations/:invitationId')
   @ApiOperation({ summary: 'Delete ecosystem pending invitations', description: 'Delete ecosystem pending invitations' })
@@ -438,4 +471,5 @@ export class EcosystemController {
     return res.status(HttpStatus.OK).json(finalResponse);
   }
 
+
 }

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

@@ -8,6 +8,7 @@ import { GetAllEcosystemInvitationsDto } from './dtos/get-all-sent-invitations.d
 import { GetAllSentEcosystemInvitationsDto } from './dtos/get-all-received-invitations.dto';
 import { GetAllEcosystemMembersDto } from './dtos/get-members.dto';
 import { GetAllEndorsementsDto } from './dtos/get-all-endorsements.dto';
+
 import { RequestSchemaDto, RequestCredDefDto } from './dtos/request-schema.dto';
 
 @Injectable()
@@ -159,4 +160,14 @@ export class EcosystemService extends BaseService {
       const payload = { endorsementId, ecosystemId };
       return this.sendNats(this.serviceProxy, 'sumbit-endorsement-transaction', payload);
     }
+
+    async declineEndorsementRequestByLead(
+      ecosystemId: string,
+      endorsementId: string,
+      orgId: string
+    ): Promise<{ response: object }> {
+      const payload = { ecosystemId, endorsementId, orgId };
+      return this.sendNats(this.serviceProxy, 'decline-endorsement-transaction', payload);
+    }
+
 }

apps/ecosystem/src/ecosystem.controller.ts

@@ -197,4 +197,19 @@ export class EcosystemController {
      ): Promise<object> {
      return this.ecosystemService.submitTransaction(payload.endorsementId, payload.ecosystemId);
    }
+
+
+    /**
+   *
+   * @param payload
+   * @returns Declien Endorsement Transaction status 
+   */
+    @MessagePattern({ cmd: 'decline-endorsement-transaction' })
+    async declineEndorsementRequestByLead(payload: {
+      ecosystemId:string, endorsementId:string, orgId:string
+    }): Promise<object> {
+      return this.ecosystemService.declineEndorsementRequestByLead(payload.ecosystemId, payload.orgId, payload.endorsementId);
+    }
+
+
 }

apps/ecosystem/src/ecosystem.repository.ts

@@ -6,6 +6,7 @@ import { EcosystemInvitationStatus, EcosystemOrgStatus, EcosystemRoles, endorsem
 import { updateEcosystemOrgsDto } from '../dtos/update-ecosystemOrgs.dto';
 import {  SchemaTransactionResponse } from '../interfaces/ecosystem.interfaces';
 import { ResponseMessages } from '@credebl/common/response-messages';
+import { NotFoundException } from '@nestjs/common';
 // eslint-disable-next-line camelcase
 
 @Injectable()
@@ -704,4 +705,38 @@ export class EcosystemRepository {
     }
   }
 
-}
+  async updateEndorsementRequestStatus(ecosystemId: string, orgId: string, endorsementId: string): Promise<object> {
+    try {
+
+      const endorsementTransaction = await this.prisma.endorsement_transaction.findUnique({
+        where: { id: endorsementId, status: endorsementTransactionStatus.REQUESTED }
+      });
+
+      if (!endorsementTransaction) {
+        throw new NotFoundException(ResponseMessages.ecosystem.error.EndorsementTransactionNotFoundException);
+      }
+      const { ecosystemOrgId } = endorsementTransaction;
+
+      const endorsementTransactionEcosystemOrg = await this.prisma.ecosystem_orgs.findUnique({
+        where: { id: ecosystemOrgId }
+      });
+
+      if (endorsementTransactionEcosystemOrg.orgId === orgId && endorsementTransactionEcosystemOrg.ecosystemId === ecosystemId) {
+        const updatedEndorsementTransaction = await this.prisma.endorsement_transaction.update({
+          where: { id: endorsementId },
+          data: {
+            status: endorsementTransactionStatus.DECLINED
+          }
+        });
+
+        return updatedEndorsementTransaction;
+      } else {
+        throw new NotFoundException(ResponseMessages.ecosystem.error.OrgOrEcosystemNotFoundExceptionForEndorsementTransaction);
+      }
+    } catch (error) {
+      this.logger.error(`Error in updating endorsement transaction status: ${error.message}`);
+      throw error;
+    }
+  }
+}
+

apps/ecosystem/src/ecosystem.service.ts

@@ -19,6 +19,7 @@ import { GetEndorsementsPayload } from '../interfaces/endorsements.interface';
 import { platform_config } from '@prisma/client';
 import { CommonConstants } from '@credebl/common/common.constant';
 
+
 @Injectable()
 export class EcosystemService {
   constructor(
@@ -706,4 +707,23 @@ export class EcosystemService {
     }
   }
 
+
+   /**
+   * 
+   * @param ecosystemId 
+   * @param endorsementId 
+   * @param orgId 
+   * @returns EndorsementTransactionRequest Status message
+   */
+
+   async declineEndorsementRequestByLead(ecosystemId:string, endorsementId:string, orgId:string): Promise<object> {
+    try {
+
+      return await this.ecosystemRepository.updateEndorsementRequestStatus(ecosystemId, orgId, endorsementId);
+      } catch (error) {
+      this.logger.error(`error in decline endorsement request: ${error}`);
+      throw new InternalServerErrorException(error);
+    }
+  }
+
 }

libs/common/src/response-messages/index.ts

@@ -195,8 +195,9 @@ export const ResponseMessages = {
             sign: 'Transaction request signed successfully',
             invitationReject: 'Ecosystem invitation rejected',
             invitationAccept: 'Ecosystem invitation accepted successfully',
-            fetchMembers: 'Ecosystem members fetched successfully',
-            fetchEndorsors: 'Endorser transactions fetched successfully'
+            fetchEndorsors: 'Endorser transactions fetched successfully',
+            DeclineEndorsementTransaction:'Decline endorsement request successfully',
+            fetchMembers: 'Ecosystem members fetched successfully'
         },
         error: {
             notCreated: 'Error while creating ecosystem',
@@ -214,7 +215,9 @@ export const ResponseMessages = {
             invalidOrgId: 'Invalid organization Id',
             invalidEcosystemId: 'Invalid ecosystem Id',
             invalidTransaction: 'Transaction does not exist',
-            invalidAgentUrl: 'Invalid agent url'
+            invalidAgentUrl: 'Invalid agent url',
+            EndorsementTransactionNotFoundException:'Endorsement transaction with status requested not found',
+            OrgOrEcosystemNotFoundExceptionForEndorsementTransaction:'Cannot update  endorsement transaction status as OrgId and EcosystemId is not present in ecosystemOrg'
         }
     }   
 };