Migrate purge rules

Update purge_old_articles to delete non-pinned, unread/articles older than 48h only when not followed by any active subscribers; add test_purge_articles and update changelog. Also log admin emails and cap deletions at 1000 per run.

X-Lovable-Edit-ID: edt-fab87aaa-7330-41d9-81c8-fc15439ad922

src/data/changelog.ts

@@ -8,6 +8,20 @@ export interface ChangelogEntry {
 }
 
 export const changelogData: ChangelogEntry[] = [
+  {
+    version: "1.13.0",
+    date: "2026-02-09",
+    category: "improvement",
+    title: "Protection des articles non lus avec abonnement actif",
+    description: "Les articles non lus appartenant à un flux suivi sont désormais protégés de la purge automatique.",
+    details: [
+      "Les articles épinglés restent toujours protégés",
+      "Les articles non lus dont le flux a au moins un abonné sont protégés",
+      "Les articles non lus sans aucun abonné sont supprimés",
+      "Les articles lus non épinglés sont supprimés après 48h",
+      "Mise à jour des fonctions purge_old_articles et test_purge_articles"
+    ]
+  },
   {
     version: "1.12.0",
     date: "2026-01-29",

supabase/migrations/20260209135254_2e552754-4888-4426-a9e8-7b225eacab90.sql

@@ -0,0 +1,98 @@
+
+CREATE OR REPLACE FUNCTION public.purge_old_articles()
+ RETURNS TABLE(deleted_count integer, admin_emails text[])
+ LANGUAGE plpgsql
+ SECURITY DEFINER
+ SET search_path TO 'public'
+AS $function$
+DECLARE
+  v_deleted_count INTEGER;
+  v_admin_emails TEXT[];
+  v_cutoff_date TIMESTAMP WITH TIME ZONE;
+BEGIN
+  v_cutoff_date := NOW() - INTERVAL '48 hours';
+  
+  SELECT ARRAY_AGG(email) INTO v_admin_emails
+  FROM public.super_users;
+  
+  WITH articles_to_delete AS (
+    SELECT a.id
+    FROM public.articles a
+    WHERE a.last_seen_at < v_cutoff_date
+    -- Exclure les articles épinglés
+    AND NOT EXISTS (
+      SELECT 1 FROM public.user_articles ua
+      WHERE ua.article_id = a.id AND ua.is_pinned = true
+    )
+    -- Exclure les articles non lus dont le flux a au moins un abonné
+    AND NOT (
+      NOT EXISTS (
+        SELECT 1 FROM public.user_articles ua
+        WHERE ua.article_id = a.id AND ua.is_read = true
+      )
+      AND EXISTS (
+        SELECT 1 FROM public.user_feeds uf
+        WHERE uf.feed_id = a.feed_id AND uf.is_followed = true
+      )
+    )
+    LIMIT 1000
+  ),
+  deleted_user_articles AS (
+    DELETE FROM public.user_articles
+    WHERE article_id IN (SELECT id FROM articles_to_delete)
+    RETURNING article_id
+  ),
+  deleted AS (
+    DELETE FROM public.articles
+    WHERE id IN (SELECT id FROM articles_to_delete)
+    RETURNING id
+  )
+  SELECT COUNT(*)::INTEGER INTO v_deleted_count FROM deleted;
+  
+  RAISE NOTICE 'Purge automatique: % articles supprimés (non vus depuis 48h, non épinglés, non protégés par abonnement)', v_deleted_count;
+  
+  RETURN QUERY SELECT v_deleted_count, v_admin_emails;
+END;
+$function$;
+
+CREATE OR REPLACE FUNCTION public.test_purge_articles()
+ RETURNS TABLE(articles_to_delete integer, oldest_article_date timestamp with time zone, newest_article_date timestamp with time zone, sample_titles text[])
+ LANGUAGE plpgsql
+ SECURITY DEFINER
+ SET search_path TO 'public'
+AS $function$
+DECLARE
+  v_cutoff_date TIMESTAMP WITH TIME ZONE;
+BEGIN
+  v_cutoff_date := NOW() - INTERVAL '48 hours';
+  
+  RETURN QUERY
+  WITH eligible_articles AS (
+    SELECT a.id, a.last_seen_at, a.title
+    FROM public.articles a
+    WHERE a.last_seen_at < v_cutoff_date
+    AND NOT EXISTS (
+      SELECT 1 FROM public.user_articles ua
+      WHERE ua.article_id = a.id AND ua.is_pinned = true
+    )
+    AND NOT (
+      NOT EXISTS (
+        SELECT 1 FROM public.user_articles ua
+        WHERE ua.article_id = a.id AND ua.is_read = true
+      )
+      AND EXISTS (
+        SELECT 1 FROM public.user_feeds uf
+        WHERE uf.feed_id = a.feed_id AND uf.is_followed = true
+      )
+    )
+  ),
+  sample_articles AS (
+    SELECT title FROM eligible_articles ORDER BY last_seen_at DESC LIMIT 5
+  )
+  SELECT 
+    (SELECT COUNT(*)::INTEGER FROM eligible_articles),
+    (SELECT MIN(last_seen_at) FROM eligible_articles),
+    (SELECT MAX(last_seen_at) FROM eligible_articles),
+    (SELECT ARRAY_AGG(title) FROM sample_articles);
+END;
+$function$;