TanStack Start SaaS Template

import { db } from '@/lib/db';
import { referrals, users } from '@/lib/schema';
import { grantReferralReward } from '@/lib/referral';

// TanStack Start + Cloudflare Workers · Referral reward grant
export async function POST(req: Request) {
  // 1. Query Cloudflare D1 for referral relation
  const relation = await db.select().from(referrals)
    .where(eq(referrals.code, 'MOKER8X'));

  // 2. Auto-grant credits + extend subscription days
  const reward = await grantReferralReward({
    referralId: relation[0].id,
    refereeId: relation[0].referredId,
    plan: 'pro',
  });

  // 3. Insert into Drizzle ORM history + trigger webhook
  await db.insert(referralHistory).values({
    userId: relation[0].referrerId,
    action: 'subscription_reward',
    pointsAwarded: reward.points,
    subscriptionDaysExtended: reward.days,
  });

  return Response.json({ ok: true, reward });
}