Skip to content

f4ah6o/http11.mbt

BranchesTags

Repository files navigation

f4ah6o/http11

MoonBit で実装された Sans I/O な HTTP/1.1 パーサー・エンコーダーライブラリ。

概要

本ライブラリは shiguredo/http11-rs を MoonBit に移植したものです。Sans I/O 設計により、I/O 処理を完全に分離しているため、任意のトランスポート（TCP、TLS、WebSocket 等）で使用できます。

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

モジュール構成

コアモジュール

ファイル 説明
error.mbt HttpError enum - パースエラーの種類
limits.mbt DecoderLimits struct - デコーダー制限値
request.mbt Request struct - HTTP リクエスト表現
response.mbt Response struct - HTTP レスポンス表現
encoder.mbt リクエスト/レスポンスのエンコード関数
decoder.mbt RequestDecoder, ResponseDecoder - Sans I/O デコーダー

URI / URL

ファイル 説明
uri.mbt Uri struct - URI パース（RFC 3986）、パーセントエンコード/デコード

HTTP ヘッダー

ファイル 説明
host.mbt Host struct - Host ヘッダー（RFC 9110）
expect.mbt Expect struct - Expect ヘッダー（RFC 9110）
trailer.mbt Trailer struct - Trailer ヘッダー（RFC 9112）
upgrade.mbt Upgrade struct - Upgrade ヘッダー（RFC 9110）
vary.mbt Vary struct - Vary ヘッダー（RFC 9110）
range.mbt Range, ContentRange, AcceptRanges - Range 関連ヘッダー（RFC 9110）

コンテント関連ヘッダー

ファイル 説明
content_type.mbt ContentType struct - Content-Type ヘッダー（RFC 9110）
content_encoding.mbt ContentEncoding struct - Content-Encoding ヘッダー（RFC 9110）
content_disposition.mbt ContentDisposition struct - Content-Disposition ヘッダー（RFC 6266）
content_language.mbt ContentLanguage struct - Content-Language ヘッダー（RFC 9110）
content_location.mbt ContentLocation struct - Content-Location ヘッダー（RFC 9110）

キャッシュ / 認証

ファイル 説明
etag.mbt EntityTag, ETagList - ETag 関連（RFC 9110）
cache.mbt CacheControl, Age, Expires - キャッシュ制御（RFC 9111）
conditional.mbt IfMatch, IfNoneMatch, IfModifiedSince など - 条件付きリクエスト（RFC 9110）
digest_fields.mbt ContentDigest, ReprDigest, WantContentDigest など - ダイジェストフィールド（RFC 9530）

認証 / クッキー / 受入

ファイル 説明
auth.mbt BasicAuth, DigestAuth, BearerToken - HTTP 認証（RFC 7617, 7616, 6750）
cookie.mbt Cookie, SetCookie - Cookie / Set-Cookie ヘッダー（RFC 6265）
accept.mbt Accept, AcceptCharset, AcceptEncoding, AcceptLanguage - コンテントネゴシエーション（RFC 9110）

日付

ファイル 説明
date.mbt HttpDate struct - HTTP-date パース（IMF-fixdate, RFC 850, ANSI C asctime）

エラー型

///|
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

サンプル

本ライブラリには3つの実行可能なサンプルプログラムが含まれています。

実行方法

# 基本例
moon run cmd/main

# HTTP クライアント
moon run cmd/client

# HTTP サーバー
moon run cmd/server

出力例

========================================
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

本ライブラリ全体も Apache License 2.0 でライセンスされています。

About

port from shiguredo/http11-rs

Resources

Readme

License

Apache-2.0 license
Activity

Stars

0 stars

Watchers

0 watching

Forks

0 forks
Report repository

Releases

No releases published

Packages

No packages published

Contributors 3

  •  
  •  
  •  

Languages