1 files changed, 84 insertions, 0 deletions
diff --git a/cmd/podman/machine/ssh.go b/cmd/podman/machine/ssh.go
new file mode 100644
index 000000000..fc7c71992
--- /dev/null
+++ b/cmd/podman/machine/ssh.go
@@ -0,0 +1,84 @@
+// +build amd64,linux arm64,linux amd64,darwin arm64,darwin
+
+package machine
+
+import (
+	"github.com/containers/podman/v3/cmd/podman/registry"
+	"github.com/containers/podman/v3/pkg/domain/entities"
+	"github.com/containers/podman/v3/pkg/machine"
+	"github.com/containers/podman/v3/pkg/machine/qemu"
+	"github.com/pkg/errors"
+	"github.com/spf13/cobra"
+)
+
+var (
+	sshCmd = &cobra.Command{
+		Use:   "ssh [NAME] [COMMAND [ARG ...]]",
+		Short: "SSH into a virtual machine",
+		Long:  "SSH into a virtual machine ",
+		RunE:  ssh,
+		Example: `podman machine ssh myvm
+  podman machine ssh -e  myvm echo hello`,
+		ValidArgsFunction: autocompleteMachineSSH,
+	}
+)
+
+var (
+	sshOpts machine.SSHOptions
+)
+
+func init() {
+	sshCmd.Flags().SetInterspersed(false)
+	registry.Commands = append(registry.Commands, registry.CliCommand{
+		Mode:    []entities.EngineMode{entities.ABIMode, entities.TunnelMode},
+		Command: sshCmd,
+		Parent:  machineCmd,
+	})
+}
+
+func ssh(cmd *cobra.Command, args []string) error {
+	var (
+		err     error
+		validVM bool
+		vm      machine.VM
+		vmType  string
+	)
+
+	// Set the VM to default
+	vmName := defaultMachineName
+	// If len is greater than 0, it means we may have been
+	// provided the VM name.  If so, we check.  The VM name,
+	// if provided, must be in args[0].
+	if len(args) > 0 {
+		switch vmType {
+		default:
+			validVM, err = qemu.IsValidVMName(args[0])
+			if err != nil {
+				return err
+			}
+			if validVM {
+				vmName = args[0]
+			} else {
+				sshOpts.Args = append(sshOpts.Args, args[0])
+			}
+		}
+	}
+	// If len is greater than 1, it means we might have been
+	// given a vmname and args or just args
+	if len(args) > 1 {
+		if validVM {
+			sshOpts.Args = args[1:]
+		} else {
+			sshOpts.Args = args
+		}
+	}
+
+	switch vmType {
+	default:
+		vm, err = qemu.LoadVMByName(vmName)
+	}
+	if err != nil {
+		return errors.Wrapf(err, "vm %s not found", args[0])
+	}
+	return vm.SSH(vmName, sshOpts)
+}