import { supabase } from '@/lib/supabaseClient'; // já pensando que estamos usando Supabase
import { sendEmail } from '@/lib/email';
import { sendWhatsApp } from '@/lib/whatsapp';

async function dispararAlertas() {
  const hoje = new Date().toISOString().split('T')[0]; // data no formato yyyy-mm-dd

  const { data: alertas, error } = await supabase
    .from('alerts')
    .select('*')
    .eq('status', 'pendente')
    .eq('data_alerta', hoje);

  if (error) {
    console.error('Erro buscando alertas:', error);
    return;
  }

  for (const alerta of alertas) {
    try {
      // Enviar E-mail
      await sendEmail(alerta);

      // Enviar WhatsApp
      await sendWhatsApp(alerta);

      // Atualizar o status para "enviado"
      await supabase
        .from('alerts')
        .update({ status: 'enviado', enviado_em: new Date() })
        .eq('id', alerta.id);

      console.log(`Alerta ${alerta.id} enviado com sucesso.`);

    } catch (e) {
      console.error(`Erro enviando alerta ${alerta.id}:`, e);
    }
  }
}

// Executar
dispararAlertas();
