client.go

package sypht

import (
	"fmt"
	"net/http"
	"os"
	"strings"
	"sync"
	"time"
)

/*
Client to the HTTP API of Sypht.
*/

// Client ...
type Client struct {
	httpClient     *http.Client
	config         *config
	apiToken       string
	tokenUpdatedAt time.Time
	mutex          sync.RWMutex
}

type config struct {
	clientID     string
	clientSecret string
	apiBaseURL   string
	authURL      string
}

var defaultTimeout = 30

// fieldSets const
const (
	Generic  = "\"sypht.generic\""
	Document = "\"sypht.document\""
	Invoice  = "\"sypht.invoice\""
	Bill     = "\"sypht.bill\""
	Bank     = "\"sypht.bank\""
)

//NewSyphtClient returns a Sypht client instance,
// default request timeout is set to 30 seconds, change it as needed
func NewSyphtClient(apiKey string, timeout *int) (client *Client, err error) {
	authURL := os.Getenv("SYPHT_AUTH_ENDPOINT")
	if authURL == "" {
		authURL = "https://login.sypht.com/oauth/token"
	}
	if timeout == nil || *timeout < 0 {
		timeout = &defaultTimeout
	}
	clientID, clientSecret, err := processAPIKey(apiKey)
	if err != nil {
		return
	}

	client = &Client{
		httpClient: &http.Client{
			CheckRedirect: func(req *http.Request, via []*http.Request) error {
				return http.ErrUseLastResponse
			},
			Timeout: time.Second * time.Duration(*timeout),
		},
		config: &config{
			clientID:     clientID,
			clientSecret: clientSecret,
			apiBaseURL:   "https://api.sypht.com",
			authURL:      authURL,
		},
	}
	_, err = client.RefreshToken()
	return
}

//NewSyphtClientFromEnv same as NewSyphtClient except it reads creds from ENV
func NewSyphtClientFromEnv(timeout *int) (client *Client, err error) {
	client, err = NewSyphtClient(os.Getenv("SYPHT_API_KEY"), timeout)
	return
}

func processAPIKey(apiKey string) (clientID string, clientSecret string, err error) {
	arr := strings.Split(apiKey, ":")
	if len(arr) != 2 {
		err = fmt.Errorf("invalid apikey %s", apiKey)
		return
	}
	clientID = arr[0]
	clientSecret = arr[1]
	return
}