From ad39179ce73b9bea83cc5d58b1961c9734c384db Mon Sep 17 00:00:00 2001
From: blam <ben@blam.sh>
Date: Thu, 16 Jan 2025 09:09:59 +0100
Subject: [PATCH] chore: only remove if ok Signed-off-by: blam <ben@blam.sh>

Signed-off-by: blam <ben@blam.sh>
---
 .../catalog-backend/src/database/DefaultProviderDatabase.ts  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts b/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts
index a078b578e4..9ec5d13591 100644
--- a/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts
+++ b/plugins/catalog-backend/src/database/DefaultProviderDatabase.ts
@@ -165,9 +165,14 @@ export class DefaultProviderDatabase implements ProviderDatabase {
 
           await tx<DbRefreshStateReferencesRow>('refresh_state_references')
             .where('target_entity_ref', entityRef)
+            .andWhere({ source_key: options.sourceKey })
             .delete();
 
           if (ok) {
+            await tx<DbRefreshStateReferencesRow>('refresh_state_references')
+              .where('target_entity_ref', entityRef)
+              .delete();
+
             await tx<DbRefreshStateReferencesRow>(
               'refresh_state_references',
             ).insert({