Struct DefinitionStore 

pub struct DefinitionStore {
    root: PathBuf,
    write_lock: Mutex<()>,
}

Fields

root: PathBuf

write_lock: Mutex<()>

Implementations

impl DefinitionStore

pub fn open(root: PathBuf) -> Result<Self, DefStoreError>

Open or create the store rooted at root. Ensures the active dir and retired/ subdir both exist.

pub fn root(&self) -> &Path

fn active_path(&self, id: &str) -> PathBuf

fn retired_path(&self, id: &str) -> PathBuf

pub fn upsert(&self, rec: &DefinitionRecord) -> Result<(), DefStoreError>

Insert or update a definition. Preserves unknown top-level + data fields on an existing file (forward-compat); refuses to overwrite a corrupt or higher-schema file.

pub fn retire(&self, id: &str) -> Result<(), DefStoreError>

Soft-delete → move into retired/ (tombstone). Idempotent. The tombstone prevents another channel’s migration from resurrecting an agent the user deliberately deleted.

pub fn unretire(&self, id: &str) -> Result<(), DefStoreError>

Move a record back from retired/ to active. Idempotent.

pub fn hard_delete(&self, id: &str) -> Result<(), DefStoreError>

Hard-delete (drops both active and retired files). Mirrors SQLite agent_def_delete. Use Self::retire when a resurrection-proof tombstone is wanted instead.

pub fn exists(&self, id: &str) -> bool

pub fn exists_anywhere(&self, id: &str) -> bool

pub fn get(&self, id: &str) -> Result<Option<DefinitionRecord>, DefStoreError>

Read a single active definition record by id. None if absent; invalid/corrupt files surface as an error (caller logs + falls back).

pub fn list_active(&self) -> Result<Vec<DefinitionRecord>, DefStoreError>

Read every valid active definition. Invalid files are skipped + logged (left on disk for ops triage).