CryptoMarket-Java

Main page.

Sign up in CryptoMarket.

Installation

Add the Maven dependency

<dependency>
    <groupId>com.cryptomkt.api</groupId>
    <artifactId>cryptomarket</artifactId>
    <version>3.1.0</version>
</dependency>

Documentation

This sdk makes use of the api version 3 of Cryptomarket.

Quick Start

Rest client

// instance a client
String apiKey = "AB32B3201";
String apiSecret = "21b12401";
CryptomarketRestClient client = new CryptomarketRestClientImpl(apiKey, apiSecret);

// get all currencies
Map<String, Currency> currencies = client.getCurrencies(null, null);

// get some symbols
List<String> symbolIDs = new ArrayList<String>(Arrays.asList("EOSETH","ETHBTC"));
Map<String, Symbol> symbols = client.getSymbols(symbolIDs);

// get an order book
OrderBook  orderbook = client.getOrderbookBySymbol("EOSETH");

// get some candles
List<String> symbols = new ArrayList<String>(Arrays.asList("EOSETH", "ETHBTC"));
Map<String, List<Candle>> candles = client.getCandles(symbols, Period._4_HOURS, Sort.ASC, null, null, null);

// get your wallet balances
List<Balance> walletBalances = client.getWalletBalances();

// get your spot trading balances
List<Balance> spotBalances = client.getSpotTradingBalances();

// move balance from account to trading
String result = client.transferBetweenWalletAndExchange(
  'ETH', 
  '3.2', 
  AccountType.WALLET,
  AccountType.SPOT);

// get your active orders
List<Order> orders = client.getAllActiveSpotOrders('ESOETH');

// create a new order
Order order = client.createOrder(new ParamsBuilder()
            .symbol("EOSETH")
            .side(Side.SELL)
            .quantity("2")
            .price("10000")
            .timeInForce(TimeInForce.DAY));

Using the ParamsBuilder

Most client methods have a version that accepts a ParamBuilder. This class makes easier to pass parameters, and is expected to recieve the same parameters as the parameterized version.

import com.cryptomarket.params.ParamsBuilder;

List<String> symbols = new ArrayList<String>(Arrays.asList("EOSETH", "ETHBTC"));
// get candles
Map<String, List<Candle>> candles = client.getCandles(
  symbols, 
  Period._4_HOURS, 
  Sort.ASC, 
  null, 
  null, 
  null);
// is equivalent to:
Map<String, List<Candle>> candles client.getCandles(new ParamsBuilder()
          .symbols(symbols)
          .period(Period._4_HOURS)
          .sort(Sort.ASC));

Exception handling

// rest exceptions
CryptomarketRestClient client = new CryptomarketRestClientImpl(api_key, api_secret);

// all rest client methods can throw a CryptomarketSDKException
try {
    List<String> symbolIds = new ArrayList<String>(Arrays.asList("eoseth","ethbtc"));
    List<Ticker> tickers = client.getTickers(symbolIds);
    assertTrue(tickers.size() == 2);
} catch (CryptomarketApiException e) {
    e.printStackTrace();
}

Websocket client

There are three websocket clients, the market data client, the spot trading client and the wallet client. The market data client requires no authentication, while the spot trading client and the wallet client do require it.

All websocket methods accept a BiConsumer with the first argument being the resulting data of the request, and the second argument a possible exception of type CryptomarketSDKException. If there is an exception the data is null: (null, exception) -> {...}. And if there is no exception, the exception argument is null: (data,null) -> {...}

websocket subscriptions take a second BiConsumer that takes the subscription data as the first argument, and the notification type as the second. The notification type is of type NotificationType, and is either SNAPSHOT, NOTIFICATION or DATA. there are functions to test the type of notification:

If there is an error in a notification of a subscription, a special notification type is used, to check it call notificationType.isError(), in such case, the data is null. This holds for all subscriptions

BiConsumer<List<Report>, NotificationType> biConsumerExample = (data, notificationType) -> {
  if (notificationType.isError()) {
    System.out.println("an error ocurred");
  }
  if (notificationType.isSnapshot()) {
    System.out.println("is a snapshot notification");
  }
  if (notificationType.isUpdate()) {
    System.out.println("is a update notification");
  }
  if (notificationType.isData()) {
    System.out.println("is a data notification");
  }
}

The documentation of a specific subscription explains which types of notification uses.

Websocket Lifetime

There are hooks for the connection, close and faiule of the websockets.

On an authenticated client, onConnect is called after authentication, which happens automatically after connection.

// ws client lifetime
CryptomarketWSSpotTradingClient wsClient;
    wsClient = new CryptomarketWSSpotTradingClientImpl(KeyLoader.getApiKey(), KeyLoader.getApiSecret());
    wsClient.onConnect(() -> System.out.println("client is connected!"));
    wsClient.onClose(reason -> System.out.println("closing: "+ reason));
    wsClient.onFailure(t -> t.printStackTrace());
    wsClient.connect();

Websocket Connection

The websockets take some time (around one second) to connect, and authenticated sockets take a little more time to authenticate, so we must wait to the client to call onConnect first.

A way of doing this is using a future task

var wsClient = new CryptomarketWSSpotTradingClientImpl(KeyLoader.getApiKey(), KeyLoader.getApiSecret());
var ft = new FutureTask<Object>(() -> {}, new Object());
wsClient.onConnect(ft);
wsClient.connect();
ft.get();
// here we are connected and authenticated already
wsClient.getSpotTradingBalances((balances, err) -> {...});

We can also run our logic inside the onConnect hook

var wsClient = new CryptomarketWSSpotTradingClientImpl(KeyLoader.getApiKey(), KeyLoader.getApiSecret());
var ft = new FutureTask<Object>(() -> {}, new Object());
wsClient.onConnect(()-> {
  // here we are connected and authenticated already
  wsClient.getSpotTradingBalances((balances, err) -> {...});
});
wsClient.connect();

Or we can sleep some time to wait connection

var wsClient = new CryptomarketWSSpotTradingClientImpl(KeyLoader.getApiKey(), KeyLoader.getApiSecret());
var ft = new FutureTask<Object>(() -> {}, new Object());
wsClient.connect();
TimeUnit.Seconds.sleep(3);
// here we are connected and authenticated already
wsClient.getSpotTradingBalances((balances, err) -> {...});

MarketDataClient

Example of use of the market data client

// instantiate a market data client
CryptomarketWSMarketDataClient marketDataClient = CryptomarketWSMarketDataClientImpl();

// make a partial orderbook subscription
//    prepare args
List<String> symbols = Arrays.asList("EOSETH");

//    make subscription
marketDataClient.subscribeToPartialOrderBook(
    (partialOrderbookMap, notificationType) -> {
      if (notificationType.isData()) {
        System.out.println("this subscription only recieves data notifications");
      }
      partialOrderbookMap.forEach((symbol, orderbook) -> {
        System.out.println("symbol:" + symbol);
        System.out.println(orderbook);
      });
    },
    Depth._5,
    OBSpeed._500_MILISECONDS,
    symbols,
    null);

SpotTradingClient

Example of use of the spot trading client

// instantiate a spot trading websocket client
String apiKey = "AB32B3201";
String apiSecret= "21b12401";
CryptomarketWSSpotTradingClient tradingClient = new CryptomarketWSSpotTradingClientImpl(apiKey, apiSecret);

// get all the spot trading balances
tradingClient.getSpotTradingBalances(
  (balanceList, exception) -> {
    if (exception != null) {
      System.out.println("something went wrong: "+ exception.toString());
      return;
    }
    balanceList.forEach(System.out::println);
  });

tradingClient.createSpotOrder(
      new ParamsBuilder()
          .side(Side.SELL)
          .symbol("EOSETH")
          .price("10000")
          .quantity("0.01")
          .clientOrderID("123123123123"),
      (report, exception) -> {
        if (exception != null) {
          System.out.println("something went wrong: "+ exception.toString());
          return;
        }
        System.out.println("new order created: " + report.toString());
      });

WalletClient

Example of use of the wallet client

// instantiate a wallet websocket client with a window of 20 seconds
CryptomarketWSWalletClient walletClient = new CryptomarketWSWalletClientImpl(apiKey, apiSecret, 20000);

// get a list of transactions
walletClient.getTransactions((transactionList, exception) -> {
    if (exception != null) {
      System.out.println("something went wrong: "+ exception.toString());
      return;
    }
    transactionList.forEach(System.out::println);
  }, null);

// subscribe to a feed of transactions
walletClient.subscribeToTransactions(
  (data, nType) -> {
    if (notificationType.isUpdate()) {
        System.out.println("this subscription only recieves update notifications");
      }
    data.forEach(transaction -> System.out.println(transaction));
  }, (subscriptionResult, exception) -> {
    if (exception != null) {
      System.out.println("subscription failed");
    }
    if (!result) {
      System.out.println("subscription failed");
    }
  });

Constants

All constants required for calls are in com.cryptomarket.sdk.params. each enum has the name of the argument that needs it.

Checkout our other SDKs

node sdk

ruby sdk

go sdk

python sdk