@@ -60,494 +60,494 @@ |
||
60 | 60 | */ |
61 | 61 | class IMipPlugin extends SabreIMipPlugin { |
62 | 62 | |
63 | - /** @var string */ |
|
64 | - private $userId; |
|
65 | - |
|
66 | - /** @var IConfig */ |
|
67 | - private $config; |
|
68 | - |
|
69 | - /** @var IMailer */ |
|
70 | - private $mailer; |
|
71 | - |
|
72 | - /** @var ILogger */ |
|
73 | - private $logger; |
|
74 | - |
|
75 | - /** @var ITimeFactory */ |
|
76 | - private $timeFactory; |
|
77 | - |
|
78 | - /** @var L10NFactory */ |
|
79 | - private $l10nFactory; |
|
80 | - |
|
81 | - /** @var IURLGenerator */ |
|
82 | - private $urlGenerator; |
|
83 | - |
|
84 | - /** @var ISecureRandom */ |
|
85 | - private $random; |
|
86 | - |
|
87 | - /** @var IDBConnection */ |
|
88 | - private $db; |
|
89 | - |
|
90 | - /** @var Defaults */ |
|
91 | - private $defaults; |
|
92 | - |
|
93 | - const MAX_DATE = '2038-01-01'; |
|
94 | - |
|
95 | - const METHOD_REQUEST = 'request'; |
|
96 | - const METHOD_REPLY = 'reply'; |
|
97 | - const METHOD_CANCEL = 'cancel'; |
|
98 | - |
|
99 | - /** |
|
100 | - * @param IConfig $config |
|
101 | - * @param IMailer $mailer |
|
102 | - * @param ILogger $logger |
|
103 | - * @param ITimeFactory $timeFactory |
|
104 | - * @param L10NFactory $l10nFactory |
|
105 | - * @param IUrlGenerator $urlGenerator |
|
106 | - * @param Defaults $defaults |
|
107 | - * @param ISecureRandom $random |
|
108 | - * @param IDBConnection $db |
|
109 | - * @param string $userId |
|
110 | - */ |
|
111 | - public function __construct(IConfig $config, IMailer $mailer, ILogger $logger, |
|
112 | - ITimeFactory $timeFactory, L10NFactory $l10nFactory, |
|
113 | - IURLGenerator $urlGenerator, Defaults $defaults, |
|
114 | - ISecureRandom $random, IDBConnection $db, $userId) { |
|
115 | - parent::__construct(''); |
|
116 | - $this->userId = $userId; |
|
117 | - $this->config = $config; |
|
118 | - $this->mailer = $mailer; |
|
119 | - $this->logger = $logger; |
|
120 | - $this->timeFactory = $timeFactory; |
|
121 | - $this->l10nFactory = $l10nFactory; |
|
122 | - $this->urlGenerator = $urlGenerator; |
|
123 | - $this->random = $random; |
|
124 | - $this->db = $db; |
|
125 | - $this->defaults = $defaults; |
|
126 | - } |
|
127 | - |
|
128 | - /** |
|
129 | - * Event handler for the 'schedule' event. |
|
130 | - * |
|
131 | - * @param Message $iTipMessage |
|
132 | - * @return void |
|
133 | - */ |
|
134 | - public function schedule(Message $iTipMessage) { |
|
135 | - |
|
136 | - // Not sending any emails if the system considers the update |
|
137 | - // insignificant. |
|
138 | - if (!$iTipMessage->significantChange) { |
|
139 | - if (!$iTipMessage->scheduleStatus) { |
|
140 | - $iTipMessage->scheduleStatus = '1.0;We got the message, but it\'s not significant enough to warrant an email'; |
|
141 | - } |
|
142 | - return; |
|
143 | - } |
|
144 | - |
|
145 | - $summary = $iTipMessage->message->VEVENT->SUMMARY; |
|
146 | - |
|
147 | - if (parse_url($iTipMessage->sender, PHP_URL_SCHEME) !== 'mailto') { |
|
148 | - return; |
|
149 | - } |
|
150 | - |
|
151 | - if (parse_url($iTipMessage->recipient, PHP_URL_SCHEME) !== 'mailto') { |
|
152 | - return; |
|
153 | - } |
|
154 | - |
|
155 | - // don't send out mails for events that already took place |
|
156 | - $lastOccurrence = $this->getLastOccurrence($iTipMessage->message); |
|
157 | - $currentTime = $this->timeFactory->getTime(); |
|
158 | - if ($lastOccurrence < $currentTime) { |
|
159 | - return; |
|
160 | - } |
|
161 | - |
|
162 | - // Strip off mailto: |
|
163 | - $sender = substr($iTipMessage->sender, 7); |
|
164 | - $recipient = substr($iTipMessage->recipient, 7); |
|
165 | - |
|
166 | - $senderName = $iTipMessage->senderName ?: null; |
|
167 | - $recipientName = $iTipMessage->recipientName ?: null; |
|
168 | - |
|
169 | - /** @var VEvent $vevent */ |
|
170 | - $vevent = $iTipMessage->message->VEVENT; |
|
171 | - |
|
172 | - $attendee = $this->getCurrentAttendee($iTipMessage); |
|
173 | - $defaultLang = $this->config->getUserValue($this->userId, 'core', 'lang', $this->l10nFactory->findLanguage()); |
|
174 | - $lang = $this->getAttendeeLangOrDefault($defaultLang, $attendee); |
|
175 | - $l10n = $this->l10nFactory->get('dav', $lang); |
|
176 | - |
|
177 | - $meetingAttendeeName = $recipientName ?: $recipient; |
|
178 | - $meetingInviteeName = $senderName ?: $sender; |
|
179 | - |
|
180 | - $meetingTitle = $vevent->SUMMARY; |
|
181 | - $meetingDescription = $vevent->DESCRIPTION; |
|
182 | - |
|
183 | - $start = $vevent->DTSTART; |
|
184 | - if (isset($vevent->DTEND)) { |
|
185 | - $end = $vevent->DTEND; |
|
186 | - } elseif (isset($vevent->DURATION)) { |
|
187 | - $isFloating = $vevent->DTSTART->isFloating(); |
|
188 | - $end = clone $vevent->DTSTART; |
|
189 | - $endDateTime = $end->getDateTime(); |
|
190 | - $endDateTime = $endDateTime->add(DateTimeParser::parse($vevent->DURATION->getValue())); |
|
191 | - $end->setDateTime($endDateTime, $isFloating); |
|
192 | - } elseif (!$vevent->DTSTART->hasTime()) { |
|
193 | - $isFloating = $vevent->DTSTART->isFloating(); |
|
194 | - $end = clone $vevent->DTSTART; |
|
195 | - $endDateTime = $end->getDateTime(); |
|
196 | - $endDateTime = $endDateTime->modify('+1 day'); |
|
197 | - $end->setDateTime($endDateTime, $isFloating); |
|
198 | - } else { |
|
199 | - $end = clone $vevent->DTSTART; |
|
200 | - } |
|
201 | - |
|
202 | - $meetingWhen = $this->generateWhenString($l10n, $start, $end); |
|
203 | - |
|
204 | - $meetingUrl = $vevent->URL; |
|
205 | - $meetingLocation = $vevent->LOCATION; |
|
206 | - |
|
207 | - $defaultVal = '--'; |
|
208 | - |
|
209 | - $method = self::METHOD_REQUEST; |
|
210 | - switch (strtolower($iTipMessage->method)) { |
|
211 | - case self::METHOD_REPLY: |
|
212 | - $method = self::METHOD_REPLY; |
|
213 | - break; |
|
214 | - case self::METHOD_CANCEL: |
|
215 | - $method = self::METHOD_CANCEL; |
|
216 | - break; |
|
217 | - } |
|
218 | - |
|
219 | - $data = array( |
|
220 | - 'attendee_name' => (string)$meetingAttendeeName ?: $defaultVal, |
|
221 | - 'invitee_name' => (string)$meetingInviteeName ?: $defaultVal, |
|
222 | - 'meeting_title' => (string)$meetingTitle ?: $defaultVal, |
|
223 | - 'meeting_description' => (string)$meetingDescription ?: $defaultVal, |
|
224 | - 'meeting_url' => (string)$meetingUrl ?: $defaultVal, |
|
225 | - ); |
|
226 | - |
|
227 | - $fromEMail = \OCP\Util::getDefaultEmailAddress('invitations-noreply'); |
|
228 | - $fromName = $l10n->t('%s via %s', [$senderName, $this->defaults->getName()]); |
|
229 | - |
|
230 | - $message = $this->mailer->createMessage() |
|
231 | - ->setFrom([$fromEMail => $fromName]) |
|
232 | - ->setReplyTo([$sender => $senderName]) |
|
233 | - ->setTo([$recipient => $recipientName]); |
|
234 | - |
|
235 | - $template = $this->mailer->createEMailTemplate('dav.calendarInvite.' . $method, $data); |
|
236 | - $template->addHeader(); |
|
237 | - |
|
238 | - $this->addSubjectAndHeading($template, $l10n, $method, $summary, |
|
239 | - $meetingAttendeeName, $meetingInviteeName); |
|
240 | - $this->addBulletList($template, $l10n, $meetingWhen, $meetingLocation, |
|
241 | - $meetingDescription, $meetingUrl); |
|
242 | - $this->addResponseButtons($template, $l10n, $iTipMessage, $lastOccurrence); |
|
243 | - |
|
244 | - $template->addFooter(); |
|
245 | - $message->useTemplate($template); |
|
246 | - |
|
247 | - $attachment = $this->mailer->createAttachment( |
|
248 | - $iTipMessage->message->serialize(), |
|
249 | - 'event.ics',// TODO(leon): Make file name unique, e.g. add event id |
|
250 | - 'text/calendar; method=' . $iTipMessage->method |
|
251 | - ); |
|
252 | - $message->attach($attachment); |
|
253 | - |
|
254 | - try { |
|
255 | - $failed = $this->mailer->send($message); |
|
256 | - $iTipMessage->scheduleStatus = '1.1; Scheduling message is sent via iMip'; |
|
257 | - if ($failed) { |
|
258 | - $this->logger->error('Unable to deliver message to {failed}', ['app' => 'dav', 'failed' => implode(', ', $failed)]); |
|
259 | - $iTipMessage->scheduleStatus = '5.0; EMail delivery failed'; |
|
260 | - } |
|
261 | - } catch(\Exception $ex) { |
|
262 | - $this->logger->logException($ex, ['app' => 'dav']); |
|
263 | - $iTipMessage->scheduleStatus = '5.0; EMail delivery failed'; |
|
264 | - } |
|
265 | - } |
|
266 | - |
|
267 | - /** |
|
268 | - * check if event took place in the past already |
|
269 | - * @param VCalendar $vObject |
|
270 | - * @return int |
|
271 | - */ |
|
272 | - private function getLastOccurrence(VCalendar $vObject) { |
|
273 | - /** @var VEvent $component */ |
|
274 | - $component = $vObject->VEVENT; |
|
275 | - |
|
276 | - $firstOccurrence = $component->DTSTART->getDateTime()->getTimeStamp(); |
|
277 | - // Finding the last occurrence is a bit harder |
|
278 | - if (!isset($component->RRULE)) { |
|
279 | - if (isset($component->DTEND)) { |
|
280 | - $lastOccurrence = $component->DTEND->getDateTime()->getTimeStamp(); |
|
281 | - } elseif (isset($component->DURATION)) { |
|
282 | - /** @var \DateTime $endDate */ |
|
283 | - $endDate = clone $component->DTSTART->getDateTime(); |
|
284 | - // $component->DTEND->getDateTime() returns DateTimeImmutable |
|
285 | - $endDate = $endDate->add(DateTimeParser::parse($component->DURATION->getValue())); |
|
286 | - $lastOccurrence = $endDate->getTimestamp(); |
|
287 | - } elseif (!$component->DTSTART->hasTime()) { |
|
288 | - /** @var \DateTime $endDate */ |
|
289 | - $endDate = clone $component->DTSTART->getDateTime(); |
|
290 | - // $component->DTSTART->getDateTime() returns DateTimeImmutable |
|
291 | - $endDate = $endDate->modify('+1 day'); |
|
292 | - $lastOccurrence = $endDate->getTimestamp(); |
|
293 | - } else { |
|
294 | - $lastOccurrence = $firstOccurrence; |
|
295 | - } |
|
296 | - } else { |
|
297 | - $it = new EventIterator($vObject, (string)$component->UID); |
|
298 | - $maxDate = new \DateTime(self::MAX_DATE); |
|
299 | - if ($it->isInfinite()) { |
|
300 | - $lastOccurrence = $maxDate->getTimestamp(); |
|
301 | - } else { |
|
302 | - $end = $it->getDtEnd(); |
|
303 | - while($it->valid() && $end < $maxDate) { |
|
304 | - $end = $it->getDtEnd(); |
|
305 | - $it->next(); |
|
306 | - |
|
307 | - } |
|
308 | - $lastOccurrence = $end->getTimestamp(); |
|
309 | - } |
|
310 | - } |
|
311 | - |
|
312 | - return $lastOccurrence; |
|
313 | - } |
|
314 | - |
|
315 | - |
|
316 | - /** |
|
317 | - * @param Message $iTipMessage |
|
318 | - * @return null|Property |
|
319 | - */ |
|
320 | - private function getCurrentAttendee(Message $iTipMessage) { |
|
321 | - /** @var VEvent $vevent */ |
|
322 | - $vevent = $iTipMessage->message->VEVENT; |
|
323 | - $attendees = $vevent->select('ATTENDEE'); |
|
324 | - foreach ($attendees as $attendee) { |
|
325 | - /** @var Property $attendee */ |
|
326 | - if (strcasecmp($attendee->getValue(), $iTipMessage->recipient) === 0) { |
|
327 | - return $attendee; |
|
328 | - } |
|
329 | - } |
|
330 | - return null; |
|
331 | - } |
|
332 | - |
|
333 | - /** |
|
334 | - * @param string $default |
|
335 | - * @param Property|null $attendee |
|
336 | - * @return string |
|
337 | - */ |
|
338 | - private function getAttendeeLangOrDefault($default, Property $attendee = null) { |
|
339 | - if ($attendee !== null) { |
|
340 | - $lang = $attendee->offsetGet('LANGUAGE'); |
|
341 | - if ($lang instanceof Parameter) { |
|
342 | - return $lang->getValue(); |
|
343 | - } |
|
344 | - } |
|
345 | - return $default; |
|
346 | - } |
|
347 | - |
|
348 | - /** |
|
349 | - * @param IL10N $l10n |
|
350 | - * @param Property $dtstart |
|
351 | - * @param Property $dtend |
|
352 | - */ |
|
353 | - private function generateWhenString(IL10N $l10n, Property $dtstart, Property $dtend) { |
|
354 | - $isAllDay = $dtstart instanceof Property\ICalendar\Date; |
|
355 | - |
|
356 | - /** @var Property\ICalendar\Date | Property\ICalendar\DateTime $dtstart */ |
|
357 | - /** @var Property\ICalendar\Date | Property\ICalendar\DateTime $dtend */ |
|
358 | - /** @var \DateTimeImmutable $dtstartDt */ |
|
359 | - $dtstartDt = $dtstart->getDateTime(); |
|
360 | - /** @var \DateTimeImmutable $dtendDt */ |
|
361 | - $dtendDt = $dtend->getDateTime(); |
|
362 | - |
|
363 | - $diff = $dtstartDt->diff($dtendDt); |
|
364 | - |
|
365 | - $dtstartDt = new \DateTime($dtstartDt->format(\DateTime::ATOM)); |
|
366 | - $dtendDt = new \DateTime($dtendDt->format(\DateTime::ATOM)); |
|
367 | - |
|
368 | - if ($isAllDay) { |
|
369 | - // One day event |
|
370 | - if ($diff->days === 1) { |
|
371 | - return $l10n->l('date', $dtstartDt, ['width' => 'medium']); |
|
372 | - } |
|
373 | - |
|
374 | - //event that spans over multiple days |
|
375 | - $localeStart = $l10n->l('date', $dtstartDt, ['width' => 'medium']); |
|
376 | - $localeEnd = $l10n->l('date', $dtendDt, ['width' => 'medium']); |
|
377 | - |
|
378 | - return $localeStart . ' - ' . $localeEnd; |
|
379 | - } |
|
380 | - |
|
381 | - /** @var Property\ICalendar\DateTime $dtstart */ |
|
382 | - /** @var Property\ICalendar\DateTime $dtend */ |
|
383 | - $isFloating = $dtstart->isFloating(); |
|
384 | - $startTimezone = $endTimezone = null; |
|
385 | - if (!$isFloating) { |
|
386 | - $prop = $dtstart->offsetGet('TZID'); |
|
387 | - if ($prop instanceof Parameter) { |
|
388 | - $startTimezone = $prop->getValue(); |
|
389 | - } |
|
390 | - |
|
391 | - $prop = $dtend->offsetGet('TZID'); |
|
392 | - if ($prop instanceof Parameter) { |
|
393 | - $endTimezone = $prop->getValue(); |
|
394 | - } |
|
395 | - } |
|
396 | - |
|
397 | - $localeStart = $l10n->l('weekdayName', $dtstartDt, ['width' => 'abbreviated']) . ', ' . |
|
398 | - $l10n->l('datetime', $dtstartDt, ['width' => 'medium|short']); |
|
399 | - |
|
400 | - // always show full date with timezone if timezones are different |
|
401 | - if ($startTimezone !== $endTimezone) { |
|
402 | - $localeEnd = $l10n->l('datetime', $dtendDt, ['width' => 'medium|short']); |
|
403 | - |
|
404 | - return $localeStart . ' (' . $startTimezone . ') - ' . |
|
405 | - $localeEnd . ' (' . $endTimezone . ')'; |
|
406 | - } |
|
407 | - |
|
408 | - // show only end time if date is the same |
|
409 | - if ($this->isDayEqual($dtstartDt, $dtendDt)) { |
|
410 | - $localeEnd = $l10n->l('time', $dtendDt, ['width' => 'short']); |
|
411 | - } else { |
|
412 | - $localeEnd = $l10n->l('weekdayName', $dtendDt, ['width' => 'abbreviated']) . ', ' . |
|
413 | - $l10n->l('datetime', $dtendDt, ['width' => 'medium|short']); |
|
414 | - } |
|
415 | - |
|
416 | - return $localeStart . ' - ' . $localeEnd . ' (' . $startTimezone . ')'; |
|
417 | - } |
|
418 | - |
|
419 | - /** |
|
420 | - * @param \DateTime $dtStart |
|
421 | - * @param \DateTime $dtEnd |
|
422 | - * @return bool |
|
423 | - */ |
|
424 | - private function isDayEqual(\DateTime $dtStart, \DateTime $dtEnd) { |
|
425 | - return $dtStart->format('Y-m-d') === $dtEnd->format('Y-m-d'); |
|
426 | - } |
|
427 | - |
|
428 | - /** |
|
429 | - * @param IEMailTemplate $template |
|
430 | - * @param IL10N $l10n |
|
431 | - * @param string $method |
|
432 | - * @param string $summary |
|
433 | - * @param string $attendeeName |
|
434 | - * @param string $inviteeName |
|
435 | - */ |
|
436 | - private function addSubjectAndHeading(IEMailTemplate $template, IL10N $l10n, |
|
437 | - $method, $summary, $attendeeName, $inviteeName) { |
|
438 | - if ($method === self::METHOD_CANCEL) { |
|
439 | - $template->setSubject('Cancelled: ' . $summary); |
|
440 | - $template->addHeading($l10n->t('Invitation canceled'), $l10n->t('Hello %s,', [$attendeeName])); |
|
441 | - $template->addBodyText($l10n->t('The meeting »%s« with %s was canceled.', [$summary, $inviteeName])); |
|
442 | - } else if ($method === self::METHOD_REPLY) { |
|
443 | - $template->setSubject('Re: ' . $summary); |
|
444 | - $template->addHeading($l10n->t('Invitation updated'), $l10n->t('Hello %s,', [$attendeeName])); |
|
445 | - $template->addBodyText($l10n->t('The meeting »%s« with %s was updated.', [$summary, $inviteeName])); |
|
446 | - } else { |
|
447 | - $template->setSubject('Invitation: ' . $summary); |
|
448 | - $template->addHeading($l10n->t('%s invited you to »%s«', [$inviteeName, $summary]), $l10n->t('Hello %s,', [$attendeeName])); |
|
449 | - } |
|
450 | - |
|
451 | - } |
|
452 | - |
|
453 | - /** |
|
454 | - * @param IEMailTemplate $template |
|
455 | - * @param IL10N $l10n |
|
456 | - * @param string $time |
|
457 | - * @param string $location |
|
458 | - * @param string $description |
|
459 | - * @param string $url |
|
460 | - */ |
|
461 | - private function addBulletList(IEMailTemplate $template, IL10N $l10n, $time, $location, $description, $url) { |
|
462 | - $template->addBodyListItem($time, $l10n->t('When:'), |
|
463 | - $this->getAbsoluteImagePath('filetypes/text-calendar.svg')); |
|
464 | - |
|
465 | - if ($location) { |
|
466 | - $template->addBodyListItem($location, $l10n->t('Where:'), |
|
467 | - $this->getAbsoluteImagePath('filetypes/location.svg')); |
|
468 | - } |
|
469 | - if ($description) { |
|
470 | - $template->addBodyListItem((string)$description, $l10n->t('Description:'), |
|
471 | - $this->getAbsoluteImagePath('filetypes/text.svg')); |
|
472 | - } |
|
473 | - if ($url) { |
|
474 | - $template->addBodyListItem((string)$url, $l10n->t('Link:'), |
|
475 | - $this->getAbsoluteImagePath('filetypes/link.svg')); |
|
476 | - } |
|
477 | - } |
|
478 | - |
|
479 | - /** |
|
480 | - * @param IEMailTemplate $template |
|
481 | - * @param IL10N $l10n |
|
482 | - * @param Message $iTipMessage |
|
483 | - * @param int $lastOccurrence |
|
484 | - */ |
|
485 | - private function addResponseButtons(IEMailTemplate $template, IL10N $l10n, |
|
486 | - Message $iTipMessage, $lastOccurrence) { |
|
487 | - $token = $this->createInvitationToken($iTipMessage, $lastOccurrence); |
|
488 | - |
|
489 | - $template->addBodyButtonGroup( |
|
490 | - $l10n->t('Accept'), |
|
491 | - $this->urlGenerator->linkToRouteAbsolute('dav.invitation_response.accept', [ |
|
492 | - 'token' => $token, |
|
493 | - ]), |
|
494 | - $l10n->t('Decline'), |
|
495 | - $this->urlGenerator->linkToRouteAbsolute('dav.invitation_response.decline', [ |
|
496 | - 'token' => $token, |
|
497 | - ]) |
|
498 | - ); |
|
499 | - |
|
500 | - $moreOptionsURL = $this->urlGenerator->linkToRouteAbsolute('dav.invitation_response.options', [ |
|
501 | - 'token' => $token, |
|
502 | - ]); |
|
503 | - $html = vsprintf('<small><a href="%s">%s</a></small>', [ |
|
504 | - $moreOptionsURL, $l10n->t('More options ...') |
|
505 | - ]); |
|
506 | - $text = $l10n->t('More options at %s', [$moreOptionsURL]); |
|
63 | + /** @var string */ |
|
64 | + private $userId; |
|
65 | + |
|
66 | + /** @var IConfig */ |
|
67 | + private $config; |
|
68 | + |
|
69 | + /** @var IMailer */ |
|
70 | + private $mailer; |
|
71 | + |
|
72 | + /** @var ILogger */ |
|
73 | + private $logger; |
|
74 | + |
|
75 | + /** @var ITimeFactory */ |
|
76 | + private $timeFactory; |
|
77 | + |
|
78 | + /** @var L10NFactory */ |
|
79 | + private $l10nFactory; |
|
80 | + |
|
81 | + /** @var IURLGenerator */ |
|
82 | + private $urlGenerator; |
|
83 | + |
|
84 | + /** @var ISecureRandom */ |
|
85 | + private $random; |
|
86 | + |
|
87 | + /** @var IDBConnection */ |
|
88 | + private $db; |
|
89 | + |
|
90 | + /** @var Defaults */ |
|
91 | + private $defaults; |
|
92 | + |
|
93 | + const MAX_DATE = '2038-01-01'; |
|
94 | + |
|
95 | + const METHOD_REQUEST = 'request'; |
|
96 | + const METHOD_REPLY = 'reply'; |
|
97 | + const METHOD_CANCEL = 'cancel'; |
|
98 | + |
|
99 | + /** |
|
100 | + * @param IConfig $config |
|
101 | + * @param IMailer $mailer |
|
102 | + * @param ILogger $logger |
|
103 | + * @param ITimeFactory $timeFactory |
|
104 | + * @param L10NFactory $l10nFactory |
|
105 | + * @param IUrlGenerator $urlGenerator |
|
106 | + * @param Defaults $defaults |
|
107 | + * @param ISecureRandom $random |
|
108 | + * @param IDBConnection $db |
|
109 | + * @param string $userId |
|
110 | + */ |
|
111 | + public function __construct(IConfig $config, IMailer $mailer, ILogger $logger, |
|
112 | + ITimeFactory $timeFactory, L10NFactory $l10nFactory, |
|
113 | + IURLGenerator $urlGenerator, Defaults $defaults, |
|
114 | + ISecureRandom $random, IDBConnection $db, $userId) { |
|
115 | + parent::__construct(''); |
|
116 | + $this->userId = $userId; |
|
117 | + $this->config = $config; |
|
118 | + $this->mailer = $mailer; |
|
119 | + $this->logger = $logger; |
|
120 | + $this->timeFactory = $timeFactory; |
|
121 | + $this->l10nFactory = $l10nFactory; |
|
122 | + $this->urlGenerator = $urlGenerator; |
|
123 | + $this->random = $random; |
|
124 | + $this->db = $db; |
|
125 | + $this->defaults = $defaults; |
|
126 | + } |
|
127 | + |
|
128 | + /** |
|
129 | + * Event handler for the 'schedule' event. |
|
130 | + * |
|
131 | + * @param Message $iTipMessage |
|
132 | + * @return void |
|
133 | + */ |
|
134 | + public function schedule(Message $iTipMessage) { |
|
135 | + |
|
136 | + // Not sending any emails if the system considers the update |
|
137 | + // insignificant. |
|
138 | + if (!$iTipMessage->significantChange) { |
|
139 | + if (!$iTipMessage->scheduleStatus) { |
|
140 | + $iTipMessage->scheduleStatus = '1.0;We got the message, but it\'s not significant enough to warrant an email'; |
|
141 | + } |
|
142 | + return; |
|
143 | + } |
|
144 | + |
|
145 | + $summary = $iTipMessage->message->VEVENT->SUMMARY; |
|
146 | + |
|
147 | + if (parse_url($iTipMessage->sender, PHP_URL_SCHEME) !== 'mailto') { |
|
148 | + return; |
|
149 | + } |
|
150 | + |
|
151 | + if (parse_url($iTipMessage->recipient, PHP_URL_SCHEME) !== 'mailto') { |
|
152 | + return; |
|
153 | + } |
|
154 | + |
|
155 | + // don't send out mails for events that already took place |
|
156 | + $lastOccurrence = $this->getLastOccurrence($iTipMessage->message); |
|
157 | + $currentTime = $this->timeFactory->getTime(); |
|
158 | + if ($lastOccurrence < $currentTime) { |
|
159 | + return; |
|
160 | + } |
|
161 | + |
|
162 | + // Strip off mailto: |
|
163 | + $sender = substr($iTipMessage->sender, 7); |
|
164 | + $recipient = substr($iTipMessage->recipient, 7); |
|
165 | + |
|
166 | + $senderName = $iTipMessage->senderName ?: null; |
|
167 | + $recipientName = $iTipMessage->recipientName ?: null; |
|
168 | + |
|
169 | + /** @var VEvent $vevent */ |
|
170 | + $vevent = $iTipMessage->message->VEVENT; |
|
171 | + |
|
172 | + $attendee = $this->getCurrentAttendee($iTipMessage); |
|
173 | + $defaultLang = $this->config->getUserValue($this->userId, 'core', 'lang', $this->l10nFactory->findLanguage()); |
|
174 | + $lang = $this->getAttendeeLangOrDefault($defaultLang, $attendee); |
|
175 | + $l10n = $this->l10nFactory->get('dav', $lang); |
|
176 | + |
|
177 | + $meetingAttendeeName = $recipientName ?: $recipient; |
|
178 | + $meetingInviteeName = $senderName ?: $sender; |
|
179 | + |
|
180 | + $meetingTitle = $vevent->SUMMARY; |
|
181 | + $meetingDescription = $vevent->DESCRIPTION; |
|
182 | + |
|
183 | + $start = $vevent->DTSTART; |
|
184 | + if (isset($vevent->DTEND)) { |
|
185 | + $end = $vevent->DTEND; |
|
186 | + } elseif (isset($vevent->DURATION)) { |
|
187 | + $isFloating = $vevent->DTSTART->isFloating(); |
|
188 | + $end = clone $vevent->DTSTART; |
|
189 | + $endDateTime = $end->getDateTime(); |
|
190 | + $endDateTime = $endDateTime->add(DateTimeParser::parse($vevent->DURATION->getValue())); |
|
191 | + $end->setDateTime($endDateTime, $isFloating); |
|
192 | + } elseif (!$vevent->DTSTART->hasTime()) { |
|
193 | + $isFloating = $vevent->DTSTART->isFloating(); |
|
194 | + $end = clone $vevent->DTSTART; |
|
195 | + $endDateTime = $end->getDateTime(); |
|
196 | + $endDateTime = $endDateTime->modify('+1 day'); |
|
197 | + $end->setDateTime($endDateTime, $isFloating); |
|
198 | + } else { |
|
199 | + $end = clone $vevent->DTSTART; |
|
200 | + } |
|
201 | + |
|
202 | + $meetingWhen = $this->generateWhenString($l10n, $start, $end); |
|
203 | + |
|
204 | + $meetingUrl = $vevent->URL; |
|
205 | + $meetingLocation = $vevent->LOCATION; |
|
206 | + |
|
207 | + $defaultVal = '--'; |
|
208 | + |
|
209 | + $method = self::METHOD_REQUEST; |
|
210 | + switch (strtolower($iTipMessage->method)) { |
|
211 | + case self::METHOD_REPLY: |
|
212 | + $method = self::METHOD_REPLY; |
|
213 | + break; |
|
214 | + case self::METHOD_CANCEL: |
|
215 | + $method = self::METHOD_CANCEL; |
|
216 | + break; |
|
217 | + } |
|
218 | + |
|
219 | + $data = array( |
|
220 | + 'attendee_name' => (string)$meetingAttendeeName ?: $defaultVal, |
|
221 | + 'invitee_name' => (string)$meetingInviteeName ?: $defaultVal, |
|
222 | + 'meeting_title' => (string)$meetingTitle ?: $defaultVal, |
|
223 | + 'meeting_description' => (string)$meetingDescription ?: $defaultVal, |
|
224 | + 'meeting_url' => (string)$meetingUrl ?: $defaultVal, |
|
225 | + ); |
|
226 | + |
|
227 | + $fromEMail = \OCP\Util::getDefaultEmailAddress('invitations-noreply'); |
|
228 | + $fromName = $l10n->t('%s via %s', [$senderName, $this->defaults->getName()]); |
|
229 | + |
|
230 | + $message = $this->mailer->createMessage() |
|
231 | + ->setFrom([$fromEMail => $fromName]) |
|
232 | + ->setReplyTo([$sender => $senderName]) |
|
233 | + ->setTo([$recipient => $recipientName]); |
|
234 | + |
|
235 | + $template = $this->mailer->createEMailTemplate('dav.calendarInvite.' . $method, $data); |
|
236 | + $template->addHeader(); |
|
237 | + |
|
238 | + $this->addSubjectAndHeading($template, $l10n, $method, $summary, |
|
239 | + $meetingAttendeeName, $meetingInviteeName); |
|
240 | + $this->addBulletList($template, $l10n, $meetingWhen, $meetingLocation, |
|
241 | + $meetingDescription, $meetingUrl); |
|
242 | + $this->addResponseButtons($template, $l10n, $iTipMessage, $lastOccurrence); |
|
243 | + |
|
244 | + $template->addFooter(); |
|
245 | + $message->useTemplate($template); |
|
246 | + |
|
247 | + $attachment = $this->mailer->createAttachment( |
|
248 | + $iTipMessage->message->serialize(), |
|
249 | + 'event.ics',// TODO(leon): Make file name unique, e.g. add event id |
|
250 | + 'text/calendar; method=' . $iTipMessage->method |
|
251 | + ); |
|
252 | + $message->attach($attachment); |
|
253 | + |
|
254 | + try { |
|
255 | + $failed = $this->mailer->send($message); |
|
256 | + $iTipMessage->scheduleStatus = '1.1; Scheduling message is sent via iMip'; |
|
257 | + if ($failed) { |
|
258 | + $this->logger->error('Unable to deliver message to {failed}', ['app' => 'dav', 'failed' => implode(', ', $failed)]); |
|
259 | + $iTipMessage->scheduleStatus = '5.0; EMail delivery failed'; |
|
260 | + } |
|
261 | + } catch(\Exception $ex) { |
|
262 | + $this->logger->logException($ex, ['app' => 'dav']); |
|
263 | + $iTipMessage->scheduleStatus = '5.0; EMail delivery failed'; |
|
264 | + } |
|
265 | + } |
|
266 | + |
|
267 | + /** |
|
268 | + * check if event took place in the past already |
|
269 | + * @param VCalendar $vObject |
|
270 | + * @return int |
|
271 | + */ |
|
272 | + private function getLastOccurrence(VCalendar $vObject) { |
|
273 | + /** @var VEvent $component */ |
|
274 | + $component = $vObject->VEVENT; |
|
275 | + |
|
276 | + $firstOccurrence = $component->DTSTART->getDateTime()->getTimeStamp(); |
|
277 | + // Finding the last occurrence is a bit harder |
|
278 | + if (!isset($component->RRULE)) { |
|
279 | + if (isset($component->DTEND)) { |
|
280 | + $lastOccurrence = $component->DTEND->getDateTime()->getTimeStamp(); |
|
281 | + } elseif (isset($component->DURATION)) { |
|
282 | + /** @var \DateTime $endDate */ |
|
283 | + $endDate = clone $component->DTSTART->getDateTime(); |
|
284 | + // $component->DTEND->getDateTime() returns DateTimeImmutable |
|
285 | + $endDate = $endDate->add(DateTimeParser::parse($component->DURATION->getValue())); |
|
286 | + $lastOccurrence = $endDate->getTimestamp(); |
|
287 | + } elseif (!$component->DTSTART->hasTime()) { |
|
288 | + /** @var \DateTime $endDate */ |
|
289 | + $endDate = clone $component->DTSTART->getDateTime(); |
|
290 | + // $component->DTSTART->getDateTime() returns DateTimeImmutable |
|
291 | + $endDate = $endDate->modify('+1 day'); |
|
292 | + $lastOccurrence = $endDate->getTimestamp(); |
|
293 | + } else { |
|
294 | + $lastOccurrence = $firstOccurrence; |
|
295 | + } |
|
296 | + } else { |
|
297 | + $it = new EventIterator($vObject, (string)$component->UID); |
|
298 | + $maxDate = new \DateTime(self::MAX_DATE); |
|
299 | + if ($it->isInfinite()) { |
|
300 | + $lastOccurrence = $maxDate->getTimestamp(); |
|
301 | + } else { |
|
302 | + $end = $it->getDtEnd(); |
|
303 | + while($it->valid() && $end < $maxDate) { |
|
304 | + $end = $it->getDtEnd(); |
|
305 | + $it->next(); |
|
306 | + |
|
307 | + } |
|
308 | + $lastOccurrence = $end->getTimestamp(); |
|
309 | + } |
|
310 | + } |
|
311 | + |
|
312 | + return $lastOccurrence; |
|
313 | + } |
|
314 | + |
|
315 | + |
|
316 | + /** |
|
317 | + * @param Message $iTipMessage |
|
318 | + * @return null|Property |
|
319 | + */ |
|
320 | + private function getCurrentAttendee(Message $iTipMessage) { |
|
321 | + /** @var VEvent $vevent */ |
|
322 | + $vevent = $iTipMessage->message->VEVENT; |
|
323 | + $attendees = $vevent->select('ATTENDEE'); |
|
324 | + foreach ($attendees as $attendee) { |
|
325 | + /** @var Property $attendee */ |
|
326 | + if (strcasecmp($attendee->getValue(), $iTipMessage->recipient) === 0) { |
|
327 | + return $attendee; |
|
328 | + } |
|
329 | + } |
|
330 | + return null; |
|
331 | + } |
|
332 | + |
|
333 | + /** |
|
334 | + * @param string $default |
|
335 | + * @param Property|null $attendee |
|
336 | + * @return string |
|
337 | + */ |
|
338 | + private function getAttendeeLangOrDefault($default, Property $attendee = null) { |
|
339 | + if ($attendee !== null) { |
|
340 | + $lang = $attendee->offsetGet('LANGUAGE'); |
|
341 | + if ($lang instanceof Parameter) { |
|
342 | + return $lang->getValue(); |
|
343 | + } |
|
344 | + } |
|
345 | + return $default; |
|
346 | + } |
|
347 | + |
|
348 | + /** |
|
349 | + * @param IL10N $l10n |
|
350 | + * @param Property $dtstart |
|
351 | + * @param Property $dtend |
|
352 | + */ |
|
353 | + private function generateWhenString(IL10N $l10n, Property $dtstart, Property $dtend) { |
|
354 | + $isAllDay = $dtstart instanceof Property\ICalendar\Date; |
|
355 | + |
|
356 | + /** @var Property\ICalendar\Date | Property\ICalendar\DateTime $dtstart */ |
|
357 | + /** @var Property\ICalendar\Date | Property\ICalendar\DateTime $dtend */ |
|
358 | + /** @var \DateTimeImmutable $dtstartDt */ |
|
359 | + $dtstartDt = $dtstart->getDateTime(); |
|
360 | + /** @var \DateTimeImmutable $dtendDt */ |
|
361 | + $dtendDt = $dtend->getDateTime(); |
|
362 | + |
|
363 | + $diff = $dtstartDt->diff($dtendDt); |
|
364 | + |
|
365 | + $dtstartDt = new \DateTime($dtstartDt->format(\DateTime::ATOM)); |
|
366 | + $dtendDt = new \DateTime($dtendDt->format(\DateTime::ATOM)); |
|
367 | + |
|
368 | + if ($isAllDay) { |
|
369 | + // One day event |
|
370 | + if ($diff->days === 1) { |
|
371 | + return $l10n->l('date', $dtstartDt, ['width' => 'medium']); |
|
372 | + } |
|
373 | + |
|
374 | + //event that spans over multiple days |
|
375 | + $localeStart = $l10n->l('date', $dtstartDt, ['width' => 'medium']); |
|
376 | + $localeEnd = $l10n->l('date', $dtendDt, ['width' => 'medium']); |
|
377 | + |
|
378 | + return $localeStart . ' - ' . $localeEnd; |
|
379 | + } |
|
380 | + |
|
381 | + /** @var Property\ICalendar\DateTime $dtstart */ |
|
382 | + /** @var Property\ICalendar\DateTime $dtend */ |
|
383 | + $isFloating = $dtstart->isFloating(); |
|
384 | + $startTimezone = $endTimezone = null; |
|
385 | + if (!$isFloating) { |
|
386 | + $prop = $dtstart->offsetGet('TZID'); |
|
387 | + if ($prop instanceof Parameter) { |
|
388 | + $startTimezone = $prop->getValue(); |
|
389 | + } |
|
390 | + |
|
391 | + $prop = $dtend->offsetGet('TZID'); |
|
392 | + if ($prop instanceof Parameter) { |
|
393 | + $endTimezone = $prop->getValue(); |
|
394 | + } |
|
395 | + } |
|
396 | + |
|
397 | + $localeStart = $l10n->l('weekdayName', $dtstartDt, ['width' => 'abbreviated']) . ', ' . |
|
398 | + $l10n->l('datetime', $dtstartDt, ['width' => 'medium|short']); |
|
399 | + |
|
400 | + // always show full date with timezone if timezones are different |
|
401 | + if ($startTimezone !== $endTimezone) { |
|
402 | + $localeEnd = $l10n->l('datetime', $dtendDt, ['width' => 'medium|short']); |
|
403 | + |
|
404 | + return $localeStart . ' (' . $startTimezone . ') - ' . |
|
405 | + $localeEnd . ' (' . $endTimezone . ')'; |
|
406 | + } |
|
407 | + |
|
408 | + // show only end time if date is the same |
|
409 | + if ($this->isDayEqual($dtstartDt, $dtendDt)) { |
|
410 | + $localeEnd = $l10n->l('time', $dtendDt, ['width' => 'short']); |
|
411 | + } else { |
|
412 | + $localeEnd = $l10n->l('weekdayName', $dtendDt, ['width' => 'abbreviated']) . ', ' . |
|
413 | + $l10n->l('datetime', $dtendDt, ['width' => 'medium|short']); |
|
414 | + } |
|
415 | + |
|
416 | + return $localeStart . ' - ' . $localeEnd . ' (' . $startTimezone . ')'; |
|
417 | + } |
|
418 | + |
|
419 | + /** |
|
420 | + * @param \DateTime $dtStart |
|
421 | + * @param \DateTime $dtEnd |
|
422 | + * @return bool |
|
423 | + */ |
|
424 | + private function isDayEqual(\DateTime $dtStart, \DateTime $dtEnd) { |
|
425 | + return $dtStart->format('Y-m-d') === $dtEnd->format('Y-m-d'); |
|
426 | + } |
|
427 | + |
|
428 | + /** |
|
429 | + * @param IEMailTemplate $template |
|
430 | + * @param IL10N $l10n |
|
431 | + * @param string $method |
|
432 | + * @param string $summary |
|
433 | + * @param string $attendeeName |
|
434 | + * @param string $inviteeName |
|
435 | + */ |
|
436 | + private function addSubjectAndHeading(IEMailTemplate $template, IL10N $l10n, |
|
437 | + $method, $summary, $attendeeName, $inviteeName) { |
|
438 | + if ($method === self::METHOD_CANCEL) { |
|
439 | + $template->setSubject('Cancelled: ' . $summary); |
|
440 | + $template->addHeading($l10n->t('Invitation canceled'), $l10n->t('Hello %s,', [$attendeeName])); |
|
441 | + $template->addBodyText($l10n->t('The meeting »%s« with %s was canceled.', [$summary, $inviteeName])); |
|
442 | + } else if ($method === self::METHOD_REPLY) { |
|
443 | + $template->setSubject('Re: ' . $summary); |
|
444 | + $template->addHeading($l10n->t('Invitation updated'), $l10n->t('Hello %s,', [$attendeeName])); |
|
445 | + $template->addBodyText($l10n->t('The meeting »%s« with %s was updated.', [$summary, $inviteeName])); |
|
446 | + } else { |
|
447 | + $template->setSubject('Invitation: ' . $summary); |
|
448 | + $template->addHeading($l10n->t('%s invited you to »%s«', [$inviteeName, $summary]), $l10n->t('Hello %s,', [$attendeeName])); |
|
449 | + } |
|
450 | + |
|
451 | + } |
|
452 | + |
|
453 | + /** |
|
454 | + * @param IEMailTemplate $template |
|
455 | + * @param IL10N $l10n |
|
456 | + * @param string $time |
|
457 | + * @param string $location |
|
458 | + * @param string $description |
|
459 | + * @param string $url |
|
460 | + */ |
|
461 | + private function addBulletList(IEMailTemplate $template, IL10N $l10n, $time, $location, $description, $url) { |
|
462 | + $template->addBodyListItem($time, $l10n->t('When:'), |
|
463 | + $this->getAbsoluteImagePath('filetypes/text-calendar.svg')); |
|
464 | + |
|
465 | + if ($location) { |
|
466 | + $template->addBodyListItem($location, $l10n->t('Where:'), |
|
467 | + $this->getAbsoluteImagePath('filetypes/location.svg')); |
|
468 | + } |
|
469 | + if ($description) { |
|
470 | + $template->addBodyListItem((string)$description, $l10n->t('Description:'), |
|
471 | + $this->getAbsoluteImagePath('filetypes/text.svg')); |
|
472 | + } |
|
473 | + if ($url) { |
|
474 | + $template->addBodyListItem((string)$url, $l10n->t('Link:'), |
|
475 | + $this->getAbsoluteImagePath('filetypes/link.svg')); |
|
476 | + } |
|
477 | + } |
|
478 | + |
|
479 | + /** |
|
480 | + * @param IEMailTemplate $template |
|
481 | + * @param IL10N $l10n |
|
482 | + * @param Message $iTipMessage |
|
483 | + * @param int $lastOccurrence |
|
484 | + */ |
|
485 | + private function addResponseButtons(IEMailTemplate $template, IL10N $l10n, |
|
486 | + Message $iTipMessage, $lastOccurrence) { |
|
487 | + $token = $this->createInvitationToken($iTipMessage, $lastOccurrence); |
|
488 | + |
|
489 | + $template->addBodyButtonGroup( |
|
490 | + $l10n->t('Accept'), |
|
491 | + $this->urlGenerator->linkToRouteAbsolute('dav.invitation_response.accept', [ |
|
492 | + 'token' => $token, |
|
493 | + ]), |
|
494 | + $l10n->t('Decline'), |
|
495 | + $this->urlGenerator->linkToRouteAbsolute('dav.invitation_response.decline', [ |
|
496 | + 'token' => $token, |
|
497 | + ]) |
|
498 | + ); |
|
499 | + |
|
500 | + $moreOptionsURL = $this->urlGenerator->linkToRouteAbsolute('dav.invitation_response.options', [ |
|
501 | + 'token' => $token, |
|
502 | + ]); |
|
503 | + $html = vsprintf('<small><a href="%s">%s</a></small>', [ |
|
504 | + $moreOptionsURL, $l10n->t('More options ...') |
|
505 | + ]); |
|
506 | + $text = $l10n->t('More options at %s', [$moreOptionsURL]); |
|
507 | 507 | |
508 | - $template->addBodyText($html, $text); |
|
509 | - } |
|
510 | - |
|
511 | - /** |
|
512 | - * @param string $path |
|
513 | - * @return string |
|
514 | - */ |
|
515 | - private function getAbsoluteImagePath($path) { |
|
516 | - return $this->urlGenerator->getAbsoluteURL( |
|
517 | - $this->urlGenerator->imagePath('core', $path) |
|
518 | - ); |
|
519 | - } |
|
520 | - |
|
521 | - /** |
|
522 | - * @param Message $iTipMessage |
|
523 | - * @param int $lastOccurrence |
|
524 | - * @return string |
|
525 | - */ |
|
526 | - private function createInvitationToken(Message $iTipMessage, $lastOccurrence):string { |
|
527 | - $token = $this->random->generate(60, ISecureRandom::CHAR_UPPER . ISecureRandom::CHAR_LOWER . ISecureRandom::CHAR_DIGITS); |
|
528 | - |
|
529 | - /** @var VEvent $vevent */ |
|
530 | - $vevent = $iTipMessage->message->VEVENT; |
|
531 | - $attendee = $iTipMessage->recipient; |
|
532 | - $organizer = $iTipMessage->sender; |
|
533 | - $sequence = $iTipMessage->sequence; |
|
534 | - $recurrenceId = isset($vevent->{'RECURRENCE-ID'}) ? |
|
535 | - $vevent->{'RECURRENCE-ID'}->getValue() : null; |
|
536 | - $uid = $vevent->{'UID'}; |
|
537 | - |
|
538 | - $query = $this->db->getQueryBuilder(); |
|
539 | - $query->insert('calendar_invitation_tokens') |
|
540 | - ->values([ |
|
541 | - 'token' => $query->createNamedParameter($token), |
|
542 | - 'attendee' => $query->createNamedParameter($attendee), |
|
543 | - 'organizer' => $query->createNamedParameter($organizer), |
|
544 | - 'sequence' => $query->createNamedParameter($sequence), |
|
545 | - 'recurrenceid' => $query->createNamedParameter($recurrenceId), |
|
546 | - 'expiration' => $query->createNamedParameter($lastOccurrence), |
|
547 | - 'uid' => $query->createNamedParameter($uid) |
|
548 | - ]) |
|
549 | - ->execute(); |
|
550 | - |
|
551 | - return $token; |
|
552 | - } |
|
508 | + $template->addBodyText($html, $text); |
|
509 | + } |
|
510 | + |
|
511 | + /** |
|
512 | + * @param string $path |
|
513 | + * @return string |
|
514 | + */ |
|
515 | + private function getAbsoluteImagePath($path) { |
|
516 | + return $this->urlGenerator->getAbsoluteURL( |
|
517 | + $this->urlGenerator->imagePath('core', $path) |
|
518 | + ); |
|
519 | + } |
|
520 | + |
|
521 | + /** |
|
522 | + * @param Message $iTipMessage |
|
523 | + * @param int $lastOccurrence |
|
524 | + * @return string |
|
525 | + */ |
|
526 | + private function createInvitationToken(Message $iTipMessage, $lastOccurrence):string { |
|
527 | + $token = $this->random->generate(60, ISecureRandom::CHAR_UPPER . ISecureRandom::CHAR_LOWER . ISecureRandom::CHAR_DIGITS); |
|
528 | + |
|
529 | + /** @var VEvent $vevent */ |
|
530 | + $vevent = $iTipMessage->message->VEVENT; |
|
531 | + $attendee = $iTipMessage->recipient; |
|
532 | + $organizer = $iTipMessage->sender; |
|
533 | + $sequence = $iTipMessage->sequence; |
|
534 | + $recurrenceId = isset($vevent->{'RECURRENCE-ID'}) ? |
|
535 | + $vevent->{'RECURRENCE-ID'}->getValue() : null; |
|
536 | + $uid = $vevent->{'UID'}; |
|
537 | + |
|
538 | + $query = $this->db->getQueryBuilder(); |
|
539 | + $query->insert('calendar_invitation_tokens') |
|
540 | + ->values([ |
|
541 | + 'token' => $query->createNamedParameter($token), |
|
542 | + 'attendee' => $query->createNamedParameter($attendee), |
|
543 | + 'organizer' => $query->createNamedParameter($organizer), |
|
544 | + 'sequence' => $query->createNamedParameter($sequence), |
|
545 | + 'recurrenceid' => $query->createNamedParameter($recurrenceId), |
|
546 | + 'expiration' => $query->createNamedParameter($lastOccurrence), |
|
547 | + 'uid' => $query->createNamedParameter($uid) |
|
548 | + ]) |
|
549 | + ->execute(); |
|
550 | + |
|
551 | + return $token; |
|
552 | + } |
|
553 | 553 | } |
@@ -32,77 +32,77 @@ |
||
32 | 32 | |
33 | 33 | class InvitationResponseServer { |
34 | 34 | |
35 | - /** @var \OCA\DAV\Connector\Sabre\Server */ |
|
36 | - public $server; |
|
35 | + /** @var \OCA\DAV\Connector\Sabre\Server */ |
|
36 | + public $server; |
|
37 | 37 | |
38 | - /** |
|
39 | - * InvitationResponseServer constructor. |
|
40 | - * |
|
41 | - * @param string $baseUri |
|
42 | - */ |
|
43 | - public function __construct($baseUri) { |
|
44 | - $logger = \OC::$server->getLogger(); |
|
45 | - $dispatcher = \OC::$server->getEventDispatcher(); |
|
38 | + /** |
|
39 | + * InvitationResponseServer constructor. |
|
40 | + * |
|
41 | + * @param string $baseUri |
|
42 | + */ |
|
43 | + public function __construct($baseUri) { |
|
44 | + $logger = \OC::$server->getLogger(); |
|
45 | + $dispatcher = \OC::$server->getEventDispatcher(); |
|
46 | 46 | |
47 | - $root = new RootCollection(); |
|
48 | - $this->server = new \OCA\DAV\Connector\Sabre\Server(new CachingTree($root)); |
|
47 | + $root = new RootCollection(); |
|
48 | + $this->server = new \OCA\DAV\Connector\Sabre\Server(new CachingTree($root)); |
|
49 | 49 | |
50 | - // Add maintenance plugin |
|
51 | - $this->server->addPlugin(new \OCA\DAV\Connector\Sabre\MaintenancePlugin(\OC::$server->getConfig())); |
|
50 | + // Add maintenance plugin |
|
51 | + $this->server->addPlugin(new \OCA\DAV\Connector\Sabre\MaintenancePlugin(\OC::$server->getConfig())); |
|
52 | 52 | |
53 | - // Set URL explicitly due to reverse-proxy situations |
|
54 | - $this->server->httpRequest->setUrl($baseUri); |
|
55 | - $this->server->setBaseUri($baseUri); |
|
53 | + // Set URL explicitly due to reverse-proxy situations |
|
54 | + $this->server->httpRequest->setUrl($baseUri); |
|
55 | + $this->server->setBaseUri($baseUri); |
|
56 | 56 | |
57 | - $this->server->addPlugin(new BlockLegacyClientPlugin(\OC::$server->getConfig())); |
|
58 | - $this->server->addPlugin(new AnonymousOptionsPlugin()); |
|
59 | - $this->server->addPlugin(new class() extends Plugin { |
|
60 | - public function getCurrentPrincipal() { |
|
61 | - return 'principals/system/public'; |
|
62 | - } |
|
63 | - }); |
|
57 | + $this->server->addPlugin(new BlockLegacyClientPlugin(\OC::$server->getConfig())); |
|
58 | + $this->server->addPlugin(new AnonymousOptionsPlugin()); |
|
59 | + $this->server->addPlugin(new class() extends Plugin { |
|
60 | + public function getCurrentPrincipal() { |
|
61 | + return 'principals/system/public'; |
|
62 | + } |
|
63 | + }); |
|
64 | 64 | |
65 | - // allow setup of additional auth backends |
|
66 | - $event = new SabrePluginEvent($this->server); |
|
67 | - $dispatcher->dispatch('OCA\DAV\Connector\Sabre::authInit', $event); |
|
65 | + // allow setup of additional auth backends |
|
66 | + $event = new SabrePluginEvent($this->server); |
|
67 | + $dispatcher->dispatch('OCA\DAV\Connector\Sabre::authInit', $event); |
|
68 | 68 | |
69 | - $this->server->addPlugin(new \OCA\DAV\Connector\Sabre\ExceptionLoggerPlugin('webdav', $logger)); |
|
70 | - $this->server->addPlugin(new \OCA\DAV\Connector\Sabre\LockPlugin()); |
|
71 | - $this->server->addPlugin(new \Sabre\DAV\Sync\Plugin()); |
|
69 | + $this->server->addPlugin(new \OCA\DAV\Connector\Sabre\ExceptionLoggerPlugin('webdav', $logger)); |
|
70 | + $this->server->addPlugin(new \OCA\DAV\Connector\Sabre\LockPlugin()); |
|
71 | + $this->server->addPlugin(new \Sabre\DAV\Sync\Plugin()); |
|
72 | 72 | |
73 | - // acl |
|
74 | - $acl = new DavAclPlugin(); |
|
75 | - $acl->principalCollectionSet = [ |
|
76 | - 'principals/users', 'principals/groups' |
|
77 | - ]; |
|
78 | - $acl->defaultUsernamePath = 'principals/users'; |
|
79 | - $this->server->addPlugin($acl); |
|
73 | + // acl |
|
74 | + $acl = new DavAclPlugin(); |
|
75 | + $acl->principalCollectionSet = [ |
|
76 | + 'principals/users', 'principals/groups' |
|
77 | + ]; |
|
78 | + $acl->defaultUsernamePath = 'principals/users'; |
|
79 | + $this->server->addPlugin($acl); |
|
80 | 80 | |
81 | - // calendar plugins |
|
82 | - $this->server->addPlugin(new \OCA\DAV\CalDAV\Plugin()); |
|
83 | - $this->server->addPlugin(new \Sabre\CalDAV\ICSExportPlugin()); |
|
84 | - $this->server->addPlugin(new \OCA\DAV\CalDAV\Schedule\Plugin()); |
|
85 | - $this->server->addPlugin(new \Sabre\CalDAV\Subscriptions\Plugin()); |
|
86 | - $this->server->addPlugin(new \Sabre\CalDAV\Notifications\Plugin()); |
|
87 | - //$this->server->addPlugin(new \OCA\DAV\DAV\Sharing\Plugin($authBackend, \OC::$server->getRequest())); |
|
88 | - $this->server->addPlugin(new \OCA\DAV\CalDAV\Publishing\PublishPlugin( |
|
89 | - \OC::$server->getConfig(), |
|
90 | - \OC::$server->getURLGenerator() |
|
91 | - )); |
|
81 | + // calendar plugins |
|
82 | + $this->server->addPlugin(new \OCA\DAV\CalDAV\Plugin()); |
|
83 | + $this->server->addPlugin(new \Sabre\CalDAV\ICSExportPlugin()); |
|
84 | + $this->server->addPlugin(new \OCA\DAV\CalDAV\Schedule\Plugin()); |
|
85 | + $this->server->addPlugin(new \Sabre\CalDAV\Subscriptions\Plugin()); |
|
86 | + $this->server->addPlugin(new \Sabre\CalDAV\Notifications\Plugin()); |
|
87 | + //$this->server->addPlugin(new \OCA\DAV\DAV\Sharing\Plugin($authBackend, \OC::$server->getRequest())); |
|
88 | + $this->server->addPlugin(new \OCA\DAV\CalDAV\Publishing\PublishPlugin( |
|
89 | + \OC::$server->getConfig(), |
|
90 | + \OC::$server->getURLGenerator() |
|
91 | + )); |
|
92 | 92 | |
93 | - // wait with registering these until auth is handled and the filesystem is setup |
|
94 | - $this->server->on('beforeMethod', function () use ($root) { |
|
95 | - // register plugins from apps |
|
96 | - $pluginManager = new PluginManager( |
|
97 | - \OC::$server, |
|
98 | - \OC::$server->getAppManager() |
|
99 | - ); |
|
100 | - foreach ($pluginManager->getAppPlugins() as $appPlugin) { |
|
101 | - $this->server->addPlugin($appPlugin); |
|
102 | - } |
|
103 | - foreach ($pluginManager->getAppCollections() as $appCollection) { |
|
104 | - $root->addChild($appCollection); |
|
105 | - } |
|
106 | - }); |
|
107 | - } |
|
93 | + // wait with registering these until auth is handled and the filesystem is setup |
|
94 | + $this->server->on('beforeMethod', function () use ($root) { |
|
95 | + // register plugins from apps |
|
96 | + $pluginManager = new PluginManager( |
|
97 | + \OC::$server, |
|
98 | + \OC::$server->getAppManager() |
|
99 | + ); |
|
100 | + foreach ($pluginManager->getAppPlugins() as $appPlugin) { |
|
101 | + $this->server->addPlugin($appPlugin); |
|
102 | + } |
|
103 | + foreach ($pluginManager->getAppCollections() as $appCollection) { |
|
104 | + $root->addChild($appCollection); |
|
105 | + } |
|
106 | + }); |
|
107 | + } |
|
108 | 108 | } |
109 | 109 | \ No newline at end of file |
@@ -11,61 +11,61 @@ |
||
11 | 11 | */ |
12 | 12 | class Version1006Date20180619154313 extends SimpleMigrationStep { |
13 | 13 | |
14 | - /** |
|
15 | - * @param IOutput $output |
|
16 | - * @param \Closure $schemaClosure The `\Closure` returns a `ISchemaWrapper` |
|
17 | - * @param array $options |
|
18 | - * @return null|ISchemaWrapper |
|
19 | - * @since 13.0.0 |
|
20 | - */ |
|
21 | - public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) { |
|
22 | - /** @var ISchemaWrapper $schema */ |
|
23 | - $schema = $schemaClosure(); |
|
14 | + /** |
|
15 | + * @param IOutput $output |
|
16 | + * @param \Closure $schemaClosure The `\Closure` returns a `ISchemaWrapper` |
|
17 | + * @param array $options |
|
18 | + * @return null|ISchemaWrapper |
|
19 | + * @since 13.0.0 |
|
20 | + */ |
|
21 | + public function changeSchema(IOutput $output, \Closure $schemaClosure, array $options) { |
|
22 | + /** @var ISchemaWrapper $schema */ |
|
23 | + $schema = $schemaClosure(); |
|
24 | 24 | |
25 | - if (!$schema->hasTable('calendar_invitation_tokens')) { |
|
26 | - $table = $schema->createTable('calendar_invitation_tokens'); |
|
25 | + if (!$schema->hasTable('calendar_invitation_tokens')) { |
|
26 | + $table = $schema->createTable('calendar_invitation_tokens'); |
|
27 | 27 | |
28 | - $table->addColumn('id', Type::BIGINT, [ |
|
29 | - 'autoincrement' => true, |
|
30 | - 'notnull' => true, |
|
31 | - 'length' => 11, |
|
32 | - 'unsigned' => true, |
|
33 | - ]); |
|
34 | - $table->addColumn('uid', Type::STRING, [ |
|
35 | - 'notnull' => true, |
|
36 | - 'length' => 255, |
|
37 | - ]); |
|
38 | - $table->addColumn('recurrenceid', Type::STRING, [ |
|
39 | - 'notnull' => false, |
|
40 | - 'length' => 255, |
|
41 | - ]); |
|
42 | - $table->addColumn('attendee', Type::STRING, [ |
|
43 | - 'notnull' => true, |
|
44 | - 'length' => 255, |
|
45 | - ]); |
|
46 | - $table->addColumn('organizer', Type::STRING, [ |
|
47 | - 'notnull' => true, |
|
48 | - 'length' => 255, |
|
49 | - ]); |
|
50 | - $table->addColumn('sequence', Type::BIGINT, [ |
|
51 | - 'notnull' => false, |
|
52 | - 'length' => 11, |
|
53 | - 'unsigned' => true, |
|
54 | - ]); |
|
55 | - $table->addColumn('token', Type::STRING, [ |
|
56 | - 'notnull' => true, |
|
57 | - 'length' => 60, |
|
58 | - ]); |
|
59 | - $table->addColumn('expiration', Type::BIGINT, [ |
|
60 | - 'notnull' => true, |
|
61 | - 'length' => 11, |
|
62 | - 'unsigned' => true, |
|
63 | - ]); |
|
28 | + $table->addColumn('id', Type::BIGINT, [ |
|
29 | + 'autoincrement' => true, |
|
30 | + 'notnull' => true, |
|
31 | + 'length' => 11, |
|
32 | + 'unsigned' => true, |
|
33 | + ]); |
|
34 | + $table->addColumn('uid', Type::STRING, [ |
|
35 | + 'notnull' => true, |
|
36 | + 'length' => 255, |
|
37 | + ]); |
|
38 | + $table->addColumn('recurrenceid', Type::STRING, [ |
|
39 | + 'notnull' => false, |
|
40 | + 'length' => 255, |
|
41 | + ]); |
|
42 | + $table->addColumn('attendee', Type::STRING, [ |
|
43 | + 'notnull' => true, |
|
44 | + 'length' => 255, |
|
45 | + ]); |
|
46 | + $table->addColumn('organizer', Type::STRING, [ |
|
47 | + 'notnull' => true, |
|
48 | + 'length' => 255, |
|
49 | + ]); |
|
50 | + $table->addColumn('sequence', Type::BIGINT, [ |
|
51 | + 'notnull' => false, |
|
52 | + 'length' => 11, |
|
53 | + 'unsigned' => true, |
|
54 | + ]); |
|
55 | + $table->addColumn('token', Type::STRING, [ |
|
56 | + 'notnull' => true, |
|
57 | + 'length' => 60, |
|
58 | + ]); |
|
59 | + $table->addColumn('expiration', Type::BIGINT, [ |
|
60 | + 'notnull' => true, |
|
61 | + 'length' => 11, |
|
62 | + 'unsigned' => true, |
|
63 | + ]); |
|
64 | 64 | |
65 | - $table->setPrimaryKey(['id'], 'calendar_invitation_tokens_id_idx'); |
|
66 | - $table->addIndex(['token'], 'calendar_invitation_tokens_token_idx'); |
|
65 | + $table->setPrimaryKey(['id'], 'calendar_invitation_tokens_id_idx'); |
|
66 | + $table->addIndex(['token'], 'calendar_invitation_tokens_token_idx'); |
|
67 | 67 | |
68 | - return $schema; |
|
69 | - } |
|
70 | - } |
|
68 | + return $schema; |
|
69 | + } |
|
70 | + } |
|
71 | 71 | } |
@@ -33,160 +33,160 @@ discard block |
||
33 | 33 | |
34 | 34 | class InvitationResponseController extends Controller { |
35 | 35 | |
36 | - /** @var IDBConnection */ |
|
37 | - private $db; |
|
38 | - |
|
39 | - /** @var TimeFactory */ |
|
40 | - private $timeFactory; |
|
41 | - |
|
42 | - /** |
|
43 | - * InvitationResponseController constructor. |
|
44 | - * |
|
45 | - * @param string $appName |
|
46 | - * @param IRequest $request |
|
47 | - * @param IDBConnection $db |
|
48 | - * @param TimeFactory $timeFactory |
|
49 | - */ |
|
50 | - public function __construct(string $appName, IRequest $request, |
|
51 | - IDBConnection $db, TimeFactory $timeFactory) { |
|
52 | - parent::__construct($appName, $request); |
|
53 | - $this->db = $db; |
|
54 | - $this->timeFactory = $timeFactory; |
|
55 | - } |
|
56 | - |
|
57 | - /** |
|
58 | - * @PublicPage |
|
59 | - * @NoCSRFRequired |
|
60 | - * |
|
61 | - * @param string $token |
|
62 | - * @return TemplateResponse |
|
63 | - */ |
|
64 | - public function accept(string $token):TemplateResponse { |
|
65 | - $row = $this->getTokenInformation($token); |
|
66 | - if (!$row) { |
|
67 | - return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest'); |
|
68 | - } |
|
69 | - |
|
70 | - $iTipMessage = $this->buildITipResponse($row, 'ACCEPTED'); |
|
71 | - $this->handleITipMessage($iTipMessage); |
|
72 | - if ($iTipMessage->getScheduleStatus() === '1.2') { |
|
73 | - return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest'); |
|
74 | - } |
|
75 | - |
|
76 | - return new TemplateResponse($this->appName, 'schedule-response-error', [ |
|
77 | - 'organizer' => $row['organizer'], |
|
78 | - ], 'guest'); |
|
79 | - } |
|
80 | - |
|
81 | - /** |
|
82 | - * @PublicPage |
|
83 | - * @NoCSRFRequired |
|
84 | - * |
|
85 | - * @param string $token |
|
86 | - * @return TemplateResponse |
|
87 | - */ |
|
88 | - public function decline(string $token):TemplateResponse { |
|
89 | - $row = $this->getTokenInformation($token); |
|
90 | - if (!$row) { |
|
91 | - return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest'); |
|
92 | - } |
|
93 | - |
|
94 | - $iTipMessage = $this->buildITipResponse($row, 'DECLINED'); |
|
95 | - $this->handleITipMessage($iTipMessage); |
|
96 | - |
|
97 | - if ($iTipMessage->getScheduleStatus() === '1.2') { |
|
98 | - return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest'); |
|
99 | - } |
|
100 | - |
|
101 | - return new TemplateResponse($this->appName, 'schedule-response-error', [ |
|
102 | - 'organizer' => $row['organizer'], |
|
103 | - ], 'guest'); |
|
104 | - } |
|
105 | - |
|
106 | - /** |
|
107 | - * @PublicPage |
|
108 | - * @NoCSRFRequired |
|
109 | - * |
|
110 | - * @param string $token |
|
111 | - * @return TemplateResponse |
|
112 | - */ |
|
113 | - public function options(string $token):TemplateResponse { |
|
114 | - return new TemplateResponse($this->appName, 'schedule-response-options', [ |
|
115 | - 'token' => $token |
|
116 | - ], 'guest'); |
|
117 | - } |
|
118 | - |
|
119 | - /** |
|
120 | - * @PublicPage |
|
121 | - * @NoCSRFRequired |
|
122 | - * |
|
123 | - * @param string $token |
|
124 | - * |
|
125 | - * @return TemplateResponse |
|
126 | - */ |
|
127 | - public function processMoreOptionsResult(string $token):TemplateResponse { |
|
128 | - $partstat = $this->request->getParam('partStat'); |
|
129 | - $guests = (int) $this->request->getParam('guests'); |
|
130 | - $comment = $this->request->getParam('comment'); |
|
131 | - |
|
132 | - $row = $this->getTokenInformation($token); |
|
133 | - if (!$row || !\in_array($partstat, ['ACCEPTED', 'DECLINED', 'TENTATIVE'])) { |
|
134 | - return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest'); |
|
135 | - } |
|
136 | - |
|
137 | - $iTipMessage = $this->buildITipResponse($row, 'ACCEPTED', $guests, $comment); |
|
138 | - $this->handleITipMessage($iTipMessage); |
|
139 | - if ($iTipMessage->getScheduleStatus() === '1.2') { |
|
140 | - return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest'); |
|
141 | - } |
|
142 | - |
|
143 | - return new TemplateResponse($this->appName, 'schedule-response-error', [ |
|
144 | - 'organizer' => $row['organizer'], |
|
145 | - ], 'guest'); |
|
146 | - } |
|
147 | - |
|
148 | - /** |
|
149 | - * @param string $token |
|
150 | - * @return array|null |
|
151 | - */ |
|
152 | - private function getTokenInformation(string $token):array { |
|
153 | - $query = $this->db->getQueryBuilder(); |
|
154 | - $query->select('*') |
|
155 | - ->from('calendar_invitation_tokens') |
|
156 | - ->where($query->expr()->eq('token', $query->createNamedParameter($token))); |
|
157 | - $stmt = $query->execute(); |
|
158 | - $row = $stmt->fetch(\PDO::FETCH_ASSOC); |
|
159 | - |
|
160 | - if(!$row) { |
|
161 | - return null; |
|
162 | - } |
|
163 | - |
|
164 | - $currentTime = $this->timeFactory->getTime(); |
|
165 | - if (((int) $row['expiration']) < $currentTime) { |
|
166 | - return null; |
|
167 | - } |
|
168 | - |
|
169 | - return $row; |
|
170 | - } |
|
171 | - |
|
172 | - /** |
|
173 | - * @param array $row |
|
174 | - * @param string $partStat participation status of attendee - SEE RFC 5545 |
|
175 | - * @param int|null $guests |
|
176 | - * @param string|null $comment |
|
177 | - * @return Message |
|
178 | - */ |
|
179 | - private function buildITipResponse(array $row, string $partStat, int $guests=null, |
|
180 | - string $comment=null):Message { |
|
181 | - $iTipMessage = new Message(); |
|
182 | - $iTipMessage->uid = $row['uid']; |
|
183 | - $iTipMessage->component = 'VEVENT'; |
|
184 | - $iTipMessage->method = 'REPLY'; |
|
185 | - $iTipMessage->sequence = $row['sequence']; |
|
186 | - $iTipMessage->sender = $row['attendee']; |
|
187 | - $iTipMessage->recipient = $row['organizer']; |
|
188 | - |
|
189 | - $message = <<<EOF |
|
36 | + /** @var IDBConnection */ |
|
37 | + private $db; |
|
38 | + |
|
39 | + /** @var TimeFactory */ |
|
40 | + private $timeFactory; |
|
41 | + |
|
42 | + /** |
|
43 | + * InvitationResponseController constructor. |
|
44 | + * |
|
45 | + * @param string $appName |
|
46 | + * @param IRequest $request |
|
47 | + * @param IDBConnection $db |
|
48 | + * @param TimeFactory $timeFactory |
|
49 | + */ |
|
50 | + public function __construct(string $appName, IRequest $request, |
|
51 | + IDBConnection $db, TimeFactory $timeFactory) { |
|
52 | + parent::__construct($appName, $request); |
|
53 | + $this->db = $db; |
|
54 | + $this->timeFactory = $timeFactory; |
|
55 | + } |
|
56 | + |
|
57 | + /** |
|
58 | + * @PublicPage |
|
59 | + * @NoCSRFRequired |
|
60 | + * |
|
61 | + * @param string $token |
|
62 | + * @return TemplateResponse |
|
63 | + */ |
|
64 | + public function accept(string $token):TemplateResponse { |
|
65 | + $row = $this->getTokenInformation($token); |
|
66 | + if (!$row) { |
|
67 | + return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest'); |
|
68 | + } |
|
69 | + |
|
70 | + $iTipMessage = $this->buildITipResponse($row, 'ACCEPTED'); |
|
71 | + $this->handleITipMessage($iTipMessage); |
|
72 | + if ($iTipMessage->getScheduleStatus() === '1.2') { |
|
73 | + return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest'); |
|
74 | + } |
|
75 | + |
|
76 | + return new TemplateResponse($this->appName, 'schedule-response-error', [ |
|
77 | + 'organizer' => $row['organizer'], |
|
78 | + ], 'guest'); |
|
79 | + } |
|
80 | + |
|
81 | + /** |
|
82 | + * @PublicPage |
|
83 | + * @NoCSRFRequired |
|
84 | + * |
|
85 | + * @param string $token |
|
86 | + * @return TemplateResponse |
|
87 | + */ |
|
88 | + public function decline(string $token):TemplateResponse { |
|
89 | + $row = $this->getTokenInformation($token); |
|
90 | + if (!$row) { |
|
91 | + return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest'); |
|
92 | + } |
|
93 | + |
|
94 | + $iTipMessage = $this->buildITipResponse($row, 'DECLINED'); |
|
95 | + $this->handleITipMessage($iTipMessage); |
|
96 | + |
|
97 | + if ($iTipMessage->getScheduleStatus() === '1.2') { |
|
98 | + return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest'); |
|
99 | + } |
|
100 | + |
|
101 | + return new TemplateResponse($this->appName, 'schedule-response-error', [ |
|
102 | + 'organizer' => $row['organizer'], |
|
103 | + ], 'guest'); |
|
104 | + } |
|
105 | + |
|
106 | + /** |
|
107 | + * @PublicPage |
|
108 | + * @NoCSRFRequired |
|
109 | + * |
|
110 | + * @param string $token |
|
111 | + * @return TemplateResponse |
|
112 | + */ |
|
113 | + public function options(string $token):TemplateResponse { |
|
114 | + return new TemplateResponse($this->appName, 'schedule-response-options', [ |
|
115 | + 'token' => $token |
|
116 | + ], 'guest'); |
|
117 | + } |
|
118 | + |
|
119 | + /** |
|
120 | + * @PublicPage |
|
121 | + * @NoCSRFRequired |
|
122 | + * |
|
123 | + * @param string $token |
|
124 | + * |
|
125 | + * @return TemplateResponse |
|
126 | + */ |
|
127 | + public function processMoreOptionsResult(string $token):TemplateResponse { |
|
128 | + $partstat = $this->request->getParam('partStat'); |
|
129 | + $guests = (int) $this->request->getParam('guests'); |
|
130 | + $comment = $this->request->getParam('comment'); |
|
131 | + |
|
132 | + $row = $this->getTokenInformation($token); |
|
133 | + if (!$row || !\in_array($partstat, ['ACCEPTED', 'DECLINED', 'TENTATIVE'])) { |
|
134 | + return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest'); |
|
135 | + } |
|
136 | + |
|
137 | + $iTipMessage = $this->buildITipResponse($row, 'ACCEPTED', $guests, $comment); |
|
138 | + $this->handleITipMessage($iTipMessage); |
|
139 | + if ($iTipMessage->getScheduleStatus() === '1.2') { |
|
140 | + return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest'); |
|
141 | + } |
|
142 | + |
|
143 | + return new TemplateResponse($this->appName, 'schedule-response-error', [ |
|
144 | + 'organizer' => $row['organizer'], |
|
145 | + ], 'guest'); |
|
146 | + } |
|
147 | + |
|
148 | + /** |
|
149 | + * @param string $token |
|
150 | + * @return array|null |
|
151 | + */ |
|
152 | + private function getTokenInformation(string $token):array { |
|
153 | + $query = $this->db->getQueryBuilder(); |
|
154 | + $query->select('*') |
|
155 | + ->from('calendar_invitation_tokens') |
|
156 | + ->where($query->expr()->eq('token', $query->createNamedParameter($token))); |
|
157 | + $stmt = $query->execute(); |
|
158 | + $row = $stmt->fetch(\PDO::FETCH_ASSOC); |
|
159 | + |
|
160 | + if(!$row) { |
|
161 | + return null; |
|
162 | + } |
|
163 | + |
|
164 | + $currentTime = $this->timeFactory->getTime(); |
|
165 | + if (((int) $row['expiration']) < $currentTime) { |
|
166 | + return null; |
|
167 | + } |
|
168 | + |
|
169 | + return $row; |
|
170 | + } |
|
171 | + |
|
172 | + /** |
|
173 | + * @param array $row |
|
174 | + * @param string $partStat participation status of attendee - SEE RFC 5545 |
|
175 | + * @param int|null $guests |
|
176 | + * @param string|null $comment |
|
177 | + * @return Message |
|
178 | + */ |
|
179 | + private function buildITipResponse(array $row, string $partStat, int $guests=null, |
|
180 | + string $comment=null):Message { |
|
181 | + $iTipMessage = new Message(); |
|
182 | + $iTipMessage->uid = $row['uid']; |
|
183 | + $iTipMessage->component = 'VEVENT'; |
|
184 | + $iTipMessage->method = 'REPLY'; |
|
185 | + $iTipMessage->sequence = $row['sequence']; |
|
186 | + $iTipMessage->sender = $row['attendee']; |
|
187 | + $iTipMessage->recipient = $row['organizer']; |
|
188 | + |
|
189 | + $message = <<<EOF |
|
190 | 190 | BEGIN:VCALENDAR |
191 | 191 | PRODID:-//Nextcloud/Nextcloud CalDAV Server//EN |
192 | 192 | METHOD:REPLY |
@@ -201,44 +201,44 @@ discard block |
||
201 | 201 | END:VCALENDAR |
202 | 202 | EOF; |
203 | 203 | |
204 | - $vObject = Reader::read(vsprintf($message, [ |
|
205 | - $partStat, $row['attendee'], $row['organizer'], |
|
206 | - $row['uid'], $row['sequence'] ?? 0, |
|
207 | - ])); |
|
208 | - $vEvent = $vObject->{'VEVENT'}; |
|
209 | - /** @var \Sabre\VObject\Property\ICalendar\CalAddress $attendee */ |
|
210 | - $attendee = $vEvent->{'ATTENDEE'}; |
|
211 | - |
|
212 | - $vEvent->DTSTAMP = date('Ymd\\THis\\Z'); |
|
213 | - |
|
214 | - if ($row['recurrenceid']) { |
|
215 | - $vEvent->add('RECURRENCE-ID', $row['recurrenceid']); |
|
216 | - } |
|
217 | - if ($comment) { |
|
218 | - $attendee->add('X-RESPONSE-COMMENT', $comment); |
|
219 | - $vObject->add('COMMENT', $comment); |
|
220 | - } |
|
221 | - if ($guests) { |
|
222 | - $attendee->add('X-NUM-GUESTS', $guests); |
|
223 | - } |
|
224 | - |
|
225 | - $iTipMessage->message = $vObject; |
|
226 | - |
|
227 | - return $iTipMessage; |
|
228 | - } |
|
229 | - |
|
230 | - /** |
|
231 | - * @param Message $iTipMessage |
|
232 | - * @return void |
|
233 | - */ |
|
234 | - private function handleITipMessage(Message $iTipMessage) { |
|
235 | - $server = new InvitationResponseServer(\OC::$WEBROOT . '/remote.php/dav/'); |
|
236 | - // Don't run `$server->exec()`, because we just need access to the |
|
237 | - // fully initialized schedule plugin, but we don't want Sabre/DAV |
|
238 | - // to actually handle and reply to the request |
|
239 | - |
|
240 | - /** @var \OCA\DAV\CalDAV\Schedule\Plugin $schedulingPlugin */ |
|
241 | - $schedulingPlugin = $server->server->getPlugin('caldav-schedule'); |
|
242 | - $schedulingPlugin->scheduleLocalDelivery($iTipMessage); |
|
243 | - } |
|
204 | + $vObject = Reader::read(vsprintf($message, [ |
|
205 | + $partStat, $row['attendee'], $row['organizer'], |
|
206 | + $row['uid'], $row['sequence'] ?? 0, |
|
207 | + ])); |
|
208 | + $vEvent = $vObject->{'VEVENT'}; |
|
209 | + /** @var \Sabre\VObject\Property\ICalendar\CalAddress $attendee */ |
|
210 | + $attendee = $vEvent->{'ATTENDEE'}; |
|
211 | + |
|
212 | + $vEvent->DTSTAMP = date('Ymd\\THis\\Z'); |
|
213 | + |
|
214 | + if ($row['recurrenceid']) { |
|
215 | + $vEvent->add('RECURRENCE-ID', $row['recurrenceid']); |
|
216 | + } |
|
217 | + if ($comment) { |
|
218 | + $attendee->add('X-RESPONSE-COMMENT', $comment); |
|
219 | + $vObject->add('COMMENT', $comment); |
|
220 | + } |
|
221 | + if ($guests) { |
|
222 | + $attendee->add('X-NUM-GUESTS', $guests); |
|
223 | + } |
|
224 | + |
|
225 | + $iTipMessage->message = $vObject; |
|
226 | + |
|
227 | + return $iTipMessage; |
|
228 | + } |
|
229 | + |
|
230 | + /** |
|
231 | + * @param Message $iTipMessage |
|
232 | + * @return void |
|
233 | + */ |
|
234 | + private function handleITipMessage(Message $iTipMessage) { |
|
235 | + $server = new InvitationResponseServer(\OC::$WEBROOT . '/remote.php/dav/'); |
|
236 | + // Don't run `$server->exec()`, because we just need access to the |
|
237 | + // fully initialized schedule plugin, but we don't want Sabre/DAV |
|
238 | + // to actually handle and reply to the request |
|
239 | + |
|
240 | + /** @var \OCA\DAV\CalDAV\Schedule\Plugin $schedulingPlugin */ |
|
241 | + $schedulingPlugin = $server->server->getPlugin('caldav-schedule'); |
|
242 | + $schedulingPlugin->scheduleLocalDelivery($iTipMessage); |
|
243 | + } |
|
244 | 244 | } |
@@ -30,23 +30,23 @@ |
||
30 | 30 | |
31 | 31 | class CleanupInvitationTokenJob extends TimedJob { |
32 | 32 | |
33 | - /** @var IDBConnection */ |
|
34 | - private $db; |
|
33 | + /** @var IDBConnection */ |
|
34 | + private $db; |
|
35 | 35 | |
36 | - /** @var ITimeFactory */ |
|
37 | - private $timeFactory; |
|
36 | + /** @var ITimeFactory */ |
|
37 | + private $timeFactory; |
|
38 | 38 | |
39 | - public function __construct(IDBConnection $db, ITimeFactory $timeFactory) { |
|
40 | - $this->db = $db; |
|
41 | - $this->timeFactory = $timeFactory; |
|
39 | + public function __construct(IDBConnection $db, ITimeFactory $timeFactory) { |
|
40 | + $this->db = $db; |
|
41 | + $this->timeFactory = $timeFactory; |
|
42 | 42 | |
43 | - $this->setInterval(60 * 60 * 24); |
|
44 | - } |
|
43 | + $this->setInterval(60 * 60 * 24); |
|
44 | + } |
|
45 | 45 | |
46 | - protected function run($argument) { |
|
47 | - $query = $this->db->getQueryBuilder(); |
|
48 | - $query->delete('calendar_invitation_tokens') |
|
49 | - ->where($query->expr()->lt('expiration', |
|
50 | - $query->createNamedParameter($this->timeFactory->getTime()))); |
|
51 | - } |
|
46 | + protected function run($argument) { |
|
47 | + $query = $this->db->getQueryBuilder(); |
|
48 | + $query->delete('calendar_invitation_tokens') |
|
49 | + ->where($query->expr()->lt('expiration', |
|
50 | + $query->createNamedParameter($this->timeFactory->getTime()))); |
|
51 | + } |
|
52 | 52 | } |
@@ -22,15 +22,15 @@ |
||
22 | 22 | */ |
23 | 23 | |
24 | 24 | return [ |
25 | - 'routes' => [ |
|
26 | - ['name' => 'birthday_calendar#enable', 'url' => '/enableBirthdayCalendar', 'verb' => 'POST'], |
|
27 | - ['name' => 'birthday_calendar#disable', 'url' => '/disableBirthdayCalendar', 'verb' => 'POST'], |
|
28 | - ['name' => 'invitation_response#accept', 'url' => '/invitation/accept/{token}', 'verb' => 'GET'], |
|
29 | - ['name' => 'invitation_response#decline', 'url' => '/invitation/decline/{token}', 'verb' => 'GET'], |
|
30 | - ['name' => 'invitation_response#options', 'url' => '/invitation/moreOptions/{token}', 'verb' => 'GET'], |
|
31 | - ['name' => 'invitation_response#processMoreOptionsResult', 'url' => '/invitation/moreOptions/{token}', 'verb' => 'POST'] |
|
32 | - ], |
|
33 | - 'ocs' => [ |
|
34 | - ['name' => 'direct#getUrl', 'url' => '/api/v1/direct', 'verb' => 'POST'], |
|
35 | - ], |
|
25 | + 'routes' => [ |
|
26 | + ['name' => 'birthday_calendar#enable', 'url' => '/enableBirthdayCalendar', 'verb' => 'POST'], |
|
27 | + ['name' => 'birthday_calendar#disable', 'url' => '/disableBirthdayCalendar', 'verb' => 'POST'], |
|
28 | + ['name' => 'invitation_response#accept', 'url' => '/invitation/accept/{token}', 'verb' => 'GET'], |
|
29 | + ['name' => 'invitation_response#decline', 'url' => '/invitation/decline/{token}', 'verb' => 'GET'], |
|
30 | + ['name' => 'invitation_response#options', 'url' => '/invitation/moreOptions/{token}', 'verb' => 'GET'], |
|
31 | + ['name' => 'invitation_response#processMoreOptionsResult', 'url' => '/invitation/moreOptions/{token}', 'verb' => 'POST'] |
|
32 | + ], |
|
33 | + 'ocs' => [ |
|
34 | + ['name' => 'direct#getUrl', 'url' => '/api/v1/direct', 'verb' => 'POST'], |
|
35 | + ], |
|
36 | 36 | ]; |