From 18d28a1fc8bd00e51de80cbdb31a6ec68ec6068f Mon Sep 17 00:00:00 2001
From: "gpt-engineer-app[bot]"
 <159125892+gpt-engineer-app[bot]@users.noreply.github.com>
Date: Wed, 5 Nov 2025 18:33:58 +0000
Subject: [PATCH] feat: Create stale temp refs cleanup function

---
 src/integrations/supabase/types.ts            |  7 +++
 ...2_02169458-8a2c-4f41-b956-49aff66571ab.sql | 48 +++++++++++++++++++
 2 files changed, 55 insertions(+)
 create mode 100644 supabase/migrations/20251105183332_02169458-8a2c-4f41-b956-49aff66571ab.sql

diff --git a/src/integrations/supabase/types.ts b/src/integrations/supabase/types.ts
index b8015e69..59c85e8f 100644
--- a/src/integrations/supabase/types.ts
+++ b/src/integrations/supabase/types.ts
@@ -5602,6 +5602,13 @@ export type Database = {
       }
       cleanup_orphaned_submissions: { Args: never; Returns: number }
       cleanup_rate_limits: { Args: never; Returns: undefined }
+      cleanup_stale_temp_refs: {
+        Args: { p_age_days?: number }
+        Returns: {
+          deleted_count: number
+          oldest_deleted_date: string
+        }[]
+      }
       create_submission_with_items: {
         Args: {
           p_content: Json
diff --git a/supabase/migrations/20251105183332_02169458-8a2c-4f41-b956-49aff66571ab.sql b/supabase/migrations/20251105183332_02169458-8a2c-4f41-b956-49aff66571ab.sql
new file mode 100644
index 00000000..d1e4274e
--- /dev/null
+++ b/supabase/migrations/20251105183332_02169458-8a2c-4f41-b956-49aff66571ab.sql
@@ -0,0 +1,48 @@
+-- Create function to clean up stale temporary submission references
+-- These are temp refs that should have been deleted during submission approval/rejection
+-- but weren't due to errors, crashes, or edge cases
+
+CREATE OR REPLACE FUNCTION public.cleanup_stale_temp_refs(
+  p_age_days INTEGER DEFAULT 30
+)
+RETURNS TABLE (
+  deleted_count INTEGER,
+  oldest_deleted_date TIMESTAMPTZ
+) 
+LANGUAGE plpgsql
+SECURITY DEFINER
+SET search_path TO 'public'
+AS $$
+DECLARE
+  v_deleted_count INTEGER;
+  v_oldest_date TIMESTAMPTZ;
+BEGIN
+  -- Capture oldest ref before deletion for logging
+  SELECT MIN(created_at) INTO v_oldest_date
+  FROM submission_item_temp_refs
+  WHERE created_at < NOW() - (p_age_days || ' days')::INTERVAL;
+  
+  -- Delete stale temp refs older than p_age_days
+  DELETE FROM submission_item_temp_refs
+  WHERE created_at < NOW() - (p_age_days || ' days')::INTERVAL;
+  
+  GET DIAGNOSTICS v_deleted_count = ROW_COUNT;
+  
+  -- Return results for logging/monitoring
+  RETURN QUERY SELECT v_deleted_count, v_oldest_date;
+  
+  -- Log the cleanup operation
+  RAISE NOTICE 'Cleaned up % stale temp refs older than % days (oldest: %)', 
+    v_deleted_count, p_age_days, v_oldest_date;
+END;
+$$;
+
+COMMENT ON FUNCTION public.cleanup_stale_temp_refs IS 
+  'Deletes temporary submission references older than specified days (default 30). Returns deleted count and oldest deletion date. Should be run via pg_cron or manually for maintenance.';
+
+-- Grant execute permission to authenticated users (moderators will use this)
+GRANT EXECUTE ON FUNCTION public.cleanup_stale_temp_refs TO authenticated;
+
+-- Example usage:
+-- SELECT * FROM cleanup_stale_temp_refs();        -- Default 30 days
+-- SELECT * FROM cleanup_stale_temp_refs(7);       -- Aggressive 7 day cleanup
\ No newline at end of file