request.go

package onedrive

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"time"
)

const (
	statusTooManyRequests     int = 429
	statusInsufficientStorage int = 507
	statusNoContent           int = 204
)

func createRequestBody(body interface{}) (io.ReadWriter, error) {
	var buf io.ReadWriter
	if body != nil {
		buf = new(bytes.Buffer)
		err := json.NewEncoder(buf).Encode(body)
		if err != nil {
			return nil, err
		}
	}
	return buf, nil
}

func calculateThrottle(currentTime time.Time, retryAfter string) (time.Time, error) {
	duration, err := time.ParseDuration(retryAfter + "s")
	if err != nil {
		return time.Time{}, err
	}
	return currentTime.Add(duration), nil
}

func (od *OneDrive) newRequest(method, uri string, requestHeaders map[string]string, body interface{}) (*http.Request, error) {
	if !time.Now().After(od.throttle) {
		return nil, fmt.Errorf("you are making too many requests. Please wait: %s", od.throttle.Sub(time.Now()))
	}

	requestBody, err := createRequestBody(body)
	if err != nil {
		return nil, err
	}

	req, err := http.NewRequest(method, od.BaseURL+uri, requestBody)
	if err != nil {
		return nil, err
	}

	acceptHeader := "application/json"
	if od.Debug {
		acceptHeader += ";format=pretty"
	}

	req.Header.Add("Accept", acceptHeader)
	req.Header.Add("Content-Type", "application/json")

	if requestHeaders != nil {
		for header, value := range requestHeaders {
			req.Header.Set(header, value)
		}
	}

	return req, nil
}

func (od *OneDrive) do(req *http.Request, decodeInto interface{}) (*http.Response, error) {
	resp, err := od.Client.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	if resp.StatusCode >= http.StatusBadRequest && resp.StatusCode <= statusInsufficientStorage {
		if resp.StatusCode == statusTooManyRequests {
			retryAfter, err := calculateThrottle(time.Now(), resp.Header.Get("Retry-After"))
			if err != nil {
				return resp, err
			}
			od.throttleRequest(retryAfter)
		}
		var errResponse struct {
			Error Error `json:"error"`
		}
		if err := json.NewDecoder(resp.Body).Decode(&errResponse); err != nil {
			return resp, err
		}
		return resp, &errResponse.Error
	}

	if decodeInto != nil {
		if err := json.NewDecoder(resp.Body).Decode(decodeInto); err != nil {
			return resp, err
		}
	}

	return resp, err
}