From be87a0e96d271cacbad22c9629b465a861d19103 Mon Sep 17 00:00:00 2001
From: Johan Haals <johan.haals@gmail.com>
Date: Tue, 17 Aug 2021 16:45:35 +0200
Subject: [PATCH] Revert refresh interval

Signed-off-by: Johan Haals <johan.haals@gmail.com>
---
 .../src/next/database/DefaultProcessingDatabase.ts    | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts
index ead857576c..faf7197bc5 100644
--- a/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts
+++ b/plugins/catalog-backend/src/next/database/DefaultProcessingDatabase.ts
@@ -471,7 +471,6 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
       .limit(request.processBatchSize)
       .orderBy('next_update_at', 'asc');
 
-    const nextRefresh = Math.random() * (150 - 100) + 100;
     await tx<DbRefreshStateRow>('refresh_state')
       .whereIn(
         'entity_ref',
@@ -480,8 +479,14 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
       .update({
         next_update_at:
           tx.client.config.client === 'sqlite3'
-            ? tx.raw(`datetime('now', ?)`, [`${nextRefresh} seconds`])
-            : tx.raw(`now() + interval '${Number(nextRefresh)} seconds'`),
+            ? tx.raw(`datetime('now', ?)`, [
+                `${this.options.refreshIntervalSeconds} seconds`,
+              ])
+            : tx.raw(
+                `now() + interval '${Number(
+                  this.options.refreshIntervalSeconds,
+                )} seconds'`,
+              ),
       });
 
     return {