Publish

.gitignore

@@ -1 +1,3 @@
-bin/
+.DS_Store
+
+bin/

cmd/delete.go

@@ -15,7 +15,7 @@ import (
 
 var deleteCmd = &cobra.Command{
 	Use:   "delete NAME",
-	Short: "Delete an Alpine VM by NAME.",
+	Short: "Delete an Alpine VM.",
 	Run:   delete,
 }
 

cmd/import.go

@@ -0,0 +1,48 @@
+package cmd
+
+import (
+	"log"
+	"os"
+	"path/filepath"
+	"strings"
+
+	"github.com/beringresearch/macpine/utils"
+	"github.com/spf13/cobra"
+)
+
+// importCmd iports an Alpine VM from file
+var importCmd = &cobra.Command{
+	Use:   "import NAME",
+	Short: "Imports Alpine VM instances.",
+	Run:   importMachine,
+}
+
+func importMachine(cmd *cobra.Command, args []string) {
+
+	if len(args) == 0 {
+		log.Fatal("missing name - please provide VM name")
+		return
+	}
+
+	userHomeDir, err := os.UserHomeDir()
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	_, err = utils.CopyFile(args[0], filepath.Join(userHomeDir, ".macpine", args[0]))
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	err = utils.Uncompress(filepath.Join(userHomeDir, ".macpine", args[0]),
+		filepath.Join(userHomeDir, ".macpine", strings.Split(args[0], ".tar.gz")[0]))
+
+	if err != nil {
+		log.Println(err)
+	}
+
+	err = os.Remove(filepath.Join(userHomeDir, ".macpine", args[0]))
+	if err != nil {
+		log.Fatal(err)
+	}
+}

cmd/list.go

@@ -14,7 +14,7 @@ import (
 	"gopkg.in/yaml.v2"
 )
 
-// listCmd starts an Alpine instance
+// listCmd lists Alpine instances
 var listCmd = &cobra.Command{
 	Use:   "list",
 	Short: "List all available Alpine VM instances.",

cmd/publish.go

@@ -0,0 +1,74 @@
+package cmd
+
+import (
+	"io/ioutil"
+	"log"
+	"os"
+	"path/filepath"
+	"time"
+
+	"github.com/beringresearch/macpine/host"
+	qemu "github.com/beringresearch/macpine/qemu"
+	"github.com/beringresearch/macpine/utils"
+	"github.com/spf13/cobra"
+)
+
+// publishCmd stops an Alpine instance
+var publishCmd = &cobra.Command{
+	Use:   "publish NAME",
+	Short: "Publish an Alpine VM.",
+	Run:   publish,
+}
+
+func publish(cmd *cobra.Command, args []string) {
+
+	userHomeDir, err := os.UserHomeDir()
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	if len(args) == 0 {
+		log.Fatal("missing name - please provide VM name")
+		return
+	}
+
+	machineConfig := qemu.MachineConfig{
+		Alias: args[0],
+	}
+	machineConfig.Location = filepath.Join(userHomeDir, ".macpine", machineConfig.Alias)
+
+	err = host.Stop(machineConfig)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	time.Sleep(time.Second)
+
+	fileInfo, err := ioutil.ReadDir(machineConfig.Location)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	files := []string{}
+	for _, f := range fileInfo {
+		files = append(files, filepath.Join(machineConfig.Location, f.Name()))
+	}
+
+	out, err := os.Create(machineConfig.Alias + ".tar.gz")
+	if err != nil {
+		log.Fatalln("Error writing archive:", err)
+	}
+	defer out.Close()
+
+	// Create the archive and write the output to the "out" Writer
+	err = utils.Compress(files, out)
+	if err != nil {
+		log.Fatalln("error creating archive:", err)
+	}
+
+	err = host.Start(machineConfig)
+	if err != nil {
+		log.Fatal(err)
+	}
+
+}

cmd/root.go

@@ -31,4 +31,6 @@ func init() {
 	rootCmd.AddCommand(startCmd)
 	rootCmd.AddCommand(deleteCmd)
 	rootCmd.AddCommand(listCmd)
+	rootCmd.AddCommand(publishCmd)
+	rootCmd.AddCommand(importCmd)
 }

cmd/start.go

@@ -15,7 +15,7 @@ import (
 // startCmd starts an Alpine instance
 var startCmd = &cobra.Command{
 	Use:   "start NAME",
-	Short: "Start an Alpine VM by NAME.",
+	Short: "Start an Alpine VM.",
 	Run:   start,
 }
 

cmd/stop.go

@@ -13,7 +13,7 @@ import (
 // stopCmd stops an Alpine instance
 var stopCmd = &cobra.Command{
 	Use:   "stop NAME",
-	Short: "Stop an Alpine VM by NAME.",
+	Short: "Stop an Alpine VM.",
 	Run:   stop,
 }
 

utils/utils.go

@@ -1,21 +1,114 @@
 package utils
 
 import (
+	"archive/tar"
+	"compress/gzip"
 	"embed"
-	_ "embed"
 	"fmt"
 	"io"
 	"math/rand"
 	"net/http"
 	"os"
 	"os/exec"
+	"path/filepath"
 	"strings"
 	"time"
 )
 
 //go:embed *.txt
 var f embed.FS
 
+//Uncompress uncompresses gzip
+func Uncompress(source string, destination string) error {
+	file, err := os.Open(source)
+	if err != nil {
+		return err
+	}
+	defer file.Close()
+
+	gzRead, err := gzip.NewReader(file)
+	if err != nil {
+		return err
+	}
+	defer gzRead.Close()
+
+	tarRead := tar.NewReader(gzRead)
+	for {
+		cur, err := tarRead.Next()
+		if err == io.EOF {
+			break
+		} else if err != nil {
+			return err
+		}
+
+		os.MkdirAll(destination, 0777)
+
+		switch cur.Typeflag {
+
+		case tar.TypeReg:
+			create, err := os.Create(filepath.Join(destination, cur.Name))
+			if err != nil {
+				return err
+			}
+			defer create.Close()
+			create.ReadFrom(tarRead)
+		case tar.TypeLink:
+			os.Link(cur.Linkname, cur.Name)
+		}
+	}
+	return nil
+}
+
+// Compress creates a tar.gz of a Direcotry
+func Compress(files []string, buf io.Writer) error {
+	gw := gzip.NewWriter(buf)
+	defer gw.Close()
+	tw := tar.NewWriter(gw)
+	defer tw.Close()
+
+	for _, file := range files {
+		err := addToArchive(tw, file)
+		if err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func addToArchive(tw *tar.Writer, filename string) error {
+
+	file, err := os.Open(filename)
+	if err != nil {
+		return err
+	}
+	defer file.Close()
+
+	info, err := file.Stat()
+	if err != nil {
+		return err
+	}
+
+	header, err := tar.FileInfoHeader(info, info.Name())
+	if err != nil {
+		return err
+	}
+
+	header.Name = filepath.Base(filename)
+
+	err = tw.WriteHeader(header)
+	if err != nil {
+		return err
+	}
+
+	_, err = io.Copy(tw, file)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
 //CopyFile copies file from src to dst
 func CopyFile(src, dst string) (int64, error) {
 	sourceFileStat, err := os.Stat(src)