feat: AI-scraped coupon submission

Submit form collects URL + code + discount type/value + expiry; "Fetch
details" calls POST /api/scrape (lib/scrape.ts, Claude claude-opus-4-8,
structured JSON output) to extract title/description/store/image from the
page. POST /api/coupons auto-resolves/creates the store by domain and
persists structured discount fields.

Adds coupons columns discount_type, discount_value, image_url (schema.sql
+ idempotent migrate.mjs). Requires ANTHROPIC_API_KEY at runtime (read
lazily in getClient()).

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

Author: ralyodio

apps/web/app/api/coupons/route.ts

@@ -1,5 +1,6 @@
 import { NextRequest, NextResponse } from 'next/server';
 import { getDb } from '@/lib/db';
+import type { DiscountType } from '@/lib/types';
 
 export async function GET(req: NextRequest) {
   const { searchParams } = new URL(req.url);
@@ -22,19 +23,106 @@ export async function GET(req: NextRequest) {
   }
 }
 
+function slugify(value: string): string {
+  return value
+    .toLowerCase()
+    .replace(/[^a-z0-9]+/g, '-')
+    .replace(/(^-|-$)/g, '');
+}
+
+/** Human-readable badge text from structured discount fields. */
+function formatDiscount(type: DiscountType | null, value: number | null): string | null {
+  if (value == null || Number.isNaN(value)) return null;
+  if (type === 'percent') return `${value}%`;
+  if (type === 'fixed') return `$${value} off`;
+  return null;
+}
+
+/**
+ * Resolve a store by website domain (preferred) or name, creating it if needed.
+ * Returns the store id.
+ */
+async function resolveStoreId(
+  db: ReturnType<typeof getDb>,
+  opts: { name: string | null; website: string | null; logoCandidate: string | null }
+): Promise<number> {
+  const name = opts.name?.trim() || null;
+
+  // Derive a stable slug: prefer the website host, fall back to the name.
+  let slugBase = name;
+  let website = opts.website?.trim() || null;
+  if (website) {
+    try {
+      const host = new URL(website).hostname.replace(/^www\./, '');
+      slugBase = slugBase ?? host.split('.')[0];
+      website = `${new URL(website).protocol}//${new URL(website).hostname}`;
+    } catch {
+      /* keep website as-is */
+    }
+  }
+  if (!slugBase) slugBase = 'unknown-store';
+  const slug = slugify(slugBase) || 'unknown-store';
+
+  const existing = await db.sql`SELECT id FROM stores WHERE slug = ${slug} LIMIT 1`;
+  if (existing.length > 0) return existing[0].id;
+
+  await db.sql`
+    INSERT INTO stores (name, slug, website)
+    VALUES (${name ?? slugBase}, ${slug}, ${website})
+  `;
+  const created = await db.sql`SELECT id FROM stores WHERE slug = ${slug} LIMIT 1`;
+  return created[0].id;
+}
+
 export async function POST(req: NextRequest) {
   try {
     const body = await req.json();
-    const { store_id, code, title, description, discount, expiry_date, url } = body;
+    const {
+      url,
+      code,
+      discount_type,
+      discount_value,
+      expiry_date,
+      // AI-scraped listing metadata
+      title,
+      description,
+      store_name,
+      store_website,
+      image_url,
+    } = body;
 
-    if (!store_id || !title) {
-      return NextResponse.json({ error: 'store_id and title are required' }, { status: 400 });
+    if (!url) {
+      return NextResponse.json({ error: 'url is required' }, { status: 400 });
     }
+    if (!title) {
+      return NextResponse.json(
+        { error: 'title is required (scrape the URL first)' },
+        { status: 400 }
+      );
+    }
+
+    const type: DiscountType | null =
+      discount_type === 'percent' || discount_type === 'fixed' ? discount_type : null;
+    const value =
+      discount_value === '' || discount_value == null ? null : Number(discount_value);
+    const discount = formatDiscount(type, value);
 
     const db = getDb();
+    const storeId = await resolveStoreId(db, {
+      name: store_name ?? null,
+      website: store_website ?? null,
+      logoCandidate: image_url ?? null,
+    });
+
     await db.sql`
-      INSERT INTO coupons (store_id, code, title, description, discount, expiry_date, url)
-      VALUES (${store_id}, ${code}, ${title}, ${description}, ${discount}, ${expiry_date}, ${url})
+      INSERT INTO coupons (
+        store_id, code, title, description, discount, discount_type, discount_value,
+        expiry_date, url, image_url
+      )
+      VALUES (
+        ${storeId}, ${code?.trim() || null}, ${title}, ${description ?? null}, ${discount},
+        ${type}, ${value}, ${expiry_date || null}, ${url}, ${image_url ?? null}
+      )
     `;
     return NextResponse.json({ success: true }, { status: 201 });
   } catch (err) {

apps/web/app/api/scrape/route.ts

@@ -0,0 +1,37 @@
+import { NextRequest, NextResponse } from 'next/server';
+import { scrapeListing } from '@/lib/scrape';
+
+// Scraping fetches an external page and calls Claude — give it room.
+export const maxDuration = 60;
+
+export async function POST(req: NextRequest) {
+  let url: string;
+  try {
+    ({ url } = await req.json());
+  } catch {
+    return NextResponse.json({ error: 'Invalid request body' }, { status: 400 });
+  }
+
+  if (!url || typeof url !== 'string') {
+    return NextResponse.json({ error: 'url is required' }, { status: 400 });
+  }
+
+  let parsed: URL;
+  try {
+    parsed = new URL(url);
+  } catch {
+    return NextResponse.json({ error: 'url is not a valid URL' }, { status: 400 });
+  }
+  if (parsed.protocol !== 'http:' && parsed.protocol !== 'https:') {
+    return NextResponse.json({ error: 'url must be http or https' }, { status: 400 });
+  }
+
+  try {
+    const listing = await scrapeListing(parsed.toString());
+    return NextResponse.json(listing);
+  } catch (err) {
+    console.error('scrape failed:', err);
+    const message = err instanceof Error ? err.message : 'Failed to scrape URL';
+    return NextResponse.json({ error: message }, { status: 502 });
+  }
+}