JSONをPOSTする

JavaScript

export default {
  async fetch(request) {
    /**
     * 例としてsomeHostはJSONリクエストを受け取るように設定されています
     * リクエストを送信したいホストでurlを置き換えてください
     * @param {string} url リクエストを送信するURL
     * @param {BodyInit} body リクエストに送信するJSONデータ
     */
    const someHost = "https://examples.cloudflareworkers.com/demos";
    const url = someHost + "/requests/json";
    const body = {
      results: ["送信するデフォルトデータ"],
      errors: null,
      msg: "これをfetchに送信しました",
    };

    /**
     * gatherResponseはレスポンスボディを文字列として待機し、返します。
     * async関数内でawait gatherResponse(..)を使用してレスポンスボディを取得します
     * @param {Response} response
     */
    async function gatherResponse(response) {
      const { headers } = response;
      const contentType = headers.get("content-type") || "";
      if (contentType.includes("application/json")) {
        return JSON.stringify(await response.json());
      } else if (contentType.includes("application/text")) {
        return response.text();
      } else if (contentType.includes("text/html")) {
        return response.text();
      } else {
        return response.text();
      }
    }

    const init = {
      body: JSON.stringify(body),
      method: "POST",
      headers: {
        "content-type": "application/json;charset=UTF-8",
      },
    };
    const response = await fetch(url, init);
    const results = await gatherResponse(response);
    return new Response(results, init);
  },
};

TypeScript

export default {
  async fetch(request): Promise<Response> {
    /**
     * 例としてsomeHostはJSONリクエストを受け取るように設定されています
     * リクエストを送信したいホストでurlを置き換えてください
     * @param {string} url リクエストを送信するURL
     * @param {BodyInit} body リクエストに送信するJSONデータ
     */
    const someHost = "https://examples.cloudflareworkers.com/demos";
    const url = someHost + "/requests/json";
    const body = {
      results: ["送信するデフォルトデータ"],
      errors: null,
      msg: "これをfetchに送信しました",
    };

    /**
     * gatherResponseはレスポンスボディを文字列として待機し、返します。
     * async関数内でawait gatherResponse(..)を使用してレスポンスボディを取得します
     * @param {Response} response
     */
    async function gatherResponse(response) {
      const { headers } = response;
      const contentType = headers.get("content-type") || "";
      if (contentType.includes("application/json")) {
        return JSON.stringify(await response.json());
      } else if (contentType.includes("application/text")) {
        return response.text();
      } else if (contentType.includes("text/html")) {
        return response.text();
      } else {
        return response.text();
      }
    }

    const init = {
      body: JSON.stringify(body),
      method: "POST",
      headers: {
        "content-type": "application/json;charset=UTF-8",
      },
    };
    const response = await fetch(url, init);
    const results = await gatherResponse(response);
    return new Response(results, init);
  },
} satisfies ExportedHandler;

Python

import json
from pyodide.ffi import to_js as _to_js
from js import Object, fetch, Response, Headers

def to_js(obj):
    return _to_js(obj, dict_converter=Object.fromEntries)

# gather_responseはcontent-typeとレスポンスボディを文字列として返します
async def gather_response(response):
    headers = response.headers
    content_type = headers["content-type"] or ""

    if "application/json" in content_type:
        return (content_type, json.dumps(dict(await response.json())))
    return (content_type, await response.text())

async def on_fetch(_request):
    url = "https://jsonplaceholder.typicode.com/todos/1"

    body = {
      "results": ["送信するデフォルトデータ"],
      "errors": None,
      "msg": "これをfetchに送信しました",
    }

    options = {
      "body": json.dumps(body),
      "method": "POST",
      "headers": {
        "content-type": "application/json;charset=UTF-8",
      },
    }

    response = await fetch(url, to_js(options))
    content_type, result = await gather_response(response)

    headers = Headers.new({"content-type": content_type}.items())
    return Response.new(result, headers=headers)