Merge branch 'wip-MDL-43398-master' of git://github.com/marinaglancy/moodle
[moodle.git] / mod / chat / chat_ajax.php
1 <?php
2 // This file is part of Moodle - http://moodle.org/
3 //
4 // Moodle is free software: you can redistribute it and/or modify
5 // it under the terms of the GNU General Public License as published by
6 // the Free Software Foundation, either version 3 of the License, or
7 // (at your option) any later version.
8 //
9 // Moodle is distributed in the hope that it will be useful,
10 // but WITHOUT ANY WARRANTY; without even the implied warranty of
11 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12 // GNU General Public License for more details.
13 //
14 // You should have received a copy of the GNU General Public License
15 // along with Moodle.  If not, see <http://www.gnu.org/licenses/>.
17 define('AJAX_SCRIPT', true);
19 require_once(dirname(dirname(dirname(__FILE__))) . '/config.php');
20 require_once(dirname(__FILE__) . '/lib.php');
22 $action       = optional_param('action', '', PARAM_ALPHANUM);
23 $beep_id      = optional_param('beep', '', PARAM_RAW);
24 $chat_sid     = required_param('chat_sid', PARAM_ALPHANUM);
25 $theme        = required_param('theme', PARAM_ALPHANUMEXT);
26 $chat_message = optional_param('chat_message', '', PARAM_RAW);
27 $chat_lasttime = optional_param('chat_lasttime', 0, PARAM_INT);
28 $chat_lastrow  = optional_param('chat_lastrow', 1, PARAM_INT);
30 if (!confirm_sesskey()) {
31     throw new moodle_exception('invalidsesskey', 'error');
32 }
34 if (!$chatuser = $DB->get_record('chat_users', array('sid'=>$chat_sid))) {
35     throw new moodle_exception('notlogged', 'chat');
36 }
37 if (!$chat = $DB->get_record('chat', array('id'=>$chatuser->chatid))) {
38     throw new moodle_exception('invaliduserid', 'error');
39 }
40 if (!$course = $DB->get_record('course', array('id'=>$chat->course))) {
41     throw new moodle_exception('invalidcourseid', 'error');
42 }
43 if (!$cm = get_coursemodule_from_instance('chat', $chat->id, $course->id)) {
44     throw new moodle_exception('invalidcoursemodule', 'error');
45 }
47 if (!isloggedin()) {
48     throw new moodle_exception('notlogged', 'chat');
49 }
51 // setup $PAGE so that format_text will work properly
52 $PAGE->set_cm($cm, $course, $chat);
53 $PAGE->set_url('/mod/chat/chat_ajax.php', array('chat_sid'=>$chat_sid));
55 require_login($course, false, $cm);
57 $context = context_module::instance($cm->id);
58 require_capability('mod/chat:chat', $context);
60 ob_start();
61 header('Expires: Sun, 28 Dec 1997 09:32:45 GMT');
62 header('Last-Modified: '.gmdate('D, d M Y H:i:s').' GMT');
63 header('Cache-Control: no-cache, must-revalidate');
64 header('Pragma: no-cache');
65 header('Content-Type: text/html; charset=utf-8');
67 switch ($action) {
68 case 'init':
69     $users = chat_get_users($chatuser->chatid, $chatuser->groupid, $cm->groupingid);
70     $users = chat_format_userlist($users, $course);
71     $response['users'] = $users;
72     echo json_encode($response);
73     break;
75 case 'chat':
76     \core\session\manager::write_close();
77     chat_delete_old_users();
78     $chat_message = clean_text($chat_message, FORMAT_MOODLE);
80     if (!empty($beep_id)) {
81         $chat_message = 'beep '.$beep_id;
82     }
84     if (!empty($chat_message)) {
86         chat_send_chatmessage($chatuser, $chat_message, 0, $cm);
88         $chatuser->lastmessageping = time() - 2;
89         $DB->update_record('chat_users', $chatuser);
91         // Response OK message.
92         echo json_encode(true);
93         ob_end_flush();
94     }
95     break;
97 case 'update':
98     if ((time() - $chat_lasttime) > $CFG->chat_old_ping) {
99         chat_delete_old_users();
100     }
102     if ($latest_message = chat_get_latest_message($chatuser->chatid, $chatuser->groupid)) {
103         $chat_newlasttime = $latest_message->timestamp;
104     } else {
105         $chat_newlasttime = 0;
106     }
108     if ($chat_lasttime == 0) {
109         $chat_lasttime = time() - $CFG->chat_old_ping;
110     }
112     $params = array('groupid'=>$chatuser->groupid, 'chatid'=>$chatuser->chatid, 'lasttime'=>$chat_lasttime);
114     $groupselect = $chatuser->groupid ? " AND (groupid=".$chatuser->groupid." OR groupid=0) " : "";
116     $messages = $DB->get_records_select('chat_messages_current',
117         'chatid = :chatid AND timestamp > :lasttime '.$groupselect, $params,
118         'timestamp ASC');
120     if (!empty($messages)) {
121         $num = count($messages);
122     } else {
123         $num = 0;
124     }
125     $chat_newrow = ($chat_lastrow + $num) % 2;
126     $send_user_list = false;
127     if ($messages && ($chat_lasttime != $chat_newlasttime)) {
128         foreach ($messages as $n => &$message) {
129             $tmp = new stdClass();
130             // when somebody enter room, user list will be updated
131             if (!empty($message->system)){
132                 $send_user_list = true;
133                 $users = chat_format_userlist(chat_get_users($chatuser->chatid, $chatuser->groupid, $cm->groupingid), $course);
134             }
135             if ($html = chat_format_message_theme($message, $chatuser, $USER, $cm->groupingid, $theme)) {
136                 $message->mymessage = ($USER->id == $message->userid);
137                 $message->message  = $html->html;
138                 if (!empty($html->type)) {
139                     $message->type = $html->type;
140                 }
141             } else {
142                 unset($messages[$n]);
143             }
144         }
145     }
147     if(!empty($users) && $send_user_list){
148         // return users when system message coming
149         $response['users'] = $users;
150     }
152     $DB->set_field('chat_users', 'lastping', time(), array('id'=>$chatuser->id));
154     $response['lasttime'] = $chat_newlasttime;
155     $response['lastrow']  = $chat_newrow;
156     if($messages){
157         $response['msgs'] = $messages;
158     }
160     echo json_encode($response);
161     header('Content-Length: ' . ob_get_length() );
163     ob_end_flush();
164     break;
166 default:
167     break;