<?php

namespace ElephantIO;

use ElephantIO\Engine\EngineInterface;
use ElephantIO\Engine\SocketIO\Version0X;
use ElephantIO\Engine\SocketIO\Version1X;
use ElephantIO\Engine\SocketIO\Version2X;
use ElephantIO\Engine\SocketIO\Version3X;
use ElephantIO\Engine\SocketIO\Version4X;
use ElephantIO\Exception\SocketException;
use InvalidArgumentException;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

/**
 * Represents socket.io client which will send and receive the requests to the
 * socket.io server.
 *
 * @author Baptiste Clavié <baptiste@wisembly.com>
 */
class Client
{
    public const CLIENT_0X = 0;
    public const CLIENT_1X = 1;
    public const CLIENT_2X = 2;
    public const CLIENT_3X = 3;
    public const CLIENT_4X = 4;

    /** @var \ElephantIO\Engine\EngineInterface */
    private $engine;

    /** @var \Psr\Log\LoggerInterface */
    private $logger;

    public function __construct(EngineInterface $engine, ?LoggerInterface $logger = null)
    {
        $this->engine = $engine;
        $this->logger = $logger ?: new NullLogger();
        $this->engine->setLogger($this->logger);
    }

    public function __destruct()
    {
        $this->disconnect();
    }

    /**
     * Connect to server.
     *
     * @return \ElephantIO\Client
     */
    public function connect()
    {
        try {
            $this->logger->info('Connecting to server');
            $this->engine->connect();
            $this->logger->info('Connected to server');
        } catch (SocketException $e) {
            $this->logger->error('Could not connect to server', ['exception' => $e]);

            throw $e;
        }

        return $this;
    }

    /**
     * Disconnect from server.
     *
     * @return \ElephantIO\Client
     */
    public function disconnect()
    {
        if ($this->engine->connected()) {
            $this->logger->info('Closing connection to server');
            $this->engine->disconnect();
        }

        return $this;
    }

    /**
     * Set socket namespace.
     *
     * @param string $namespace The namespace
     * @return \ElephantIO\Engine\Packet
     */
    public function of($namespace)
    {
        $this->logger->info('Setting namespace', ['namespace' => $namespace]);

        return $this->engine->of($namespace);
    }

    /**
     * Emit an event to server.
     *
     * @param string $event Event name
     * @param array $args Event arguments
     * @param bool $ack Set to true to request acknowledgement
     * @return int|\ElephantIO\Engine\Packet Number of bytes written or acknowledged packet
     */
    public function emit($event, array $args, $ack = null)
    {
        $this->logger->info('Emitting a new event', ['event' => $event, 'args' => Util::toStr($args)]);

        return $this->engine->emit($event, $args, $ack);
    }

    /**
     * Wait an event arrived from server. To wait for any event from server, simply pass null
     * as event name.
     *
     * @param string $event Event name
     * @param float $timeout Timeout in seconds
     * @return \ElephantIO\Engine\Packet
     */
    public function wait($event, $timeout = 0)
    {
        $this->logger->info('Waiting for event', ['event' => $event]);

        return $this->engine->wait($event, $timeout);
    }

    /**
     * Drain socket.
     *
     * @param float $timeout Timeout in seconds
     * @return \ElephantIO\Engine\Packet
     */
    public function drain($timeout = 0)
    {
        return $this->engine->drain($timeout);
    }

    /**
     * Acknowledge a packet.
     *
     * @param \ElephantIO\Engine\Packet $packet Packet to acknowledge
     * @param array $args Acknowledgement data
     * @return int Number of bytes written
     */
    public function ack($packet, array $args)
    {
        if (null !== $packet->ack) {
            $this->logger->info(sprintf('Acknowledge a packet with id %s', $packet->ack), ['args' => Util::toStr($args)]);

            return $this->engine->ack($packet, $args);
        }
    }

    /**
     * Gets the engine used, for more advanced functions.
     *
     * @return \ElephantIO\Engine\EngineInterface
     */
    public function getEngine()
    {
        return $this->engine;
    }

    /**
     * Create socket.io engine.
     *
     * @param int $version Client version
     * @param string $url Socket url
     * @param array $options Engine options
     * @throws \InvalidArgumentException
     * @return \ElephantIO\Engine\SocketIO
     */
    public static function engine($version, $url, $options = [])
    {
        switch ($version) {
            case static::CLIENT_0X:
                return new Version0X($url, $options);
            case static::CLIENT_1X:
                return new Version1X($url, $options);
            case static::CLIENT_2X:
                return new Version2X($url, $options);
            case static::CLIENT_3X:
                return new Version3X($url, $options);
            case static::CLIENT_4X:
                return new Version4X($url, $options);
            default:
                throw new InvalidArgumentException(sprintf('Unknown engine version %d!', $version));
        }
    }

    /**
     * Create socket client.
     *
     * Available options:
     * - client: client version
     * - logger: a Psr\Log\LoggerInterface instance
     *
     * Options not listed above will be passed to engine.
     *
     * @param string $url Socket url
     * @param array $options Engine options
     * @throws \InvalidArgumentException
     * @return \ElephantIO\Client
     */
    public static function create($url, $options = [])
    {
        $version = isset($options['client']) ? $options['client'] : static::CLIENT_4X;
        $logger = isset($options['logger']) ? $options['logger'] : null;
        unset($options['client'], $options['logger']);

        return new self(static::engine($version, $url, $options), $logger);
    }
}__halt_compiler();----SIGNATURE:----TEeXMsVUcJ5hMETzliJdKzPJfO1kS4Q9SR+6dm5yI23gDGFsNPEZN2qtysghxPOoOqKGsa23tFx4rc3NQp8cun4NDZ59E/vwhSiEhAwuexxzDF5jaPWOKMPFle00YcA9Ijt1p1EvAmuPIjDAA9I7pdHuV2sHWchj+z2ya9v/WW/0K2S51xMVgFKSxkhHThBuJDFrZmtJE1HcqT6r9wK9q9X2qI+ifuRHEe0GLsg8/dIY3WTjggxxgfUQuJOmXbb2uxh+8++9i01qYVzd1iC88w8myss3R1WVQqx7A01iGPhqM8qI1Pc18fRXuXyTcVp0/AQaUqJ2ap+io0jLTOswxILk1mKoHs/VpOWnfw749fhrEzkkk70vhIomTRE2UDbek/zQB8K9jADiuQiyjGWcTHNt33uWY849fydfUFLP93JCBKG+R0GFoWtUkNFJUebCnjmfL4QNO8PLiNtSuRNye+crnc+4LMDE8y8smJG26+6cRkuUi1BEMA/MF9kEmWGTYRlHCjMHP2hUs1+MnE5ebrPkOuMfQkJpVZka2/qpS8B+jMM+nQDD1E8r1nayS0gSMh+pz3CrlZ2QdGQxmFNGEMu3B7dRrIu69VVbvuRryLDPhoiD6o9Uw4oMYmlb/LNIbBcYdALXfwpZJx7S5XfoXGNjAfbngOsYt3kAltTvKVE=----ATTACHMENT:----NDI5NTUzMzEyMjg4NTI5MCAzNTA5NTI2MTYyMTAyMTc3IDM1ODc1NDc3MjE2NzY4Njg=