nextcloud / server

apps/files_reminders/lib/Dav/PropFindPlugin.php

Indentation +47 added lines, -47 removed lines

@@ -23,60 +23,60 @@
 
 class PropFindPlugin extends ServerPlugin {
 
-	public const REMINDER_DUE_DATE_PROPERTY = '{http://nextcloud.org/ns}reminder-due-date';
+    public const REMINDER_DUE_DATE_PROPERTY = '{http://nextcloud.org/ns}reminder-due-date';
 
-	public function __construct(
-		private ReminderService $reminderService,
-		private IUserSession $userSession,
-	) {
-	}
+    public function __construct(
+        private ReminderService $reminderService,
+        private IUserSession $userSession,
+    ) {
+    }
 
-	public function initialize(Server $server): void {
-		$server->on('propFind', [$this, 'propFind']);
-	}
+    public function initialize(Server $server): void {
+        $server->on('propFind', [$this, 'propFind']);
+    }
 
-	public function propFind(PropFind $propFind, INode $node) {
-		if (!in_array(static::REMINDER_DUE_DATE_PROPERTY, $propFind->getRequestedProperties())) {
-			return;
-		}
+    public function propFind(PropFind $propFind, INode $node) {
+        if (!in_array(static::REMINDER_DUE_DATE_PROPERTY, $propFind->getRequestedProperties())) {
+            return;
+        }
 
-		if (!($node instanceof Node)) {
-			return;
-		}
+        if (!($node instanceof Node)) {
+            return;
+        }
 
-		if (
-			$node instanceof Directory
-			&& $propFind->getDepth() > 0
-			&& $propFind->getStatus(static::REMINDER_DUE_DATE_PROPERTY) !== null
-		) {
-			$folder = $node->getNode();
-			$this->cacheFolder($folder);
-		}
+        if (
+            $node instanceof Directory
+            && $propFind->getDepth() > 0
+            && $propFind->getStatus(static::REMINDER_DUE_DATE_PROPERTY) !== null
+        ) {
+            $folder = $node->getNode();
+            $this->cacheFolder($folder);
+        }
 
-		$propFind->handle(
-			static::REMINDER_DUE_DATE_PROPERTY,
-			function () use ($node) {
-				$user = $this->userSession->getUser();
-				if (!($user instanceof IUser)) {
-					return '';
-				}
+        $propFind->handle(
+            static::REMINDER_DUE_DATE_PROPERTY,
+            function () use ($node) {
+                $user = $this->userSession->getUser();
+                if (!($user instanceof IUser)) {
+                    return '';
+                }
 
-				$fileId = $node->getId();
-				$reminder = $this->reminderService->getDueForUser($user, $fileId, false);
-				if ($reminder === null) {
-					return '';
-				}
+                $fileId = $node->getId();
+                $reminder = $this->reminderService->getDueForUser($user, $fileId, false);
+                if ($reminder === null) {
+                    return '';
+                }
 
-				return $reminder->getDueDate()->format(DateTimeInterface::ATOM); // ISO 8601
-			},
-		);
-	}
+                return $reminder->getDueDate()->format(DateTimeInterface::ATOM); // ISO 8601
+            },
+        );
+    }
 
-	private function cacheFolder(Folder $folder): void {
-		$user = $this->userSession->getUser();
-		if (!($user instanceof IUser)) {
-			return;
-		}
-		$this->reminderService->cacheFolder($user, $folder);
-	}
+    private function cacheFolder(Folder $folder): void {
+        $user = $this->userSession->getUser();
+        if (!($user instanceof IUser)) {
+            return;
+        }
+        $this->reminderService->cacheFolder($user, $folder);
+    }
 }

apps/files_reminders/lib/Service/ReminderService.php

Indentation +181 added lines, -181 removed lines

@@ -33,185 +33,185 @@
 
 class ReminderService {
 
-	private ICache $cache;
-
-	public function __construct(
-		protected IUserManager $userManager,
-		protected IURLGenerator $urlGenerator,
-		protected INotificationManager $notificationManager,
-		protected ReminderMapper $reminderMapper,
-		protected IRootFolder $root,
-		protected LoggerInterface $logger,
-		protected ICacheFactory $cacheFactory,
-	) {
-		$this->cache = $this->cacheFactory->createInMemory();
-	}
-
-	public function cacheFolder(IUser $user, Folder $folder): void {
-		$reminders = $this->reminderMapper->findAllInFolder($user, $folder);
-		$reminderMap = [];
-		foreach ($reminders as $reminder) {
-			$reminderMap[$reminder->getFileId()] = $reminder;
-		}
-
-		$nodes = $folder->getDirectoryListing();
-		foreach ($nodes as $node) {
-			$reminder = $reminderMap[$node->getId()] ?? false;
-			$this->cache->set("{$user->getUID()}-{$node->getId()}", $reminder);
-		}
-	}
-
-	/**
-	 * @throws NodeNotFoundException
-	 */
-	public function getDueForUser(IUser $user, int $fileId, bool $checkNode = true): ?RichReminder {
-		if ($checkNode) {
-			$this->checkNode($user, $fileId);
-		}
-		/** @var null|false|Reminder $cachedReminder */
-		$cachedReminder = $this->cache->get("{$user->getUID()}-$fileId");
-		if ($cachedReminder === false) {
-			return null;
-		}
-		if ($cachedReminder instanceof Reminder) {
-			return new RichReminder($cachedReminder, $this->root);
-		}
-
-		try {
-			$reminder = $this->reminderMapper->findDueForUser($user, $fileId);
-			$this->cache->set("{$user->getUID()}-$fileId", $reminder);
-			return new RichReminder($reminder, $this->root);
-		} catch (DoesNotExistException $e) {
-			$this->cache->set("{$user->getUID()}-$fileId", false);
-			return null;
-		}
-	}
-
-	/**
-	 * @return RichReminder[]
-	 */
-	public function getAll(?IUser $user = null) {
-		$reminders = ($user !== null)
-			? $this->reminderMapper->findAllForUser($user)
-			: $this->reminderMapper->findAll();
-		return array_map(
-			fn (Reminder $reminder) => new RichReminder($reminder, $this->root),
-			$reminders,
-		);
-	}
-
-	/**
-	 * @return bool true if created, false if updated
-	 *
-	 * @throws NodeNotFoundException
-	 */
-	public function createOrUpdate(IUser $user, int $fileId, DateTime $dueDate): bool {
-		$now = new DateTime('now', new DateTimeZone('UTC'));
-		$this->checkNode($user, $fileId);
-		$reminder = $this->getDueForUser($user, $fileId);
-		if ($reminder === null) {
-			$reminder = new Reminder();
-			$reminder->setUserId($user->getUID());
-			$reminder->setFileId($fileId);
-			$reminder->setDueDate($dueDate);
-			$reminder->setUpdatedAt($now);
-			$reminder->setCreatedAt($now);
-			$this->reminderMapper->insert($reminder);
-			$this->cache->set("{$user->getUID()}-$fileId", $reminder);
-			return true;
-		}
-		$reminder->setDueDate($dueDate);
-		$reminder->setUpdatedAt($now);
-		$this->reminderMapper->update($reminder);
-		$this->cache->set("{$user->getUID()}-$fileId", $reminder);
-		return false;
-	}
-
-	/**
-	 * @throws NodeNotFoundException
-	 * @throws ReminderNotFoundException
-	 */
-	public function remove(IUser $user, int $fileId): void {
-		$this->checkNode($user, $fileId);
-		$reminder = $this->getDueForUser($user, $fileId);
-		if ($reminder === null) {
-			throw new ReminderNotFoundException();
-		}
-		$this->deleteReminder($reminder);
-	}
-
-	public function removeAllForNode(Node $node): void {
-		$reminders = $this->reminderMapper->findAllForNode($node);
-		foreach ($reminders as $reminder) {
-			$this->deleteReminder($reminder);
-		}
-	}
-
-	public function removeAllForUser(IUser $user): void {
-		$reminders = $this->reminderMapper->findAllForUser($user);
-		foreach ($reminders as $reminder) {
-			$this->deleteReminder($reminder);
-		}
-	}
-
-	/**
-	 * @throws DoesNotExistException
-	 * @throws UserNotFoundException
-	 */
-	public function send(Reminder $reminder): void {
-		if ($reminder->getNotified()) {
-			return;
-		}
-
-		$user = $this->userManager->get($reminder->getUserId());
-		if ($user === null) {
-			throw new UserNotFoundException();
-		}
-
-		$notification = $this->notificationManager->createNotification();
-		$notification
-			->setApp(Application::APP_ID)
-			->setIcon($this->urlGenerator->getAbsoluteURL($this->urlGenerator->imagePath('files', 'folder.svg')))
-			->setUser($user->getUID())
-			->setObject('reminder', (string)$reminder->getId())
-			->setSubject('reminder-due', [
-				'fileId' => $reminder->getFileId(),
-			])
-			->setDateTime($reminder->getDueDate());
-
-		try {
-			$this->notificationManager->notify($notification);
-			$this->reminderMapper->markNotified($reminder);
-			$this->cache->set("{$user->getUID()}-{$reminder->getFileId()}", $reminder);
-		} catch (Throwable $th) {
-			$this->logger->error($th->getMessage(), $th->getTrace());
-		}
-	}
-
-	public function cleanUp(?int $limit = null): void {
-		$buffer = (new DateTime())
-			->setTimezone(new DateTimeZone('UTC'))
-			->modify('-1 day');
-		$reminders = $this->reminderMapper->findNotified($buffer, $limit);
-		foreach ($reminders as $reminder) {
-			$this->deleteReminder($reminder);
-		}
-	}
-
-	private function deleteReminder(Reminder $reminder): void {
-		$this->reminderMapper->delete($reminder);
-		$this->cache->set("{$reminder->getUserId()}-{$reminder->getFileId()}", false);
-	}
-
-
-	/**
-	 * @throws NodeNotFoundException
-	 */
-	private function checkNode(IUser $user, int $fileId): void {
-		$userFolder = $this->root->getUserFolder($user->getUID());
-		$node = $userFolder->getFirstNodeById($fileId);
-		if ($node === null) {
-			throw new NodeNotFoundException();
-		}
-	}
+    private ICache $cache;
+
+    public function __construct(
+        protected IUserManager $userManager,
+        protected IURLGenerator $urlGenerator,
+        protected INotificationManager $notificationManager,
+        protected ReminderMapper $reminderMapper,
+        protected IRootFolder $root,
+        protected LoggerInterface $logger,
+        protected ICacheFactory $cacheFactory,
+    ) {
+        $this->cache = $this->cacheFactory->createInMemory();
+    }
+
+    public function cacheFolder(IUser $user, Folder $folder): void {
+        $reminders = $this->reminderMapper->findAllInFolder($user, $folder);
+        $reminderMap = [];
+        foreach ($reminders as $reminder) {
+            $reminderMap[$reminder->getFileId()] = $reminder;
+        }
+
+        $nodes = $folder->getDirectoryListing();
+        foreach ($nodes as $node) {
+            $reminder = $reminderMap[$node->getId()] ?? false;
+            $this->cache->set("{$user->getUID()}-{$node->getId()}", $reminder);
+        }
+    }
+
+    /**
+     * @throws NodeNotFoundException
+     */
+    public function getDueForUser(IUser $user, int $fileId, bool $checkNode = true): ?RichReminder {
+        if ($checkNode) {
+            $this->checkNode($user, $fileId);
+        }
+        /** @var null|false|Reminder $cachedReminder */
+        $cachedReminder = $this->cache->get("{$user->getUID()}-$fileId");
+        if ($cachedReminder === false) {
+            return null;
+        }
+        if ($cachedReminder instanceof Reminder) {
+            return new RichReminder($cachedReminder, $this->root);
+        }
+
+        try {
+            $reminder = $this->reminderMapper->findDueForUser($user, $fileId);
+            $this->cache->set("{$user->getUID()}-$fileId", $reminder);
+            return new RichReminder($reminder, $this->root);
+        } catch (DoesNotExistException $e) {
+            $this->cache->set("{$user->getUID()}-$fileId", false);
+            return null;
+        }
+    }
+
+    /**
+     * @return RichReminder[]
+     */
+    public function getAll(?IUser $user = null) {
+        $reminders = ($user !== null)
+            ? $this->reminderMapper->findAllForUser($user)
+            : $this->reminderMapper->findAll();
+        return array_map(
+            fn (Reminder $reminder) => new RichReminder($reminder, $this->root),
+            $reminders,
+        );
+    }
+
+    /**
+     * @return bool true if created, false if updated
+     *
+     * @throws NodeNotFoundException
+     */
+    public function createOrUpdate(IUser $user, int $fileId, DateTime $dueDate): bool {
+        $now = new DateTime('now', new DateTimeZone('UTC'));
+        $this->checkNode($user, $fileId);
+        $reminder = $this->getDueForUser($user, $fileId);
+        if ($reminder === null) {
+            $reminder = new Reminder();
+            $reminder->setUserId($user->getUID());
+            $reminder->setFileId($fileId);
+            $reminder->setDueDate($dueDate);
+            $reminder->setUpdatedAt($now);
+            $reminder->setCreatedAt($now);
+            $this->reminderMapper->insert($reminder);
+            $this->cache->set("{$user->getUID()}-$fileId", $reminder);
+            return true;
+        }
+        $reminder->setDueDate($dueDate);
+        $reminder->setUpdatedAt($now);
+        $this->reminderMapper->update($reminder);
+        $this->cache->set("{$user->getUID()}-$fileId", $reminder);
+        return false;
+    }
+
+    /**
+     * @throws NodeNotFoundException
+     * @throws ReminderNotFoundException
+     */
+    public function remove(IUser $user, int $fileId): void {
+        $this->checkNode($user, $fileId);
+        $reminder = $this->getDueForUser($user, $fileId);
+        if ($reminder === null) {
+            throw new ReminderNotFoundException();
+        }
+        $this->deleteReminder($reminder);
+    }
+
+    public function removeAllForNode(Node $node): void {
+        $reminders = $this->reminderMapper->findAllForNode($node);
+        foreach ($reminders as $reminder) {
+            $this->deleteReminder($reminder);
+        }
+    }
+
+    public function removeAllForUser(IUser $user): void {
+        $reminders = $this->reminderMapper->findAllForUser($user);
+        foreach ($reminders as $reminder) {
+            $this->deleteReminder($reminder);
+        }
+    }
+
+    /**
+     * @throws DoesNotExistException
+     * @throws UserNotFoundException
+     */
+    public function send(Reminder $reminder): void {
+        if ($reminder->getNotified()) {
+            return;
+        }
+
+        $user = $this->userManager->get($reminder->getUserId());
+        if ($user === null) {
+            throw new UserNotFoundException();
+        }
+
+        $notification = $this->notificationManager->createNotification();
+        $notification
+            ->setApp(Application::APP_ID)
+            ->setIcon($this->urlGenerator->getAbsoluteURL($this->urlGenerator->imagePath('files', 'folder.svg')))
+            ->setUser($user->getUID())
+            ->setObject('reminder', (string)$reminder->getId())
+            ->setSubject('reminder-due', [
+                'fileId' => $reminder->getFileId(),
+            ])
+            ->setDateTime($reminder->getDueDate());
+
+        try {
+            $this->notificationManager->notify($notification);
+            $this->reminderMapper->markNotified($reminder);
+            $this->cache->set("{$user->getUID()}-{$reminder->getFileId()}", $reminder);
+        } catch (Throwable $th) {
+            $this->logger->error($th->getMessage(), $th->getTrace());
+        }
+    }
+
+    public function cleanUp(?int $limit = null): void {
+        $buffer = (new DateTime())
+            ->setTimezone(new DateTimeZone('UTC'))
+            ->modify('-1 day');
+        $reminders = $this->reminderMapper->findNotified($buffer, $limit);
+        foreach ($reminders as $reminder) {
+            $this->deleteReminder($reminder);
+        }
+    }
+
+    private function deleteReminder(Reminder $reminder): void {
+        $this->reminderMapper->delete($reminder);
+        $this->cache->set("{$reminder->getUserId()}-{$reminder->getFileId()}", false);
+    }
+
+
+    /**
+     * @throws NodeNotFoundException
+     */
+    private function checkNode(IUser $user, int $fileId): void {
+        $userFolder = $this->root->getUserFolder($user->getUID());
+        $node = $userFolder->getFirstNodeById($fileId);
+        if ($node === null) {
+            throw new NodeNotFoundException();
+        }
+    }
 }