Hotfix db improvements (#1523) (#1524)

* add extra configurations for postgresql connections * add master and slave replication strategy for typeorm Co-authored-by: CarlosQ96 <[email protected]>
Giveth · May 2, 2024 · c30dcab · c30dcab
1 parent 4a49857
commit c30dcab
Showing 1 changed file with 29 additions and 5 deletions.
diff --git a/src/orm.ts b/src/orm.ts
@@ -17,11 +17,25 @@ export class AppDataSource {
       AppDataSource.datasource = new DataSource({
         schema: 'public',
         type: 'postgres',
-        database: config.get('TYPEORM_DATABASE_NAME') as string,
-        username: config.get('TYPEORM_DATABASE_USER') as string,
-        password: config.get('TYPEORM_DATABASE_PASSWORD') as string,
-        port: config.get('TYPEORM_DATABASE_PORT') as number,
-        host: config.get('TYPEORM_DATABASE_HOST') as string,
+        replication: {
+          master: {
+            database: config.get('TYPEORM_DATABASE_NAME') as string,
+            username: config.get('TYPEORM_DATABASE_USER') as string,
+            password: config.get('TYPEORM_DATABASE_PASSWORD') as string,
+            port: config.get('TYPEORM_DATABASE_PORT') as number,
+            host: config.get('TYPEORM_DATABASE_HOST') as string,
+          },
+          slaves: [
+            {
+              database: config.get('TYPEORM_DATABASE_NAME') as string,
+              username: config.get('TYPEORM_DATABASE_USER') as string,
+              password: config.get('TYPEORM_DATABASE_PASSWORD') as string,
+              port: config.get('TYPEORM_DATABASE_PORT') as number,
+              host: config.get('TYPEORM_DATABASE_HOST_READONLY') as string,
+            },
+          ],
+        },
+
         entities,
         synchronize,
         dropSchema,
@@ -35,6 +49,11 @@ export class AppDataSource {
           },
         },
         poolSize,
+        extra: {
+          maxWaitingClients: 10,
+          evictionRunIntervalMillis: 500,
+          idleTimeoutMillis: 500,
+        },
       });
       await AppDataSource.datasource.initialize();
     }
@@ -59,6 +78,11 @@ export class CronDataSource {
         entities: [CronJob],
         synchronize: false,
         dropSchema: false,
+        extra: {
+          maxWaitingClients: 10,
+          evictionRunIntervalMillis: 500,
+          idleTimeoutMillis: 500,
+        },
       });
       await CronDataSource.datasource.initialize();
     }