fix(userservice): init db for reports

gobitfly · Sep 26, 2024 · 59c4a0b · 59c4a0b
1 parent 80d2c12
commit 59c4a0b
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 0 deletions.
diff --git a/backend/cmd/user_service/main.go b/backend/cmd/user_service/main.go
@@ -93,6 +93,30 @@ func Run() {
 		}, "pgx", "postgres")
 	}()
 
+	wg.Add(1)
+	go func() {
+		defer wg.Done()
+		db.WriterDb, db.ReaderDb = db.MustInitDB(&types.DatabaseConfig{
+			Username:     utils.Config.WriterDatabase.Username,
+			Password:     utils.Config.WriterDatabase.Password,
+			Name:         utils.Config.WriterDatabase.Name,
+			Host:         utils.Config.WriterDatabase.Host,
+			Port:         utils.Config.WriterDatabase.Port,
+			MaxOpenConns: utils.Config.WriterDatabase.MaxOpenConns,
+			MaxIdleConns: utils.Config.WriterDatabase.MaxIdleConns,
+			SSL:          utils.Config.WriterDatabase.SSL,
+		}, &types.DatabaseConfig{
+			Username:     utils.Config.ReaderDatabase.Username,
+			Password:     utils.Config.ReaderDatabase.Password,
+			Name:         utils.Config.ReaderDatabase.Name,
+			Host:         utils.Config.ReaderDatabase.Host,
+			Port:         utils.Config.ReaderDatabase.Port,
+			MaxOpenConns: utils.Config.ReaderDatabase.MaxOpenConns,
+			MaxIdleConns: utils.Config.ReaderDatabase.MaxIdleConns,
+			SSL:          utils.Config.ReaderDatabase.SSL,
+		}, "pgx", "postgres")
+	}()
+
 	// if needed, init the database, cache or bigtable
 
 	wg.Wait()

diff --git a/backend/pkg/api/data_access/data_access.go b/backend/pkg/api/data_access/data_access.go
@@ -196,6 +196,7 @@ func createDataAccessService(cfg *types.Config) *DataAccessService {
 				Port:         cfg.Frontend.ReaderDatabase.Port,
 				MaxOpenConns: cfg.Frontend.ReaderDatabase.MaxOpenConns,
 				MaxIdleConns: cfg.Frontend.ReaderDatabase.MaxIdleConns,
+				SSL:          cfg.Frontend.ReaderDatabase.SSL,
 			}, "pgx", "postgres",
 		)
 	}()