Public channel
Realtime API
Data | Channel | Event | Event trigger |
マーケット情報 | product_cash_${currencypair_code}_${product_id} | updated | 最終取引価格が更新された |
板情報 | price_ladders_cash_${currencypair_code}_${side} | updated | 板の情報が更新された |
約定情報 | executions_cash_${currency_pair_code} | updated | 最新の約定リストが更新された |
約定情報（詳細） | execution_details_cash_${currency_pair_code} | updated | 最新の約定リストが更新された |
Javascript sample
const { TapClient } = require("liquid-tap");
const tap = new TapClient();
const public_channel = tap.subscribe("product_cash_btcsgd_7");
public_channel.bind("updated", function(data) {
console.log("product_cash_btcsgd_7 has been updated", data);
});
const product_channel = tap.subscribe("product_cash_btcusd_1");
const orderbook_channel = tap.subscribe("price_ladders_cash_btcjpy_sell");
const executions_channel = tap.subscribe("executions_cash_btcjpy");
const executions_detail_channel = tap.subscribe("execution_details_cash_btcusd");
/* javascript - using raw websockets */
const ws = new WebSocket('wss://tap.liquid.com/app/LiquidTapClient');
ws.onmessage = (message) => {
const wsEvent = JSON.parse(message.data);
switch(wsEvent.event){
case 'pusher:connection_established':
console.log('Connected!');
ws.send(JSON.stringify({"event":"pusher:subscribe","data":{"channel":"some_public_channel"}}));
break;
case 'pusher_internal:subscription_succeeded':
console.log('Subscribed: ' + wsEvent.channel);
case 'updated':
console.log('Updated: ' + wsEvent.data);
}
}
最終更新 2yr ago