systemprompt-api 0.2.0

HTTP API server and gateway for systemprompt.io OS
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

pub mod blog;
pub mod links;
pub mod query;

use std::sync::Arc;

use axum::Router;
use axum::routing::{get, post};
use systemprompt_database::DbPool;
use systemprompt_runtime::AppContext;

pub use blog::{get_content_handler, get_content_markdown_handler, list_content_by_source_handler};
pub use links::{
    generate_link_handler, get_campaign_performance_handler, get_content_journey_handler,
    get_link_clicks_handler, get_link_performance_handler, list_links_handler, redirect_handler,
};
pub use query::query_handler;

pub fn router(ctx: &AppContext) -> Router {
    let suffix = ctx
        .config()
        .content_negotiation
        .markdown_suffix
        .trim_start_matches('.');

    let mut router = Router::new()
        .route("/query", post(query_handler))
        .route("/{source_id}", get(list_content_by_source_handler))
        .route("/{source_id}/{slug}", get(get_content_handler))
        .route("/links/generate", post(generate_link_handler))
        .route("/links", get(list_links_handler))
        .route(
            "/links/{link_id}/performance",
            get(get_link_performance_handler),
        )
        .route("/links/{link_id}/clicks", get(get_link_clicks_handler))
        .route(
            "/links/campaigns/{campaign_id}/performance",
            get(get_campaign_performance_handler),
        )
        .route("/links/journey", get(get_content_journey_handler));

    if ctx.config().content_negotiation.enabled {
        router = router.route(
            &format!("/{{source_id}}/{{slug}}/{}", suffix),
            get(get_content_markdown_handler),
        );
    }

    router.with_state(ctx.clone())
}

pub fn redirect_router(db_pool: &DbPool) -> Router {
    Router::new()
        .route("/r/{short_code}", get(redirect_handler))
        .with_state(Arc::clone(db_pool))
}