From 47717bc66869af5be7e08f8f4ef120a2ef8a475d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Fredrik=20Adel=C3=B6w?= <freben@gmail.com>
Date: Thu, 23 Mar 2023 10:25:14 +0100
Subject: [PATCH] add a test for cascading deletes in the catalog
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: Fredrik Adelöw <freben@gmail.com>
---
 .../catalog-backend/src/migrations.test.ts    | 61 +++++++++++++++++++
 1 file changed, 61 insertions(+)

diff --git a/plugins/catalog-backend/src/migrations.test.ts b/plugins/catalog-backend/src/migrations.test.ts
index f1ed40dbbe..33f88e9aa7 100644
--- a/plugins/catalog-backend/src/migrations.test.ts
+++ b/plugins/catalog-backend/src/migrations.test.ts
@@ -44,6 +44,67 @@ describe('migrations', () => {
     ids: ['MYSQL_8', 'POSTGRES_13', 'POSTGRES_9', 'SQLITE_3'],
   });
 
+  it.each(databases.eachSupportedId())(
+    'latest version correctly cascades deletions, %p',
+    async databaseId => {
+      const knex = await databases.init(databaseId);
+      await knex.migrate.latest({ directory: migrationsDir });
+
+      await knex
+        .insert({
+          entity_id: 'i1',
+          entity_ref: 'k:ns/n1',
+          unprocessed_entity: '{}',
+          errors: '[]',
+          next_update_at: new Date(),
+          last_discovery_at: new Date(),
+        })
+        .into('refresh_state');
+      await knex
+        .insert({
+          entity_id: 'i2',
+          entity_ref: 'k:ns/n2',
+          unprocessed_entity: '{}',
+          errors: '[]',
+          next_update_at: new Date(),
+          last_discovery_at: new Date(),
+        })
+        .into('refresh_state');
+      await knex
+        .insert({ entity_id: 'i1', key: 'k1', value: 'v1' })
+        .into('search');
+      await knex
+        .insert({
+          source_entity_ref: 'k:ns/n1',
+          target_entity_ref: 'k:ns/n2',
+        })
+        .into('refresh_state_references');
+      await knex
+        .insert({
+          originating_entity_id: 'i1',
+          source_entity_ref: 'k:ns/n1',
+          target_entity_ref: 'k:ns/n2',
+          type: 't',
+        })
+        .into('relations');
+      await knex
+        .insert({
+          entity_id: 'i1',
+          hash: 'h',
+          stitch_ticket: '',
+          final_entity: '{}',
+        })
+        .into('final_entities');
+
+      await knex.delete().from('refresh_state').where({ entity_id: 'i1' });
+
+      await expect(knex('search')).resolves.toEqual([]);
+      await expect(knex('refresh_state_references')).resolves.toEqual([]);
+      await expect(knex('relations')).resolves.toEqual([]);
+      await expect(knex('final_entities')).resolves.toEqual([]);
+    },
+  );
+
   it.each(databases.eachSupportedId())(
     '20221109192547_search_add_original_value_column.js, %p',
     async databaseId => {