// workers/order-webhook.js // Deploy: wrangler deploy // Route: api.orderahead.merchdot.com/webhooks/order-created export default { async fetch(request, env) { const order = await request.json(); // 1. Write venue metafields to order (Admin API) await shopifyAdmin(env, `/orders/${order.id}/metafields`, { metafield: { namespace: "merchdot", key: "venue_id", value: order.note_attributes?.find( a => a.name === "venue_id")?.value, type: "single_line_text_field" } }); // 2. Tag customer TC-MEMBER via Admin API // (Shopify Flow also handles this — belt + braces) await tagCustomer(env, order.customer.id, "TC-MEMBER"); // 3. Fire Klaviyo event → triggers Welcome Series await klaviyoEvent(env, order.customer.email, "tc_member_joined", { source: "PWA", venue: order.note_attributes?.find(a => a.name === "venue_id")?.value, show: "maybe-happy-ending" }); // 4. Notify staff dashboard (real-time queue update) await env.STAFF_QUEUE.put( `order:${order.id}`, JSON.stringify({ order, status: "new" }) ); return new Response("OK", { status: 200 }); } };