pipey 0.2.1

A lightweight HTTP-to-WebSocket event delivery service.
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

use crate::models::AppState;
use crate::utils::format_count;
use actix_web::{HttpResponse, Responder, get, web};
use askama::Template;

#[derive(Template)]
#[template(path = "./files/index.html")]
struct IndexTemplate {
    online_users: String,
}

#[derive(Template)]
#[template(path = "./files/docs.html")]
struct DocumentationTemplate;

#[derive(Template)]
#[template(path = "./files/sdk.html")]
struct SdksTemplate;

#[derive(Template)]
#[template(path = "./files/client.html")]
struct ClientTemplate;

#[get("/")]
pub async fn pipey(state: web::Data<AppState>) -> impl Responder {
    let metrics = state.arifa.metrics.snapshot();
    let template = IndexTemplate {
        online_users: format_count(metrics.sessions_active),
    };

    match template.render() {
        Ok(html) => HttpResponse::Ok()
            .content_type("text/html; charset=utf-8")
            .body(html),
        Err(err) => HttpResponse::InternalServerError().body(format!("Template error: {err}")),
    }
}

#[get("/docs")]
pub async fn pipey_docs() -> impl Responder {
    let template = DocumentationTemplate;

    match template.render() {
        Ok(html) => HttpResponse::Ok()
            .content_type("text/html; charset=utf-8")
            .body(html),
        Err(err) => HttpResponse::InternalServerError().body(format!("Template error: {err}")),
    }
}

#[get("/sdks")]
pub async fn pipey_sdks() -> impl Responder {
    let template = SdksTemplate;

    match template.render() {
        Ok(html) => HttpResponse::Ok()
            .content_type("text/html; charset=utf-8")
            .body(html),
        Err(err) => HttpResponse::InternalServerError().body(format!("Template error: {err}")),
    }
}

#[get("/client")]
pub async fn pipey_client() -> impl Responder {
    let template = ClientTemplate;

    match template.render() {
        Ok(html) => HttpResponse::Ok()
            .content_type("text/html; charset=utf-8")
            .body(html),
        Err(err) => HttpResponse::InternalServerError().body(format!("Template error: {err}")),
    }
}