Using go generate for mock generation. Adding docker-username to dock…

…er push.

out/cloud_foundry.go

@@ -5,10 +5,11 @@ import (
 	"os/exec"
 )
 
+//go:generate counterfeiter . PAAS
 type PAAS interface {
 	Login(api string, username string, password string, insecure bool) error
 	Target(organization string, space string) error
-	PushApp(manifest string, path string, currentAppName string) error
+	PushApp(manifest string, path string, currentAppName string, dockerUser string) error
 }
 
 type CloudFoundry struct{}
@@ -35,7 +36,7 @@ func (cf *CloudFoundry) Target(organization string, space string) error {
 	return cf.cf("target", "-o", organization, "-s", space).Run()
 }
 
-func (cf *CloudFoundry) PushApp(manifest string, path string, currentAppName string) error {
+func (cf *CloudFoundry) PushApp(manifest string, path string, currentAppName string, dockerUser string) error {
 	args := []string{}
 
 	if currentAppName == "" {
@@ -44,6 +45,10 @@ func (cf *CloudFoundry) PushApp(manifest string, path string, currentAppName str
 		args = append(args, "zero-downtime-push", currentAppName, "-f", manifest)
 	}
 
+	if dockerUser != "" {
+		args = append(args, "--docker-username", dockerUser)
+	}
+
 	if path != "" {
 		stat, err := os.Stat(path)
 		if err != nil {

out/command.go

@@ -50,6 +50,7 @@ func (command *Command) Run(request Request) (Response, error) {
 		request.Params.ManifestPath,
 		request.Params.Path,
 		request.Params.CurrentAppName,
+		request.Params.DockerUsername,
 	)
 	if err != nil {
 		return Response{}, err

out/command_test.go

@@ -10,20 +10,20 @@ import (
 
 	"github.com/concourse/cf-resource"
 	"github.com/concourse/cf-resource/out"
-	"github.com/concourse/cf-resource/out/fakes"
+	"github.com/concourse/cf-resource/out/outfakes"
 	"io"
 	"io/ioutil"
 )
 
 var _ = Describe("Out Command", func() {
 	var (
-		cloudFoundry *fakes.FakePAAS
+		cloudFoundry *outfakes.FakePAAS
 		request      out.Request
 		command      *out.Command
 	)
 
 	BeforeEach(func() {
-		cloudFoundry = &fakes.FakePAAS{}
+		cloudFoundry = &outfakes.FakePAAS{}
 		command = out.NewCommand(cloudFoundry)
 
 		request = out.Request{
@@ -78,10 +78,11 @@ var _ = Describe("Out Command", func() {
 			By("pushing the app")
 			Expect(cloudFoundry.PushAppCallCount()).To(Equal(1))
 
-			manifest, path, currentAppName := cloudFoundry.PushAppArgsForCall(0)
+			manifest, path, currentAppName, dockerUser := cloudFoundry.PushAppArgsForCall(0)
 			Expect(manifest).To(Equal("assets/manifest.yml"))
 			Expect(path).To(Equal(""))
 			Expect(currentAppName).To(Equal(""))
+			Expect(dockerUser).To(Equal(""))
 		})
 
 		Describe("handling any errors", func() {
@@ -219,10 +220,36 @@ var _ = Describe("Out Command", func() {
 			By("pushing the app")
 			Expect(cloudFoundry.PushAppCallCount()).To(Equal(1))
 
-			_, _, currentAppName := cloudFoundry.PushAppArgsForCall(0)
+			_, _, currentAppName, _ := cloudFoundry.PushAppArgsForCall(0)
 			Expect(currentAppName).To(Equal("cool-app-name"))
 		})
 
+		It("lets people define a user for connecting to a docker registry", func() {
+			request = out.Request{
+				Source: resource.Source{
+					API:          "https://api.run.pivotal.io",
+					Username:     "awesome@example.com",
+					Password:     "hunter2",
+					Organization: "secret",
+					Space:        "volcano-base",
+				},
+				Params: out.Params{
+					ManifestPath:   "a/path/to/a/manifest.yml",
+					CurrentAppName: "cool-app-name",
+					DockerUsername: "DOCKER_USER",
+				},
+			}
+
+			_, err := command.Run(request)
+			Expect(err).NotTo(HaveOccurred())
+
+			By("pushing the app")
+			Expect(cloudFoundry.PushAppCallCount()).To(Equal(1))
+
+			_, _, _, dockerUser := cloudFoundry.PushAppArgsForCall(0)
+			Expect(dockerUser).To(Equal("DOCKER_USER"))
+		})
+
 		Context("using a docker registry which requires authentication", func() {
 
 			var savedVar string

out/integration_test.go

@@ -248,4 +248,38 @@ var _ = Describe("Out", func() {
 			})
 		})
 	})
+
+	Context("when accessing a protected docker registry", func() {
+		BeforeEach(func() {
+			request.Params.DockerUsername = "DOCKER_USERNAME"
+			request.Params.DockerPassword = "DOCKER_PASSWORD"
+		})
+
+		It("pushes an application to cloud foundry", func() {
+			session, err := gexec.Start(
+				cmd,
+				GinkgoWriter,
+				GinkgoWriter,
+			)
+			Expect(err).NotTo(HaveOccurred())
+
+			Eventually(session).Should(gexec.Exit(0))
+
+			var response out.Response
+			err = json.Unmarshal(session.Out.Contents(), &response)
+			Expect(err).NotTo(HaveOccurred())
+
+			Expect(response.Version.Timestamp).To(BeTemporally("~", time.Now(), time.Second))
+
+			// shim outputs arguments
+			Expect(session.Err).To(gbytes.Say("cf api https://api.run.pivotal.io --skip-ssl-validation"))
+			Expect(session.Err).To(gbytes.Say("cf auth awesome@example.com hunter2"))
+			Expect(session.Err).To(gbytes.Say("cf target -o org -s space"))
+			Expect(session.Err).To(gbytes.Say("cf zero-downtime-push awesome-app -f %s --docker-username %s",
+				filepath.Join(tmpDir, "project/manifest.yml"),
+				request.Params.DockerUsername,
+			))
+			Expect(session.Err).To(gbytes.Say("CF_DOCKER_PASSWORD=DOCKER_PASSWORD"))
+		})
+	})
 })

out/models.go

@@ -12,6 +12,7 @@ type Params struct {
 	Path                 string            `json:"path"`
 	CurrentAppName       string            `json:"current_app_name"`
 	EnvironmentVariables map[string]string `json:"environment_variables"`
+	DockerUsername       string            `json:"docker_username"`
 	DockerPassword       string            `json:"docker_password"`
 }