From 8b05b9f27b500d7584bfb83852592bafeac25de8 Mon Sep 17 00:00:00 2001
From: Radu M <root@radu.sh>
Date: Mon, 12 Aug 2019 18:21:04 +0300
Subject: [PATCH] Remove command_driver from Duffle since it moved to cnab-go
 (#825)

Signed-off-by: Radu M <root@radu.sh>
---
 pkg/driver/command_driver.go | 105 -----------------------------------
 1 file changed, 105 deletions(-)
 delete mode 100644 pkg/driver/command_driver.go

diff --git a/pkg/driver/command_driver.go b/pkg/driver/command_driver.go
deleted file mode 100644
index a4fed51e..00000000
--- a/pkg/driver/command_driver.go
+++ /dev/null
@@ -1,105 +0,0 @@
-package driver
-
-import (
-	"bytes"
-	"encoding/json"
-	"fmt"
-	"io"
-	"os"
-	"os/exec"
-	"strings"
-
-	"github.com/deislabs/cnab-go/driver"
-)
-
-// CommandDriver relies upon a system command to provide a driver implementation
-type CommandDriver struct {
-	Name string
-}
-
-// Run executes the command
-func (d *CommandDriver) Run(op *driver.Operation) error {
-	return d.exec(op)
-}
-
-// Handles executes the driver with `--handles` and parses the results
-func (d *CommandDriver) Handles(dt string) bool {
-	out, err := exec.Command(d.cliName(), "--handles").CombinedOutput()
-	if err != nil {
-		fmt.Printf("%s --handles: %s", d.cliName(), err)
-		return false
-	}
-	types := strings.Split(string(out), ",")
-	for _, tt := range types {
-		if dt == strings.TrimSpace(tt) {
-			return true
-		}
-	}
-	return false
-}
-
-func (d *CommandDriver) cliName() string {
-	return "duffle-" + strings.ToLower(d.Name)
-}
-
-func (d *CommandDriver) exec(op *driver.Operation) error {
-	// We need to do two things here: We need to make it easier for the
-	// command to access data, and we need to make it easy for the command
-	// to pass that data on to the image it invokes. So we do some data
-	// duplication.
-
-	// Construct an environment for the subprocess by cloning our
-	// environment and adding in all the extra env vars.
-	pairs := os.Environ()
-	added := []string{}
-	for k, v := range op.Environment {
-		pairs = append(pairs, fmt.Sprintf("%s=%s", k, v))
-		added = append(added, k)
-	}
-	// DUFFLE_VARS is a list of variables we added to the env. This is to make
-	// it easier for shell script drivers to clone the env vars.
-	pairs = append(pairs, fmt.Sprintf("DUFFLE_VARS=%s", strings.Join(added, ",")))
-
-	data, err := json.Marshal(op)
-	if err != nil {
-		return err
-	}
-	args := []string{}
-	cmd := exec.Command(d.cliName(), args...)
-	cmd.Dir, err = os.Getwd()
-	if err != nil {
-		return err
-	}
-	cmd.Env = pairs
-	cmd.Stdin = bytes.NewBuffer(data)
-
-	// Make stdout and stderr from driver available immediately
-
-	stdout, err := cmd.StdoutPipe()
-	if err != nil {
-		return fmt.Errorf("Setting up output handling for driver (%s) failed: %v", d.Name, err)
-	}
-
-	go func() {
-
-		// Errors not handled here as they only prevent output from the driver being shown, errors in the command execution are handled when command is executed
-
-		io.Copy(op.Out, stdout)
-	}()
-	stderr, err := cmd.StderrPipe()
-	if err != nil {
-		return fmt.Errorf("Setting up error output handling for driver (%s) failed: %v", d.Name, err)
-	}
-	go func() {
-
-		// Errors not handled here as they only prevent output from the driver being shown, errors in the command execution are handled when command is executed
-
-		io.Copy(op.Out, stderr)
-	}()
-
-	if err = cmd.Start(); err != nil {
-		return fmt.Errorf("Start of driver (%s) failed: %v", d.Name, err)
-	}
-
-	return cmd.Wait()
-}