gitote.go 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. package gitote
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "io"
  6. "io/ioutil"
  7. "net/http"
  8. "strings"
  9. )
  10. func Version() string {
  11. return "0.0.1"
  12. }
  13. // Client represents a Gitote API client.
  14. type Client struct {
  15. url string
  16. accessToken string
  17. client *http.Client
  18. }
  19. // NewClient initializes and returns a API client.
  20. func NewClient(url, token string) *Client {
  21. return &Client{
  22. url: strings.TrimSuffix(url, "/"),
  23. accessToken: token,
  24. client: &http.Client{},
  25. }
  26. }
  27. // SetHTTPClient replaces default http.Client with user given one.
  28. func (c *Client) SetHTTPClient(client *http.Client) {
  29. c.client = client
  30. }
  31. func (c *Client) doRequest(method, path string, header http.Header, body io.Reader) (*http.Response, error) {
  32. req, err := http.NewRequest(method, c.url+"/api/v1"+path, body)
  33. if err != nil {
  34. return nil, err
  35. }
  36. req.Header.Set("Authorization", "token "+c.accessToken)
  37. for k, v := range header {
  38. req.Header[k] = v
  39. }
  40. return c.client.Do(req)
  41. }
  42. func (c *Client) getResponse(method, path string, header http.Header, body io.Reader) ([]byte, error) {
  43. resp, err := c.doRequest(method, path, header, body)
  44. if err != nil {
  45. return nil, err
  46. }
  47. defer resp.Body.Close()
  48. data, err := ioutil.ReadAll(resp.Body)
  49. if err != nil {
  50. return nil, err
  51. }
  52. switch resp.StatusCode {
  53. case 403:
  54. return nil, errors.New("403 Forbidden")
  55. case 404:
  56. return nil, errors.New("404 Not Found")
  57. }
  58. if resp.StatusCode/100 != 2 {
  59. errMap := make(map[string]interface{})
  60. if err = json.Unmarshal(data, &errMap); err != nil {
  61. return nil, err
  62. }
  63. return nil, errors.New(errMap["message"].(string))
  64. }
  65. return data, nil
  66. }
  67. func (c *Client) getParsedResponse(method, path string, header http.Header, body io.Reader, obj interface{}) error {
  68. data, err := c.getResponse(method, path, header, body)
  69. if err != nil {
  70. return err
  71. }
  72. return json.Unmarshal(data, obj)
  73. }