Function getDbConnection

services/libs/database/src/connection.ts:47–74

(
  config: IDatabaseConfig,
  maxPoolSize?: number,
  idleTimeoutMillis?: number,
)

const dbConnection: Record<string, DbConnection | undefined> = {}

export const getDbConnection = async (
  config: IDatabaseConfig,
  maxPoolSize?: number,
  idleTimeoutMillis?: number,
): Promise<DbConnection> => {
  if (dbConnection[config.host]) {
    return dbConnection[config.host]
  }

  log.info(
    { database: config.database, host: config.host, port: config.port },
    'Connecting to database!',
  )

  const dbInstance = getDbInstance()

  dbConnection[config.host] = dbInstance({
    ...config,
    max: maxPoolSize || 20,
    idleTimeoutMillis: idleTimeoutMillis !== undefined ? idleTimeoutMillis : 10000,
    // query_timeout: 30000,
    application_name: process.env.SERVICE || 'unknown-app',
  })

  await dbConnection[config.host].connect()

  return dbConnection[config.host]
}