forked from openshift/origin
/
builder.go
74 lines (65 loc) · 2.29 KB
/
builder.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
package cmd
import (
"log"
"os"
"github.com/fsouza/go-dockerclient"
"github.com/openshift/origin/pkg/api/latest"
"github.com/openshift/origin/pkg/build/api"
bld "github.com/openshift/origin/pkg/build/builder"
"github.com/openshift/origin/pkg/build/builder/cmd/dockercfg"
dockerutil "github.com/openshift/origin/pkg/cmd/util/docker"
image "github.com/openshift/origin/pkg/image/api"
)
const DefaultDockerEndpoint = "unix:///var/run/docker.sock"
const DockerCfgFile = ".dockercfg"
type builder interface {
Build() error
}
type factoryFunc func(
client bld.DockerClient,
dockerSocket string,
authConfig docker.AuthConfiguration,
authPresent bool,
build *api.Build) builder
func run(builderFactory factoryFunc) {
client, endpoint, err := dockerutil.NewHelper().GetClient()
if err != nil {
log.Fatalf("Error obtaining docker client: %v", err)
}
buildStr := os.Getenv("BUILD")
build := api.Build{}
if err := latest.Codec.DecodeInto([]byte(buildStr), &build); err != nil {
log.Fatalf("Unable to parse build: %v", err)
}
var (
authcfg docker.AuthConfiguration
authPresent bool
)
if len(build.Parameters.Output.DockerImageReference) == 0 {
if build.Parameters.Output.To != nil {
log.Fatalf("Cannot determine an output image reference. Make sure a registry service is running.")
}
log.Fatal("Build output has an empty Docker image reference.")
}
registry, _, _, _, err := image.SplitDockerPullSpec(build.Parameters.Output.DockerImageReference)
if err != nil {
log.Fatalf("Build output does not have a valid Docker image reference: %v", err)
}
authcfg, authPresent = dockercfg.NewHelper().GetDockerAuth(registry)
b := builderFactory(client, endpoint, authcfg, authPresent, &build)
if err = b.Build(); err != nil {
log.Fatalf("Build error: %v", err)
}
}
// RunDockerBuild creates a docker builder and runs its build
func RunDockerBuild() {
run(func(client bld.DockerClient, sock string, auth docker.AuthConfiguration, present bool, build *api.Build) builder {
return bld.NewDockerBuilder(client, auth, present, build)
})
}
// RunSTIBuild creates a STI builder and runs its build
func RunSTIBuild() {
run(func(client bld.DockerClient, sock string, auth docker.AuthConfiguration, present bool, build *api.Build) builder {
return bld.NewSTIBuilder(client, sock, auth, present, build)
})
}