gobby-wiki 0.2.0

use std::path::Path;

use serde_json::json;

use crate::collect::{self as wiki_collect, CollectReport};
use crate::support::scope::{resolve_command_scope, resolved_scope_identity};
use crate::support::time::collect_timestamp;
use crate::{CommandOutcome, ScopeIdentity, ScopeSelection, WikiError, store, vault};

pub(crate) fn execute(selection: ScopeSelection) -> Result<CommandOutcome, WikiError> {
    let scope = resolve_command_scope(&selection)?;

    // Vault initialization is idempotent here; collect only needs the paths to exist.
    vault::initialize(&scope)?;
    let output_scope = resolved_scope_identity(&scope);
    let mut store = store::MemoryWikiStore::default();
    let timestamp = collect_timestamp().map_err(|error| WikiError::Config {
        detail: format!("failed to read system clock: {error}"),
    })?;
    let report = wiki_collect::collect_inbox_and_index(scope.root(), &mut store, &timestamp)?;
    Ok(render(output_scope, scope.root(), report))
}

fn render(scope: ScopeIdentity, root: &Path, report: CollectReport) -> CommandOutcome {
    let accepted = report.accepted.len();
    let skipped = report.skipped.len();
    let payload = json!({
        "command": "collect",
        "scope": scope,
        "status": "ready",
        "root": root.display().to_string(),
        "accepted": accepted,
        "skipped": skipped,
        "actions": report,
    });
    let text = format!(
        "Collect ready
Scope: {scope}
Root: {}
Accepted: {accepted}
Skipped: {skipped}",
        root.display()
    );
    super::scoped_outcome("collect", &scope, payload, text)
}