worked on the eslint issues (#117)

Signed-off-by: Nishad <nishad.shirsat@ayanworks.com> Signed-off-by: KulkarniShashank <shashank.kulkarni@ayanworks.com>
credebl · Sep 11, 2024 · d4e50fa · d4e50fa
1 parent 0955455
commit d4e50fa
Show file tree

Hide file tree

Showing 9 changed files with 267 additions and 2 deletions.
diff --git a/apps/api-gateway/src/ecosystem/dtos/send-invitation.dto.ts b/apps/api-gateway/src/ecosystem/dtos/send-invitation.dto.ts
@@ -0,0 +1,28 @@
+import { ApiExtraModels, ApiProperty } from '@nestjs/swagger';
+import { IsArray, IsEmail, IsNotEmpty, IsString, ValidateNested } from 'class-validator';
+import { Transform, Type } from 'class-transformer';
+
+import { trim } from '@credebl/common/cast.helper';
+
+@ApiExtraModels()
+export class EcosystemInvitationDto {
+
+    @ApiProperty({ example: 'acqx@getnada.com' })
+    @IsEmail()
+    @Transform(({ value }) => trim(value))
+    @IsNotEmpty({ message: 'Please provide valid email' })
+    @IsString({ message: 'email should be string' })
+    email: string;
+
+}
+
+@ApiExtraModels()
+export class BulkEcosystemInvitationDto {
+
+    @ApiProperty({ type: [EcosystemInvitationDto] })
+    @IsArray()
+    @ValidateNested({ each: true })
+    @Type(() => EcosystemInvitationDto)
+    invitations: EcosystemInvitationDto[];
+    ecosystemId: string;
+}
diff --git a/apps/api-gateway/src/ecosystem/ecosystem.controller.ts b/apps/api-gateway/src/ecosystem/ecosystem.controller.ts
@@ -100,6 +100,38 @@ export class EcosystemController {
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
 
+
+  /**
+   * 
+   * @param bulkInvitationDto 
+   * @param ecosystemId 
+   * @param user 
+   * @param res 
+   * @returns Ecosystem invitation send details
+   */
+  @Post('/:ecosystemId/invitations')
+  @ApiOperation({
+    summary: 'Send ecosystem invitation',
+    description: 'Send ecosystem invitation'
+  })
+  @ApiResponse({ status: 201, description: 'Success', type: ApiResponseDto })
+  @UseGuards(AuthGuard('jwt'))
+  @ApiBearerAuth()
+  async createInvitation(@Body() bulkInvitationDto: BulkEcosystemInvitationDto, @Param('ecosystemId') ecosystemId: string, @User() user: user, @Res() res: Response): Promise<Response> {
+
+    bulkInvitationDto.ecosystemId = ecosystemId;
+    await this.ecosystemService.createInvitation(bulkInvitationDto, String(user.id));
+
+    const finalResponse: IResponseType = {
+      statusCode: HttpStatus.CREATED,
+      message: ResponseMessages.ecosystem.success.createInvitation
+    };
+
+    return res.status(HttpStatus.CREATED).json(finalResponse);
+
+  }
+
+
   @Put('/:ecosystemId/')
   @ApiOperation({ summary: 'Edit ecosystem', description: 'Edit existing ecosystem' })
   @ApiResponse({ status: 201, description: 'Success', type: ApiResponseDto })
@@ -113,4 +145,5 @@ export class EcosystemController {
     };
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
+
 }
diff --git a/apps/api-gateway/src/ecosystem/ecosystem.service.ts b/apps/api-gateway/src/ecosystem/ecosystem.service.ts
@@ -39,5 +39,18 @@ export class EcosystemService extends BaseService {
   async getAllEcosystem(): Promise<{ response: object }> {
     return this.sendNats(this.serviceProxy, 'get-all-ecosystem', '');
   }
+
+
+  /**
+   * 
+   * @param bulkInvitationDto 
+   * @param userId 
+   * @returns 
+   */
+  async createInvitation(bulkInvitationDto: BulkEcosystemInvitationDto, userId: string): Promise<object> {
+      const payload = { bulkInvitationDto, userId };
+      return this.sendNats(this.serviceProxy, 'send-ecosystem-invitation', payload);
+  }
+
 
 }
diff --git a/apps/ecosystem/dtos/send-invitation.dto.ts b/apps/ecosystem/dtos/send-invitation.dto.ts
@@ -0,0 +1,12 @@
+import { ApiExtraModels } from '@nestjs/swagger';
+
+@ApiExtraModels()
+export class SendInvitationDto {
+    email: string;
+}
+
+@ApiExtraModels()
+export class BulkSendInvitationDto {
+    invitations: SendInvitationDto[];
+    ecosystemId: string;
+}
diff --git a/apps/ecosystem/enums/ecosystem.enum.ts b/apps/ecosystem/enums/ecosystem.enum.ts
@@ -6,4 +6,10 @@ export enum EcosystemRoles {
 
 export enum EcosystemOrgStatus {
     ACTIVE = 'ACTIVE'
+}
+
+export enum EcosystemInvitationStatus {
+    ACCEPTED = 'accepted',
+    REJECTED = 'rejected',
+    PENDING = 'pending'
 }
diff --git a/apps/ecosystem/src/ecosystem.controller.ts b/apps/ecosystem/src/ecosystem.controller.ts
@@ -3,6 +3,7 @@ import { Controller, Logger } from '@nestjs/common';
 import { MessagePattern } from '@nestjs/microservices';
 import { EcosystemService } from './ecosystem.service';
 import { Body } from '@nestjs/common';
+import { BulkSendInvitationDto } from '../dtos/send-invitation.dto';
 
 @Controller()
 export class EcosystemController {
@@ -39,5 +40,18 @@ export class EcosystemController {
   async getAllEcosystems(): Promise<object> {
     return this.ecosystemService.getAllEcosystem();
   }
+
+
+  /**
+   * 
+   * @param payload 
+   * @returns Sent ecosystem invitations status
+   */
+  @MessagePattern({ cmd: 'send-ecosystem-invitation' })
+  async createInvitation(
+    @Body() payload: { bulkInvitationDto: BulkSendInvitationDto; userId: string }
+    ): Promise<string> {
+    return this.ecosystemService.createInvitation(payload.bulkInvitationDto, payload.userId);
+  }
 
 }
diff --git a/apps/ecosystem/src/ecosystem.repository.ts b/apps/ecosystem/src/ecosystem.repository.ts
@@ -1,7 +1,8 @@
 import { Injectable, InternalServerErrorException, Logger } from '@nestjs/common';
 import { PrismaService } from '@credebl/prisma-service';
-import { ecosystem } from '@prisma/client';
-import {EcosystemOrgStatus, EcosystemRoles} from '../enums/ecosystem.enum';
+// eslint-disable-next-line camelcase
+import { ecosystem, ecosystem_invitations } from '@prisma/client';
+import {EcosystemInvitationStatus, EcosystemOrgStatus, EcosystemRoles} from '../enums/ecosystem.enum';
 // eslint-disable-next-line camelcase
 @Injectable()
 export class EcosystemRepository {

diff --git a/apps/ecosystem/src/ecosystem.service.ts b/apps/ecosystem/src/ecosystem.service.ts
@@ -57,4 +57,96 @@ export class EcosystemService {
       }
       return getAllEcosystemDetails;
     } 
+
+
+  /**
+   * 
+   * @param bulkInvitationDto 
+   * @param userId 
+   * @returns 
+   */
+  async createInvitation(bulkInvitationDto: BulkSendInvitationDto, userId: string): Promise<string> {
+    const { invitations, ecosystemId } = bulkInvitationDto;
+
+    try {
+      const ecosystemDetails = await this.ecosystemRepository.getEcosystemDetails(ecosystemId);
+
+      for (const invitation of invitations) {
+        const { email } = invitation;
+
+        const isInvitationExist = await this.checkInvitationExist(email, ecosystemId);
+
+        if (!isInvitationExist) {
+          await this.ecosystemRepository.createSendInvitation(email, ecosystemId, userId);
+
+          try {
+            await this.sendInviteEmailTemplate(email, ecosystemDetails.name);
+          } catch (error) {
+            throw new InternalServerErrorException(ResponseMessages.user.error.emailSend);
+          }
+        }
+      }
+      return ResponseMessages.ecosystem.success.createInvitation;
+    } catch (error) {
+      this.logger.error(`In send Invitation : ${JSON.stringify(error)}`);
+      throw new RpcException(error.response ? error.response : error);
+    }
+  } 
+
+
+  /**
+   * 
+   * @param email 
+   * @param ecosystemId 
+   * @returns Returns boolean status for invitation
+   */
+  async checkInvitationExist(
+    email: string,
+    ecosystemId: string
+  ): Promise<boolean> {
+    try {
+
+      const query = {
+        email,
+        ecosystemId
+      };
+
+      const invitations = await this.ecosystemRepository.getEcosystemInvitations(query);
+
+      if (0 < invitations.length) {
+        return true;
+      }
+      return false;
+    } catch (error) {
+      throw new RpcException(error.response ? error.response : error);
+    }
+  }
+
+  /**
+   * 
+   * @param email 
+   * @param ecosystemName 
+   * @returns Send invitation mail 
+   */
+  async sendInviteEmailTemplate(
+    email: string,
+    ecosystemName: string
+  ): Promise<boolean> {
+    const platformConfigData = await this.prisma.platform_config.findMany();
+
+    const urlEmailTemplate = new EcosystemInviteTemplate();
+    const emailData = new EmailDto();
+    emailData.emailFrom = platformConfigData[0].emailFrom;
+    emailData.emailTo = email;
+    emailData.emailSubject = `${process.env.PLATFORM_NAME} Platform: Invitation`;
+
+    emailData.emailHtml = await urlEmailTemplate.sendInviteEmailTemplate(email, ecosystemName);
+
+    //Email is sent to user for the verification through emailData
+    const isEmailSent = await sendEmail(emailData);
+
+    return isEmailSent;
+  }
+
+
 }
diff --git a/apps/ecosystem/templates/EcosystemInviteTemplate.ts b/apps/ecosystem/templates/EcosystemInviteTemplate.ts
@@ -0,0 +1,66 @@
+export class EcosystemInviteTemplate {
+
+    public sendInviteEmailTemplate(
+        email: string,
+        ecosystemName: string
+    ): string {
+
+        const validUrl = `${process.env.FRONT_END_URL}/authentication/sign-in`;
+
+        const message = `You have been invited to join the ecosystem so please log in and accept the ecosystem “INVITATION” and participate in the ecosystem`;
+        const year: number = new Date().getFullYear();
+
+        return `<!DOCTYPE html>
+            <html lang="en">
+            
+            <head>
+                <title></title>
+                <meta charset="UTF-8">
+                <meta name="viewport" content="width=device-width, initial-scale=1">
+            </head>
+            
+            <body style="margin: 0px; padding:0px; background-color:#F9F9F9;">
+                <div style="margin: auto; width: 40%; padding: 20px 30px; background-color: #FFFFFF; display:block; word-break: break-word;">
+
+                    <div style="font-family: Montserrat; font-style: normal; font-weight: 500;
+                    font-size: 15px; line-height: 24px;color: #5E5873;">
+                        <p style="margin-top:0px">
+                            Hello ${email},
+                        </p>
+                        <p>
+                        Congratulations!
+                        Your have been successfully invited to join.
+                          <ul style="color:#005EFF; padding-left:10px; font-family: Montserrat;font-style: normal;
+                        font-weight: normal;font-size: 14px;line-height: 21px;">
+                            <li>Ecosystem:  ${ecosystemName}</li>
+                        </ul>
+                        ${message}
+                        <ul style="color:#005EFF; padding-left:10px; font-family: Montserrat;font-style: normal;
+                        font-weight: normal;font-size: 14px;line-height: 21px;">
+                            <li>Platform Link: <a href="${validUrl}">${validUrl}</a></li>
+                        </ul>
+                        <div style="text-align: center; padding-bottom: 20px;">
+                            <a href="${validUrl}"
+                                style="padding: 10px 20px 10px 20px;color: #fff;background: #1F4EAD;border-radius: 5px;text-decoration: none;">
+                                INVITATION
+                            </a>
+                        </div>
+                        <p>In case you need any assistance to access your account, please contact <a href="https://credebl.in/"
+                                target="_blank">CREDEBL Platform</a>
+                        </p>
+                        <hr style="border-top:1px solid #e8e8e8" />
+                        <footer style="padding-top: 20px;">
+                            <p style="margin-top: 2px;">
+                                &reg; CREDEBL ${year}, Powered by Blockster Labs. All Rights Reserved.
+                            </p>
+                        </footer>
+                    </div>
+                </div>
+            </body>
+            
+            </html>`;
+
+    }
+
+
+}