Backend.php

<?php

declare(strict_types=1);

/**
 * SPDX-FileCopyrightText: 2019-2026 Nextcloud GmbH and Nextcloud contributors
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */
namespace OCA\DAV\CalDAV\Reminder;

use OCP\AppFramework\Utility\ITimeFactory;
use OCP\IDBConnection;

class Backend {
	public function __construct(
		protected IDBConnection $db,
		protected ITimeFactory $timeFactory,
	) {
	}

	/**
	 * Get all reminders with a notification date before now,
	 * excluding objects that have been moved to the trashbin.
	 */
	public function getRemindersToProcess(): array {
		$query = $this->db->getQueryBuilder();

		$columns = [
			'cr.id',
			'cr.calendar_id',
			'cr.object_id',
			'cr.is_recurring',
			'cr.uid',
			'cr.recurrence_id',
			'cr.is_recurrence_exception',
			'cr.event_hash',
			'cr.alarm_hash',
			'cr.type',
			'cr.is_relative',
			'cr.notification_date',
			'cr.is_repeat_based',
			'co.calendardata',
			'c.displayname',
			'c.principaluri',
		];

		$query->select($columns)
			->from('calendar_reminders', 'cr')
			->where($query->expr()->lte(
				'cr.notification_date',
				$query->createNamedParameter($this->timeFactory->getTime())
			))
			->join('cr', 'calendarobjects', 'co', $query->expr()->andX(
				$query->expr()->eq('cr.object_id', 'co.id'),
				$query->expr()->isNull('co.deleted_at')
			))
			->join('cr', 'calendars', 'c', $query->expr()->eq('cr.calendar_id', 'c.id'));

		$stmt = $query->executeQuery();
		$rows = $stmt->fetchAllAssociative();
		$stmt->closeCursor();

		return array_map([$this, 'fixRowTyping'], $rows);
	}

	/**
	 * Get all scheduled reminders for an event.
	 */
	public function getAllScheduledRemindersForEvent(int $objectId): array {
		$query = $this->db->getQueryBuilder();
		$query->select('*')
			->from('calendar_reminders')
			->where($query->expr()->eq('object_id', $query->createNamedParameter($objectId)));

		$stmt = $query->executeQuery();
		$rows = $stmt->fetchAllAssociative();
		$stmt->closeCursor();

		return array_map([$this, 'fixRowTyping'], $rows);
	}

	/**
	 * Insert a new reminder into the database.
	 *
	 * @return int The insert id
	 */
	public function insertReminder(
		int $calendarId,
		int $objectId,
		string $uid,
		bool $isRecurring,
		int $recurrenceId,
		bool $isRecurrenceException,
		string $eventHash,
		string $alarmHash,
		string $type,
		bool $isRelative,
		int $notificationDate,
		bool $isRepeatBased,
	): int {
		$query = $this->db->getQueryBuilder();
		$query->insert('calendar_reminders')
			->values([
				'calendar_id' => $query->createNamedParameter($calendarId),
				'object_id' => $query->createNamedParameter($objectId),
				'uid' => $query->createNamedParameter($uid),
				'is_recurring' => $query->createNamedParameter($isRecurring ? 1 : 0),
				'recurrence_id' => $query->createNamedParameter($recurrenceId),
				'is_recurrence_exception' => $query->createNamedParameter($isRecurrenceException ? 1 : 0),
				'event_hash' => $query->createNamedParameter($eventHash),
				'alarm_hash' => $query->createNamedParameter($alarmHash),
				'type' => $query->createNamedParameter($type),
				'is_relative' => $query->createNamedParameter($isRelative ? 1 : 0),
				'notification_date' => $query->createNamedParameter($notificationDate),
				'is_repeat_based' => $query->createNamedParameter($isRepeatBased ? 1 : 0),
			])
			->executeStatement();

		return $query->getLastInsertId();
	}

	/**
	 * Set a new notification date on an existing reminder.
	 */
	public function updateReminder(
		int $reminderId,
		int $newNotificationDate
	): void {
		$query = $this->db->getQueryBuilder();
		$query->update('calendar_reminders')
			->set('notification_date', $query->createNamedParameter($newNotificationDate))
			->where($query->expr()->eq('id', $query->createNamedParameter($reminderId)))
			->executeStatement();
	}

	/**
	 * Remove a reminder by its id.
	 */
	public function removeReminder(int $reminderId): void {
		$query = $this->db->getQueryBuilder();

		$query->delete('calendar_reminders')
			->where($query->expr()->eq('id', $query->createNamedParameter($reminderId)))
			->executeStatement();
	}

	/**
	 * Remove all reminders for a calendar object.
	 */
	public function cleanRemindersForEvent(int $objectId): void {
		$query = $this->db->getQueryBuilder();

		$query->delete('calendar_reminders')
			->where($query->expr()->eq('object_id', $query->createNamedParameter($objectId)))
			->executeStatement();
	}

	/**
	 * Remove all reminders for a calendar.
	 */
	public function cleanRemindersForCalendar(int $calendarId): void {
		$query = $this->db->getQueryBuilder();

		$query->delete('calendar_reminders')
			->where($query->expr()->eq('calendar_id', $query->createNamedParameter($calendarId)))
			->executeStatement();
	}

	private function fixRowTyping(array $row): array {
		$row['id'] = (int)$row['id'];
		$row['calendar_id'] = (int)$row['calendar_id'];
		$row['object_id'] = (int)$row['object_id'];
		$row['is_recurring'] = (bool)$row['is_recurring'];
		$row['recurrence_id'] = (int)$row['recurrence_id'];
		$row['is_recurrence_exception'] = (bool)$row['is_recurrence_exception'];
		$row['is_relative'] = (bool)$row['is_relative'];
		$row['notification_date'] = (int)$row['notification_date'];
		$row['is_repeat_based'] = (bool)$row['is_repeat_based'];

		return $row;
	}
}