Skip to content

Commit 8f6b05b

Browse files
committed
Added fallback logic to db host as a source host in hasura config.
1 parent 7101f46 commit 8f6b05b

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

hasura/api.go

+8-3
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,12 @@ func (api *API) Health(ctx context.Context) error {
124124

125125
// AddSource -
126126
func (api *API) AddSource(ctx context.Context, hasura *config.Hasura, cfg config.Database) error {
127-
databaseUrl := DatabaseUrl(fmt.Sprintf("postgresql://%s:%s@%s:%d/%s", cfg.User, cfg.Password, hasura.Source.DatabaseHost, cfg.Port, cfg.Database))
127+
host := cfg.Host
128+
if hasura.Source.DatabaseHost != "" {
129+
host = hasura.Source.DatabaseHost
130+
}
131+
132+
databaseUrl := DatabaseUrl(fmt.Sprintf("postgresql://%s:%s@%s:%d/%s", cfg.User, cfg.Password, host, cfg.Port, cfg.Database))
128133

129134
req := Request{
130135
Type: "pg_add_source",
@@ -133,8 +138,8 @@ func (api *API) AddSource(ctx context.Context, hasura *config.Hasura, cfg config
133138
"configuration": Configuration{
134139
ConnectionInfo: ConnectionInfo{
135140
DatabaseUrl: databaseUrl,
136-
UsePreparedStatements: hasura.Source.UsePreparedStatements, // true
137-
IsolationLevel: hasura.Source.IsolationLevel, // "read-committed"
141+
UsePreparedStatements: hasura.Source.UsePreparedStatements,
142+
IsolationLevel: hasura.Source.IsolationLevel,
138143
},
139144
},
140145
"replace_configuration": true,

0 commit comments

Comments
 (0)