resuma 0.4.2

Resuma - SSR + Resumability + Islands + Server Actions + JS Bridge for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! SQLite pool — init before `FlowApp::serve()`.

use sqlx::sqlite::SqlitePoolOptions;
use std::sync::OnceLock;

static POOL: OnceLock<sqlx::SqlitePool> = OnceLock::new();

pub async fn init_db() -> anyhow::Result<()> {
    let url = std::env::var("DATABASE_URL").unwrap_or_else(|_| "sqlite:local.db".into());
    let pool = SqlitePoolOptions::new()
        .max_connections(5)
        .connect(&url)
        .await?;
    sqlx::migrate!("./migrations").run(&pool).await?;
    POOL.set(pool)
        .map_err(|_| anyhow::anyhow!("database pool already initialized"))?;
    Ok(())
}

pub fn pool() -> &'static sqlx::SqlitePool {
    POOL.get().expect("call db::init_db() before FlowApp::serve()")
}