opys-engine 0.12.0

Core library for opys — a file-based inventory of typed markdown documents with a verify gate and SQL query layer
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

//! `opys tag` — add/remove tags on documents through the corpus store.

use crate::commands::{expand_ids, for_each_id, maybe_sync, split_csv, touch};
use crate::error::{usage, Result};
use crate::project::Project;
use crate::store::Store;
use crate::Ctx;

/// Add and/or remove tags on a document; returns the doc's resulting tag list.
/// Does not flush/print/sync.
pub fn core(
    prj: &Project,
    store: &mut Store,
    id: &str,
    add: Option<&str>,
    remove: Option<&str>,
) -> Result<Vec<String>> {
    let tags_required = prj
        .pcfg
        .type_name_for_id(id)
        .map(|n| prj.pcfg.types[n].tags_required)
        .unwrap_or(false);

    let dkey = store.dkey_of(id)?;
    let mut doc = store.doc(dkey)?;

    let mut tags = doc.frontmatter.tags().unwrap_or_default();
    for t in split_csv(add.unwrap_or("")) {
        if !tags.contains(&t) {
            tags.push(t);
        }
    }
    for t in split_csv(remove.unwrap_or("")) {
        tags.retain(|x| x != &t);
    }
    if tags.is_empty() {
        if tags_required {
            return Err(usage("this type requires at least one tag"));
        }
        doc.frontmatter.remove("tags");
    } else {
        doc.frontmatter.set_tags(&tags);
    }
    touch(&mut doc.frontmatter);

    store.put_doc(&prj.pcfg, Some(dkey), &doc)?;
    Ok(tags)
}

pub fn run(ctx: &Ctx, ids: &str, add: Option<&str>, remove: Option<&str>) -> Result<()> {
    let prj = ctx.open()?;
    let ids = expand_ids(ids)?;
    let (mut store, _) = ctx.load(&prj)?;
    let res = for_each_id(&ids, |id| {
        let tags = core(&prj, &mut store, id, add, remove)?;
        println!("{id} tags: {}", tags.join(", "));
        Ok(())
    });
    ctx.flush(&prj, store)?;
    maybe_sync(ctx, &prj);
    res
}