Merge pull request #128 from topcoder-platform/pm-2539

chore(PM-2539): added timeout for prisma service

Author: hentrymartin

.circleci/config.yml

@@ -77,6 +77,7 @@ workflows:
                               - feat/ai-workflows
                               - pm-1955_2
                               - re-try-failed-jobs
+                              - pm-2539
 
 
             - 'build-prod':

.env.sample

@@ -73,3 +73,5 @@ SENDGRID_ACCEPT_REVIEW_APPLICATION="d-2de72880bd69499e9c16369398d34bb9"
 SENDGRID_REJECT_REVIEW_APPLICATION="d-82ed74e778e84d8c9bc02eeda0f44b5e"
 # For pulling payment details (used by platform-ui)
 FINANCE_DB_URL=
+#Prisma timeout
+REVIEW_SERVICE_PRISMA_TIMEOUT=10000

src/shared/modules/global/challenge-prisma.service.ts

@@ -1,6 +1,7 @@
 import { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common';
 import { PrismaClient, Prisma } from '@prisma/client';
 import { LoggerService } from './logger.service';
+import { Utils } from './utils.service';
 
 @Injectable()
 export class ChallengePrismaService
@@ -11,6 +12,7 @@ export class ChallengePrismaService
 
   constructor() {
     super({
+      ...Utils.getPrismaTimeout(),
       log: [
         { level: 'query', emit: 'event' },
         { level: 'info', emit: 'event' },

src/shared/modules/global/member-prisma.service.ts

@@ -1,6 +1,7 @@
 import { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common';
 import { PrismaClient, Prisma } from '@prisma/client-member';
 import { LoggerService } from './logger.service';
+import { Utils } from './utils.service';
 
 @Injectable()
 export class MemberPrismaService
@@ -11,6 +12,7 @@ export class MemberPrismaService
 
   constructor() {
     super({
+      ...Utils.getPrismaTimeout(),
       log: [
         { level: 'query', emit: 'event' },
         { level: 'info', emit: 'event' },

src/shared/modules/global/prisma.service.ts

@@ -3,6 +3,7 @@ import { PrismaClient, Prisma } from '@prisma/client';
 import { LoggerService } from './logger.service';
 import { PrismaErrorService } from './prisma-error.service';
 import { getStore } from 'src/shared/request/requestStore';
+import { Utils } from './utils.service';
 
 enum auditField {
   createdBy = 'createdBy',
@@ -197,6 +198,7 @@ export class PrismaService
     const schema = process.env.POSTGRES_SCHEMA || 'public';
 
     super({
+      ...Utils.getPrismaTimeout(),
       log: [
         { level: 'query', emit: 'event' },
         { level: 'info', emit: 'event' },

src/shared/modules/global/resource-prisma.service.ts

@@ -1,6 +1,7 @@
 import { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common';
 import { PrismaClient, Prisma } from '@prisma/client-resource';
 import { LoggerService } from './logger.service';
+import { Utils } from './utils.service';
 
 @Injectable()
 export class ResourcePrismaService
@@ -11,6 +12,7 @@ export class ResourcePrismaService
 
   constructor() {
     super({
+      ...Utils.getPrismaTimeout(),
       log: [
         { level: 'query', emit: 'event' },
         { level: 'info', emit: 'event' },

src/shared/modules/global/utils.service.ts

@@ -4,4 +4,14 @@ export class Utils {
   static bigIntToNumber(t) {
     return t ? Number(t) : null;
   }
+
+  static getPrismaTimeout() {
+    return {
+      transactionOptions: {
+        timeout: process.env.REVIEW_SERVICE_PRISMA_TIMEOUT
+          ? parseInt(process.env.REVIEW_SERVICE_PRISMA_TIMEOUT, 10)
+          : 10000,
+      },
+    };
+  }
 }