VoxLegal — Deepgram Webhook Handler

import { createClient } from '@supabase/supabase-js';
import sgMail from '@sendgrid/mail';

const supabase = createClient(
  process.env.SUPABASE_URL,
  process.env.SUPABASE_SERVICE_KEY
);

// ── Middleware: verificar dg-token ──────────────────
const verifyDgToken = (req, res, next) => {
  const dgToken = req.headers['dg-token'];
  if (!dgToken) {
    return res.status(401).json({ error: 'Missing dg-token' });
  }
  if (dgToken !== process.env.DEEPGRAM_API_KEY_ID) {
    return res.status(403).json({ error: 'Invalid dg-token' });
  }
  next();
};

// ── Endpoint principal ──────────────────────────────
router.post(
  '/webhooks/deepgram',
  express.raw({ type: 'application/json' }),
  verifyDgToken,
  async (req, res) => {
    try {
      const result = JSON.parse(req.body.toString());
      const { request_id, results, duration } = result;
      const transcript =
        results.channels[0].alternatives[0].transcript;
      const confidence =
        results.channels[0].alternatives[0].confidence;

      // 1. Guardar en Supabase
      const { data, error } = await supabase
        .from('transcriptions')
        .update({
          status:     'completed',
          transcript,
          confidence,
          duration_s:  duration,
          completed_at: new Date().toISOString(),
        })
        .eq('deepgram_request_id', request_id)
        .select('lawyer_email, case_ref');

      if (error) throw error;

      // 2. Notificar al abogado (SendGrid)
      if (data?.[0]?.lawyer_email) {
        await sgMail.send({
          to:      data[0].lawyer_email,
          from:    'actas@voxlegal.io',
          subject: `Acta lista · Expediente ${data[0].case_ref}`,
          text:    `Transcripción completada. Confianza: ${confidence}`,
        });
      }

      // Deepgram NO reintentará si devolvemos 2xx
      return res.status(200).json({ ok: true });

    } catch (err) {
      console.error('[deepgram-webhook] Error:', err);
      // Retornar 5xx → Deepgram reintentará hasta 10x
      return res.status(500).json({ error: 'Processing failed' });
    }
  }
);