init

Author: iGoogle-ink

.gitignore

@@ -0,0 +1,15 @@
+# Binaries for programs and plugins
+*.exe
+*.exe~
+*.dll
+*.so
+*.dylib
+
+# Test binary, build with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+/.idea
+.DS_Store

README.md

@@ -0,0 +1,3 @@
+## xhttp
+
+http request library for Go

client.go

@@ -0,0 +1,104 @@
+package xhttp
+
+import (
+	"crypto/tls"
+	"net"
+	"net/http"
+	"time"
+)
+
+type Client struct {
+	HttpClient *http.Client
+	bodySize   int // body size limit(MB), default is 10MB
+}
+
+func defaultClient() *Client {
+	return &Client{
+		HttpClient: &http.Client{
+			Timeout: 60 * time.Second,
+			Transport: &http.Transport{
+				Proxy: http.ProxyFromEnvironment,
+				DialContext: defaultTransportDialContext(&net.Dialer{
+					Timeout:   30 * time.Second,
+					KeepAlive: 30 * time.Second,
+					DualStack: true,
+				}),
+				TLSClientConfig:       &tls.Config{InsecureSkipVerify: true},
+				MaxIdleConns:          100,
+				IdleConnTimeout:       90 * time.Second,
+				TLSHandshakeTimeout:   10 * time.Second,
+				ExpectContinueTimeout: 1 * time.Second,
+				DisableKeepAlives:     true,
+				ForceAttemptHTTP2:     true,
+			},
+		},
+		bodySize: 10, // default is 10MB
+	}
+}
+
+// NewClient , default tls.Config{InsecureSkipVerify: true}
+func NewClient() (client *Client) {
+	return defaultClient()
+}
+
+func (c *Client) SetTransport(transport *http.Transport) (client *Client) {
+	c.HttpClient.Transport = transport
+	return c
+}
+
+func (c *Client) SetTLSConfig(tlsCfg *tls.Config) (client *Client) {
+	c.HttpClient.Transport.(*http.Transport).TLSClientConfig = tlsCfg
+	return c
+}
+
+func (c *Client) SetTimeout(timeout time.Duration) (client *Client) {
+	c.HttpClient.Timeout = timeout
+	return c
+}
+
+// set body size (MB), default is 10MB
+func (c *Client) SetBodySize(sizeMB int) (client *Client) {
+	c.bodySize = sizeMB
+	return c
+}
+
+// typeStr is request type and response type
+// default is TypeJSON
+// first param is request type
+// second param is response data type
+func (c *Client) Req(typeStr ...string) *Request {
+	var (
+		reqTp = TypeJSON    // default
+		resTp = ResTypeJSON // default
+		tLen  = len(typeStr)
+	)
+	switch {
+	case tLen == 1:
+		tpp := typeStr[0]
+		if _, ok := _ReqContentTypeMap[tpp]; ok {
+			reqTp = tpp
+		}
+	case tLen > 1:
+		// first param is request type
+		tpp := typeStr[0]
+		if _, ok := _ReqContentTypeMap[tpp]; ok {
+			reqTp = tpp
+		}
+		// second param is response data type
+		stpp := typeStr[1]
+		if _, ok := _ResTypeMap[stpp]; ok {
+			resTp = stpp
+		}
+	}
+	if c == nil {
+		c = defaultClient()
+	}
+	r := &Request{
+		client:       c,
+		Header:       make(http.Header),
+		requestType:  reqTp,
+		responseType: resTp,
+	}
+	r.Header.Set("Content-Type", _ReqContentTypeMap[reqTp])
+	return r
+}

client_test.go

@@ -0,0 +1,67 @@
+package xhttp
+
+import (
+	"context"
+	"os"
+	"testing"
+
+	"github.com/go-pay/bm"
+	"github.com/go-pay/xlog"
+)
+
+type HttpGet struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+	Data    any    `json:"data,omitempty"`
+}
+
+var ctx = context.Background()
+
+func TestHttpGet(t *testing.T) {
+	xlog.Level = xlog.DebugLevel
+	var client *Client
+	// test
+	_, bs, err := client.Req().Get("http://www.baidu.com").EndBytes(ctx)
+	if err != nil {
+		xlog.Error(err)
+		return
+	}
+	xlog.Debug(string(bs))
+
+	//rsp := new(HttpGet)
+	//_, err = client.Type(TypeJSON).Get("http://api.igoogle.ink/app/v1/ping").EndStruct(ctx, rsp)
+	//if err != nil {
+	//	xlog.Error(err)
+	//	return
+	//}
+	//xlog.Debug(rsp)
+}
+
+func TestHttpUploadFile(t *testing.T) {
+	xlog.Level = xlog.DebugLevel
+	fileContent, err := os.ReadFile("logo.png")
+	if err != nil {
+		xlog.Error(err)
+		return
+	}
+	//xlog.Debug("fileByte：", string(fileContent))
+
+	bmm := make(bm.BodyMap)
+	bmm.SetBodyMap("meta", func(bm bm.BodyMap) {
+		bm.Set("filename", "123.jpg").
+			Set("sha256", "ad4465asd4fgw5q")
+	}).SetFormFile("image", &bm.File{Name: "logo.png", Content: fileContent})
+
+	client := NewClient()
+
+	rsp := new(HttpGet)
+	_, err = client.Req(TypeMultipartFormData).
+		Post("http://localhost:2233/admin/v1/oss/uploadImage").
+		SendMultipartBodyMap(bmm).
+		EndStruct(ctx, rsp)
+	if err != nil {
+		xlog.Error(err)
+		return
+	}
+	xlog.Debugf("%+v", rsp)
+}

go.mod

@@ -0,0 +1,13 @@
+module github.com/go-pay/xhttp
+
+go 1.20.0
+
+require (
+	github.com/go-pay/bm v0.0.0-20231104140628-922a8107c7dd
+	github.com/go-pay/xlog v0.0.0-20231104134525-b6ce65b7e035
+)
+
+require (
+	go.uber.org/multierr v1.11.0 // indirect
+	go.uber.org/zap v1.26.0 // indirect
+)

go.sum

@@ -0,0 +1,13 @@
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/go-pay/bm v0.0.0-20231104140628-922a8107c7dd h1:FxRmde5/CEIh5hy6zHfhqzKJGyhbI9JoNf6h/LlbiVM=
+github.com/go-pay/bm v0.0.0-20231104140628-922a8107c7dd/go.mod h1:puiU1FnDsC1m2h8ArJc4n1WZuzAMZEYex0Gp10PY3fI=
+github.com/go-pay/xlog v0.0.0-20231104134525-b6ce65b7e035 h1:jlc9l6rgHlUSYP/hN8JzH8mTGn2YzQD7KJ1tCW+PwR8=
+github.com/go-pay/xlog v0.0.0-20231104134525-b6ce65b7e035/go.mod h1:9PX534KUJqcKyxfEgNDms41EiwSm+IR0NxY01k31YHs=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
+go.uber.org/goleak v1.2.0 h1:xqgm/S+aQvhWFTtR0XK3Jvg7z8kGV8P4X14IzwN3Eqk=
+go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
+go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
+go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo=
+go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

logo.png

@@ -0,0 +1,48 @@
+package xhttp
+
+import "encoding/json"
+
+const (
+	GET    = "GET"
+	POST   = "POST"
+	PUT    = "PUT"
+	DELETE = "DELETE"
+	PATCH  = "PATCH"
+
+	ResTypeJSON = "json"
+	ResTypeXML  = "xml"
+
+	TypeJSON              = "json"
+	TypeXML               = "xml"
+	TypeFormData          = "form-data"
+	TypeMultipartFormData = "multipart-form-data"
+)
+
+var (
+	_ReqContentTypeMap = map[string]string{
+		TypeJSON:              "application/json",
+		TypeXML:               "application/xml",
+		TypeFormData:          "application/x-www-form-urlencoded",
+		TypeMultipartFormData: "multipart/form-data",
+	}
+
+	_ResTypeMap = map[string]string{
+		ResTypeJSON: "application/json",
+		ResTypeXML:  "application/xml",
+	}
+)
+
+func ConvertToString(v any) (str string) {
+	if v == nil {
+		return ""
+	}
+	var (
+		bs  []byte
+		err error
+	)
+	if bs, err = json.Marshal(v); err != nil {
+		return ""
+	}
+	str = string(bs)
+	return
+}