The official Node.js library for the Shrimpy Developer API https://developers.shrimpy.io/docs
npm install shrimpy-nodeYou can learn about the API responses of each endpoint by reading our documentation.
All asynchronous methods return promises.
client
.getTicker('kucoin')
.then(data => {
// do something with the data
})
.catch(error => {
// handle the error
});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
}
}const Shrimpy = require('shrimpy-node');
const publicClient = new Shrimpy.ShrimpyApiClient();The public client can only use public methods.
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.
const supportedExchanges = await client.getSupportedExchanges();const exchangeAssets = await client.getExchangeAssets(
'coinbasepro' // exchange
);const tradingPairs = await client.getTradingPairs(
'coinbasepro' // exchange
);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
);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
);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
);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
);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
);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
);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
);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
);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
);const assetDominance = await client.getAssetDominance();const assetPopularity = await client.getAssetPopularity();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
);const status = await client.getStatus();const usage = await client.getCredits();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);
})()
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent