class.ilChatroomServerConnector.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

class ilChatroomServerConnector
{
    protected static ?bool $connection_status = null;

    public function __construct(private readonly ilChatroomServerSettings $settings)
    {
    }

    public static function checkServerConnection(bool $use_cache = true): bool
    {
        if ($use_cache && self::$connection_status !== null) {
            return self::$connection_status;
        }

        $connector = new self(ilChatroomAdmin::getDefaultConfiguration()->getServerSettings());
        self::$connection_status = $connector->isServerAlive();

        return self::$connection_status;
    }

    public function isServerAlive(): bool
    {
        $response = $this->file_get_contents(
            $this->settings->getURL('Heartbeat'),
            [
                'http' => [
                    'timeout' => 2
                ],
                'https' => [
                    'timeout' => 2
                ]
            ]
        );

        if (false === $response) {
            return false;
        }

        $responseObject = json_decode($response, false, 512, JSON_THROW_ON_ERROR);

        return $responseObject instanceof stdClass && ((int) $responseObject->status) === 200;
    }

    public function connect(int $scope, int $userId)
    {
        return $this->file_get_contents(
            $this->settings->getURL('Connect', (string) $scope) . '/' . $userId
        );
    }

    protected function file_get_contents(string $url, ?array $stream_context_params = null)
    {
        $credentials = $this->settings->getAuthKey() . ':' . $this->settings->getAuthSecret();
        $header =
            "Connection: close\r\n" .
            "Content-Type: application/json; charset=utf-8\r\n" .
            "Authorization: Basic " . base64_encode($credentials);

        $ctx = [
            'http' => [
                'method' => 'GET',
                'header' => $header
            ],
            'https' => [
                'method' => 'GET',
                'header' => $header
            ]
        ];

        if (is_array($stream_context_params)) {
            $ctx = array_merge_recursive($ctx, $stream_context_params);
        }

        set_error_handler(static function (int $severity, string $message, string $file, int $line): never {
            throw new ErrorException($message, $severity, $severity, $file, $line);
        });

        try {
            return file_get_contents($url, false, stream_context_create($ctx));
        } catch (Exception $e) {
            ilLoggerFactory::getLogger('chatroom')->alert($e->getMessage());
        } finally {
            restore_error_handler();
        }

        return false;
    }

    public function sendCreatePrivateRoom(int $scope, int $user, string $title)
    {
        return $this->file_get_contents(
            $this->settings->getURL('CreatePrivateRoom', (string) $scope) .
            '/' . $user . '/' . rawurlencode($title)
        );
    }

    public function enterPrivateRoom(int $scope, int $user)
    {
        return $this->sendEnterPrivateRoom($scope, $user);
    }

    public function sendEnterPrivateRoom(int $scope, int $user)
    {
        return $this->file_get_contents(
            $this->settings->getURL('EnterPrivateRoom', (string) $scope) . '/' . $user
        );
    }

    public function sendClearMessages(int $scope, int $user)
    {
        return $this->file_get_contents(
            $this->settings->getURL('ClearMessages', (string) $scope) . '/' . $user
        );
    }

    public function leavePrivateRoom(int $scope, int $user)
    {
        return $this->sendLeavePrivateRoom($scope, $user);
    }

    public function sendLeavePrivateRoom(int $scope, int $user)
    {
        return $this->file_get_contents(
            $this->settings->getURL('LeavePrivateRoom', (string) $scope) . '/' . $user
        );
    }

    public function sendKick(int $scope, int $user)
    {
        return $this->kick($scope, $user);
    }

    public function kick(int $scope, int $user)
    {
        return $this->file_get_contents(
            $this->settings->getURL('Kick', (string) $scope) . '/' . $user
        );
    }

    public function sendBan(int $scope, int $user)
    {
        return $this->file_get_contents(
            $this->settings->getURL('Ban', (string) $scope) . '/' . $user
        );
    }

    public function getSettings(): ilChatroomServerSettings
    {
        return $this->settings;
    }

    public function sendInviteToPrivateRoom(int $scope, int $user, int $invited_id)
    {
        return $this->file_get_contents(
            $this->settings->getURL('InvitePrivateRoom', (string) $scope) .
            '/' . $user . '/' . $invited_id
        );
    }

    public function sendUserConfigChange(string $message)
    {
        $query = http_build_query(['message' => $message]);

        return $this->file_get_contents(
            $this->settings->getURL('UserConfigChange', null) . '?' . $query
        );
    }
}