React Native

Binary.com Tick Stream

See more WebSocket Examples

Tick Stream Request -- Initiate a continuous stream of spot price updates for a given symbol. React Native

import { JsonObject, Rest, WebSocket } from '@chilkat/react-native'

async function chilkatExample() {
  // This example requires the Chilkat API to have been previously unlocked.
  // See Global Unlock Sample for sample code.

  const ws = new WebSocket();

  // For brevity, this example does not check for errors when etablishing the WebSocket connection.
  // See Establish WebSocket Connection for more complete sample code for making the connection.

  const rest = new Rest();

  // Connect to ws.binaryws.com
  await rest.connectAsync('ws.binaryws.com', 443, true, false);
  ws.useConnection(rest);
  ws.addClientHeaders();

  // My app_id is 12332.  You'll wnat to use your own...
  const responseBody = await rest.fullRequestNoBodyAsync('GET', '/websockets/v3?app_id=12332');
  try {
    ws.validateServerHandshake();
  } catch {
    console.log(ws.lastErrorText);
    console.log(responseBody);
    console.log(rest.responseHeader);
    return;
  }

  // Build and send the following message:

  // {
  //   "ticks": "R_50",
  //   "subscribe": 1
  // }

  const json = new JsonObject();
  json.appendString('ticks', 'R_50');
  json.appendInt('subscribe', 1);

  // Send a full message in a single frame
  const finalFrame = true;
  try {
    await ws.sendFrameAsync(json.emit(), finalFrame);
  } catch {
    console.log(ws.lastErrorText);
    return;
  }

  const jsonTickData = new JsonObject();
  jsonTickData.emitCompact = false;

  // Begin reading the tick stream response.
  // We'll just read the 1st 10 updates and then exit..
  let numTicksReceived = 0;
  while (numTicksReceived < 5) {

    try {
      await ws.readFrameAsync();
    } catch {
      console.log('Failed to receive a frame');
      console.log(`ReadFrame fail reason = ${ws.readFrameFailReason}`);
      console.log(ws.lastErrorText);
      return;
    }

    // The responses we desire are in Text frames, where the opcode = 1.
    if (ws.frameOpcodeInt === 1) {
      const receivedJson = ws.getFrameData();

      jsonTickData.load(receivedJson);
      console.log(jsonTickData.emit());

      numTicksReceived++;
    }
  }

  // Close the websocket connection.
  try {
    await ws.sendCloseAsync(true, 1000, 'Closing this websocket.');
  } catch {
    console.log(ws.lastErrorText);
    return;
  }

  // Read the Close response.
  try {
    await ws.readFrameAsync();
  } catch {
    console.log(`ReadFrame fail reason = ${ws.readFrameFailReason}`);
    console.log(ws.lastErrorText);
    return;
  }

  console.log('Success.');

  // The output of the above code is shown here:

  // {
  //   "echo_req": {
  //     "subscribe": 1,
  //     "ticks": "R_50"
  //   },
  //   "msg_type": "tick",
  //   "tick": {
  //     "ask": "373.8725",
  //     "bid": "373.8325",
  //     "epoch": "1517437456",
  //     "id": "2d3dedf1-45e2-66a5-d0d3-72bd7f0a6ea9",
  //     "quote": "373.8525",
  //     "symbol": "R_50"
  //   }
  // }
  // 
  // {
  //   "echo_req": {
  //     "subscribe": 1,
  //     "ticks": "R_50"
  //   },
  //   "msg_type": "tick",
  //   "tick": {
  //     "ask": "373.7952",
  //     "bid": "373.7552",
  //     "epoch": "1517437458",
  //     "id": "2d3dedf1-45e2-66a5-d0d3-72bd7f0a6ea9",
  //     "quote": "373.7752",
  //     "symbol": "R_50"
  //   }
  // }
  // 
  // {
  //   "echo_req": {
  //     "subscribe": 1,
  //     "ticks": "R_50"
  //   },
  //   "msg_type": "tick",
  //   "tick": {
  //     "ask": "373.8638",
  //     "bid": "373.8238",
  //     "epoch": "1517437460",
  //     "id": "2d3dedf1-45e2-66a5-d0d3-72bd7f0a6ea9",
  //     "quote": "373.8438",
  //     "symbol": "R_50"
  //   }
  // }
  // 
  // {
  //   "echo_req": {
  //     "subscribe": 1,
  //     "ticks": "R_50"
  //   },
  //   "msg_type": "tick",
  //   "tick": {
  //     "ask": "373.7636",
  //     "bid": "373.7236",
  //     "epoch": "1517437462",
  //     "id": "2d3dedf1-45e2-66a5-d0d3-72bd7f0a6ea9",
  //     "quote": "373.7436",
  //     "symbol": "R_50"
  //   }
  // }
  // 
  // {
  //   "echo_req": {
  //     "subscribe": 1,
  //     "ticks": "R_50"
  //   },
  //   "msg_type": "tick",
  //   "tick": {
  //     "ask": "373.6870",
  //     "bid": "373.6470",
  //     "epoch": "1517437464",
  //     "id": "2d3dedf1-45e2-66a5-d0d3-72bd7f0a6ea9",
  //     "quote": "373.6670",
  //     "symbol": "R_50"
  //   }
  // }
  // 
  // Success.
}