urdt/ussd
5
0
Fork 1
Code Issues 41 Pull Requests Actions Packages Projects Releases Wiki Activity

allow the BuildConnStr to be accessed by different packages

Browse Source
This commit is contained in:
Alfred Kamanda 2025-01-08 10:56:59 +03:00 committed by konstantinmds
parent c34fe192c6
commit b0c9197ce4
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/storage/storage_service.go
View File

@ -36,7 +36,23 @@ type MenuStorageService struct {
userDataStore db.Db userDataStore db.Db
} }
func NewMenuStorageService(conn ConnData, resourceDir string) *MenuStorageService { func BuildConnStr() string {
host := initializers.GetEnv("DB_HOST", "localhost")
user := initializers.GetEnv("DB_USER", "postgres")
password := initializers.GetEnv("DB_PASSWORD", "")
dbName := initializers.GetEnv("DB_NAME", "")
port := initializers.GetEnv("DB_PORT", "5432")
connString := fmt.Sprintf(
"postgres://%s:%s@%s:%s/%s",
user, password, host, port, dbName,
)
logg.Debugf("pg conn string", "conn", connString)
return connString
}
func NewMenuStorageService(dbDir string, resourceDir string) *MenuStorageService {
return &MenuStorageService{ return &MenuStorageService{
conn: conn, conn: conn,
resourceDir: resourceDir, resourceDir: resourceDir,
@ -58,7 +74,7 @@ func (ms *MenuStorageService) getOrCreateDb(ctx context.Context, existingDb db.D
if database == "postgres" { if database == "postgres" {
connStr := buildConnStr() connStr := BuildConnStr()
// Ensure the schema exists // Ensure the schema exists
err = ensureSchemaExists(ctx, connStr, schema) err = ensureSchemaExists(ctx, connStr, schema)