From 1055007cbac737b0c15da32a6da81e0e54537d22 Mon Sep 17 00:00:00 2001 From: PacoDw <__pm@outlook.com> Date: Mon, 17 Aug 2020 10:02:00 -0500 Subject: [PATCH] :chore: added OSC API Client Connection --- builder/osc/common/access_config.go | 47 +++++++++++++++++++++++++++++ 1 file changed, 47 insertions(+) diff --git a/builder/osc/common/access_config.go b/builder/osc/common/access_config.go index c5bfabddf..764657f9c 100644 --- a/builder/osc/common/access_config.go +++ b/builder/osc/common/access_config.go @@ -9,6 +9,7 @@ import ( "github.com/hashicorp/packer/template/interpolate" "github.com/outscale/osc-go/oapi" + "github.com/outscale/osc-sdk-go/osc" ) // AccessConfig is for common configuration related to Outscale API access @@ -24,6 +25,7 @@ type AccessConfig struct { SkipMetadataApiCheck bool `mapstructure:"skip_metadata_api_check"` Token string `mapstructure:"token"` clientConfig *oapi.Config + API string `mapstructure:"api"` getOAPIConnection func() oapi.OAPIClient } @@ -66,7 +68,44 @@ func (c *AccessConfig) Config() (*oapi.Config, error) { } return config, nil +} +// NewOSCClient retrieves the Outscale OSC-SDK client +func (c *AccessConfig) NewOSCClient() *osc.APIClient { + if c.AccessKey == "" { + c.AccessKey = os.Getenv("OUTSCALE_ACCESSKEYID") + } + + if c.SecretKey == "" { + c.SecretKey = os.Getenv("OUTSCALE_SECRETKEYID") + } + + if c.RawRegion == "" { + c.RawRegion = os.Getenv("OUTSCALE_REGION") + } + + if c.CustomEndpointOAPI == "" { + c.CustomEndpointOAPI = os.Getenv("OUTSCALE_OAPI_URL") + } + + if c.CustomEndpointOAPI == "" { + c.CustomEndpointOAPI = "outscale.com/oapi/latest" + } + + skipClient := &http.Client{ + Transport: &http.Transport{ + TLSClientConfig: &tls.Config{InsecureSkipVerify: true}, + }, + } + + skipClient.Transport = NewTransport(c.AccessKey, c.SecretKey, c.RawRegion, skipClient.Transport) + + return osc.NewAPIClient(&osc.Configuration{ + BasePath: fmt.Sprintf("https://api.%s.%s", c.RawRegion, c.CustomEndpointOAPI), + DefaultHeader: make(map[string]string), + UserAgent: "packer-osc", + HTTPClient: skipClient, + }) } func (c *AccessConfig) NewOAPIConnection() (oapi.OAPIClient, error) { @@ -102,5 +141,13 @@ func (c *AccessConfig) Prepare(ctx *interpolate.Context) []error { fmt.Errorf("`access_key` and `secret_key` must both be either set or not set.")) } + if c.API != "" { + if c.API != "osc" && c.API != "oapi" { + c.API = "oapi" + } + } else { + c.API = "oapi" + } + return errs }