Mirror/SponsorBlockServer
1
0
Fork 0
mirror of https://github.com/ajayyy/SponsorBlockServer.git synced 2025-12-09 13:07:02 +03:00
Code Issues Packages Projects Releases Wiki Activity

Add option to disable fallback after failure

Browse Source
This commit is contained in:
Ajay
2022-09-08 15:02:56 -04:00
parent 072324f0ab
commit 1e66a2e57a
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/config.ts
View File

@@ -88,7 +88,8 @@ addDefaults(config, {
readTimeout: 250, readTimeout: 250,
max: 10, max: 10,
idleTimeoutMillis: 10000, idleTimeoutMillis: 10000,
maxTries: 3 maxTries: 3,
fallbackOnFail: true
}, },
dumpDatabase: { dumpDatabase: {
enabled: false, enabled: false,

6
src/databases/Postgres.ts
View File

@@ -148,8 +148,10 @@ export class Postgres implements IDatabase {
private getPool(type: string, options: QueryOption): Pool { private getPool(type: string, options: QueryOption): Pool {
const readAvailable = this.poolRead && options.useReplica && this.isReadQuery(type); const readAvailable = this.poolRead && options.useReplica && this.isReadQuery(type);
const ignroreReadDueToFailure = this.lastPoolReadFail > Date.now() - 1000 * 30; const ignroreReadDueToFailure = this.config.postgresReadOnly.fallbackOnFail
const readDueToFailure = this.lastPoolFail > Date.now() - 1000 * 30; && this.lastPoolReadFail > Date.now() - 1000 * 30;
const readDueToFailure = this.config.postgresReadOnly.fallbackOnFail
&& this.lastPoolFail > Date.now() - 1000 * 30;
if (readAvailable && !ignroreReadDueToFailure && (options.forceReplica || readDueToFailure || if (readAvailable && !ignroreReadDueToFailure && (options.forceReplica || readDueToFailure ||
Math.random() > 1 / (this.config.postgresReadOnly.weight + 1))) { Math.random() > 1 / (this.config.postgresReadOnly.weight + 1))) {
return this.poolRead; return this.poolRead;