From 30adbb735f13e12dfc3e5c6972fea018d4cf35f7 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Wed, 12 Jun 2024 19:41:07 +0800
Subject: [PATCH] fix typo in sql

---
 .../0181.do.batch_delete_trash_items.sql      | 25 ++++++++++---------
 1 file changed, 13 insertions(+), 12 deletions(-)

diff --git a/packages/db/migrations/0181.do.batch_delete_trash_items.sql b/packages/db/migrations/0181.do.batch_delete_trash_items.sql
index 38a619469..38518b6b6 100755
--- a/packages/db/migrations/0181.do.batch_delete_trash_items.sql
+++ b/packages/db/migrations/0181.do.batch_delete_trash_items.sql
@@ -5,7 +5,7 @@
 BEGIN;
 
 CREATE OR REPLACE PROCEDURE omnivore.batch_delete_trash_items()
-RETURNS VOID AS $$
+LANGUAGE plpgsql AS $$
 DECLARE
     user_record RECORD;
     user_cursor CURSOR FOR
@@ -17,20 +17,21 @@ DECLARE
         status = 'ACTIVE';
 BEGIN
     FOR user_record IN user_cursor LOOP
-        BEGIN;
+        BEGIN
         
-        -- For Row Level Security
-        PERFORM omnivore.set_claims(user_record.id, 'omnivore_user');
+            -- For Row Level Security
+            PERFORM omnivore.set_claims(user_record.id, 'omnivore_user');
 
-        DELETE FROM omnivore.library_item
-        WHERE
-            user_id = user_record.id
-            AND state = 'DELETED'
-            AND deleted_at < NOW() - INTERVAL '14 days';
+            DELETE FROM omnivore.library_item
+            WHERE
+                user_id = user_record.id
+                AND state = 'DELETED'
+                AND deleted_at < NOW() - INTERVAL '14 days';
 
-        COMMIT;
+            COMMIT;
+        END;
     END LOOP;
-END;
-$$ LANGUAGE plpgsql;
+END
+$$;
 
 COMMIT;