Function fetch

apps/proxy/src/index.ts:19–46

(request: Request, env: Env, ctx: ExecutionContext)

export default {
  async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
    if (!env.REWRITE_HOSTNAME) throw new Error("Missing REWRITE_HOSTNAME");
    console.log("url", request.url);

    if (!queueingIsEnabled(env)) {
      console.log("Missing AWS credentials. Passing through to the origin.");
      return redirectToOrigin(request, env);
    }

    const url = new URL(request.url);
    switch (url.pathname) {
      case "/api/v1/events": {
        if (request.method === "POST") {
          return applyRateLimit(request, env, () => queueEvent(request, env));
        }
        break;
      }
      case "/api/v1/events/bulk": {
        if (request.method === "POST") {
          return applyRateLimit(request, env, () => queueEvents(request, env));
        }
        break;
      }
    }

    //the same request but with the hostname (and port) changed
    return redirectToOrigin(request, env);
  },
};

function redirectToOrigin(request: Request, env: Env) {