duc 3.3.0

The duc 2D CAD file format Rust implementation.
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

//! WASM (`wasm32-unknown-unknown`) storage backend.
//!
//! Two connection modes:
//!
//! * **OPFS SAH-pool** (`open_file_opfs`) — persistent, browser-only.
//!   Requires a Dedicated Worker context; uses `FileSystemSyncAccessHandle`.
//! * **In-memory** (`open_memory`) — synchronous, no persistence.

use rusqlite::Connection;
#[cfg(feature = "opfs")]
use sqlite_wasm_vfs::sahpool::{install as install_opfs_sahpool, OpfsSAHPoolCfg};

use crate::db::{bootstrap, DbResult, DucConnection};

/// Open (or reopen) a persistent OPFS-backed database.
///
/// # Worker requirement
/// `SyncAccessHandle` is not available on the main browser thread.
/// Spawn a `Worker` and call this from there, then communicate via
/// `postMessage` / `SharedArrayBuffer` or a `BroadcastChannel`.
#[cfg(feature = "opfs")]
pub(crate) async fn open_file_opfs(name: &str) -> DbResult<DucConnection> {
    // Install the OPFS SAH-pool VFS and make it the default for this Worker.
    install_opfs_sahpool::<rusqlite::ffi::WasmOsCallback>(&OpfsSAHPoolCfg::default(), true)
        .await
        .map_err(|e| DbError::Opfs(format!("{e:?}")))?;

    // `Connection::open` will use the default VFS (opfs-sahpool) set above.
    let conn = Connection::open(name)?;
    bootstrap::bootstrap(&conn)?;
    Ok(DucConnection(conn))
}

/// Open an ephemeral in-memory database (synchronous, works on any thread).
pub(crate) fn open_memory() -> DbResult<DucConnection> {
    let conn = Connection::open_in_memory()?;
    bootstrap::bootstrap(&conn)?;
    Ok(DucConnection(conn))
}