#f4ah6o/http11

#概要

• 依存ライブラリなし: MoonBit 標準ライブラリのみで動作
• DoS 攻撃対策: デコーダーリミット機能でリソース枯渇攻撃を防御
• HTTP/1.1 準拠: Content-Length および chunked 転送エンコーディングに対応

#モジュール構成

#コアモジュール

#URI / URL

#HTTP ヘッダー

#コンテント関連ヘッダー

#キャッシュ / 認証

#認証 / クッキー / 受入

#日付

#エラー型

///|
pub enum HttpError {
  InvalidData(String) // 不正なデータ
  BufferOverflow(Int, Int) // (size, limit)
  TooManyHeaders(Int, Int) // (count, limit)
  HeaderLineTooLong(Int, Int) // (size, limit)
  BodyTooLarge(Int, Int) // (size, limit)
  UnexpectedEof // 予期しない EOF
  InvalidHeaderValue // 不正なヘッダー値
  InvalidStatusCode // 不正なステータスコード
  InvalidChunkSize // 不正なチャンクサイズ
}

#デコーダーリミット

///|
pub struct DecoderLimits {
  max_buffer_size : Int // デフォルト: 65536
  max_headers_count : Int // デフォルト: 100
  max_header_line_size : Int // デフォルト: 8192
  max_body_size : Int // デフォルト: 10485760 (10MB)
}

// デフォルトリミットで作成

///|
let decoder = RequestDecoder::new()

// カスタムリミットで作成

///|
let limits = {
  max_buffer_size: 32768,
  max_headers_count: 50,
  max_header_line_size: 4096,
  max_body_size: 5242880,
}

///|
let decoder = RequestDecoder::with_limits(limits)

// 無制限（テスト用途）

///|
let decoder = RequestDecoder::with_limits(DecoderLimits::unlimited())

#リクエスト

#作成とエンコード

// 基本的なリクエスト作成

///|
let req = Request::new("GET", "/test")
  .header("Host", "example.com")
  .header("Connection", "keep-alive")

// ボディ付きリクエスト

///|
let req = Request::new("POST", "/api")
  .header("Content-Type", "application/json")
  .body("{\"key\":\"value\"}".to_bytes())

// バージョン指定

///|
let req = Request::with_version("GET", "/", "HTTP/1.0")

// エンコード

///|
let encoded = encode_request(req)
// GET /test HTTP/1.1\r\nHost: example.com\r\nConnection: keep-alive\r\n\r\n

#ヘルパーメソッド

req.http_method()         // "GET"
req.get_header("Host")    // Some("example.com")
req.has_header("Host")    // true
req.is_keep_alive()       // true
req.content_length()      // Some(123)
req.is_chunked()          // false

#レスポンス

#作成とエンコード

// 基本的なレスポンス作成

///|
let resp = Response::new(200, "OK")
  .header("Content-Type", "text/plain")
  .header("Content-Length", "5")

// ボディ付きレスポンス

///|
let resp = Response::new(404, "Not Found")
  .header("Content-Type", "text/html")
  .body("<h1>Not Found</h1>".to_bytes())

// エンコード

///|
let encoded = encode_response(resp)
// HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nContent-Length: 5\r\n\r\n

#ステータスチェック

resp.is_success()      // 200-299
resp.is_redirect()     // 300-399
resp.is_client_error() // 400-499
resp.is_server_error() // 500-599

#デコーダー（Sans I/O）

#リクエストデコード

let decoder = RequestDecoder::new()

// データをフィード
decoder.feed(data)?

// デコード試行
match decoder.decode() {
  Ok(Some(request)) => // リクエスト完了
    // request.http_method, request.uri, request.headers, request.body
  Ok(None) => // データが不十分 - 更にデータを feed して再試行
  Err(e) => // エラー処理
}

// デコーダーをリセットして次のリクエストに備える
decoder.reset()

// 未処理のデータを取得
let remaining = decoder.remaining()

#レスポンスデコード

let decoder = ResponseDecoder::new()

decoder.feed(data)?
match decoder.decode() {
  Ok(Some(response)) => // レスポンス完了
    // response.status_code, response.reason_phrase, response.headers, response.body
  Ok(None) => // データが不十分
  Err(e) => // エラー処理
}

#URI パース（RFC 3986）

// URI パース

///|
let uri = Uri::parse("https://example.com:8080/path?query=value#fragment")

// アクセサー
uri.scheme()      // Some("https")
uri.host()        // Some("example.com")
uri.port()        // Some(8080)
uri.path()        // "/path"
uri.query()       // Some("query=value")
uri.fragment()    // Some("fragment")
uri.origin_form() // "/path?query=value"

#ヘッダーパース

#Host ヘッダー

let host = Host::parse("example.com:8080")
host.host() // "example.com"
host.port() // Some(8080)

#Content-Type ヘッダー

let ct = ContentType::parse("application/json; charset=utf-8")
ct.media_type()  // "application"
ct.subtype()      // "json"
ct.mime_type()   // "application/json"
ct.charset()      // Some("utf-8")
ct.is_json()     // true

#Cookie

// Cookie ヘッダー

///|
let cookies = Cookie::parse("name1=value1; name2=value2")

// Set-Cookie ヘッダー

///|
let set_cookie = SetCookie::new("session", "abc123")
  .with_domain("example.com")
  .with_path("/")
  .with_secure(true)
  .with_http_only(true)

#認証

// Basic 認証

///|
let auth = BasicAuth::new("username", "password")

///|
let header_value = auth.to_header_value() // "Basic base64(...)"

///|
let parsed = BasicAuth::parse(header_value)

// Bearer トークン

///|
let token = BearerToken::parse("Bearer abc123")

#ETag

// ETag パース
let etag = EntityTag::parse("W/\"abc123\"")
etag.is_weak()      // true
etag.tag()          // "abc123"

// ETag リスト
let etags = parse_etag_list("*") // Any
etags.is_any()     // true

#Range

// Range ヘッダー
let range = Range::parse("bytes=0-499")
range.unit()       // "bytes"
range.ranges()     // [Range(0UL, 499UL)]

// Content-Range ヘッダー
let cr = ContentRange::new_bytes(0UL, 499UL, Some(1000UL))
cr.to_string()    // "bytes 0-499/1000"

#Chunked 転送エンコーディング

// チャンクエンコード

///|
let chunk1 = "Hello, ".to_bytes()

///|
let chunk2 = "world!".to_bytes()

///|
let encoded = encode_chunks([chunk1, chunk2])
// 7\r\nHello, \r\n6\r\nworld!\r\n0\r\n\r\n

// 単一チャンク

///|
let encoded = encode_chunk("data".to_bytes())
// 4\r\ndata\r\n

#サンプル

#実行方法

# 基本例
moon run src/cmd/main

# HTTP クライアント
moon run src/cmd/client --target native

# HTTP サーバー
moon run src/cmd/server --target native

#出力例

========================================
http11.mbt Example Program
========================================

1. GET Request Example
---
Encoded GET request:
GET /api/users HTTP/1.1\r\n
Host: example.com\r\n
Connection: keep-alive\r\n
Accept: application/json\r\n
\r\n

2. POST Request with Body Example
---
Encoded POST request:
POST /api/users HTTP/1.1\r\n
Host: example.com\r\n
Content-Type: application/json\r\n
\r\n
{"name":"Alice","age":30}

3. Response Example
---
Encoded response:
HTTP/1.1 200 OK\r\n
Content-Type: text/plain\r\n
Content-Length: 13\r\n
\r\n
Hello, World!

4. Chunked Transfer Encoding Example
---
Encoded chunked data:
7\r\n
Hello, \r\n
6\r\n
world!\r\n
0\r\n
\r\n

5. Request Decoder Example
---
RequestDecoder API usage:
  let decoder = @lib.RequestDecoder::new()
  decoder.feed(data)  // Feed raw bytes
  decoder.decode()    // Try to decode a request
  Note: Decoder is intended for use with network I/O

6. Response Decoder Example
---
ResponseDecoder API usage:
  let decoder = @lib.ResponseDecoder::new()
  decoder.feed(data)  // Feed raw bytes
  decoder.decode()    // Try to decode a response
  Note: Decoder is intended for use with network I/O

========================================
All examples completed successfully!
========================================

#ライセンス

Portions derived from https://github.com/shiguredo/http11-rs
Copyright 2026 Shiguredo Inc.
Licensed under the Apache License, Version 2.0