From fa87ea55d419ca95384aa4917d62fdf73b59cd8a Mon Sep 17 00:00:00 2001
From: Maor Friedman <maor.friedman@nuvo-group.com>
Date: Sat, 8 Sep 2018 11:16:33 +0300
Subject: [PATCH] change command from string to []string

---
 pkg/skbn/kube.go | 33 +++++++++++++++++----------------
 pkg/skbn/skbn.go |  6 ------
 2 files changed, 17 insertions(+), 22 deletions(-)

diff --git a/pkg/skbn/kube.go b/pkg/skbn/kube.go
index 633d5a3..cfced4a 100644
--- a/pkg/skbn/kube.go
+++ b/pkg/skbn/kube.go
@@ -66,7 +66,7 @@ func GetListOfFilesFromK8s(iClient interface{}, path, findType, findName string)
 		return nil, err
 	}
 	namespace, podName, containerName, findPath := initK8sVariables(pSplit)
-	command := fmt.Sprintf("find %s -type %s -name %s", findPath, findType, findName)
+	command := []string{"find", findPath, "-type", findType, "-name", findName}
 
 	attempts := 3
 	attempt := 0
@@ -111,7 +111,7 @@ func DownloadFromK8s(iClient interface{}, path string) ([]byte, error) {
 		return nil, err
 	}
 	namespace, podName, containerName, pathToCopy := initK8sVariables(pSplit)
-	command := fmt.Sprintf("cat %s", pathToCopy)
+	command := []string{"cat", pathToCopy}
 
 	attempts := 3
 	attempt := 0
@@ -154,7 +154,7 @@ func UploadToK8s(iClient interface{}, toPath, fromPath string, buffer []byte) er
 	for attempt < attempts {
 		attempt++
 		dir, _ := filepath.Split(pathToCopy)
-		command := fmt.Sprintf("mkdir -p %s", dir)
+		command := []string{"mkdir", "-p", dir}
 		_, stderr, err := Exec(client, namespace, podName, containerName, command, nil)
 
 		if len(stderr) != 0 {
@@ -173,24 +173,25 @@ func UploadToK8s(iClient interface{}, toPath, fromPath string, buffer []byte) er
 		}
 
 		chunkSize := 16777215
+		command = []string{"dd", "if=/dev/stdin", "of=" + pathToCopy}
 
-		command = fmt.Sprintf("dd if=/dev/stdin of=%s", pathToCopy)
+		// Implement upload using chunks
 		for i := 0; i < len(buffer); i += chunkSize {
 			end := i + chunkSize
 			if end > len(buffer) {
 				end = len(buffer)
 			}
 			stdin := bytes.NewReader(buffer[i:end])
-			_, _, err = Exec(client, namespace, podName, containerName, command, stdin)
-			command = fmt.Sprintf("dd if=/dev/stdin of=%s oflag=append conv=notrunc", pathToCopy)
-
-			// if len(stderr) != 0 {
-			// 	if attempt == attempts {
-			// 		return fmt.Errorf("STDERR: " + (string)(stderr))
-			// 	}
-			// 	utils.Sleep(attempt)
-			// 	continue
-			// }
+			_, stderr, err = Exec(client, namespace, podName, containerName, command, stdin)
+			command = []string{"dd", "if=/dev/stdin", "of=" + pathToCopy, "oflag=append", "conv=notrunc"}
+
+			if len(stderr) != 0 {
+				if attempt == attempts {
+					return fmt.Errorf("STDERR: " + (string)(stderr))
+				}
+				utils.Sleep(attempt)
+				continue
+			}
 			if err != nil {
 				if attempt == attempts {
 					return err
@@ -206,7 +207,7 @@ func UploadToK8s(iClient interface{}, toPath, fromPath string, buffer []byte) er
 }
 
 // Exec executes a command in a given container
-func Exec(client K8sClient, namespace, podName, containerName, command string, stdin io.Reader) ([]byte, []byte, error) {
+func Exec(client K8sClient, namespace, podName, containerName string, command []string, stdin io.Reader) ([]byte, []byte, error) {
 	clientset, config := client.ClientSet, client.Config
 
 	req := clientset.Core().RESTClient().Post().
@@ -221,7 +222,7 @@ func Exec(client K8sClient, namespace, podName, containerName, command string, s
 
 	parameterCodec := runtime.NewParameterCodec(scheme)
 	req.VersionedParams(&core_v1.PodExecOptions{
-		Command:   strings.Fields(command),
+		Command:   command,
 		Container: containerName,
 		Stdin:     stdin != nil,
 		Stdout:    true,
diff --git a/pkg/skbn/skbn.go b/pkg/skbn/skbn.go
index 512a8b3..354896c 100644
--- a/pkg/skbn/skbn.go
+++ b/pkg/skbn/skbn.go
@@ -5,7 +5,6 @@ import (
 	"log"
 	"math"
 	"path/filepath"
-	"strings"
 
 	"github.com/maorfr/skbn/pkg/utils"
 )
@@ -152,11 +151,6 @@ func PerformCopy(srcClient, dstClient interface{}, srcPrefix, dstPrefix string,
 		currentLinePadded := utils.LeftPad2Len(currentLine, 0, totalDigits)
 
 		go func(srcClient, dstClient interface{}, srcPrefix, fromPath, dstPrefix, toPath, currentLinePadded string, totalFiles int) {
-			if strings.Contains(fromPath, " ") {
-				bwg.Done()
-				log.Printf("file [%s/%d] skip: %s", currentLinePadded, totalFiles, fromPath)
-				return
-			}
 			buffer, err := Download(srcClient, srcPrefix, fromPath)
 			if err != nil {
 				bwg.Done()