-
Notifications
You must be signed in to change notification settings - Fork 11
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
add integration with generic httpclient
- Loading branch information
Showing
8 changed files
with
183 additions
and
198 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,2 +1,4 @@ | ||
| # sdk-go | ||
| Mercado Pago's official Go SDK. | ||
| Mercado Pago's official Go SDK. | ||
|
|
||
| This library is a work in progress. |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,137 @@ | ||
| package httpclient | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "io" | ||
| "net/http" | ||
| "runtime" | ||
| "strings" | ||
|
|
||
| "github.com/google/uuid" | ||
| "github.com/mercadopago/sdk-go/pkg/config" | ||
| ) | ||
|
|
||
| const ( | ||
| currentSDKVersion string = "x.x.x" | ||
| productID string = "abc" | ||
| accept string = "application/json" | ||
| contentType string = "application/json; charset=UTF-8" | ||
|
|
||
| headerProductID = "X-Product-Id" | ||
| headerAccept = "Accept" | ||
| headerContentType = "Content-Type" | ||
| headerUserAgent = "User-Agent" | ||
| headerTrackingID = "X-Tracking-Id" | ||
| headerRequestID = "X-Request-Id" | ||
| headerAuthorization = "Authorization" | ||
| headerIdempotency = "X-Idempotency-Key" | ||
|
|
||
| headerCorporationID = "X-Corporation-Id" | ||
| headerIntegratorID = "X-Integrator-Id" | ||
| headerPlatformID = "X-Platform-Id" | ||
| ) | ||
|
|
||
| var ( | ||
| userAgent = fmt.Sprintf("MercadoPago Go SDK/%s", currentSDKVersion) | ||
| trackingID = fmt.Sprintf("platform:%s,type:SDK%s,so;", runtime.Version(), currentSDKVersion) | ||
| ) | ||
|
|
||
| // Get makes requests with the GET method | ||
| // Will return the struct specified in Generics | ||
| func Get[T any](ctx context.Context, cfg *config.Config, path string) (*T, error) { | ||
| req, err := makeRequest(ctx, cfg, http.MethodGet, path, nil) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return send[T](cfg.Requester, req) | ||
| } | ||
|
|
||
| // Post makes requests with the POST method | ||
| // Will return the struct specified in Generics | ||
| func Post[T any](ctx context.Context, cfg *config.Config, path string, body any) (*T, error) { | ||
| req, err := makeRequest(ctx, cfg, http.MethodPost, path, body) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return send[T](cfg.Requester, req) | ||
| } | ||
|
|
||
| // Put makes requests with the PUT method | ||
| // Will return the struct specified in Generics | ||
| func Put[T any](ctx context.Context, cfg *config.Config, path string, body any) (*T, error) { | ||
| req, err := makeRequest(ctx, cfg, http.MethodPut, path, body) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return send[T](cfg.Requester, req) | ||
| } | ||
|
|
||
| // Delete makes requests with the DELETE method | ||
| // Will return the struct specified in Generics | ||
| func Delete[T any](ctx context.Context, cfg *config.Config, path string, body any) (*T, error) { | ||
| req, err := makeRequest(ctx, cfg, http.MethodDelete, path, body) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return send[T](cfg.Requester, req) | ||
| } | ||
|
|
||
| func makeRequest(ctx context.Context, cfg *config.Config, method, path string, body any) (*http.Request, error) { | ||
| req, err := buildHTTPRequest(ctx, method, path, body) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("error creating request: %w", err) | ||
| } | ||
|
|
||
| makeHeaders(req, cfg) | ||
|
|
||
| return req, nil | ||
| } | ||
|
|
||
| func makeHeaders(req *http.Request, cfg *config.Config) { | ||
| req.Header.Set(headerProductID, productID) | ||
| req.Header.Set(headerAccept, accept) | ||
| req.Header.Set(headerContentType, contentType) | ||
| req.Header.Set(headerUserAgent, userAgent) | ||
| req.Header.Set(headerTrackingID, trackingID) | ||
| req.Header.Set(headerAuthorization, "Bearer "+cfg.AccessToken) | ||
| req.Header.Set(headerIdempotency, uuid.New().String()) | ||
| req.Header.Set(headerRequestID, uuid.New().String()) | ||
|
|
||
| if cfg.CorporationID != "" { | ||
| req.Header.Set(headerCorporationID, cfg.CorporationID) | ||
| } | ||
| if cfg.IntegratorID != "" { | ||
| req.Header.Set(headerIntegratorID, cfg.IntegratorID) | ||
| } | ||
| if cfg.PlatformID != "" { | ||
| req.Header.Set(headerPlatformID, cfg.PlatformID) | ||
| } | ||
| } | ||
|
|
||
| func buildHTTPRequest(ctx context.Context, method, url string, body any) (*http.Request, error) { | ||
| b, err := buildBody(body) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| return http.NewRequestWithContext(ctx, method, url, b) | ||
| } | ||
|
|
||
| func buildBody(body any) (io.Reader, error) { | ||
| if body == nil { | ||
| return nil, nil | ||
| } | ||
|
|
||
| b, err := json.Marshal(&body) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("error marshaling request body: %w", err) | ||
| } | ||
|
|
||
| return strings.NewReader(string(b)), nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.