]> git.immae.eu Git - github/fretlink/terraform-provider-statuscake.git/blobdiff - vendor/github.com/fsouza/go-dockerclient/auth.go
Transfer of provider code
[github/fretlink/terraform-provider-statuscake.git] / vendor / github.com / fsouza / go-dockerclient / auth.go
diff --git a/vendor/github.com/fsouza/go-dockerclient/auth.go b/vendor/github.com/fsouza/go-dockerclient/auth.go
new file mode 100644 (file)
index 0000000..95596d7
--- /dev/null
@@ -0,0 +1,158 @@
+// Copyright 2015 go-dockerclient authors. All rights reserved.
+// Use of this source code is governed by a BSD-style
+// license that can be found in the LICENSE file.
+
+package docker
+
+import (
+       "bytes"
+       "encoding/base64"
+       "encoding/json"
+       "errors"
+       "fmt"
+       "io"
+       "io/ioutil"
+       "os"
+       "path"
+       "strings"
+)
+
+// ErrCannotParseDockercfg is the error returned by NewAuthConfigurations when the dockercfg cannot be parsed.
+var ErrCannotParseDockercfg = errors.New("Failed to read authentication from dockercfg")
+
+// AuthConfiguration represents authentication options to use in the PushImage
+// method. It represents the authentication in the Docker index server.
+type AuthConfiguration struct {
+       Username      string `json:"username,omitempty"`
+       Password      string `json:"password,omitempty"`
+       Email         string `json:"email,omitempty"`
+       ServerAddress string `json:"serveraddress,omitempty"`
+}
+
+// AuthConfigurations represents authentication options to use for the
+// PushImage method accommodating the new X-Registry-Config header
+type AuthConfigurations struct {
+       Configs map[string]AuthConfiguration `json:"configs"`
+}
+
+// AuthConfigurations119 is used to serialize a set of AuthConfigurations
+// for Docker API >= 1.19.
+type AuthConfigurations119 map[string]AuthConfiguration
+
+// dockerConfig represents a registry authentation configuration from the
+// .dockercfg file.
+type dockerConfig struct {
+       Auth  string `json:"auth"`
+       Email string `json:"email"`
+}
+
+// NewAuthConfigurationsFromDockerCfg returns AuthConfigurations from the
+// ~/.dockercfg file.
+func NewAuthConfigurationsFromDockerCfg() (*AuthConfigurations, error) {
+       var r io.Reader
+       var err error
+       p := path.Join(os.Getenv("HOME"), ".docker", "config.json")
+       r, err = os.Open(p)
+       if err != nil {
+               p := path.Join(os.Getenv("HOME"), ".dockercfg")
+               r, err = os.Open(p)
+               if err != nil {
+                       return nil, err
+               }
+       }
+       return NewAuthConfigurations(r)
+}
+
+// NewAuthConfigurations returns AuthConfigurations from a JSON encoded string in the
+// same format as the .dockercfg file.
+func NewAuthConfigurations(r io.Reader) (*AuthConfigurations, error) {
+       var auth *AuthConfigurations
+       confs, err := parseDockerConfig(r)
+       if err != nil {
+               return nil, err
+       }
+       auth, err = authConfigs(confs)
+       if err != nil {
+               return nil, err
+       }
+       return auth, nil
+}
+
+func parseDockerConfig(r io.Reader) (map[string]dockerConfig, error) {
+       buf := new(bytes.Buffer)
+       buf.ReadFrom(r)
+       byteData := buf.Bytes()
+
+       confsWrapper := struct {
+               Auths map[string]dockerConfig `json:"auths"`
+       }{}
+       if err := json.Unmarshal(byteData, &confsWrapper); err == nil {
+               if len(confsWrapper.Auths) > 0 {
+                       return confsWrapper.Auths, nil
+               }
+       }
+
+       var confs map[string]dockerConfig
+       if err := json.Unmarshal(byteData, &confs); err != nil {
+               return nil, err
+       }
+       return confs, nil
+}
+
+// authConfigs converts a dockerConfigs map to a AuthConfigurations object.
+func authConfigs(confs map[string]dockerConfig) (*AuthConfigurations, error) {
+       c := &AuthConfigurations{
+               Configs: make(map[string]AuthConfiguration),
+       }
+       for reg, conf := range confs {
+               data, err := base64.StdEncoding.DecodeString(conf.Auth)
+               if err != nil {
+                       return nil, err
+               }
+               userpass := strings.SplitN(string(data), ":", 2)
+               if len(userpass) != 2 {
+                       return nil, ErrCannotParseDockercfg
+               }
+               c.Configs[reg] = AuthConfiguration{
+                       Email:         conf.Email,
+                       Username:      userpass[0],
+                       Password:      userpass[1],
+                       ServerAddress: reg,
+               }
+       }
+       return c, nil
+}
+
+// AuthStatus returns the authentication status for Docker API versions >= 1.23.
+type AuthStatus struct {
+       Status        string `json:"Status,omitempty" yaml:"Status,omitempty"`
+       IdentityToken string `json:"IdentityToken,omitempty" yaml:"IdentityToken,omitempty"`
+}
+
+// AuthCheck validates the given credentials. It returns nil if successful.
+//
+// For Docker API versions >= 1.23, the AuthStatus struct will be populated, otherwise it will be empty.`
+//
+// See https://goo.gl/6nsZkH for more details.
+func (c *Client) AuthCheck(conf *AuthConfiguration) (AuthStatus, error) {
+       var authStatus AuthStatus
+       if conf == nil {
+               return authStatus, fmt.Errorf("conf is nil")
+       }
+       resp, err := c.do("POST", "/auth", doOptions{data: conf})
+       if err != nil {
+               return authStatus, err
+       }
+       defer resp.Body.Close()
+       data, err := ioutil.ReadAll(resp.Body)
+       if err != nil {
+               return authStatus, err
+       }
+       if len(data) == 0 {
+               return authStatus, nil
+       }
+       if err := json.Unmarshal(data, &authStatus); err != nil {
+               return authStatus, err
+       }
+       return authStatus, nil
+}