outlayer-cli 0.1.1

CLI for deploying, running, and managing OutLayer agents
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

use anyhow::Result;
use serde_json::json;

use crate::config::{self, NetworkConfig, ProjectConfig};
use crate::near::{ContractCaller, NearClient};

/// `outlayer versions` — list project versions
pub async fn list(network: &NetworkConfig, project_config: &ProjectConfig) -> Result<()> {
    let near = NearClient::new(network);

    let project_id = format!(
        "{}/{}",
        project_config.project.owner, project_config.project.name
    );

    let versions = near.list_versions(&project_id, None, Some(50)).await?;

    if versions.is_empty() {
        eprintln!("No versions found for {project_id}");
        return Ok(());
    }

    println!(
        "{:<12} {:<50} {:<8}",
        "VERSION", "SOURCE", "STATUS"
    );

    for v in &versions {
        let version_key = &v.wasm_hash;
        let short_key = if version_key.len() > 10 {
            &version_key[..10]
        } else {
            version_key
        };

        let source_str = format_source(&v.source);
        let status = if v.is_active { "active" } else { "---" };

        println!("{:<12} {:<50} {:<8}", short_key, source_str, status);
    }

    Ok(())
}

/// `outlayer versions activate <version_key>` — switch active version
pub async fn activate(
    network: &NetworkConfig,
    project_config: &ProjectConfig,
    version_key: &str,
) -> Result<()> {
    let creds = config::load_credentials(network)?;

    let caller = ContractCaller::from_credentials(&creds, network)?;
    let gas = 30_000_000_000_000u64; // 30 TGas

    caller
        .call_contract(
            "set_active_version",
            json!({
                "project_name": project_config.project.name,
                "version_key": version_key,
            }),
            gas,
            0,
        )
        .await?;

    eprintln!("Activated version: {version_key}");
    Ok(())
}

/// `outlayer versions remove <version_key>` — remove a version
pub async fn remove(
    network: &NetworkConfig,
    project_config: &ProjectConfig,
    version_key: &str,
) -> Result<()> {
    let creds = config::load_credentials(network)?;

    let caller = ContractCaller::from_credentials(&creds, network)?;
    let gas = 30_000_000_000_000u64; // 30 TGas

    caller
        .call_contract(
            "remove_version",
            json!({
                "project_name": project_config.project.name,
                "version_key": version_key,
            }),
            gas,
            0,
        )
        .await?;

    eprintln!("Removed version: {version_key}");
    Ok(())
}

fn format_source(source: &serde_json::Value) -> String {
    if let Some(obj) = source.as_object() {
        if let Some(github) = obj.get("GitHub") {
            let repo = github
                .get("repo")
                .and_then(|v| v.as_str())
                .unwrap_or("?");
            let commit = github
                .get("commit")
                .and_then(|v| v.as_str())
                .unwrap_or("?");
            let short_commit = if commit.len() > 7 {
                &commit[..7]
            } else {
                commit
            };
            return format!("github:{repo}@{short_commit}");
        }
        if let Some(wasm) = obj.get("WasmUrl") {
            let url = wasm.get("url").and_then(|v| v.as_str()).unwrap_or("?");
            return format!("wasm:{url}");
        }
    }
    source.to_string()
}