/
publish_docker.go
65 lines (55 loc) · 1.77 KB
/
publish_docker.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
package launchpad
import (
"encoding/base64"
"encoding/json"
"os"
"path/filepath"
"github.com/docker/cli/cli/config"
"github.com/docker/cli/cli/config/configfile"
"github.com/docker/docker/api/types"
"github.com/docker/docker/pkg/homedir"
"github.com/pkg/errors"
"go.jetpack.io/launchpad/goutil/errorutil"
)
// Gets the base64 encoded RegistryAuth parameter that dockerclient.ImagePush
// will use. Uses the docker credential store on the user's laptop to find
// the credentials. It requires the docker credential store to have been
// configured already.
//
// inspired by:
// https://github.com/GoogleContainerTools/skaffold/blob/main/pkg/skaffold/docker/auth.go
func credentialsFromDockerCredentialStore(registryHostname string) (string, error) {
cf, err := loadDockerConfig()
if err != nil {
return "", errors.Wrap(err, "error loading docker config")
}
auth, err := cf.GetAuthConfig(registryHostname)
if err != nil {
return "", errorutil.CombinedError(
errors.Wrapf(err, "error getting auth config for registry: %s", registryHostname),
errUserNoGCPCredentials,
)
}
ac := types.AuthConfig(auth)
jsonAuthConfig, err := json.Marshal(ac)
if err != nil {
return "", errors.Wrap(err, "failed to json marshal")
}
return base64.URLEncoding.EncodeToString(jsonAuthConfig), nil
}
// Gets the Docker ConfigFile
//
// inspired by:
// https://github.com/GoogleContainerTools/skaffold/blob/main/pkg/skaffold/docker/auth.go
func loadDockerConfig() (*configfile.ConfigFile, error) {
configDir := os.Getenv("DOCKER_CONFIG")
const configFileDir = ".docker"
if configDir == "" {
configDir = filepath.Join(homedir.Get(), configFileDir)
}
cf, err := config.Load(configDir)
if err != nil {
return nil, errors.Wrapf(err, "failed loading docker config")
}
return cf, nil
}