@@ -57,183 +57,183 @@ discard block |
||
| 57 | 57 | |
| 58 | 58 | class Plugin extends \Sabre\CalDAV\Schedule\Plugin { |
| 59 | 59 | |
| 60 | - /** |
|
| 61 | - * @var IConfig |
|
| 62 | - */ |
|
| 63 | - private $config; |
|
| 64 | - |
|
| 65 | - /** @var ITip\Message[] */ |
|
| 66 | - private $schedulingResponses = []; |
|
| 67 | - |
|
| 68 | - /** @var string|null */ |
|
| 69 | - private $pathOfCalendarObjectChange = null; |
|
| 70 | - |
|
| 71 | - public const CALENDAR_USER_TYPE = '{' . self::NS_CALDAV . '}calendar-user-type'; |
|
| 72 | - public const SCHEDULE_DEFAULT_CALENDAR_URL = '{' . Plugin::NS_CALDAV . '}schedule-default-calendar-URL'; |
|
| 73 | - private LoggerInterface $logger; |
|
| 74 | - |
|
| 75 | - /** |
|
| 76 | - * @param IConfig $config |
|
| 77 | - */ |
|
| 78 | - public function __construct(IConfig $config, LoggerInterface $logger) { |
|
| 79 | - $this->config = $config; |
|
| 80 | - $this->logger = $logger; |
|
| 81 | - } |
|
| 82 | - |
|
| 83 | - /** |
|
| 84 | - * Initializes the plugin |
|
| 85 | - * |
|
| 86 | - * @param Server $server |
|
| 87 | - * @return void |
|
| 88 | - */ |
|
| 89 | - public function initialize(Server $server) { |
|
| 90 | - parent::initialize($server); |
|
| 91 | - $server->on('propFind', [$this, 'propFindDefaultCalendarUrl'], 90); |
|
| 92 | - $server->on('afterWriteContent', [$this, 'dispatchSchedulingResponses']); |
|
| 93 | - $server->on('afterCreateFile', [$this, 'dispatchSchedulingResponses']); |
|
| 94 | - } |
|
| 95 | - |
|
| 96 | - /** |
|
| 97 | - * Allow manual setting of the object change URL |
|
| 98 | - * to support public write |
|
| 99 | - * |
|
| 100 | - * @param string $path |
|
| 101 | - */ |
|
| 102 | - public function setPathOfCalendarObjectChange(string $path): void { |
|
| 103 | - $this->pathOfCalendarObjectChange = $path; |
|
| 104 | - } |
|
| 105 | - |
|
| 106 | - /** |
|
| 107 | - * This method handler is invoked during fetching of properties. |
|
| 108 | - * |
|
| 109 | - * We use this event to add calendar-auto-schedule-specific properties. |
|
| 110 | - * |
|
| 111 | - * @param PropFind $propFind |
|
| 112 | - * @param INode $node |
|
| 113 | - * @return void |
|
| 114 | - */ |
|
| 115 | - public function propFind(PropFind $propFind, INode $node) { |
|
| 116 | - if ($node instanceof IPrincipal) { |
|
| 117 | - // overwrite Sabre/Dav's implementation |
|
| 118 | - $propFind->handle(self::CALENDAR_USER_TYPE, function () use ($node) { |
|
| 119 | - if ($node instanceof IProperties) { |
|
| 120 | - $props = $node->getProperties([self::CALENDAR_USER_TYPE]); |
|
| 121 | - |
|
| 122 | - if (isset($props[self::CALENDAR_USER_TYPE])) { |
|
| 123 | - return $props[self::CALENDAR_USER_TYPE]; |
|
| 124 | - } |
|
| 125 | - } |
|
| 126 | - |
|
| 127 | - return 'INDIVIDUAL'; |
|
| 128 | - }); |
|
| 129 | - } |
|
| 130 | - |
|
| 131 | - parent::propFind($propFind, $node); |
|
| 132 | - } |
|
| 133 | - |
|
| 134 | - /** |
|
| 135 | - * Returns a list of addresses that are associated with a principal. |
|
| 136 | - * |
|
| 137 | - * @param string $principal |
|
| 138 | - * @return array |
|
| 139 | - */ |
|
| 140 | - protected function getAddressesForPrincipal($principal) { |
|
| 141 | - $result = parent::getAddressesForPrincipal($principal); |
|
| 142 | - |
|
| 143 | - if ($result === null) { |
|
| 144 | - $result = []; |
|
| 145 | - } |
|
| 146 | - |
|
| 147 | - return $result; |
|
| 148 | - } |
|
| 149 | - |
|
| 150 | - /** |
|
| 151 | - * @param RequestInterface $request |
|
| 152 | - * @param ResponseInterface $response |
|
| 153 | - * @param VCalendar $vCal |
|
| 154 | - * @param mixed $calendarPath |
|
| 155 | - * @param mixed $modified |
|
| 156 | - * @param mixed $isNew |
|
| 157 | - */ |
|
| 158 | - public function calendarObjectChange(RequestInterface $request, ResponseInterface $response, VCalendar $vCal, $calendarPath, &$modified, $isNew) { |
|
| 159 | - // Save the first path we get as a calendar-object-change request |
|
| 160 | - if (!$this->pathOfCalendarObjectChange) { |
|
| 161 | - $this->pathOfCalendarObjectChange = $request->getPath(); |
|
| 162 | - } |
|
| 163 | - |
|
| 164 | - parent::calendarObjectChange($request, $response, $vCal, $calendarPath, $modified, $isNew); |
|
| 165 | - } |
|
| 166 | - |
|
| 167 | - /** |
|
| 168 | - * @inheritDoc |
|
| 169 | - */ |
|
| 170 | - public function scheduleLocalDelivery(ITip\Message $iTipMessage):void { |
|
| 171 | - /** @var VEvent|null $vevent */ |
|
| 172 | - $vevent = $iTipMessage->message->VEVENT ?? null; |
|
| 173 | - |
|
| 174 | - // Strip VALARMs from incoming VEVENT |
|
| 175 | - if ($vevent && isset($vevent->VALARM)) { |
|
| 176 | - $vevent->remove('VALARM'); |
|
| 177 | - } |
|
| 178 | - |
|
| 179 | - parent::scheduleLocalDelivery($iTipMessage); |
|
| 180 | - // We only care when the message was successfully delivered locally |
|
| 181 | - // Log all possible codes returned from the parent method that mean something went wrong |
|
| 182 | - // 3.7, 3.8, 5.0, 5.2 |
|
| 183 | - if ($iTipMessage->scheduleStatus !== '1.2;Message delivered locally') { |
|
| 184 | - $this->logger->debug('Message not delivered locally with status: ' . $iTipMessage->scheduleStatus); |
|
| 185 | - return; |
|
| 186 | - } |
|
| 187 | - // We only care about request. reply and cancel are properly handled |
|
| 188 | - // by parent::scheduleLocalDelivery already |
|
| 189 | - if (strcasecmp($iTipMessage->method, 'REQUEST') !== 0) { |
|
| 190 | - return; |
|
| 191 | - } |
|
| 192 | - |
|
| 193 | - // If parent::scheduleLocalDelivery set scheduleStatus to 1.2, |
|
| 194 | - // it means that it was successfully delivered locally. |
|
| 195 | - // Meaning that the ACL plugin is loaded and that a principal |
|
| 196 | - // exists for the given recipient id, no need to double check |
|
| 197 | - /** @var \Sabre\DAVACL\Plugin $aclPlugin */ |
|
| 198 | - $aclPlugin = $this->server->getPlugin('acl'); |
|
| 199 | - $principalUri = $aclPlugin->getPrincipalByUri($iTipMessage->recipient); |
|
| 200 | - $calendarUserType = $this->getCalendarUserTypeForPrincipal($principalUri); |
|
| 201 | - if (strcasecmp($calendarUserType, 'ROOM') !== 0 && strcasecmp($calendarUserType, 'RESOURCE') !== 0) { |
|
| 202 | - $this->logger->debug('Calendar user type is room or resource, not processing further'); |
|
| 203 | - return; |
|
| 204 | - } |
|
| 205 | - |
|
| 206 | - $attendee = $this->getCurrentAttendee($iTipMessage); |
|
| 207 | - if (!$attendee) { |
|
| 208 | - $this->logger->debug('No attendee set for scheduling message'); |
|
| 209 | - return; |
|
| 210 | - } |
|
| 211 | - |
|
| 212 | - // We only respond when a response was actually requested |
|
| 213 | - $rsvp = $this->getAttendeeRSVP($attendee); |
|
| 214 | - if (!$rsvp) { |
|
| 215 | - $this->logger->debug('No RSVP requested for attendee ' . $attendee->getValue()); |
|
| 216 | - return; |
|
| 217 | - } |
|
| 218 | - |
|
| 219 | - if (!$vevent) { |
|
| 220 | - $this->logger->debug('No VEVENT set to process on scheduling message'); |
|
| 221 | - return; |
|
| 222 | - } |
|
| 223 | - |
|
| 224 | - // We don't support autoresponses for recurrencing events for now |
|
| 225 | - if (isset($vevent->RRULE) || isset($vevent->RDATE)) { |
|
| 226 | - $this->logger->debug('VEVENT is a recurring event, autoresponding not supported'); |
|
| 227 | - return; |
|
| 228 | - } |
|
| 229 | - |
|
| 230 | - $dtstart = $vevent->DTSTART; |
|
| 231 | - $dtend = $this->getDTEndFromVEvent($vevent); |
|
| 232 | - $uid = $vevent->UID->getValue(); |
|
| 233 | - $sequence = isset($vevent->SEQUENCE) ? $vevent->SEQUENCE->getValue() : 0; |
|
| 234 | - $recurrenceId = isset($vevent->{'RECURRENCE-ID'}) ? $vevent->{'RECURRENCE-ID'}->serialize() : ''; |
|
| 235 | - |
|
| 236 | - $message = <<<EOF |
|
| 60 | + /** |
|
| 61 | + * @var IConfig |
|
| 62 | + */ |
|
| 63 | + private $config; |
|
| 64 | + |
|
| 65 | + /** @var ITip\Message[] */ |
|
| 66 | + private $schedulingResponses = []; |
|
| 67 | + |
|
| 68 | + /** @var string|null */ |
|
| 69 | + private $pathOfCalendarObjectChange = null; |
|
| 70 | + |
|
| 71 | + public const CALENDAR_USER_TYPE = '{' . self::NS_CALDAV . '}calendar-user-type'; |
|
| 72 | + public const SCHEDULE_DEFAULT_CALENDAR_URL = '{' . Plugin::NS_CALDAV . '}schedule-default-calendar-URL'; |
|
| 73 | + private LoggerInterface $logger; |
|
| 74 | + |
|
| 75 | + /** |
|
| 76 | + * @param IConfig $config |
|
| 77 | + */ |
|
| 78 | + public function __construct(IConfig $config, LoggerInterface $logger) { |
|
| 79 | + $this->config = $config; |
|
| 80 | + $this->logger = $logger; |
|
| 81 | + } |
|
| 82 | + |
|
| 83 | + /** |
|
| 84 | + * Initializes the plugin |
|
| 85 | + * |
|
| 86 | + * @param Server $server |
|
| 87 | + * @return void |
|
| 88 | + */ |
|
| 89 | + public function initialize(Server $server) { |
|
| 90 | + parent::initialize($server); |
|
| 91 | + $server->on('propFind', [$this, 'propFindDefaultCalendarUrl'], 90); |
|
| 92 | + $server->on('afterWriteContent', [$this, 'dispatchSchedulingResponses']); |
|
| 93 | + $server->on('afterCreateFile', [$this, 'dispatchSchedulingResponses']); |
|
| 94 | + } |
|
| 95 | + |
|
| 96 | + /** |
|
| 97 | + * Allow manual setting of the object change URL |
|
| 98 | + * to support public write |
|
| 99 | + * |
|
| 100 | + * @param string $path |
|
| 101 | + */ |
|
| 102 | + public function setPathOfCalendarObjectChange(string $path): void { |
|
| 103 | + $this->pathOfCalendarObjectChange = $path; |
|
| 104 | + } |
|
| 105 | + |
|
| 106 | + /** |
|
| 107 | + * This method handler is invoked during fetching of properties. |
|
| 108 | + * |
|
| 109 | + * We use this event to add calendar-auto-schedule-specific properties. |
|
| 110 | + * |
|
| 111 | + * @param PropFind $propFind |
|
| 112 | + * @param INode $node |
|
| 113 | + * @return void |
|
| 114 | + */ |
|
| 115 | + public function propFind(PropFind $propFind, INode $node) { |
|
| 116 | + if ($node instanceof IPrincipal) { |
|
| 117 | + // overwrite Sabre/Dav's implementation |
|
| 118 | + $propFind->handle(self::CALENDAR_USER_TYPE, function () use ($node) { |
|
| 119 | + if ($node instanceof IProperties) { |
|
| 120 | + $props = $node->getProperties([self::CALENDAR_USER_TYPE]); |
|
| 121 | + |
|
| 122 | + if (isset($props[self::CALENDAR_USER_TYPE])) { |
|
| 123 | + return $props[self::CALENDAR_USER_TYPE]; |
|
| 124 | + } |
|
| 125 | + } |
|
| 126 | + |
|
| 127 | + return 'INDIVIDUAL'; |
|
| 128 | + }); |
|
| 129 | + } |
|
| 130 | + |
|
| 131 | + parent::propFind($propFind, $node); |
|
| 132 | + } |
|
| 133 | + |
|
| 134 | + /** |
|
| 135 | + * Returns a list of addresses that are associated with a principal. |
|
| 136 | + * |
|
| 137 | + * @param string $principal |
|
| 138 | + * @return array |
|
| 139 | + */ |
|
| 140 | + protected function getAddressesForPrincipal($principal) { |
|
| 141 | + $result = parent::getAddressesForPrincipal($principal); |
|
| 142 | + |
|
| 143 | + if ($result === null) { |
|
| 144 | + $result = []; |
|
| 145 | + } |
|
| 146 | + |
|
| 147 | + return $result; |
|
| 148 | + } |
|
| 149 | + |
|
| 150 | + /** |
|
| 151 | + * @param RequestInterface $request |
|
| 152 | + * @param ResponseInterface $response |
|
| 153 | + * @param VCalendar $vCal |
|
| 154 | + * @param mixed $calendarPath |
|
| 155 | + * @param mixed $modified |
|
| 156 | + * @param mixed $isNew |
|
| 157 | + */ |
|
| 158 | + public function calendarObjectChange(RequestInterface $request, ResponseInterface $response, VCalendar $vCal, $calendarPath, &$modified, $isNew) { |
|
| 159 | + // Save the first path we get as a calendar-object-change request |
|
| 160 | + if (!$this->pathOfCalendarObjectChange) { |
|
| 161 | + $this->pathOfCalendarObjectChange = $request->getPath(); |
|
| 162 | + } |
|
| 163 | + |
|
| 164 | + parent::calendarObjectChange($request, $response, $vCal, $calendarPath, $modified, $isNew); |
|
| 165 | + } |
|
| 166 | + |
|
| 167 | + /** |
|
| 168 | + * @inheritDoc |
|
| 169 | + */ |
|
| 170 | + public function scheduleLocalDelivery(ITip\Message $iTipMessage):void { |
|
| 171 | + /** @var VEvent|null $vevent */ |
|
| 172 | + $vevent = $iTipMessage->message->VEVENT ?? null; |
|
| 173 | + |
|
| 174 | + // Strip VALARMs from incoming VEVENT |
|
| 175 | + if ($vevent && isset($vevent->VALARM)) { |
|
| 176 | + $vevent->remove('VALARM'); |
|
| 177 | + } |
|
| 178 | + |
|
| 179 | + parent::scheduleLocalDelivery($iTipMessage); |
|
| 180 | + // We only care when the message was successfully delivered locally |
|
| 181 | + // Log all possible codes returned from the parent method that mean something went wrong |
|
| 182 | + // 3.7, 3.8, 5.0, 5.2 |
|
| 183 | + if ($iTipMessage->scheduleStatus !== '1.2;Message delivered locally') { |
|
| 184 | + $this->logger->debug('Message not delivered locally with status: ' . $iTipMessage->scheduleStatus); |
|
| 185 | + return; |
|
| 186 | + } |
|
| 187 | + // We only care about request. reply and cancel are properly handled |
|
| 188 | + // by parent::scheduleLocalDelivery already |
|
| 189 | + if (strcasecmp($iTipMessage->method, 'REQUEST') !== 0) { |
|
| 190 | + return; |
|
| 191 | + } |
|
| 192 | + |
|
| 193 | + // If parent::scheduleLocalDelivery set scheduleStatus to 1.2, |
|
| 194 | + // it means that it was successfully delivered locally. |
|
| 195 | + // Meaning that the ACL plugin is loaded and that a principal |
|
| 196 | + // exists for the given recipient id, no need to double check |
|
| 197 | + /** @var \Sabre\DAVACL\Plugin $aclPlugin */ |
|
| 198 | + $aclPlugin = $this->server->getPlugin('acl'); |
|
| 199 | + $principalUri = $aclPlugin->getPrincipalByUri($iTipMessage->recipient); |
|
| 200 | + $calendarUserType = $this->getCalendarUserTypeForPrincipal($principalUri); |
|
| 201 | + if (strcasecmp($calendarUserType, 'ROOM') !== 0 && strcasecmp($calendarUserType, 'RESOURCE') !== 0) { |
|
| 202 | + $this->logger->debug('Calendar user type is room or resource, not processing further'); |
|
| 203 | + return; |
|
| 204 | + } |
|
| 205 | + |
|
| 206 | + $attendee = $this->getCurrentAttendee($iTipMessage); |
|
| 207 | + if (!$attendee) { |
|
| 208 | + $this->logger->debug('No attendee set for scheduling message'); |
|
| 209 | + return; |
|
| 210 | + } |
|
| 211 | + |
|
| 212 | + // We only respond when a response was actually requested |
|
| 213 | + $rsvp = $this->getAttendeeRSVP($attendee); |
|
| 214 | + if (!$rsvp) { |
|
| 215 | + $this->logger->debug('No RSVP requested for attendee ' . $attendee->getValue()); |
|
| 216 | + return; |
|
| 217 | + } |
|
| 218 | + |
|
| 219 | + if (!$vevent) { |
|
| 220 | + $this->logger->debug('No VEVENT set to process on scheduling message'); |
|
| 221 | + return; |
|
| 222 | + } |
|
| 223 | + |
|
| 224 | + // We don't support autoresponses for recurrencing events for now |
|
| 225 | + if (isset($vevent->RRULE) || isset($vevent->RDATE)) { |
|
| 226 | + $this->logger->debug('VEVENT is a recurring event, autoresponding not supported'); |
|
| 227 | + return; |
|
| 228 | + } |
|
| 229 | + |
|
| 230 | + $dtstart = $vevent->DTSTART; |
|
| 231 | + $dtend = $this->getDTEndFromVEvent($vevent); |
|
| 232 | + $uid = $vevent->UID->getValue(); |
|
| 233 | + $sequence = isset($vevent->SEQUENCE) ? $vevent->SEQUENCE->getValue() : 0; |
|
| 234 | + $recurrenceId = isset($vevent->{'RECURRENCE-ID'}) ? $vevent->{'RECURRENCE-ID'}->serialize() : ''; |
|
| 235 | + |
|
| 236 | + $message = <<<EOF |
|
| 237 | 237 | BEGIN:VCALENDAR |
| 238 | 238 | PRODID:-//Nextcloud/Nextcloud CalDAV Server//EN |
| 239 | 239 | METHOD:REPLY |
@@ -248,386 +248,386 @@ discard block |
||
| 248 | 248 | END:VCALENDAR |
| 249 | 249 | EOF; |
| 250 | 250 | |
| 251 | - if ($this->isAvailableAtTime($attendee->getValue(), $dtstart->getDateTime(), $dtend->getDateTime(), $uid)) { |
|
| 252 | - $partStat = 'ACCEPTED'; |
|
| 253 | - } else { |
|
| 254 | - $partStat = 'DECLINED'; |
|
| 255 | - } |
|
| 256 | - |
|
| 257 | - $vObject = Reader::read(vsprintf($message, [ |
|
| 258 | - $partStat, |
|
| 259 | - $iTipMessage->recipient, |
|
| 260 | - $iTipMessage->sender, |
|
| 261 | - $uid, |
|
| 262 | - $sequence, |
|
| 263 | - $recurrenceId |
|
| 264 | - ])); |
|
| 265 | - |
|
| 266 | - $responseITipMessage = new ITip\Message(); |
|
| 267 | - $responseITipMessage->uid = $uid; |
|
| 268 | - $responseITipMessage->component = 'VEVENT'; |
|
| 269 | - $responseITipMessage->method = 'REPLY'; |
|
| 270 | - $responseITipMessage->sequence = $sequence; |
|
| 271 | - $responseITipMessage->sender = $iTipMessage->recipient; |
|
| 272 | - $responseITipMessage->recipient = $iTipMessage->sender; |
|
| 273 | - $responseITipMessage->message = $vObject; |
|
| 274 | - |
|
| 275 | - // We can't dispatch them now already, because the organizers calendar-object |
|
| 276 | - // was not yet created. Hence Sabre/DAV won't find a calendar-object, when we |
|
| 277 | - // send our reply. |
|
| 278 | - $this->schedulingResponses[] = $responseITipMessage; |
|
| 279 | - } |
|
| 280 | - |
|
| 281 | - /** |
|
| 282 | - * @param string $uri |
|
| 283 | - */ |
|
| 284 | - public function dispatchSchedulingResponses(string $uri):void { |
|
| 285 | - if ($uri !== $this->pathOfCalendarObjectChange) { |
|
| 286 | - return; |
|
| 287 | - } |
|
| 288 | - |
|
| 289 | - foreach ($this->schedulingResponses as $schedulingResponse) { |
|
| 290 | - $this->scheduleLocalDelivery($schedulingResponse); |
|
| 291 | - } |
|
| 292 | - } |
|
| 293 | - |
|
| 294 | - /** |
|
| 295 | - * Always use the personal calendar as target for scheduled events |
|
| 296 | - * |
|
| 297 | - * @param PropFind $propFind |
|
| 298 | - * @param INode $node |
|
| 299 | - * @return void |
|
| 300 | - */ |
|
| 301 | - public function propFindDefaultCalendarUrl(PropFind $propFind, INode $node) { |
|
| 302 | - if ($node instanceof IPrincipal) { |
|
| 303 | - $propFind->handle(self::SCHEDULE_DEFAULT_CALENDAR_URL, function () use ($node) { |
|
| 304 | - /** @var \OCA\DAV\CalDAV\Plugin $caldavPlugin */ |
|
| 305 | - $caldavPlugin = $this->server->getPlugin('caldav'); |
|
| 306 | - $principalUrl = $node->getPrincipalUrl(); |
|
| 307 | - |
|
| 308 | - $calendarHomePath = $caldavPlugin->getCalendarHomeForPrincipal($principalUrl); |
|
| 309 | - if (!$calendarHomePath) { |
|
| 310 | - return null; |
|
| 311 | - } |
|
| 312 | - |
|
| 313 | - $isResourceOrRoom = strpos($principalUrl, 'principals/calendar-resources') === 0 || |
|
| 314 | - strpos($principalUrl, 'principals/calendar-rooms') === 0; |
|
| 315 | - |
|
| 316 | - if (strpos($principalUrl, 'principals/users') === 0) { |
|
| 317 | - [, $userId] = split($principalUrl); |
|
| 318 | - $uri = $this->config->getUserValue($userId, 'dav', 'defaultCalendar', CalDavBackend::PERSONAL_CALENDAR_URI); |
|
| 319 | - $displayName = CalDavBackend::PERSONAL_CALENDAR_NAME; |
|
| 320 | - } elseif ($isResourceOrRoom) { |
|
| 321 | - $uri = CalDavBackend::RESOURCE_BOOKING_CALENDAR_URI; |
|
| 322 | - $displayName = CalDavBackend::RESOURCE_BOOKING_CALENDAR_NAME; |
|
| 323 | - } else { |
|
| 324 | - // How did we end up here? |
|
| 325 | - // TODO - throw exception or just ignore? |
|
| 326 | - return null; |
|
| 327 | - } |
|
| 328 | - |
|
| 329 | - /** @var CalendarHome $calendarHome */ |
|
| 330 | - $calendarHome = $this->server->tree->getNodeForPath($calendarHomePath); |
|
| 331 | - $currentCalendarDeleted = false; |
|
| 332 | - if (!$calendarHome->childExists($uri) || $currentCalendarDeleted = $this->isCalendarDeleted($calendarHome, $uri)) { |
|
| 333 | - // If the default calendar doesn't exist |
|
| 334 | - if ($isResourceOrRoom) { |
|
| 335 | - // Resources or rooms can't be in the trashbin, so we're fine |
|
| 336 | - $this->createCalendar($calendarHome, $principalUrl, $uri, $displayName); |
|
| 337 | - } else { |
|
| 338 | - // And we're not handling scheduling on resource/room booking |
|
| 339 | - $userCalendars = []; |
|
| 340 | - /** |
|
| 341 | - * If the default calendar of the user isn't set and the |
|
| 342 | - * fallback doesn't match any of the user's calendar |
|
| 343 | - * try to find the first "personal" calendar we can write to |
|
| 344 | - * instead of creating a new one. |
|
| 345 | - * A appropriate personal calendar to receive invites: |
|
| 346 | - * - isn't a calendar subscription |
|
| 347 | - * - user can write to it (no virtual/3rd-party calendars) |
|
| 348 | - * - calendar isn't a share |
|
| 349 | - */ |
|
| 350 | - foreach ($calendarHome->getChildren() as $node) { |
|
| 351 | - if ($node instanceof Calendar && !$node->isSubscription() && $node->canWrite() && !$node->isShared() && !$node->isDeleted()) { |
|
| 352 | - $userCalendars[] = $node; |
|
| 353 | - } |
|
| 354 | - } |
|
| 355 | - |
|
| 356 | - if (count($userCalendars) > 0) { |
|
| 357 | - // Calendar backend returns calendar by calendarorder property |
|
| 358 | - $uri = $userCalendars[0]->getName(); |
|
| 359 | - } else { |
|
| 360 | - // Otherwise if we have really nothing, create a new calendar |
|
| 361 | - if ($currentCalendarDeleted) { |
|
| 362 | - // If the calendar exists but is deleted, we need to purge it first |
|
| 363 | - // This may cause some issues in a non synchronous database setup |
|
| 364 | - $calendar = $this->getCalendar($calendarHome, $uri); |
|
| 365 | - if ($calendar instanceof Calendar) { |
|
| 366 | - $calendar->disableTrashbin(); |
|
| 367 | - $calendar->delete(); |
|
| 368 | - } |
|
| 369 | - } |
|
| 370 | - $this->createCalendar($calendarHome, $principalUrl, $uri, $displayName); |
|
| 371 | - } |
|
| 372 | - } |
|
| 373 | - } |
|
| 374 | - |
|
| 375 | - $result = $this->server->getPropertiesForPath($calendarHomePath . '/' . $uri, [], 1); |
|
| 376 | - if (empty($result)) { |
|
| 377 | - return null; |
|
| 378 | - } |
|
| 379 | - |
|
| 380 | - return new LocalHref($result[0]['href']); |
|
| 381 | - }); |
|
| 382 | - } |
|
| 383 | - } |
|
| 384 | - |
|
| 385 | - /** |
|
| 386 | - * Returns a list of addresses that are associated with a principal. |
|
| 387 | - * |
|
| 388 | - * @param string $principal |
|
| 389 | - * @return string|null |
|
| 390 | - */ |
|
| 391 | - protected function getCalendarUserTypeForPrincipal($principal):?string { |
|
| 392 | - $calendarUserType = '{' . self::NS_CALDAV . '}calendar-user-type'; |
|
| 393 | - $properties = $this->server->getProperties( |
|
| 394 | - $principal, |
|
| 395 | - [$calendarUserType] |
|
| 396 | - ); |
|
| 397 | - |
|
| 398 | - // If we can't find this information, we'll stop processing |
|
| 399 | - if (!isset($properties[$calendarUserType])) { |
|
| 400 | - return null; |
|
| 401 | - } |
|
| 402 | - |
|
| 403 | - return $properties[$calendarUserType]; |
|
| 404 | - } |
|
| 405 | - |
|
| 406 | - /** |
|
| 407 | - * @param ITip\Message $iTipMessage |
|
| 408 | - * @return null|Property |
|
| 409 | - */ |
|
| 410 | - private function getCurrentAttendee(ITip\Message $iTipMessage):?Property { |
|
| 411 | - /** @var VEvent $vevent */ |
|
| 412 | - $vevent = $iTipMessage->message->VEVENT; |
|
| 413 | - $attendees = $vevent->select('ATTENDEE'); |
|
| 414 | - foreach ($attendees as $attendee) { |
|
| 415 | - /** @var Property $attendee */ |
|
| 416 | - if (strcasecmp($attendee->getValue(), $iTipMessage->recipient) === 0) { |
|
| 417 | - return $attendee; |
|
| 418 | - } |
|
| 419 | - } |
|
| 420 | - return null; |
|
| 421 | - } |
|
| 422 | - |
|
| 423 | - /** |
|
| 424 | - * @param Property|null $attendee |
|
| 425 | - * @return bool |
|
| 426 | - */ |
|
| 427 | - private function getAttendeeRSVP(Property $attendee = null):bool { |
|
| 428 | - if ($attendee !== null) { |
|
| 429 | - $rsvp = $attendee->offsetGet('RSVP'); |
|
| 430 | - if (($rsvp instanceof Parameter) && (strcasecmp($rsvp->getValue(), 'TRUE') === 0)) { |
|
| 431 | - return true; |
|
| 432 | - } |
|
| 433 | - } |
|
| 434 | - // RFC 5545 3.2.17: default RSVP is false |
|
| 435 | - return false; |
|
| 436 | - } |
|
| 437 | - |
|
| 438 | - /** |
|
| 439 | - * @param VEvent $vevent |
|
| 440 | - * @return Property\ICalendar\DateTime |
|
| 441 | - */ |
|
| 442 | - private function getDTEndFromVEvent(VEvent $vevent):Property\ICalendar\DateTime { |
|
| 443 | - if (isset($vevent->DTEND)) { |
|
| 444 | - return $vevent->DTEND; |
|
| 445 | - } |
|
| 446 | - |
|
| 447 | - if (isset($vevent->DURATION)) { |
|
| 448 | - $isFloating = $vevent->DTSTART->isFloating(); |
|
| 449 | - /** @var Property\ICalendar\DateTime $end */ |
|
| 450 | - $end = clone $vevent->DTSTART; |
|
| 451 | - $endDateTime = $end->getDateTime(); |
|
| 452 | - $endDateTime = $endDateTime->add(DateTimeParser::parse($vevent->DURATION->getValue())); |
|
| 453 | - $end->setDateTime($endDateTime, $isFloating); |
|
| 454 | - return $end; |
|
| 455 | - } |
|
| 456 | - |
|
| 457 | - if (!$vevent->DTSTART->hasTime()) { |
|
| 458 | - $isFloating = $vevent->DTSTART->isFloating(); |
|
| 459 | - /** @var Property\ICalendar\DateTime $end */ |
|
| 460 | - $end = clone $vevent->DTSTART; |
|
| 461 | - $endDateTime = $end->getDateTime(); |
|
| 462 | - $endDateTime = $endDateTime->modify('+1 day'); |
|
| 463 | - $end->setDateTime($endDateTime, $isFloating); |
|
| 464 | - return $end; |
|
| 465 | - } |
|
| 466 | - |
|
| 467 | - return clone $vevent->DTSTART; |
|
| 468 | - } |
|
| 469 | - |
|
| 470 | - /** |
|
| 471 | - * @param string $email |
|
| 472 | - * @param \DateTimeInterface $start |
|
| 473 | - * @param \DateTimeInterface $end |
|
| 474 | - * @param string $ignoreUID |
|
| 475 | - * @return bool |
|
| 476 | - */ |
|
| 477 | - private function isAvailableAtTime(string $email, \DateTimeInterface $start, \DateTimeInterface $end, string $ignoreUID):bool { |
|
| 478 | - // This method is heavily inspired by Sabre\CalDAV\Schedule\Plugin::scheduleLocalDelivery |
|
| 479 | - // and Sabre\CalDAV\Schedule\Plugin::getFreeBusyForEmail |
|
| 480 | - |
|
| 481 | - $aclPlugin = $this->server->getPlugin('acl'); |
|
| 482 | - $this->server->removeListener('propFind', [$aclPlugin, 'propFind']); |
|
| 483 | - |
|
| 484 | - $result = $aclPlugin->principalSearch( |
|
| 485 | - ['{http://sabredav.org/ns}email-address' => $this->stripOffMailTo($email)], |
|
| 486 | - [ |
|
| 487 | - '{DAV:}principal-URL', |
|
| 488 | - '{' . self::NS_CALDAV . '}calendar-home-set', |
|
| 489 | - '{' . self::NS_CALDAV . '}schedule-inbox-URL', |
|
| 490 | - '{http://sabredav.org/ns}email-address', |
|
| 491 | - |
|
| 492 | - ] |
|
| 493 | - ); |
|
| 494 | - $this->server->on('propFind', [$aclPlugin, 'propFind'], 20); |
|
| 495 | - |
|
| 496 | - |
|
| 497 | - // Grabbing the calendar list |
|
| 498 | - $objects = []; |
|
| 499 | - $calendarTimeZone = new DateTimeZone('UTC'); |
|
| 500 | - |
|
| 501 | - $homePath = $result[0][200]['{' . self::NS_CALDAV . '}calendar-home-set']->getHref(); |
|
| 502 | - foreach ($this->server->tree->getNodeForPath($homePath)->getChildren() as $node) { |
|
| 503 | - if (!$node instanceof ICalendar) { |
|
| 504 | - continue; |
|
| 505 | - } |
|
| 506 | - |
|
| 507 | - // Getting the list of object uris within the time-range |
|
| 508 | - $urls = $node->calendarQuery([ |
|
| 509 | - 'name' => 'VCALENDAR', |
|
| 510 | - 'comp-filters' => [ |
|
| 511 | - [ |
|
| 512 | - 'name' => 'VEVENT', |
|
| 513 | - 'is-not-defined' => false, |
|
| 514 | - 'time-range' => [ |
|
| 515 | - 'start' => $start, |
|
| 516 | - 'end' => $end, |
|
| 517 | - ], |
|
| 518 | - 'comp-filters' => [], |
|
| 519 | - 'prop-filters' => [], |
|
| 520 | - ], |
|
| 521 | - [ |
|
| 522 | - 'name' => 'VEVENT', |
|
| 523 | - 'is-not-defined' => false, |
|
| 524 | - 'time-range' => null, |
|
| 525 | - 'comp-filters' => [], |
|
| 526 | - 'prop-filters' => [ |
|
| 527 | - [ |
|
| 528 | - 'name' => 'UID', |
|
| 529 | - 'is-not-defined' => false, |
|
| 530 | - 'time-range' => null, |
|
| 531 | - 'text-match' => [ |
|
| 532 | - 'value' => $ignoreUID, |
|
| 533 | - 'negate-condition' => true, |
|
| 534 | - 'collation' => 'i;octet', |
|
| 535 | - ], |
|
| 536 | - 'param-filters' => [], |
|
| 537 | - ], |
|
| 538 | - ] |
|
| 539 | - ], |
|
| 540 | - ], |
|
| 541 | - 'prop-filters' => [], |
|
| 542 | - 'is-not-defined' => false, |
|
| 543 | - 'time-range' => null, |
|
| 544 | - ]); |
|
| 545 | - |
|
| 546 | - foreach ($urls as $url) { |
|
| 547 | - $objects[] = $node->getChild($url)->get(); |
|
| 548 | - } |
|
| 549 | - } |
|
| 550 | - |
|
| 551 | - $inboxProps = $this->server->getProperties( |
|
| 552 | - $result[0][200]['{' . self::NS_CALDAV . '}schedule-inbox-URL']->getHref(), |
|
| 553 | - ['{' . self::NS_CALDAV . '}calendar-availability'] |
|
| 554 | - ); |
|
| 555 | - |
|
| 556 | - $vcalendar = new VCalendar(); |
|
| 557 | - $vcalendar->METHOD = 'REPLY'; |
|
| 558 | - |
|
| 559 | - $generator = new FreeBusyGenerator(); |
|
| 560 | - $generator->setObjects($objects); |
|
| 561 | - $generator->setTimeRange($start, $end); |
|
| 562 | - $generator->setBaseObject($vcalendar); |
|
| 563 | - $generator->setTimeZone($calendarTimeZone); |
|
| 564 | - |
|
| 565 | - if (isset($inboxProps['{' . self::NS_CALDAV . '}calendar-availability'])) { |
|
| 566 | - $generator->setVAvailability( |
|
| 567 | - Reader::read( |
|
| 568 | - $inboxProps['{' . self::NS_CALDAV . '}calendar-availability'] |
|
| 569 | - ) |
|
| 570 | - ); |
|
| 571 | - } |
|
| 572 | - |
|
| 573 | - $result = $generator->getResult(); |
|
| 574 | - if (!isset($result->VFREEBUSY)) { |
|
| 575 | - return false; |
|
| 576 | - } |
|
| 577 | - |
|
| 578 | - /** @var Component $freeBusyComponent */ |
|
| 579 | - $freeBusyComponent = $result->VFREEBUSY; |
|
| 580 | - $freeBusyProperties = $freeBusyComponent->select('FREEBUSY'); |
|
| 581 | - // If there is no Free-busy property at all, the time-range is empty and available |
|
| 582 | - if (count($freeBusyProperties) === 0) { |
|
| 583 | - return true; |
|
| 584 | - } |
|
| 585 | - |
|
| 586 | - // If more than one Free-Busy property was returned, it means that an event |
|
| 587 | - // starts or ends inside this time-range, so it's not available and we return false |
|
| 588 | - if (count($freeBusyProperties) > 1) { |
|
| 589 | - return false; |
|
| 590 | - } |
|
| 591 | - |
|
| 592 | - /** @var Property $freeBusyProperty */ |
|
| 593 | - $freeBusyProperty = $freeBusyProperties[0]; |
|
| 594 | - if (!$freeBusyProperty->offsetExists('FBTYPE')) { |
|
| 595 | - // If there is no FBTYPE, it means it's busy |
|
| 596 | - return false; |
|
| 597 | - } |
|
| 598 | - |
|
| 599 | - $fbTypeParameter = $freeBusyProperty->offsetGet('FBTYPE'); |
|
| 600 | - if (!($fbTypeParameter instanceof Parameter)) { |
|
| 601 | - return false; |
|
| 602 | - } |
|
| 603 | - |
|
| 604 | - return (strcasecmp($fbTypeParameter->getValue(), 'FREE') === 0); |
|
| 605 | - } |
|
| 606 | - |
|
| 607 | - /** |
|
| 608 | - * @param string $email |
|
| 609 | - * @return string |
|
| 610 | - */ |
|
| 611 | - private function stripOffMailTo(string $email): string { |
|
| 612 | - if (stripos($email, 'mailto:') === 0) { |
|
| 613 | - return substr($email, 7); |
|
| 614 | - } |
|
| 615 | - |
|
| 616 | - return $email; |
|
| 617 | - } |
|
| 618 | - |
|
| 619 | - private function getCalendar(CalendarHome $calendarHome, string $uri): INode { |
|
| 620 | - return $calendarHome->getChild($uri); |
|
| 621 | - } |
|
| 622 | - |
|
| 623 | - private function isCalendarDeleted(CalendarHome $calendarHome, string $uri): bool { |
|
| 624 | - $calendar = $this->getCalendar($calendarHome, $uri); |
|
| 625 | - return $calendar instanceof Calendar && $calendar->isDeleted(); |
|
| 626 | - } |
|
| 627 | - |
|
| 628 | - private function createCalendar(CalendarHome $calendarHome, string $principalUri, string $uri, string $displayName): void { |
|
| 629 | - $calendarHome->getCalDAVBackend()->createCalendar($principalUri, $uri, [ |
|
| 630 | - '{DAV:}displayname' => $displayName, |
|
| 631 | - ]); |
|
| 632 | - } |
|
| 251 | + if ($this->isAvailableAtTime($attendee->getValue(), $dtstart->getDateTime(), $dtend->getDateTime(), $uid)) { |
|
| 252 | + $partStat = 'ACCEPTED'; |
|
| 253 | + } else { |
|
| 254 | + $partStat = 'DECLINED'; |
|
| 255 | + } |
|
| 256 | + |
|
| 257 | + $vObject = Reader::read(vsprintf($message, [ |
|
| 258 | + $partStat, |
|
| 259 | + $iTipMessage->recipient, |
|
| 260 | + $iTipMessage->sender, |
|
| 261 | + $uid, |
|
| 262 | + $sequence, |
|
| 263 | + $recurrenceId |
|
| 264 | + ])); |
|
| 265 | + |
|
| 266 | + $responseITipMessage = new ITip\Message(); |
|
| 267 | + $responseITipMessage->uid = $uid; |
|
| 268 | + $responseITipMessage->component = 'VEVENT'; |
|
| 269 | + $responseITipMessage->method = 'REPLY'; |
|
| 270 | + $responseITipMessage->sequence = $sequence; |
|
| 271 | + $responseITipMessage->sender = $iTipMessage->recipient; |
|
| 272 | + $responseITipMessage->recipient = $iTipMessage->sender; |
|
| 273 | + $responseITipMessage->message = $vObject; |
|
| 274 | + |
|
| 275 | + // We can't dispatch them now already, because the organizers calendar-object |
|
| 276 | + // was not yet created. Hence Sabre/DAV won't find a calendar-object, when we |
|
| 277 | + // send our reply. |
|
| 278 | + $this->schedulingResponses[] = $responseITipMessage; |
|
| 279 | + } |
|
| 280 | + |
|
| 281 | + /** |
|
| 282 | + * @param string $uri |
|
| 283 | + */ |
|
| 284 | + public function dispatchSchedulingResponses(string $uri):void { |
|
| 285 | + if ($uri !== $this->pathOfCalendarObjectChange) { |
|
| 286 | + return; |
|
| 287 | + } |
|
| 288 | + |
|
| 289 | + foreach ($this->schedulingResponses as $schedulingResponse) { |
|
| 290 | + $this->scheduleLocalDelivery($schedulingResponse); |
|
| 291 | + } |
|
| 292 | + } |
|
| 293 | + |
|
| 294 | + /** |
|
| 295 | + * Always use the personal calendar as target for scheduled events |
|
| 296 | + * |
|
| 297 | + * @param PropFind $propFind |
|
| 298 | + * @param INode $node |
|
| 299 | + * @return void |
|
| 300 | + */ |
|
| 301 | + public function propFindDefaultCalendarUrl(PropFind $propFind, INode $node) { |
|
| 302 | + if ($node instanceof IPrincipal) { |
|
| 303 | + $propFind->handle(self::SCHEDULE_DEFAULT_CALENDAR_URL, function () use ($node) { |
|
| 304 | + /** @var \OCA\DAV\CalDAV\Plugin $caldavPlugin */ |
|
| 305 | + $caldavPlugin = $this->server->getPlugin('caldav'); |
|
| 306 | + $principalUrl = $node->getPrincipalUrl(); |
|
| 307 | + |
|
| 308 | + $calendarHomePath = $caldavPlugin->getCalendarHomeForPrincipal($principalUrl); |
|
| 309 | + if (!$calendarHomePath) { |
|
| 310 | + return null; |
|
| 311 | + } |
|
| 312 | + |
|
| 313 | + $isResourceOrRoom = strpos($principalUrl, 'principals/calendar-resources') === 0 || |
|
| 314 | + strpos($principalUrl, 'principals/calendar-rooms') === 0; |
|
| 315 | + |
|
| 316 | + if (strpos($principalUrl, 'principals/users') === 0) { |
|
| 317 | + [, $userId] = split($principalUrl); |
|
| 318 | + $uri = $this->config->getUserValue($userId, 'dav', 'defaultCalendar', CalDavBackend::PERSONAL_CALENDAR_URI); |
|
| 319 | + $displayName = CalDavBackend::PERSONAL_CALENDAR_NAME; |
|
| 320 | + } elseif ($isResourceOrRoom) { |
|
| 321 | + $uri = CalDavBackend::RESOURCE_BOOKING_CALENDAR_URI; |
|
| 322 | + $displayName = CalDavBackend::RESOURCE_BOOKING_CALENDAR_NAME; |
|
| 323 | + } else { |
|
| 324 | + // How did we end up here? |
|
| 325 | + // TODO - throw exception or just ignore? |
|
| 326 | + return null; |
|
| 327 | + } |
|
| 328 | + |
|
| 329 | + /** @var CalendarHome $calendarHome */ |
|
| 330 | + $calendarHome = $this->server->tree->getNodeForPath($calendarHomePath); |
|
| 331 | + $currentCalendarDeleted = false; |
|
| 332 | + if (!$calendarHome->childExists($uri) || $currentCalendarDeleted = $this->isCalendarDeleted($calendarHome, $uri)) { |
|
| 333 | + // If the default calendar doesn't exist |
|
| 334 | + if ($isResourceOrRoom) { |
|
| 335 | + // Resources or rooms can't be in the trashbin, so we're fine |
|
| 336 | + $this->createCalendar($calendarHome, $principalUrl, $uri, $displayName); |
|
| 337 | + } else { |
|
| 338 | + // And we're not handling scheduling on resource/room booking |
|
| 339 | + $userCalendars = []; |
|
| 340 | + /** |
|
| 341 | + * If the default calendar of the user isn't set and the |
|
| 342 | + * fallback doesn't match any of the user's calendar |
|
| 343 | + * try to find the first "personal" calendar we can write to |
|
| 344 | + * instead of creating a new one. |
|
| 345 | + * A appropriate personal calendar to receive invites: |
|
| 346 | + * - isn't a calendar subscription |
|
| 347 | + * - user can write to it (no virtual/3rd-party calendars) |
|
| 348 | + * - calendar isn't a share |
|
| 349 | + */ |
|
| 350 | + foreach ($calendarHome->getChildren() as $node) { |
|
| 351 | + if ($node instanceof Calendar && !$node->isSubscription() && $node->canWrite() && !$node->isShared() && !$node->isDeleted()) { |
|
| 352 | + $userCalendars[] = $node; |
|
| 353 | + } |
|
| 354 | + } |
|
| 355 | + |
|
| 356 | + if (count($userCalendars) > 0) { |
|
| 357 | + // Calendar backend returns calendar by calendarorder property |
|
| 358 | + $uri = $userCalendars[0]->getName(); |
|
| 359 | + } else { |
|
| 360 | + // Otherwise if we have really nothing, create a new calendar |
|
| 361 | + if ($currentCalendarDeleted) { |
|
| 362 | + // If the calendar exists but is deleted, we need to purge it first |
|
| 363 | + // This may cause some issues in a non synchronous database setup |
|
| 364 | + $calendar = $this->getCalendar($calendarHome, $uri); |
|
| 365 | + if ($calendar instanceof Calendar) { |
|
| 366 | + $calendar->disableTrashbin(); |
|
| 367 | + $calendar->delete(); |
|
| 368 | + } |
|
| 369 | + } |
|
| 370 | + $this->createCalendar($calendarHome, $principalUrl, $uri, $displayName); |
|
| 371 | + } |
|
| 372 | + } |
|
| 373 | + } |
|
| 374 | + |
|
| 375 | + $result = $this->server->getPropertiesForPath($calendarHomePath . '/' . $uri, [], 1); |
|
| 376 | + if (empty($result)) { |
|
| 377 | + return null; |
|
| 378 | + } |
|
| 379 | + |
|
| 380 | + return new LocalHref($result[0]['href']); |
|
| 381 | + }); |
|
| 382 | + } |
|
| 383 | + } |
|
| 384 | + |
|
| 385 | + /** |
|
| 386 | + * Returns a list of addresses that are associated with a principal. |
|
| 387 | + * |
|
| 388 | + * @param string $principal |
|
| 389 | + * @return string|null |
|
| 390 | + */ |
|
| 391 | + protected function getCalendarUserTypeForPrincipal($principal):?string { |
|
| 392 | + $calendarUserType = '{' . self::NS_CALDAV . '}calendar-user-type'; |
|
| 393 | + $properties = $this->server->getProperties( |
|
| 394 | + $principal, |
|
| 395 | + [$calendarUserType] |
|
| 396 | + ); |
|
| 397 | + |
|
| 398 | + // If we can't find this information, we'll stop processing |
|
| 399 | + if (!isset($properties[$calendarUserType])) { |
|
| 400 | + return null; |
|
| 401 | + } |
|
| 402 | + |
|
| 403 | + return $properties[$calendarUserType]; |
|
| 404 | + } |
|
| 405 | + |
|
| 406 | + /** |
|
| 407 | + * @param ITip\Message $iTipMessage |
|
| 408 | + * @return null|Property |
|
| 409 | + */ |
|
| 410 | + private function getCurrentAttendee(ITip\Message $iTipMessage):?Property { |
|
| 411 | + /** @var VEvent $vevent */ |
|
| 412 | + $vevent = $iTipMessage->message->VEVENT; |
|
| 413 | + $attendees = $vevent->select('ATTENDEE'); |
|
| 414 | + foreach ($attendees as $attendee) { |
|
| 415 | + /** @var Property $attendee */ |
|
| 416 | + if (strcasecmp($attendee->getValue(), $iTipMessage->recipient) === 0) { |
|
| 417 | + return $attendee; |
|
| 418 | + } |
|
| 419 | + } |
|
| 420 | + return null; |
|
| 421 | + } |
|
| 422 | + |
|
| 423 | + /** |
|
| 424 | + * @param Property|null $attendee |
|
| 425 | + * @return bool |
|
| 426 | + */ |
|
| 427 | + private function getAttendeeRSVP(Property $attendee = null):bool { |
|
| 428 | + if ($attendee !== null) { |
|
| 429 | + $rsvp = $attendee->offsetGet('RSVP'); |
|
| 430 | + if (($rsvp instanceof Parameter) && (strcasecmp($rsvp->getValue(), 'TRUE') === 0)) { |
|
| 431 | + return true; |
|
| 432 | + } |
|
| 433 | + } |
|
| 434 | + // RFC 5545 3.2.17: default RSVP is false |
|
| 435 | + return false; |
|
| 436 | + } |
|
| 437 | + |
|
| 438 | + /** |
|
| 439 | + * @param VEvent $vevent |
|
| 440 | + * @return Property\ICalendar\DateTime |
|
| 441 | + */ |
|
| 442 | + private function getDTEndFromVEvent(VEvent $vevent):Property\ICalendar\DateTime { |
|
| 443 | + if (isset($vevent->DTEND)) { |
|
| 444 | + return $vevent->DTEND; |
|
| 445 | + } |
|
| 446 | + |
|
| 447 | + if (isset($vevent->DURATION)) { |
|
| 448 | + $isFloating = $vevent->DTSTART->isFloating(); |
|
| 449 | + /** @var Property\ICalendar\DateTime $end */ |
|
| 450 | + $end = clone $vevent->DTSTART; |
|
| 451 | + $endDateTime = $end->getDateTime(); |
|
| 452 | + $endDateTime = $endDateTime->add(DateTimeParser::parse($vevent->DURATION->getValue())); |
|
| 453 | + $end->setDateTime($endDateTime, $isFloating); |
|
| 454 | + return $end; |
|
| 455 | + } |
|
| 456 | + |
|
| 457 | + if (!$vevent->DTSTART->hasTime()) { |
|
| 458 | + $isFloating = $vevent->DTSTART->isFloating(); |
|
| 459 | + /** @var Property\ICalendar\DateTime $end */ |
|
| 460 | + $end = clone $vevent->DTSTART; |
|
| 461 | + $endDateTime = $end->getDateTime(); |
|
| 462 | + $endDateTime = $endDateTime->modify('+1 day'); |
|
| 463 | + $end->setDateTime($endDateTime, $isFloating); |
|
| 464 | + return $end; |
|
| 465 | + } |
|
| 466 | + |
|
| 467 | + return clone $vevent->DTSTART; |
|
| 468 | + } |
|
| 469 | + |
|
| 470 | + /** |
|
| 471 | + * @param string $email |
|
| 472 | + * @param \DateTimeInterface $start |
|
| 473 | + * @param \DateTimeInterface $end |
|
| 474 | + * @param string $ignoreUID |
|
| 475 | + * @return bool |
|
| 476 | + */ |
|
| 477 | + private function isAvailableAtTime(string $email, \DateTimeInterface $start, \DateTimeInterface $end, string $ignoreUID):bool { |
|
| 478 | + // This method is heavily inspired by Sabre\CalDAV\Schedule\Plugin::scheduleLocalDelivery |
|
| 479 | + // and Sabre\CalDAV\Schedule\Plugin::getFreeBusyForEmail |
|
| 480 | + |
|
| 481 | + $aclPlugin = $this->server->getPlugin('acl'); |
|
| 482 | + $this->server->removeListener('propFind', [$aclPlugin, 'propFind']); |
|
| 483 | + |
|
| 484 | + $result = $aclPlugin->principalSearch( |
|
| 485 | + ['{http://sabredav.org/ns}email-address' => $this->stripOffMailTo($email)], |
|
| 486 | + [ |
|
| 487 | + '{DAV:}principal-URL', |
|
| 488 | + '{' . self::NS_CALDAV . '}calendar-home-set', |
|
| 489 | + '{' . self::NS_CALDAV . '}schedule-inbox-URL', |
|
| 490 | + '{http://sabredav.org/ns}email-address', |
|
| 491 | + |
|
| 492 | + ] |
|
| 493 | + ); |
|
| 494 | + $this->server->on('propFind', [$aclPlugin, 'propFind'], 20); |
|
| 495 | + |
|
| 496 | + |
|
| 497 | + // Grabbing the calendar list |
|
| 498 | + $objects = []; |
|
| 499 | + $calendarTimeZone = new DateTimeZone('UTC'); |
|
| 500 | + |
|
| 501 | + $homePath = $result[0][200]['{' . self::NS_CALDAV . '}calendar-home-set']->getHref(); |
|
| 502 | + foreach ($this->server->tree->getNodeForPath($homePath)->getChildren() as $node) { |
|
| 503 | + if (!$node instanceof ICalendar) { |
|
| 504 | + continue; |
|
| 505 | + } |
|
| 506 | + |
|
| 507 | + // Getting the list of object uris within the time-range |
|
| 508 | + $urls = $node->calendarQuery([ |
|
| 509 | + 'name' => 'VCALENDAR', |
|
| 510 | + 'comp-filters' => [ |
|
| 511 | + [ |
|
| 512 | + 'name' => 'VEVENT', |
|
| 513 | + 'is-not-defined' => false, |
|
| 514 | + 'time-range' => [ |
|
| 515 | + 'start' => $start, |
|
| 516 | + 'end' => $end, |
|
| 517 | + ], |
|
| 518 | + 'comp-filters' => [], |
|
| 519 | + 'prop-filters' => [], |
|
| 520 | + ], |
|
| 521 | + [ |
|
| 522 | + 'name' => 'VEVENT', |
|
| 523 | + 'is-not-defined' => false, |
|
| 524 | + 'time-range' => null, |
|
| 525 | + 'comp-filters' => [], |
|
| 526 | + 'prop-filters' => [ |
|
| 527 | + [ |
|
| 528 | + 'name' => 'UID', |
|
| 529 | + 'is-not-defined' => false, |
|
| 530 | + 'time-range' => null, |
|
| 531 | + 'text-match' => [ |
|
| 532 | + 'value' => $ignoreUID, |
|
| 533 | + 'negate-condition' => true, |
|
| 534 | + 'collation' => 'i;octet', |
|
| 535 | + ], |
|
| 536 | + 'param-filters' => [], |
|
| 537 | + ], |
|
| 538 | + ] |
|
| 539 | + ], |
|
| 540 | + ], |
|
| 541 | + 'prop-filters' => [], |
|
| 542 | + 'is-not-defined' => false, |
|
| 543 | + 'time-range' => null, |
|
| 544 | + ]); |
|
| 545 | + |
|
| 546 | + foreach ($urls as $url) { |
|
| 547 | + $objects[] = $node->getChild($url)->get(); |
|
| 548 | + } |
|
| 549 | + } |
|
| 550 | + |
|
| 551 | + $inboxProps = $this->server->getProperties( |
|
| 552 | + $result[0][200]['{' . self::NS_CALDAV . '}schedule-inbox-URL']->getHref(), |
|
| 553 | + ['{' . self::NS_CALDAV . '}calendar-availability'] |
|
| 554 | + ); |
|
| 555 | + |
|
| 556 | + $vcalendar = new VCalendar(); |
|
| 557 | + $vcalendar->METHOD = 'REPLY'; |
|
| 558 | + |
|
| 559 | + $generator = new FreeBusyGenerator(); |
|
| 560 | + $generator->setObjects($objects); |
|
| 561 | + $generator->setTimeRange($start, $end); |
|
| 562 | + $generator->setBaseObject($vcalendar); |
|
| 563 | + $generator->setTimeZone($calendarTimeZone); |
|
| 564 | + |
|
| 565 | + if (isset($inboxProps['{' . self::NS_CALDAV . '}calendar-availability'])) { |
|
| 566 | + $generator->setVAvailability( |
|
| 567 | + Reader::read( |
|
| 568 | + $inboxProps['{' . self::NS_CALDAV . '}calendar-availability'] |
|
| 569 | + ) |
|
| 570 | + ); |
|
| 571 | + } |
|
| 572 | + |
|
| 573 | + $result = $generator->getResult(); |
|
| 574 | + if (!isset($result->VFREEBUSY)) { |
|
| 575 | + return false; |
|
| 576 | + } |
|
| 577 | + |
|
| 578 | + /** @var Component $freeBusyComponent */ |
|
| 579 | + $freeBusyComponent = $result->VFREEBUSY; |
|
| 580 | + $freeBusyProperties = $freeBusyComponent->select('FREEBUSY'); |
|
| 581 | + // If there is no Free-busy property at all, the time-range is empty and available |
|
| 582 | + if (count($freeBusyProperties) === 0) { |
|
| 583 | + return true; |
|
| 584 | + } |
|
| 585 | + |
|
| 586 | + // If more than one Free-Busy property was returned, it means that an event |
|
| 587 | + // starts or ends inside this time-range, so it's not available and we return false |
|
| 588 | + if (count($freeBusyProperties) > 1) { |
|
| 589 | + return false; |
|
| 590 | + } |
|
| 591 | + |
|
| 592 | + /** @var Property $freeBusyProperty */ |
|
| 593 | + $freeBusyProperty = $freeBusyProperties[0]; |
|
| 594 | + if (!$freeBusyProperty->offsetExists('FBTYPE')) { |
|
| 595 | + // If there is no FBTYPE, it means it's busy |
|
| 596 | + return false; |
|
| 597 | + } |
|
| 598 | + |
|
| 599 | + $fbTypeParameter = $freeBusyProperty->offsetGet('FBTYPE'); |
|
| 600 | + if (!($fbTypeParameter instanceof Parameter)) { |
|
| 601 | + return false; |
|
| 602 | + } |
|
| 603 | + |
|
| 604 | + return (strcasecmp($fbTypeParameter->getValue(), 'FREE') === 0); |
|
| 605 | + } |
|
| 606 | + |
|
| 607 | + /** |
|
| 608 | + * @param string $email |
|
| 609 | + * @return string |
|
| 610 | + */ |
|
| 611 | + private function stripOffMailTo(string $email): string { |
|
| 612 | + if (stripos($email, 'mailto:') === 0) { |
|
| 613 | + return substr($email, 7); |
|
| 614 | + } |
|
| 615 | + |
|
| 616 | + return $email; |
|
| 617 | + } |
|
| 618 | + |
|
| 619 | + private function getCalendar(CalendarHome $calendarHome, string $uri): INode { |
|
| 620 | + return $calendarHome->getChild($uri); |
|
| 621 | + } |
|
| 622 | + |
|
| 623 | + private function isCalendarDeleted(CalendarHome $calendarHome, string $uri): bool { |
|
| 624 | + $calendar = $this->getCalendar($calendarHome, $uri); |
|
| 625 | + return $calendar instanceof Calendar && $calendar->isDeleted(); |
|
| 626 | + } |
|
| 627 | + |
|
| 628 | + private function createCalendar(CalendarHome $calendarHome, string $principalUri, string $uri, string $displayName): void { |
|
| 629 | + $calendarHome->getCalDAVBackend()->createCalendar($principalUri, $uri, [ |
|
| 630 | + '{DAV:}displayname' => $displayName, |
|
| 631 | + ]); |
|
| 632 | + } |
|
| 633 | 633 | } |