<?php
/**
 * Orange Management
 *
 * PHP Version 7.4
 *
 * @package   phpOMS\Socket\Client
 * @copyright Dennis Eichhorn
 * @license   OMS License 1.0
 * @version   1.0.0
 * @link      https://orange-management.org
 */
declare(strict_types=1);

namespace phpOMS\Socket\Client;

use phpOMS\Socket\CommandManager;
use phpOMS\Socket\SocketAbstract;

/**
 * Client socket class.
 *
 * @package phpOMS\Socket\Client
 * @license OMS License 1.0
 * @link    https://orange-management.org
 * @since   1.0.0
 */
class Client extends SocketAbstract
{
    private $commands;

    /**
     * Constructor.
     *
     * @since 1.0.0
     */
    public function __construct()
    {
        $this->commands = new CommandManager();

        /** @noinspection PhpUnusedParameterInspection */
        $this->commands->attach('disconnect', function ($conn, $para) : void {
            $this->disconnect();
        }, $this);
    }

    /**
     * Disconnect from server.
     *
     * @return void
     *
     * @since 1.0.0
     */
    private function disconnect() : void
    {
        $this->run = false;
    }

    /**
     * {@inheritdoc}
     */
    public function create(string $ip, int $port) : void
    {
        parent::create($ip, $port);
    }

    /**
     * {@inheritdoc}
     */
    public function run() : void
    {
        \socket_connect($this->sock, $this->ip, $this->port);
        $i = 0;

        $errorCounter = 0;

        while ($this->run) {
            try {
                ++$i;
                $msg = 'disconnect';
                \socket_write($this->sock, $msg, \strlen($msg));

                $read = [$this->sock];

                if (\socket_last_error() !== 0) {
                    ++$errorCounter;
                }

                // todo: create reset condition for errorCounter. Probably if a successfull read happened

                //if (socket_select($read, $write = null, $except = null, 0) < 1) {
                // error
                // socket_last_error();
                // socket_strerror(socket_last_error());
                //}

                if (\count($read) > 0) {
                    $data = \socket_read($this->sock, 1024);

                    /* Server no data */
                    if ($data === false) {
                        continue;
                    }

                    /* Normalize */
                    $data = \trim($data);

                    if (!empty($data)) {
                        $data = \explode(' ', $data);
                        $this->commands->trigger($data[0], 0, $data);
                    }
                }

                if ($errorCounter > 10) {
                    $this->run = false;
                }
            } catch (\Throwable $e) {
                $this->run = false;
            }
        }

        $this->close();
    }

    /**
     * {@inheritdoc}
     */
    public function close() : void
    {
        parent::close();
    }

    /**
     * {@inheritdoc}
     */
    public function __destruct()
    {
        parent::__destruct();
    }
}