Integraciones y APIs: Conecta Cadences con Todo

// Worker: Validar token de Google en el edge
async function validateGoogleAuth(request, storefrontConfig) {
  const token = request.headers.get('Authorization')
    ?.replace('Bearer ', '');

  // Verificar token con Google
  const googleResponse = await fetch(
    'https://www.googleapis.com/oauth2/v3/tokeninfo?access_token=' + token
  );
  const googleData = await googleResponse.json();

  // ¿El email está autorizado para este storefront?
  const authorized = storefrontConfig
    .authorizedEmails
    .includes(googleData.email);

  if (!authorized) {
    return new Response('Unauthorized', { status: 403 });
  }

  return { email: googleData.email, verified: true };
}

// El agente define qué provider usar
const agent = {
  name: "Analista de Ventas",
  provider: "gemini",      // o "deepseek", "openai", "anthropic"
  model: "gemini-2.0-flash",
  system_prompt: "Eres un analista de ventas experto..."
};

// El servicio de ejecución abstrae las diferencias
async function generateContent(agent, prompt) {
  switch (agent.provider) {
    case "gemini":
      return await callGemini(agent.model, prompt);
    case "deepseek":
      return await callOpenAICompatible(
        "https://api.deepseek.com", agent.model, prompt
      );
    case "openai":
      return await callOpenAICompatible(
        "https://api.openai.com", agent.model, prompt
      );
    case "anthropic":
      return await callAnthropic(agent.model, prompt);
  }
}

// Worker: recibe webhook de Stripe
export async function handleStripeWebhook(request, env) {
  // 1. Verificar firma del webhook
  const signature = request.headers.get('stripe-signature');
  const body = await request.text();
  const event = verifyStripeSignature(body, signature, env.STRIPE_WEBHOOK_SECRET);

  // 2. Procesar según el tipo de evento
  switch (event.type) {
    case 'payment_intent.succeeded':
      // 3. Buscar contacto en el CRM por email
      const contact = await db.prepare(
        'SELECT * FROM contacts WHERE email = ?'
      ).bind(event.data.object.receipt_email).first();

      // 4. Crear actividad en el timeline del contacto
      await db.prepare('INSERT INTO activities ...').bind(
        contact.id, 'payment', event.data.object.amount
      ).run();

      // 5. Disparar workflow "Nuevo pago recibido"
      await triggerWorkflow('payment-received', {
        contact, amount: event.data.object.amount
      });
      break;
  }

  return new Response('OK', { status: 200 });
}