Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
<?php
/*
* Copyright (c) 2011 Rasmus Fuhse
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License as
* published by the Free Software Foundation; either version 2 of
* the License, or (at your option) any later version.
*/
/**
* Controller called by the main periodical ajax-request. It collects data,
* converts the textstrings to utf8 and returns it as a json-object to the
* internal javascript-function "STUDIP.JSUpdater.process(json)".
*/
class JsupdaterController extends AuthenticatedController
{
// Allow nobody to prevent login screen
// Refers to http://develop.studip.de/trac/ticket/4771
protected $allow_nobody = true;
/**
* Checks whether we have a valid logged in user,
* send "Forbidden" otherwise.
*
* @param String $action The action to perform
* @param Array $args Potential arguments
*/
public function before_filter(&$action, &$args)
{
parent::before_filter($action, $args);
// Check for a valid logged in user (only when an ajax request occurs)
if (Request::isXhr() && (!is_object($GLOBALS['user']) || $GLOBALS['user']->id === 'nobody')) {
$this->response->set_status(403);
$action = 'nop';
}
}
/**
* Does and renders absolute nothing.
*/
public function nop_action()
{
$this->render_nothing();
}
/**
* Main action that returns a json-object like
* {
* 'js_function.sub_function': data,
* 'anotherjs_function.sub_function': moredata
* }
* This action is called by STUDIP.JSUpdater.poll and the result processed
* the internal STUDIP.JSUpdater.process method
*/
public function get_action()
{
UpdateInformation::setInformation("server_timestamp", time());
$data = UpdateInformation::getInformation();
$data = array_merge($data, $this->coreInformation());
$this->set_content_type('application/json;charset=utf-8');
$this->render_text(json_encode($data));
}
/**
* Marks a personal notification as read by the user so it won't be displayed
* in the list in the header.
* @param string $id : hash-id of the notification
*/
public function mark_notification_read_action($id)
{
if ($id === 'all') {
PersonalNotifications::markAllAsRead();
} else {
PersonalNotifications::markAsRead($id);
}
$url = false;
if ($id === 'all') {
$url = Request::get('return_to');
} elseif (!Request::isXhr() || Request::isDialog()) {
$notification = new PersonalNotifications($id);
$url = $notification->url;
}
if ($url) {
$this->redirect(URLHelper::getURL(TransformInternalLinks($url)));
} else {
$this->render_nothing();
}
}
/**
* Sets the background-color of the notification-number to blue, so it does
* not annoy the user anymore. But he/she is still able to see the notificaion-list.
* Just sets a unix-timestamp in the user-config NOTIFICATIONS_SEEN_LAST_DATE.
*/
public function notifications_seen_action()
{
UserConfig::get($GLOBALS['user']->id)->store('NOTIFICATIONS_SEEN_LAST_DATE', time());
$this->render_text(time());
}
/**
* SystemPlugins may call UpdateInformation::setInformation to set information
* to be sent via ajax to the main request. Core-functionality-data should be
* collected and set here.
* @return array: array(array('index' => $data), ...)
*/
protected function coreInformation()
{
$pageInfo = Request::getArray("page_info");
$data = [
'coursewareclipboard' => $this->getCoursewareClipboardUpdates($pageInfo),
'blubber' => $this->getBlubberUpdates($pageInfo),
'messages' => $this->getMessagesUpdates($pageInfo),
'personalnotifications' => $this->getPersonalNotificationUpdates($pageInfo),
'questionnaire' => $this->getQuestionnaireUpdates($pageInfo),
];
return array_filter($data);
}
private function getBlubberUpdates($pageInfo)
{
$data = [];
if (isset($pageInfo['blubber']['threads']) && is_array($pageInfo['blubber']['threads'])) {
$blubber_data = [];
foreach ($pageInfo['blubber']['threads'] as $thread_id) {
$thread = new BlubberThread($thread_id);
if ($thread->isReadable()) {
$comments = BlubberComment::findBySQL(
"thread_id = :thread_id AND chdate >= :time ORDER BY mkdate ASC",
['thread_id' => $thread_id, 'time' => UpdateInformation::getTimestamp()]
);
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
foreach ($comments as $comment) {
$blubber_data[$thread_id][] = $comment->getJSONdata();
}
}
}
if (count($blubber_data)) {
$data['addNewComments'] = $blubber_data;
}
$statement = DBManager::get()->prepare("
SELECT blubber_events_queue.item_id
FROM blubber_events_queue
WHERE blubber_events_queue.event_type = 'delete'
");
$statement->execute([$pageInfo['blubber']['threads']]);
$comment_ids = $statement->fetchAll(PDO::FETCH_COLUMN, 0);
if (count($comment_ids)) {
$data['removeDeletedComments'] = $comment_ids;
}
$statement = DBManager::get()->prepare("
DELETE FROM blubber_events_queue
WHERE mkdate <= UNIX_TIMESTAMP() - 60 * 15
");
$statement->execute();
}
if (mb_stripos(Request::get("page"), "dispatch.php/blubber") !== false) {
//collect updated threads for the widget
$threads = BlubberThread::findMyGlobalThreads(30, UpdateInformation::getTimestamp());
foreach ($threads as $thread) {
'thread_id' => $thread->getId(),
'avatar' => $thread->getAvatar(),
'name' => $thread->getName(),
'timestamp' => (int) $thread->getLatestActivity()
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
}
if (count($thread_widget_data)) {
$data['updateThreadWidget'] = $thread_widget_data;
}
}
return $data;
}
/**
* @SuppressWarnings(PHPMD.Superglobals)
*/
private function getMessagesUpdates($pageInfo)
{
$data = [];
if (mb_stripos(Request::get("page"), "dispatch.php/messages") !== false) {
$messages = Message::findNew(
$GLOBALS["user"]->id,
$pageInfo['messages']['received'],
$pageInfo['messages']['since'],
$pageInfo['messages']['tag']
);
$templateFactory = $this->get_template_factory();
foreach ($messages as $message) {
$attributes = [
'message' => $message,
'received' => $pageInfo['messages']['received'],
'controller' => $this,
];
$html = $templateFactory->open("messages/_message_row.php")
->render($attributes);
$data['messages'][$message->getId()] = $html;
}
}
return $data;
}
/**
* @SuppressWarnings(UnusedFormalParameter)
*/
private function getPersonalNotificationUpdates($pageInfo)
{
$data = [];
if (PersonalNotifications::isActivated()) {
$notifications = PersonalNotifications::getMyNotifications();
if ($notifications && count($notifications)) {
$ret = [];
foreach ($notifications as $notification) {
$info = $notification->toArray();
$info['html'] = $notification->getLiElement();
$ret[] = $info;
}
$data['notifications'] = $ret;
} else {
$data['notifications'] = [];
}
}
return $data;
}
private function getQuestionnaireUpdates($pageInfo)
{
if (
!isset($pageInfo['questionnaire']['questionnaire_ids'])
|| !is_array($pageInfo['questionnaire']['questionnaire_ids'])
) {
return [];
}
Questionnaire::findEachMany(
function (Questionnaire $questionnaire) use ($pageInfo, &$data) {
if ($questionnaire->latestAnswerTimestamp() > $pageInfo['questionnaire']['last_update']) {
$template = $this->get_template_factory()->open("questionnaire/evaluate");
$template->filtered = $pageInfo['questionnaire']['filtered'];
$template->set_layout(null);
$template->set_attribute("questionnaire", $questionnaire);
'html' => $template->render()
];
}
},
$pageInfo['questionnaire']['questionnaire_ids']
);
private function getCoursewareClipboardUpdates($pageInfo)
{
return count(\Courseware\Clipboard::findUsersClipboards($GLOBALS["user"])) != $pageInfo['coursewareclipboard']['counter'];
}