TradeAggregationsRequestBuilder
extends RequestBuilder
in package
Builds requests for the trade aggregations endpoint in Horizon
This class provides methods to query aggregated trade data for asset pairs on the Stellar network. Trade aggregations provide OHLCV (Open, High, Low, Close, Volume) candlestick data over specified time periods, useful for charting and market analysis.
Query Methods:
- forBaseAsset(): Set the base asset for the trading pair (required)
- forCounterAsset(): Set the counter asset for the trading pair (required)
- forStartTime(): Set the start time for aggregation period
- forEndTime(): Set the end time for aggregation period
- forResolution(): Set the time resolution (e.g., 60000 for 1 minute, 3600000 for 1 hour)
- forOffset(): Set time offset for aggregation buckets
Both base and counter assets must be specified. Resolution is in milliseconds and determines the bucket size for aggregation.
Usage Examples:
// Get 1-hour trade aggregations for XLM/USD $base = Asset::native(); $counter = Asset::createNonNativeAsset("USD", "GBBD..."); $aggregations = $sdk->tradeAggregations() ->forBaseAsset($base) ->forCounterAsset($counter) ->forResolution("3600000") ->forStartTime("1609459200000") ->execute();
Tags
Table of Contents
Constants
- HEADERS = ["X-Client-Name" => "stellar_php_sdk", "X-Client-Version" => \Soneso\StellarSDK\StellarSDK::VERSION_NR]
Properties
- $httpClient : Client
- $queryParameters : array<string|int, mixed>
- $segments : array<string|int, mixed>
Methods
- __construct() : mixed
- Constructor
- buildUrl() : string
- Builds the complete request URL with all segments and query parameters
- cursor() : TradeAggregationsRequestBuilder
- Sets <code>cursor</code> parameter on the request.
- execute() : Response
- Build and execute request.
- executeRequest() : Response
- Executes an HTTP request to Horizon and returns a parsed response object
- forBaseAsset() : TradeAggregationsRequestBuilder
- Set the base asset for the trading pair
- forCounterAsset() : TradeAggregationsRequestBuilder
- Returns all trades for the given counter asset.
- forEndTime() : TradeAggregationsRequestBuilder
- forOffset() : TradeAggregationsRequestBuilder
- forResolution() : TradeAggregationsRequestBuilder
- forStartTime() : TradeAggregationsRequestBuilder
- getAndStream() : void
- Streams Server-Sent Events from Horizon to a callback function
- limit() : TradeAggregationsRequestBuilder
- Sets <code>limit</code> parameter on the request.
- order() : TradeAggregationsRequestBuilder
- Sets <code>order</code> parameter on the request.
- request() : TradeAggregationsPageResponse
- Requests specific <code>url</code> and returns {@link TradeAggregationsPageResponse}.
- setSegments() : RequestBuilder
- Sets the URL path segments for this request
Constants
HEADERS
public
mixed
HEADERS
= ["X-Client-Name" => "stellar_php_sdk", "X-Client-Version" => \Soneso\StellarSDK\StellarSDK::VERSION_NR]
Properties
$httpClient
protected
Client
$httpClient
$queryParameters
protected
array<string|int, mixed>
$queryParameters
$segments
protected
array<string|int, mixed>
$segments
Methods
__construct()
Constructor
public
__construct(Client $httpClient) : mixed
Parameters
- $httpClient : Client
-
The HTTP client used for making requests to Horizon
buildUrl()
Builds the complete request URL with all segments and query parameters
public
buildUrl() : string
Combines the URL path segments with query parameters to create the final request URL string that will be sent to Horizon.
Return values
string —The constructed URL with query parameters
cursor()
Sets <code>cursor</code> parameter on the request.
public
cursor(string $cursor) : TradeAggregationsRequestBuilder
A cursor is a value that points to a specific location in a collection of resources. The cursor attribute itself is an opaque value meaning that users should not try to parse it.
Parameters
- $cursor : string
Tags
Return values
TradeAggregationsRequestBuilderexecute()
Build and execute request.
public
execute() : Response
@throws HorizonRequestException
Return values
Response —The parsed response object
executeRequest()
Executes an HTTP request to Horizon and returns a parsed response object
public
executeRequest(string $url, string $requestType[, string|null $requestMethod = "GET" ]) : Response
This method sends the HTTP request to the Horizon server, handles errors, and parses the JSON response into the appropriate response type.
Parameters
- $url : string
-
The complete request URL to fetch
- $requestType : string
-
The expected response type for parsing
- $requestMethod : string|null = "GET"
-
The HTTP method to use (default: "GET")
Tags
Return values
Response —The parsed response object of the specified type
forBaseAsset()
Set the base asset for the trading pair
public
forBaseAsset(Asset $baseAsset) : TradeAggregationsRequestBuilder
The base asset forms the numerator in price calculations.
Parameters
- $baseAsset : Asset
-
The base asset for the trading pair
Return values
TradeAggregationsRequestBuilder —This builder for method chaining
forCounterAsset()
Returns all trades for the given counter asset.
public
forCounterAsset(Asset $counterAsset) : TradeAggregationsRequestBuilder
Parameters
- $counterAsset : Asset
Return values
TradeAggregationsRequestBuilder —current instance
forEndTime()
public
forEndTime(string $endTime) : TradeAggregationsRequestBuilder
Parameters
- $endTime : string
Return values
TradeAggregationsRequestBuilderforOffset()
public
forOffset(string $offset) : TradeAggregationsRequestBuilder
Parameters
- $offset : string
Return values
TradeAggregationsRequestBuilderforResolution()
public
forResolution(string $resolution) : TradeAggregationsRequestBuilder
Parameters
- $resolution : string
Return values
TradeAggregationsRequestBuilderforStartTime()
public
forStartTime(string $startTime) : TradeAggregationsRequestBuilder
Parameters
- $startTime : string
Return values
TradeAggregationsRequestBuildergetAndStream()
Streams Server-Sent Events from Horizon to a callback function
public
getAndStream(string $relativeUrl, callable $callback[, bool $retryOnServerException = true ]) : void
This method establishes a persistent connection to Horizon's streaming endpoints using Server-Sent Events (SSE). It processes each event and passes the parsed data to the provided callback function. The stream automatically reconnects on server exceptions if retryOnServerException is true.
Horizon streaming uses SSE to push real-time updates. The stream sends:
- "hello" message on connection
- "byebye" message on disconnection
- JSON data objects for actual events
Parameters
- $relativeUrl : string
-
The relative URL to stream from
- $callback : callable
-
Function to receive parsed event data
- $retryOnServerException : bool = true
-
If true, automatically retry on server errors (default: true)
Tags
Return values
void —This method runs indefinitely until interrupted
limit()
Sets <code>limit</code> parameter on the request.
public
limit(int $number) : TradeAggregationsRequestBuilder
It defines maximum number of records to return. For range and default values check documentation of the endpoint requested.
Parameters
- $number : int
-
Maximum number of records to return
Return values
TradeAggregationsRequestBuilderorder()
Sets <code>order</code> parameter on the request.
public
order([string $direction = "asc" ]) : TradeAggregationsRequestBuilder
Parameters
- $direction : string = "asc"
-
"asc" or "desc"
Return values
TradeAggregationsRequestBuilderrequest()
Requests specific <code>url</code> and returns {@link TradeAggregationsPageResponse}.
public
request(string $url) : TradeAggregationsPageResponse
Parameters
- $url : string
Tags
Return values
TradeAggregationsPageResponsesetSegments()
Sets the URL path segments for this request
protected
setSegments(string ...$segments) : RequestBuilder
This method constructs the URL path by combining multiple segments. Can only be called once per request builder instance.
Parameters
- $segments : string
-
Variable number of URL path segments
Tags
Return values
RequestBuilder —This instance for method chaining