axiomsync 0.1.8

Core data-processing engine for AxiomSync local retrieval runtime.
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

use std::path::Path;

use chrono::Utc;
use uuid::Uuid;

use crate::error::Result;
use crate::fs::LocalContextFs;
use crate::index::InMemoryIndex;
use crate::tier_documents::{
    abstract_path, overview_path, read_abstract, read_overview, write_tiers,
};
use crate::uri::{AxiomUri, Scope};

pub(super) fn ensure_directory_record(
    fs: &LocalContextFs,
    index: &mut InMemoryIndex,
    uri: &AxiomUri,
) -> Result<()> {
    if index.get(&uri.to_string()).is_some() {
        return Ok(());
    }

    let path = fs.resolve_uri(uri);
    if !Path::new(&path).exists() {
        fs.create_dir_all(uri, true)?;
    }

    if !abstract_path(fs, uri).exists() || !overview_path(fs, uri).exists() {
        write_tiers(
            fs,
            uri,
            &format!(
                "Directory {}",
                uri.last_segment().unwrap_or_else(|| uri.scope().as_str())
            ),
            &format!("# Overview\n\nURI: {uri}"),
            true,
        )?;
    }

    let abstract_text = read_abstract(fs, uri)?;
    let overview_text = read_overview(fs, uri)?;

    index.upsert(crate::models::IndexRecord {
        id: Uuid::new_v4().to_string(),
        uri: uri.to_string(),
        parent_uri: uri.parent().map(|p| p.to_string()),
        is_leaf: false,
        context_type: if matches!(uri.scope(), Scope::User | Scope::Agent) {
            "memory".to_string()
        } else {
            "resource".to_string()
        },
        name: uri
            .last_segment()
            .unwrap_or_else(|| uri.scope().as_str())
            .to_string(),
        abstract_text,
        content: overview_text,
        tags: vec![],
        updated_at: Utc::now(),
        depth: uri.segments().len(),
    });

    Ok(())
}