packer-cn/vendor/github.com/profitbricks/profitbricks-sdk-go/req.go

81 lines
1.9 KiB
Go
Raw Normal View History

2016-06-28 22:35:41 -04:00
package profitbricks
import (
"bytes"
"encoding/json"
"io/ioutil"
"net/http"
"strings"
)
//FullHeader is the standard header to include with all http requests except is_patch and is_command
const FullHeader = "application/vnd.profitbricks.resource+json"
//PatchHeader is used with is_patch .
const PatchHeader = "application/vnd.profitbricks.partial-properties+json"
//CommandHeader is used with is_command
const CommandHeader = "application/x-www-form-urlencoded"
var Depth = "5"
// SetDepth is used to set Depth
func SetDepth(newdepth string) string {
Depth = newdepth
return Depth
}
// mk_url either:
// returns the path (if it`s a full url)
// or
// returns Endpoint+ path .
func mk_url(path string) string {
if strings.HasPrefix(path, "http") {
2016-08-01 07:15:21 -04:00
//REMOVE AFTER TESTING
2016-06-28 22:35:41 -04:00
path := strings.Replace(path, "https://api.profitbricks.com/rest/v2", Endpoint, 1)
2016-08-01 07:15:21 -04:00
// END REMOVE
2016-06-28 22:35:41 -04:00
return path
}
if strings.HasPrefix(path, "<base>") {
2016-08-01 07:15:21 -04:00
//REMOVE AFTER TESTING
2016-06-28 22:35:41 -04:00
path := strings.Replace(path, "<base>", Endpoint, 1)
return path
}
url := Endpoint + path
return url
}
func do(req *http.Request) Resp {
client := &http.Client{}
req.SetBasicAuth(Username, Passwd)
resp, err := client.Do(req)
if err != nil {
panic(err)
}
defer resp.Body.Close()
resp_body, _ := ioutil.ReadAll(resp.Body)
var R Resp
R.Req = resp.Request
R.Body = resp_body
R.Headers = resp.Header
R.StatusCode = resp.StatusCode
return R
}
// is_delete performs an http.NewRequest DELETE and returns a Resp struct
func is_delete(path string) Resp {
url := mk_url(path)
req, _ := http.NewRequest("DELETE", url, nil)
req.Header.Add("Content-Type", FullHeader)
return do(req)
}
// is_command performs an http.NewRequest POST and returns a Resp struct
func is_command(path string, jason string) Resp {
url := mk_url(path)
body := json.RawMessage(jason)
req, _ := http.NewRequest("POST", url, bytes.NewBuffer(body))
req.Header.Add("Content-Type", CommandHeader)
return do(req)
}