acton-htmx 1.0.0-beta.7

Opinionated Rust web framework for HTMX applications
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

//! Simple HTMX example demonstrating corrected API usage for axum-htmx 0.8.1
//!
//! This example shows the correct usage of axum-htmx 0.8.1 API:
//! - HxRedirect::from() instead of ::to()
//! - HxResponseTrigger instead of HxTrigger
//! - HxRefresh::from(true) instead of bare HxRefresh
//! - HxEvent for event data
//!
//! Run with:
//! ```bash
//! cargo run --example simple_htmx
//! ```

use acton_htmx::{observability, state::ActonHtmxState};
use acton_reactive::prelude::ActonApp;
use axum::{
    response::Html,
    routing::{get, post},
    Router,
};
use axum_htmx::{HxEvent, HxRedirect, HxRefresh, HxRequest, HxResponseTrigger};
use serde_json::json;
use tracing::info;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // Initialize observability
    observability::init()?;

    // Launch the Acton runtime
    let mut runtime = ActonApp::launch();

    // Create application state
    let state = ActonHtmxState::new(&mut runtime).await?;

    // Build router
    let app = Router::new()
        .route("/", get(index))
        .route("/partial", get(partial))
        .route("/redirect", post(redirect))
        .route("/trigger", post(trigger))
        .route("/refresh", post(refresh))
        .with_state(state);

    // Start server
    info!("Starting simple HTMX server on http://127.0.0.1:3000");

    let listener = tokio::net::TcpListener::bind("127.0.0.1:3000").await?;
    axum::serve(listener, app).await?;

    // Shutdown the agent runtime
    runtime.shutdown_all().await?;

    Ok(())
}

async fn index() -> Html<&'static str> {
    Html(include_str!("simple_htmx.html"))
}

async fn partial(HxRequest(is_htmx): HxRequest) -> Html<String> {
    if is_htmx {
        Html("<p>This is a partial response (HTMX detected)</p>".to_string())
    } else {
        Html("<html><body><h1>Full Page</h1></body></html>".to_string())
    }
}

async fn redirect() -> (HxRedirect, Html<&'static str>) {
    info!("Redirecting...");
    (HxRedirect::from("/"), Html("<p>Redirecting...</p>"))
}

async fn trigger() -> (HxResponseTrigger, Html<&'static str>) {
    info!("Triggering event");
    let event =
        HxEvent::new_with_data("myEvent", json!({"message": "Hello!"})).expect("valid JSON");
    (
        HxResponseTrigger::normal([event]),
        Html("<p>Event triggered!</p>"),
    )
}

async fn refresh() -> (HxRefresh, Html<&'static str>) {
    info!("Triggering refresh");
    (HxRefresh::from(true), Html("<p>Refreshing...</p>"))
}