nextcloud/apps/calendar/lib/repeat.php

<?php
/**
 * Copyright (c) 2012 Georg Ehrke <ownclouddev@georgswebsite.de>
 * This file is licensed under the Affero General Public License version 3 or
 * later.
 * See the COPYING-README file.
 */
/*
 * This class manages the caching of repeating events
 * Events will be cached for the current year ± 5 years
 */
class OC_Calendar_Repeat{
	/*
	 * @brief returns the cache of an event
	 * @param (int) $id - id of the event
	 * @return (array) 
	 */
	public static function get($id){
		$stmt = OCP\DB::prepare('SELECT * FROM *PREFIX*calendar_repeat WHERE eventid = ?');
		$result = $stmt->execute(array($id));
		$return = array();
		while($row = $result->fetchRow()){
			$return[] = $row;
		}
		return $return;
	}
	/*
	 * @brief returns the cache of an event in a specific peroid
	 * @param (int) $id - id of the event
	 * @param (DateTime) $from - start for period in UTC
	 * @param (DateTime) $until - end for period in UTC
	 * @return (array)
	 */
	public static function get_inperiod($id, $from, $until){
		$stmt = OCP\DB::prepare( 'SELECT * FROM *PREFIX*calendar_repeat WHERE eventid = ?'
		.' AND ((startdate >= ? AND startdate <= ?)'
		.' OR (enddate >= ? AND enddate <= ?))');
		$result = $stmt->execute(array($id,
					OC_Calendar_Object::getUTCforMDB($from), OC_Calendar_Object::getUTCforMDB($until),
					OC_Calendar_Object::getUTCforMDB($from), OC_Calendar_Object::getUTCforMDB($until)));
		$return = array();
		while($row = $result->fetchRow()){
			$return[] = $row;
		}
		return $return;
	}
	/*
	 * @brief returns the cache of all repeating events of a calendar
	 * @param (int) $id - id of the calendar
	 * @return (array) 
	 */
	public static function getCalendar($id){
		$stmt = OCP\DB::prepare('SELECT * FROM *PREFIX*calendar_repeat WHERE calid = ?');
		$result = $stmt->execute(array($id));
		$return = array();
		while($row = $result->fetchRow()){
			$return[] = $row;
		}
		return $return;
	}
	/*
	 * @brief returns the cache of all repeating events of a calendar in a specific period
	 * @param (int) $id - id of the event
	 * @param (string) $from - start for period in UTC
	 * @param (string) $until - end for period in UTC
	 * @return (array)
	 */
	public static function getCalendar_inperiod($id, $from, $until){
		$stmt = OCP\DB::prepare( 'SELECT * FROM *PREFIX*calendar_repeat WHERE calid = ?'
		.' AND ((startdate >= ? AND startdate <= ?)'
		.' OR (enddate >= ? AND enddate <= ?))');
		$result = $stmt->execute(array($id,
					$from, $until,
					$from, $until));
		$return = array();
		while($row = $result->fetchRow()){
			$return[] = $row;
		}
		return $return;
	}
	/*
	 * @brief generates the cache the first time
	 * @param (int) id - id of the event
	 * @return (bool)
	 */
	public static function generate($id){
		$event = OC_Calendar_Object::find($id);
		if($event['repeating'] == 0){
			return false;
		}
		$object = OC_VObject::parse($event['calendardata']);
		$start = new DateTime('01-01-' . date('Y') . ' 00:00:00', new DateTimeZone('UTC'));
		$start->modify('-5 years');
		$end = new DateTime('31-12-' . date('Y') . ' 23:59:59', new DateTimeZone('UTC'));
		$end->modify('+5 years');
		$object->expand($start, $end);
		foreach($object->getComponents() as $vevent){
			if(get_class($vevent) != 'Sabre_VObject_Component_VEvent'){
				continue;
			}
			$dtstart = $vevent->DTSTART;
			$start_dt = $dtstart->getDateTime();
			$dtend = OC_Calendar_Object::getDTEndFromVEvent($vevent);
			$end_dt = $dtend->getDateTime();
			if ($dtstart->getDateType() == Sabre_VObject_Element_DateTime::DATE){
				$startdate = $start_dt->format('Y-m-d');
				$end_dt->modify('-1 sec');
				$enddate = $end_dt->format('Y-m-d');
			}else{
				$start_dt->setTimezone(new DateTimeZone('UTC'));
				$end_dt->setTimezone(new DateTimeZone('UTC'));
				$startdate = $start_dt->format('Y-m-d H:i:s');
				$enddate = $end_dt->format('Y-m-d H:i:s');
			}
			$stmt = OCP\DB::prepare('INSERT INTO *PREFIX*calendar_repeat (eventid,calid,startdate,enddate) VALUES(?,?,?,?)');
			$stmt->execute(array($id,OC_Calendar_Object::getCalendarid($id),$startdate,$enddate));
		}
		return true;
	}
	/*
	 * @brief generates the cache the first time for all repeating event of an calendar
	 * @param (int) id - id of the calendar
	 * @return (bool)
	 */
	public static function generateCalendar($id){
		$allobjects = OC_Calendar_Object::all($id);
		foreach($allobjects['id'] as $eventid){
			self::generate($eventid);
		}
		return true;
	}
	/*
	 * @brief updates an event that is already cached
	 * @param (int) id - id of the event
	 * @return (bool)
	 */
	public static function update($id){
		self::clean($id);
		self::generate($id);
		return true;
	}
	/*
	 * @brief updates all repating events of a calendar that are already cached
	 * @param (int) id - id of the calendar
	 * @return (bool)
	 */
	public static function updateCalendar($id){
		self::cleanCalendar($id);
		self::generateCalendar($id);
		return true;
	}
	/*
	 * @brief checks if an event is already cached
	 * @param (int) id - id of the event
	 * @return (bool)
	 */
	public static function is_cached($id){
		if(count(self::get($id)) != 0){
			return true;
		}else{
			return false;
		}
	}
	/*
	 * @brief checks if an event is already cached in a specific period
	 * @param (int) id - id of the event
	 * @param (DateTime) $from - start for period in UTC
	 * @param (DateTime) $until - end for period in UTC
	 * @return (bool)
	 */
	public static function is_cached_inperiod($id, $start, $end){
		if(count(self::get_inperiod($id, $start, $end)) != 0){
			return true;
		}else{
			return false;
		}

	}
	/*
	 * @brief checks if a whole calendar is already cached
	 * @param (int) id - id of the calendar
	 * @return (bool)
	 */
	public static function is_calendar_cached($id){
		$cachedevents = count(self::getCalendar($id));
		$repeatingevents = 0;
		$allevents = OC_Calendar_Object::all($id);
		foreach($allevents as $event){
			if($event['repeating'] === 1){
				$repeatingevents++;
			}
		}
		if($cachedevents < $repeatingevents){
			return false;
		}else{
			return true;
		}
	}
	/*
	 * @brief removes the cache of an event
	 * @param (int) id - id of the event
	 * @return (bool)
	 */
	public static function clean($id){
		$stmt = OCP\DB::prepare('DELETE FROM *PREFIX*calendar_repeat WHERE eventid = ?');
		$stmt->execute(array($id));
	}
	/*
	 * @brief removes the cache of all events of a calendar
	 * @param (int) id - id of the calendar
	 * @return (bool)
	 */
	public static function cleanCalendar($id){
		$stmt = OCP\DB::prepare('DELETE FROM *PREFIX*calendar_repeat WHERE calid = ?');
		$stmt->execute(array($id));
	}
}