docker: adds integration test

.travis.yml

@@ -28,6 +28,22 @@ jobs:
     script: make test
     env: GOARCH=386
     go: "master"
+  - stage: integration
+    script: make integration
+    env: GOARCH=386
+    go: "1.10.x"
+  - stage: integration
+    script: make integration
+    env: GOARCH=amd64
+    go: "1.10.x"
+  - stage: integration
+    script: make integration
+    env: GOARCH=amd64
+    go: "master"
+  - stage: integration
+    script: make integration
+    env: GOARCH=386
+    go: "master"
   - stage: push to docker
     script:
     - docker login -u $DOCKER_USER -p $DOCKER_PASS

Makefile

@@ -2,7 +2,7 @@ TAG=latest
 BINARY=deploy-agent
 IMAGE=tsuru/$(BINARY)
 
-.PHONY: build-docker push test
+.PHONY: build-docker push test integration
 
 build-docker:
 	docker build --rm -t $(IMAGE):$(TAG) .
@@ -12,3 +12,6 @@ push: build-docker
 
 test: 
 	go test ./... -coverprofile=
+
+integration:
+	DEPLOYAGENT_INTEGRATION="true" make test

internal/docker/integration_test.go

@@ -0,0 +1,105 @@
+package docker
+
+import (
+	"bytes"
+	"context"
+	"fmt"
+	"os"
+	"time"
+
+	"github.com/fsouza/go-dockerclient"
+	"github.com/tsuru/tsuru/exec"
+	"gopkg.in/check.v1"
+)
+
+const primaryImage = "tsuru/base-platform"
+
+func checkSkip(c *check.C) {
+	if os.Getenv("DEPLOYAGENT_INTEGRATION") == "" {
+		c.Skip("skipping integration tests")
+	}
+}
+
+func (s *S) TestSidecarUploadToPrimaryContainerIntegration(c *check.C) {
+	checkSkip(c)
+
+	dClient, err := NewClient("")
+	c.Assert(err, check.IsNil)
+
+	pContID, err := setupPrimaryContainer(c, dClient)
+	defer func(id string) {
+		if id != "" {
+			dClient.api.RemoveContainer(docker.RemoveContainerOptions{ID: id, Force: true})
+		}
+	}(pContID)
+	c.Assert(err, check.IsNil)
+
+	sidecar, err := NewSidecar(dClient, "")
+	c.Assert(err, check.IsNil)
+
+	err = sidecar.UploadToPrimaryContainer(context.Background(), "testdata/file.txt")
+	c.Assert(err, check.IsNil)
+
+	outBuff := new(bytes.Buffer)
+	errBuff := new(bytes.Buffer)
+	err = sidecar.Execute(exec.ExecuteOptions{
+		Cmd:    "/bin/sh",
+		Args:   []string{"-lc", "cat /testdata/file.txt"},
+		Stdout: outBuff,
+		Stderr: errBuff,
+	})
+	out, errOutput := outBuff.String(), errBuff.String()
+	c.Assert(err, check.IsNil, check.Commentf("error checking file uploaded: %v. Output: %v. Error: %v", err, out, errOutput))
+	c.Assert(out, check.DeepEquals, "file data", check.Commentf("unexpected filed content: %v. Err output: %v", out, errOutput))
+	c.Assert(errOutput, check.DeepEquals, "")
+}
+
+func setupPrimaryContainer(c *check.C, dClient *Client) (string, error) {
+	hostname, err := os.Hostname()
+	if err != nil {
+		return "", fmt.Errorf("error getting hostname: %v", err)
+	}
+
+	err = dClient.api.PullImage(docker.PullImageOptions{Repository: primaryImage}, docker.AuthConfiguration{})
+	if err != nil {
+		return "", fmt.Errorf("error pulling image %v: %v", primaryImage, err)
+	}
+
+	pCont, err := dClient.api.CreateContainer(docker.CreateContainerOptions{
+		Config: &docker.Config{
+			Image: primaryImage,
+			Cmd:   []string{"/bin/sh", "-lc", "while true; do sleep 10; done"},
+			Labels: map[string]string{
+				"io.kubernetes.container.name": hostname,
+				"io.kubernetes.pod.name":       hostname,
+			},
+		},
+	})
+
+	if err != nil {
+		return "", fmt.Errorf("error creating primary container: %v", err)
+	}
+
+	err = dClient.api.StartContainer(pCont.ID, nil)
+	if err != nil {
+		return pCont.ID, fmt.Errorf("error starting primary container: %v", err)
+	}
+
+	timeout := time.After(time.Second * 15)
+	for {
+		c, err := dClient.api.InspectContainer(pCont.ID)
+		if err != nil {
+			return pCont.ID, fmt.Errorf("error inspecting primary container: %v", err)
+		}
+		if c.State.Running {
+			break
+		}
+		select {
+		case <-time.After(time.Second):
+		case <-timeout:
+			return pCont.ID, fmt.Errorf("timeout waiting for primary container to run")
+		}
+	}
+
+	return pCont.ID, nil
+}

internal/docker/testdata/file.txt

@@ -0,0 +1 @@
+file data