- 
- 
- 
- 
+
jsonschema2pojo with special configurations
+ * and generation logic.
+ * @see GenerateJsonSchemaJavaTask
+ */
+class GeneratePOJOsTask extends DefaultTask {
+
+ @ReplacedBy("configurationString")
+ GenerationConfig configuration
+
+ @Input
+ String getConfigurationString() {
+ configuration.toString()
+ }
+
+ @Internal
+ Listjsonschema2pojo Gradle plugin
+ * to add/change some features.
+ */
+class JSONSchema2POJOAdaptedPlugin implements Pluginnullalpaca.properties file (or their
- * associated defaults).
+ * Instantiates a new {@link AlpacaAPI}. Use this constructor if you are using the Trading or Market Data APIs for a
+ * single Alpaca account.
+ *
+ * @param traderKeyID the Trader key ID
+ * @param traderSecretKey the Trader secret key
+ * @param traderAPIEndpointType the {@link TraderAPIEndpointType}
+ * @param marketDataWebsocketSourceType the {@link MarketDataWebsocketSourceType}
*/
- public AlpacaAPI() {
- this(AlpacaProperties.KEY_ID,
- AlpacaProperties.SECRET_KEY,
- AlpacaProperties.ENDPOINT_API_TYPE,
- AlpacaProperties.DATA_API_TYPE);
+ public AlpacaAPI(String traderKeyID, String traderSecretKey, TraderAPIEndpointType traderAPIEndpointType,
+ MarketDataWebsocketSourceType marketDataWebsocketSourceType) {
+ this(traderKeyID, traderSecretKey, null, traderAPIEndpointType, marketDataWebsocketSourceType, null, null, null,
+ null);
}
/**
- * Instantiates a new {@link AlpacaAPI}.
+ * Instantiates a new {@link AlpacaAPI}. Use this constructor if you are using the Trading or Market Data APIs for a
+ * single Alpaca account and a custom {@link OkHttpClient} instance.
*
- * @param keyID the key ID
- * @param secret the secret
+ * @param traderKeyID the Trader key ID
+ * @param traderSecretKey the Trader secret key
+ * @param traderAPIEndpointType the {@link TraderAPIEndpointType}
+ * @param marketDataWebsocketSourceType the {@link MarketDataWebsocketSourceType}
+ * @param okHttpClient an existing {@link OkHttpClient} or null to create a new
+ * default instance
*/
- public AlpacaAPI(String keyID, String secret) {
- this(null, keyID, secret, null,
- AlpacaProperties.ENDPOINT_API_TYPE,
- AlpacaProperties.DATA_API_TYPE);
+ public AlpacaAPI(String traderKeyID, String traderSecretKey, TraderAPIEndpointType traderAPIEndpointType,
+ MarketDataWebsocketSourceType marketDataWebsocketSourceType, OkHttpClient okHttpClient) {
+ this(traderKeyID, traderSecretKey, null, traderAPIEndpointType, marketDataWebsocketSourceType, null, null, null,
+ okHttpClient);
}
/**
- * Instantiates a new {@link AlpacaAPI}.
+ * Instantiates a new {@link AlpacaAPI}. Use this constructor if you are using the Trading API with OAuth to act on
+ * behalf of an Alpaca account.
*
- * @param keyID the key ID
- * @param secret the secret
- * @param endpointAPIType the {@link EndpointAPIType}
- * @param dataAPIType the {@link DataAPIType}
+ * @param traderOAuthToken the Trader OAuth token
+ * @param traderAPIEndpointType the {@link TraderAPIEndpointType}
*/
- public AlpacaAPI(String keyID, String secret, EndpointAPIType endpointAPIType, DataAPIType dataAPIType) {
- this(null, keyID, secret, null, endpointAPIType, dataAPIType);
+ public AlpacaAPI(String traderOAuthToken, TraderAPIEndpointType traderAPIEndpointType) {
+ this(null, null, traderOAuthToken, traderAPIEndpointType, null, null, null, null, null);
}
/**
- * Instantiates a new {@link AlpacaAPI}.
+ * Instantiates a new {@link AlpacaAPI}. Use this constructor if you are using the Trading API with OAuth to act on
+ * behalf of an Alpaca account and a custom {@link OkHttpClient} instance.
+ *
+ * @param traderOAuthToken the Trader OAuth token
+ * @param traderAPIEndpointType the {@link TraderAPIEndpointType}
+ * @param okHttpClient an existing {@link OkHttpClient} or null to create a new default
+ * instance
+ */
+ public AlpacaAPI(String traderOAuthToken, TraderAPIEndpointType traderAPIEndpointType, OkHttpClient okHttpClient) {
+ this(null, null, traderOAuthToken, traderAPIEndpointType, null, null, null, null, okHttpClient);
+ }
+
+ /**
+ * Instantiates a new {@link AlpacaAPI}. Use this constructor if you are using the Broker API.
+ *
+ * @param brokerAPIKey the Broker API key
+ * @param brokerAPISecret the Broker API secret
+ * @param brokerAPIEndpointType the {@link BrokerAPIEndpointType}
+ */
+ public AlpacaAPI(String brokerAPIKey, String brokerAPISecret, BrokerAPIEndpointType brokerAPIEndpointType) {
+ this(null, null, null, null, null, brokerAPIKey, brokerAPISecret, brokerAPIEndpointType, null);
+ }
+
+ /**
+ * Instantiates a new {@link AlpacaAPI}. Use this constructor if you are using the Broker API and a custom
+ * {@link OkHttpClient} instance.
*
- * @param oAuthToken the OAuth token. Note that the Data API v2 does not work with OAuth tokens.
+ * @param brokerAPIKey the Broker API key
+ * @param brokerAPISecret the Broker API secret
+ * @param brokerAPIEndpointType the {@link BrokerAPIEndpointType}
+ * @param okHttpClient an existing {@link OkHttpClient} or null to create a new default
+ * instance
*/
- public AlpacaAPI(String oAuthToken) {
- this(null, null, null, oAuthToken,
- AlpacaProperties.ENDPOINT_API_TYPE,
- AlpacaProperties.DATA_API_TYPE);
+ public AlpacaAPI(String brokerAPIKey, String brokerAPISecret, BrokerAPIEndpointType brokerAPIEndpointType,
+ OkHttpClient okHttpClient) {
+ this(null, null, null, null, null, brokerAPIKey, brokerAPISecret, brokerAPIEndpointType, okHttpClient);
}
/**
* Instantiates a new {@link AlpacaAPI}.
*
- * @param okHttpClient the {@link OkHttpClient} or null to create a default instance
- * @param keyID the key ID
- * @param secretKey the secret key
- * @param oAuthToken the OAuth token
- * @param endpointAPIType the {@link EndpointAPIType}
- * @param dataAPIType the {@link DataAPIType}
+ * @param traderKeyID the Trader key ID
+ * @param traderSecretKey the Trader secret key
+ * @param traderOAuthToken the Trader OAuth token
+ * @param traderAPIEndpointType the {@link TraderAPIEndpointType}
+ * @param marketDataWebsocketSourceType the {@link MarketDataWebsocketSourceType}
+ * @param brokerAPIKey the Broker API key
+ * @param brokerAPISecret the Broker API secret
+ * @param brokerAPIEndpointType the {@link BrokerAPIEndpointType}
+ * @param okHttpClient an existing {@link OkHttpClient} or null to create a new
+ * default instance
*/
- public AlpacaAPI(OkHttpClient okHttpClient, String keyID, String secretKey, String oAuthToken,
- EndpointAPIType endpointAPIType, DataAPIType dataAPIType) {
- checkArgument((keyID != null && secretKey != null) ^ oAuthToken != null,
- "You must specify a (KeyID (%s) and Secret Key (%s)) or an OAuthToken (%s)!",
- keyID, secretKey, oAuthToken);
- checkNotNull(endpointAPIType);
- checkNotNull(dataAPIType);
-
- // Create default 'okHttpClient'
+ public AlpacaAPI(String traderKeyID, String traderSecretKey,
+ String traderOAuthToken, TraderAPIEndpointType traderAPIEndpointType,
+ MarketDataWebsocketSourceType marketDataWebsocketSourceType,
+ String brokerAPIKey, String brokerAPISecret, BrokerAPIEndpointType brokerAPIEndpointType,
+ OkHttpClient okHttpClient) {
+ this.traderKeyID = traderKeyID;
+ this.traderSecretKey = traderSecretKey;
+ this.traderOAuthToken = traderOAuthToken;
+ this.traderAPIEndpointType = traderAPIEndpointType != null ?
+ traderAPIEndpointType : PAPER;
+ this.marketDataWebsocketSourceType = marketDataWebsocketSourceType != null ?
+ marketDataWebsocketSourceType : IEX;
+ this.brokerAPIKey = brokerAPIKey;
+ this.brokerAPISecret = brokerAPISecret;
+ this.brokerAPIEndpointType = brokerAPIEndpointType != null ?
+ brokerAPIEndpointType : SANDBOX;
+
+ // Create default OkHttpClient instance
if (okHttpClient == null) {
- OkHttpClient.Builder clientBuilder = new OkHttpClient.Builder()
- .cache(null); // Ensure response caching is disabled
-
+ final OkHttpClient.Builder clientBuilder = new OkHttpClient.Builder();
if (LOGGER.isDebugEnabled()) {
- clientBuilder.addInterceptor(new HttpLoggingInterceptor(LOGGER));
+ final HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor(LOGGER::debug);
+ loggingInterceptor.setLevel(BODY);
+ clientBuilder.addInterceptor(loggingInterceptor);
}
-
okHttpClient = clientBuilder.build();
}
-
this.okHttpClient = okHttpClient;
-
- String brokerHostSubdomain;
- switch (endpointAPIType) {
- case LIVE:
- brokerHostSubdomain = "api";
- break;
- case PAPER:
- brokerHostSubdomain = "paper-api";
- break;
- default:
- throw new UnsupportedOperationException();
- }
-
- if (oAuthToken == null) {
- brokerClient = new AlpacaClient(okHttpClient, keyID, secretKey,
- brokerHostSubdomain, VERSION_2_PATH_SEGMENT);
- dataClient = new AlpacaClient(okHttpClient, keyID, secretKey, "data", VERSION_2_PATH_SEGMENT);
- marketDataWebsocket = new MarketDataWebsocket(okHttpClient, dataAPIType, keyID, secretKey);
- } else {
- brokerClient = new AlpacaClient(okHttpClient, oAuthToken, brokerHostSubdomain, VERSION_2_PATH_SEGMENT);
- dataClient = null;
- marketDataWebsocket = null;
- }
-
- accountEndpoint = new AccountEndpoint(brokerClient);
- marketDataEndpoint = dataClient == null ? null : new MarketDataEndpoint(dataClient);
- ordersEndpoint = new OrdersEndpoint(brokerClient);
- positionsEndpoint = new PositionsEndpoint(brokerClient);
- assetsEndpoint = new AssetsEndpoint(brokerClient);
- watchlistEndpoint = new WatchlistEndpoint(brokerClient);
- calendarEndpoint = new CalendarEndpoint(brokerClient);
- clockEndpoint = new ClockEndpoint(brokerClient);
- accountConfigurationEndpoint = new AccountConfigurationEndpoint(brokerClient);
- accountActivitiesEndpoint = new AccountActivitiesEndpoint(brokerClient);
- portfolioHistoryEndpoint = new PortfolioHistoryEndpoint(brokerClient);
- streamingWebsocket = new StreamingWebsocket(okHttpClient, brokerHostSubdomain, keyID, secretKey, oAuthToken);
}
/**
- * @return {@link AccountEndpoint}
+ * Gets the {@link OkHttpClient}.
+ *
+ * @return the {@link OkHttpClient}
*/
- public AccountEndpoint account() {
- return accountEndpoint;
+ public OkHttpClient getOkHttpClient() {
+ return okHttpClient;
}
/**
- * @return the {@link MarketDataEndpoint}
+ * Gets the {@link AlpacaTraderAPI}. Lazily instantiated.
+ *
+ * @return the {@link AlpacaTraderAPI}
*/
- public MarketDataEndpoint marketData() {
- return marketDataEndpoint;
+ public synchronized AlpacaTraderAPI trader() {
+ if (trader == null) {
+ trader = new AlpacaTraderAPI(traderKeyID, traderSecretKey, traderOAuthToken, traderAPIEndpointType,
+ okHttpClient);
+ }
+ return trader;
}
/**
- * @return {@link OrdersEndpoint}
+ * Gets the {@link AlpacaMarketDataAPI}. Lazily instantiated.
+ *
+ * @return the {@link AlpacaMarketDataAPI}
*/
- public OrdersEndpoint orders() {
- return ordersEndpoint;
+ public synchronized AlpacaMarketDataAPI marketData() {
+ if (marketData == null) {
+ marketData = new AlpacaMarketDataAPI(traderKeyID, traderSecretKey, brokerAPIKey, brokerAPISecret,
+ okHttpClient);
+ }
+ return marketData;
}
/**
- * @return {@link PositionsEndpoint}
+ * Gets the {@link AlpacaBrokerAPI}. Lazily instantiated.
+ *
+ * @return the {@link AlpacaBrokerAPI}
*/
- public PositionsEndpoint positions() {
- return positionsEndpoint;
+ public synchronized AlpacaBrokerAPI broker() {
+ if (broker == null) {
+ broker = new AlpacaBrokerAPI(brokerAPIKey, brokerAPISecret, brokerAPIEndpointType, okHttpClient);
+ }
+ return broker;
}
/**
- * @return {@link AssetsEndpoint}
+ * Gets the {@link UpdatesWebsocketInterface}. Lazily instantiated.
+ *
+ * @return the {@link UpdatesWebsocketInterface}
*/
- public AssetsEndpoint assets() {
- return assetsEndpoint;
+ public synchronized UpdatesWebsocketInterface updatesStream() {
+ if (updatesWebsocket == null) {
+ updatesWebsocket = new UpdatesWebsocket(okHttpClient, traderAPIEndpointType,
+ traderKeyID, traderSecretKey, traderOAuthToken);
+ }
+ return updatesWebsocket;
}
/**
- * @return {@link WatchlistEndpoint}
+ * Gets the {@link StockMarketDataWebsocketInterface}. Lazily instantiated.
+ *
+ * @return the {@link StockMarketDataWebsocketInterface}
*/
- public WatchlistEndpoint watchlist() {
- return watchlistEndpoint;
+ public synchronized StockMarketDataWebsocketInterface stockMarketDataStream() {
+ if (stockMarketDataWebsocket == null) {
+ stockMarketDataWebsocket = new StockMarketDataWebsocket(okHttpClient,
+ traderKeyID, traderSecretKey, brokerAPIKey, brokerAPISecret, marketDataWebsocketSourceType);
+ }
+ return stockMarketDataWebsocket;
}
/**
- * @return {@link CalendarEndpoint}
+ * Gets the {@link CryptoMarketDataWebsocketInterface}. Lazily instantiated.
+ *
+ * @return the {@link CryptoMarketDataWebsocketInterface}
*/
- public CalendarEndpoint calendar() {
- return calendarEndpoint;
+ public synchronized CryptoMarketDataWebsocketInterface cryptoMarketDataStream() {
+ if (cryptoMarketDataWebsocket == null) {
+ cryptoMarketDataWebsocket = new CryptoMarketDataWebsocket(okHttpClient,
+ traderKeyID, traderSecretKey, brokerAPIKey, brokerAPISecret);
+ }
+ return cryptoMarketDataWebsocket;
}
/**
- * @return {@link ClockEndpoint}
+ * Gets the {@link NewsMarketDataWebsocketInterface}. Lazily instantiated.
+ *
+ * @return the {@link NewsMarketDataWebsocketInterface}
*/
- public ClockEndpoint clock() {
- return clockEndpoint;
+ public synchronized NewsMarketDataWebsocketInterface newsMarketDataStream() {
+ if (newsMarketDataWebsocket == null) {
+ newsMarketDataWebsocket = new NewsMarketDataWebsocket(okHttpClient,
+ traderKeyID, traderSecretKey, brokerAPIKey, brokerAPISecret);
+ }
+ return newsMarketDataWebsocket;
}
/**
- * @return the {@link AccountConfigurationEndpoint}
+ * Creates a {@link Builder} for {@link AlpacaAPI}.
+ *
+ * @return the {@link Builder}
*/
- public AccountConfigurationEndpoint accountConfiguration() {
- return accountConfigurationEndpoint;
+ public static Builder builder() {
+ return new Builder();
}
/**
- * @return the {@link AccountActivitiesEndpoint}
+ * A builder for {@link AlpacaAPI}
*/
- public AccountActivitiesEndpoint accountActivities() {
- return accountActivitiesEndpoint;
- }
+ public static final class Builder {
+
+ private String traderKeyID;
+ private String traderSecretKey;
+ private String traderOAuthToken;
+ private TraderAPIEndpointType traderAPIEndpointType;
+ private MarketDataWebsocketSourceType marketDataWebsocketSourceType;
+ private String brokerAPIKey;
+ private String brokerAPISecret;
+ private BrokerAPIEndpointType brokerAPIEndpointType;
+ private OkHttpClient okHttpClient;
+
+ private Builder() {}
+
+ public Builder withTraderKeyID(String traderKeyID) {
+ this.traderKeyID = traderKeyID;
+ return this;
+ }
- /**
- * @return the {@link PortfolioHistoryEndpoint}
- */
- public PortfolioHistoryEndpoint portfolioHistory() {
- return portfolioHistoryEndpoint;
- }
+ public Builder withTraderSecretKey(String traderSecretKey) {
+ this.traderSecretKey = traderSecretKey;
+ return this;
+ }
- /**
- * @return the {@link StreamingWebsocketInterface}
- */
- public StreamingWebsocketInterface streaming() {
- return streamingWebsocket;
- }
+ public Builder withTraderOAuthToken(String traderOAuthToken) {
+ this.traderOAuthToken = traderOAuthToken;
+ return this;
+ }
- /**
- * @return the {@link MarketDataWebsocketInterface}
- */
- public MarketDataWebsocketInterface marketDataStreaming() {
- return marketDataWebsocket;
- }
+ public Builder withTraderAPIEndpointType(TraderAPIEndpointType traderAPIEndpointType) {
+ this.traderAPIEndpointType = traderAPIEndpointType;
+ return this;
+ }
- /**
- * Gets {@link #okHttpClient}.
- *
- * @return the {@link OkHttpClient}
- */
- public OkHttpClient getOkHttpClient() {
- return okHttpClient;
- }
+ public Builder withMarketDataWebsocketSourceType(MarketDataWebsocketSourceType marketDataWebsocketSourceType) {
+ this.marketDataWebsocketSourceType = marketDataWebsocketSourceType;
+ return this;
+ }
- /**
- * Gets {@link #brokerClient}.
- *
- * @return the broker {@link AlpacaClient}
- */
- public AlpacaClient getBrokerClient() {
- return brokerClient;
- }
+ public Builder withBrokerAPIKey(String brokerAPIKey) {
+ this.brokerAPIKey = brokerAPIKey;
+ return this;
+ }
- /**
- * Gets {@link #dataClient}.
- *
- * @return the data {@link AlpacaClient}
- */
- public AlpacaClient getDataClient() {
- return dataClient;
+ public Builder withBrokerAPISecret(String brokerAPISecret) {
+ this.brokerAPISecret = brokerAPISecret;
+ return this;
+ }
+
+ public Builder withBrokerAPIEndpointType(BrokerAPIEndpointType brokerAPIEndpointType) {
+ this.brokerAPIEndpointType = brokerAPIEndpointType;
+ return this;
+ }
+
+ public Builder withOkHttpClient(OkHttpClient okHttpClient) {
+ this.okHttpClient = okHttpClient;
+ return this;
+ }
+
+ public AlpacaAPI build() {
+ return new AlpacaAPI(traderKeyID, traderSecretKey, traderOAuthToken, traderAPIEndpointType,
+ marketDataWebsocketSourceType, brokerAPIKey, brokerAPISecret, brokerAPIEndpointType, okHttpClient);
+ }
}
}
diff --git a/src/main/java/net/jacobpeterson/alpaca/properties/AlpacaProperties.java b/src/main/java/net/jacobpeterson/alpaca/properties/AlpacaProperties.java
deleted file mode 100644
index 2b8d0b79..00000000
--- a/src/main/java/net/jacobpeterson/alpaca/properties/AlpacaProperties.java
+++ /dev/null
@@ -1,46 +0,0 @@
-package net.jacobpeterson.alpaca.properties;
-
-import net.jacobpeterson.alpaca.AlpacaAPI;
-import net.jacobpeterson.alpaca.model.properties.DataAPIType;
-import net.jacobpeterson.alpaca.model.properties.EndpointAPIType;
-
-import static net.jacobpeterson.alpaca.util.properties.PropertyUtil.getProperty;
-
-/**
- * {@link AlpacaProperties} defines properties for {@link AlpacaAPI}.
- */
-public class AlpacaProperties {
-
- private static final String ALPACA_PROPERTIES_FILE = "alpaca.properties";
- private static final String ALPACA_DEFAULT_PROPERTIES_FILE = "alpaca.default.properties";
-
- private static final String KEY_ID_KEY = "key_id";
- /** The value of {@link #KEY_ID_KEY} in {@link #ALPACA_PROPERTIES_FILE}. */
- public static final String KEY_ID = getProperty(
- ALPACA_PROPERTIES_FILE, ALPACA_DEFAULT_PROPERTIES_FILE,
- KEY_ID_KEY);
-
- private static final String SECRET_KEY_KEY = "secret_key";
- /** The value of {@link #SECRET_KEY_KEY} in {@link #ALPACA_PROPERTIES_FILE}. */
- public static final String SECRET_KEY = getProperty(
- ALPACA_PROPERTIES_FILE, ALPACA_DEFAULT_PROPERTIES_FILE,
- SECRET_KEY_KEY);
-
- private static final String ENDPOINT_API_TYPE_KEY = "endpoint_api_type";
- /** The value of {@link #ENDPOINT_API_TYPE_KEY} in {@link #ALPACA_PROPERTIES_FILE}. */
- public static final EndpointAPIType ENDPOINT_API_TYPE = EndpointAPIType.fromValue(getProperty(
- ALPACA_PROPERTIES_FILE, ALPACA_DEFAULT_PROPERTIES_FILE,
- ENDPOINT_API_TYPE_KEY));
-
- private static final String DATA_API_TYPE_KEY = "data_api_type";
- /** The value of {@link #DATA_API_TYPE_KEY} in {@link #ALPACA_PROPERTIES_FILE}. */
- public static final DataAPIType DATA_API_TYPE = DataAPIType.fromValue(getProperty(
- ALPACA_PROPERTIES_FILE, ALPACA_DEFAULT_PROPERTIES_FILE,
- DATA_API_TYPE_KEY));
-
- private static final String USER_AGENT_KEY = "user_agent";
- /** The value of {@link #USER_AGENT_KEY} in {@link #ALPACA_PROPERTIES_FILE}. */
- public static final String USER_AGENT = getProperty(
- ALPACA_PROPERTIES_FILE, ALPACA_DEFAULT_PROPERTIES_FILE,
- USER_AGENT_KEY);
-}
diff --git a/src/main/java/net/jacobpeterson/alpaca/rest/AlpacaClient.java b/src/main/java/net/jacobpeterson/alpaca/rest/AlpacaClient.java
deleted file mode 100644
index 90e7265a..00000000
--- a/src/main/java/net/jacobpeterson/alpaca/rest/AlpacaClient.java
+++ /dev/null
@@ -1,242 +0,0 @@
-package net.jacobpeterson.alpaca.rest;
-
-import com.google.gson.Gson;
-import com.google.gson.JsonElement;
-import com.google.gson.JsonParser;
-import net.jacobpeterson.alpaca.properties.AlpacaProperties;
-import okhttp3.Headers;
-import okhttp3.HttpUrl;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
-
-import java.io.IOException;
-import java.io.Reader;
-import java.lang.reflect.Type;
-import java.util.function.Predicate;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-import static com.google.common.base.Preconditions.checkState;
-import static net.jacobpeterson.alpaca.util.gson.GsonUtil.GSON;
-
-/**
- * {@link AlpacaClient} represents an HTTP RestAPI client for Alpaca.
- */
-public class AlpacaClient {
-
- private final OkHttpClient okHttpClient;
- private final HttpUrl baseURL;
- private final Headers requestHeaders;
-
- /**
- * Instantiates a new {@link AlpacaClient}.
- *
- * @param okHttpClient the {@link OkHttpClient}
- * @param keyID the key ID
- * @param secretKey the secret key
- * @param alpacaSubdomain the Alpaca subdomain
- * @param versionPathSegment the version path segment e.g. "v2"
- */
- public AlpacaClient(OkHttpClient okHttpClient, String keyID, String secretKey, String alpacaSubdomain,
- String versionPathSegment) {
- this(okHttpClient, keyID, secretKey, null, alpacaSubdomain, versionPathSegment);
- }
-
- /**
- * Instantiates a new {@link AlpacaClient}.
- *
- * @param okHttpClient the {@link OkHttpClient}
- * @param oAuthToken the OAuth token
- * @param alpacaSubdomain the Alpaca subdomain
- * @param versionPathSegment the version path segment e.g. "v2"
- */
- public AlpacaClient(OkHttpClient okHttpClient, String oAuthToken, String alpacaSubdomain,
- String versionPathSegment) {
- this(okHttpClient, null, null, oAuthToken, alpacaSubdomain, versionPathSegment);
- }
-
- /**
- * Instantiates a new {@link AlpacaClient}.
- *
- * @param okHttpClient the {@link OkHttpClient}
- * @param keyID the key ID
- * @param secretKey the secret key
- * @param oAuthToken the OAuth token
- * @param alpacaSubdomain the Alpaca subdomain
- * @param versionPathSegment the version path segment e.g. "v2"
- */
- protected AlpacaClient(OkHttpClient okHttpClient, String keyID, String secretKey, String oAuthToken,
- String alpacaSubdomain, String versionPathSegment) {
- checkNotNull(okHttpClient);
- checkNotNull(alpacaSubdomain);
- checkNotNull(versionPathSegment);
-
- this.okHttpClient = okHttpClient;
-
- baseURL = new HttpUrl.Builder()
- .scheme("https")
- .host(alpacaSubdomain + ".alpaca.markets")
- .addPathSegment(versionPathSegment)
- .build();
-
- Headers.Builder requestHeadersBuilder = new Headers.Builder();
- requestHeadersBuilder.add("User-Agent", AlpacaProperties.USER_AGENT);
- if (oAuthToken != null) {
- requestHeadersBuilder.add("Authorization", "Bearer " + oAuthToken);
- } else {
- requestHeadersBuilder
- .add("APCA-API-KEY-ID", keyID)
- .add("APCA-API-SECRET-KEY", secretKey);
- }
- requestHeaders = requestHeadersBuilder.build();
- }
-
- /**
- * Gets a new {@link okhttp3.HttpUrl.Builder}.
- *
- * @return a {@link okhttp3.HttpUrl.Builder}
- */
- public HttpUrl.Builder urlBuilder() {
- return baseURL.newBuilder();
- }
-
- /**
- * Gets a new {@link okhttp3.Request.Builder} with {@link #requestHeaders}.
- *
- * @param httpUrl the {@link okhttp3.HttpUrl}
- *
- * @return a {@link okhttp3.Request.Builder}
- */
- public Request.Builder requestBuilder(HttpUrl httpUrl) {
- return new Request.Builder().headers(requestHeaders).url(httpUrl);
- }
-
- /**
- * Calls {@link #requestObject(Request, Predicate, Type)} with a success code of 200.
- */
- public T requestObject(Request request, Type type) throws AlpacaClientException {
- return requestObject(request, (code) -> code == 200, type);
- }
-
- /**
- * Requests an object given a {@link Request} that is deserialized via {@link Gson#fromJson(Reader, Type)}.
- *
- * @param the type of object
- * @param request the {@link Request}
- * @param isSuccessCode throws {@link AlpacaClientException} if passed in {@link Response#code()} to the {@link
- * Predicate#test(Object)} returns false
- * @param type the object {@link Type}
- *
- * @return the requested object
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- */
- public T requestObject(Request request, Predicate isSuccessCode, Type type)
- throws AlpacaClientException {
- return GSON.fromJson(requestJSON(request, isSuccessCode), type);
- }
-
- /**
- * Calls {@link #requestJSON(Request, Predicate)} with a success code of 200.
- */
- public JsonElement requestJSON(Request request) throws AlpacaClientException {
- return requestJSON(request, (code) -> code == 200);
- }
-
- /**
- * Requests a {@link JsonElement} given a {@link Request}.
- *
- * @param request the {@link Request}
- * @param isSuccessCode throws {@link AlpacaClientException} if passed in {@link Response#code()} to the {@link
- * Predicate#test(Object)} returns false
- *
- * @return the {@link JsonElement}
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- */
- public JsonElement requestJSON(Request request, Predicate isSuccessCode) throws AlpacaClientException {
- try (Response response = request(request, isSuccessCode)) {
- try (ResponseBody responseBody = response.body()) {
- // Throw exception if 'responseBody' is ever null since we never want to use cachedResponse or
- // other types of responses.
- checkState(responseBody != null);
-
- try (Reader charStream = responseBody.charStream()) {
- return JsonParser.parseReader(charStream);
- } catch (IOException ioException) {
- throw new AlpacaClientException(ioException);
- }
- }
- }
- }
-
- /**
- * Sends a {@link Request} and ignores any {@link ResponseBody}.
- *
- * @param request the {@link Request}
- * @param isSuccessCode throws {@link AlpacaClientException} if passed in {@link Response#code()} to the {@link
- * Predicate#test(Object)} returns false
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- */
- public void requestVoid(Request request, Predicate isSuccessCode) throws AlpacaClientException {
- // close() will throw an exception if cachedResponse or others were used which is fine
- // since we never want to use those types of responses.
- request(request, isSuccessCode).close();
- }
-
- /**
- * Sends a {@link Request} and returns a {@link Response}.
- *
- * @param request the {@link Request}
- * @param isSuccessCode throws {@link AlpacaClientException} if passed in {@link Response#code()} to the {@link
- * Predicate#test(Object)} returns false
- *
- * @return the {@link Response}. Be sure to call {@link Response#close()} after use.
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- */
- public Response request(Request request, Predicate isSuccessCode) throws AlpacaClientException {
- try {
- Response response = executeRequest(request);
- if (!isSuccessCode.test(response.code())) {
- throw new AlpacaClientException(response);
- }
- return response;
- } catch (IOException ioException) {
- throw new AlpacaClientException(ioException);
- }
- }
-
- /**
- * Executes a {@link Request}.
- *
- * @param request the {@link Request}
- *
- * @return the {@link Response}. Be sure to call {@link Response#close()} after use.
- *
- * @throws IOException thrown for {@link IOException}s
- */
- public Response executeRequest(Request request) throws IOException {
- return okHttpClient.newCall(request).execute();
- }
-
- /**
- * Gets {@link #baseURL}.
- *
- * @return the base {@link HttpUrl}
- */
- public HttpUrl getBaseURL() {
- return baseURL;
- }
-
- /**
- * Gets {@link #requestHeaders}.
- *
- * @return the request {@link Headers}
- */
- public Headers getRequestHeaders() {
- return requestHeaders;
- }
-}
diff --git a/src/main/java/net/jacobpeterson/alpaca/rest/AlpacaClientException.java b/src/main/java/net/jacobpeterson/alpaca/rest/AlpacaClientException.java
deleted file mode 100644
index 40ef1d6c..00000000
--- a/src/main/java/net/jacobpeterson/alpaca/rest/AlpacaClientException.java
+++ /dev/null
@@ -1,160 +0,0 @@
-package net.jacobpeterson.alpaca.rest;
-
-import com.google.gson.JsonElement;
-import com.google.gson.JsonObject;
-import com.google.gson.JsonParser;
-import okhttp3.Response;
-import okhttp3.ResponseBody;
-
-public class AlpacaClientException extends Exception {
-
- private static final String CODE_KEY = "code";
- private static final String MESSAGE_KEY = "message";
-
- private String responseBody;
- private Integer responseStatusCode;
- private String responseStatusMessage;
- private Integer apiResponseCode;
- private String apiResponseMessage;
-
- /**
- * Instantiates a new {@link AlpacaClientException}.
- *
- * @param message the message
- */
- public AlpacaClientException(String message) {
- super(message);
- }
-
- /**
- * Instantiates a new {@link AlpacaClientException}.
- *
- * @param cause the cause {@link Throwable}
- */
- public AlpacaClientException(Throwable cause) {
- super(cause);
- }
-
- /**
- * Instantiates a new {@link AlpacaClientException}.
- *
- * @param message the message
- * @param cause the cause {@link Throwable}
- */
- public AlpacaClientException(String message, Throwable cause) {
- super(message, cause);
- }
-
- /**
- * Instantiates a new {@link AlpacaClientException}.
- *
- * @param response the {@link Response} containing an API response code and message JSON
- */
- protected AlpacaClientException(Response response) {
- responseStatusCode = response.code();
- responseStatusMessage = response.message();
-
- try (ResponseBody clientResponseBody = response.body()) {
- if (clientResponseBody != null) {
- this.responseBody = clientResponseBody.string();
- }
- } catch (Exception ignored) {}
- }
-
- @Override
- public String getMessage() {
- if (responseBody == null) {
- return super.getMessage();
- } else {
- try {
- return parseAPIErrorResponse();
- } catch (Exception ignored) {
- return super.getMessage();
- }
- }
- }
-
- /**
- * Parses an API error response of the following format:
- *
- * {
- * "code": 505,
- * "message": "Error message"
- * }
- *
- * and sets {@link #apiResponseCode} and {@link #apiResponseMessage} accordingly.
- *
- * @return a formatted message of the error response
- */
- private String parseAPIErrorResponse() {
- JsonElement responseJsonElement = JsonParser.parseString(responseBody);
-
- if (responseJsonElement instanceof JsonObject) {
- JsonObject responseJsonObject = responseJsonElement.getAsJsonObject();
-
- if (responseJsonObject.has(CODE_KEY)) {
- apiResponseCode = responseJsonObject.get(CODE_KEY).getAsInt();
- }
-
- if (responseJsonObject.has(MESSAGE_KEY)) {
- apiResponseMessage = responseJsonObject.get(MESSAGE_KEY).getAsString();
- }
- }
-
- // Just use the response JSON if the message could not be parsed.
- if (apiResponseMessage == null) {
- apiResponseMessage = responseJsonElement.toString();
- }
-
- // Build message
- StringBuilder messageBuilder = new StringBuilder();
- messageBuilder.append("Status Code: ").append(responseStatusCode);
- messageBuilder.append(", Status Message: \"").append(responseStatusMessage).append("\"");
-
- if (apiResponseCode != null) {
- messageBuilder.append(", API Response Code: ").append(apiResponseCode);
- }
-
- if (apiResponseMessage != null) {
- messageBuilder.append(", API Response Message: \"").append(apiResponseMessage).append("\"");
- }
-
- return messageBuilder.toString();
- }
-
- /**
- * Gets the {@link #responseStatusCode}.
- *
- * @return an {@link Integer}
- */
- public Integer getResponseStatusCode() {
- return responseStatusCode;
- }
-
- /**
- * Gets the {@link #responseStatusMessage}.
- *
- * @return a {@link String}
- */
- public String getResponseStatusMessage() {
- return responseStatusMessage;
- }
-
- /**
- * Gets the {@link #apiResponseCode}.
- *
- * @return an {@link Integer}
- */
- public Integer getAPIResponseCode() {
- return apiResponseCode;
- }
-
- /**
- * Gets the {@link #apiResponseMessage}.
- *
- * @return a {@link String}
- */
- public String getAPIResponseMessage() {
- return apiResponseMessage;
- }
-}
diff --git a/src/main/java/net/jacobpeterson/alpaca/rest/broker/AlpacaBrokerAPI.java b/src/main/java/net/jacobpeterson/alpaca/rest/broker/AlpacaBrokerAPI.java
new file mode 100644
index 00000000..cfbd3e75
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/rest/broker/AlpacaBrokerAPI.java
@@ -0,0 +1,338 @@
+package net.jacobpeterson.alpaca.rest.broker;
+
+import com.google.gson.JsonElement;
+import net.jacobpeterson.alpaca.model.util.apitype.BrokerAPIEndpointType;
+import net.jacobpeterson.alpaca.openapi.broker.ApiClient;
+import net.jacobpeterson.alpaca.openapi.broker.api.AccountsApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.AssetsApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.CalendarApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.ClockApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.CorporateActionsApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.CountryInfoApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.DocumentsApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.FundingApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.FundingWalletsApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.JournalsApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.KycApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.LogosApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.OAuthApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.RebalancingApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.ReportingApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.TradingApi;
+import net.jacobpeterson.alpaca.openapi.broker.api.WatchlistApi;
+import net.jacobpeterson.alpaca.openapi.broker.model.AdminActionLegacyNote;
+import net.jacobpeterson.alpaca.openapi.broker.model.AdminActionLiquidation;
+import net.jacobpeterson.alpaca.openapi.broker.model.AdminActionTransactionCancel;
+import net.jacobpeterson.alpaca.openapi.broker.model.JNLC;
+import net.jacobpeterson.alpaca.openapi.broker.model.JNLS;
+import net.jacobpeterson.alpaca.openapi.broker.model.NonTradeActivity;
+import net.jacobpeterson.alpaca.openapi.broker.model.TradeActivity;
+import net.jacobpeterson.alpaca.rest.broker.events.EventsApiSSE;
+import okhttp3.OkHttpClient;
+
+import java.util.function.BiFunction;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+import static net.jacobpeterson.alpaca.util.apikey.APIKeyUtil.createBrokerAPIAuthKey;
+
+/**
+ * {@link AlpacaBrokerAPI} is the class used to interface with the Alpaca Broker API endpoints. This class is
+ * thread-safe.
+ */
+public class AlpacaBrokerAPI {
+
+ // Set validation predicates for 'anyOf' and 'oneOf' models
+ static {
+ // 'AccountsApi' models
+ TradeActivity.isValid = jsonElement -> jsonElement.getAsJsonObject().has("type");
+ NonTradeActivity.isValid = jsonElement -> !jsonElement.getAsJsonObject().has("type");
+
+ // 'JournalsApi' models
+ final BiFunction transferPredicate = (jnlc, jsonElement) -> {
+ final String entryType = jsonElement.getAsJsonObject().get("entry_type").getAsString();
+ return jnlc ? entryType.equals("JNLC") : entryType.equals("JNLS");
+ };
+ JNLS.isValid = jsonElement -> transferPredicate.apply(true, jsonElement);
+ JNLC.isValid = jsonElement -> transferPredicate.apply(false, jsonElement);
+
+ // 'EventsApi' models
+ AdminActionLegacyNote.isValid = jsonElement -> jsonElement.getAsJsonObject()
+ .get("type").getAsString().contains("note_admin_event");
+ AdminActionLiquidation.isValid = jsonElement -> jsonElement.getAsJsonObject()
+ .get("type").getAsString().equals("liquidation_admin_event");
+ AdminActionTransactionCancel.isValid = jsonElement -> jsonElement.getAsJsonObject()
+ .get("type").getAsString().equals("transaction_cancel_admin_event");
+ }
+
+ private final ApiClient apiClient;
+ private AccountsApi accounts;
+ private AssetsApi assets;
+ private CalendarApi calendar;
+ private ClockApi clock;
+ private CorporateActionsApi corporateActions;
+ private CountryInfoApi countryInfo;
+ private DocumentsApi documents;
+ private EventsApiSSE events;
+ private FundingApi funding;
+ private FundingWalletsApi fundingWallets;
+ private JournalsApi journals;
+ private KycApi kyc;
+ private LogosApi logos;
+ private OAuthApi oAuth;
+ private RebalancingApi rebalancing;
+ private ReportingApi reporting;
+ private TradingApi trading;
+ private WatchlistApi watchlist;
+
+ /**
+ * Instantiates a new {@link AlpacaBrokerAPI}.
+ *
+ * @param brokerAPIKey the Broker API key
+ * @param brokerAPISecret the Broker API secret
+ * @param brokerAPIEndpointType the {@link BrokerAPIEndpointType}
+ * @param okHttpClient an existing {@link OkHttpClient} or null to create a new default
+ * instance
+ */
+ @SuppressWarnings("UnnecessaryDefault")
+ public AlpacaBrokerAPI(String brokerAPIKey, String brokerAPISecret, BrokerAPIEndpointType brokerAPIEndpointType,
+ OkHttpClient okHttpClient) {
+ checkNotNull(brokerAPIKey);
+ checkNotNull(brokerAPISecret);
+ checkNotNull(brokerAPIEndpointType);
+ checkNotNull(okHttpClient);
+
+ apiClient = new ApiClient(okHttpClient);
+ apiClient.setServerIndex(switch (brokerAPIEndpointType) {
+ case SANDBOX -> 0;
+ case PRODUCTION -> 1;
+ default -> throw new UnsupportedOperationException();
+ });
+ apiClient.addDefaultHeader("Authorization", "Basic " +
+ createBrokerAPIAuthKey(brokerAPIKey, brokerAPISecret));
+ }
+
+ /**
+ * Gets the internal {@link ApiClient}.
+ *
+ * @return the {@link ApiClient}
+ */
+ public ApiClient getInternalAPIClient() {
+ return apiClient;
+ }
+
+ /**
+ * Gets the {@link AccountsApi}. Lazily instantiated.
+ *
+ * @return the {@link AccountsApi}
+ */
+ public synchronized AccountsApi accounts() {
+ if (accounts == null) {
+ accounts = new AccountsApi(apiClient);
+ }
+ return accounts;
+ }
+
+ /**
+ * Gets the {@link AssetsApi}. Lazily instantiated.
+ *
+ * @return the {@link AssetsApi}
+ */
+ public synchronized AssetsApi assets() {
+ if (assets == null) {
+ assets = new AssetsApi(apiClient);
+ }
+ return assets;
+ }
+
+ /**
+ * Gets the {@link CalendarApi}. Lazily instantiated.
+ *
+ * @return the {@link CalendarApi}
+ */
+ public synchronized CalendarApi calendar() {
+ if (calendar == null) {
+ calendar = new CalendarApi(apiClient);
+ }
+ return calendar;
+ }
+
+ /**
+ * Gets the {@link ClockApi}. Lazily instantiated.
+ *
+ * @return the {@link ClockApi}
+ */
+ public synchronized ClockApi clock() {
+ if (clock == null) {
+ clock = new ClockApi(apiClient);
+ }
+ return clock;
+ }
+
+ /**
+ * Gets the {@link CorporateActionsApi}. Lazily instantiated.
+ *
+ * @return the {@link CorporateActionsApi}
+ */
+ public synchronized CorporateActionsApi corporateActions() {
+ if (corporateActions == null) {
+ corporateActions = new CorporateActionsApi(apiClient);
+ }
+ return corporateActions;
+ }
+
+ /**
+ * Gets the {@link CountryInfoApi}. Lazily instantiated.
+ *
+ * @return the {@link CountryInfoApi}
+ */
+ public synchronized CountryInfoApi countryInfo() {
+ if (countryInfo == null) {
+ countryInfo = new CountryInfoApi(apiClient);
+ }
+ return countryInfo;
+ }
+
+ /**
+ * Gets the {@link DocumentsApi}. Lazily instantiated.
+ *
+ * @return the {@link DocumentsApi}
+ */
+ public synchronized DocumentsApi documents() {
+ if (documents == null) {
+ documents = new DocumentsApi(apiClient);
+ }
+ return documents;
+ }
+
+ /**
+ * Gets the {@link EventsApiSSE}. Lazily instantiated.
+ *
+ * @return the {@link EventsApiSSE}
+ */
+ public synchronized EventsApiSSE events() {
+ if (events == null) {
+ events = new EventsApiSSE(apiClient);
+ }
+ return events;
+ }
+
+ /**
+ * Gets the {@link FundingApi}. Lazily instantiated.
+ *
+ * @return the {@link FundingApi}
+ */
+ public synchronized FundingApi funding() {
+ if (funding == null) {
+ funding = new FundingApi(apiClient);
+ }
+ return funding;
+ }
+
+ /**
+ * Gets the {@link FundingWalletsApi}. Lazily instantiated.
+ *
+ * @return the {@link FundingWalletsApi}
+ */
+ public synchronized FundingWalletsApi fundingWallets() {
+ if (fundingWallets == null) {
+ fundingWallets = new FundingWalletsApi(apiClient);
+ }
+ return fundingWallets;
+ }
+
+ /**
+ * Gets the {@link JournalsApi}. Lazily instantiated.
+ *
+ * @return the {@link JournalsApi}
+ */
+ public synchronized JournalsApi journals() {
+ if (journals == null) {
+ journals = new JournalsApi(apiClient);
+ }
+ return journals;
+ }
+
+ /**
+ * Gets the {@link KycApi}. Lazily instantiated.
+ *
+ * @return the {@link KycApi}
+ */
+ public synchronized KycApi kyc() {
+ if (kyc == null) {
+ kyc = new KycApi(apiClient);
+ }
+ return kyc;
+ }
+
+ /**
+ * Gets the {@link LogosApi}. Lazily instantiated.
+ *
+ * @return the {@link LogosApi}
+ */
+ public synchronized LogosApi logos() {
+ if (logos == null) {
+ logos = new LogosApi(apiClient);
+ }
+ return logos;
+ }
+
+ /**
+ * Gets the {@link OAuthApi}. Lazily instantiated.
+ *
+ * @return the {@link OAuthApi}
+ */
+ public synchronized OAuthApi oAuth() {
+ if (oAuth == null) {
+ oAuth = new OAuthApi(apiClient);
+ }
+ return oAuth;
+ }
+
+ /**
+ * Gets the {@link RebalancingApi}. Lazily instantiated.
+ *
+ * @return the {@link RebalancingApi}
+ */
+ public synchronized RebalancingApi rebalancing() {
+ if (rebalancing == null) {
+ rebalancing = new RebalancingApi(apiClient);
+ }
+ return rebalancing;
+ }
+
+ /**
+ * Gets the {@link ReportingApi}. Lazily instantiated.
+ *
+ * @return the {@link ReportingApi}
+ */
+ public synchronized ReportingApi reporting() {
+ if (reporting == null) {
+ reporting = new ReportingApi(apiClient);
+ }
+ return reporting;
+ }
+
+ /**
+ * Gets the {@link TradingApi}. Lazily instantiated.
+ *
+ * @return the {@link TradingApi}
+ */
+ public synchronized TradingApi trading() {
+ if (trading == null) {
+ trading = new TradingApi(apiClient);
+ }
+ return trading;
+ }
+
+ /**
+ * Gets the {@link WatchlistApi}. Lazily instantiated.
+ *
+ * @return the {@link WatchlistApi}
+ */
+ public synchronized WatchlistApi watchlist() {
+ if (watchlist == null) {
+ watchlist = new WatchlistApi(apiClient);
+ }
+ return watchlist;
+ }
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/rest/broker/events/EventsApiSSE.java b/src/main/java/net/jacobpeterson/alpaca/rest/broker/events/EventsApiSSE.java
new file mode 100644
index 00000000..2c18b5ff
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/rest/broker/events/EventsApiSSE.java
@@ -0,0 +1,190 @@
+package net.jacobpeterson.alpaca.rest.broker.events;
+
+import com.google.gson.reflect.TypeToken;
+import net.jacobpeterson.alpaca.openapi.broker.ApiClient;
+import net.jacobpeterson.alpaca.openapi.broker.ApiException;
+import net.jacobpeterson.alpaca.openapi.broker.api.EventsApi;
+import net.jacobpeterson.alpaca.openapi.broker.model.AccountStatusEvent;
+import net.jacobpeterson.alpaca.openapi.broker.model.JournalStatusEvent;
+import net.jacobpeterson.alpaca.openapi.broker.model.NonTradeActivityEvent;
+import net.jacobpeterson.alpaca.openapi.broker.model.SubscribeToAdminActionSSE200ResponseInner;
+import net.jacobpeterson.alpaca.openapi.broker.model.TradeUpdateEvent;
+import net.jacobpeterson.alpaca.openapi.broker.model.TradeUpdateEventV2;
+import net.jacobpeterson.alpaca.openapi.broker.model.TransferStatusEvent;
+import net.jacobpeterson.alpaca.util.sse.SSEListener;
+import net.jacobpeterson.alpaca.util.sse.SSERequest;
+import okhttp3.Request;
+import okhttp3.Response;
+import okhttp3.sse.EventSource;
+import okhttp3.sse.EventSourceListener;
+import okhttp3.sse.EventSources;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.lang.reflect.Type;
+import java.time.LocalDate;
+import java.time.OffsetDateTime;
+import java.util.UUID;
+
+import static java.util.concurrent.TimeUnit.SECONDS;
+import static net.jacobpeterson.alpaca.openapi.broker.JSON.getGson;
+
+/**
+ * {@link EventsApiSSE} add SSE support to {@link EventsApi}.
+ */
+public class EventsApiSSE {
+
+ private static final Logger LOGGER = LoggerFactory.getLogger(EventsApiSSE.class);
+
+ private final EventsApi eventsAPI;
+ private final EventSource.Factory eventSourceFactory;
+
+ /**
+ * Instantiates a new {@link EventsApiSSE}.
+ *
+ * @param apiClient the api client
+ */
+ public EventsApiSSE(ApiClient apiClient) {
+ eventsAPI = new EventsApi(apiClient);
+ eventSourceFactory = EventSources.createFactory(apiClient.getHttpClient().newBuilder() // Shallow clone
+ .readTimeout(0, SECONDS)
+ .writeTimeout(0, SECONDS)
+ .build());
+ }
+
+ /**
+ * See {@link EventsApi#getV1EventsNta(String, String, String, Integer, Integer, String, String, Boolean, UUID)}.
+ *
+ * @return a {@link SSERequest}
+ */
+ public SSERequest subscribeToNonTradingActivitiesEvents(String id, String since, String until, Integer sinceId,
+ Integer untilId, String sinceUlid, String untilUlid, Boolean includePreprocessing, UUID groupId,
+ SSEListener if this websocket is connected, false otherwise.
*
* @return a boolean
*/
boolean isConnected();
/**
- * Returns true if this websocket is authenticated.
+ * Returns true if this websocket is authenticated, false otherwise.
*
* @return a boolean
*/
boolean isAuthenticated();
+ /**
+ * Returns true if {@link #isConnected()} and {@link #isAuthenticated()}, false
+ * otherwise.
+ *
+ * @return a boolean
+ */
+ default boolean isValid() {
+ return isConnected() && isAuthenticated();
+ }
+
/**
* Gets a {@link Boolean} {@link Future} that completes when an authentication message that is received after a new
* websocket connection indicates successful authentication.
+ * false.
+ * Waits for {@link #getAuthorizationFuture()} to complete and returns its value, except when timeout
+ * time has elapsed, then this will return false.
+ *
+ * @param timeout the timeout time
+ * @param unit the timeout {@link TimeUnit}
*
* @return a boolean
*/
- default boolean waitForAuthorization() {
+ default boolean waitForAuthorization(long timeout, TimeUnit unit) {
try {
- return getAuthorizationFuture().get(10, TimeUnit.SECONDS);
+ return getAuthorizationFuture().get(timeout, unit);
} catch (InterruptedException | ExecutionException | TimeoutException ignored) {}
return false;
}
/**
- * True if {@link #isConnected()} and {@link #isAuthenticated()}.
+ * Sets the {@link AlpacaWebsocketStateListener}.
+ *
+ * @param alpacaWebsocketStateListener the {@link AlpacaWebsocketStateListener}
+ */
+ void setAlpacaWebsocketStateListener(AlpacaWebsocketStateListener alpacaWebsocketStateListener);
+
+ /**
+ * Returns true if this websocket automatically reconnects, false otherwise.
*
* @return a boolean
*/
- default boolean isValid() {
- return isConnected() && isAuthenticated();
- }
+ boolean doesAutomaticallyReconnect();
/**
- * Sets the {@link AlpacaWebsocketMessageListener} for this {@link AlpacaWebsocketInterface}.
+ * Sets whether to automatically reconnect and reauthenticate on a websocket failure. true by default.
*
- * @param listener the {@link AlpacaWebsocketMessageListener}
+ * @param automaticallyReconnect true to automatically reconnect, false otherwise
*/
- void setListener(L listener);
+ void setAutomaticallyReconnect(boolean automaticallyReconnect);
}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/AlpacaWebsocketMessageListener.java b/src/main/java/net/jacobpeterson/alpaca/websocket/AlpacaWebsocketMessageListener.java
deleted file mode 100644
index da55535c..00000000
--- a/src/main/java/net/jacobpeterson/alpaca/websocket/AlpacaWebsocketMessageListener.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package net.jacobpeterson.alpaca.websocket;
-
-/**
- * {@link AlpacaWebsocketMessageListener} defines a listener interface for messages from an {@link AlpacaWebsocket}
- * instances.
- *
- * @param dataAPIType.
- *
- * @param dataAPIType the {@link DataAPIType}
- *
- * @return a {@link HttpUrl}
- */
- private static HttpUrl createWebsocketURL(DataAPIType dataAPIType) {
- return new HttpUrl.Builder()
- .scheme("https") // HttpUrl.Builder doesn't recognize "wss" scheme, but "https" works fine
- .host("stream.data.alpaca.markets")
- .addPathSegment("v2")
- .addPathSegment(dataAPIType.toString())
- .build();
- }
-
- private final Setnull.
+ * Whether the given messageType is "success".
+ *
+ * @param messageType the message type
*
- * @param marketDataMessageType the {@link MarketDataMessageType}
- * @param newSubscribedSymbols the new subscribed symbols from {@link SubscriptionsMessage}
- * @param currentSubscribeSymbols the currently subscribe symbols {@link Set}
+ * @return a boolean
*/
- private void handleSubscriptionMessageList(MarketDataMessageType marketDataMessageType,
- CollectionmessageType is "error".
*
- * @param errorMessage the {@link ErrorMessage}
+ * @param messageType the message type
*
* @return a boolean
*/
- private boolean isErrorMessageAuthFailure(ErrorMessage errorMessage) {
- return AUTH_FAILURE_MESSAGES.contains(errorMessage.getMessage().toLowerCase());
- }
-
- @Override
- public void subscribeToControl(MarketDataMessageType... marketDataMessageTypes) {
- if (marketDataMessageTypes == null) {
- return;
- }
-
- Arrays.stream(marketDataMessageTypes)
- .filter(not(SUBSCRIBABLE_MARKET_DATA_MESSAGE_TYPES::contains))
- .forEach(listenedMarketDataMessageTypes::add);
- }
-
- @Override
- public void subscribe(CollectionmessageType is "subscription".
*
- * @param tradeSymbols a {@link Collection} of symbols to update for trades or null for no change
- * @param quoteSymbols a {@link Collection} of symbols to update for quotes or null for no change
- * @param barSymbols a {@link Collection} of symbols to update for bars or null for no change
- * @param subscribe true to subscribe, false to unsubscribe
+ * @param messageType the message type
+ *
+ * @return a boolean
*/
- private void sendSubscriptionUpdate(Collectionsymbols to subscriptionUpdateObject with elementKey if not empty.
+ * Calls the {@link #listener} with a {@link MarketDataMessage} from a {@link JsonObject}.
*
- * @param subscriptionUpdateObject the subscription update {@link JsonObject}
- * @param elementKey the element key
- * @param symbols the symbols {@link Collection}
+ * @param messageType the message type
+ * @param messageObject the message {@link JsonObject}
*/
- private void addSubscriptionUpdateList(JsonObject subscriptionUpdateObject, String elementKey,
- Collectionnull for no change
- * @param quoteSymbols a {@link Collection} of symbols to subscribe to quotes or null for no change
- * @param barSymbols a {@link Collection} of symbols to subscribe to bars or null for no change
- *
- * @see #unsubscribe(Collection, Collection, Collection)
- */
- void subscribe(Collectionnull for no
- * change
- * @param quoteSymbols a {@link Collection} of symbols to unsubscribe from quotes or null for no
- * change
- * @param barSymbols a {@link Collection} of symbols to unsubscribe from bars or null for no change
- *
- * @see #subscribe(Collection, Collection, Collection)
- */
- void unsubscribe(Collectionsymbols to {@link CryptoMarketDataMessageType#TRADES}. This will remove all
+ * previous {@link CryptoMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setTradeSubscriptions(Setsymbols to {@link CryptoMarketDataMessageType#QUOTES}. This will remove all
+ * previous {@link CryptoMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setQuoteSubscriptions(Setsymbols to {@link CryptoMarketDataMessageType#MINUTE_BARS}. This will remove
+ * all previous {@link CryptoMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setMinuteBarSubscriptions(Setsymbols to {@link CryptoMarketDataMessageType#DAILY_BARS}. This will remove all
+ * previous {@link CryptoMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setDailyBarSubscriptions(Setsymbols to {@link CryptoMarketDataMessageType#UPDATED_BARS}. This will remove
+ * all previous {@link CryptoMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setUpdatedBarSubscriptions(Setsymbols to {@link CryptoMarketDataMessageType#ORDER_BOOKS}. This will remove
+ * all previous {@link CryptoMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setOrderBookSubscriptions(Settrue for the first message and false for subsequent messages."
+ }
+ }
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/quote/crypto_quote_message.json b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/quote/crypto_quote_message.json
new file mode 100644
index 00000000..d314de7a
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/quote/crypto_quote_message.json
@@ -0,0 +1,38 @@
+{
+ "type": "object",
+ "extends": {
+ "existingJavaType": "net.jacobpeterson.alpaca.model.websocket.marketdata.streams.crypto.model.CryptoMarketDataMessage"
+ },
+ "properties": {
+ "S": {
+ "existingJavaType": "java.lang.String",
+ "javaName": "symbol",
+ "title": "The symbol."
+ },
+ "ap": {
+ "existingJavaType": "java.lang.Double",
+ "javaName": "askPrice",
+ "title": "The ask price."
+ },
+ "as": {
+ "existingJavaType": "java.lang.Double",
+ "javaName": "askSize",
+ "title": "The ask size."
+ },
+ "bp": {
+ "existingJavaType": "java.lang.Double",
+ "javaName": "bidPrice",
+ "title": "The bid price."
+ },
+ "bs": {
+ "existingJavaType": "java.lang.Double",
+ "javaName": "bidSize",
+ "title": "The bid size."
+ },
+ "t": {
+ "existingJavaType": "java.time.OffsetDateTime",
+ "javaName": "timestamp",
+ "title": "The timestamp with nanosecond precision."
+ }
+ }
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/trade/crypto_trade_message.json b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/trade/crypto_trade_message.json
new file mode 100644
index 00000000..13118dd7
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/trade/crypto_trade_message.json
@@ -0,0 +1,38 @@
+{
+ "type": "object",
+ "extends": {
+ "existingJavaType": "net.jacobpeterson.alpaca.model.websocket.marketdata.streams.crypto.model.CryptoMarketDataMessage"
+ },
+ "properties": {
+ "S": {
+ "existingJavaType": "java.lang.String",
+ "javaName": "symbol",
+ "title": "The symbol."
+ },
+ "i": {
+ "existingJavaType": "java.lang.Long",
+ "javaName": "tradeID",
+ "title": "The trade ID."
+ },
+ "p": {
+ "existingJavaType": "java.lang.Double",
+ "javaName": "price",
+ "title": "The trade price."
+ },
+ "s": {
+ "existingJavaType": "java.lang.Double",
+ "javaName": "size",
+ "title": "The trade size."
+ },
+ "t": {
+ "existingJavaType": "java.time.OffsetDateTime",
+ "javaName": "timestamp",
+ "title": "The timestamp with nanosecond precision."
+ },
+ "tks": {
+ "existingJavaType": "net.jacobpeterson.alpaca.model.websocket.marketdata.streams.crypto.model.trade.CryptoTradeTakerSide",
+ "javaName": "takerSide",
+ "title": "The taker side."
+ }
+ }
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/trade/crypto_trade_taker_side.json b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/trade/crypto_trade_taker_side.json
new file mode 100644
index 00000000..d793fbfb
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/crypto/model/trade/crypto_trade_taker_side.json
@@ -0,0 +1,15 @@
+{
+ "type": "string",
+ "enum": [
+ "B",
+ "S"
+ ],
+ "javaEnums": [
+ {
+ "name": "BUY"
+ },
+ {
+ "name": "SELL"
+ }
+ ]
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataListener.java b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataListener.java
new file mode 100644
index 00000000..c47cb6dc
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataListener.java
@@ -0,0 +1,17 @@
+package net.jacobpeterson.alpaca.websocket.marketdata.streams.news;
+
+import net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.news.NewsMessage;
+
+/**
+ * {@link NewsMarketDataListener} defines a listener interface for {@link NewsMarketDataWebsocketInterface} messages.
+ */
+@FunctionalInterface
+public interface NewsMarketDataListener {
+
+ /**
+ * Called when a {@link NewsMessage} is received.
+ *
+ * @param news the {@link NewsMessage}
+ */
+ void onNews(NewsMessage news);
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataListenerAdapter.java b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataListenerAdapter.java
new file mode 100644
index 00000000..2278df82
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataListenerAdapter.java
@@ -0,0 +1,12 @@
+package net.jacobpeterson.alpaca.websocket.marketdata.streams.news;
+
+import net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.news.NewsMessage;
+
+/**
+ * {@link NewsMarketDataListenerAdapter} is an adapter for {@link NewsMarketDataListener}.
+ */
+public class NewsMarketDataListenerAdapter implements NewsMarketDataListener {
+
+ @Override
+ public void onNews(NewsMessage news) {}
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataWebsocket.java b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataWebsocket.java
new file mode 100644
index 00000000..495f7932
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/marketdata/streams/news/NewsMarketDataWebsocket.java
@@ -0,0 +1,85 @@
+package net.jacobpeterson.alpaca.websocket.marketdata.streams.news;
+
+import com.google.gson.JsonObject;
+import net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.NewsMarketDataMessageType;
+import net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.control.NewsSubscriptionsMessage;
+import net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.news.NewsMessage;
+import net.jacobpeterson.alpaca.websocket.marketdata.MarketDataWebsocket;
+import okhttp3.HttpUrl;
+import okhttp3.OkHttpClient;
+
+import java.util.Set;
+
+import static net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.NewsMarketDataMessageType.ERROR;
+import static net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.NewsMarketDataMessageType.SUBSCRIPTION;
+import static net.jacobpeterson.alpaca.model.websocket.marketdata.streams.news.model.NewsMarketDataMessageType.SUCCESS;
+import static net.jacobpeterson.alpaca.openapi.marketdata.JSON.getGson;
+
+/**
+ * {@link NewsMarketDataWebsocket} is an implementation for {@link NewsMarketDataWebsocketInterface}.
+ */
+public class NewsMarketDataWebsocket
+ extends MarketDataWebsocketsymbols to {@link NewsMarketDataMessageType#NEWS}. This will remove all
+ * previous {@link NewsMarketDataMessageType#NEWS} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setNewsSubscriptions(Setsymbols to {@link StockMarketDataMessageType#TRADES}. This will remove all
+ * previous {@link StockMarketDataMessageType#TRADES} subscriptions.
+ * symbols subscription list to the
+ * {@link StockMarketDataMessageType#TRADE_CORRECTIONS} and {@link StockMarketDataMessageType#TRADE_CANCEL_ERRORS}
+ * types.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setTradeSubscriptions(Setsymbols to {@link StockMarketDataMessageType#QUOTES}. This will remove all
+ * previous {@link StockMarketDataMessageType#QUOTES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setQuoteSubscriptions(Setsymbols to {@link StockMarketDataMessageType#MINUTE_BARS}. This will remove all
+ * previous {@link StockMarketDataMessageType#MINUTE_BARS} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setMinuteBarSubscriptions(Setsymbols to {@link StockMarketDataMessageType#DAILY_BARS}. This will remove all
+ * previous {@link StockMarketDataMessageType#DAILY_BARS} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setDailyBarSubscriptions(Setsymbols to {@link StockMarketDataMessageType#UPDATED_BARS}. This will remove
+ * all previous {@link StockMarketDataMessageType#UPDATED_BARS} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setUpdatedBarSubscriptions(Setsymbols to {@link StockMarketDataMessageType#LIMIT_UP_LIMIT_DOWN_BANDS}. This
+ * will remove all previous {@link StockMarketDataMessageType#LIMIT_UP_LIMIT_DOWN_BANDS} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setLimitUpLimitDownBandSubscriptions(Setsymbols to {@link StockMarketDataMessageType#TRADING_STATUSES}. This will
+ * remove all previous {@link StockMarketDataMessageType#TRADING_STATUSES} subscriptions.
+ *
+ * @param symbols the {@link Set} of symbols (use an asterisk ("*") as a wildcard to subscribe to all available
+ * symbols) or null to unsubscribe from all symbols
+ */
+ void setTradingStatuseSubscriptions(SetalpacaSubdomain.
- *
- * @param alpacaSubdomain the Alpaca subdomain
- *
- * @return a {@link HttpUrl}
- */
- private static HttpUrl createWebsocketURL(String alpacaSubdomain) {
- return new HttpUrl.Builder()
- .scheme("https") // HttpUrl.Builder doesn't recognize "wss" scheme, but "https" works fine
- .host(alpacaSubdomain + ".alpaca.markets")
- .addPathSegment("stream")
- .build();
- }
-
- private final SetstreamingMessageTypes.
- * true to subscribe, false otherwise
+ */
+ void subscribeToTradeUpdates(boolean subscribe);
+}
diff --git a/schema_json/endpoint/streaming/authorization/authorization_data.json b/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/authorization/authorization_data.json
similarity index 69%
rename from schema_json/endpoint/streaming/authorization/authorization_data.json
rename to src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/authorization/authorization_data.json
index e88df4d5..f05ae9bd 100644
--- a/schema_json/endpoint/streaming/authorization/authorization_data.json
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/authorization/authorization_data.json
@@ -1,6 +1,5 @@
{
"type": "object",
- "title": "See Streaming.",
"properties": {
"status": {
"existingJavaType": "java.lang.String",
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/authorization/authorization_message.json b/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/authorization/authorization_message.json
new file mode 100644
index 00000000..4c991d10
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/authorization/authorization_message.json
@@ -0,0 +1,12 @@
+{
+ "type": "object",
+ "extends": {
+ "existingJavaType": "net.jacobpeterson.alpaca.model.websocket.updates.model.UpdatesMessage"
+ },
+ "properties": {
+ "data": {
+ "existingJavaType": "net.jacobpeterson.alpaca.model.websocket.updates.model.authorization.AuthorizationData",
+ "title": "The {@link net.jacobpeterson.alpaca.model.websocket.updates.model.authorization.AuthorizationData}."
+ }
+ }
+}
diff --git a/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/listening/listening_data.json b/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/listening/listening_data.json
new file mode 100644
index 00000000..b2798264
--- /dev/null
+++ b/src/main/java/net/jacobpeterson/alpaca/websocket/updates/model/listening/listening_data.json
@@ -0,0 +1,9 @@
+{
+ "type": "object",
+ "properties": {
+ "streams": {
+ "existingJavaType": "java.util.Setalpaca.properties file on the classpath.
- */
-@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
-public class AlpacaAPITest {
-
- private static final Logger LOGGER = LoggerFactory.getLogger(AlpacaAPITest.class);
- private static final int RATE_LIMIT_MILLIS = 200; // Wait 200ms between every test to prevent rate-limiting
-
- static {
- // Log trace-level
- System.setProperty("org.slf4j.simpleLogger.log.net.jacobpeterson", "trace");
- }
-
- private static AlpacaAPI alpacaAPI;
- private static boolean marketOpen;
- private static AccountConfiguration accountConfiguration;
-
- /**
- * Executed before all tests in this class.
- */
- @BeforeAll
- public static void beforeAll() {
- alpacaAPI = new AlpacaAPI();
- marketOpen = false;
- }
-
- /**
- * Executed before each test.
- */
- @BeforeEach
- public void beforeEach() {
- }
-
- /**
- * Executed after each test. Note that this will {@link Thread#sleep(long)} for {@link #RATE_LIMIT_MILLIS} to
- * protect against rate limiting.
- */
- @AfterEach
- public void afterEach() {
- try {
- Thread.sleep(RATE_LIMIT_MILLIS);
- } catch (InterruptedException exception) {
- fail("Interrupted when tearing down!");
- }
- }
-
- /**
- * Tests {@link ClockEndpoint#get()}.
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- */
- @Test
- @org.junit.jupiter.api.Order(1)
- public void test_ClockEndpoint_get() throws AlpacaClientException {
- Clock clock = alpacaAPI.clock().get();
- assertNotNull(clock);
-
- LOGGER.debug("{}", clock);
-
- assertNotNull(clock.getTimestamp());
- assertNotNull(clock.getIsOpen());
- assertNotNull(clock.getNextOpen());
- assertNotNull(clock.getNextClose());
-
- marketOpen = clock.getIsOpen();
- if (marketOpen) {
- LOGGER.info("Market is currently open! All live endpoints will be tested.");
- } else {
- LOGGER.info("Market is currently closed! Only some live endpoints will be tested.");
- }
- }
-
- /**
- * Tests {@link AccountEndpoint#get()}.
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- * @throws NumberFormatException thrown for {@link NumberFormatException}s
- */
- @Test
- @SuppressWarnings("ResultOfMethodCallIgnored")
- public void test_AccountEndpoint_get() throws AlpacaClientException, NumberFormatException {
- Account account = alpacaAPI.account().get();
- assertNotNull(account);
-
- LOGGER.debug("{}", account);
-
- // Assert basic data integrity and not null
- Double.parseDouble(account.getCash());
- Double.parseDouble(account.getPortfolioValue());
- Double.parseDouble(account.getLongMarketValue());
- Double.parseDouble(account.getShortMarketValue());
- Double.parseDouble(account.getEquity());
- Double.parseDouble(account.getLastEquity());
- Double.parseDouble(account.getBuyingPower());
- Double.parseDouble(account.getInitialMargin());
- Double.parseDouble(account.getMaintenanceMargin());
- Double.parseDouble(account.getLastMaintenanceMargin());
- Double.parseDouble(account.getDaytradingBuyingPower());
- Double.parseDouble(account.getRegtBuyingPower());
-
- // Assert other data exists
- assertNotNull(account.getId());
- assertNotNull(account.getAccountNumber());
- assertNotNull(account.getStatus());
- assertNotNull(account.getCurrency());
- assertNotNull(account.getPatternDayTrader());
- assertNotNull(account.getTradeSuspendedByUser());
- assertNotNull(account.getTradingBlocked());
- assertNotNull(account.getTransfersBlocked());
- assertNotNull(account.getAccountBlocked());
- assertNotNull(account.getCreatedAt());
- assertNotNull(account.getShortingEnabled());
- assertNotNull(account.getMultiplier());
- assertNotNull(account.getSma());
- assertNotNull(account.getDaytradeCount());
- }
-
- /**
- * Tests @{@link AccountActivitiesEndpoint#get(ZonedDateTime,
- * ZonedDateTime, ZonedDateTime, SortDirection, Integer, String, ActivityType...)} one {@link AccountActivity}
- * exists until now.
- *
- * @throws AlpacaClientException thrown for {@link AlpacaClientException}s
- */
- @Test
- public void test_AccountActivitiesEndpoint_get_One_Activity_Exists_Until_Now() throws AlpacaClientException {
- List