Fix SSL configuration regression in streaming API (#10225)
* Fix SSL configuration regression in streaming API Fix #10223 * Fix code style issues and integrate #10219 * Fix dumb thing
This commit is contained in:
parent
b6bc98c480
commit
dbeab5a036
1 changed files with 5 additions and 9 deletions
|
@ -24,7 +24,7 @@ const dbUrlToConfig = (dbUrl) => {
|
||||||
return {};
|
return {};
|
||||||
}
|
}
|
||||||
|
|
||||||
const params = url.parse(dbUrl);
|
const params = url.parse(dbUrl, true);
|
||||||
const config = {};
|
const config = {};
|
||||||
|
|
||||||
if (params.auth) {
|
if (params.auth) {
|
||||||
|
@ -45,8 +45,8 @@ const dbUrlToConfig = (dbUrl) => {
|
||||||
|
|
||||||
const ssl = params.query && params.query.ssl;
|
const ssl = params.query && params.query.ssl;
|
||||||
|
|
||||||
if (ssl) {
|
if (ssl && ssl === 'true' || ssl === '1') {
|
||||||
config.ssl = ssl === 'true' || ssl === '1';
|
config.ssl = true;
|
||||||
}
|
}
|
||||||
|
|
||||||
return config;
|
return config;
|
||||||
|
@ -89,9 +89,7 @@ const startWorker = (workerId) => {
|
||||||
host: process.env.DB_HOST || pg.defaults.host,
|
host: process.env.DB_HOST || pg.defaults.host,
|
||||||
port: process.env.DB_PORT || pg.defaults.port,
|
port: process.env.DB_PORT || pg.defaults.port,
|
||||||
max: 10,
|
max: 10,
|
||||||
ssl: {
|
ssl: !!process.env.DB_SSLMODE && process.env.DB_SSLMODE !== 'disable' ? true : undefined,
|
||||||
sslmode: process.env.DB_SSLMODE || 'prefer',
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
|
|
||||||
production: {
|
production: {
|
||||||
|
@ -101,9 +99,7 @@ const startWorker = (workerId) => {
|
||||||
host: process.env.DB_HOST || 'localhost',
|
host: process.env.DB_HOST || 'localhost',
|
||||||
port: process.env.DB_PORT || 5432,
|
port: process.env.DB_PORT || 5432,
|
||||||
max: 10,
|
max: 10,
|
||||||
ssl: {
|
ssl: !!process.env.DB_SSLMODE && process.env.DB_SSLMODE !== 'disable' ? true : undefined,
|
||||||
sslmode: process.env.DB_SSLMODE || 'prefer',
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue