DataFlex
DataFlex
Binary.com Tick Stream
See more WebSocket Examples
Tick Stream Request -- Initiate a continuous stream of spot price updates for a given symbol.Chilkat DataFlex Downloads
Use ChilkatAx-win32.pkg
Procedure Test
Boolean iSuccess
Handle hoWs
Variant vRest
Handle hoRest
String sResponseBody
Handle hoJson
Boolean iFinalFrame
Handle hoJsonTickData
Boolean iReceivedFinalFrame
Integer iNumTicksReceived
String sReceivedJson
String sTemp1
Integer iTemp1
Move False To iSuccess
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
Get Create (RefClass(cComChilkatWebSocket)) To hoWs
If (Not(IsComObjectCreated(hoWs))) Begin
Send CreateComObject of hoWs
End
// 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.
Get Create (RefClass(cComChilkatRest)) To hoRest
If (Not(IsComObjectCreated(hoRest))) Begin
Send CreateComObject of hoRest
End
// Connect to ws.binaryws.com
Get ComConnect Of hoRest "ws.binaryws.com" 443 True False To iSuccess
Get pvComObject of hoRest to vRest
Get ComUseConnection Of hoWs vRest To iSuccess
Get ComAddClientHeaders Of hoWs To iSuccess
// My app_id is 12332. You'll wnat to use your own...
Get ComFullRequestNoBody Of hoRest "GET" "/websockets/v3?app_id=12332" To sResponseBody
Get ComValidateServerHandshake Of hoWs To iSuccess
If (iSuccess <> True) Begin
Get ComLastErrorText Of hoWs To sTemp1
Showln sTemp1
Showln sResponseBody
Get ComResponseHeader Of hoRest To sTemp1
Showln sTemp1
Procedure_Return
End
// Build and send the following message:
// {
// "ticks": "R_50",
// "subscribe": 1
// }
Get Create (RefClass(cComChilkatJsonObject)) To hoJson
If (Not(IsComObjectCreated(hoJson))) Begin
Send CreateComObject of hoJson
End
Get ComAppendString Of hoJson "ticks" "R_50" To iSuccess
Get ComAppendInt Of hoJson "subscribe" 1 To iSuccess
// Send a full message in a single frame
Move True To iFinalFrame
Get ComEmit Of hoJson To sTemp1
Get ComSendFrame Of hoWs sTemp1 iFinalFrame To iSuccess
If (iSuccess <> True) Begin
Get ComLastErrorText Of hoWs To sTemp1
Showln sTemp1
Procedure_Return
End
Get Create (RefClass(cComChilkatJsonObject)) To hoJsonTickData
If (Not(IsComObjectCreated(hoJsonTickData))) Begin
Send CreateComObject of hoJsonTickData
End
Set ComEmitCompact Of hoJsonTickData To False
// Begin reading the tick stream response.
// We'll just read the 1st 10 updates and then exit..
Move False To iReceivedFinalFrame
Move 0 To iNumTicksReceived
While (iNumTicksReceived < 5)
Get ComReadFrame Of hoWs To iSuccess
If (iSuccess <> True) Begin
Showln "Failed to receive a frame"
Get ComReadFrameFailReason Of hoWs To iTemp1
Showln "ReadFrame fail reason = " iTemp1
Get ComLastErrorText Of hoWs To sTemp1
Showln sTemp1
Procedure_Return
End
// The responses we desire are in Text frames, where the opcode = 1.
Get ComFrameOpcodeInt Of hoWs To iTemp1
If (iTemp1 = 1) Begin
Get ComGetFrameData Of hoWs To sReceivedJson
Get ComLoad Of hoJsonTickData sReceivedJson To iSuccess
Get ComEmit Of hoJsonTickData To sTemp1
Showln sTemp1
Move (iNumTicksReceived + 1) To iNumTicksReceived
End
Loop
// Close the websocket connection.
Get ComSendClose Of hoWs True 1000 "Closing this websocket." To iSuccess
If (iSuccess <> True) Begin
Get ComLastErrorText Of hoWs To sTemp1
Showln sTemp1
Procedure_Return
End
// Read the Close response.
Get ComReadFrame Of hoWs To iSuccess
If (iSuccess <> True) Begin
Get ComReadFrameFailReason Of hoWs To iTemp1
Showln "ReadFrame fail reason = " iTemp1
Get ComLastErrorText Of hoWs To sTemp1
Showln sTemp1
Procedure_Return
End
Showln "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.
End_Procedure