Perl

Read Bitfinex WebSocket Ticker Channel

See more WebSocket Examples

Subscribes to the public Bitfinex websocket ticker channel and receives ticker updates. Perl

use chilkat();

$success = 0;

# This example requires the Chilkat API to have been previously unlocked.
# See Global Unlock Sample for sample code.

$ws = chilkat::CkWebSocket->new();

# 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 = chilkat::CkRest->new();

# Connect to api.bitfinex.com
$success = $rest->Connect("api.bitfinex.com",443,1,0);
$ws->UseConnection($rest);
$ws->AddClientHeaders();

$responseBody = $rest->fullRequestNoBody("GET","/ws");
$success = $ws->ValidateServerHandshake();
if ($success != 1) {
    print $ws->lastErrorText() . "\r\n";
    print $responseBody . "\r\n";
    print $rest->responseHeader() . "\r\n";
    exit;
}

# After connecting, the bitfinex websocket server will send
# an info message that contains the actual version of the websocket stream.
# Receive that message..
$success = $ws->ReadFrame();
if ($success != 1) {
    print "Failed to receive a frame" . "\r\n";
    print "ReadFrame fail reason = " . $ws->get_ReadFrameFailReason() . "\r\n";
    print $ws->lastErrorText() . "\r\n";
    exit;
}

# We should get this:
# {"event":"info","version":1.1,"platform":{"status":1}}
print $ws->getFrameData() . "\r\n";

# Subscribe to the public ticker feed.
# See https://docs.bitfinex.com/docs for more information.
$json = chilkat::CkJsonObject->new();
$json->AppendString("event","subscribe");
$json->AppendString("channel","ticker");
$json->AppendString("pair","BTCUSD");

$finalFrame = 1;
$success = $ws->SendFrame($json->emit(),$finalFrame);

# Read the response.
$success = $ws->ReadFrame();
if ($success != 1) {
    print "Failed to receive a frame" . "\r\n";
    print "ReadFrame fail reason = " . $ws->get_ReadFrameFailReason() . "\r\n";
    print $ws->lastErrorText() . "\r\n";
    exit;
}

# Examine the response
# We should get this:
# {"event":"subscribed","channel":"ticker","chanId":2751,"pair":"BTCUSD"}
print $ws->getFrameData() . "\r\n";

# Begin reading the ticker feed.
# We'll just read the 1st 5 updates and then exit..
$receivedFinalFrame = 0;
$numUpdatesReceived = 0;
while ($numUpdatesReceived < 5) {

    $success = $ws->ReadFrame();
    if ($success != 1) {
        print "Failed to receive a frame" . "\r\n";
        print "ReadFrame fail reason = " . $ws->get_ReadFrameFailReason() . "\r\n";
        print $ws->lastErrorText() . "\r\n";
        exit;
    }

    # The responses we desire are in Text frames, where the opcode = 1.
    if ($ws->get_FrameOpcodeInt() == 1) {
        $receivedText = $ws->getFrameData();
        print $receivedText . "\r\n";
        # 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]
        $numUpdatesReceived = $numUpdatesReceived + 1;
    }

}

# Close the websocket connection.
$success = $ws->SendClose(1,1000,"Closing this websocket.");
if ($success != 1) {
    print $ws->lastErrorText() . "\r\n";
    exit;
}

# Read the Close response.
$success = $ws->ReadFrame();
if ($success != 1) {
    print "ReadFrame fail reason = " . $ws->get_ReadFrameFailReason() . "\r\n";
    print $ws->lastErrorText() . "\r\n";
    exit;
}

print "Success." . "\r\n";