elph-agent 0.0.20

Agent runtime for Elph coding assistant
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

use std::sync::atomic::{AtomicBool, Ordering};

use anyhow::Result;
use tokio::sync::Mutex;

use super::{DatabaseSpec, ensure_databases};

static READY: AtomicBool = AtomicBool::new(false);
static LOCK: Mutex<()> = Mutex::const_new(());

/// Initialize databases once per process; subsequent calls are no-ops.
pub async fn ensure_databases_once(specs: &[DatabaseSpec<'_>]) -> Result<()> {
    if READY.load(Ordering::Acquire) {
        return Ok(());
    }

    let _guard = LOCK.lock().await;
    if READY.load(Ordering::Acquire) {
        return Ok(());
    }

    ensure_databases(specs).await?;
    READY.store(true, Ordering::Release);
    Ok(())
}