Method fetch

loop-library/worker/src/index.js:828–864

(request)

  }

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

    if (request.method !== "POST") {
      return jsonResponse({ error: "Method not allowed" }, 405);
    }

    let body;

    try {
      body = await request.json();
    } catch {
      return jsonResponse({ error: "Invalid request" }, 400);
    }

    if (url.pathname === "/rate") {
      return this.rate(body);
    }

    if (url.pathname === "/dedupe/reserve") {
      return this.reserve(body);
    }

    if (url.pathname === "/dedupe/release") {
      return this.release(body);
    }

    if (url.pathname === "/idempotency/check") {
      return this.idempotency(body, false);
    }

    if (url.pathname === "/idempotency/bind") {
      return this.idempotency(body, true);
    }

    return jsonResponse({ error: "Not found" }, 404);
  }

  async scheduleCleanup(expiresAt) {
    const scheduledAt = await this.state.storage.getAlarm();