fix: rollback prefix migration (#770)

Author: fenos

migrations/tenant/0042-rollback-prefix-triggers.sql

@@ -0,0 +1,32 @@
+DROP TRIGGER IF EXISTS objects_delete_cleanup ON storage.objects;
+DROP TRIGGER IF EXISTS prefixes_delete_cleanup ON storage.prefixes;
+DROP TRIGGER IF EXISTS objects_update_cleanup ON storage.objects;
+DROP TRIGGER IF EXISTS objects_update_level_trigger ON storage.objects;
+
+CREATE OR REPLACE TRIGGER "objects_insert_create_prefix"
+    BEFORE INSERT ON "storage"."objects"
+    FOR EACH ROW
+    EXECUTE FUNCTION "storage"."objects_insert_prefix_trigger"();
+
+CREATE OR REPLACE TRIGGER "objects_update_create_prefix"
+    BEFORE UPDATE ON "storage"."objects"
+    FOR EACH ROW
+    WHEN (NEW.name != OLD.name)
+    EXECUTE FUNCTION "storage"."objects_insert_prefix_trigger"();
+
+CREATE OR REPLACE TRIGGER "objects_delete_delete_prefix"
+    AFTER DELETE ON "storage"."objects"
+    FOR EACH ROW
+    EXECUTE FUNCTION "storage"."delete_prefix_hierarchy_trigger"();
+
+CREATE OR REPLACE TRIGGER "objects_update_create_prefix"
+    BEFORE UPDATE ON "storage"."objects"
+    FOR EACH ROW
+    WHEN (NEW.name != OLD.name OR NEW.bucket_id != OLD.bucket_id)
+    EXECUTE FUNCTION "storage"."objects_update_prefix_trigger"();
+
+-- "storage"."prefixes"
+CREATE OR REPLACE TRIGGER "prefixes_delete_hierarchy"
+    AFTER DELETE ON "storage"."prefixes"
+    FOR EACH ROW
+EXECUTE FUNCTION "storage"."delete_prefix_hierarchy_trigger"();

migrations/tenant/0042-fix-object-level.sql renamed to migrations/tenant/0043-fix-object-level.sql

@@ -166,7 +166,7 @@ describe('Prefix Hierarchy Race Condition Tests', () => {
   })
 
   describe('Race Condition Scenario 1: Concurrent Deletes of Related Objects', () => {
-    it('should handle concurrent deletion of objects in same folder without leaving dangling prefixes', async () => {
+    it.skip('should handle concurrent deletion of objects in same folder without leaving dangling prefixes', async () => {
       // Create multiple objects in the same folder structure
       await createObject('shared/folder/file1.txt')
       await createObject('shared/folder/file2.txt')
@@ -198,7 +198,7 @@ describe('Prefix Hierarchy Race Condition Tests', () => {
       expect(prefixes).toHaveLength(0)
     })
 
-    it('should handle partial concurrent deletion correctly', async () => {
+    it.skip('should handle partial concurrent deletion correctly', async () => {
       // Create objects in multiple subfolders
       await createObject('race/test/file1.txt')
       await createObject('race/test/file2.txt')
@@ -400,7 +400,7 @@ describe('Prefix Hierarchy Race Condition Tests', () => {
   })
 
   describe('Stress Test: High Concurrency', () => {
-    it('should handle many concurrent operations without corruption', async () => {
+    it.skip('should handle many concurrent operations without corruption', async () => {
       // Create many objects in overlapping folder structures
       const objects: string[] = []
       const folders = ['stress1', 'stress2', 'stress3']
@@ -539,7 +539,7 @@ describe('Prefix Hierarchy Race Condition Tests', () => {
       expect(prefixes).toHaveLength(0)
     })
 
-    it('should handle concurrent moves from the same source folder without dangling prefixes', async () => {
+    it.skip('should handle concurrent moves from the same source folder without dangling prefixes', async () => {
       await createObject('race-move/src/f1.txt')
       await createObject('race-move/src/f2.txt')
       await createObject('race-move/src/f3.txt')
@@ -564,7 +564,7 @@ describe('Prefix Hierarchy Race Condition Tests', () => {
       })
     })
 
-    it('should handle deadlock scenario in concurrent cross-prefix moves without hanging', async () => {
+    it.skip('should handle deadlock scenario in concurrent cross-prefix moves without hanging', async () => {
       // This test reproduces the deadlock scenario where two transactions
       // try to move files between overlapping top-level prefixes in opposite directions:
       // Transaction 1: photos/* -> docs/*  (locks photos -> docs)
@@ -699,7 +699,7 @@ describe('Prefix Hierarchy Race Condition Tests', () => {
   })
 
   describe('Stress Test: Move Operations', () => {
-    it('should handle many concurrent moves and clean old prefixes correctly', async () => {
+    it.skip('should handle many concurrent moves and clean old prefixes correctly', async () => {
       const sources = ['mvstress/src1', 'mvstress/src2', 'mvstress/src3']
       const subs = ['sub1', 'sub2', 'sub3']
       const countPerSub = 5