3 Commits

Author SHA1 Message Date
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
2 changed files with 15 additions and 11 deletions

View File

@@ -40,6 +40,6 @@ func NewDMClient(token, dmURL, device string) *Client {
device: device, device: device,
resty: restyClient, resty: restyClient,
apiBaseURL: dmURL, apiBaseURL: dmURL,
fiscalEndpoint: "/dm/fiscal", fiscalEndpoint: "/dm/execute",
} }
} }

View File

@@ -5,6 +5,7 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"io" "io"
"log"
) )
func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, response interface{}) error { func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, response interface{}) error {
@@ -15,31 +16,34 @@ func (c *Client) executeRequest(ctx context.Context, request FiscalRequest, resp
return fmt.Errorf("failed to marshal request: %w", err) 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(). 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(url)
if err != nil { if err != nil {
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)
} }
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 { 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