webhook api shouldnt kill db client connections at all (#1853)

Author: Uros Marolt

backend/src/segment/track.ts

@@ -1,9 +1,9 @@
 import { getServiceChildLogger } from '@crowd/logging'
 import { Edition } from '@crowd/types'
 import { API_CONFIG, IS_TEST_ENV, SEGMENT_CONFIG } from '../conf'
-import getTenatUser from './trackHelper'
-import addProductData, { CROWD_ANALYTICS_PLATORM_NAME } from './addProductDataToCrowdTenant'
 import SequelizeRepository from '../database/repositories/sequelizeRepository'
+import { CROWD_ANALYTICS_PLATORM_NAME } from './addProductDataToCrowdTenant'
+import getTenatUser from './trackHelper'
 
 const log = getServiceChildLogger('segment')
 

services/apps/webhook_api/src/main.ts

@@ -20,7 +20,7 @@ setImmediate(async () => {
 
   const sqsClient = getSqsClient(SQS_CONFIG())
 
-  const dbConnection = await getDbConnection(DB_CONFIG(), 3)
+  const dbConnection = await getDbConnection(DB_CONFIG(), 3, 0)
 
   app.use((req, res, next) => {
     // Groups.io doesn't send a content-type header,

services/libs/database/src/connection.ts

@@ -47,6 +47,7 @@ let dbConnection: DbConnection | undefined
 export const getDbConnection = async (
   config: IDatabaseConfig,
   maxPoolSize?: number,
+  idleTimeoutMillis?: number,
 ): Promise<DbConnection> => {
   if (dbConnection) {
     return dbConnection
@@ -62,6 +63,7 @@ export const getDbConnection = async (
   dbConnection = dbInstance({
     ...config,
     max: maxPoolSize || 20,
+    idleTimeoutMillis: idleTimeoutMillis !== undefined ? idleTimeoutMillis : 10000,
     // query_timeout: 30000,
     application_name: process.env.SERVICE || 'unknown-app',
   })