refactor: removed userId parameter from send invitation and get invitation api

Signed-off-by: pranalidhanavade <pranali.dhanavade@ayanworks.com>

Author: pranalidhanavade

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

@@ -7,19 +7,20 @@ import {
   ApiUnauthorizedResponse
 } from '@nestjs/swagger';
 import { Body, Controller, Get, HttpStatus, Param, Post, Res, UseFilters, UseGuards } from '@nestjs/common';
-import { ApiResponseDto } from '../dtos/apiResponse.dto';
 import { Response } from 'express';
 import { AuthGuard } from '@nestjs/passport';
 import { CustomExceptionFilter } from '@credebl/common/exception-handler';
 import { EcosystemService } from './ecosystem.service';
 import { ForbiddenErrorDto } from '../dtos/forbidden-error.dto';
-import { IResponse } from '@credebl/common/interfaces/response.interface';
 import { OrgRoles } from 'libs/org-roles/enums';
 import { ResponseMessages } from '@credebl/common/response-messages';
 import { Roles } from '../authz/decorators/roles.decorator';
 import { UnauthorizedErrorDto } from '../dtos/unauthorized-error.dto';
 import { SendEcosystemCreateDto } from './dtos/send-ecosystem-invitation';
 import { OrgRolesGuard } from '../authz/guards/org-roles.guard';
+import { user } from '@prisma/client';
+import { User } from '../authz/decorators/user.decorator';
+import { ApiResponseDto } from '../dtos/apiResponse.dto';
 
 @UseFilters(CustomExceptionFilter)
 @Controller('ecosystem')
@@ -41,28 +42,30 @@ export class EcosystemController {
    * @param userId The ID of the organization
    * @returns Success message
    */
-  @Post('/:userId/invitations')
-  @Roles(OrgRoles.PLATFORM_ADMIN)
+  @Post('/invitations')
+  @Roles(OrgRoles.OWNER, OrgRoles.ADMIN)
   @ApiOperation({
     summary: 'Create ecosystem invitation',
-    description: 'Create an invitation to user to create a new ecosystem'
+    description: 'Invite a user to create an ecosystem'
   })
-  @ApiResponse({ status: HttpStatus.CREATED, description: 'Success', type: ApiResponseDto })
-  @UseGuards(AuthGuard('jwt'), OrgRolesGuard)
+  @ApiResponse({
+    status: HttpStatus.CREATED,
+    description: 'Success',
+    type: ApiResponseDto
+  })
+  @UseGuards(AuthGuard('jwt'))
   @ApiBearerAuth()
   async createInvitation(
     @Body() sendEcosystemCreateDto: SendEcosystemCreateDto,
-    @Param('userId') userId: string,
+    @User() reqUser: user,
     @Res() res: Response
   ): Promise<Response> {
-    await this.ecosystemService.inviteUserToCreateEcosystem(sendEcosystemCreateDto, userId);
+    await this.ecosystemService.inviteUserToCreateEcosystem(sendEcosystemCreateDto, reqUser.id);
 
-    const finalResponse: IResponse = {
+    return res.status(HttpStatus.CREATED).json({
       statusCode: HttpStatus.CREATED,
       message: ResponseMessages.ecosystem.success.createInvitation
-    };
-
-    return res.status(HttpStatus.CREATED).json(finalResponse);
+    });
   }
 
   @Get('/:userId/invitations')

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

@@ -16,10 +16,13 @@ export class EcosystemService {
    * @param SendEcosystemCreateDto
    * @returns Ecosystem creation success
    */
-  async inviteUserToCreateEcosystem(dto: SendEcosystemCreateDto, userId: string): Promise<IEcosystemInvitations> {
+  async inviteUserToCreateEcosystem(
+    dto: SendEcosystemCreateDto,
+    platformAdminId: string
+  ): Promise<IEcosystemInvitations> {
     return this.natsClient.sendNatsMessage(this.serviceProxy, 'invite-user-for-ecosystem-creation', {
       email: dto.email,
-      userId
+      platformAdminId
     });
   }
 

apps/ecosystem/repositories/ecosystem.repository.ts

@@ -15,17 +15,25 @@ export class EcosystemRepository {
    * @returns orgInvitaionDetails
    */
 
-  async createEcosystemInvitation(email: string, userId: string): Promise<ecosystem_invitations> {
+  async createEcosystemInvitation(payload: {
+    email: string;
+    invitedUserId: string | null;
+    platformAdminId: string;
+  }): Promise<ecosystem_invitations> {
+    const { email, invitedUserId, platformAdminId } = payload;
+
     return this.prisma.ecosystem_invitations.create({
       data: {
         email,
-        // FIXME: Change status to PENDING once invitation accept/reject implemented
-        status: Invitation.ACCEPTED,
-        createdBy: userId,
-        lastChangedBy: userId,
-        user: {
-          connect: { id: userId }
-        }
+        // Change to PENDING when accept/reject flow is ready
+        status: Invitation.PENDING,
+
+        // invited user (nullable)
+        userId: invitedUserId,
+
+        // platform admin
+        createdBy: platformAdminId,
+        lastChangedBy: platformAdminId
       }
     });
   }

apps/ecosystem/src/ecosystem.controller.ts

@@ -16,7 +16,10 @@ export class EcosystemController {
    */
 
   @MessagePattern({ cmd: 'invite-user-for-ecosystem-creation' })
-  async inviteUserToCreateEcosystem(payload: { email: string; userId: string }): Promise<IEcosystemInvitations> {
+  async inviteUserToCreateEcosystem(payload: {
+    email: string;
+    platformAdminId: string;
+  }): Promise<IEcosystemInvitations> {
     return this.ecosystemService.inviteUserToCreateEcosystem(payload);
   }
 

apps/ecosystem/src/ecosystem.service.ts

@@ -34,19 +34,31 @@ export class EcosystemService {
    * @param userId
    * @returns
    */
-  async inviteUserToCreateEcosystem(payload: { email: string; userId: string }): Promise<IEcosystemInvitations> {
-    const { email, userId } = payload;
-
-    if (!email || !userId) {
-      throw new BadRequestException('Email or userId missing');
+  async inviteUserToCreateEcosystem(payload: {
+    email: string;
+    platformAdminId: string;
+  }): Promise<IEcosystemInvitations> {
+    const { email, platformAdminId } = payload;
+
+    if (!email || !platformAdminId) {
+      throw new BadRequestException('Email or platformAdminId missing');
     }
 
-    const invitation = await this.ecosystemRepository.createEcosystemInvitation(email, userId);
+    // Find invited user
+    const invitedUser = await this.prisma.user.findUnique({
+      where: { email }
+    });
+
+    const invitation = await this.ecosystemRepository.createEcosystemInvitation({
+      email,
+      invitedUserId: invitedUser?.id ?? null,
+      platformAdminId
+    });
 
-    const isUserExist = await this.checkUserExistInPlatform(email);
-    const userData = await this.getUserUserId(userId);
+    const isUserExist = Boolean(invitedUser);
+    const adminData = await this.getUserUserId(platformAdminId);
 
-    await this.sendInviteEmailTemplate(email, userData.firstName, isUserExist);
+    await this.sendInviteEmailTemplate(email, adminData.firstName, isUserExist);
 
     return invitation;
   }

apps/ecosystem/templates/create-ecosystem.templates.ts

@@ -19,9 +19,9 @@ export class CreateEcosystemInviteTemplate {
       ? ``
       : `To get started, kindly register on ${process.env.PLATFORM_NAME} platform using this link:`;
 
-    const buttonText = isUserExist
-      ? `Sign in to ${process.env.PLATFORM_NAME}`
-      : `Register on ${process.env.PLATFORM_NAME}`;
+    const secondaryMessage = isUserExist ? `Please log in to the platform to start creating your ecosystem.` : ``;
+
+    const buttonText = isUserExist ? `Create Ecosystem` : `Register on ${process.env.PLATFORM_NAME}`;
 
     const safeEmail = escapeHtml(email);
 
@@ -48,8 +48,8 @@ export class CreateEcosystemInviteTemplate {
       </p>
 
       <p>
-        You have been invited to create a new ecosystem
-        on <strong>${process.env.PLATFORM_NAME}</strong>.
+        You have been granted access by the platform admin to create a new ecosystem on <strong>${process.env.PLATFORM_NAME}</strong>. ${secondaryMessage}
+        
       </p>
 
       <p>${message}</p>
@@ -64,11 +64,6 @@ export class CreateEcosystemInviteTemplate {
                   text-decoration: none;">
           ${buttonText}
         </a>
-
-        <p style="margin-top:10px;">
-          Verification Link:
-          <a clicktracking="off" href="${validUrl}">${validUrl}</a>
-        </p>
       </div>
 
       <hr style="border-top:1px solid #e8e8e8" />

…tation_to_create_ecosystem/migration.sql …tation_to_create_ecosystem/migration.sqllibs/prisma-service/prisma/migrations/20260105101757_invitation_to_create_ecosystem/migration.sql renamed to libs/prisma-service/prisma/migrations/20260106131405_send_invitation_to_create_ecosystem/migration.sql libs/prisma-service/prisma/migrations/20260105101757_invitation_to_create_ecosystem/migration.sql renamed to libs/prisma-service/prisma/migrations/20260106131405_send_invitation_to_create_ecosystem/migration.sql

@@ -82,6 +82,9 @@ CREATE UNIQUE INDEX "ecosystem_users_userId_ecosystemId_key" ON "ecosystem_users
 -- CreateIndex
 CREATE UNIQUE INDEX "ecosystem_orgs_orgId_ecosystemId_key" ON "ecosystem_orgs"("orgId", "ecosystemId");
 
+-- CreateIndex
+CREATE UNIQUE INDEX "ecosystem_invitations_email_key" ON "ecosystem_invitations"("email");
+
 -- AddForeignKey
 ALTER TABLE "ecosystem_users" ADD CONSTRAINT "ecosystem_users_ecosystemId_fkey" FOREIGN KEY ("ecosystemId") REFERENCES "ecosystem"("id") ON DELETE RESTRICT ON UPDATE CASCADE;
 

libs/prisma-service/prisma/schema.prisma

@@ -800,7 +800,7 @@ model ecosystem_orgs {
 
 model ecosystem_invitations {
   id                  String    @id @default(uuid()) @db.Uuid
-  email               String
+  email               String    @unique
   status              String
 
   userId              String?   @db.Uuid
@@ -810,7 +810,7 @@ model ecosystem_invitations {
   lastChangedDateTime DateTime  @default(now()) @db.Timestamptz(6)
   lastChangedBy       String    @db.Uuid
 
-  user      user?      @relation(fields: [userId], references: [id])
+  user user? @relation(fields: [userId], references: [id])
 }