rust-web-server 17.44.0

An HTTP web framework, reverse proxy, and server for Rust supporting HTTP/1.1, HTTP/2, and HTTP/3. Config-driven proxy mode (rws.config.toml with [[route]] / [[upstream]]) or library crate. No third-party HTTP dependencies.
Documentation 
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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

use crate::sse::{Sse, SseEvent};

// ── SseEvent encoding ─────────────────────────────────────────────────────────

#[test]
fn data_only_event() {
    let encoded = SseEvent::data("hello").encode();
    assert_eq!(encoded, b"data: hello\n\n");
}

#[test]
fn empty_data_field_is_preserved() {
    let encoded = SseEvent::data("").encode();
    assert_eq!(encoded, b"data: \n\n");
}

#[test]
fn event_with_type() {
    let encoded = SseEvent::data("payload").event_type("update").encode();
    assert_eq!(encoded, b"event: update\ndata: payload\n\n");
}

#[test]
fn event_with_id() {
    let encoded = SseEvent::data("x").id("42").encode();
    assert_eq!(encoded, b"id: 42\ndata: x\n\n");
}

#[test]
fn event_with_all_fields() {
    let encoded = SseEvent::data("msg")
        .id("7")
        .event_type("ping")
        .retry(3000)
        .encode();
    assert_eq!(encoded, b"id: 7\nevent: ping\ndata: msg\nretry: 3000\n\n");
}

#[test]
fn multi_line_data_produces_multiple_data_lines() {
    let encoded = SseEvent::data("line1\nline2\nline3").encode();
    assert_eq!(encoded, b"data: line1\ndata: line2\ndata: line3\n\n");
}

// ── Sse builder ───────────────────────────────────────────────────────────────

#[test]
fn sse_event_convenience() {
    let response = Sse::new().event("update", "hello").into_response();
    let body = response.content_range_list[0].body.clone();
    assert_eq!(body, b"event: update\ndata: hello\n\n");
}

#[test]
fn sse_data_convenience() {
    let response = Sse::new().data("raw").into_response();
    let body = response.content_range_list[0].body.clone();
    assert_eq!(body, b"data: raw\n\n");
}

#[test]
fn sse_push_raw_event() {
    let response = Sse::new()
        .push(SseEvent::data("v").id("1").event_type("tick"))
        .into_response();
    let body = response.content_range_list[0].body.clone();
    assert_eq!(body, b"id: 1\nevent: tick\ndata: v\n\n");
}

#[test]
fn sse_retry_directive() {
    let response = Sse::new().retry(5000).into_response();
    let body = response.content_range_list[0].body.clone();
    assert_eq!(body, b"retry: 5000\n\n");
}

#[test]
fn sse_comment() {
    let response = Sse::new().comment("keep-alive").into_response();
    let body = response.content_range_list[0].body.clone();
    assert_eq!(body, b": keep-alive\n\n");
}

#[test]
fn sse_multiple_events_concatenated() {
    let response = Sse::new()
        .event("open", "")
        .data("first")
        .data("second")
        .into_response();
    let body = String::from_utf8(response.content_range_list[0].body.clone()).unwrap();
    assert_eq!(
        body,
        "event: open\ndata: \n\ndata: first\n\ndata: second\n\n"
    );
}

// ── Response headers ──────────────────────────────────────────────────────────

#[test]
fn into_response_status_200() {
    let response = Sse::new().into_response();
    assert_eq!(200, response.status_code);
}

#[test]
fn into_response_cache_control_no_cache() {
    let response = Sse::new().into_response();
    let cc = response.headers.iter().find(|h| h.name == "Cache-Control");
    assert!(cc.is_some());
    assert_eq!("no-cache", cc.unwrap().value);
}

#[test]
fn into_response_x_accel_buffering_no() {
    let response = Sse::new().into_response();
    let xab = response.headers.iter().find(|h| h.name == "X-Accel-Buffering");
    assert!(xab.is_some());
    assert_eq!("no", xab.unwrap().value);
}

#[test]
fn into_response_content_type_is_event_stream() {
    let response = Sse::new().data("x").into_response();
    let ct = response.content_range_list[0].content_type.clone();
    assert_eq!("text/event-stream", ct);
}