ja-furigana-cli 0.1.0

CLI and HTTP server for ja-furigana — Japanese ruby annotation. Installs the `furigana` binary.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

//! `serve` の HTTP 型 + AppState + エラーヘルパ

use crate::paths::Paths;
use axum::http::StatusCode;
use axum::Json;
use furigana::{AnalyzeResult, Furigana};
use serde::{Deserialize, Serialize};
use serde_json::{json, Value};
use std::sync::Arc;
use tokio::sync::RwLock;

/// 1 リクエストあたりの最大入力文字数 (公開 API 仕様)
pub(super) const MAX_TEXT_LEN: usize = 10_000;

/// HTTP サーバーの共有状態
///
/// `furigana` は `RwLock<Arc<...>>` でホットリロード対応:
/// - read 側 (lookup): `read().await.clone()` で `Arc` を即取り出して lock を即解放
/// - write 側 (reload): `write().await` で中の `Arc` を差し替え
///
/// `paths` は reload 時に `build_furigana` を再実行するため保持。
#[derive(Clone)]
pub(super) struct AppState {
    pub(super) furigana: Arc<RwLock<Arc<Furigana>>>,
    pub(super) tokens: Arc<Vec<String>>,
    pub(super) admin_tokens: Arc<Vec<String>>,
    pub(super) paths: Arc<Paths>,
}

/// `/furigana` のクエリ / body パラメータ
#[derive(Debug, Deserialize)]
pub(super) struct FuriganaParams {
    #[serde(default)]
    pub(super) text: Option<String>,
    #[serde(default)]
    pub(super) text_b64: Option<String>,
    #[serde(default = "default_mode")]
    pub(super) mode: String,
    #[serde(default = "default_short_pause")]
    pub(super) short_pause: String,
    #[serde(default = "default_long_pause")]
    pub(super) long_pause: String,
    #[serde(default = "default_true")]
    pub(super) keep_period: bool,
    #[serde(default)]
    pub(super) segmented: bool,
    #[serde(default = "default_max_seg")]
    pub(super) max_segment_len: usize,
    #[serde(default)]
    pub(super) debug: bool,
}

pub(super) fn default_mode() -> String {
    "tts".to_string()
}
pub(super) fn default_short_pause() -> String {
    " ".to_string()
}
pub(super) fn default_long_pause() -> String {
    "   ".to_string()
}
pub(super) fn default_true() -> bool {
    true
}
pub(super) fn default_max_seg() -> usize {
    60
}

/// `/furigana` の正常レスポンス
#[derive(Debug, Serialize)]
pub(super) struct FuriganaResponse {
    pub(super) result: String,
    pub(super) mode: String,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub(super) segments: Option<Vec<String>>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub(super) timings_ms: Option<Value>,
    /// `mode=analyze` の時のみ入る Smart engine debug 詳細 (★F1)。
    /// `result` には採択 path の reading 連結が入る。
    #[serde(skip_serializing_if = "Option::is_none")]
    pub(super) analyze: Option<AnalyzeResult>,
}

/// `/furigana` のエラーレスポンス (`{"error": "..."}` + HTTP ステータス)
pub(super) type ApiError = (StatusCode, Json<Value>);

/// エラーレスポンスを生成するショートカット
pub(super) fn error(code: StatusCode, msg: impl Into<String>) -> ApiError {
    (code, Json(json!({ "error": msg.into() })))
}