cubic 0.13.0

Cubic is a lightweight command line manager for virtual machines. It has a simple, daemon-less and rootless design. All Cubic virtual machines run isolated in the user context. Cubic is built on top of QEMU, KVM and cloud-init. Show all supported images: $ cubic image ls Create a new virtual machine instance: $ cubic add mymachine --image ubuntu:noble List all virtual machine instances: $ cubic ls Start an instance: $ cubic start <instance name> Stop an instance: $ cubic stop <instance name> Open a shell in the instance: $ cubic ssh <machine name> Copy a file from the host to the instance: $ cubic scp <path/to/host/file> <machine>:<path/to/guest/file> Copy a file from the instance to the hots: $ cubic scp <machine>:<path/to/guest/file> <path/to/host/file> 
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

use crate::commands::{self, Verbosity};
use crate::error::Error;
use crate::instance::{InstanceDao, InstanceStore};
use crate::ssh_cmd::{get_ssh_private_key_names, Ssh};
use crate::view::SpinnerView;
use clap::Parser;
use std::env;
use std::thread;
use std::time::{Duration, Instant};

fn get_instance_name(target: &str) -> Result<String, Error> {
    if target.contains('@') {
        target
            .split('@')
            .nth(1)
            .map(|instance| instance.to_string())
            .ok_or(Error::InvalidSshTarget(target.to_string()))
    } else {
        Ok(target.to_string())
    }
}

fn get_user_name(target: &str) -> Result<Option<String>, Error> {
    if target.contains('@') {
        target
            .split('@')
            .next()
            .map(|instance| Some(instance.to_string()))
            .ok_or(Error::InvalidSshTarget(target.to_string()))
    } else {
        Ok(None)
    }
}

/// Connect to a virtual machine instance with SSH
#[derive(Parser)]
pub struct InstanceSshCommand {
    /// Name of the virtual machine instance
    pub instance: String,
    /// Forward X over SSH
    #[clap(short = 'X', default_value_t = false)]
    pub xforward: bool,
    /// Enable verbose logging
    #[clap(short, long, default_value_t = false)]
    pub verbose: bool,
    /// Reduce logging output
    #[clap(short, long, default_value_t = false)]
    pub quiet: bool,
    /// Pass additional SSH arguments
    #[clap(long)]
    pub ssh_args: Option<String>,
    /// Execute a command in the virtual machine
    pub cmd: Option<String>,
}

impl InstanceSshCommand {
    pub fn run(&self, instance_dao: &InstanceDao) -> Result<(), Error> {
        let name = get_instance_name(&self.instance)?;
        let instance = instance_dao.load(&name)?;
        let user = get_user_name(&self.instance)?.unwrap_or(instance.user.to_string());
        let ssh_port = instance.ssh_port;
        let verbosity = Verbosity::new(self.verbose, self.quiet);

        commands::InstanceStartCommand {
            qemu_args: None,
            verbose: self.verbose,
            quiet: self.quiet,
            wait: true,
            instances: vec![name.to_string()],
        }
        .run(instance_dao)?;

        let mut ssh = None;
        let mut start_time = Instant::now();

        if !verbosity.is_quiet() {
            println!("Default login user: cubic / password: cubic");
        }

        loop {
            if ssh.is_none() {
                ssh = Some(
                    Ssh::new()
                        .set_known_hosts_file(
                            env::var("HOME")
                                .map(|dir| format!("{dir}/.ssh/known_hosts"))
                                .ok(),
                        )
                        .set_private_keys(get_ssh_private_key_names()?)
                        .set_port(Some(ssh_port))
                        .set_xforward(self.xforward)
                        .set_args(self.ssh_args.clone().unwrap_or_default())
                        .set_user(user.clone())
                        .set_cmd(self.cmd.clone())
                        .set_verbose(verbosity.is_verbose())
                        .connect()
                        .spawn()?,
                );
                start_time = Instant::now();
            }

            if let Ok(Some(exit)) = ssh.as_mut().unwrap().try_wait() {
                if exit.success() || self.cmd.is_some() || start_time.elapsed().as_secs() > 5 {
                    break;
                }
                let spinner = (!verbosity.is_quiet()).then(|| SpinnerView::new("Try to connect"));
                thread::sleep(Duration::from_secs(5));
                if let Some(mut s) = spinner {
                    s.stop()
                }
                ssh = None;
            } else {
                thread::sleep(Duration::from_secs(1));
            }
        }

        Ok(())
    }
}