Shopify + Cloudflare

/**
 * Cloudflare Worker - stream page views to analytics server
 *
 * Sends JSON in the expected crawler logs schema.
 * Content type filtering is handled server-side.
 */
const ANALYTICS_ENDPOINT = "https://logs.promptwatch.com/event";

export default {
  async fetch(request, env, ctx) {
    const { pathname, search } = new URL(request.url);

    // 1. Make the upstream request (cache/origin)
    const response = await fetch(request);
    
    const contentType = response.headers.get("content-type")?.split(";")[0];
    const queryString = search.startsWith("?") && search.length > 1 ? search.slice(1) : null;

    // 2. Build the log object
    const log = {
      timestamp: new Date().toISOString(),
      status_code: response.status,
      request_method: request.method,
      request_path: pathname,
      query_string: queryString,
      content_type: contentType,
      client_ip: request.headers.get("CF-Connecting-IP") || null,
      hostname: request.headers.get("Host") || null,
      user_agent: request.headers.get("User-Agent") || null,
      referrer: request.headers.get("Referer") || null,
    };

    // 3. Fire-and-forget upload - never delays the visitor
    ctx.waitUntil(
      fetch(ANALYTICS_ENDPOINT, {
        method: "POST",
        headers: {
          "Content-Type": "application/json",
          "X-API-Key": env.ANALYTICS_KEY,
        },
        body: JSON.stringify(log),
      }).catch(() => {}), // swallow network errors
    );

    return response;
  },
};