Wire It All Together

-- Core tables for a revenue-generating AI app

CREATE TABLE subscribers (
  id         uuid DEFAULT gen_random_uuid() PRIMARY KEY,
  email      text UNIQUE NOT NULL,
  name       text,
  created_at timestamptz DEFAULT now()
);

CREATE TABLE revenue (
  id                uuid DEFAULT gen_random_uuid() PRIMARY KEY,
  amount            int4,        -- in cents (Stripe standard)
  product           text,
  customer_email    text,
  stripe_session_id text UNIQUE, -- prevents duplicate processing
  created_at        timestamptz DEFAULT now()
);

-- Enable RLS — critical for security
ALTER TABLE subscribers ENABLE ROW LEVEL SECURITY;
ALTER TABLE revenue ENABLE ROW LEVEL SECURITY;

import { createClient } from "https://esm.sh/@supabase/supabase-js@2"
import { Resend } from "https://esm.sh/resend"

const supabase = createClient(
  Deno.env.get("SUPABASE_URL")!,
  Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!
)
const resend = new Resend(Deno.env.get("RESEND_API_KEY")!)

Deno.serve(async (req) => {
  const { email, name } = await req.json()

  // 1. Store in Supabase (UNIQUE constraint rejects duplicates)
  const { error } = await supabase
    .from("subscribers")
    .insert({ email, name })

  if (error?.code === "23505") {
    // Already subscribed — not an error, just skip
    return new Response(JSON.stringify({ status: "already_subscribed" }))
  }

  // 2. Send welcome email via Resend
  await resend.emails.send({
    from: "hello@yourdomain.com",
    to: email,
    subject: `Welcome, ${name || "friend"}!`,
    html: `<p>Thanks for joining. You're in.</p>`
  })

  return new Response(JSON.stringify({ status: "subscribed" }))
})

import Stripe from "https://esm.sh/stripe@14"

const stripe = new Stripe(Deno.env.get("STRIPE_SECRET_KEY")!)

Deno.serve(async (req) => {
  const { price_id } = await req.json()

  // Create checkout session — Stripe hosts the payment page
  const session = await stripe.checkout.sessions.create({
    mode: "payment",
    line_items: [{ price: price_id, quantity: 1 }],
    success_url: "https://yourdomain.com/success",
    cancel_url: "https://yourdomain.com",
  })

  // Return the Stripe-hosted checkout URL
  return new Response(JSON.stringify({ url: session.url }))
})

// Verify signature → Process event → Log revenue
const body = await req.text()  // Raw text — never req.json()
const sig = req.headers.get("stripe-signature")!
const event = stripe.webhooks.constructEvent(
  body, sig, Deno.env.get("STRIPE_WEBHOOK_SECRET")!
)

if (event.type === "checkout.session.completed") {
  const session = event.data.object
  await supabase.from("revenue").insert({
    amount: session.amount_total,
    customer_email: session.customer_details?.email,
    stripe_session_id: session.id  // UNIQUE — idempotent
  })
}

# Deploy to production
git add . && git commit -m "wire complete stack"
git push origin main
# Vercel auto-deploys from main → live in ~60 seconds

# Required environment variables in Vercel dashboard:
NEXT_PUBLIC_SUPABASE_URL=https://<ref>.supabase.co
NEXT_PUBLIC_SUPABASE_ANON_KEY=eyJhbGciOi...

// Make.com Scenarios to create:

Scenario 1: New Subscriber Alert
  Trigger: Supabase webhook (INSERT on subscribers)
  → Slack: Post to #growth channel

Scenario 2: Revenue Celebration
  Trigger: Supabase webhook (INSERT on revenue)
  → Filter: amount > 5000  // $50+ (amounts in cents)
  → Slack: Post to #revenue channel
  → Google Sheets: Log to analytics spreadsheet

Scenario 3: Daily Digest
  Trigger: Schedule (every day at 9am)
  → Supabase: Count today's subscribers + revenue
  → Slack: Post daily summary to #dashboard