diff --git a/src/common/database/prisma.lambda.service.ts b/src/common/database/prisma.lambda.service.ts new file mode 100644 index 0000000..0aa5b78 --- /dev/null +++ b/src/common/database/prisma.lambda.service.ts @@ -0,0 +1,22 @@ +import { PrismaClient } from '@prisma/client'; +import { PrismaPg } from '@prisma/adapter-pg'; + +const adapter = new PrismaPg({ + connectionString: process.env.DATABASE_URL!, +}); + +let prisma: PrismaClient; + +if (!(global as any).prisma) { + (global as any).prisma = new PrismaClient({ + adapter, + log: + process.env.NODE_ENV === 'dev' + ? ['query', 'info', 'warn', 'error'] + : ['error'], + }); +} + +prisma = (global as any).prisma; + +export const prismaClient = prisma; \ No newline at end of file diff --git a/src/common/database/prisma.module.ts b/src/common/database/prisma.module.ts index ee44123..b7dc0c2 100644 --- a/src/common/database/prisma.module.ts +++ b/src/common/database/prisma.module.ts @@ -1,5 +1,5 @@ import { Global, Module } from '@nestjs/common'; -import { PrismaService } from './prisma.service'; +import { PrismaService } from './prisma.lambda.service'; @Global() @Module({ diff --git a/src/common/database/prisma.service.ts b/src/common/database/prisma.service.ts index e891991..bb6565f 100644 --- a/src/common/database/prisma.service.ts +++ b/src/common/database/prisma.service.ts @@ -1,17 +1,8 @@ -import { Injectable, OnModuleInit, OnModuleDestroy, INestApplication } from '@nestjs/common'; +import { Injectable, OnModuleInit, OnModuleDestroy } from '@nestjs/common'; import { PrismaClient } from '@prisma/client'; -import { PrismaPg } from '@prisma/adapter-pg'; @Injectable() export class PrismaService extends PrismaClient implements OnModuleInit, OnModuleDestroy { - constructor() { - const adapter = new PrismaPg({ connectionString: process.env.DATABASE_URL }); - super({ - adapter, - log: process.env.NODE_ENV === 'dev' ? ['query', 'info', 'warn', 'error'] : ['error'], - }); - } - async onModuleInit() { await this.$connect(); } @@ -19,10 +10,4 @@ export class PrismaService extends PrismaClient implements OnModuleInit, OnModul async onModuleDestroy() { await this.$disconnect(); } - - async enableShutdownHooks(app: INestApplication) { - process.on('beforeExit', async () => { - await app.close(); - }); - } -} \ No newline at end of file +} diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/createActivityAndAllQuestionsEntry.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/createActivityAndAllQuestionsEntry.ts index e24bea3..da5fac1 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/createActivityAndAllQuestionsEntry.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/createActivityAndAllQuestionsEntry.ts @@ -4,13 +4,12 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler( async ( diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllActivityType.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllActivityType.ts index 2b816a2..e6839d0 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllActivityType.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllActivityType.ts @@ -1,14 +1,13 @@ import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; import { PrePopulateService } from '../../../../prepopulate/services/prepopulate.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); -const prePopulateService = new PrePopulateService(prismaService); +const hostService = new HostService(prismaClient); +const prePopulateService = new PrePopulateService(prismaClient); /** * Add suggestion handler for host applications diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllHostActivity.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllHostActivity.ts index fa441b1..0f67a78 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllHostActivity.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllHostActivity.ts @@ -1,14 +1,13 @@ import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); /** diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllPQQwithSubmittedAns.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllPQQwithSubmittedAns.ts index ad10e74..b37a024 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllPQQwithSubmittedAns.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/getAllPQQwithSubmittedAns.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; import { verifyMinglarAdminHostToken } from '../../../../../common/middlewares/jwt/authForMinglarAdminHost'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQScore.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQScore.ts index 173eb9b..154f15b 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQScore.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQScore.ts @@ -3,14 +3,13 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda'; import AWS from 'aws-sdk'; import Busboy from 'busboy'; import crypto from 'crypto'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prisma = new PrismaService(); -const hostService = new HostService(prisma); +const hostService = new HostService(prismaClient); const s3 = new AWS.S3({ region: config.aws.region }); diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_ByQuestionId.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_ByQuestionId.ts index 897a823..f8af885 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_ByQuestionId.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_ByQuestionId.ts @@ -1,12 +1,11 @@ import { verifyMinglarAdminHostToken } from '../../../../../common/middlewares/jwt/authForMinglarAdminHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, context?: Context diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_LastUpdatedQuestion.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_LastUpdatedQuestion.ts index d891ce4..80bd5b9 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_LastUpdatedQuestion.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/getPQQ_LastUpdatedQuestion.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, context?: Context diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/saveActivity_ForPQQ.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/saveActivity_ForPQQ.ts index 80d4c12..f8a648e 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/saveActivity_ForPQQ.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/saveActivity_ForPQQ.ts @@ -1,12 +1,11 @@ import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQAnswer.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQAnswer.ts index b74d084..ca76754 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQAnswer.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQAnswer.ts @@ -3,14 +3,13 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda'; import AWS from 'aws-sdk'; import Busboy from 'busboy'; import crypto from 'crypto'; -import { PrismaService } from '../../../../../common/database/prisma.service'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; -const prisma = new PrismaService(); -const hostService = new HostService(prisma); +const hostService = new HostService(prismaClient); const s3 = new AWS.S3({ region: config.aws.region }); diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQForReview.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQForReview.ts index d461bb9..df4c4a9 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQForReview.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQForReview.ts @@ -1,12 +1,11 @@ import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prisma = new PrismaService(); -const pqqService = new HostService(prisma); +const pqqService = new HostService(prismaClient); export const handler = safeHandler(async (event: APIGatewayProxyEvent): Promise => { try { diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQ_Answer.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQ_Answer.ts index 9e0cf0e..509635e 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQ_Answer.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/submitPQQ_Answer.ts @@ -3,14 +3,13 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda'; import AWS from 'aws-sdk'; import Busboy from 'busboy'; import crypto from 'crypto'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prisma = new PrismaService(); -const pqqService = new HostService(prisma); +const pqqService = new HostService(prismaClient); const s3 = new AWS.S3({ region: config.aws.region }); diff --git a/src/modules/host/handlers/Activity_Hub/OnBoarding/updateSuggestionAsReviewed.ts b/src/modules/host/handlers/Activity_Hub/OnBoarding/updateSuggestionAsReviewed.ts index d63f5ba..c71d66f 100644 --- a/src/modules/host/handlers/Activity_Hub/OnBoarding/updateSuggestionAsReviewed.ts +++ b/src/modules/host/handlers/Activity_Hub/OnBoarding/updateSuggestionAsReviewed.ts @@ -1,12 +1,11 @@ import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/host/handlers/Host_Admin/onboarding/acceptAggrement.ts b/src/modules/host/handlers/Host_Admin/onboarding/acceptAggrement.ts index 2aa1de4..500eec1 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/acceptAggrement.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/acceptAggrement.ts @@ -1,12 +1,11 @@ import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); /** * Add suggestion handler for host applications diff --git a/src/modules/host/handlers/Host_Admin/onboarding/createPassword.ts b/src/modules/host/handlers/Host_Admin/onboarding/createPassword.ts index c182f62..cdf3f79 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/createPassword.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/createPassword.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { HostService } from '../../../services/host.service'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/host/handlers/Host_Admin/onboarding/login.ts b/src/modules/host/handlers/Host_Admin/onboarding/login.ts index afc24d0..5577c6f 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/login.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/login.ts @@ -1,15 +1,13 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { HostService } from '../../../services/host.service'; import { TokenService } from '../../../services/token.service'; import { GetHostLoginResponseDTO } from '../../../dto/host.dto'; import ApiError from '../../../../../common/utils/helper/ApiError'; -import * as bcrypt from 'bcryptjs'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); -const tokenService = new TokenService(prismaService); +const hostService = new HostService(prismaClient); +const tokenService = new TokenService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, @@ -42,7 +40,7 @@ export const handler = safeHandler(async ( const generateTokenForHost = await tokenService.generateAuthToken( loginForHost.id - ); + ); if (!generateTokenForHost) { throw new ApiError(500, 'Failed to generate token'); diff --git a/src/modules/host/handlers/Host_Admin/onboarding/showSuggestion.ts b/src/modules/host/handlers/Host_Admin/onboarding/showSuggestion.ts index 65ff5ed..e43ca80 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/showSuggestion.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/showSuggestion.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { MinglarService } from '../../../../minglaradmin/services/minglar.service'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); /** * Get suggestions handler diff --git a/src/modules/host/handlers/Host_Admin/onboarding/signUp.ts b/src/modules/host/handlers/Host_Admin/onboarding/signUp.ts index bc2f2c8..63bef4d 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/signUp.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/signUp.ts @@ -1,6 +1,6 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import * as bcrypt from 'bcryptjs'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { ROLE } from '../../../../../common/utils/constants/common.constant'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; @@ -8,8 +8,7 @@ import { encryptUserId } from '../../../../../common/utils/helper/CodeGenerator' import { OtpGeneratorSixDigit } from '../../../../../common/utils/helper/OtpGenerator'; import { HostService } from '../../../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export async function generateHostRefNumber(tx: any) { const lastrecord = await tx.user.findFirst({ @@ -46,7 +45,7 @@ export const handler = safeHandler(async ( } // Use a single transaction for user creation/lookup and OTP storage - const transactionResult = await prismaService.$transaction(async (tx) => { + const transactionResult = await prismaClient.$transaction(async (tx) => { const user = await tx.user.findUnique({ where: { emailAddress: email }, select: { emailAddress: true, id: true, userPassword: true }, diff --git a/src/modules/host/handlers/Host_Admin/onboarding/submitCompanyDetails.ts b/src/modules/host/handlers/Host_Admin/onboarding/submitCompanyDetails.ts index a68c7eb..de59512 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/submitCompanyDetails.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/submitCompanyDetails.ts @@ -3,7 +3,7 @@ import config from '../../../../../config/config'; import { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda'; import AWS from 'aws-sdk'; import Busboy from 'busboy'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; @@ -15,8 +15,7 @@ import { import { HostService } from '../../../services/host.service'; import { sendEmailToAM, sendEmailToMinglarAdmin } from '../../../services/sendHostResubmitEmailToAM.service'; -const prisma = new PrismaService(); -const hostService = new HostService(prisma); +const hostService = new HostService(prismaClient); const s3 = new AWS.S3({ region: config.aws.region, @@ -156,7 +155,7 @@ export const handler = safeHandler(async (event: APIGatewayProxyEvent): Promise< if (userProfileRaw) { const { firstName, lastName, mobileNumber } = userProfileRaw; - await prisma.user.update({ + await prismaClient.user.update({ where: { id: userInfo.id }, data: { ...(firstName && { firstName }), @@ -250,7 +249,7 @@ export const handler = safeHandler(async (event: APIGatewayProxyEvent): Promise< await deleteFromS3(s3Key); // Delete from DB - await prisma.hostDocuments.delete({ + await prismaClient.hostDocuments.delete({ where: { id } }); @@ -277,7 +276,7 @@ export const handler = safeHandler(async (event: APIGatewayProxyEvent): Promise< await deleteFromS3(s3Key); // Delete DB - await prisma.hostParenetDocuments.delete({ + await prismaClient.hostParenetDocuments.delete({ where: { id } }); diff --git a/src/modules/host/handlers/Host_Admin/onboarding/updateBankDetails.ts b/src/modules/host/handlers/Host_Admin/onboarding/updateBankDetails.ts index 6b23ce6..edfabfe 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/updateBankDetails.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/updateBankDetails.ts @@ -1,13 +1,12 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { HostService } from '../../../services/host.service'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { verifyHostToken } from '../../../../../common/middlewares/jwt/authForHost'; import { hostBankDetailsSchema } from '../../../../../common/utils/validation/host/addPaymentDetails.validation'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/host/handlers/Host_Admin/onboarding/verifyOTP.ts b/src/modules/host/handlers/Host_Admin/onboarding/verifyOTP.ts index a079c53..eb4f9cf 100644 --- a/src/modules/host/handlers/Host_Admin/onboarding/verifyOTP.ts +++ b/src/modules/host/handlers/Host_Admin/onboarding/verifyOTP.ts @@ -1,13 +1,12 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { HostService } from '../../../services/host.service'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { TokenService } from '../../../services/token.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); -const tokenService = new TokenService(prismaService); +const hostService = new HostService(prismaClient); +const tokenService = new TokenService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/host/handlers/getStepper.ts b/src/modules/host/handlers/getStepper.ts index fae6b65..38e3b63 100644 --- a/src/modules/host/handlers/getStepper.ts +++ b/src/modules/host/handlers/getStepper.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import ApiError from '../../../common/utils/helper/ApiError'; import { verifyHostToken } from '../../../common/middlewares/jwt/authForHost'; import { HostService } from '../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, context?: Context diff --git a/src/modules/host/handlers/getbyidhandler.ts b/src/modules/host/handlers/getbyidhandler.ts index 3fc81fb..8b58c19 100644 --- a/src/modules/host/handlers/getbyidhandler.ts +++ b/src/modules/host/handlers/getbyidhandler.ts @@ -1,12 +1,11 @@ import { verifyMinglarAdminHostToken } from '../../../common/middlewares/jwt/authForMinglarAdminHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { HostService } from '../services/host.service'; -const prismaService = new PrismaService(); -const hostService = new HostService(prismaService); +const hostService = new HostService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, @@ -14,7 +13,7 @@ export const handler = safeHandler(async ( ): Promise => { // Get host ID from path parameters const token = event.headers['x-auth-token'] || event.headers['X-Auth-Token'] - if(!token) { + if (!token) { throw new ApiError(400, 'This is a protected route. Please provide a valid token.'); } diff --git a/src/modules/host/handlers/host.ts b/src/modules/host/handlers/host.ts index 9b100cd..4c26c96 100644 --- a/src/modules/host/handlers/host.ts +++ b/src/modules/host/handlers/host.ts @@ -1,8 +1,8 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaClient } from '@prisma/client'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; -const prisma = new PrismaClient(); +const prisma = prismaClient; export const handler = safeHandler(async ( event: APIGatewayProxyEvent @@ -11,7 +11,6 @@ export const handler = safeHandler(async ( const result = await prisma.hostHeader.findMany({ select: { hostParent: true, - hostRefNumber: true, hostStatusDisplay: true, accountManager: true, }, diff --git a/src/modules/host/handlers/resendOtp.ts b/src/modules/host/handlers/resendOtp.ts index 91b8f63..3950735 100644 --- a/src/modules/host/handlers/resendOtp.ts +++ b/src/modules/host/handlers/resendOtp.ts @@ -1,11 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult } from "aws-lambda"; -import { PrismaService } from "../../../common/database/prisma.service"; +import { prismaClient } from "../../../common/database/prisma.lambda.service"; import { safeHandler } from "../../../common/utils/handlers/safeHandler"; import ApiError from "../../../common/utils/helper/ApiError"; import { resendOtpHelper } from "../../../common/utils/helper/resendOtpHelper"; import { resendOtpEmail } from "../services/resendOTPEmail.service"; -const prisma = new PrismaService(); +const prisma = prismaClient; // allowed purposes const ALLOWED_PURPOSES = ["Register", "Login", "ForgotPassword"] as const; diff --git a/src/modules/host/services/host.service.ts b/src/modules/host/services/host.service.ts index 01fe64d..d7f269e 100644 --- a/src/modules/host/services/host.service.ts +++ b/src/modules/host/services/host.service.ts @@ -1,6 +1,5 @@ // src/modules/host/services/host.service.ts import { Injectable } from '@nestjs/common'; -import { PrismaService } from '../../../common/database/prisma.service'; import { AddPaymentDetailsDTO, CreateHostDto, @@ -9,28 +8,29 @@ import { import * as bcrypt from 'bcryptjs'; import ApiError from '../../../common/utils/helper/ApiError'; import { User } from '@prisma/client'; +import { PrismaClient } from '@prisma/client'; import { z } from 'zod'; -import { hostCompanyDetailsSchema } from '@/common/utils/validation/host/hostCompanyDetails.validation'; +import { hostCompanyDetailsSchema } from '../../../common/utils/validation/host/hostCompanyDetails.validation'; import { ACTIVITY_AM_DISPLAY_STATUS, ACTIVITY_AM_INTERNAL_STATUS, ACTIVITY_DISPLAY_STATUS, ACTIVITY_INTERNAL_STATUS, HOST_STATUS_DISPLAY, HOST_STATUS_INTERNAL, STEPPER, -} from '@/common/utils/constants/host.constant'; +} from '../../../common/utils/constants/host.constant'; import { ACTIVITY_TRACK_STATUS, ACTIVITY_TRACK_TYPE, MINGLAR_STATUS_DISPLAY, MINGLAR_STATUS_INTERNAL, -} from '@/common/utils/constants/minglar.constant'; +} from '../../../common/utils/constants/minglar.constant'; import { ROLE, ROLE_NAME, USER_STATUS, -} from '@/common/utils/constants/common.constant'; -import { getPresignedUrl } from '@/common/middlewares/aws/getPreSignedUrl'; -import config from '@/config/config'; +} from '../../../common/utils/constants/common.constant'; +import { getPresignedUrl } from '../../../common/middlewares/aws/getPreSignedUrl'; +import config from '../../../config/config'; type HostCompanyDetailsInput = z.infer; @@ -63,7 +63,7 @@ const bucket = config.aws.bucketName; @Injectable() export class HostService { - constructor(private prisma: PrismaService) { } + constructor(private prisma: PrismaClient) { } async createHost(data: CreateHostDto) { return this.prisma.user.create({ data }); @@ -298,6 +298,7 @@ export class HostService { userStatus: true } }); + console.log(existingUser, "ajsbfkjd") if (!existingUser) { throw new ApiError(404, 'User not found'); @@ -1786,6 +1787,7 @@ export class HostService { isActive: true, }, select: { + id: true, comments: true, pqqAnswerXid: true, pqqQuestions: { @@ -1851,15 +1853,20 @@ export class HostService { const sub = q.pqqSubCategories; const cat = sub.category; + // 1️⃣ Category level // 1️⃣ Category level if (!grouped[cat.id]) { grouped[cat.id] = { id: cat.id, categoryName: cat.categoryName, displayOrder: cat.displayOrder, + activityPqqHeaderId: item.id, // ✅ Added to match AM response pqqsubCategories: [] }; + } else if (!grouped[cat.id].activityPqqHeaderId) { + grouped[cat.id].activityPqqHeaderId = item.id; // Ensures it's set if missing } + const category = grouped[cat.id]; // 2️⃣ Subcategory level diff --git a/src/modules/host/services/token.service.ts b/src/modules/host/services/token.service.ts index bef0729..d4f350b 100644 --- a/src/modules/host/services/token.service.ts +++ b/src/modules/host/services/token.service.ts @@ -1,10 +1,10 @@ -import { PrismaService } from "../../../common/database/prisma.service"; +import { PrismaClient } from '@prisma/client'; import jwt, { JwtPayload } from "jsonwebtoken"; import moment from "moment"; import config from "../../../config/config"; export class TokenService { - constructor(private readonly prisma: PrismaService = new PrismaService()) {} + constructor(private prisma: PrismaClient) { } private generateToken( user_xid: number, diff --git a/src/modules/minglaradmin/handlers/createPassword.ts b/src/modules/minglaradmin/handlers/createPassword.ts index c5e77c4..bebd923 100644 --- a/src/modules/minglaradmin/handlers/createPassword.ts +++ b/src/modules/minglaradmin/handlers/createPassword.ts @@ -1,12 +1,11 @@ import { verifyMinglarAdminToken } from '../../../common/middlewares/jwt/authForMinglarAdmin'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { MinglarService } from '../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/minglaradmin/handlers/getAMDetail_ById.ts b/src/modules/minglaradmin/handlers/getAMDetail_ById.ts index dddfc3a..591a609 100644 --- a/src/modules/minglaradmin/handlers/getAMDetail_ById.ts +++ b/src/modules/minglaradmin/handlers/getAMDetail_ById.ts @@ -3,14 +3,13 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { MinglarService } from '../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); /** * Get all host applications handler diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/acceptHostApplication.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/acceptHostApplication.ts index a7067d9..264949e 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/acceptHostApplication.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/acceptHostApplication.ts @@ -1,13 +1,12 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { sendEmailToHostForApprovedApplication } from '../../../services/approvalMailtoHost.service'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface AddSuggestionBody { hostXid: number; diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/acceptPQByAM.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/acceptPQByAM.ts index 13b207c..f5ff82a 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/acceptPQByAM.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/acceptPQByAM.ts @@ -1,12 +1,11 @@ import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { MinglarService } from '../../../services/minglar.service'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface Body { activityId: number; diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/addPQQSuggestion.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/addPQQSuggestion.ts index 01e64b6..ae153a3 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/addPQQSuggestion.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/addPQQSuggestion.ts @@ -1,13 +1,12 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; // import { HOST_SUGGESTION_TITLES } from '../../../../../common/utils/constants/minglar.constant'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface AddSuggestionBody { title: string; @@ -34,7 +33,7 @@ export const handler = safeHandler(async ( const userInfo = await verifyMinglarAdminToken(token); // Get user details - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true } }); diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/addSuggestion.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/addSuggestion.ts index 742fe9e..b759a64 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/addSuggestion.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/addSuggestion.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface AddSuggestionBody { hostXid: number; @@ -34,7 +33,7 @@ export const handler = safeHandler(async ( const userInfo = await verifyMinglarAdminToken(token); // Get user details - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true } }); diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/getAllHostApplicationForAM.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/getAllHostApplicationForAM.ts index 3c858ea..e8a38f4 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/getAllHostApplicationForAM.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/getAllHostApplicationForAM.ts @@ -1,13 +1,12 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); /** * Get all host applications handler with pagination @@ -26,7 +25,7 @@ export const handler = safeHandler(async ( const userInfo = await verifyMinglarAdminToken(token); // Get user details including role - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true } }); diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/getByIdHostDetails.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/getByIdHostDetails.ts index 19e371a..2c392e9 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/getByIdHostDetails.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/getByIdHostDetails.ts @@ -1,12 +1,11 @@ -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/rejectHostApplicationAM.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/rejectHostApplicationAM.ts index 5748a70..6b9eacb 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/rejectHostApplicationAM.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/rejectHostApplicationAM.ts @@ -1,13 +1,12 @@ import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; import { sendAMRejectionMailtoHost } from '../../../services/rejectionMailtoHost.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface AddSuggestionBody { hostXid: number; diff --git a/src/modules/minglaradmin/handlers/hosthub/hosts/rejectPQQbyAM.ts b/src/modules/minglaradmin/handlers/hosthub/hosts/rejectPQQbyAM.ts index fec946a..322c1f8 100644 --- a/src/modules/minglaradmin/handlers/hosthub/hosts/rejectPQQbyAM.ts +++ b/src/modules/minglaradmin/handlers/hosthub/hosts/rejectPQQbyAM.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface Body { activityId: number; diff --git a/src/modules/minglaradmin/handlers/hosthub/onboarding/assignAM.ts b/src/modules/minglaradmin/handlers/hosthub/onboarding/assignAM.ts index cdad011..972b923 100644 --- a/src/modules/minglaradmin/handlers/hosthub/onboarding/assignAM.ts +++ b/src/modules/minglaradmin/handlers/hosthub/onboarding/assignAM.ts @@ -3,14 +3,13 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyOnlyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForOnlyMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface assignAMToHostBody { host_xid: number; @@ -40,7 +39,7 @@ export const handler = safeHandler( const userInfo = await verifyOnlyMinglarAdminToken(token); // Get user details including role - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true }, }); diff --git a/src/modules/minglaradmin/handlers/hosthub/onboarding/editAgreementDetailsAndAccept.ts b/src/modules/minglaradmin/handlers/hosthub/onboarding/editAgreementDetailsAndAccept.ts index 528e300..f49f467 100644 --- a/src/modules/minglaradmin/handlers/hosthub/onboarding/editAgreementDetailsAndAccept.ts +++ b/src/modules/minglaradmin/handlers/hosthub/onboarding/editAgreementDetailsAndAccept.ts @@ -1,12 +1,11 @@ import { verifyOnlyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForOnlyMinglarAdmin'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface assignAMToHostBody { host_xid: number, @@ -34,7 +33,7 @@ export const handler = safeHandler(async ( const userInfo = await verifyOnlyMinglarAdminToken(token); // Get user details including role - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true } }); diff --git a/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllActivityOfHost.ts b/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllActivityOfHost.ts index 9571c2e..baa8504 100644 --- a/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllActivityOfHost.ts +++ b/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllActivityOfHost.ts @@ -1,15 +1,14 @@ import { verifyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForMinglarAdmin'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { PrePopulateService } from '../../../../prepopulate/services/prepopulate.service'; import { MinglarService } from '../../../services/minglar.service'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); -const prePopulateService = new PrePopulateService(prismaService); +const minglarService = new MinglarService(prismaClient); +const prePopulateService = new PrePopulateService(prismaClient); /** * Add suggestion handler for host applications diff --git a/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllOnboardingHosts.ts b/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllOnboardingHosts.ts index 2efc04f..351aef1 100644 --- a/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllOnboardingHosts.ts +++ b/src/modules/minglaradmin/handlers/hosthub/onboarding/getAllOnboardingHosts.ts @@ -4,14 +4,13 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); /** * Get all host applications handler @@ -36,7 +35,7 @@ export const handler = safeHandler( const userInfo = await verifyOnlyMinglarAdminToken(token); // Get user details including role - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true }, }); diff --git a/src/modules/minglaradmin/handlers/hosthub/onboarding/getOnboardingNewApplications.ts b/src/modules/minglaradmin/handlers/hosthub/onboarding/getOnboardingNewApplications.ts index d309627..ab95c1c 100644 --- a/src/modules/minglaradmin/handlers/hosthub/onboarding/getOnboardingNewApplications.ts +++ b/src/modules/minglaradmin/handlers/hosthub/onboarding/getOnboardingNewApplications.ts @@ -3,15 +3,14 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyOnlyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForOnlyMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); /** * Get all NEW host applications handler @@ -36,7 +35,7 @@ export const handler = safeHandler( const userInfo = await verifyOnlyMinglarAdminToken(token); // Get user details including role - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { id: userInfo.id }, select: { id: true, roleXid: true }, }); diff --git a/src/modules/minglaradmin/handlers/hosthub/onboarding/rejectHostApplication.ts b/src/modules/minglaradmin/handlers/hosthub/onboarding/rejectHostApplication.ts index 0f0e7fc..a1b145c 100644 --- a/src/modules/minglaradmin/handlers/hosthub/onboarding/rejectHostApplication.ts +++ b/src/modules/minglaradmin/handlers/hosthub/onboarding/rejectHostApplication.ts @@ -1,13 +1,12 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { verifyOnlyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForOnlyMinglarAdmin'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; import { sendEmailToHostForRejectedApplication } from '../../../services/rejectionMailtoHost.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface AddSuggestionBody { hostXid: number; diff --git a/src/modules/minglaradmin/handlers/hosthub/pqp/getAllPQPDetailsForAM.ts b/src/modules/minglaradmin/handlers/hosthub/pqp/getAllPQPDetailsForAM.ts index d41f86c..f541235 100644 --- a/src/modules/minglaradmin/handlers/hosthub/pqp/getAllPQPDetailsForAM.ts +++ b/src/modules/minglaradmin/handlers/hosthub/pqp/getAllPQPDetailsForAM.ts @@ -1,12 +1,11 @@ -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import { MinglarService } from '../../../services/minglar.service'; import { verifyMinglarAdminHostToken } from '../../../../../common/middlewares/jwt/authForMinglarAdminHost'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/minglaradmin/handlers/loginForMinglar.ts b/src/modules/minglaradmin/handlers/loginForMinglar.ts index f16ffd4..0db40c6 100644 --- a/src/modules/minglaradmin/handlers/loginForMinglar.ts +++ b/src/modules/minglaradmin/handlers/loginForMinglar.ts @@ -1,14 +1,13 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { GetMinglarLoginResponseDTO } from '../dto/minglar.dto'; import { MinglarService } from '../services/minglar.service'; import { TokenService } from "../services/token.service"; -const prismaService = new PrismaService(); -const minglarSerivce = new MinglarService(prismaService); -const tokenService = new TokenService(prismaService); +const minglarSerivce = new MinglarService(prismaClient); +const tokenService = new TokenService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/minglaradmin/handlers/prepopulateRole.ts b/src/modules/minglaradmin/handlers/prepopulateRole.ts index f6ed0db..5be3d9e 100644 --- a/src/modules/minglaradmin/handlers/prepopulateRole.ts +++ b/src/modules/minglaradmin/handlers/prepopulateRole.ts @@ -3,13 +3,13 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../common/middlewares/jwt/authForMinglarAdmin'; import { ROLE } from '../../../common/utils/constants/common.constant'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; -const prismaService = new PrismaService(); +const prismaService = prismaClient; export const handler = safeHandler( async ( event: APIGatewayProxyEvent, diff --git a/src/modules/minglaradmin/handlers/registration.ts b/src/modules/minglaradmin/handlers/registration.ts index f7e4ba5..cdf943b 100644 --- a/src/modules/minglaradmin/handlers/registration.ts +++ b/src/modules/minglaradmin/handlers/registration.ts @@ -1,13 +1,12 @@ import { ROLE, USER_STATUS } from '../../../common/utils/constants/common.constant'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { generateOtpHelper } from '../../../common/utils/helper/sendOtp'; import { MinglarService } from './../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, @@ -28,7 +27,7 @@ export const handler = safeHandler(async ( throw new ApiError(400, 'Email is required'); } - const user = await prismaService.user.findUnique({ + const user = await prismaClient.user.findUnique({ where: { emailAddress: email, isActive: true, userStatus: USER_STATUS.INVITED }, select: { emailAddress: true, id: true, userPassword: true, roleXid: true }, }); @@ -54,7 +53,7 @@ export const handler = safeHandler(async ( } const otpResult = await generateOtpHelper( - prismaService, // ⭐ pass Prisma from here + prismaClient, // ⭐ pass Prisma from here Number(newUser?.id), newUser?.emailAddress, 'Register', diff --git a/src/modules/minglaradmin/handlers/settings/teammates/getAllCoadminAndAM.ts b/src/modules/minglaradmin/handlers/settings/teammates/getAllCoadminAndAM.ts index 3092bc1..d153737 100644 --- a/src/modules/minglaradmin/handlers/settings/teammates/getAllCoadminAndAM.ts +++ b/src/modules/minglaradmin/handlers/settings/teammates/getAllCoadminAndAM.ts @@ -1,12 +1,11 @@ import { verifyOnlyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForOnlyMinglarAdmin'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitationDetails.ts b/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitationDetails.ts index 5a114f3..2eeb17d 100644 --- a/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitationDetails.ts +++ b/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitationDetails.ts @@ -4,14 +4,13 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler( async ( diff --git a/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitedCoadminAndAM.ts b/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitedCoadminAndAM.ts index 26b2f68..289162a 100644 --- a/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitedCoadminAndAM.ts +++ b/src/modules/minglaradmin/handlers/settings/teammates/getAllInvitedCoadminAndAM.ts @@ -4,14 +4,13 @@ import { APIGatewayProxyResult, Context, } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; import { MinglarService } from '../../../services/minglar.service'; import { paginationService } from '../../../../../common/utils/pagination/pagination.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); export const handler = safeHandler( async ( diff --git a/src/modules/minglaradmin/handlers/settings/teammates/inviteTeammate.ts b/src/modules/minglaradmin/handlers/settings/teammates/inviteTeammate.ts index b285571..63eaeec 100644 --- a/src/modules/minglaradmin/handlers/settings/teammates/inviteTeammate.ts +++ b/src/modules/minglaradmin/handlers/settings/teammates/inviteTeammate.ts @@ -1,6 +1,6 @@ import { verifyOnlyMinglarAdminToken } from '../../../../../common/middlewares/jwt/authForOnlyMinglarAdmin'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../../../common/database/prisma.service'; +import { prismaClient } from '../../../../../common/database/prisma.lambda.service'; import { ROLE } from '../../../../../common/utils/constants/common.constant'; import { safeHandler } from '../../../../../common/utils/handlers/safeHandler'; import ApiError from '../../../../../common/utils/helper/ApiError'; @@ -8,8 +8,7 @@ import { sendInvitationEmailForMinglarAdmin } from '../../../services/inviteTeam import { MinglarService } from '../../../services/minglar.service'; import config from '../../../../../config/config'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); interface InviteTeammateBody { emailAddress: string; diff --git a/src/modules/minglaradmin/handlers/updateProfile.ts b/src/modules/minglaradmin/handlers/updateProfile.ts index 8d5194b..667a985 100644 --- a/src/modules/minglaradmin/handlers/updateProfile.ts +++ b/src/modules/minglaradmin/handlers/updateProfile.ts @@ -2,15 +2,14 @@ import config from '../../../config/config'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; import AWS from 'aws-sdk'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminToken } from '../../../common/middlewares/jwt/authForMinglarAdmin'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { parseJsonField, parseMultipartFormData } from '../../../common/utils/helper/parseMultipartFormData'; import { MinglarService } from '../services/minglar.service'; -const prismaService = new PrismaService(); -const minglarService = new MinglarService(prismaService); +const minglarService = new MinglarService(prismaClient); const s3 = new AWS.S3({ region: config.aws.region, diff --git a/src/modules/minglaradmin/services/amNotification.service.ts b/src/modules/minglaradmin/services/amNotification.service.ts index 33e4c43..d38bf39 100644 --- a/src/modules/minglaradmin/services/amNotification.service.ts +++ b/src/modules/minglaradmin/services/amNotification.service.ts @@ -1,5 +1,5 @@ import { Injectable } from '@nestjs/common'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { PrismaService } from '../../../common/database/prisma.lambda.service'; import { sendAMEmailForHostAssign } from './AMEmail.service'; @Injectable() diff --git a/src/modules/minglaradmin/services/minglar.service.ts b/src/modules/minglaradmin/services/minglar.service.ts index 8ce3c93..3ca7c01 100644 --- a/src/modules/minglaradmin/services/minglar.service.ts +++ b/src/modules/minglaradmin/services/minglar.service.ts @@ -26,6 +26,7 @@ import { Injectable } from '@nestjs/common'; import { User } from '@prisma/client'; import * as bcrypt from 'bcryptjs'; import { PrismaService } from '../../../common/database/prisma.service'; +import { PrismaClient } from '@prisma/client'; import ApiError from '../../../common/utils/helper/ApiError'; import { CreateMinglarDto, UpdateMinglarDto } from '../dto/minglar.dto'; import { sendAMEmailForHostAssign } from './AMEmail.service'; @@ -34,7 +35,7 @@ const bucket = config.aws.bucketName; @Injectable() export class MinglarService { - constructor(private prisma: PrismaService) { } + constructor(private prisma: PrismaService | PrismaClient) { } async createPassword(user_xid: number, password: string): Promise { // Find user by id @@ -261,7 +262,6 @@ export class MinglarService { const whereClause: any = { isActive: true, activityInternalStatus: { notIn: [ACTIVITY_INTERNAL_STATUS.DRAFT_PQ] }, - activityInternalStatus: { notIn: [ACTIVITY_INTERNAL_STATUS.DRAFT_PQ] }, ...(hostXid ? { hostXid } : {}), }; diff --git a/src/modules/minglaradmin/services/token.service.ts b/src/modules/minglaradmin/services/token.service.ts index bef0729..d4f350b 100644 --- a/src/modules/minglaradmin/services/token.service.ts +++ b/src/modules/minglaradmin/services/token.service.ts @@ -1,10 +1,10 @@ -import { PrismaService } from "../../../common/database/prisma.service"; +import { PrismaClient } from '@prisma/client'; import jwt, { JwtPayload } from "jsonwebtoken"; import moment from "moment"; import config from "../../../config/config"; export class TokenService { - constructor(private readonly prisma: PrismaService = new PrismaService()) {} + constructor(private prisma: PrismaClient) { } private generateToken( user_xid: number, diff --git a/src/modules/prepopulate/handlers/getAllBankDetails.ts b/src/modules/prepopulate/handlers/getAllBankDetails.ts index 9f1016f..62228e8 100644 --- a/src/modules/prepopulate/handlers/getAllBankDetails.ts +++ b/src/modules/prepopulate/handlers/getAllBankDetails.ts @@ -1,12 +1,11 @@ import { verifyMinglarAdminHostToken } from '../../../common/middlewares/jwt/authForMinglarAdminHost'; import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { PrePopulateService } from '../services/prepopulate.service'; -const prismaService = new PrismaService(); -const prePopulateService = new PrePopulateService(prismaService); +const prePopulateService = new PrePopulateService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/prepopulate/handlers/getAllDocTypeWithCountryState.ts b/src/modules/prepopulate/handlers/getAllDocTypeWithCountryState.ts index cbc950d..75e7431 100644 --- a/src/modules/prepopulate/handlers/getAllDocTypeWithCountryState.ts +++ b/src/modules/prepopulate/handlers/getAllDocTypeWithCountryState.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminHostToken } from '../../../common/middlewares/jwt/authForMinglarAdminHost'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { PrePopulateService } from '../services/prepopulate.service'; -const prismaService = new PrismaService(); -const prePopulateService = new PrePopulateService(prismaService); +const prePopulateService = new PrePopulateService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/prepopulate/handlers/getAllFrequencies.ts b/src/modules/prepopulate/handlers/getAllFrequencies.ts index f26594b..383cafc 100644 --- a/src/modules/prepopulate/handlers/getAllFrequencies.ts +++ b/src/modules/prepopulate/handlers/getAllFrequencies.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminHostToken } from '../../../common/middlewares/jwt/authForMinglarAdminHost'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { PrePopulateService } from '../services/prepopulate.service'; -const prismaService = new PrismaService(); -const prePopulateService = new PrePopulateService(prismaService); +const prePopulateService = new PrePopulateService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/prepopulate/handlers/getAllPQQQuesWithAns.ts b/src/modules/prepopulate/handlers/getAllPQQQuesWithAns.ts index 4169c10..c9c7852 100644 --- a/src/modules/prepopulate/handlers/getAllPQQQuesWithAns.ts +++ b/src/modules/prepopulate/handlers/getAllPQQQuesWithAns.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from 'aws-lambda'; -import { PrismaService } from '../../../common/database/prisma.service'; +import { prismaClient } from '../../../common/database/prisma.lambda.service'; import { verifyMinglarAdminHostToken } from '../../../common/middlewares/jwt/authForMinglarAdminHost'; import { safeHandler } from '../../../common/utils/handlers/safeHandler'; import ApiError from '../../../common/utils/helper/ApiError'; import { PrePopulateService } from '../services/prepopulate.service'; -const prismaService = new PrismaService(); -const prePopulateService = new PrePopulateService(prismaService); +const prePopulateService = new PrePopulateService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/prepopulate/handlers/getBranchByBank.ts b/src/modules/prepopulate/handlers/getBranchByBank.ts index 9e6bcaf..09f8e50 100644 --- a/src/modules/prepopulate/handlers/getBranchByBank.ts +++ b/src/modules/prepopulate/handlers/getBranchByBank.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from "aws-lambda"; -import { PrismaService } from "../../../common/database/prisma.service"; +import { prismaClient } from "../../../common/database/prisma.lambda.service"; import { verifyMinglarAdminHostToken } from "../../../common/middlewares/jwt/authForMinglarAdminHost"; import { safeHandler } from "../../../common/utils/handlers/safeHandler"; import ApiError from "../../../common/utils/helper/ApiError"; import { PrePopulateService } from "../services/prepopulate.service"; -const prismaService = new PrismaService(); -const prePopulateService = new PrePopulateService(prismaService); +const prePopulateService = new PrePopulateService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/prepopulate/handlers/getCityByState.ts b/src/modules/prepopulate/handlers/getCityByState.ts index 813ef95..66515f1 100644 --- a/src/modules/prepopulate/handlers/getCityByState.ts +++ b/src/modules/prepopulate/handlers/getCityByState.ts @@ -1,12 +1,11 @@ import { APIGatewayProxyEvent, APIGatewayProxyResult, Context } from "aws-lambda"; -import { PrismaService } from "../../../common/database/prisma.service"; +import { prismaClient } from "../../../common/database/prisma.lambda.service"; import { verifyMinglarAdminHostToken } from "../../../common/middlewares/jwt/authForMinglarAdminHost"; import { safeHandler } from "../../../common/utils/handlers/safeHandler"; import ApiError from "../../../common/utils/helper/ApiError"; import { PrePopulateService } from "../services/prepopulate.service"; -const prismaService = new PrismaService(); -const prePopulateService = new PrePopulateService(prismaService); +const prePopulateService = new PrePopulateService(prismaClient); export const handler = safeHandler(async ( event: APIGatewayProxyEvent, diff --git a/src/modules/prepopulate/services/prepopulate.service.ts b/src/modules/prepopulate/services/prepopulate.service.ts index f8dbccd..b62e2ae 100644 --- a/src/modules/prepopulate/services/prepopulate.service.ts +++ b/src/modules/prepopulate/services/prepopulate.service.ts @@ -1,9 +1,8 @@ import { Injectable } from '@nestjs/common'; -import { PrismaService } from '../../../common/database/prisma.service'; - +import { PrismaClient } from '@prisma/client'; @Injectable() export class PrePopulateService { - constructor(private prisma: PrismaService) { } + constructor(private prisma: PrismaClient) { } async getAllBankDetails() { return await this.prisma.banks.findMany({