rssume 0.3.5

RSS middleware with AI-powered translation and summarization
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
128
129
130
131
132

use super::api::AppState;
use axum::{Extension, Router, routing::get};
use std::sync::Arc;

const RSS_STYLE_XSL: &str = include_str!("../../templates/rss_style.xsl");
const HIGHLIGHT_JS: &[u8] = include_bytes!("../../static/assets/highlight.min.js");
const HIGHLIGHT_CSS: &[u8] = include_bytes!("../../static/assets/highlight-github.min.css");
const JETBRAINS_MONO_REGULAR: &[u8] =
    include_bytes!("../../static/assets/JetBrainsMono-Regular.woff2");
const JETBRAINS_MONO_BOLD: &[u8] = include_bytes!("../../static/assets/JetBrainsMono-Bold.woff2");

pub fn router(state: Arc<AppState>) -> Router {
    Router::new()
        .route("/feeds/{name}", get(serve_feed))
        .route("/feeds/style.xsl", get(serve_style))
        .route("/feeds/assets/highlight.min.js", get(serve_highlight_js))
        .route("/feeds/assets/highlight.min.css", get(serve_highlight_css))
        .route(
            "/feeds/assets/jetbrains-mono-regular.woff2",
            get(serve_jetbrains_mono_regular),
        )
        .route(
            "/feeds/assets/jetbrains-mono-bold.woff2",
            get(serve_jetbrains_mono_bold),
        )
        .layer(Extension(state))
}

async fn serve_style() -> (axum::http::StatusCode, [(String, String); 1], String) {
    (
        axum::http::StatusCode::OK,
        [(
            "Content-Type".to_string(),
            "application/xslt+xml; charset=utf-8".to_string(),
        )],
        RSS_STYLE_XSL.to_string(),
    )
}

async fn serve_highlight_js() -> (axum::http::StatusCode, [(String, String); 2], Vec<u8>) {
    (
        axum::http::StatusCode::OK,
        [
            (
                "Content-Type".to_string(),
                "application/javascript; charset=utf-8".to_string(),
            ),
            (
                "Cache-Control".to_string(),
                "public, max-age=31536000".to_string(),
            ),
        ],
        HIGHLIGHT_JS.to_vec(),
    )
}

async fn serve_highlight_css() -> (axum::http::StatusCode, [(String, String); 2], Vec<u8>) {
    (
        axum::http::StatusCode::OK,
        [
            (
                "Content-Type".to_string(),
                "text/css; charset=utf-8".to_string(),
            ),
            (
                "Cache-Control".to_string(),
                "public, max-age=31536000".to_string(),
            ),
        ],
        HIGHLIGHT_CSS.to_vec(),
    )
}

async fn serve_jetbrains_mono_regular() -> (axum::http::StatusCode, [(String, String); 2], Vec<u8>)
{
    (
        axum::http::StatusCode::OK,
        [
            ("Content-Type".to_string(), "font/woff2".to_string()),
            (
                "Cache-Control".to_string(),
                "public, max-age=31536000".to_string(),
            ),
        ],
        JETBRAINS_MONO_REGULAR.to_vec(),
    )
}

async fn serve_jetbrains_mono_bold() -> (axum::http::StatusCode, [(String, String); 2], Vec<u8>) {
    (
        axum::http::StatusCode::OK,
        [
            ("Content-Type".to_string(), "font/woff2".to_string()),
            (
                "Cache-Control".to_string(),
                "public, max-age=31536000".to_string(),
            ),
        ],
        JETBRAINS_MONO_BOLD.to_vec(),
    )
}

async fn serve_feed(
    axum::extract::Path(name): axum::extract::Path<String>,
    Extension(state): Extension<Arc<AppState>>,
) -> Result<(axum::http::StatusCode, [(String, String); 1], String), crate::error::AppError> {
    let config = state.config.read().await;
    let feed_cfg = config
        .feeds
        .iter()
        .find(|f| f.name == name)
        .ok_or_else(|| crate::error::AppError::NotFound(format!("Feed '{}' not found", name)))?;

    if !feed_cfg.enabled {
        return Err(crate::error::AppError::NotFound(format!(
            "Feed '{}' is disabled",
            name
        )));
    }

    let feed_data = crate::storage::FeedData::load(&name)?;
    let rss_xml = crate::rss::generate::generate_rss(&name, &feed_data.articles);

    Ok((
        axum::http::StatusCode::OK,
        [(
            "Content-Type".to_string(),
            "text/xml; charset=utf-8".to_string(),
        )],
        rss_xml,
    ))
}