C
C
Binary.com Tick Stream
See more WebSocket Examples
Tick Stream Request -- Initiate a continuous stream of spot price updates for a given symbol.Chilkat C Downloads
#include <C_CkWebSocket.h>
#include <C_CkRest.h>
#include <C_CkJsonObject.h>
void ChilkatSample(void)
{
BOOL success;
HCkWebSocket ws;
HCkRest rest;
const char *responseBody;
HCkJsonObject json;
BOOL finalFrame;
HCkJsonObject jsonTickData;
BOOL receivedFinalFrame;
int numTicksReceived;
const char *receivedJson;
success = FALSE;
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
ws = CkWebSocket_Create();
// 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.
rest = CkRest_Create();
// Connect to ws.binaryws.com
success = CkRest_Connect(rest,"ws.binaryws.com",443,TRUE,FALSE);
CkWebSocket_UseConnection(ws,rest);
CkWebSocket_AddClientHeaders(ws);
// My app_id is 12332. You'll wnat to use your own...
responseBody = CkRest_fullRequestNoBody(rest,"GET","/websockets/v3?app_id=12332");
success = CkWebSocket_ValidateServerHandshake(ws);
if (success != TRUE) {
printf("%s\n",CkWebSocket_lastErrorText(ws));
printf("%s\n",responseBody);
printf("%s\n",CkRest_responseHeader(rest));
CkWebSocket_Dispose(ws);
CkRest_Dispose(rest);
return;
}
// Build and send the following message:
// {
// "ticks": "R_50",
// "subscribe": 1
// }
json = CkJsonObject_Create();
CkJsonObject_AppendString(json,"ticks","R_50");
CkJsonObject_AppendInt(json,"subscribe",1);
// Send a full message in a single frame
finalFrame = TRUE;
success = CkWebSocket_SendFrame(ws,CkJsonObject_emit(json),finalFrame);
if (success != TRUE) {
printf("%s\n",CkWebSocket_lastErrorText(ws));
CkWebSocket_Dispose(ws);
CkRest_Dispose(rest);
CkJsonObject_Dispose(json);
return;
}
jsonTickData = CkJsonObject_Create();
CkJsonObject_putEmitCompact(jsonTickData,FALSE);
// Begin reading the tick stream response.
// We'll just read the 1st 10 updates and then exit..
receivedFinalFrame = FALSE;
numTicksReceived = 0;
while (numTicksReceived < 5) {
success = CkWebSocket_ReadFrame(ws);
if (success != TRUE) {
printf("Failed to receive a frame\n");
printf("ReadFrame fail reason = %d\n",CkWebSocket_getReadFrameFailReason(ws));
printf("%s\n",CkWebSocket_lastErrorText(ws));
CkWebSocket_Dispose(ws);
CkRest_Dispose(rest);
CkJsonObject_Dispose(json);
CkJsonObject_Dispose(jsonTickData);
return;
}
// The responses we desire are in Text frames, where the opcode = 1.
if (CkWebSocket_getFrameOpcodeInt(ws) == 1) {
receivedJson = CkWebSocket_getFrameData(ws);
CkJsonObject_Load(jsonTickData,receivedJson);
printf("%s\n",CkJsonObject_emit(jsonTickData));
numTicksReceived = numTicksReceived + 1;
}
}
// Close the websocket connection.
success = CkWebSocket_SendClose(ws,TRUE,1000,"Closing this websocket.");
if (success != TRUE) {
printf("%s\n",CkWebSocket_lastErrorText(ws));
CkWebSocket_Dispose(ws);
CkRest_Dispose(rest);
CkJsonObject_Dispose(json);
CkJsonObject_Dispose(jsonTickData);
return;
}
// Read the Close response.
success = CkWebSocket_ReadFrame(ws);
if (success != TRUE) {
printf("ReadFrame fail reason = %d\n",CkWebSocket_getReadFrameFailReason(ws));
printf("%s\n",CkWebSocket_lastErrorText(ws));
CkWebSocket_Dispose(ws);
CkRest_Dispose(rest);
CkJsonObject_Dispose(json);
CkJsonObject_Dispose(jsonTickData);
return;
}
printf("Success.\n");
// 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.
CkWebSocket_Dispose(ws);
CkRest_Dispose(rest);
CkJsonObject_Dispose(json);
CkJsonObject_Dispose(jsonTickData);
}