feat(core): propagate context through HTTP

client.go

@@ -47,15 +47,15 @@ func NewClient(baseURL string, opts ...ClientOpt) *Client {
 	return cli
 }
 
-func (c *Client) post(path string, payload any) ([]byte, error) {
+func (c *Client) post(ctx context.Context, path string, payload any) ([]byte, error) {
 	jsonData, err := json.Marshal(payload)
 	if err != nil {
 		return nil, fmt.Errorf("failed to marshal payload: %w", err)
 	}
 
 	url := c.baseURL + path
 	req, err := http.NewRequestWithContext(
-		context.Background(),
+		ctx,
 		http.MethodPost,
 		url,
 		bytes.NewBuffer(jsonData),

exchange.go

@@ -1,6 +1,7 @@
 package hyperliquid
 
 import (
+	"context"
 	"crypto/ecdsa"
 	"encoding/json"
 	"sync/atomic"
@@ -78,7 +79,7 @@ func (e *Exchange) SetLastNonce(n int64) {
 }
 
 // executeAction executes an action and unmarshals the response into the given result
-func (e *Exchange) executeAction(action, result any) error {
+func (e *Exchange) executeAction(ctx context.Context, action, result any) error {
 	nonce := e.nextNonce()
 
 	sig, err := SignL1Action(
@@ -93,7 +94,7 @@ func (e *Exchange) executeAction(action, result any) error {
 		return err
 	}
 
-	resp, err := e.postAction(action, sig, nonce)
+	resp, err := e.postAction(ctx, action, sig, nonce)
 	if err != nil {
 		return err
 	}
@@ -106,6 +107,7 @@ func (e *Exchange) executeAction(action, result any) error {
 }
 
 func (e *Exchange) postAction(
+	ctx context.Context,
 	action any,
 	signature SignatureResult,
 	nonce int64,
@@ -136,5 +138,5 @@ func (e *Exchange) postAction(
 		payload["expiresAfter"] = *e.expiresAfter
 	}
 
-	return e.client.post("/exchange", payload)
+	return e.client.post(ctx, "/exchange", payload)
 }

exchange_orders.go

@@ -1,6 +1,7 @@
 package hyperliquid
 
 import (
+	"context"
 	"encoding/json"
 	"fmt"
 )
@@ -132,15 +133,47 @@ func (e *Exchange) Order(
 	return data.Statuses[0], nil
 }
 
+func (e *Exchange) OrderWithContext(
+	ctx context.Context,
+	req CreateOrderRequest,
+	builder *BuilderInfo,
+) (result OrderStatus, err error) {
+	resp, err := e.BulkOrdersWithContext(ctx, []CreateOrderRequest{req}, builder)
+	if err != nil {
+		return
+	}
+
+	if !resp.Ok {
+		err = fmt.Errorf("failed to create order: %s", resp.Err)
+		return
+	}
+
+	data := resp.Data
+	if len(data.Statuses) == 0 {
+		err = fmt.Errorf("no status for order: %s", resp.Err)
+		return
+	}
+
+	return data.Statuses[0], nil
+}
+
 func (e *Exchange) BulkOrders(
 	orders []CreateOrderRequest,
 	builder *BuilderInfo,
+) (result *APIResponse[OrderResponse], err error) {
+	return e.BulkOrdersWithContext(context.Background(), orders, builder)
+}
+
+func (e *Exchange) BulkOrdersWithContext(
+	ctx context.Context,
+	orders []CreateOrderRequest,
+	builder *BuilderInfo,
 ) (result *APIResponse[OrderResponse], err error) {
 	action, err := newCreateOrderAction(e, orders, builder)
 	if err != nil {
 		return nil, err
 	}
-	err = e.executeAction(action, &result)
+	err = e.executeAction(ctx, action, &result)
 	if err != nil {
 		return nil, err
 	}
@@ -229,14 +262,21 @@ func newModifyOrdersAction(
 // ModifyOrder modifies an existing order
 func (e *Exchange) ModifyOrder(
 	req ModifyOrderRequest,
+) (result OrderStatus, err error) {
+	return e.ModifyOrderWithContext(context.Background(), req)
+}
+
+func (e *Exchange) ModifyOrderWithContext(
+	ctx context.Context,
+	req ModifyOrderRequest,
 ) (result OrderStatus, err error) {
 	resp := APIResponse[OrderResponse]{}
 	action, err := newModifyOrderAction(e, req)
 	if err != nil {
 		return result, fmt.Errorf("failed to create modify action: %w", err)
 	}
 
-	err = e.executeAction(action, &resp)
+	err = e.executeAction(ctx, action, &resp)
 	if err != nil {
 		err = fmt.Errorf("failed to modify order: %w", err)
 		return
@@ -259,14 +299,21 @@ func (e *Exchange) ModifyOrder(
 // BulkModifyOrders modifies multiple orders
 func (e *Exchange) BulkModifyOrders(
 	modifyRequests []ModifyOrderRequest,
+) ([]OrderStatus, error) {
+	return e.BulkModifyOrdersWithContext(context.Background(), modifyRequests)
+}
+
+func (e *Exchange) BulkModifyOrdersWithContext(
+	ctx context.Context,
+	modifyRequests []ModifyOrderRequest,
 ) ([]OrderStatus, error) {
 	resp := APIResponse[OrderResponse]{}
 	action, err := newModifyOrdersAction(e, modifyRequests)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create bulk modify action: %w", err)
 	}
 
-	err = e.executeAction(action, &resp)
+	err = e.executeAction(ctx, action, &resp)
 	if err != nil {
 		return nil, fmt.Errorf("failed to modify orders: %w", err)
 	}

exchange_orders_cancel.go

@@ -1,6 +1,7 @@
 package hyperliquid
 
 import (
+	"context"
 	"fmt"
 
 	"github.com/sonirico/vago/slices"
@@ -31,6 +32,13 @@ func (e *Exchange) Cancel(
 
 func (e *Exchange) BulkCancel(
 	requests []CancelOrderRequest,
+) (res *APIResponse[CancelOrderResponse], err error) {
+	return e.BulkCancelWithContext(context.Background(), requests)
+}
+
+func (e *Exchange) BulkCancelWithContext(
+	ctx context.Context,
+	requests []CancelOrderRequest,
 ) (res *APIResponse[CancelOrderResponse], err error) {
 	cancels := slices.Map(requests, func(req CancelOrderRequest) CancelOrderWire {
 		return CancelOrderWire{
@@ -44,7 +52,7 @@ func (e *Exchange) BulkCancel(
 		Cancels: cancels,
 	}
 
-	if err = e.executeAction(action, &res); err != nil {
+	if err = e.executeAction(ctx, action, &res); err != nil {
 		return
 	}
 
@@ -80,6 +88,13 @@ func (e *Exchange) CancelByCloid(
 
 func (e *Exchange) BulkCancelByCloids(
 	requests []CancelOrderRequestByCloid,
+) (res *APIResponse[CancelOrderResponse], err error) {
+	return e.BulkCancelByCloidsWithContext(context.Background(), requests)
+}
+
+func (e *Exchange) BulkCancelByCloidsWithContext(
+	ctx context.Context,
+	requests []CancelOrderRequestByCloid,
 ) (res *APIResponse[CancelOrderResponse], err error) {
 	cancels := slices.Map(requests, func(req CancelOrderRequestByCloid) CancelByCloidWire {
 		return CancelByCloidWire{
@@ -93,7 +108,7 @@ func (e *Exchange) BulkCancelByCloids(
 		Cancels: cancels,
 	}
 
-	if err = e.executeAction(action, &res); err != nil {
+	if err = e.executeAction(ctx, action, &res); err != nil {
 		return
 	}