methods.go

package nfeio

import (
	"encoding/json"
	"errors"
	"io/ioutil"
	"net/http"
	"strings"
)

const (
	ServiceUrl = "https://api.nfe.io/v1/"
	ProductUrl = "https://api.nfse.io/v2/"
	AddressUrl = "https://address.api.nfe.io/v2/"
)

// Map data por post in the request
type Params map[string]interface{}

// Map extra request headers
type Headers map[string]string

// Make request and return the response
func (c *Client) execute(method string, path string, params interface{}, headers Headers, model interface{}) error {

	// init vars
	var url = c.GetEndpoint(path) + path

	// init an empty payload
	payload := strings.NewReader("")

	// check for params
	if params != nil {

		// marshal params
		b, err := json.Marshal(params)
		if err != nil {
			return err
		}

		// set payload with params
		payload = strings.NewReader(string(b))

	}

	// set request
	request, _ := http.NewRequest(method, url, payload)
	request.Header.Add("Authorization", c.GetAuthorization(path))
	request.Header.Add("accept", "application/json")
	request.Header.Add("content-type", "application/json")

	// add extra headers
	if headers != nil {
		for key, value := range headers {
			request.Header.Add(key, value)
		}
	}

	response, err := http.DefaultClient.Do(request)
	if err != nil {
		return err
	}

	defer response.Body.Close()

	// read response
	data, err := ioutil.ReadAll(response.Body)
	if err != nil {
		return err
	}

	// init error response
	erm := &ErrMessage{}

	// check for error message
	if err = json.Unmarshal(data, erm); err == nil && erm.Message != "" {
		return erm
	}

	// init array of errors
	errs := &ErrArray{}

	// check for multiple errors
	if err = json.Unmarshal(data, errs); err == nil && errs.Count() > 0 {
		return errs
	}

	// verify status code
	if NotIn(response.StatusCode, http.StatusOK, http.StatusCreated, http.StatusAccepted, http.StatusNoContent, http.StatusContinue) {

		if len(data) > 0 {
			return errors.New(string(data))
		}

		return errors.New(response.Status)

	}

	// some services have empty response
	if len(data) == 0 {
		return nil
	}

	// pdf
	if len(data) > 3 && string(data)[1:4] == "PDF" {
		*model.(*[]byte) = data
		return nil
	}

	// xml
	if len(data) > 5 && string(data)[:6] == "<Nfse>" {
		*model.(*string) = string(data)
		return nil
	}

	// parse data
	return json.Unmarshal(data, model)

}

// Execute GET requests
func (c *Client) Get(path string, params interface{}, headers Headers, model interface{}) error {
	return c.execute("GET", path, params, headers, model)
}

// Execute POST requests
func (c *Client) Post(path string, params interface{}, headers Headers, model interface{}) error {
	return c.execute("POST", path, params, headers, model)
}

// Execute PUT requests
func (c *Client) Put(path string, params interface{}, headers Headers, model interface{}) error {
	return c.execute("PUT", path, params, headers, model)
}

// Execute DELETE requests
func (c *Client) Delete(path string, params interface{}, headers Headers, model interface{}) error {
	return c.execute("DELETE", path, params, headers, model)
}