pipi-rs 0.1.1

Pipi web framework for 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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

use axum::extract::FromRef;
use pipi::{
    app::{AppContext, SharedStore},
    cache,
    prelude::*,
    tests_cfg,
};
use std::sync::Arc;

use crate::infra_cfg;

#[cfg(feature = "with-db")]
use sea_orm::DatabaseConnection;

/// Tests that DatabaseConnection can be extracted from AppContext via FromRef
#[cfg(feature = "with-db")]
#[tokio::test]
async fn can_extract_db_connection_from_app_context() {
    let ctx = tests_cfg::app::get_app_context().await;

    #[allow(clippy::items_after_statements)]
    async fn action(State(ctx): State<AppContext>) -> Result<Response> {
        // Use FromRef to extract DatabaseConnection from AppContext
        let _db: DatabaseConnection = DatabaseConnection::from_ref(&ctx);
        format::json(serde_json::json!({"extracted": "db"}))
    }

    let port = get_available_port().await;
    let handle = infra_cfg::server::start_with_route(ctx, "/", get(action), Some(port)).await;

    let res = reqwest::get(get_base_url_port(port))
        .await
        .expect("Valid response");

    assert_eq!(res.status(), 200);

    let body: serde_json::Value = res.json().await.expect("JSON response");
    assert_eq!(body["extracted"], "db");

    handle.abort();
}

/// Tests that Arc<Cache> can be extracted from AppContext via FromRef
#[tokio::test]
async fn can_extract_cache_from_app_context() {
    let ctx = tests_cfg::app::get_app_context().await;

    #[allow(clippy::items_after_statements)]
    async fn action(State(ctx): State<AppContext>) -> Result<Response> {
        // Use FromRef to extract Arc<Cache> from AppContext
        let _cache: Arc<cache::Cache> = Arc::from_ref(&ctx);
        format::json(serde_json::json!({"extracted": "cache"}))
    }

    let port = get_available_port().await;
    let handle = infra_cfg::server::start_with_route(ctx, "/", get(action), Some(port)).await;

    let res = reqwest::get(get_base_url_port(port))
        .await
        .expect("Valid response");

    assert_eq!(res.status(), 200);

    let body: serde_json::Value = res.json().await.expect("JSON response");
    assert_eq!(body["extracted"], "cache");

    handle.abort();
}

/// Tests that Arc<SharedStore> can be extracted from AppContext via FromRef
#[tokio::test]
async fn can_extract_shared_store_from_app_context() {
    let ctx = tests_cfg::app::get_app_context().await;

    #[allow(clippy::items_after_statements)]
    async fn action(State(ctx): State<AppContext>) -> Result<Response> {
        // Use FromRef to extract Arc<SharedStore> from AppContext
        let _store: Arc<SharedStore> = Arc::from_ref(&ctx);
        format::json(serde_json::json!({"extracted": "shared_store"}))
    }

    let port = get_available_port().await;
    let handle = infra_cfg::server::start_with_route(ctx, "/", get(action), Some(port)).await;

    let res = reqwest::get(get_base_url_port(port))
        .await
        .expect("Valid response");

    assert_eq!(res.status(), 200);

    let body: serde_json::Value = res.json().await.expect("JSON response");
    assert_eq!(body["extracted"], "shared_store");

    handle.abort();
}