-
Notifications
You must be signed in to change notification settings - Fork 61
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Closes: #6 Signed-off-by: Alex Ellis (OpenFaaS Ltd) <alexellis2@gmail.com>
- Loading branch information
Showing
3 changed files
with
174 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,151 @@ | ||
| package pkg | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
| "io/ioutil" | ||
| "log" | ||
| "net/http" | ||
| "net/url" | ||
|
|
||
| "strings" | ||
| "time" | ||
|
|
||
| "github.com/inlets/inlets-operator/pkg/provision" | ||
| ) | ||
|
|
||
| // CivoProvisioner creates instances on civo.com | ||
| type CivoProvisioner struct { | ||
| APIKey string | ||
| } | ||
|
|
||
| // NewCivoProvisioner with an accessKey | ||
| func NewCivoProvisioner(accessKey string) (*CivoProvisioner, error) { | ||
|
|
||
| return &CivoProvisioner{ | ||
| APIKey: accessKey, | ||
| }, nil | ||
| } | ||
|
|
||
| func (p *CivoProvisioner) Status(id string) (*provision.ProvisionedHost, error) { | ||
| host := &provision.ProvisionedHost{} | ||
|
|
||
| apiURL := fmt.Sprint("https://api.civo.com/v2/instances/", id) | ||
|
|
||
| req, err := http.NewRequest(http.MethodGet, apiURL, nil) | ||
| if err != nil { | ||
| return host, err | ||
| } | ||
| addAuth(req, p.APIKey) | ||
|
|
||
| req.Header.Add("Accept", "application/json") | ||
| instance := CreatedInstance{} | ||
|
|
||
| res, err := http.DefaultClient.Do(req) | ||
| if err != nil { | ||
| return host, err | ||
| } | ||
|
|
||
| var body []byte | ||
| if res.Body != nil { | ||
| defer res.Body.Close() | ||
| body, _ = ioutil.ReadAll(res.Body) | ||
| } | ||
|
|
||
| if res.StatusCode != http.StatusOK { | ||
| return host, fmt.Errorf("unexpected HTTP code: %d\n%q", res.StatusCode, string(body)) | ||
| } | ||
|
|
||
| unmarshalErr := json.Unmarshal(body, &instance) | ||
| if unmarshalErr != nil { | ||
| return host, unmarshalErr | ||
| } | ||
|
|
||
| return &provision.ProvisionedHost{ | ||
| ID: instance.ID, | ||
| IP: instance.PublicIP, | ||
| Status: strings.ToLower(instance.Status), | ||
| }, nil | ||
| } | ||
|
|
||
| func (p *CivoProvisioner) Delete(id string) error { | ||
| return nil | ||
| } | ||
|
|
||
| func (p *CivoProvisioner) Provision(host provision.BasicHost) (*provision.ProvisionedHost, error) { | ||
|
|
||
| log.Printf("Provisioning host with Civo\n") | ||
|
|
||
| if host.Region == "" { | ||
| host.Region = "lon1" | ||
| } | ||
|
|
||
| res, err := provisionCivoInstance(host, p.APIKey) | ||
|
|
||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return &provision.ProvisionedHost{ | ||
| ID: res.ID, | ||
| }, nil | ||
| } | ||
|
|
||
| func provisionCivoInstance(host provision.BasicHost, key string) (CreatedInstance, error) { | ||
| instance := CreatedInstance{} | ||
|
|
||
| apiURL := "https://api.civo.com/v2/instances" | ||
|
|
||
| values := url.Values{} | ||
| values.Add("hostname", host.Name) | ||
| values.Add("size", host.Plan) | ||
| values.Add("public_ip", "true") | ||
| values.Add("template_id", host.OS) | ||
| values.Add("initial_user", "civo") | ||
| values.Add("script", host.UserData) | ||
| values.Add("script", "inlets") | ||
|
|
||
| req, err := http.NewRequest(http.MethodPost, apiURL, strings.NewReader(values.Encode())) | ||
| if err != nil { | ||
| return instance, err | ||
| } | ||
| addAuth(req, key) | ||
|
|
||
| req.Header.Add("Accept", "application/json") | ||
| req.Header.Add("Content-Type", "application/x-www-form-urlencoded") | ||
|
|
||
| res, err := http.DefaultClient.Do(req) | ||
| if err != nil { | ||
| return instance, err | ||
| } | ||
|
|
||
| var body []byte | ||
| if res.Body != nil { | ||
| defer res.Body.Close() | ||
| body, _ = ioutil.ReadAll(res.Body) | ||
| } | ||
|
|
||
| if res.StatusCode != http.StatusOK { | ||
| return instance, fmt.Errorf("unexpected HTTP code: %d\n%q", res.StatusCode, string(body)) | ||
| } | ||
|
|
||
| unmarshalErr := json.Unmarshal(body, &instance) | ||
| if unmarshalErr != nil { | ||
| return instance, unmarshalErr | ||
| } | ||
|
|
||
| fmt.Printf("Instance ID: %s\n", instance.ID) | ||
| return instance, nil | ||
| } | ||
|
|
||
| type CreatedInstance struct { | ||
| ID string `json:"id"` | ||
| CreatedAt time.Time `json:"created_at"` | ||
| PublicIP string `json:"public_ip"` | ||
| Status string `json:"status"` | ||
| } | ||
|
|
||
| func addAuth(r *http.Request, APIKey string) { | ||
| r.Header.Add("Authorization", fmt.Sprintf("bearer %s", APIKey)) | ||
| r.Header.Add("User-Agent", "inlets") | ||
| } |