Fix sending packets to server by fixing zstd --adapt argument.

README.md

@@ -61,6 +61,7 @@ Creating the Alfred node image is done using [Packer](https://www.packer.io/) in
 
 ### Dependencies
 
+- bash
 - docker
 - tar
 - zstd

client/jobfile/reader.go

@@ -158,7 +158,7 @@ func evaluateTemplate(source string, dir string, options ReadOptions) (string, e
 			return strings.Split(s, "\n")
 		},
 		"shell": func(script string) string {
-			cmd := exec.Command("/bin/sh", "-c", script)
+			cmd := exec.Command("/bin/bash", "-euo", "pipefail", "-c", script)
 			cmd.Dir = dir
 			cmd.Stdin = os.Stdin
 			cmd.Stderr = os.Stderr

client/run.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"os"
 	"os/exec"
 	"strings"
 
@@ -116,7 +117,8 @@ func sendImageToServer(cmd *cobra.Command, image string) error {
 		return nil
 	case proto.LoadImageResponse_CONTINUE:
 		// The image does not exist on the server, send it
-		cmd := exec.Command("/bin/sh", "-c", fmt.Sprintf("docker save '%s' | zstd --compress --adapt --min=5 --max=15", image))
+		cmd := exec.Command("/bin/bash", "-euo", "pipefail", "-c", fmt.Sprintf("docker save '%s' | zstd --compress --adapt=min=5,max=15", image))
+		cmd.Stderr = os.Stderr
 		reader := lo.Must(cmd.StdoutPipe())
 		if err := cmd.Start(); err != nil {
 			return fmt.Errorf("docker save: %w", err)

provisioner/openstack/node.go

@@ -173,9 +173,10 @@ func (n *Node) ensureNodeHasImage(image string) error {
 	}
 	defer session.Close()
 
-	saveCmd := exec.Command("/bin/sh", "-c", fmt.Sprintf("docker save '%s' | zstd --compress --adapt --min=5 --max=15", image))
+	saveCmd := exec.Command("/bin/bash", "-euo", "pipefail", "-c", fmt.Sprintf("docker save '%s' | zstd --compress --adapt=min=5,max=15", image))
 	saveOut := lo.Must(saveCmd.StdoutPipe())
 	session.Stdin = saveOut
+	session.Stderr = os.Stderr
 
 	if err := saveCmd.Start(); err != nil {
 		return fmt.Errorf("failed to start docker save: %w", err)

server/server_load.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"os"
 	"os/exec"
 	"time"
 
@@ -54,8 +55,9 @@ func (s *server) LoadImage(srv proto.Alfred_LoadImageServer) (err error) {
 	}
 
 	// Main load loop
-	cmd := exec.Command("/bin/sh", "-c", "zstd --decompress | docker load")
+	cmd := exec.Command("/bin/bash", "-euo", "pipefail", "-c", "zstd --decompress | docker load")
 	cmd.WaitDelay = 10 * time.Second
+	cmd.Stderr = os.Stderr
 
 	writer := lo.Must(cmd.StdinPipe())
 	if err := cmd.Start(); err != nil {