<?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:----Tld+O1TYjl7BnJ4g9POnnDicEIc4ec/j6+uyQfCazv0yyfD0NhhcttntY8c99p1lk4W+5w2MbeEXLqlCrAc6bDQwBfixhlLVUZn3Yn/nwQxEK9+Jd47JBEv9R0puIY9ePzomSZkYqt4oAYcf5QEWd6r2FA7VMZQowtQhb/uD28yOh2qQBNQjWlLiV/Oea6GTy+wizHGxA9jY8q4dP+itEVP9+MTv9NGzyGDIclikQYz+4EZiRJbmWPxxNc1Jr3ywBw+hUZoeL1N15ZH6XluM7FCJx35YUgmRQvdnYgmi9GjijEo7H3irKyOsfk2+6eKvg4yN6uAJJwNgv6hYpWgA0pqo0fo9dF9x8zYJiq9KAMlp34aXx3SmZX0nEaDWk5P4cX/ZjkyAFLUCOQ0DDEgOqZc0AVBLSrQWp32EPBdpdiosfKHA7HSxy5chL2fhpDY1fDphpb5W9m98xlkbfCQSM9xph4FnNCH+Zf2rqk3P4W8WC98Gk4KLdhKNKXMcHuIst9JjwUGNeJ/Zk0NYZP/FB2lMCs7RoVafCa9kpj0ywBd2Ya6ukzlsupJTgdm4MzK8Fbw6nh66+btXuKdZKounc4In1Tupv2S0owu/9g4VZo0jUH3bcX5n/WeYLaoIMpuU+KzdRprrjLPNkz78If2TzB5KnDqKoBSZlO3kGz7IGuo=----ATTACHMENT:----MTA5NTc2OTQ1MDI5NDU2NCA1MjE5MjI3NTM2MjU5NjgwIDIwOTk4MDc0OTIxNjk3OTQ=