Function main

src/main.rs:29–232

()

#[tokio::main]
async fn main() -> Result<()> {
    let config = Config::load();

    // Initialize logging
    tracing_subscriber::fmt()
        .with_env_filter(config.log_level.clone())
        .init();

    // Display version
    info!("pgsqlite v{}", env!("CARGO_PKG_VERSION"));

    // Determine database path based on --in-memory flag
    let db_path = if config.in_memory {
        info!("Using in-memory SQLite database (testing mode)");
        ":memory:".to_string()
    } else {
        config.database.clone()
    };

    // Handle migration command
    if config.migrate {
        info!("Running database migrations...");
        
        // Open connection directly for migration
        let conn = rusqlite::Connection::open(&db_path)
            .map_err(|e| anyhow::anyhow!("Failed to open database: {}", e))?;
        
        // Register functions needed for migrations
        pgsqlite::functions::register_all_functions(&conn)
            .map_err(|e| anyhow::anyhow!("Failed to register functions: {}", e))?;
        
        let mut runner = MigrationRunner::new(conn);
        match runner.run_pending_migrations() {
            Ok(applied) => {
                if applied.is_empty() {
                    info!("No pending migrations. Database is up to date.");
                } else {
                    info!("Successfully applied {} migrations: {:?}", applied.len(), applied);
                }
                std::process::exit(0);
            }
            Err(e) => {
                error!("Migration failed: {}", e);
                std::process::exit(1);
            }
        }
    }

    // Initialize database handler with direct executor
    let db_handler = Arc::new(
        DbHandler::new_with_config(&db_path, &config)
            .map_err(|e| anyhow::anyhow!("Failed to create database handler: {}", e))?,
    );

    // Unix socket setup (only on Unix platforms)
    #[cfg(unix)]
    let (socket_path, unix_listener) = {
        let socket_path = PathBuf::from(&config.socket_dir).join(format!(".s.PGSQL.{}", config.port));