class.ilChatroomServerConnector.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2009 ILIAS open source, Extended GPL, see docs/LICENSE */

class ilChatroomServerConnector
{
        protected static $connection_status = null;

        private $settings;

        public function __construct(ilChatroomServerSettings $settings)
        {
                $this->settings = $settings;
        }

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

                require_once 'Modules/Chatroom/classes/class.ilChatroomAdmin.php';
                $connector               = new self(ilChatroomAdmin::getDefaultConfiguration()->getServerSettings());
                self::$connection_status = (bool)$connector->isServerAlive();

                return self::$connection_status;
        }

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

                $responseObject = json_decode($response);

                return $responseObject->status == 200;
        }

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

        protected function file_get_contents($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 = array(
                        'http'  => array(
                                'method' => 'GET',
                                'header' => $header
                        ),
                        'https' => array(
                                'method' => 'GET',
                                'header' => $header
                        )
                );

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

                set_error_handler(function ($severity, $message, $file, $line)
                {
                        throw new ErrorException($message, $severity, $severity, $file, $line);
                });

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

                return false;
        }

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

        public function sendDeletePrivateRoom($scope, $subScope, $user)
        {
                return $this->file_get_contents(
                        $this->settings->getURL('DeletePrivateRoom', $scope) . '/' . $subScope . '/' . $user
                );
        }

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

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

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

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

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

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

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

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

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

        public function sendMessage($scope, $message, $options = array())
        {
                $query    = http_build_query(array('message' => $message) + $options);
                $response = $this->post($scope, $query);
                return @json_decode($response);
        }

        public function post($scope, $query)
        {
                return $this->file_get_contents(
                        $this->settings->getURL('Post', $scope) . '?' . $query
                );
        }

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

        public function createUniqueScopeId($roomId, $pRoomId = null)
        {
                if($pRoomId != null)
                {
                        $roomId .= '-' . $pRoomId;
                }

                return $roomId;
        }

        public function sendUserConfigChange($message)
        {
                $query = http_build_query(array('message' => $message));
                return $this->file_get_contents(
                        $this->settings->getURL('UserConfigChange', null) . '?' . $query);
        }
}