Download API documentation:Download
ODIN Price Feed API or Web Feed Handler API (internal name) allows the developer to fetch the price related information like last traded price, Touch Line, Best Five etc. The Price Feed API communicates to applications on TCP/Web Socket connection using subscription model and data is transmitted in a compressed mode.
WFH API can be used to display following information on any mobile or web application.
This step-by- step guide will assist you through the entire flow of API implementation; right from authentication, to handle the request and response structure of the API.
| MODE : WS WSS | IP : | PORT : |
|
UserId :
|
|
SEND MESSAGE
|
||||||||||||||
|
CONNECTION STATUS
|
||||||||||||||
|
RESPONSE MESSAGE
|
||||||||||||||
function ConnectSocket(mode,ip,port){
try
{
objSocket = null;
objSocket = new WebSocket(mode + '://' + ip + ':' + port);
objSocket.binaryType = 'arraybuffer';
objSocket.onopen = socketOnOpen;
objSocket.onclose = socketOnClose;
objSocket.onerror = socketOnError;
objSocket.onmessage = socketOnMessage;
}
catch(ex)
{
}
}
socketOnOpen = function(){
var sUsedId = 'TEST';
var sLoginRequest ="63=FT3.0|64=101|65=74|66=14:59:22|67=TEST|68=YOUR_API_KEY|4=|400=0|401=2|396=HO|51=4|395=127.0.0.1";
SendMessageOnSocket((sLoginRequest));
}
function SendMessageOnSocket(msg){
try
{
if(objSocket.readyState == 1)
{
objSocket.send(fragmentData(msg));
}
}
catch(ex)
{
}
}
function fragmentData(_requestPacket) {
try {
var _strHead = _strHead = String.fromCharCode('5'); //5 comprression char
var i;
var _data = new ArrayBuffer(_strHead.length);
var _headerBytes = new Uint8Array(_data);
for (i = 0; i < _strHead.length; i += 1) {
_headerBytes[i] = _strHead.charCodeAt(i);
}
var _baRequest;
_baRequest = HandleCompressedData(_requestPacket);
var _length = _baRequest.length + 4;
var _lenLength = _length.toString().length;
var _lengthString = "";
for (i = 0; i < (5 - _lenLength); i++) {
_lengthString += "0";
}
_lengthString += _length.toString();
_data = new ArrayBuffer(_lengthString.length);
var _lenBytes = new Uint8Array(_data);
for (i = 0; i < _lengthString.length; i += 1) {
_lenBytes[i] = _lengthString.charCodeAt(i);
}
var _baActualSend = new Uint8Array(5 + _length);
_baActualSend.set(_lenBytes);
_baActualSend.set(_baRequest, 5);
var _outputStream = new Uint8Array(_headerBytes.length + _baActualSend.length);
_outputStream.set(_headerBytes);
_outputStream.set(_baActualSend, 1);
return _outputStream.buffer;
}
catch (e)
{
}
};
function HandleCompressedData(_rawData) {
try {
var _data = new ArrayBuffer(_rawData.length);
var _uint8buf = new Uint8Array(_data);
for (var i = 0; i < _rawData.length; i += 1) {
_uint8buf[i] = _rawData.charCodeAt(i) & 0xFF;
}
var _compData = Zlib.compress(new Uint8Array(_data), 6);
return _compData;
}
catch (e)
{
}
};
var sMsg ='',sMsgToSend ='';
sMsg = 1_22,1_2885;
var sTokenArr = sMsg.split(',')
sMsgToSend = "63=FT3.0|64=206|65=84|66=19:02:31|4=|";
for(var i=0;i < sTokenArr.length;i++)
{
sMsgToSend += "1=" + (sTokenArr[i].split('_')[0]) + "$7=" + sTokenArr[i].split('_')[1] + "|";
}
sMsgToSend += "230=1";
//Sample String Generated: = 63=FT3.0|64=206|65=84|66=19:02:31|1=1$7=22|1=1$7=2885|230=1
SendMessageOnSocket(sMsgToSend);
function SendMessageOnSocket(msg){
try
{
if(objSocket.readyState == 1)
{
objSocket.send(fragmentData(msg));
}
}
catch(ex)
{
}
}
function fragmentData(_requestPacket) {
try {
var _strHead = _strHead = String.fromCharCode('5'); //5 comprression char
var i;
var _data = new ArrayBuffer(_strHead.length);
var _headerBytes = new Uint8Array(_data);
for (i = 0; i < _strHead.length; i += 1) {
_headerBytes[i] = _strHead.charCodeAt(i);
}
var _baRequest;
_baRequest = HandleCompressedData(_requestPacket);
var _length = _baRequest.length + 4;
var _lenLength = _length.toString().length;
var _lengthString = "";
for (i = 0; i < (5 - _lenLength); i++) {
_lengthString += "0";
}
_lengthString += _length.toString();
_data = new ArrayBuffer(_lengthString.length);
var _lenBytes = new Uint8Array(_data);
for (i = 0; i < _lengthString.length; i += 1) {
_lenBytes[i] = _lengthString.charCodeAt(i);
}
var _baActualSend = new Uint8Array(5 + _length);
_baActualSend.set(_lenBytes);
_baActualSend.set(_baRequest, 5);
var _outputStream = new Uint8Array(_headerBytes.length + _baActualSend.length);
_outputStream.set(_headerBytes);
_outputStream.set(_baActualSend, 1);
return _outputStream.buffer;
}
catch (e)
{
}
};
function HandleCompressedData(_rawData) {
try {
var _data = new ArrayBuffer(_rawData.length);
var _uint8buf = new Uint8Array(_data);
for (var i = 0; i < _rawData.length; i += 1) {
_uint8buf[i] = _rawData.charCodeAt(i) & 0xFF;
}
var _compData = Zlib.compress(new Uint8Array(_data), 6);
return _compData;
}
catch (e)
{
}
};
var sMsg ='',sMsgToSend ='';
sMsg = 1_22;
sMsgToSend = "63=FT3.0|64=127|65=84|66=19:02:31|1=" + (sMsg.split('_')[0]) + "|7=" + sMsg.split('_')[1] + "|230=1";
//Sample String Generated: = 63=FT3.0|64=127|65=84|66=19:02:31|1=1|7=22|230=1
SendMessageOnSocket(sMsgToSend);
function SendMessageOnSocket(msg){
try
{
if(objSocket.readyState == 1)
{
objSocket.send(fragmentData(msg));
}
}
catch(ex)
{
}
}
function fragmentData(_requestPacket) {
try {
var _strHead = _strHead = String.fromCharCode('5'); //5 comprression char
var i;
var _data = new ArrayBuffer(_strHead.length);
var _headerBytes = new Uint8Array(_data);
for (i = 0; i < _strHead.length; i += 1) {
_headerBytes[i] = _strHead.charCodeAt(i);
}
var _baRequest;
_baRequest = HandleCompressedData(_requestPacket);
var _length = _baRequest.length + 4;
var _lenLength = _length.toString().length;
var _lengthString = "";
for (i = 0; i < (5 - _lenLength); i++) {
_lengthString += "0";
}
_lengthString += _length.toString();
_data = new ArrayBuffer(_lengthString.length);
var _lenBytes = new Uint8Array(_data);
for (i = 0; i < _lengthString.length; i += 1) {
_lenBytes[i] = _lengthString.charCodeAt(i);
}
var _baActualSend = new Uint8Array(5 + _length);
_baActualSend.set(_lenBytes);
_baActualSend.set(_baRequest, 5);
var _outputStream = new Uint8Array(_headerBytes.length + _baActualSend.length);
_outputStream.set(_headerBytes);
_outputStream.set(_baActualSend, 1);
return _outputStream.buffer;
}
catch (e)
{
}
};
function HandleCompressedData(_rawData) {
try {
var _data = new ArrayBuffer(_rawData.length);
var _uint8buf = new Uint8Array(_data);
for (var i = 0; i < _rawData.length; i += 1) {
_uint8buf[i] = _rawData.charCodeAt(i) & 0xFF;
}
var _compData = Zlib.compress(new Uint8Array(_data), 6);
return _compData;
}
catch (e)
{
}
};
function socketOnMessage(_event){
try
{
var baProcessData = null;
var intRawPktLen;
var intCompLen = 0;
var _response, isBroken = false;
var totalPacketLength = 0;
if (_event.data instanceof ArrayBuffer) {
var dataReceived = null;
var dataPacketLengthList = [];
if (baOldData == null)
dataReceived = new Uint8Array(_event.data);
else {
dataReceived = AppendOrCopyBuffer(baOldData, _event.data);
baOldData = null;
}
intRawPktLen = dataReceived.byteLength;
var i = 0;
if (intRawPktLen > 5) {
while (i < intRawPktLen) {
if (dataReceived[i] == 5 || dataReceived[i] == 2) {
var strPacketLength = String.fromCharCode.apply(null, dataReceived.subarray(i + 1, i + 6));
if (strPacketLength.length == 5) {
var packetLength = parseInt(strPacketLength, 10);
dataPacketLengthList.push(packetLength + 6);
totalPacketLength += packetLength + 6;
i = i + 6 + packetLength;
}
else {
baOldData = dataReceived.subarray(i, intRawPktLen);
isBroken = true;
break;
}
}
}
}
else
baOldData = dataReceived;
if (intRawPktLen == totalPacketLength) {
// split and pass to zlib to uncompress
for (var i = 0, j = 0, k = dataPacketLengthList[0], len = dataPacketLengthList.length; i < len ; i++) {
var uncompData = dataReceived.subarray(j, k);
ProcessSocketMessage(uncompData);
j = k;
k = k + dataPacketLengthList[i + 1];
}
baOldData = null;
}
else {
var i = 0, j = 0;
var k = (dataPacketLengthList.length > 0 ? dataPacketLengthList[0] : 0);
if (!isBroken) {
for (var len = dataPacketLengthList.length ; i < len - 1; i++) {
var uncompData = dataReceived.subarray(j, k);
ProcessSocketMessage(uncompData);
j = k;
k = k + dataPacketLengthList[i + 1];
}
if (i == dataPacketLengthList.length - 1) {
baOldData = null;
baOldData = dataReceived.subarray(j, k);
if (baOldData[0] != 5 && baOldData[0] != 2)
alert();
}
}
else {
for (var len = dataPacketLengthList.length; i < len; i++) {
var uncompData = dataReceived.subarray(j, k);
ProcessSocketMessage(uncompData);
j = k;
k = k + dataPacketLengthList[i + 1];
}
isBroken = false;
}
}
}
}
catch(ex)
{
}
}
function ProcessSocketMessage(uncompData) {
_response = DeCompressData(uncompData);
if (_response == undefined) {
console.log(_response);
}
//remove End of response char
var intTmtrIndex = _response.indexOf('\u0000');
if (intTmtrIndex != -1) {
_response = _response.substr(0, intTmtrIndex);
}
//split multi response packet with Start of response char C_S_CHAR2
var arrData = _response.split("\u0002");
var intDataCount = arrData.length;
for (var intDataCntr = 0; intDataCntr < intDataCount; intDataCntr++) {
if (arrData[intDataCntr] != "") {
console.log("Packet: " + arrData[intDataCntr]);
}
}
}