chore: only remove if ok

Signed-off-by: blam <ben@blam.sh> Signed-off-by: blam <ben@blam.sh>
2025-01-16 09:09:59 +01:00
parent f178b129b4
commit ad39179ce7
1 changed files with 5 additions and 0 deletions
@@ -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({