cubic 0.14.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 images Create a new virtual machine instance: $ cubic create mymachine --image ubuntu:noble List all virtual machine instances: $ cubic instances 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

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

/// Connect to a virtual machine instance with SSH
#[derive(Parser)]
pub struct InstanceSshCommand {
    /// Target instance (format: [username@]instance, e.g. 'cubic@mymachine' or 'mymachine')
    pub target: Target,
    /// Forward X over SSH
    #[clap(short = 'X', default_value_t = false)]
    pub xforward: 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,
        console: &mut dyn Console,
        instance_dao: &InstanceDao,
        verbosity: Verbosity,
    ) -> Result<(), Error> {
        let name = self.target.get_instance();
        let instance = instance_dao.load(name.as_str())?;
        let user = self
            .target
            .get_user()
            .map(|user| user.to_string())
            .unwrap_or(instance.user.to_string());
        let ssh_port = instance.ssh_port;

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

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

        console.info("Default login user: cubic / password: cubic");

        loop {
            if ssh.is_none() {
                let mut cmd = 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())
                    .connect();
                console.debug(&cmd.get_command());
                ssh = Some(cmd.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(())
    }
}