8 Commits

Author SHA1 Message Date
64787c7cb0 refactored HTTP header handling 2025-02-13 16:23:51 +01:00
b68c93e092 implemented RemoveAllHeaders 2025-02-13 16:20:22 +01:00
767b660a22 fixed HTTP auth header name 2025-02-12 13:22:24 +01:00
6142a1100c remove old auth header on Auth() call 2025-02-11 12:45:20 +01:00
9babe85048 RemoveQuery implemented 2025-02-11 12:38:33 +01:00
b59185d56c RemoveHeaders implemented 2025-02-11 12:30:35 +01:00
1c3a45729b fixed status check 2025-02-02 20:06:45 +01:00
f5ff99a2a8 ParseJsonResponse returns error based on status code 2025-02-02 20:02:13 +01:00
3 changed files with 78 additions and 5 deletions

23
do.go
View File

@ -2,6 +2,7 @@ package ezhttp
import (
"encoding/json"
"fmt"
"io"
"net/http"
)
@ -10,10 +11,28 @@ func Do(req *http.Request) (*http.Response, error) {
return http.DefaultClient.Do(req)
}
func ParseJsonResponse[T any](r io.Reader) (*T, error) {
func ParseJsonResponse[T any](resp *http.Response) (*T, error) {
if resp.StatusCode/100 != 2 {
return nil, fmt.Errorf(
"request '%s' returned status code %s\nOutput: %s",
resp.Request.URL.String(),
resp.Status,
ReadAllString(resp.Body),
)
}
res := new(T)
if err := json.NewDecoder(r).Decode(res); err != nil {
if err := json.NewDecoder(resp.Body).Decode(res); err != nil {
return nil, err
}
return res, nil
}
func ReadAllString(r io.Reader) string {
data, err := io.ReadAll(r)
if err != nil {
return fmt.Errorf("could not read response body: %w", err).Error()
}
return string(data)
}

View File

@ -92,6 +92,17 @@ func Query(keyValuePairs ...string) RequestModifier {
}
}
func RemoveQuery(keys ...string) RequestModifier {
return func(r *RequestBuilder) *RequestBuilder {
q := r.URL.Query()
for _, key := range keys {
q.Del(key)
}
r.URL.RawQuery = q.Encode()
return r
}
}
func QueryMap(query map[string]string) RequestModifier {
return func(r *RequestBuilder) *RequestBuilder {
q := r.URL.Query()
@ -110,7 +121,7 @@ func Method(method string) RequestModifier {
}
}
func Headers(keyValuePairs ...string) RequestModifier {
func AddHeaders(keyValuePairs ...string) RequestModifier {
if len(keyValuePairs)%2 != 0 {
panic("keyValuePairs must have an even length")
}
@ -123,7 +134,30 @@ func Headers(keyValuePairs ...string) RequestModifier {
}
}
func HeadersMap(headers map[string]string) RequestModifier {
func RemoveHeaders(headers ...string) RequestModifier {
return func(r *RequestBuilder) *RequestBuilder {
for _, header := range headers {
r.Header.Del(header)
}
return r
}
}
func RemoveAllHeaders() RequestModifier {
return func(r *RequestBuilder) *RequestBuilder {
r.Header = make(http.Header)
return r
}
}
func Headers(keyValuePairs ...string) RequestModifier {
return chainMods(
RemoveAllHeaders(),
AddHeaders(keyValuePairs...),
)
}
func AddHeadersMap(headers map[string]string) RequestModifier {
return func(r *RequestBuilder) *RequestBuilder {
for key, value := range headers {
r.Header.Add(key, value)
@ -132,8 +166,18 @@ func HeadersMap(headers map[string]string) RequestModifier {
}
}
func HeadersMap(headers map[string]string) RequestModifier {
return chainMods(
RemoveAllHeaders(),
AddHeadersMap(headers),
)
}
func Auth(auth AuthProvider) RequestModifier {
return Headers("Authentication", auth())
return chainMods(
RemoveHeaders("Authorization"),
AddHeaders("Authorization", auth()),
)
}
func Basic(username, password string) AuthProvider {

10
utils.go Normal file
View File

@ -0,0 +1,10 @@
package ezhttp
func chainMods(mods ...RequestModifier) RequestModifier {
return func(r *RequestBuilder) *RequestBuilder {
for _, mod := range mods {
r = mod(r)
}
return r
}
}