123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204 |
- <?php
- declare(strict_types=1);
- namespace OCA\DAV\Controller;
- use OCA\DAV\CalDAV\InvitationResponse\InvitationResponseServer;
- use OCP\AppFramework\Controller;
- use OCP\AppFramework\Http\Attribute\NoCSRFRequired;
- use OCP\AppFramework\Http\Attribute\OpenAPI;
- use OCP\AppFramework\Http\Attribute\PublicPage;
- use OCP\AppFramework\Http\TemplateResponse;
- use OCP\AppFramework\Utility\ITimeFactory;
- use OCP\IDBConnection;
- use OCP\IRequest;
- use Sabre\VObject\ITip\Message;
- use Sabre\VObject\Reader;
- class InvitationResponseController extends Controller {
-
- public function __construct(
- string $appName,
- IRequest $request,
- private IDBConnection $db,
- private ITimeFactory $timeFactory,
- private InvitationResponseServer $responseServer,
- ) {
- parent::__construct($appName, $request);
-
-
-
- }
-
-
-
- public function accept(string $token):TemplateResponse {
- $row = $this->getTokenInformation($token);
- if (!$row) {
- return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest');
- }
- $iTipMessage = $this->buildITipResponse($row, 'ACCEPTED');
- $this->responseServer->handleITipMessage($iTipMessage);
- if ($iTipMessage->getScheduleStatus() === '1.2') {
- return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest');
- }
- return new TemplateResponse($this->appName, 'schedule-response-error', [
- 'organizer' => $row['organizer'],
- ], 'guest');
- }
-
-
-
- public function decline(string $token):TemplateResponse {
- $row = $this->getTokenInformation($token);
- if (!$row) {
- return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest');
- }
- $iTipMessage = $this->buildITipResponse($row, 'DECLINED');
- $this->responseServer->handleITipMessage($iTipMessage);
- if ($iTipMessage->getScheduleStatus() === '1.2') {
- return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest');
- }
- return new TemplateResponse($this->appName, 'schedule-response-error', [
- 'organizer' => $row['organizer'],
- ], 'guest');
- }
-
-
-
- public function options(string $token):TemplateResponse {
- return new TemplateResponse($this->appName, 'schedule-response-options', [
- 'token' => $token
- ], 'guest');
- }
-
-
-
- public function processMoreOptionsResult(string $token):TemplateResponse {
- $partstat = $this->request->getParam('partStat');
- $row = $this->getTokenInformation($token);
- if (!$row || !\in_array($partstat, ['ACCEPTED', 'DECLINED', 'TENTATIVE'])) {
- return new TemplateResponse($this->appName, 'schedule-response-error', [], 'guest');
- }
- $iTipMessage = $this->buildITipResponse($row, $partstat);
- $this->responseServer->handleITipMessage($iTipMessage);
- if ($iTipMessage->getScheduleStatus() === '1.2') {
- return new TemplateResponse($this->appName, 'schedule-response-success', [], 'guest');
- }
- return new TemplateResponse($this->appName, 'schedule-response-error', [
- 'organizer' => $row['organizer'],
- ], 'guest');
- }
-
- private function getTokenInformation(string $token) {
- $query = $this->db->getQueryBuilder();
- $query->select('*')
- ->from('calendar_invitations')
- ->where($query->expr()->eq('token', $query->createNamedParameter($token)));
- $stmt = $query->executeQuery();
- $row = $stmt->fetch(\PDO::FETCH_ASSOC);
- $stmt->closeCursor();
- if (!$row) {
- return null;
- }
- $currentTime = $this->timeFactory->getTime();
- if (((int)$row['expiration']) < $currentTime) {
- return null;
- }
- return $row;
- }
-
- private function buildITipResponse(array $row, string $partStat):Message {
- $iTipMessage = new Message();
- $iTipMessage->uid = $row['uid'];
- $iTipMessage->component = 'VEVENT';
- $iTipMessage->method = 'REPLY';
- $iTipMessage->sequence = $row['sequence'];
- $iTipMessage->sender = $row['attendee'];
- if ($this->responseServer->isExternalAttendee($row['attendee'])) {
- $iTipMessage->recipient = $row['organizer'];
- } else {
- $iTipMessage->recipient = $row['attendee'];
- }
- $message = <<<EOF
- BEGIN:VCALENDAR
- PRODID:-//Nextcloud/Nextcloud CalDAV Server//EN
- METHOD:REPLY
- VERSION:2.0
- BEGIN:VEVENT
- ATTENDEE;PARTSTAT=%s:%s
- ORGANIZER:%s
- UID:%s
- SEQUENCE:%s
- REQUEST-STATUS:2.0;Success
- %sEND:VEVENT
- END:VCALENDAR
- EOF;
- $vObject = Reader::read(vsprintf($message, [
- $partStat, $row['attendee'], $row['organizer'],
- $row['uid'], $row['sequence'] ?? 0, $row['recurrenceid'] ?? ''
- ]));
- $vEvent = $vObject->{'VEVENT'};
- $vEvent->DTSTAMP = date('Ymd\\THis\\Z', $this->timeFactory->getTime());
- $iTipMessage->message = $vObject;
- return $iTipMessage;
- }
- }
|