Unicode C
Unicode 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 Unicode C Downloads
#include <C_CkWebSocketW.h>
#include <C_CkRestW.h>
#include <C_CkJsonObjectW.h>
void ChilkatSample(void)
{
BOOL success;
HCkWebSocketW ws;
HCkRestW rest;
const wchar_t *responseBody;
HCkJsonObjectW json;
BOOL finalFrame;
HCkJsonObjectW jsonTickData;
BOOL receivedFinalFrame;
int numTicksReceived;
const wchar_t *receivedJson;
success = FALSE;
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
ws = CkWebSocketW_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 = CkRestW_Create();
// Connect to ws.binaryws.com
success = CkRestW_Connect(rest,L"ws.binaryws.com",443,TRUE,FALSE);
CkWebSocketW_UseConnection(ws,rest);
CkWebSocketW_AddClientHeaders(ws);
// My app_id is 12332. You'll wnat to use your own...
responseBody = CkRestW_fullRequestNoBody(rest,L"GET",L"/websockets/v3?app_id=12332");
success = CkWebSocketW_ValidateServerHandshake(ws);
if (success != TRUE) {
wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws));
wprintf(L"%s\n",responseBody);
wprintf(L"%s\n",CkRestW_responseHeader(rest));
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
return;
}
// Build and send the following message:
// {
// "ticks": "R_50",
// "subscribe": 1
// }
json = CkJsonObjectW_Create();
CkJsonObjectW_AppendString(json,L"ticks",L"R_50");
CkJsonObjectW_AppendInt(json,L"subscribe",1);
// Send a full message in a single frame
finalFrame = TRUE;
success = CkWebSocketW_SendFrame(ws,CkJsonObjectW_emit(json),finalFrame);
if (success != TRUE) {
wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws));
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
CkJsonObjectW_Dispose(json);
return;
}
jsonTickData = CkJsonObjectW_Create();
CkJsonObjectW_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 = CkWebSocketW_ReadFrame(ws);
if (success != TRUE) {
wprintf(L"Failed to receive a frame\n");
wprintf(L"ReadFrame fail reason = %d\n",CkWebSocketW_getReadFrameFailReason(ws));
wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws));
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
CkJsonObjectW_Dispose(json);
CkJsonObjectW_Dispose(jsonTickData);
return;
}
// The responses we desire are in Text frames, where the opcode = 1.
if (CkWebSocketW_getFrameOpcodeInt(ws) == 1) {
receivedJson = CkWebSocketW_getFrameData(ws);
CkJsonObjectW_Load(jsonTickData,receivedJson);
wprintf(L"%s\n",CkJsonObjectW_emit(jsonTickData));
numTicksReceived = numTicksReceived + 1;
}
}
// Close the websocket connection.
success = CkWebSocketW_SendClose(ws,TRUE,1000,L"Closing this websocket.");
if (success != TRUE) {
wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws));
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
CkJsonObjectW_Dispose(json);
CkJsonObjectW_Dispose(jsonTickData);
return;
}
// Read the Close response.
success = CkWebSocketW_ReadFrame(ws);
if (success != TRUE) {
wprintf(L"ReadFrame fail reason = %d\n",CkWebSocketW_getReadFrameFailReason(ws));
wprintf(L"%s\n",CkWebSocketW_lastErrorText(ws));
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
CkJsonObjectW_Dispose(json);
CkJsonObjectW_Dispose(jsonTickData);
return;
}
wprintf(L"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.
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
CkJsonObjectW_Dispose(json);
CkJsonObjectW_Dispose(jsonTickData);
}