absurder-sql 0.1.23

AbsurderSQL - SQLite + IndexedDB that's absurdly better than absurd-sql
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

//! Export/Import Operation Locking
//!
//! Uses weblocks crate to serialize export/import operations.

use wasm_bindgen::prelude::*;

/// Request a Web Lock and execute work
pub async fn with_lock<F, Fut>(lock_name: &str, f: F) -> Result<(), JsValue>
where
    F: FnOnce() -> Fut + 'static,
    Fut: std::future::Future<Output = Result<(), JsValue>> + 'static,
{
    log::info!("[LOCK] ===== STARTING LOCK REQUEST =====");
    log::info!("[LOCK] Lock name: {}", lock_name);
    log::info!("[LOCK] Creating AcquireOptions...");

    let opts = weblocks::AcquireOptions::exclusive();
    log::info!("[LOCK] AcquireOptions created, calling acquire()...");

    // Try to acquire the lock
    let acquire_future = weblocks::acquire(lock_name, opts);
    log::info!("[LOCK] acquire() called, awaiting future...");

    let guard_result = acquire_future.await;
    log::info!(
        "[LOCK] acquire() future resolved: {:?}",
        guard_result.is_ok()
    );

    let _guard = guard_result.map_err(|e| {
        log::error!("[LOCK] Failed to acquire lock: {:?}", e);
        e
    })?;

    log::info!("[LOCK] ===== LOCK ACQUIRED, EXECUTING WORK =====");

    // Execute the work while holding the lock
    let result = f().await;

    log::info!("[LOCK] ===== WORK COMPLETED: {:?} =====", result.is_ok());

    // Lock is released when _guard is dropped
    result
}