Stellar PHP SDK API Documentation

TradeAggregationsRequestBuilder extends RequestBuilder

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
see
TradeAggregationsPageResponse

For the response format

see
https://developers.stellar.org

Stellar developer docs Horizon API Trade Aggregations

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

$queryParameters

protected array<string|int, mixed> $queryParameters

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
see
https://developers.stellar.org

Stellar developer docs Page documentation

Return values
TradeAggregationsRequestBuilder

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
throws
HorizonRequestException

If the request fails or response cannot be parsed

Return values
Response

The parsed response object of the specified type

getAndStream()

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
throws
GuzzleException

If a network error occurs and retryOnServerException is false

Return values
void

This method runs indefinitely until interrupted

setSegments()

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
throws
RuntimeException

If segments have already been set

Return values
RequestBuilder

This instance for method chaining


        
On this page

Search results