mirror of
https://github.com/opentofu/opentofu.git
synced 2025-02-20 11:48:24 -06:00
10cda98245
Also doesnt use decode/encode anymore since those methods are more intended for streams. So this goes to the more standed marshal/unmarshal of data. This also adds better error support and will try to give the user better errors from the api if it can. Or any issues with the bitbucket service.
109 lines
2.5 KiB
Go
109 lines
2.5 KiB
Go
package bitbucket
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"io/ioutil"
|
|
"log"
|
|
"net/http"
|
|
)
|
|
|
|
// Error represents a error from the bitbucket api.
|
|
type Error struct {
|
|
APIError struct {
|
|
Message string `json:"message,omitempty"`
|
|
} `json:"error,omitempty"`
|
|
Type string `json:"type,omitempty"`
|
|
StatusCode int
|
|
Endpoint string
|
|
}
|
|
|
|
func (e Error) Error() string {
|
|
return fmt.Sprintf("API Error: %d %s %s", e.StatusCode, e.Endpoint, e.APIError.Message)
|
|
}
|
|
|
|
const (
|
|
// BitbucketEndpoint is the fqdn used to talk to bitbucket
|
|
BitbucketEndpoint string = "https://api.bitbucket.org/"
|
|
)
|
|
|
|
type BitbucketClient struct {
|
|
Username string
|
|
Password string
|
|
HTTPClient *http.Client
|
|
}
|
|
|
|
func (c *BitbucketClient) Do(method, endpoint string, payload *bytes.Buffer) (*http.Response, error) {
|
|
|
|
absoluteendpoint := BitbucketEndpoint + endpoint
|
|
log.Printf("[DEBUG] Sending request to %s %s", method, absoluteendpoint)
|
|
|
|
var bodyreader io.Reader
|
|
|
|
if payload != nil {
|
|
log.Printf("[DEBUG] With payload %s", payload.String())
|
|
bodyreader = payload
|
|
}
|
|
|
|
req, err := http.NewRequest(method, absoluteendpoint, bodyreader)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
req.SetBasicAuth(c.Username, c.Password)
|
|
|
|
if payload != nil {
|
|
// Can cause bad request when putting default reviews if set.
|
|
req.Header.Add("Content-Type", "application/json")
|
|
}
|
|
|
|
req.Close = true
|
|
|
|
resp, err := c.HTTPClient.Do(req)
|
|
log.Printf("[DEBUG] Resp: %v Err: %v", resp, err)
|
|
if resp.StatusCode >= 400 || resp.StatusCode < 200 {
|
|
apiError := Error{
|
|
StatusCode: resp.StatusCode,
|
|
Endpoint: endpoint,
|
|
}
|
|
|
|
body, err := ioutil.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
log.Printf("[DEBUG] Resp Body: %s", string(body))
|
|
|
|
err = json.Unmarshal(body, &apiError)
|
|
if err != nil {
|
|
apiError.APIError.Message = string(body)
|
|
}
|
|
|
|
return resp, error(apiError)
|
|
|
|
}
|
|
return resp, err
|
|
}
|
|
|
|
func (c *BitbucketClient) Get(endpoint string) (*http.Response, error) {
|
|
return c.Do("GET", endpoint, nil)
|
|
}
|
|
|
|
func (c *BitbucketClient) Post(endpoint string, jsonpayload *bytes.Buffer) (*http.Response, error) {
|
|
return c.Do("POST", endpoint, jsonpayload)
|
|
}
|
|
|
|
func (c *BitbucketClient) Put(endpoint string, jsonpayload *bytes.Buffer) (*http.Response, error) {
|
|
return c.Do("PUT", endpoint, jsonpayload)
|
|
}
|
|
|
|
func (c *BitbucketClient) PutOnly(endpoint string) (*http.Response, error) {
|
|
return c.Do("PUT", endpoint, nil)
|
|
}
|
|
|
|
func (c *BitbucketClient) Delete(endpoint string) (*http.Response, error) {
|
|
return c.Do("DELETE", endpoint, nil)
|
|
}
|