Close closes the WebSocket connection

* Helper method to safely extract data from API response * Throws an error if data is null when response is ok

makeRequest is the ctx-less convenience wrapper; existing callers go through here with context.Background().

extractResponseData safely extracts data from API response

Process checks if a message is a duplicate. Returns true if the message is new and should be forwarded to the consumer.

* Helper method to safely extract data from API response * Throws an error if data is null when response is ok

makeRequest makes an HTTP request and returns the response

* Register event handlers

extractResponseData safely extracts data from API response

* Get current positions for a user * * @param query - Query parameters including required user address * @returns Promise resolving to array of

Helper functions to create pointers

Health check GetHealth performs a health check on the Gamma API

GetPrivateKey returns the private key

* Get active events * * @param query - Optional query parameters (excluding active which is set to true) * @returns Promise resolving to arra

* Get list of teams with optional filtering * * @param query - Optional query parameters to filter teams * @returns Promise resolving to arra

ratToDecimal6 multiplies by 10^6 and rounds half-up to integer string.

Events API GetEvents gets list of events with optional filtering

Tags API GetTags gets list of tags with optional filtering

NewAggregator creates an aggregator with the given capacity and TTL.

* Get list of events with optional filtering * * @param query - Query parameters for pagination and filtering * @returns Promise resolving to

GetAddressHex returns the wallet address as a hex string

* Get a specific event by ID * * @param id - The event ID to fetch * @param query - Optional query parameters * @returns Promise resolving

* Get a specific event by slug * * @param slug - The event slug to fetch * @param query - Optional query parameters * @returns Promise res

* Get a specific market by slug * * @param slug - The market slug to fetch * @param query - Optional query parameters * @returns Promise r

* Get user activity * * @param query - Query parameters including required user address * @returns Promise resolving to array of activity object

makeRequestCtx makes an HTTP request and returns the response. ctx cancellation aborts the in-flight HTTP call (via net/http context support); useful

parseJSONArray parses a JSON array from either string or already parsed array

* Parse JSON array string or return as-is if already an array

* Search across markets, events, and profiles * * @param query - Search query parameters * @returns Promise resolving to search results *

* Transform event data from Gamma API to match expected schema * Transforms nested market data as well

transformEventData transforms event data to parse JSON string fields in nested markets

GetServerTime gets the server time

SplitArrayMessage 将 JSON 数组消息拆分为单条消息。 如果输入不是数组，返回 nil（调用方应按单条处理）。

Stop gracefully closes the connection.

computeAmounts returns (makerAmount, takerAmount) as 6-decimal-encoded uint strings. Matches rs-clob-client limit-order semantics exactly: notional =

* Connect to the WebSocket server

* Get active markets * * @param query - Optional query parameters (excluding active which is set to true) * @returns Promise resolving to arr

* Health check for the Data API * * @returns Promise resolving to health check response * @throws {Error} When API request fails * * @exampl

* Initialize the CLOB client with appropriate authentication

* Transform market data from Gamma API to match expected schema * Parses JSON string fields that should be arrays

transformMarketData transforms market data to parse JSON string fields

unmarshalTagsResponse extracts and unmarshals tags response

BuildPolyHmacSignature builds the canonical Polymarket CLOB HMAC signature

CreateApiKey creates a new API key

Get get basic information about the API and available endpoints returns a []byte when successful

Positions API GetCurrentPositions gets current positions for a user

GetPricesHistory gets price history for a market

computeMarketAmounts mirrors rs-clob-client's market builder (vendors/rs-clob-client/src/clob/order_builder.rs::OrderBuilder<Market>::build). Inputs:

* Connect directly to Hyperdrive as if it's your database, returning a TCP socket. * * Calling this method returns an idential socket to if you ca

* Disconnect from the WebSocket server