From bc6a09798b6e3c71273fbc5945b123c15c472c43 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Wed, 26 Jun 2024 16:11:34 +0800
Subject: [PATCH] fix read replica not being used

---
 packages/api/src/data_source.ts | 43 +++++++++++++++------------------
 1 file changed, 20 insertions(+), 23 deletions(-)

diff --git a/packages/api/src/data_source.ts b/packages/api/src/data_source.ts
index bb6afd714..cb3ab4549 100644
--- a/packages/api/src/data_source.ts
+++ b/packages/api/src/data_source.ts
@@ -23,27 +23,24 @@ export const appDataSource = new DataSource({
     max: env.pg.pool.max,
     idleTimeoutMillis: 10000, // 10 seconds
   },
-})
-
-if (env.pg.replication) {
-  appDataSource.setOptions({
-    replication: {
-      master: {
-        host: env.pg.host,
-        port: env.pg.port,
-        username: env.pg.userName,
-        password: env.pg.password,
-        database: env.pg.dbName,
-      },
-      slaves: [
-        {
-          host: env.pg.replica.host,
-          port: env.pg.replica.port,
-          username: env.pg.replica.userName,
-          password: env.pg.replica.password,
-          database: env.pg.replica.dbName,
+  replication: env.pg.replication
+    ? {
+        master: {
+          host: env.pg.host,
+          port: env.pg.port,
+          username: env.pg.userName,
+          password: env.pg.password,
+          database: env.pg.dbName,
         },
-      ],
-    },
-  })
-}
+        slaves: [
+          {
+            host: env.pg.replica.host,
+            port: env.pg.replica.port,
+            username: env.pg.replica.userName,
+            password: env.pg.replica.password,
+            database: env.pg.replica.dbName,
+          },
+        ],
+      }
+    : undefined,
+})