From 2b1ab47a7a4bacea634a09b6a9404dbf2eb79929 Mon Sep 17 00:00:00 2001
From: Kiss Miklos <miklos@roadie.io>
Date: Wed, 22 Jun 2022 13:08:16 +0200
Subject: [PATCH] add deleteRefreshKey

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

diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
index 20ef39f6e8..a003328244 100644
--- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
+++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
@@ -518,6 +518,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
       throw new NotFoundError(`Failed to schedule ${entityRef} for refresh`);
     }
   }
+
   async refreshByRefreshKey(
     txOpaque: Transaction,
     options: RefreshByKeyOptions,
@@ -533,6 +534,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
 
     await Promise.all(rows.map(r => this.refresh(tx, r.entity_ref)));
   }
+
   async setRefreshKeys(
     txOpaque: Transaction,
     options: RefreshKeyOptions,
@@ -552,6 +554,17 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
       }),
     );
   }
+
+  async deleteRefreshKey(
+    txOpaque: Transaction,
+    options: RefreshByKeyOptions,
+  ): Promise<void> {
+    const tx = txOpaque as Knex.Transaction;
+    const { key } = options;
+
+    await tx<DbRefreshKeysRow>('refresh_keys').where({ key }).delete();
+  }
+
   async transaction<T>(fn: (tx: Transaction) => Promise<T>): Promise<T> {
     try {
       let result: T | undefined = undefined;