Merge pull request #27 from sidan-lab/main

fix: fixing tx submission

client/client.go

@@ -101,3 +101,14 @@ func (c *Client) post(url string, body interface{}) (*http.Response, error) {
 	req.Header.Set("Content-Type", "application/json")
 	return c.HTTPClient.Do(req)
 }
+
+func (c *Client) postBuffer(url string, buffer []byte) (*http.Response, error) {
+	req, err := http.NewRequest("POST", c.BaseUrl+url, bytes.NewBuffer(buffer))
+	req.Header.Set("Accept", "application/cbor")
+	req.Header.Add("api-key", c.apiKey)
+	if err != nil {
+		return nil, err
+	}
+	req.Header.Set("Content-Type", "application/cbor")
+	return c.HTTPClient.Do(req)
+}

client/txmanager.go

@@ -1,8 +1,10 @@
 package client
 
 import (
+	"encoding/hex"
 	"encoding/json"
 	"fmt"
+	"io"
 
 	"github.com/maestro-org/go-sdk/models"
 )
@@ -22,34 +24,42 @@ func (c *Client) TxManagerHistory() (*[]models.TxManagerState, error) {
 	return &txManagerStates, nil
 }
 
-func (c *Client) TxManagerSubmit(cbor string) (models.BasicResponse, error) {
+func (c *Client) TxManagerSubmit(txHex string) (string, error) {
 	url := "/txmanager"
-	resp, err := c.post(url, cbor)
+	txBuffer, err := hex.DecodeString(txHex)
 	if err != nil {
-		return models.BasicResponse{}, err
+		return "", err
+	}
+	resp, err := c.postBuffer(url, txBuffer)
+	if err != nil {
+		return "", err
 	}
 	defer resp.Body.Close()
-	var submitTx models.BasicResponse
-	err = json.NewDecoder(resp.Body).Decode(&submitTx)
+	bodyBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
-		return models.BasicResponse{}, err
+		return "", err
 	}
-	return submitTx, nil
+	txHash := string(bodyBytes)
+	return txHash, nil
 }
 
-func (c *Client) TxManagerSubmitTurbo(cbor string) (models.BasicResponse, error) {
+func (c *Client) TxManagerSubmitTurbo(txHex string) (string, error) {
 	url := "/txmanager/turbosubmit"
-	resp, err := c.post(url, cbor)
+	txBuffer, err := hex.DecodeString(txHex)
+	if err != nil {
+		return "", err
+	}
+	resp, err := c.postBuffer(url, txBuffer)
 	if err != nil {
-		return models.BasicResponse{}, err
+		return "", err
 	}
 	defer resp.Body.Close()
-	var submitTx models.BasicResponse
-	err = json.NewDecoder(resp.Body).Decode(&submitTx)
+	bodyBytes, err := io.ReadAll(resp.Body)
 	if err != nil {
-		return models.BasicResponse{}, err
+		return "", err
 	}
-	return submitTx, nil
+	txHash := string(bodyBytes)
+	return txHash, nil
 }
 
 func (c *Client) TxManagerState(txHash string) (*models.TxManagerState, error) {