Cloudflare Workers Proxy Setup

// Cloudflare Worker for Rybbit Analytics Proxy

// Proxies every /analytics/* route (script.js, replay.js, track, identify,
// site/tracking-config/:siteId, site/:siteId/feature-flags/evaluate,
// session-replay/record/:siteId) to Rybbit's /api/*.

const RYBBIT_HOST = 'https://app.rybbit.io';

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

    // Only proxy /analytics/* paths
    if (!url.pathname.startsWith('/analytics/')) {
      // Pass through to origin
      return fetch(request);
    }

    try {
      return await proxyToRybbit(request, url);
    } catch (error) {
      console.error('Proxy error:', error);
      return new Response('Analytics proxy error', { status: 500 });
    }
  },
};

async function proxyToRybbit(request, url) {
  // Map paths: /analytics/* → /api/*
  let rybbitPath = url.pathname.replace('/analytics/', '/api/');

  // Build Rybbit URL
  const rybbitUrl = new URL(rybbitPath, RYBBIT_HOST);
  rybbitUrl.search = url.search; // Preserve query params

  // Get client IP
  const clientIp = request.headers.get('CF-Connecting-IP') ||
                   request.headers.get('X-Forwarded-For') ||
                   '0.0.0.0';

  // Build request headers
  const proxyHeaders = new Headers(request.headers);
  proxyHeaders.set('X-Real-IP', clientIp);
  proxyHeaders.set('X-Forwarded-For', clientIp);
  proxyHeaders.delete('CF-Connecting-IP'); // Remove Cloudflare internal header

  // Build proxy request
  const proxyRequest = new Request(rybbitUrl, {
    method: request.method,
    headers: proxyHeaders,
    body: request.method !== 'GET' && request.method !== 'HEAD' ? request.body : undefined,
  });

  // Check cache for GET requests
  if (request.method === 'GET') {
    const cache = caches.default;
    let response = await cache.match(proxyRequest);

    if (response) {
      // Return cached response
      return new Response(response.body, {
        status: response.status,
        statusText: response.statusText,
        headers: {
          ...Object.fromEntries(response.headers),
          'X-Cache-Status': 'HIT',
        },
      });
    }
  }

  // Fetch from Rybbit
  const response = await fetch(proxyRequest);

  // Cache scripts for 1 hour
  if (request.method === 'GET' && url.pathname.match(/\.(js)$/)) {
    const cacheResponse = new Response(response.body, response);
    cacheResponse.headers.set('Cache-Control', 'public, max-age=3600');
    cacheResponse.headers.set('X-Cache-Status', 'MISS');

    // Clone and cache
    const cache = caches.default;
    await cache.put(proxyRequest, cacheResponse.clone());

    return cacheResponse;
  }

  // Return non-cacheable response
  return new Response(response.body, {
    status: response.status,
    statusText: response.statusText,
    headers: response.headers,
  });
}

// Minimal Cloudflare Worker for Rybbit

const RYBBIT_HOST = 'https://app.rybbit.io';

export default {
  async fetch(request) {
    const url = new URL(request.url);

    // Only proxy /analytics/script.js and /analytics/track
    if (url.pathname === '/analytics/script.js' || url.pathname === '/analytics/track') {
      const rybbitPath = url.pathname.replace('/analytics/', '/api/');
      const rybbitUrl = `${RYBBIT_HOST}${rybbitPath}${url.search}`;

      const clientIp = request.headers.get('CF-Connecting-IP') || '0.0.0.0';

      const proxyHeaders = new Headers(request.headers);
      proxyHeaders.set('X-Real-IP', clientIp);
      proxyHeaders.set('X-Forwarded-For', clientIp);

      return fetch(rybbitUrl, {
        method: request.method,
        headers: proxyHeaders,
        body: request.method === 'POST' ? request.body : undefined,
      });
    }

    // Pass through to origin
    return fetch(request);
  },
};

export default {
  async fetch(request, env) {
    const RYBBIT_HOST = env.RYBBIT_HOST || 'https://app.rybbit.io';
    const url = new URL(request.url);

    if (!url.pathname.startsWith('/analytics/')) {
      return fetch(request);
    }

    // Map paths: /analytics/* → /api/*
    const rybbitUrl = new URL(url.pathname.replace('/analytics/', '/api/'), RYBBIT_HOST);
    rybbitUrl.search = url.search; // Preserve query params (e.g. ?siteId=)

    const clientIp = request.headers.get('CF-Connecting-IP') || '0.0.0.0';

    const proxyHeaders = new Headers(request.headers);
    proxyHeaders.set('X-Real-IP', clientIp);
    proxyHeaders.set('X-Forwarded-For', clientIp);

    return fetch(rybbitUrl.toString(), {
      method: request.method,
      headers: proxyHeaders,
      body: request.method !== 'GET' && request.method !== 'HEAD' ? request.body : undefined,
    });
  },
};