1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73
|
package cmsapi
import (
"bytes"
"context"
"encoding/json"
"fmt"
"io"
"net/http"
"net/url"
"github.com/la5nta/pat/internal/buildinfo"
)
type responseStatus struct {
ErrorCode string
Message string
}
func (r responseStatus) errorOrNil() error {
if (r == responseStatus{}) {
return nil
}
return &r
}
func (r *responseStatus) Error() string { return r.Message }
func getJSON(ctx context.Context, path string, queryParams url.Values, v interface{}) error {
req := newJSONRequest("GET", path, queryParams, nil).WithContext(ctx)
return doJSON(req, v)
}
func doJSON(req *http.Request, v interface{}) error {
resp, err := http.DefaultClient.Do(req)
if err != nil {
return err
}
defer resp.Body.Close()
if resp.StatusCode/100 != 2 {
return fmt.Errorf("unexpected status code: %d (%s)", resp.StatusCode, resp.Status)
}
return json.NewDecoder(resp.Body).Decode(v)
}
func bodyJSON(v interface{}) io.Reader {
b, err := json.Marshal(v)
if err != nil {
panic(err)
}
return bytes.NewReader(b)
}
func newJSONRequest(method string, path string, queryParams url.Values, body io.Reader) *http.Request {
url, err := url.JoinPath(RootURL, path)
if err != nil {
panic(err)
}
url += "?key=" + AccessKey
if len(queryParams) > 0 {
url += "&" + queryParams.Encode()
}
req, err := http.NewRequest(method, url, body)
if err != nil {
panic(err)
}
req.Header.Set("User-Agent", buildinfo.UserAgent())
req.Header.Set("Accept", "application/json")
if body != nil {
req.Header.Set("Content-Type", "application/json")
}
return req
}
|