add lo req examples

Author: qdriven

go.mod

@@ -7,7 +7,7 @@ require (
 	github.com/gin-contrib/static v1.1.2
 	github.com/google/go-cmp v0.6.0
 	github.com/google/uuid v1.6.0
-	github.com/imroc/req/v3 v3.43.7
+	github.com/imroc/req/v3 v3.44.0
 	github.com/itchyny/gojq v0.12.16
 	github.com/joho/godotenv v1.5.1
 	github.com/labstack/echo/v5 v5.0.0-20230722203903-ec5b858dab61

go.sum

@@ -194,6 +194,8 @@ github.com/hinshun/vt10x v0.0.0-20220119200601-820417d04eec h1:qv2VnGeEQHchGaZ/u
 github.com/hinshun/vt10x v0.0.0-20220119200601-820417d04eec/go.mod h1:Q48J4R4DvxnHolD5P8pOtXigYlRuPLGl6moFx3ulM68=
 github.com/imroc/req/v3 v3.43.7 h1:dOcNb9n0X83N5/5/AOkiU+cLhzx8QFXjv5MhikazzQA=
 github.com/imroc/req/v3 v3.43.7/go.mod h1:SQIz5iYop16MJxbo8ib+4LnostGCok8NQf8ToyQc2xA=
+github.com/imroc/req/v3 v3.44.0 h1:JBrxoN5DykYvkeEZx3dski8/A+WVz9HD147cwEeyFlM=
+github.com/imroc/req/v3 v3.44.0/go.mod h1:6cQ91w7qPn+bYjcWnA1S/LmTh6z3cz8Oa9qdwm7gS8w=
 github.com/inconshreveable/mousetrap v1.1.0 h1:wN+x4NVGpMsO7ErUn/mUI3vEoE6Jt13X2s0bqwp9tc8=
 github.com/inconshreveable/mousetrap v1.1.0/go.mod h1:vpF70FUmC8bwa3OWnCshd2FqLfsEA9PFc4w1p2J65bw=
 github.com/itchyny/gojq v0.12.16 h1:yLfgLxhIr/6sJNVmYfQjTIv0jGctu6/DgDoivmxTr7g=

internal/utils/qhttp/client.go

@@ -18,8 +18,13 @@ func NewHttpClient() *Client {
 	}
 }
 
-func (h Client) Get(url string) (string, string, *req.Response) {
+func (h *Client) Get(url string) (string, string, *req.Response) {
 	resp := h.Client.R(). // Use R() to create a request.
 				MustGet(url)
 	return resp.Status, resp.String(), resp
 }
+
+func (h *Client) DebugOptions() {
+	req.EnableAutoDecode()
+	req.EnableDebugLog()
+}

internal/utils/qhttp/client_test.go

@@ -1,8 +1,13 @@
 package qhttp
 
+//https://github.com/imroc/req
+
 import (
 	"fmt"
+	"github.com/imroc/req/v3"
+	"log"
 	"testing"
+	"time"
 )
 
 const MD = "https://raw.githubusercontent.com/luban-agi/Awesome-AIGC-Tutorials/main/README.md"
@@ -16,3 +21,124 @@ func TestHttpClient_Get(t *testing.T) {
 	fmt.Println(statusCode, md)
 	fmt.Println(statusCode1, md_zh)
 }
+
+func TestReqMode(t *testing.T) {
+	req.DevMode()
+	req.EnableAutoDecode()
+	req.EnableForceHTTP1()
+	var result = req.MustGet("https://httpbin.org/uuid")
+	print(result)
+}
+
+type ErrorMessage struct {
+	Message string `json:"message"`
+}
+
+func (msg *ErrorMessage) Error() string {
+	return fmt.Sprintf("API Error: %s", msg.Message)
+}
+
+type UserInfo struct {
+	Name string `json:"name"`
+	Blog string `json:"blog"`
+}
+
+func TestAdvancedUsage(t *testing.T) {
+	client := req.C().
+		SetUserAgent("my-custom-client"). // Chainable client settings.
+		SetTimeout(5 * time.Second).
+		OnAfterResponse(func(client *req.Client, resp *req.Response) error {
+			if resp.Err != nil { // There is an underlying error, e.g. network error or unmarshal error.
+				return nil
+			}
+			if errMsg, ok := resp.ErrorResult().(*ErrorMessage); ok {
+				resp.Err = errMsg // Convert api error into go error
+				return nil
+			}
+			if !resp.IsSuccessState() {
+				// Neither a success response nor a error response, record details to help troubleshooting
+				resp.Err = fmt.Errorf("bad status: %s\nraw content:\n%s", resp.Status, resp.Dump())
+			}
+			return nil
+		})
+
+	var userInfo UserInfo
+	var errMsg ErrorMessage
+	resp, err := client.R().
+		SetHeader("Accept", "application/vnd.github.v3+json"). // Chainable request settings.
+		SetPathParam("username", "imroc").                     // Replace path variable in url.
+		SetSuccessResult(&userInfo).                           // Unmarshal response body into userInfo automatically if status code is between 200 and 299.
+		SetErrorResult(&errMsg).                               // Unmarshal response body into errMsg automatically if status code >= 400.
+		EnableDump().                                          // Enable dump at request level, only print dump content if there is an error or some unknown situation occurs to help troubleshoot.
+		Get("https://api.github.com/users/{username}")
+
+	if err != nil { // Error handling.
+		log.Println("error:", err)
+		log.Println("raw content:")
+		log.Println(resp.Dump()) // Record raw content when error occurs.
+		return
+	}
+
+	if resp.IsErrorState() { // Status code >= 400.
+		fmt.Println(errMsg.Message) // Record error message returned.
+		return
+	}
+
+	if resp.IsSuccessState() { // Status code is between 200 and 299.
+		fmt.Printf("%s (%s)\n", userInfo.Name, userInfo.Blog)
+		return
+	}
+
+	// Unknown status code.
+	log.Println("unknown status", resp.Status)
+	log.Println("raw content:")
+	log.Println(resp.Dump()) // Record raw content when server returned unknown status code.
+}
+
+type Repo struct {
+	Name string `json:"name"`
+	Url  string `json:"url"`
+}
+
+type Result struct {
+	Data string `json:"data"`
+}
+
+func TestSimplePost(t *testing.T) {
+	client := req.C().DevMode()
+	var result Result
+
+	resp, err := client.R().
+		SetBody(&Repo{Name: "req", Url: "https://github.com/imroc/req"}).
+		SetSuccessResult(&result).
+		Post("https://httpbin.org/post")
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	if !resp.IsSuccessState() {
+		fmt.Println("bad response status:", resp.Status)
+		return
+	}
+	fmt.Println("++++++++++++++++++++++++++++++++++++++++++++++++")
+	fmt.Println("data:", result.Data)
+	fmt.Println("++++++++++++++++++++++++++++++++++++++++++++++++")
+}
+
+type APIResponse struct {
+	Origin string `json:"origin"`
+	Url    string `json:"url"`
+}
+
+func TestApiStyleReq(t *testing.T) {
+	var resp APIResponse
+	c := req.C().SetBaseURL("https://httpbin.org/post")
+	err := c.Post().
+		SetBody("hello").
+		Do().
+		Into(&resp)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Println("My IP is", resp.Origin)
+}

internal/utils/structs.go

@@ -2,7 +2,9 @@ package utils
 
 import (
 	"fmt"
+	"github.com/samber/lo"
 	"reflect"
+	"strings"
 )
 
 // StructToMap : returns a map of names to values for struct passed .
@@ -37,3 +39,13 @@ func CopyToStringStruct(src interface{}, dest interface{}) {
 		newField.SetString(fmt.Sprintf("%v", srcField.Interface()))
 	}
 }
+
+func FilterStringMap(mapping []string, key string) []string {
+	matching := lo.FilterMap(mapping, func(x string, _ int) (string, bool) {
+		if strings.HasSuffix(x, key) {
+			return x, true
+		}
+		return "", false
+	})
+	return matching
+}