Reuse database connection when using repository outside controller

Author: Matija Petrunic

package.json

@@ -10,7 +10,7 @@
   "scripts": {
     "start:dev": "npx task dev",
     "db:migration:new": "yarn run typeorm-ts migration:create -n ",
-    "db:migration:generate": "yarn run typeorm-ts migration:create -n ",
+    "db:migration:generate": "yarn run typeorm-ts migration:generate -n ",
     "db:entity:new": "yarn run typeorm-ts entity:create -n ",
     "db:subscriber:new": "yarn run typeorm-ts subscriber:create -n ",
     "db:migrate": "npx task npm typeorm-ts migration:run",

src/services/db/index.ts

@@ -1,17 +1,22 @@
-import {Connection, createConnection, getConnectionOptions} from "typeorm";
+import {Connection, createConnection, getConnectionOptions, ObjectType, getConnection} from "typeorm";
 import {sleep} from "../utils";
 import {logger} from "../logger";
 import {PostgresConnectionCredentialsOptions} from "typeorm/driver/postgres/PostgresConnectionCredentialsOptions";
 import {TypeOrmLogger} from "../logger/typeorm";
 
 export async function getDatabaseConnection(): Promise<Connection> {
   const opts = await getConnectionOptions();
-  let conn = await createConnection({
-    ...opts,
-    logger: new TypeOrmLogger()
-  });
-  conn = await openConnection(conn);
-  await conn.runMigrations({transaction: "all"});
+  let conn: Connection;
+  try {
+    conn = getConnection();
+  } catch{
+    conn = await createConnection({
+      ...opts,
+      logger: new TypeOrmLogger()
+    });
+    conn = await openConnection(conn);
+    await conn.runMigrations({transaction: "all"});
+  }
   return conn;
 }
 
@@ -28,4 +33,9 @@ async function openConnection(conn: Connection): Promise<Connection> {
     await sleep(3000);
     return openConnection(conn);
   }
-}
+}
+
+export async function getRepository<T>(customRepository: ObjectType<T>): Promise<T> {
+  const connection = await getDatabaseConnection();
+  return connection.getCustomRepository<T>(customRepository);
+}