Integrations and APIs: Connect Cadences with Everything

// Worker: Validate Google token at the edge
async function validateGoogleAuth(request, storefrontConfig) {
  const token = request.headers.get('Authorization')
    ?.replace('Bearer ', '');

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

  // Is the email authorized for this storefront?
  const authorized = storefrontConfig
    .authorizedEmails
    .includes(googleData.email);

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

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

// The agent defines which provider to use
const agent = {
  name: "Sales Analyst",
  provider: "gemini",      // or "deepseek", "openai", "anthropic"
  model: "gemini-2.0-flash",
  system_prompt: "You are an expert sales analyst..."
};

// The execution service abstracts the differences
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: receive Stripe webhook
export async function handleStripeWebhook(request, env) {
  // 1. Verify webhook signature
  const signature = request.headers.get('stripe-signature');
  const body = await request.text();
  const event = verifyStripeSignature(body, signature, env.STRIPE_WEBHOOK_SECRET);

  // 2. Process by event type
  switch (event.type) {
    case 'payment_intent.succeeded':
      // 3. Find contact in CRM by email
      const contact = await db.prepare(
        'SELECT * FROM contacts WHERE email = ?'
      ).bind(event.data.object.receipt_email).first();

      // 4. Create activity in contact timeline
      await db.prepare('INSERT INTO activities ...').bind(
        contact.id, 'payment', event.data.object.amount
      ).run();

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

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