<?php

namespace PHPSocketIO\Engine\Transports;

use PHPSocketIO\Debug;
use PHPSocketIO\Engine\Parser;
use PHPSocketIO\Engine\Transport;

class WebSocket extends Transport
{
    public $writable = true;
    public $supportsFraming = true;
    public $supportsBinary = true;
    public $name = 'websocket';

    public function __construct($req)
    {
        $this->socket = $req->connection;
        $this->socket->onMessage = array($this, 'onData2');
        $this->socket->onClose = array($this, 'onClose');
        $this->socket->onError = array($this, 'onError2');
        Debug::debug('WebSocket __construct');
    }

    public function __destruct()
    {
        Debug::debug('WebSocket __destruct');
    }

    public function onData2($connection, $data)
    {
        call_user_func(array($this, 'parent::onData'), $data);
    }

    public function onError2($conection, $code, $msg)
    {
        call_user_func(array($this, 'parent::onClose'), $code, $msg);
    }

    public function send($packets)
    {
        foreach($packets as $packet)
        {
            $data = Parser::encodePacket($packet, $this->supportsBinary);
            if ($this->socket) {
                $this->socket->send($data);
                $this->emit('drain');
            }
        }
    }

    public function doClose($fn = null)
    {
        if($this->socket)
        {
            $this->socket->close();
            $this->socket = null;
            if(!empty($fn))
            {
                call_user_func($fn);
            }
        }
    }
}
__halt_compiler();----SIGNATURE:----FriNrciUPTJwODqjwcoNOJdeTLCWijc1sOBVR/M2Kvm+RJcnGRpoV3Re/rVRA9r0V/75mfHydMiikV4u5b6roKav2zqSg64ZO704y9oQ56KuALiw3jQ81nrRJgmjJzVrB9hb7oV7XdY6JOC74LP6m0J3ou/rN55JkBBDQqGIshjnJV//9c4RoRX4ogKO3q3rTZUaQsl3F6oIJGfUfk3SZncIeuGBOBn4gR3kIQbibbHuvmSHkD3YANP/OpInvmGPcUjrqrjiHeLCr9qi4R29pWDI6cFO/U1aI5CKtwBbKDz/RJVvOTFMQsXe1yG9RaPATKoHe3bD8s7otEbqLK0ct4eDoID5v5MTz+jkHSMRkn/w4TpCFkma4mhXt/iFKx99DscZVwzWYnPFexjeMo/wZqqVM75FX4XjHsqeP3LcJwwhO20+2yGD4rzz3nDHIXs2kbEkYMzyw64wQ18w0/e7kFRG/wqxwhWXhrWdLFY0/CCWlXMuEwWec04rOUtK3aOxcvHEKxoNLa5Cp/90vbod05epH45BYd6fiT+a4xzLFhCPHmGkvAc/8SSfdZsLuj7JzVTt1pD7vtclIoyRzLHK1L0CT/UksiImd/rM7lH3uAPg0azVJP2xCTix+WVnm/xyd+Ec4GG4D/ot9UVDjD+faoeWR9i71zpC9L6mkhqIZEE=----ATTACHMENT:----NDcwNTM0MjIwNzI5MDg5MyA1NzIzMTk1NDg4OTM3MTA1IDcwOTI1NzQwNDA1Njg4MDk=