client.go

package smmssdk

import (
	"bytes"
	"context"
	"encoding/json"
	"io"
	"log/slog"
	"net/http"
)

type Requester interface {
	Request(ctx context.Context) (*http.Request, error)
}

type Responder interface {
}

type baseResponse struct {
	Success   bool   `json:"success"`
	Code      string `json:"code"`
	Message   string `json:"message"`
	RequestId string `json:"RequestId"`

	Data *interface{} `json:"data,omitempty"`
}

type Client struct {
	Options
	baseURL string

	respBodyRaw string
}

const (
	baseURL = "https://sm.ms/api/v2"
)

func NewClient(options ...Option) *Client {
	c := new(Client)
	c.baseURL = baseURL
	c.logger = slog.Default()
	c.logEnabled = false
	for _, option := range options {
		option(c)
	}
	return c
}

func (c *Client) Do(ctx context.Context, request Requester, responder Responder) error {
	err := c.do(ctx, request, responder)
	if err != nil {
		return err
	}

	return nil
}

func (c *Client) do(ctx context.Context, request Requester, response Responder) error {
	req, err := request.Request(ctx)
	if err != nil {
		return err
	}

	if c.secretToken != "" {
		req.Header.Set("Authorization", c.secretToken)
	}

	if c.logEnabled {
		c.logger.InfoContext(ctx, "starting request",
			slog.String("method", req.Method),
			slog.String("url", req.URL.String()),
			//slog.Any("headers", req.Header),
		)
	}

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

	var buf bytes.Buffer
	//io.TeeReader(resp.Body, &buf)
	_, err = io.Copy(&buf, resp.Body)
	if err != nil {
		return err
	}

	// response raw text
	c.respBodyRaw = buf.String()
	if c.logEnabled {
		c.logger.Info("response",
			slog.Int("status code", resp.StatusCode),
			slog.String("body raw", c.respBodyRaw),
		)
	}

	// response json to struct
	err = json.NewDecoder(&buf).Decode(response)
	if err != nil {
		return err
	}

	return nil
}