POSTを読む

JavaScript

export default {
  async fetch(request) {
    /**
     * rawHtmlResponseは、ワーカースクリプトに直接入力されたHTMLを返します
     * @param {string} html
     */
    function rawHtmlResponse(html) {
      return new Response(html, {
        headers: {
          "content-type": "text/html;charset=UTF-8",
        },
      });
    }

    /**
     * readRequestBodyは、受信リクエストボディを読み取ります
     * 非同期関数内でawait readRequestBody(..)を使用して文字列を取得します
     * @param {Request} request 読み取る受信リクエスト
     */
    async function readRequestBody(request) {
      const contentType = request.headers.get("content-type");
      if (contentType.includes("application/json")) {
        return JSON.stringify(await request.json());
      } else if (contentType.includes("application/text")) {
        return request.text();
      } else if (contentType.includes("text/html")) {
        return request.text();
      } else if (contentType.includes("form")) {
        const formData = await request.formData();
        const body = {};
        for (const entry of formData.entries()) {
          body[entry[0]] = entry[1];
        }
        return JSON.stringify(body);
      } else {
        // フォームに他のタイプのデータが送信された可能性があります
        // 例えば画像や他のバイナリデータなど。
        return "ファイル";
      }
    }

    const { url } = request;
    if (url.includes("form")) {
      return rawHtmlResponse(someForm);
    }
    if (request.method === "POST") {
      const reqBody = await readRequestBody(request);
      const retBody = `送信されたリクエストボディは ${reqBody} です`;
      return new Response(retBody);
    } else if (request.method === "GET") {
      return new Response("リクエストはGETでした");
    }
  },
};

TypeScript

export default {
  async fetch(request): Promise<Response> {
    /**
     * rawHtmlResponseは、ワーカースクリプトに直接入力されたHTMLを返します
     * @param {string} html
     */
    function rawHtmlResponse(html) {
      return new Response(html, {
        headers: {
          "content-type": "text/html;charset=UTF-8",
        },
      });
    }

    /**
     * readRequestBodyは、受信リクエストボディを読み取ります
     * 非同期関数内でawait readRequestBody(..)を使用して文字列を取得します
     * @param {Request} request 読み取る受信リクエスト
     */
    async function readRequestBody(request: Request) {
      const contentType = request.headers.get("content-type");
      if (contentType.includes("application/json")) {
        return JSON.stringify(await request.json());
      } else if (contentType.includes("application/text")) {
        return request.text();
      } else if (contentType.includes("text/html")) {
        return request.text();
      } else if (contentType.includes("form")) {
        const formData = await request.formData();
        const body = {};
        for (const entry of formData.entries()) {
          body[entry[0]] = entry[1];
        }
        return JSON.stringify(body);
      } else {
        // フォームに他のタイプのデータが送信された可能性があります
        // 例えば画像や他のバイナリデータなど。
        return "ファイル";
      }
    }

    const { url } = request;
    if (url.includes("form")) {
      return rawHtmlResponse(someForm);
    }
    if (request.method === "POST") {
      const reqBody = await readRequestBody(request);
      const retBody = `送信されたリクエストボディは ${reqBody} です`;
      return new Response(retBody);
    } else if (request.method === "GET") {
      return new Response("リクエストはGETでした");
    }
  },
} satisfies ExportedHandler;

Python

from js import Object, Response, Headers, JSON

async def read_request_body(request):
    headers = request.headers
    content_type = headers["content-type"] or ""

    if "application/json" in content_type:
        return JSON.stringify(await request.json())
    if "form" in content_type:
        form = await request.formData()
        data = Object.fromEntries(form.entries())
        return JSON.stringify(data)
    return await request.text()

async def on_fetch(request):
    def raw_html_response(html):
        headers = Headers.new({"content-type": "text/html;charset=UTF-8"}.items())
        return Response.new(html, headers=headers)

    if "form" in request.url:
        return raw_html_response("")

    if "POST" in request.method:
        req_body = await read_request_body(request)
        ret_body = f"送信されたリクエストボディは {req_body} です"
        return Response.new(ret_body)

    return Response.new("リクエストはPOSTではありません")

Rust

use serde::{Deserialize, Serialize};
use worker::*;

fn raw_html_response(html: &str) -> Result<Response> {
    Response::from_html(html)
}

#[derive(Deserialize, Serialize, Debug)]
struct Payload {
    msg: String,
}

async fn read_request_body(mut req: Request) -> String {
    let ctype = req.headers().get("content-type").unwrap().unwrap();
    match ctype.as_str() {
        "application/json" => format!("{:?}", req.json::<Payload>().await.unwrap()),
        "text/html" => req.text().await.unwrap(),
        "multipart/form-data" => format!("{:?}", req.form_data().await.unwrap()),
        _ => String::from("ファイル"),
    }
}

#[event(fetch)]
async fn fetch(req: Request, _env: Env, _ctx: Context) -> Result<Response> {
    if String::from(req.url()?).contains("form") {
        return raw_html_response("some html form");
    }

    match req.method() {
        Method::Post => {
            let req_body = read_request_body(req).await;
            Response::ok(format!("送信されたリクエストボディは {}", req_body))
        }
        _ => Response::ok(format!("結果は {:?}", req.method())),
    }
}