class.ilChatroomServerHandler.php

Go to the documentation of this file.

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

require_once 'Modules/Chatroom/classes/class.ilChatroom.php';

class ilChatroomServerHandler
{
        public function __construct()
        {
                $this->handleCommand($_REQUEST['task']);
                exit;
        }

        private function handleCommand($task)
        {
                switch($task)
                {
                        case 'disconnectedUsers':
                                if(isset($_REQUEST['scope']))
                                {
                                        $this->disconnectedUsers($_REQUEST['scope']);
                                }
                                $this->cleanupPrivateRooms();
                                break;
                        case 'serverStarted':
                                $this->serverStarted();
                                break;
                }
        }

        private function disconnectedUsers($usersByScope)
        {
                require_once 'Modules/Chatroom/classes/class.ilChatroom.php';

                foreach($usersByScope as $scope => $users)
                {
                        $users    = explode(',', $users);
                        $chatroom = ilChatroom::byRoomId($scope);

                        if($chatroom instanceof ilChatroom && is_array($users))
                        {
                                $users       = array_filter($users);
                                $userDetails = $this->getUserInformation($users);
                                $message     = json_encode(array(
                                        'type'      => 'disconnected',
                                        'users'     => $userDetails,
                                        'timestamp' => date('c')
                                ));

                                $chatroom->disconnectUsers($users);

                                if(!isset($_REQUEST['handledAction']) || $_REQUEST['handledAction'] != 'kick')
                                {
                                        $this->getConnector()->sendMessage($chatroom->getRoomId(), $message);
                                }

                                if(true || $chatroom->getSetting('enable_history'))
                                {
                                        $messageObject = array(
                                                'type'      => 'disconnected',
                                                'users'     => $userDetails,
                                                'timestamp' => date('c')
                                        );

                                        $chatroom->addHistoryEntry($messageObject);
                                }
                        }
                }
        }

        private function getUserInformation($user_ids)
        {
                global $ilDB;

                $rset  = $ilDB->query('SELECT userdata FROM chatroom_users WHERE ' . $ilDB->in('user_id', $user_ids, false, 'integer'));
                $users = array();
                while($row = $ilDB->fetchAssoc($rset))
                {
                        $users[] = json_decode($row['userdata']);
                }
                return $users;
        }

        public function getConnector()
        {
                require_once 'Modules/Chatroom/classes/class.ilChatroomServerConnector.php';
                require_once 'Modules/Chatroom/classes/class.ilChatroomAdmin.php';

                $settings  = ilChatroomAdmin::getDefaultConfiguration()->getServerSettings();
                $connector = new ilChatroomServerConnector($settings);

                return $connector;
        }

        public function cleanupPrivateRooms()
        {
                $deletableRooms = ilChatroom::findDeletablePrivateRooms();

                $connector = $this->getConnector();

                foreach($deletableRooms as $deletableRoom)
                {

                        $room = ilChatroom::byObjectId($deletableRoom['object_id']);

                        $params['user'] = -1; //$chat_user->getUserId();
                        $room->closePrivateRoom($deletableRoom['proom_id']);
                        $query = http_build_query($params);

                        $message = json_encode(array(
                                'type'      => 'private_room_deleted',
                                'timestamp' => date('c'),
                                'public'    => 1,
                                'id'        => $deletableRoom['proom_id'],
                                'proom_id'  => $deletableRoom['proom_id'],
                                'message'   => array(
                                        'message' => 'room deleted',
                                        'public'  => '1',
                                        'user'    => 'system'
                                )
                        ));

                        $result = $connector->sendMessage($room->getRoomId(), $message, array('public' => 1));

                }
        }

        private function serverStarted()
        {
                require_once 'Modules/Chatroom/classes/class.ilChatroom.php';

                ilChatroom::disconnectAllUsersFromAllRooms();
        }
}

?>