From 3744b0c67a6cda52730cce7badd1df30a32c2d4d Mon Sep 17 00:00:00 2001
From: Kiss Miklos <miklos@roadie.io>
Date: Wed, 22 Jun 2022 12:43:44 +0200
Subject: [PATCH] addRefreshKEys -> setRefreshKeys

Signed-off-by: Kiss Miklos <miklos@roadie.io>
---
 .../catalog-backend/src/database/DefaultProcessingDatabase.ts   | 2 +-
 plugins/catalog-backend/src/database/types.ts                   | 2 +-
 .../src/processing/DefaultCatalogProcessingEngine.ts            | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
index e4a5ab3d85..20ef39f6e8 100644
--- a/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
+++ b/plugins/catalog-backend/src/database/DefaultProcessingDatabase.ts
@@ -533,7 +533,7 @@ export class DefaultProcessingDatabase implements ProcessingDatabase {
 
     await Promise.all(rows.map(r => this.refresh(tx, r.entity_ref)));
   }
-  async addRefreshKeys(
+  async setRefreshKeys(
     txOpaque: Transaction,
     options: RefreshKeyOptions,
   ): Promise<void> {
diff --git a/plugins/catalog-backend/src/database/types.ts b/plugins/catalog-backend/src/database/types.ts
index bf3f765f4a..9d4043a340 100644
--- a/plugins/catalog-backend/src/database/types.ts
+++ b/plugins/catalog-backend/src/database/types.ts
@@ -157,7 +157,7 @@ export interface ProcessingDatabase {
    */
   refresh(txOpaque: Transaction, options: RefreshOptions): Promise<void>;
 
-  addRefreshKeys(
+  setRefreshKeys(
     txOpaque: Transaction,
     options: RefreshKeyOptions,
   ): Promise<void>;
diff --git a/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts b/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts
index d3d679d2b7..5cb9c76e62 100644
--- a/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts
+++ b/plugins/catalog-backend/src/processing/DefaultCatalogProcessingEngine.ts
@@ -124,7 +124,7 @@ export class DefaultCatalogProcessingEngine implements CatalogProcessingEngine {
           let hashBuilder = this.createHash().update(errorsString);
           if (result.ok) {
             await this.processingDatabase.transaction(tx =>
-              this.processingDatabase.addRefreshKeys(tx, {
+              this.processingDatabase.setRefreshKeys(tx, {
                 keys: result.refreshKeys,
               }),
             );