feat: schedule delete

src/components/HelpOffers/HelpOfferForm.tsx

@@ -9,6 +9,7 @@ import Unauthorized from '@/components/Unauthorized';
 import { useTowns } from '@/context/TownProvider';
 import { toast } from 'sonner';
 import { CheckboxLegalText } from '../CheckboxLegalText';
+import { InfoIcon } from 'lucide-react';
 
 export type HelpOfferFormData = {
   aceptaProtocolo: boolean;
@@ -272,6 +273,15 @@ export default function HelpOfferForm({ data, buttonText, submitMutation }: Help
           {buttonText[0]}
         </button>
       </div>
+      <div className="mt-6 flex items-start gap-4">
+        <InfoIcon className="h-6 w-6 text-blue-400 flex-shrink-0" />
+        <div>
+          <p className="text-sm text-gray-700">
+            Las ofertas de ayuda se borrarán automáticamente a los 7 días. Si lo deseas, tras este plazo puedes crear
+            una nueva oferta con datos actualizados.
+          </p>
+        </div>
+      </div>
     </form>
   );
 }

src/components/HelpRequests/HelpRequestForm.tsx

@@ -12,6 +12,7 @@ import { LngLat } from '@/components/map/GeolocationMap';
 import { useSession } from '@/context/SessionProvider';
 import Unauthorized from '@/components/Unauthorized';
 import { CheckboxLegalText } from '../CheckboxLegalText';
+import { InfoIcon } from 'lucide-react';
 
 export type HelpRequestFormData = {
   nombre: string;
@@ -276,6 +277,15 @@ export default function HelpRequestForm({
       >
         {isSubmitting ? buttonText[1] : buttonText[0]}
       </button>
+      <div className="pb-3 flex gap-4">
+        <InfoIcon className="h-6 w-6 text-blue-400 flex-shrink-0" />
+        <div>
+          <p className="text-sm text-gray-700">
+            Las solicitudes de ayuda se borrarán automáticamente a los 7 días. Si tras este plazo sigues necesitando
+            ayuda, crea una nueva solicitud con datos actualizados.
+          </p>
+        </div>
+      </div>
     </form>
   );
 }

supabase/migrations/20241121143450_delete_expired_requests.sql

@@ -0,0 +1,138 @@
+create extension if not exists pg_cron with schema extensions;
+create extension if not exists http with schema extensions;
+
+grant usage on schema cron to postgres;
+grant all privileges on all tables in schema cron to postgres;
+
+select cron.schedule (
+    'delete_expired_records', -- name of the cron job
+    '*/5 * * * *', -- Every day at 4:00am (GMT)
+    $$ delete from public.help_requests where created_at < now() - interval '7 days'; $$
+);
+
+alter table public.help_requests add column expiry_notice_sent boolean default false;
+
+create index if not exists idx_help_requests_created_at on public.help_requests using btree (created_at, expiry_notice_sent, type);
+
+create or replace function send_request_expiry_notices() returns void as $$
+declare
+    api_key text;
+    email_body text;
+    email_list text[];
+    help_request_ids bigint[];
+    status_code int;
+begin
+    -- Get the RESEND_API_KEY
+    select decrypted_secret into api_key
+    from vault.decrypted_secrets
+    where name = 'RESEND_API_KEY'
+    limit 1;
+
+    -- If the API key is not found, do nothing
+    if api_key is null then
+        return;
+    end if;
+
+    -- Construct the email body
+    email_body := 'Tu solicitud de ayuda en ajudadana.es caducará en 1 día y será eliminada automáticamente. Si todavía necesitas ayuda, considera crear una solicitud nueva con datos actualizados.';
+
+    -- Collect email addresses and help request IDs
+    select array_agg(u.email), array_agg(h.id)
+    into email_list, help_request_ids
+    from public.help_requests h
+    join auth.users u on h.user_id = u.id
+    where h.created_at < now() - interval '6 days'
+      and h.created_at >= now() - interval '7 days'
+      and h.expiry_notice_sent = false
+      and h.status = 'active'
+      and h.type = 'necesita'
+      limit 50;
+
+    -- If there are no emails to send, do nothing
+    if email_list is null then
+        return;
+    end if;
+
+    -- Send the email using the resend API
+    select status into status_code from http((
+      'POST',
+      'https://api.resend.com/emails',
+      array[http_header('Authorization','Bearer ' || api_key)],
+      'application/json',
+      '{
+        "from": "Ajudadana <[email protected]>",
+        "to": ["' || array_to_string(email_list, '","') || '"],
+        "subject": "Tu solicitud en Ajudadana.es será eliminada",
+        "html": "<p>' || email_body || '</p>"
+      }'
+    )::http_request);
+
+    if status_code <> 200 then
+       return;
+    end if;
+
+    -- Update the help requests to mark the expiry notice as sent
+    update help_requests set expiry_notice_sent = true where id = any(help_request_ids);
+end;
+$$ language plpgsql;
+
+create or replace function send_offer_expiry_notices() returns void as $$
+declare
+    api_key text;
+    email_body text;
+    email_list text[];
+    help_request_ids bigint[];
+    status_code int;
+begin
+    -- Get the RESEND_API_KEY
+    select decrypted_secret into api_key
+    from vault.decrypted_secrets
+    where name = 'RESEND_API_KEY'
+    limit 1;
+
+    -- If the API key is not found, do nothing
+    if api_key is null then
+        return;
+    end if;
+
+    -- Construct the email body
+    email_body := 'Tu oferta de ayuda en ajudadana.es caducará en 1 día y será eliminada automáticamente. Si lo deseas, crea una oferta de ayuda nueva con datos actualizados.';
+
+    -- Collect email addresses and help request IDs
+    select array_agg(u.email), array_agg(h.id)
+    into email_list, help_request_ids
+    from public.help_requests h
+    join auth.users u on h.user_id = u.id
+    where h.created_at < now() - interval '6 days'
+      and h.created_at >= now() - interval '7 days'
+      and h.expiry_notice_sent = false
+      and h.type = 'ofrece'
+      limit 50;
+
+    -- If there are no emails to send, do nothing
+    if email_list is null then
+        return;
+    end if;
+
+    -- Send the email using the resend API
+    select status into status_code from http((
+      'POST',
+      'https://api.resend.com/emails',
+      array[http_header('Authorization','Bearer ' || api_key)],
+      'application/json',
+      '{
+        "from": "Ajudadana <[email protected]>",
+        "to": ["' || array_to_string(email_list, '","') || '"],
+        "subject": "Tu oferta de ayuda en Ajudadana.es será eliminada",
+        "html": "<p>' || email_body || '</p>"
+      }'
+    )::http_request);
+
+    if status_code <> 200 then
+       return;
+    end if;
+
+    -- Update the help requests to mark the expiry notice as sent
+    update help_requests set expiry_notice_sent = true where id = any(help_request_ids);
+end;
+$$ language plpgsql;