6 Commits

Author SHA1 Message Date
861a1640d4 Improved error handling in vchasno responses 2026-01-16 02:27:09 +03:00
28a8810ffb set default devicemanager endpoint as /dm/execute. As stated in VCHASNO docs. 2026-01-16 02:23:48 +03:00
3ed7d33b84 Added Verbose mode 2026-01-16 02:21:37 +03:00
3e02c6f2d5 improved error messages 2026-01-16 02:19:24 +03:00
9513c373aa some more tls magic 2026-01-16 02:17:39 +03:00
961b90626f set TLS to version 1.2 2026-01-16 02:14:31 +03:00
3 changed files with 61 additions and 12 deletions

View File

@@ -1,6 +1,10 @@
package api
import "resty.dev/v3"
import (
"crypto/tls"
"resty.dev/v3"
)
type Client struct {
token string
@@ -20,10 +24,21 @@ func NewClient(token 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{
token: token,
device: device,
resty: resty.New(),
resty: restyClient,
apiBaseURL: dmURL,
fiscalEndpoint: "/dm/execute",
}

View File

@@ -5,8 +5,18 @@ import (
"encoding/json"
"fmt"
"io"
"log"
)
type APIError struct {
Code int
Message string
}
func (e *APIError) Error() string {
return fmt.Sprintf("vchasno api error %d: %s", e.Code, e.Message)
}
func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, response interface{}) error {
request.Device = c.device
@@ -15,31 +25,44 @@ func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, resp
return fmt.Errorf("failed to marshal request: %w", err)
}
url := c.apiBaseURL + c.fiscalEndpoint
log.Printf("[VCHASNO] POST %s", url)
log.Printf("[VCHASNO] Request: %s", string(reqJson))
resp, err := c.resty.R().
SetContext(ctx).
SetHeader("Authorization", c.token).
SetHeader("Content-Type", "application/json").
SetBody(reqJson).
Post(c.apiBaseURL + c.fiscalEndpoint)
Post(url)
if err != nil {
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)
if err != nil {
return fmt.Errorf("failed to read response: %w", err)
}
log.Printf("[VCHASNO] Response (status %d): %s", resp.StatusCode(), string(body))
if resp.StatusCode() != 200 {
return fmt.Errorf("api error (status %d): %s", resp.StatusCode(), string(body))
}
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))
}
var baseResp BaseResponse
if err := json.Unmarshal(body, &baseResp); err == nil {
if baseResp.HasError() {
return &APIError{
Code: baseResp.Res,
Message: baseResp.Errortxt,
}
}
}
return nil

View File

@@ -15,6 +15,17 @@ type BaseResponse struct {
ErrorExtra interface{} `json:"error_extra"`
}
func (r *BaseResponse) HasError() bool {
return r.Res != 0
}
func (r *BaseResponse) Error() string {
if r.Errortxt != "" {
return r.Errortxt
}
return ""
}
type SellResponse struct {
BaseResponse
Info SellInfo `json:"info"`