README
shrimpy-node
The official Node.js library for the Shrimpy Developer API https://developers.shrimpy.io/docs
Installation
npm install shrimpy-node
You can learn about the API responses of each endpoint by reading our documentation.
Quick Start
All asynchronous methods return promises.
Promise Example
client
.getTicker('kucoin')
.then(data => {
// do something with the data
})
.catch(error => {
// handle the error
});
Async Example
The promises can be used as expected in async functions in ES2017+ environments:
async function yourFunction() {
try {
const ticker = await client.getTicker('kucoin');
// do something with the data
} catch (error) {
// handle the error
}
}
Public Client
const Shrimpy = require('shrimpy-node');
const publicClient = new Shrimpy.ShrimpyApiClient();
The public client can only use public methods.
Private Client
const publicKey = 'your_public_key'; // e.g. 12326758a39a720e15d064cab3c1f0a9332d107de453bd41926bb3acd565059e
const privateKey = 'your_private_key'; // e.g. 6991cf4c9b518293429db0df6085d1731074bed8abccd7f0279a52fac5b0c1a8a2f6d28e11a50fbb1c6575d1407e637f9ad7c73fbddfa87c5d418fd58971f829
const Shrimpy = require('shrimpy-node');
const privateClient = new Shrimpy.ShrimpyApiClient(publicKey, privateKey);
The private client can use public and private methods.
Public Methods
const supportedExchanges = await client.getSupportedExchanges();
const exchangeAssets = await client.getExchangeAssets(
'coinbasepro' // exchange
);
const tradingPairs = await client.getTradingPairs(
'coinbasepro' // exchange
);
Market Data Methods
const ticker = await client.getTicker(
'kucoin' // exchange
);
const orderBooks = await client.getOrderBooks(
'bittrex', // exchange
'XLM', // baseSymbol
'BTC', // quoteSymbol
10 // limit
);
const candles = await client.getCandles(
'bittrex', // exchange
'XLM', // baseTradingSymbol
'BTC', // quoteTradingSymbol
'15m' // interval
);
User Methods
const users = await client.getUsers();
const user = await client.getUser(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' //userId
);
const userId = await client.createUser();
await client.setUserName(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', //userId
'mycustomname' // name
);
await client.removeUser(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', //userId
);
await client.enableUser(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' //userId
);
await client.disableUser(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' //userId
);
User API Keys Methods
const publicKeys = await client.getApiKeys(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' //userId
);
const apiKeys = await client.createApiKeys(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' // userId
);
const apiKeys = await client.deleteApiKeys(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
'51ac18b7d208f59b3c88acbb1ecefe6ba6be6ea4edc07e7a2450307ddc27ab80' // publicKey
);
const permissions = await client.getPermissions(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
'51ac18b7d208f59b3c88acbb1ecefe6ba6be6ea4edc07e7a2450307ddc27ab80' // publicKey
);
await client.setPermissions(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
'51ac18b7d208f59b3c88acbb1ecefe6ba6be6ea4edc07e7a2450307ddc27ab80', // publicKey
true, // enable account methods
false // enable trading methods
);
Account Methods
const accounts = await client.getAccounts(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' // userId
);
const account = await client.getAccount(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
const accountId = await client.createAccount(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
'binance', // exchange
'GOelL5FT6TklPxAzICIQK25aqct52T2lHoKvtcwsFla5sbVXmeePqVJaoXmXI6Qd', // publicKey (a.k.a. apiKey)
'SelUuFq1sF2zGd97Lmfbb4ghITeziKo9IvM5NltjEdffatRN1N5vfHXIU6dsqRQw' // privateKey (a.k.a. secretKey
);
Note: The createAccount method accepts a fifth optional parameter: passphrase. The passphrase is only required for some exchanges, such as Coinbase Pro.
await client.deleteAccount(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
456 // accountId
);
const IpAddresses = await client.getIpWhitelistAddresses(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8' // userId
);
Trading Methods
const tradeId = await client.createTrade(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
'BTC', // fromSymbol
'ETH', // toSymbol
new Decimal('0.01') // amount of fromSymbol
);
const trade = await client.getTrade(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // exchangeAccountId
'72dff099-54c0-4a32-b046-5c19d4f55758' // tradeId
);
const activeTrades = await client.getActiveTrades(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // exchangeAccountId
);
Balance Methods
const balance = await client.getBalance(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
const totalBalanceHistory = await client.getTotalBalanceHistory(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
Asset Management Methods
await client.rebalance(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
const rebalancePeriodHours = await client.getRebalancePeriod(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
await client.setRebalancePeriod(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
24 // rebalancePeriod in hours
);
const strategy = await client.getStrategy(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
await client.setStrategy(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
{
isDynamic: false,
allocations: [
{ symbol: 'BTC', percent: '50' },
{ symbol: 'ETH', percent: '50' }
]
} // strategy
);
await client.clearStrategy(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
await client.allocate(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
{
isDynamic: false,
allocations: [
{ symbol: 'USDT', percent: '100' }
]
} // strategy
);
Limit Order Methods
const orderId = await client.createOrder(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
'ETH', // baseSymbol
'BTC', // quoteSymbol
new Decimal('0.01'), // quantity of baseSymbol
new Decimal('0.026'), // price
'SELL', // side
'IOC', // timeInForce
);
const order = await client.getOrder(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
'8c2a9401-eb5b-48eb-9ae2-e9e02c174058' // orderId
);
const order = await client.getOrders(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123 // accountId
);
const order = await client.cancelOrder(
'701e0d16-1e9e-42c9-b6a1-4cada1f395b8', // userId
123, // accountId
'8c2a9401-eb5b-48eb-9ae2-e9e02c174058' // orderId
);
Analytics Methods
const backtestAssets = await client.getBacktestAssets(
'kucoin' // exchange
);
const backtestResults = await client.runBacktest(
'binance', // exchange
10, // rebalancePeriod in hours
new Decimal(0.1), // fee in percent
new Date("2018-05-19T00:00:00.000Z"), // startTime
new Date("2018-11-02T00:00:00.000Z"), // endTime
new Decimal(5000), // initialValue in USD
[
{ symbol: "BTC", percent: new Decimal(50) },
{ symbol: "ETH", percent: new Decimal(50) }
] // allocations
);
const predictions = await client.getPredictions(
'bittrex', // exchange
'LTC', // baseSymbol
'BTC' // quoteSymbol
)
const trendResults = await client.getTrend(
'binance', # exchange
'BTC', # base_symbol
'BIDR', # quote_symbol
);
Insight Methods
const assetDominance = await client.getAssetDominance();
const assetPopularity = await client.getAssetPopularity();
Historical Methods
const count = await client.getHistoricalCount(
'trade', // type
'binance', // exchange
'LTC', // baseTradingSymbol
'BTC', // quoteTradingSymbol
new Date("2018-05-19T01:00:00.000Z"), // startTime
new Date("2018-11-02T02:00:00.000Z") // endTime
);
const instruments = await client.getHistoricalInstruments();
const bittrexInstruments = await client.getHistoricalInstruments('bittrex');
const trades = await client.getHistoricalTrades(
'binance', // exchange
'LTC', // baseTradingSymbol
'BTC', // quoteTradingSymbol
new Date("2018-05-19T00:00:00.000Z"), // startTime
new Date("2018-11-02T00:00:00.000Z"), // endTime
100 // limit
);
const orderbooks = await client.getHistoricalOrderBooks(
'binance', // exchange
'LTC', // baseTradingSymbol
'BTC', // quoteTradingSymbol
new Date("2018-05-19T00:00:00.000Z"), // startTime
new Date("2018-11-02T00:00:00.000Z"), // endTime
100 // limit
);
API Management Methods
const status = await client.getStatus();
const usage = await client.getCredits();
Websocket
Users can access the Shrimpy websocket feed using the ShrimpyWsClient class. A handler must be passed in on subscription
that is responsible for processing incoming messages from the websocket stream. It is recommended that you simply send the message
to another processing thread from your custom handler to prevent blocking the incoming message stream.
The client handles pings to the Shrimpy server based on the API Documentation
const Shrimpy = require('shrimpy-node');
let apiClient = null;
let wsClient = null;
let token = null;
const publicKey = "<Public Key Here>";
const privateKey = "<Private Key Here>";
function handler(msg){
console.log(msg);
};
function subscribeWhenConnected(oData){
if (wsClient.getReadyState() === 1) {
console.log("Subcribing to the order book for ETH-BTC");
wsClient.subscribe(oData, handler);
} else {
console.log("waiting for ws connection...");
setTimeout(subscribeWhenConnected.bind(null, oData), 1000);
}
};
function unsubscribe(oData){
console.log("Unsubcribing now");
wsClient.unsubscribe(oData);
console.log("Stopping the application");
process.exit(1);
};
(async () => {
apiClient = new Shrimpy.ShrimpyApiClient(publicKey, privateKey);
token = await apiClient.getToken();
wsClient = new Shrimpy.ShrimpyWsClient(function (error) {
console.error(error);
}, token);
wsClient.connect();
subscribeWhenConnected({
"type": "subscribe",
"pair": "ETH-BTC",
"exchange": "coinbasepro",
"channel": "orderbook"
});
setTimeout(unsubscribe.bind(null, {
"type": "unsubscribe",
"pair": "ETH-BTC",
"exchange": "coinbasepro",
"channel": "orderbook"
}), 10000);
})()