feat: added consent notice and intent mapping logic

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

@@ -19,6 +19,7 @@ import { CreateIntentTemplateDto, UpdateIntentTemplateDto } from '../utilities/d
 import { GetAllIntentTemplatesDto } from '../utilities/dtos/get-all-intent-templates.dto';
 import { IIntentTemplateList } from '@credebl/common/interfaces/intents-template.interface';
 import { IPaginationSortingDto, PaginatedResponse } from 'libs/common/src/interfaces/interface';
+import { CreateIntentNoticeDto, UpdateIntentNoticeDto } from '../oid4vc-verification/dtos/create-intent-notice.dto';
 
 @Injectable()
 export class EcosystemService {
@@ -251,4 +252,42 @@ export class EcosystemService {
   async getCreateEcosystemInvitationStatus(email: string, status: Invitation): Promise<boolean> {
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-ecosystem-created-status', { email, status });
   }
+
+  async createIntentNotice(createIntentNoticeDto: CreateIntentNoticeDto, userDetails: user): Promise<object> {
+    const payload = { createIntentNoticeDto, userId: userDetails.id };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'create-intent-notice', payload);
+  }
+
+  async getIntentNotices(id?: string, intentId?: string): Promise<object[]> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intent-notices', { id, intentId });
+  }
+
+  async getIntentNoticesByEcosystemId(
+    ecosystemId: string,
+    pageNumber: number,
+    pageSize: number,
+    search: string,
+    intentId?: string
+  ): Promise<object> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-intent-notices-by-ecosystem', {
+      ecosystemId,
+      pageNumber,
+      pageSize,
+      search,
+      intentId
+    });
+  }
+
+  async updateIntentNotice(
+    id: string,
+    updateIntentNoticeDto: UpdateIntentNoticeDto,
+    userDetails: user
+  ): Promise<object> {
+    const payload = { id, updateIntentNoticeDto, userId: userDetails.id };
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'update-intent-notice', payload);
+  }
+
+  async deleteIntentNotice(id: string, userDetails: user): Promise<object> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'delete-intent-notice', { id, userId: userDetails.id });
+  }
 }

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

@@ -47,6 +47,7 @@ import { PaginationDto } from '@credebl/common/dtos/pagination.dto';
 import { TrimStringParamPipe } from '@credebl/common/cast.helper';
 import { EcosystemService } from '../ecosystem.service';
 import { ForbiddenErrorDto } from '../../dtos/forbidden-error.dto';
+import { CreateIntentNoticeDto, UpdateIntentNoticeDto } from '../../oid4vc-verification/dtos/create-intent-notice.dto';
 
 @UseFilters(CustomExceptionFilter)
 @Controller('intent')
@@ -611,4 +612,183 @@ export class IntentController {
     };
     return res.status(HttpStatus.OK).json(finalResponse);
   }
+
+  @Post('/notice')
+  @ApiBearerAuth()
+  @Roles(OrgRoles.ECOSYSTEM_LEAD)
+  @UseGuards(AuthGuard('jwt'), EcosystemRolesGuard)
+  @ApiOperation({ summary: 'Create intent notice', description: 'Stores a notice URL associated with an intent.' })
+  @ApiResponse({ status: HttpStatus.CREATED, description: 'Intent notice created successfully', type: ApiResponseDto })
+  async createIntentNotice(
+    @Body() createIntentNoticeDto: CreateIntentNoticeDto,
+    @User() user: PrismaUser,
+    @Res() res: Response
+  ): Promise<Response> {
+    const result = await this.ecosystemService.createIntentNotice(createIntentNoticeDto, user);
+    const finalResponse: IResponse = {
+      statusCode: HttpStatus.CREATED,
+      message: ResponseMessages.intentNotice.success.create,
+      data: result
+    };
+    return res.status(HttpStatus.CREATED).json(finalResponse);
+  }
+
+  @Get('/notice')
+  @ApiBearerAuth()
+  @Roles(OrgRoles.ECOSYSTEM_LEAD, OrgRoles.ECOSYSTEM_MEMBER)
+  @UseGuards(AuthGuard('jwt'), EcosystemRolesGuard)
+  @ApiOperation({
+    summary: 'Get intent notices',
+    description: 'Retrieves intent notices. Filter by notice id or intentId (both optional).'
+  })
+  @ApiQuery({ name: 'id', required: false, type: String, description: 'Filter by notice PK UUID (optional)' })
+  @ApiQuery({ name: 'intentId', required: false, type: String, description: 'Filter by intent UUID (optional)' })
+  @ApiResponse({ status: HttpStatus.OK, description: 'Intent notices fetched successfully', type: ApiResponseDto })
+  async getIntentNotices(
+    @Res() res: Response,
+    @Query(
+      'id',
+      new ParseUUIDPipe({
+        version: '4',
+        optional: true,
+        exceptionFactory: (): Error => {
+          throw new BadRequestException('Invalid notice ID');
+        }
+      })
+    )
+    id?: string,
+    @Query(
+      'intentId',
+      new ParseUUIDPipe({
+        version: '4',
+        optional: true,
+        exceptionFactory: (): Error => {
+          throw new BadRequestException('Invalid intent ID');
+        }
+      })
+    )
+    intentId?: string
+  ): Promise<Response> {
+    const result = await this.ecosystemService.getIntentNotices(id, intentId);
+    const finalResponse: IResponse = {
+      statusCode: HttpStatus.OK,
+      message: ResponseMessages.intentNotice.success.fetchAll,
+      data: result
+    };
+    return res.status(HttpStatus.OK).json(finalResponse);
+  }
+
+  @Get('/ecosystem/:ecosystemId/notice')
+  @ApiBearerAuth()
+  @Roles(OrgRoles.ECOSYSTEM_LEAD, OrgRoles.ECOSYSTEM_MEMBER)
+  @UseGuards(AuthGuard('jwt'), EcosystemRolesGuard)
+  @ApiOperation({
+    summary: 'Get intent notices by ecosystem',
+    description: 'Retrieves all intent notices for an ecosystem with pagination, search, and optional intent filter.'
+  })
+  @ApiQuery({ name: 'pageNumber', required: false, type: Number, description: 'Page number (default: 1)' })
+  @ApiQuery({ name: 'pageSize', required: false, type: Number, description: 'Page size (default: 10, max: 100)' })
+  @ApiQuery({ name: 'search', required: false, type: String, description: 'Search by notice URL' })
+  @ApiQuery({ name: 'intentId', required: false, type: String, description: 'Filter by intent UUID' })
+  @ApiResponse({ status: HttpStatus.OK, description: 'Intent notices fetched successfully', type: ApiResponseDto })
+  async getIntentNoticesByEcosystemId(
+    @Param(
+      'ecosystemId',
+      TrimStringParamPipe,
+      new ParseUUIDPipe({
+        exceptionFactory: (): Error => {
+          throw new BadRequestException(ResponseMessages.ecosystem.error.invalidFormatOfEcosystemId);
+        }
+      })
+    )
+    ecosystemId: string,
+    @Query() pageDto: PaginationDto,
+    @Query(
+      'intentId',
+      new ParseUUIDPipe({
+        version: '4',
+        optional: true,
+        exceptionFactory: (): Error => {
+          throw new BadRequestException('Invalid intent ID');
+        }
+      })
+    )
+    intentId: string,
+    @Res() res: Response
+  ): Promise<Response> {
+    const result = await this.ecosystemService.getIntentNoticesByEcosystemId(
+      ecosystemId,
+      pageDto.pageNumber,
+      pageDto.pageSize,
+      pageDto.search,
+      intentId
+    );
+    return res.status(HttpStatus.OK).json({
+      statusCode: HttpStatus.OK,
+      message: ResponseMessages.intentNotice.success.fetchAll,
+      data: result
+    });
+  }
+
+  @Put('/notice/:id')
+  @ApiBearerAuth()
+  @Roles(OrgRoles.ECOSYSTEM_LEAD)
+  @UseGuards(AuthGuard('jwt'), EcosystemRolesGuard)
+  @ApiOperation({
+    summary: 'Update intent notice',
+    description: 'Updates the notice URL for a given notice ID.'
+  })
+  @ApiResponse({ status: HttpStatus.OK, description: 'Intent notice updated successfully', type: ApiResponseDto })
+  async updateIntentNotice(
+    @Param(
+      'id',
+      TrimStringParamPipe,
+      new ParseUUIDPipe({
+        exceptionFactory: (): Error => {
+          throw new BadRequestException('Invalid notice ID');
+        }
+      })
+    )
+    id: string,
+    @Body() updateIntentNoticeDto: UpdateIntentNoticeDto,
+    @User() user: PrismaUser,
+    @Res() res: Response
+  ): Promise<Response> {
+    const result = await this.ecosystemService.updateIntentNotice(id, updateIntentNoticeDto, user);
+    const finalResponse: IResponse = {
+      statusCode: HttpStatus.OK,
+      message: ResponseMessages.intentNotice.success.update,
+      data: result
+    };
+    return res.status(HttpStatus.OK).json(finalResponse);
+  }
+
+  @Delete('/notice/:id')
+  @ApiBearerAuth()
+  @Roles(OrgRoles.ECOSYSTEM_LEAD)
+  @UseGuards(AuthGuard('jwt'), EcosystemRolesGuard)
+  @ApiOperation({ summary: 'Delete intent notice', description: 'Deletes an intent notice by its ID.' })
+  @ApiResponse({ status: HttpStatus.OK, description: 'Intent notice deleted successfully', type: ApiResponseDto })
+  async deleteIntentNotice(
+    @Param(
+      'id',
+      TrimStringParamPipe,
+      new ParseUUIDPipe({
+        exceptionFactory: (): Error => {
+          throw new BadRequestException('Invalid notice ID');
+        }
+      })
+    )
+    id: string,
+    @User() user: PrismaUser,
+    @Res() res: Response
+  ): Promise<Response> {
+    const result = await this.ecosystemService.deleteIntentNotice(id, user);
+    const finalResponse: IResponse = {
+      statusCode: HttpStatus.OK,
+      message: ResponseMessages.intentNotice.success.delete,
+      data: result
+    };
+    return res.status(HttpStatus.OK).json(finalResponse);
+  }
 }

apps/api-gateway/src/oid4vc-verification/dtos/create-intent-notice.dto.ts

@@ -0,0 +1,26 @@
+import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
+import { IsDefined, IsOptional, IsString, IsUrl, IsUUID } from 'class-validator';
+
+export class CreateIntentNoticeDto {
+  @ApiProperty({ description: 'Intent ID to associate the notice with', example: 'uuid-of-intent' })
+  @IsDefined()
+  @IsUUID()
+  intentId: string;
+
+  @ApiProperty({ description: 'URL of the notice', example: 'https://example.com/notice' })
+  @IsDefined()
+  @IsString()
+  noticeUrl: string;
+
+  @ApiPropertyOptional({ description: 'Organization ID (optional)', example: 'uuid-of-org' })
+  @IsOptional()
+  @IsUUID()
+  orgId?: string;
+}
+
+export class UpdateIntentNoticeDto {
+  @ApiPropertyOptional({ description: 'URL of the notice', example: 'https://example.com/notice' })
+  @IsOptional()
+  @IsUrl()
+  noticeUrl?: string;
+}

apps/api-gateway/src/oid4vc-verification/oid4vc-verification.controller.ts

@@ -319,6 +319,7 @@ export class Oid4vcVerificationController {
     description: 'Verification presentation created successfully.',
     type: ApiResponseDto
   })
+  @ApiQuery({ name: 'ecosystemId', required: true })
   @ApiBearerAuth()
   @Roles(OrgRoles.OWNER)
   @UseGuards(AuthGuard('jwt'), OrgRolesGuard)
@@ -341,19 +342,29 @@ export class Oid4vcVerificationController {
       })
     )
     verifierId: string,
+    @Query(
+      'ecosystemId',
+      new ParseUUIDPipe({
+        exceptionFactory: (): Error => {
+          throw new BadRequestException('Invalid ecosystem ID');
+        }
+      })
+    )
+    ecosystemId: string,
     @User() user: user,
     @Body() createIntentDto: CreateIntentBasedVerificationDto,
     @Res() res: Response
   ): Promise<Response> {
     this.logger.debug(
-      `[createIntentBasedVerificationPresentation] Called with orgId=${orgId}, verifierId=${verifierId}, intent=${createIntentDto?.intent}, user=${user.id}`
+      `[createIntentBasedVerificationPresentation] Called with orgId=${orgId}, verifierId=${verifierId}, intent=${createIntentDto?.intent}, ecosystemId=${ecosystemId}, user=${user.id}`
     );
 
     const presentation = await this.oid4vcVerificationService.createIntentBasedVerificationPresentation(
       orgId,
       verifierId,
       createIntentDto,
-      user
+      user,
+      ecosystemId
     );
 
     this.logger.debug(`[createIntentBasedVerificationPresentation] Presentation created successfully`);

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

@@ -25,10 +25,20 @@ export class Oid4vcVerificationService {
     orgId: string,
     verifierId: string,
     createIntentDto: CreateIntentBasedVerificationDto,
-    userDetails: user
+    userDetails: user,
+    ecosystemId: string
   ): Promise<object> {
     const { intent, responseMode, requestSigner, expectedOrigins } = createIntentDto;
-    const payload = { orgId, verifierId, intent, responseMode, requestSigner, expectedOrigins, userDetails };
+    const payload = {
+      orgId,
+      verifierId,
+      intent,
+      responseMode,
+      requestSigner,
+      expectedOrigins,
+      userDetails,
+      ecosystemId
+    };
     this.logger.debug(
       `[createIntentBasedVerificationPresentation] Called with orgId=${orgId}, verifierId=${verifierId}, intent=${intent}, user=${userDetails?.id}`
     );