embystream 0.0.25

Another Emby streaming application (frontend/backend separation) written in Rust.
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

use std::time::Instant;

use hyper::{Method, Uri};

use super::context::Context;

#[test]
fn context_stores_request_id() {
    let uri: Uri = "http://localhost/test".parse().expect("valid uri");
    let ctx = Context::new(
        uri,
        Method::GET,
        hyper::HeaderMap::new(),
        Instant::now(),
        "test-req-123".to_string(),
    );

    assert_eq!(ctx.request_id, "test-req-123");
}

#[test]
fn context_request_id_is_unique() {
    let uri1: Uri = "http://localhost/test1".parse().expect("valid uri");
    let uri2: Uri = "http://localhost/test2".parse().expect("valid uri");

    let ctx1 = Context::new(
        uri1,
        Method::GET,
        hyper::HeaderMap::new(),
        Instant::now(),
        "req-1".to_string(),
    );

    let ctx2 = Context::new(
        uri2,
        Method::GET,
        hyper::HeaderMap::new(),
        Instant::now(),
        "req-2".to_string(),
    );

    assert_ne!(ctx1.request_id, ctx2.request_id);
}

#[test]
fn context_tracks_start_time() {
    let uri: Uri = "http://localhost/test".parse().expect("valid uri");
    let start = Instant::now();
    let ctx = Context::new(
        uri,
        Method::GET,
        hyper::HeaderMap::new(),
        start,
        "test-req".to_string(),
    );

    let elapsed = ctx.start_time.elapsed();
    assert!(elapsed.as_millis() < 100);
}

#[test]
fn context_clones_request_id() {
    let uri: Uri = "http://localhost/test".parse().expect("valid uri");
    let request_id = "test-req-456".to_string();
    let ctx = Context::new(
        uri,
        Method::GET,
        hyper::HeaderMap::new(),
        Instant::now(),
        request_id.clone(),
    );

    assert_eq!(ctx.request_id, request_id);
    assert_eq!(ctx.request_id.len(), request_id.len());
}