eure-cli 0.1.8

Command-line tool for Eure format conversion and validation
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

use eure::query::{
    DocumentToSchemaQuery, TextFile, TextFileContent, WithFormattedError, build_runtime,
};
use eure::query_flow::DurabilityLevel;
use eure_json::{Config as JsonConfig, JsonToEure};
use eure_document::document::EureDocument;
use eure_document::source::{EureSource, SourceDocument};
use eure_schema::interop::VariantRepr;

use crate::args::CacheArgs;
use crate::util::{
    VariantFormat, display_path, handle_formatted_error, handle_query_error, read_input,
    run_query_with_file_loading_cached,
};

#[derive(clap::Args)]
pub struct Args {
    /// Path to JSON file to convert (use - for stdin)
    pub file: String,
    /// Schema file for schema-aware JSON via serde-eure (union wire shape follows schema $interop)
    #[arg(short, long)]
    pub schema: Option<String>,
    /// Variant representation format (ignored when --schema is set)
    #[arg(short = 'v', long, value_enum, default_value = "external")]
    pub variant: VariantFormat,
    /// Tag field name for internal/adjacent representations
    #[arg(short = 't', long, default_value = "type")]
    pub tag: String,
    /// Content field name for adjacent representation
    #[arg(short = 'c', long, default_value = "content")]
    pub content: String,
    /// Cache options when the schema is loaded from a remote URL
    #[command(flatten)]
    pub cache: CacheArgs,
}

pub fn run(args: Args) {
    // 1. Read input from file or stdin
    let file_opt = if args.file == "-" {
        None
    } else {
        Some(args.file.as_str())
    };
    let contents = match read_input(file_opt) {
        Ok(c) => c,
        Err(e) => {
            eprintln!("{e}");
            std::process::exit(1);
        }
    };

    // 2. Create query runtime
    let runtime = build_runtime();

    let file = TextFile::from_path(display_path(file_opt).into());
    let cache_opts = args.cache.to_cache_options();

    // 3–5. Convert JSON to EureDocument
    let document = if let Some(schema_path) = args.schema.as_ref() {
        let schema_file = match TextFile::parse(schema_path) {
            Ok(f) => f,
            Err(e) => {
                eprintln!("Invalid schema path or URL: {e}");
                std::process::exit(1);
            }
        };

        let validated = handle_formatted_error(run_query_with_file_loading_cached(
            &runtime,
            WithFormattedError::new(DocumentToSchemaQuery::new(schema_file), false),
            Some(&cache_opts),
        ));

        let mut de = serde_json::Deserializer::from_str(&contents);
        match serde_eure::from_deserializer(&mut de, &validated.schema) {
            Ok(doc) => std::sync::Arc::new(doc),
            Err(e) => {
                eprintln!("Schema-aware JSON deserialization failed: {e}");
                std::process::exit(1);
            }
        }
    } else {
        runtime.resolve_asset(
            file.clone(),
            TextFileContent(contents),
            DurabilityLevel::Static,
        );

        let variant_repr = match args.variant {
            VariantFormat::External => VariantRepr::External,
            VariantFormat::Internal => VariantRepr::Internal { tag: args.tag },
            VariantFormat::Adjacent => VariantRepr::Adjacent {
                tag: args.tag,
                content: args.content,
            },
            VariantFormat::Untagged => VariantRepr::Untagged,
        };
        let config = JsonConfig { variant_repr };

        match runtime.query(JsonToEure::new(file.clone(), config)) {
            Ok(doc) => doc,
            Err(e) => handle_query_error(e),
        }
    };

    // 6. Build minimal SourceDocument for formatting
    let source_doc = build_minimal_source_document(document);

    // 7. Format and output
    let output = eure_fmt::format_source_document(&source_doc);
    println!("{output}");
}

fn build_minimal_source_document(document: std::sync::Arc<EureDocument>) -> SourceDocument {
    // Create a minimal SourceDocument with a single root source
    // that has the document's root as a value binding
    let doc = std::sync::Arc::unwrap_or_clone(document);
    let root_source = EureSource {
        value: Some(doc.get_root_id()),
        ..Default::default()
    };

    SourceDocument::new(doc, vec![root_source])
}