Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 3e02c6f2d5 | |||
| 9513c373aa | |||
| 961b90626f |
@@ -1,6 +1,10 @@
|
|||||||
package api
|
package api
|
||||||
|
|
||||||
import "resty.dev/v3"
|
import (
|
||||||
|
"crypto/tls"
|
||||||
|
|
||||||
|
"resty.dev/v3"
|
||||||
|
)
|
||||||
|
|
||||||
type Client struct {
|
type Client struct {
|
||||||
token string
|
token string
|
||||||
@@ -20,11 +24,22 @@ func NewClient(token string) *Client {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func NewDMClient(token, dmURL, device string) *Client {
|
func NewDMClient(token, dmURL, device string) *Client {
|
||||||
|
restyClient := resty.New()
|
||||||
|
restyClient.SetTLSClientConfig(&tls.Config{
|
||||||
|
MinVersion: tls.VersionTLS12,
|
||||||
|
CipherSuites: []uint16{
|
||||||
|
tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,
|
||||||
|
tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,
|
||||||
|
tls.TLS_RSA_WITH_AES_256_GCM_SHA384,
|
||||||
|
tls.TLS_RSA_WITH_AES_128_GCM_SHA256,
|
||||||
|
},
|
||||||
|
})
|
||||||
|
|
||||||
return &Client{
|
return &Client{
|
||||||
token: token,
|
token: token,
|
||||||
device: device,
|
device: device,
|
||||||
resty: resty.New(),
|
resty: restyClient,
|
||||||
apiBaseURL: dmURL,
|
apiBaseURL: dmURL,
|
||||||
fiscalEndpoint: "/dm/execute",
|
fiscalEndpoint: "/dm/fiscal",
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -18,6 +18,7 @@ func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, resp
|
|||||||
resp, err := c.resty.R().
|
resp, err := c.resty.R().
|
||||||
SetContext(ctx).
|
SetContext(ctx).
|
||||||
SetHeader("Authorization", c.token).
|
SetHeader("Authorization", c.token).
|
||||||
|
SetHeader("Content-Type", "application/json").
|
||||||
SetBody(reqJson).
|
SetBody(reqJson).
|
||||||
Post(c.apiBaseURL + c.fiscalEndpoint)
|
Post(c.apiBaseURL + c.fiscalEndpoint)
|
||||||
|
|
||||||
@@ -25,21 +26,17 @@ func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, resp
|
|||||||
return fmt.Errorf("request failed: %w", err)
|
return fmt.Errorf("request failed: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if resp.IsError() {
|
|
||||||
return fmt.Errorf("api error: %v", resp.Error())
|
|
||||||
}
|
|
||||||
|
|
||||||
if resp.StatusCode() != 200 {
|
|
||||||
return fmt.Errorf("unexpected status code: %d", resp.StatusCode())
|
|
||||||
}
|
|
||||||
|
|
||||||
body, err := io.ReadAll(resp.Body)
|
body, err := io.ReadAll(resp.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return fmt.Errorf("failed to read response: %w", err)
|
return fmt.Errorf("failed to read response: %w", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if resp.StatusCode() != 200 {
|
||||||
|
return fmt.Errorf("api error (status %d): %s", resp.StatusCode(), string(body))
|
||||||
|
}
|
||||||
|
|
||||||
if err := json.Unmarshal(body, response); err != nil {
|
if err := json.Unmarshal(body, response); err != nil {
|
||||||
return fmt.Errorf("failed to unmarshal response: %w", err)
|
return fmt.Errorf("failed to unmarshal response: %w, body: %s", err, string(body))
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
Reference in New Issue
Block a user