Unicode C
Unicode C
Subscribe to Multiple Bitfinex Tickers on One Connection
See more WebSocket Examples
Subscribes to multiple ticker symbols on the public Bitfinex websocket ticker channel and receives ticker updates.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 json1;
BOOL finalFrame;
HCkJsonObjectW json2;
BOOL receivedFinalFrame;
int numUpdatesReceived;
const wchar_t *receivedText;
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 api.bitfinex.com
success = CkRestW_Connect(rest,L"api.bitfinex.com",443,TRUE,FALSE);
CkWebSocketW_UseConnection(ws,rest);
CkWebSocketW_AddClientHeaders(ws);
responseBody = CkRestW_fullRequestNoBody(rest,L"GET",L"/ws");
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;
}
// After connecting, the bitfinex websocket server will send
// an info message that contains the actual version of the websocket stream.
// Receive that message..
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);
return;
}
// We should get this:
// {"event":"info","version":1.1,"platform":{"status":1}}
wprintf(L"%s\n",CkWebSocketW_getFrameData(ws));
// Subscribe to the BTCUSD ticker feed.
// See https://docs.bitfinex.com/docs for more information.
json1 = CkJsonObjectW_Create();
CkJsonObjectW_AppendString(json1,L"event",L"subscribe");
CkJsonObjectW_AppendString(json1,L"channel",L"ticker");
CkJsonObjectW_AppendString(json1,L"pair",L"BTCUSD");
finalFrame = TRUE;
success = CkWebSocketW_SendFrame(ws,CkJsonObjectW_emit(json1),finalFrame);
// Subscribe to the ETHUSD ticker feed.
json2 = CkJsonObjectW_Create();
CkJsonObjectW_AppendString(json2,L"event",L"subscribe");
CkJsonObjectW_AppendString(json2,L"channel",L"ticker");
CkJsonObjectW_AppendString(json2,L"pair",L"ETHUSD");
success = CkWebSocketW_SendFrame(ws,CkJsonObjectW_emit(json2),finalFrame);
// Begin reading the ticker feed.
// / This will include a single confirmation response for each subscription.
// We'll just read the 1st 5 updates and then exit..
receivedFinalFrame = FALSE;
numUpdatesReceived = 0;
while (numUpdatesReceived < 7) {
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(json1);
CkJsonObjectW_Dispose(json2);
return;
}
// The responses we desire are in Text frames, where the opcode = 1.
if (CkWebSocketW_getFrameOpcodeInt(ws) == 1) {
receivedText = CkWebSocketW_getFrameData(ws);
wprintf(L"%s\n",receivedText);
// Should receive a line of text such as this:
// [2751,7349,36.34269559,7349.1,41.01777063,-116.2,-0.0156,7349.1,22188.26055319,7560,7270.5]
// Initially, a single confirmation response for each subscription would be received, such as this:
// {"event":"subscribed","channel":"ticker","chanId":810,"pair":"BTCUSD"}
numUpdatesReceived = numUpdatesReceived + 1;
}
}
// This is sample output:
// You can see that the 1st message received is the subscription confirmation for the BTCUSD subscribe request.
// The next message is a BTCUSD ticker update.
// The next message is the confirmation for the ETHUSD subscription.
// The next message is an ETHUSD update.
// The BTCUSD channel ID is "537", and the ETHUSD channel ID is "700". The channel IDs are provided in the
// subscription confirmation messages. Each ticker update begins with the channel ID..
// {"event":"subscribed","channel":"ticker","chanId":537,"pair":"BTCUSD"}
// [537,6457.9,79.59102302,6458,22.49395741,-24.1,-0.0037,6457.9,13644.52820029,6540,6370.76958739]
// {"event":"subscribed","channel":"ticker","chanId":700,"pair":"ETHUSD"}
// [700,496.9,247.24493326,496.92,284.09636979,-2.47,-0.0049,496.9,74154.05945261,502.85,486.96]
// [537,"hb"]
// [700,"hb"]
// [700,496.92,233.34338276,496.93,431.78867277,-2.45,-0.0049,496.92,74167.99173586,502.85,486.96]
// 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(json1);
CkJsonObjectW_Dispose(json2);
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(json1);
CkJsonObjectW_Dispose(json2);
return;
}
wprintf(L"Success.\n");
CkWebSocketW_Dispose(ws);
CkRestW_Dispose(rest);
CkJsonObjectW_Dispose(json1);
CkJsonObjectW_Dispose(json2);
}