http.go

// Copyright 2017-2026 Allow2 Pty Ltd. All rights reserved.
// Use of this source code is governed by the Allow2 API and SDK Licence.

package allow2service

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

// HttpResponse is a simple value object representing an HTTP response.
type HttpResponse struct {
	StatusCode int
	Body       string
	decoded    map[string]interface{}
	decodeOnce sync.Once
}

// JSON decodes the response body as JSON.
// Returns nil if the body is not valid JSON.
func (r *HttpResponse) JSON() map[string]interface{} {
	r.decodeOnce.Do(func() {
		var result map[string]interface{}
		if err := json.Unmarshal([]byte(r.Body), &result); err == nil {
			r.decoded = result
		}
	})
	return r.decoded
}

// IsSuccess returns true if the HTTP status code is 2xx.
func (r *HttpResponse) IsSuccess() bool {
	return r.StatusCode >= 200 && r.StatusCode < 300
}

// IsUnauthorized returns true if the HTTP status code is 401 or 403.
func (r *HttpResponse) IsUnauthorized() bool {
	return r.StatusCode == 401 || r.StatusCode == 403
}

// defaultHTTPClient is the default HTTP client implementation using net/http.
type defaultHTTPClient struct {
	client *http.Client
}

const (
	defaultTimeout = 15 * time.Second
	userAgentValue = "Allow2-Go-SDK/2.0"
)

// newDefaultHTTPClient creates a new default HTTP client with a 15-second timeout.
func newDefaultHTTPClient() *defaultHTTPClient {
	return &defaultHTTPClient{
		client: &http.Client{
			Timeout: defaultTimeout,
		},
	}
}

// Post sends a POST request with JSON-encoded body data.
func (c *defaultHTTPClient) Post(url string, data map[string]interface{}, headers map[string]string) (*HttpResponse, error) {
	return c.request("POST", url, data, headers)
}

// Get sends a GET request.
func (c *defaultHTTPClient) Get(url string, headers map[string]string) (*HttpResponse, error) {
	return c.request("GET", url, nil, headers)
}

// request executes an HTTP request.
func (c *defaultHTTPClient) request(method, url string, data map[string]interface{}, headers map[string]string) (*HttpResponse, error) {
	var bodyReader io.Reader
	if data != nil && method == "POST" {
		jsonData, err := json.Marshal(data)
		if err != nil {
			return nil, err
		}
		bodyReader = bytes.NewReader(jsonData)
	}

	req, err := http.NewRequest(method, url, bodyReader)
	if err != nil {
		return nil, err
	}

	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Accept", "application/json")
	req.Header.Set("User-Agent", userAgentValue)

	for k, v := range headers {
		req.Header.Set(k, v)
	}

	resp, err := c.client.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	bodyBytes, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}

	return &HttpResponse{
		StatusCode: resp.StatusCode,
		Body:       string(bodyBytes),
	}, nil
}