elph-agent 0.0.18

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::Mutex;
use std::sync::atomic::{AtomicBool, Ordering};

use anyhow::Result;

use super::{DatabaseSpec, ensure_databases};

static READY: AtomicBool = AtomicBool::new(false);
static LOCK: Mutex<()> = Mutex::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().unwrap_or_else(|poisoned| poisoned.into_inner());
    if READY.load(Ordering::Acquire) {
        return Ok(());
    }

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