resuma 1.1.0

Resuma — resumable SSR Rust web framework: zero hydration, islands, server actions, Flow (Axum).
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

//! Resuma OS bootstrap — configure durable storage, queues, node pool from env.

use super::durable;
use super::node::{self, NodePool};
use super::queue;
use super::scheduler;
use super::webhooks;

/// Initialize the execution layer (call once before serving).
pub async fn init() {
    init_storage();
    init_queue();
    init_scheduler();
    init_webhooks();
    init_node_pool();
    init_security();
    super::actions::register_builtin_actions();
    queue::start_consumers().await;
    scheduler::start().await;
    super::tools::init_http_client();
}

fn init_security() {
    super::security::configure(super::security::ExecSecurityConfig::from_env());
    let root = data_root();
    crate::server::rate_limit_disk::configure(format!("{root}/rate-limit"));
}

fn data_root() -> String {
    std::env::var("RESUMA_DATA_DIR").unwrap_or_else(|_| ".resuma".into())
}

fn init_storage() {
    durable::configure(format!("{}/durable", data_root()));
}

fn init_queue() {
    queue::configure_disk(format!("{}/queue", data_root()));
}

fn init_scheduler() {
    scheduler::configure(format!("{}/scheduler", data_root()));
}

fn init_webhooks() {
    webhooks::configure(format!("{}/webhooks", data_root()));
    webhooks::init_from_env();
}

fn init_node_pool() {
    let parallel = std::env::var("RESUMA_NODE_PARALLEL")
        .ok()
        .and_then(|s| s.parse().ok())
        .unwrap_or(4);
    node::configure_pool(NodePool {
        parallel_limit: parallel,
    });
}