|  | @@ -1,21 +1,42 @@
 | 
	
		
			
				|  |  | +/*
 | 
	
		
			
				|  |  | +	Copyright (c) 2020 Docker Inc.
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +	Permission is hereby granted, free of charge, to any person
 | 
	
		
			
				|  |  | +	obtaining a copy of this software and associated documentation
 | 
	
		
			
				|  |  | +	files (the "Software"), to deal in the Software without
 | 
	
		
			
				|  |  | +	restriction, including without limitation the rights to use, copy,
 | 
	
		
			
				|  |  | +	modify, merge, publish, distribute, sublicense, and/or sell copies
 | 
	
		
			
				|  |  | +	of the Software, and to permit persons to whom the Software is
 | 
	
		
			
				|  |  | +	furnished to do so, subject to the following conditions:
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +	The above copyright notice and this permission notice shall be
 | 
	
		
			
				|  |  | +	included in all copies or substantial portions of the Software.
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +	THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 | 
	
		
			
				|  |  | +	EXPRESS OR IMPLIED,
 | 
	
		
			
				|  |  | +	INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 | 
	
		
			
				|  |  | +	FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 | 
	
		
			
				|  |  | +	IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 | 
	
		
			
				|  |  | +	HOLDERS BE LIABLE FOR ANY CLAIM,
 | 
	
		
			
				|  |  | +	DAMAGES OR OTHER LIABILITY,
 | 
	
		
			
				|  |  | +	WHETHER IN AN ACTION OF CONTRACT,
 | 
	
		
			
				|  |  | +	TORT OR OTHERWISE,
 | 
	
		
			
				|  |  | +	ARISING FROM, OUT OF OR IN CONNECTION WITH
 | 
	
		
			
				|  |  | +	THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 | 
	
		
			
				|  |  | +*/
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  |  package framework
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |  import (
 | 
	
		
			
				|  |  |  	"bytes"
 | 
	
		
			
				|  |  |  	"fmt"
 | 
	
		
			
				|  |  |  	"io"
 | 
	
		
			
				|  |  | -	"io/ioutil"
 | 
	
		
			
				|  |  | -	"os"
 | 
	
		
			
				|  |  |  	"os/exec"
 | 
	
		
			
				|  |  | -	"path/filepath"
 | 
	
		
			
				|  |  | -	"runtime"
 | 
	
		
			
				|  |  |  	"strings"
 | 
	
		
			
				|  |  |  	"time"
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |  	"github.com/onsi/gomega"
 | 
	
		
			
				|  |  |  	log "github.com/sirupsen/logrus"
 | 
	
		
			
				|  |  | -	"github.com/stretchr/testify/require"
 | 
	
		
			
				|  |  | -	"github.com/stretchr/testify/suite"
 | 
	
		
			
				|  |  |  )
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |  func (b CmdContext) makeCmd() *exec.Cmd {
 | 
	
	
		
			
				|  | @@ -40,81 +61,6 @@ type RetriesContext struct {
 | 
	
		
			
				|  |  |  	interval time.Duration
 | 
	
		
			
				|  |  |  }
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | -// Suite is used to store context information for e2e tests
 | 
	
		
			
				|  |  | -type Suite struct {
 | 
	
		
			
				|  |  | -	suite.Suite
 | 
	
		
			
				|  |  | -	ConfigDir string
 | 
	
		
			
				|  |  | -	BinDir    string
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -// SetupSuite is run before running any tests
 | 
	
		
			
				|  |  | -func (s *Suite) SetupSuite() {
 | 
	
		
			
				|  |  | -	d, _ := ioutil.TempDir("", "")
 | 
	
		
			
				|  |  | -	s.BinDir = d
 | 
	
		
			
				|  |  | -	gomega.RegisterFailHandler(func(message string, callerSkip ...int) {
 | 
	
		
			
				|  |  | -		log.Error(message)
 | 
	
		
			
				|  |  | -		cp := filepath.Join(s.ConfigDir, "config.json")
 | 
	
		
			
				|  |  | -		d, _ := ioutil.ReadFile(cp)
 | 
	
		
			
				|  |  | -		fmt.Printf("Contents of %s:\n%s\n\nContents of config dir:\n", cp, string(d))
 | 
	
		
			
				|  |  | -		out, _ := s.NewCommand("find", s.ConfigDir).Exec()
 | 
	
		
			
				|  |  | -		fmt.Println(out)
 | 
	
		
			
				|  |  | -		s.T().Fail()
 | 
	
		
			
				|  |  | -	})
 | 
	
		
			
				|  |  | -	s.linkClassicDocker()
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -// TearDownSuite is run after all tests
 | 
	
		
			
				|  |  | -func (s *Suite) TearDownSuite() {
 | 
	
		
			
				|  |  | -	_ = os.RemoveAll(s.BinDir)
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -func (s *Suite) linkClassicDocker() {
 | 
	
		
			
				|  |  | -	p, err := exec.LookPath("docker")
 | 
	
		
			
				|  |  | -	gomega.Expect(err).To(gomega.BeNil())
 | 
	
		
			
				|  |  | -	err = os.Symlink(p, filepath.Join(s.BinDir, "docker-classic"))
 | 
	
		
			
				|  |  | -	gomega.Expect(err).To(gomega.BeNil())
 | 
	
		
			
				|  |  | -	err = os.Setenv("PATH", fmt.Sprintf("%s:%s", s.BinDir, os.Getenv("PATH")))
 | 
	
		
			
				|  |  | -	gomega.Expect(err).To(gomega.BeNil())
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -// BeforeTest is run before each test
 | 
	
		
			
				|  |  | -func (s *Suite) BeforeTest(suite, test string) {
 | 
	
		
			
				|  |  | -	d, _ := ioutil.TempDir("", "")
 | 
	
		
			
				|  |  | -	s.ConfigDir = d
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -// AfterTest is run after each test
 | 
	
		
			
				|  |  | -func (s *Suite) AfterTest(suite, test string) {
 | 
	
		
			
				|  |  | -	err := os.RemoveAll(s.ConfigDir)
 | 
	
		
			
				|  |  | -	require.NoError(s.T(), err)
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -// NewCommand creates a command context.
 | 
	
		
			
				|  |  | -func (s *Suite) NewCommand(command string, args ...string) *CmdContext {
 | 
	
		
			
				|  |  | -	var envs []string
 | 
	
		
			
				|  |  | -	if s.ConfigDir != "" {
 | 
	
		
			
				|  |  | -		envs = append(os.Environ(), fmt.Sprintf("DOCKER_CONFIG=%s", s.ConfigDir))
 | 
	
		
			
				|  |  | -	}
 | 
	
		
			
				|  |  | -	return &CmdContext{
 | 
	
		
			
				|  |  | -		command: command,
 | 
	
		
			
				|  |  | -		args:    args,
 | 
	
		
			
				|  |  | -		envs:    envs,
 | 
	
		
			
				|  |  | -		retries: RetriesContext{interval: time.Second},
 | 
	
		
			
				|  |  | -	}
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -func dockerExecutable() string {
 | 
	
		
			
				|  |  | -	if runtime.GOOS == "windows" {
 | 
	
		
			
				|  |  | -		return "../../bin/docker.exe"
 | 
	
		
			
				|  |  | -	}
 | 
	
		
			
				|  |  | -	return "../../bin/docker"
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -// NewDockerCommand creates a docker builder.
 | 
	
		
			
				|  |  | -func (s *Suite) NewDockerCommand(args ...string) *CmdContext {
 | 
	
		
			
				|  |  | -	return s.NewCommand(dockerExecutable(), args...)
 | 
	
		
			
				|  |  | -}
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  |  // WithinDirectory tells Docker the cwd.
 | 
	
		
			
				|  |  |  func (b *CmdContext) WithinDirectory(path string) *CmdContext {
 | 
	
		
			
				|  |  |  	b.dir = path
 |