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

Fix fail calculation

Browse Source
This commit is contained in:
Ajay
2022-06-25 12:30:16 -04:00
parent e615d7c032
commit 86e61c778c
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/databases/Postgres.ts
View File

@@ -111,8 +111,8 @@ export class Postgres implements IDatabase {
private getClient(type: string): Promise<PoolClient> { private getClient(type: string): Promise<PoolClient> {
const readAvailable = this.poolRead && (type === "get" || type === "all"); const readAvailable = this.poolRead && (type === "get" || type === "all");
const ignroreReadDueToFailure = this.lastPoolReadFail < Date.now() - 1000 * 30; const ignroreReadDueToFailure = this.lastPoolReadFail > Date.now() - 1000 * 30;
const readDueToFailure = this.lastPoolFail < Date.now() - 1000 * 30; const readDueToFailure = this.lastPoolFail > Date.now() - 1000 * 30;
if (readAvailable && !ignroreReadDueToFailure && (readDueToFailure || if (readAvailable && !ignroreReadDueToFailure && (readDueToFailure ||
Math.random() > 1 / (this.config.postgresReadOnly.weight + 1))) { Math.random() > 1 / (this.config.postgresReadOnly.weight + 1))) {
return this.poolRead.connect(); return this.poolRead.connect();