ایجاد درخواست های HTTP مانند Pro in Go: استفاده از Go -Resty با Goframe 🚀 – Community Dev

go install github.com/gogf/gf/v2/cmd/gf@latest
go get github.com/go-resty/resty/v2

import (
    "github.com/go-resty/resty/v2"
    "github.com/gogf/gf/v2/frame/g"
)

func main() {
    // Create a client (tip: reuse this client!)
    client := resty.New()

    // Make a request
    resp, err := client.R().
        SetQueryParams(map[string]string{
            "page": "1",
            "limit": "10",
        }).
        Get("https://api.example.com/users")

    if err != nil {
        g.Log().Errorf(ctx, "Oops! Something went wrong: %v", err)
        return
    }

    // Use the response
    fmt.Printf("Status: %v\n", resp.Status())
    fmt.Printf("Body: %v\n", resp.String())
}

resp, err := client.R().
    SetHeader("Content-Type", "application/json").
    SetBody(map[string]interface{}{
        "username": "gopher",
        "email": "gopher@go.dev",
    }).
    Post("https://api.example.com/users")

client.SetDebug(true)

// Global timeout for all requests
client := resty.New().
    SetTimeout(5 * time.Second)

// Or for a specific request
resp, err := client.R().
    SetTimeout(3 * time.Second).
    Get("https://api.example.com/users")

// Check for timeout errors
if err != nil {
    if errors.Is(err, context.DeadlineExceeded) {
        fmt.Println("Request timed out! 😱")
        return
    }
    fmt.Printf("Other error: %v\n", err)
}

client.
    SetRetryCount(3).
    SetRetryWaitTime(5 * time.Second).
    SetRetryMaxWaitTime(20 * time.Second).
    AddRetryCondition(
        func(r *resty.Response, err error) bool {
            return r.StatusCode() >= 500 // Retry on server errors
        },
    )

client.OnBeforeRequest(func(c *resty.Client, req *resty.Request) error {
    req.SetHeader("Authorization", "Bearer " + getToken())
    return nil
})

   ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
   defer cancel()

   resp, err := client.R().
       SetContext(ctx).
       Get("https://api.example.com/users")

   if err != nil {
       return fmt.Errorf("request failed: %w", err)
   }
   if resp.StatusCode() >= 400 {
       return fmt.Errorf("bad status: %s", resp.Status())
   }

func NewWeatherService() *WeatherService {
    client := resty.New().
        SetTimeout(10 * time.Second).
        SetRetryCount(3).
        SetRetryWaitTime(1 * time.Second).
        SetHostURL("https://api.weatherapi.com/v1")

    return &WeatherService{client: client}
}

func (s *WeatherService) GetCurrentWeather(ctx context.Context, city string) (*WeatherData, error) {
    var result WeatherData

    resp, err := s.client.R().
        SetQueryParam("q", city).
        SetQueryParam("key", os.Getenv("WEATHER_API_KEY")).
        SetResult(&result).
        SetContext(ctx).
        Get("/current.json")

    if err != nil {
        return nil, fmt.Errorf("weather request failed: %w", err)
    }

    if resp.IsError() {
        return nil, fmt.Errorf("weather API error: %s", resp.String())
    }

    return &result, nil
}