witai.go

// Copyright (c) Facebook, Inc. and its affiliates. All Rights Reserved.

package witai

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

const (
	DefaultVersion = "20240304"
	WitTimeFormat  = "2006-01-02T15:04:05Z0700"
)

// Client - Wit.ai client type
type Client struct {
	APIBase      string
	Token        string
	Version      string
	headerAuth   string
	headerAccept string
	httpClient   *http.Client
}

type errorResp struct {
	Body  string `json:"body"`
	Error string `json:"error"`
}

// NewClient returns client for default API version
func NewClient(token string) *Client {
	return newClientWithVersion(token, DefaultVersion)
}

// SetHTTPClient allows to use your custom http.Client
func (c *Client) SetHTTPClient(httpClient *http.Client) {
	c.httpClient = httpClient
}

func newClientWithVersion(token, version string) *Client {
	headerAuth := fmt.Sprintf("Bearer %s", token)
	headerAccept := fmt.Sprintf("application/vnd.wit.%s+json", version)

	defaultClient := &http.Client{
		Timeout: time.Second * 10,
	}

	return &Client{
		APIBase:      "https://api.wit.ai",
		Token:        token,
		Version:      version,
		headerAuth:   headerAuth,
		headerAccept: headerAccept,
		httpClient:   defaultClient,
	}
}

func (c *Client) request(method, url string, ct string, body io.Reader) (io.ReadCloser, error) {
	req, err := http.NewRequest(method, c.APIBase+url, body)
	if err != nil {
		return nil, err
	}

	req.Header.Set("Authorization", c.headerAuth)
	req.Header.Set("Accept", c.headerAccept)
	req.Header.Set("Content-Type", ct)

	resp, err := c.httpClient.Do(req)
	if err != nil {
		return nil, err
	}

	if resp.StatusCode >= http.StatusBadRequest {
		defer resp.Body.Close()

		var e *errorResp
		decoder := json.NewDecoder(resp.Body)
		err = decoder.Decode(&e)
		if err != nil {
			return nil, fmt.Errorf("unable to decode error message: %s", err.Error())
		}

		// Wit.ai errors sometimes have "error", sometimes "body" message
		if len(e.Error) > 0 {
			return nil, fmt.Errorf("unable to make a request. error: %s", e.Error)
		}

		if len(e.Body) > 0 {
			return nil, fmt.Errorf("unable to make a request. error: %s", e.Body)
		}

		return nil, fmt.Errorf("unable to make a request. error: %v", e)
	}

	return resp.Body, nil
}