Upgrade to 0.12

[github/fretlink/terraform-provider-statuscake.git] / vendor / github.com / hashicorp / terraform / registry / client.go

diff --git a/vendor/github.com/hashicorp/terraform/registry/client.go b/vendor/github.com/hashicorp/terraform/registry/client.go
index a18e6b861e043d996a42c8ccac4e62dc288f5080..93424d1764543afff10fb485bd397e9e307daad3 100644 (file)
--- a/vendor/github.com/hashicorp/terraform/registry/client.go
+++ b/vendor/github.com/hashicorp/terraform/registry/client.go
@@ -20,10 +20,11 @@ import (
 )
 
 const (
-       xTerraformGet     = "X-Terraform-Get"
-       xTerraformVersion = "X-Terraform-Version"
-       requestTimeout    = 10 * time.Second
-       serviceID         = "modules.v1"
+       xTerraformGet      = "X-Terraform-Get"
+       xTerraformVersion  = "X-Terraform-Version"
+       requestTimeout     = 10 * time.Second
+       modulesServiceID   = "modules.v1"
+       providersServiceID = "providers.v1"
 )
 
 var tfVersion = version.String()
@@ -58,10 +59,10 @@ func NewClient(services *disco.Disco, client *http.Client) *Client {
 }
 
 // Discover queries the host, and returns the url for the registry.
-func (c *Client) Discover(host svchost.Hostname) (*url.URL, error) {
+func (c *Client) Discover(host svchost.Hostname, serviceID string) (*url.URL, error) {
        service, err := c.services.DiscoverServiceURL(host, serviceID)
        if err != nil {
-               return nil, err
+               return nil, &ServiceUnreachableError{err}
        }
        if !strings.HasSuffix(service.Path, "/") {
                service.Path += "/"
@@ -69,14 +70,14 @@ func (c *Client) Discover(host svchost.Hostname) (*url.URL, error) {
        return service, nil
 }
 
-// Versions queries the registry for a module, and returns the available versions.
-func (c *Client) Versions(module *regsrc.Module) (*response.ModuleVersions, error) {
+// ModuleVersions queries the registry for a module, and returns the available versions.
+func (c *Client) ModuleVersions(module *regsrc.Module) (*response.ModuleVersions, error) {
        host, err := module.SvcHost()
        if err != nil {
                return nil, err
        }
 
-       service, err := c.Discover(host)
+       service, err := c.Discover(host, modulesServiceID)
        if err != nil {
                return nil, err
        }
@@ -141,15 +142,15 @@ func (c *Client) addRequestCreds(host svchost.Hostname, req *http.Request) {
        }
 }
 
-// Location find the download location for a specific version module.
+// ModuleLocation find the download location for a specific version module.
 // This returns a string, because the final location may contain special go-getter syntax.
-func (c *Client) Location(module *regsrc.Module, version string) (string, error) {
+func (c *Client) ModuleLocation(module *regsrc.Module, version string) (string, error) {
        host, err := module.SvcHost()
        if err != nil {
                return "", err
        }
 
-       service, err := c.Discover(host)
+       service, err := c.Discover(host, modulesServiceID)
        if err != nil {
                return "", err
        }
@@ -225,3 +226,118 @@ func (c *Client) Location(module *regsrc.Module, version string) (string, error)
 
        return location, nil
 }
+
+// TerraformProviderVersions queries the registry for a provider, and returns the available versions.
+func (c *Client) TerraformProviderVersions(provider *regsrc.TerraformProvider) (*response.TerraformProviderVersions, error) {
+       host, err := provider.SvcHost()
+       if err != nil {
+               return nil, err
+       }
+
+       service, err := c.Discover(host, providersServiceID)
+       if err != nil {
+               return nil, err
+       }
+
+       p, err := url.Parse(path.Join(provider.TerraformProvider(), "versions"))
+       if err != nil {
+               return nil, err
+       }
+
+       service = service.ResolveReference(p)
+
+       log.Printf("[DEBUG] fetching provider versions from %q", service)
+
+       req, err := http.NewRequest("GET", service.String(), nil)
+       if err != nil {
+               return nil, err
+       }
+
+       c.addRequestCreds(host, req)
+       req.Header.Set(xTerraformVersion, tfVersion)
+
+       resp, err := c.client.Do(req)
+       if err != nil {
+               return nil, err
+       }
+       defer resp.Body.Close()
+
+       switch resp.StatusCode {
+       case http.StatusOK:
+               // OK
+       case http.StatusNotFound:
+               return nil, &errProviderNotFound{addr: provider}
+       default:
+               return nil, fmt.Errorf("error looking up provider versions: %s", resp.Status)
+       }
+
+       var versions response.TerraformProviderVersions
+
+       dec := json.NewDecoder(resp.Body)
+       if err := dec.Decode(&versions); err != nil {
+               return nil, err
+       }
+
+       return &versions, nil
+}
+
+// TerraformProviderLocation queries the registry for a provider download metadata
+func (c *Client) TerraformProviderLocation(provider *regsrc.TerraformProvider, version string) (*response.TerraformProviderPlatformLocation, error) {
+       host, err := provider.SvcHost()
+       if err != nil {
+               return nil, err
+       }
+
+       service, err := c.Discover(host, providersServiceID)
+       if err != nil {
+               return nil, err
+       }
+
+       p, err := url.Parse(path.Join(
+               provider.TerraformProvider(),
+               version,
+               "download",
+               provider.OS,
+               provider.Arch,
+       ))
+       if err != nil {
+               return nil, err
+       }
+
+       service = service.ResolveReference(p)
+
+       log.Printf("[DEBUG] fetching provider location from %q", service)
+
+       req, err := http.NewRequest("GET", service.String(), nil)
+       if err != nil {
+               return nil, err
+       }
+
+       c.addRequestCreds(host, req)
+       req.Header.Set(xTerraformVersion, tfVersion)
+
+       resp, err := c.client.Do(req)
+       if err != nil {
+               return nil, err
+       }
+       defer resp.Body.Close()
+
+       var loc response.TerraformProviderPlatformLocation
+
+       dec := json.NewDecoder(resp.Body)
+       if err := dec.Decode(&loc); err != nil {
+               return nil, err
+       }
+
+       switch resp.StatusCode {
+       case http.StatusOK, http.StatusNoContent:
+               // OK
+       case http.StatusNotFound:
+               return nil, fmt.Errorf("provider %q version %q not found", provider.TerraformProvider(), version)
+       default:
+               // anything else is an error:
+               return nil, fmt.Errorf("error getting download location for %q: %s", provider.TerraformProvider(), resp.Status)
+       }
+
+       return &loc, nil
+}