rustchain 0.1.0

Workflow transpilation and execution framework - import LangChain, Airflow, GitHub Actions, and more
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

pub mod commands;
pub mod commands_pretty;
pub mod handlers;
pub mod handlers_pretty;
pub mod help_examples;
pub mod interactive;
pub mod pretty;

use clap::Parser;
use commands::Cli;
use handlers::handle_command;

/// Main CLI entry point
pub async fn run() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let args = Cli::parse();

    // Initialize logging
    init_logging()?;

    // Handle the command with enhanced error formatting
    handle_command(args.command).await
}

/// Initialize logging system
fn init_logging() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

    // Only initialize if not already initialized
    if std::env::var("RUST_LOG").is_err() {
        std::env::set_var("RUST_LOG", "info");
    }

    // Initialize logging - surface any errors
    tracing_subscriber::registry()
        .with(tracing_subscriber::EnvFilter::from_default_env())
        .with(tracing_subscriber::fmt::layer())
        .try_init()
        .map_err(|e| format!("Failed to initialize logging: {}", e))?;

    Ok(())
}

/// Graceful error handling
pub fn handle_error(error: &dyn std::error::Error) {
    eprintln!("Fatal error: {}", error);
    tracing::error!("Application error: {}", error);
}