agentor 0.3.0

Agent-native Actor runtime — an Actor-model execution platform designed for AI Agents
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

use anyhow::Result;
use crate::config::Config;
use crate::{builder, deployer, rollback, syncer};

/// Run the complete deployment workflow: build -> deploy -> sync
pub fn run(config: &Config) -> Result<()> {
    log::info!("=== Starting Agentor deployment workflow ===");
    
    let start_time = std::time::Instant::now();
    
    // Get current commit for logging
    let commit = syncer::get_short_commit().unwrap_or_else(|_| "unknown".to_string());
    log::info!("Current commit: {}", commit);
    
    // Step 1: Build
    if let Err(e) = builder::build(&config.build.command) {
        log::error!("Build failed: {}", e);
        
        // Attempt rollback if enabled
        if config.rollback.enabled && !config.deploy.target_dir.is_empty() {
            log::warn!("Attempting to rollback due to build failure...");
            if let Err(rollback_err) = rollback::rollback(".", &config.deploy.target_dir) {
                log::error!("Rollback failed: {}", rollback_err);
            }
        }
        
        return Err(e);
    }
    
    // Verify artifacts exist
    if !config.deploy.artifacts.is_empty() {
        if let Err(e) = builder::verify_artifacts(&config.deploy.artifacts) {
            log::error!("Artifact verification failed: {}", e);
            return Err(e);
        }
    }
    
    // Step 2: Backup current version (before deployment)
    if config.rollback.enabled && !config.deploy.artifacts.is_empty() {
        let full_commit = syncer::get_current_commit().unwrap_or_else(|_| commit.clone());
        if let Err(e) = rollback::backup_version(
            ".",
            &full_commit,
            &config.deploy.artifacts,
            config.rollback.keep_versions,
        ) {
            log::warn!("Failed to backup version: {}", e);
        }
    }
    
    // Step 3: Deploy
    if let Err(e) = deployer::deploy(
        &config.deploy.command,
        &config.deploy.target_dir,
        &config.deploy.artifacts,
    ) {
        log::error!("Deployment failed: {}", e);
        
        // Attempt rollback if enabled
        if config.rollback.enabled && !config.deploy.target_dir.is_empty() {
            log::warn!("Attempting to rollback due to deployment failure...");
            if let Err(rollback_err) = rollback::rollback(".", &config.deploy.target_dir) {
                log::error!("Rollback failed: {}", rollback_err);
            }
        }
        
        return Err(e);
    }
    
    // Step 4: Sync to remote (if enabled)
    if config.sync.enabled {
        if let Err(e) = syncer::sync(&config.sync.remote, &config.sync.branch) {
            log::error!("Sync to remote failed: {}", e);
            log::warn!("Local deployment succeeded but sync failed");
            // Don't return error - local deployment is more important
        }
    }
    
    let duration = start_time.elapsed();
    log::info!("=== Deployment workflow completed successfully in {:.2}s ===", duration.as_secs_f64());
    
    Ok(())
}