refactor: get all ecosystems api to support orgid as optional query params

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

Author: pranalidhanavade

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

@@ -206,9 +206,14 @@ export class EcosystemController {
     summary: 'Get ecosystems',
     description: 'Fetch ecosystems for Platform Admin or Ecosystem Lead'
   })
+  @ApiQuery({
+    name: 'orgId',
+    required: false,
+    type: String
+  })
   @Roles(OrgRoles.PLATFORM_ADMIN, OrgRoles.ECOSYSTEM_LEAD)
-  async getEcosystems(@User() reqUser: user, @Res() res: Response): Promise<Response> {
-    const ecosystems = await this.ecosystemService.getEcosystems(reqUser.id);
+  async getEcosystems(@User() reqUser: user, @Res() res: Response, @Query('orgId') orgId?: string): Promise<Response> {
+    const ecosystems = await this.ecosystemService.getEcosystems(reqUser.id, orgId);
 
     return res.status(HttpStatus.OK).json({
       statusCode: HttpStatus.OK,

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

@@ -39,8 +39,8 @@ export class EcosystemService {
    * @param userId
    * @returns All ecosystems from platform
    */
-  async getEcosystems(userId: string): Promise<IEcosystem[]> {
-    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-ecosystems', { userId });
+  async getEcosystems(userId: string, orgId: string): Promise<IEcosystem[]> {
+    return this.natsClient.sendNatsMessage(this.serviceProxy, 'get-ecosystems', { userId, orgId });
   }
 
   /**

apps/ecosystem/repositories/ecosystem.repository.ts

@@ -1241,4 +1241,49 @@ export class EcosystemRepository {
       }
     });
   }
+
+  async getAllEcosystemsByOrgId(orgId: string): Promise<ecosystem[]> {
+    try {
+      if (!orgId) {
+        throw new BadRequestException(ResponseMessages.ecosystem.error.invalidOrgId);
+      }
+
+      return await this.prisma.ecosystem.findMany({
+        where: {
+          deletedAt: null,
+          ecosystemOrgs: {
+            some: {
+              orgId,
+              deletedAt: null
+            }
+          }
+        },
+        orderBy: {
+          createDateTime: 'desc'
+        },
+        include: {
+          ecosystemOrgs: {
+            where: {
+              orgId,
+              deletedAt: null
+            },
+            include: {
+              ecosystemRole: true,
+              organisation: {
+                select: {
+                  id: true,
+                  name: true,
+                  orgSlug: true,
+                  logoUrl: true
+                }
+              }
+            }
+          }
+        }
+      });
+    } catch (error) {
+      this.logger.error(`getAllEcosystemsByOrgId error: ${error.message}`);
+      throw error;
+    }
+  }
 }

apps/ecosystem/src/ecosystem.controller.ts

@@ -68,8 +68,8 @@ export class EcosystemController {
    * @returns List of ecosystems
    */
   @MessagePattern({ cmd: 'get-ecosystems' })
-  async getEcosystems(payload: { userId: string }): Promise<IEcosystem[]> {
-    return this.ecosystemService.getEcosystems(payload.userId);
+  async getEcosystems(payload: { userId: string; orgId: string }): Promise<IEcosystem[]> {
+    return this.ecosystemService.getEcosystems(payload.userId, payload.orgId);
   }
 
   /**

apps/ecosystem/src/ecosystem.service.ts

@@ -280,11 +280,15 @@ export class EcosystemService {
     }
   }
 
-  async getEcosystems(userId: string): Promise<IEcosystem[]> {
+  async getEcosystems(userId: string, orgId: string): Promise<IEcosystem[]> {
     if (!userId) {
       throw new BadRequestException(ResponseMessages.ecosystem.error.userIdMissing);
     }
     try {
+      if (orgId) {
+        return this.ecosystemRepository.getAllEcosystemsByOrgId(orgId);
+      }
+
       const leadEcosystems = await this.ecosystemRepository.getEcosystemsForEcosystemLead(userId);
 
       if (0 < leadEcosystems.length) {