From 67980a927a39d194d77dff123a5036f60a567248 Mon Sep 17 00:00:00 2001
From: Kiss Miklos <miklos@roadie.io>
Date: Mon, 29 Aug 2022 10:59:55 +0200
Subject: [PATCH] remove condition to delete refreshKeys

Signed-off-by: Kiss Miklos <miklos@roadie.io>
---
 .../src/database/DefaultProcessingDatabase.ts | 28 +++++++++----------
 1 file changed, 13 insertions(+), 15 deletions(-)

diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
index c1a8ee9d33..1cf2643339 100644
--- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
+++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
@@ -145,22 +145,20 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
       BATCH_SIZE,
     );
 
-    if (refreshKeys && refreshKeys.length > 0) {
-      // Delete old refresh keys
-      await tx<DbRefreshKeysRow>('refresh_keys')
-        .where({ entity_id: id })
-        .delete();
+    // Delete old refresh keys
+    await tx<DbRefreshKeysRow>('refresh_keys')
+      .where({ entity_id: id })
+      .delete();
 
-      // Insert the refresh keys for the processed entity
-      await tx.batchInsert(
-        'refresh_keys',
-        refreshKeys.map(k => ({
-          entity_id: id,
-          key: k.key,
-        })),
-        BATCH_SIZE,
-      );
-    }
+    // Insert the refresh keys for the processed entity
+    await tx.batchInsert(
+      'refresh_keys',
+      refreshKeys.map(k => ({
+        entity_id: id,
+        key: k.key,
+      })),
+      BATCH_SIZE,
+    );
 
     return {
       previous: {