Viewing File: /usr/local/cpanel/base/3rdparty/roundcube/plugins/calendar/drivers/caldav/caldav_driver.php
<?php
/**
* plugins/calendar/drivers/caldav/caldav_driver.php
*
* @package default
*/
/**
* CalDAV driver for the Calendar plugin
*
*
* Copyright (C) Awesome IT GbR <info@awesome-it.de>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
* @author Daniel Morlock <daniel.morlock@awesome-it.de>
*/
require_once dirname(__FILE__).'/caldav_sync.php';
require_once dirname(__FILE__).'/../../lib/encryption.php';
class caldav_driver extends calendar_driver
{
const DB_DATE_FORMAT = 'Y-m-d H:i:s';
public static $scheduling_properties = array('start', 'end', 'allday', 'recurrence', 'location', 'cancelled');
// features this backend supports
public $alarms = true;
public $attendees = true;
public $freebusy = false;
public $attachments = true;
public $alarm_types = array('DISPLAY');
private $rc;
private $cal;
private $cache = array();
protected $calendars = array();
private $calendar_ids = '';
private $free_busy_map = array('free' => 0, 'busy' => 1, 'out-of-office' => 2, 'outofoffice' => 2, 'tentative' => 3);
private $sensitivity_map = array('public' => 0, 'private' => 1, 'confidential' => 2);
protected $server_timezone;
private $db_events = 'caldav_events';
private $db_calendars = 'caldav_calendars_merged';
private $db_attachments = 'caldav_attachments';
// Crypt key for CalDAV auth
private $crypt_key;
// Holds CalDAV sync clients
protected $sync_clients = array();
// Min. time period to wait until CalDAV sync check.
private $sync_period = 1; // TODO 0; // seconds
private $_num_events_removed_in_last_sync = 0;
// Indicates debug mode for CalDAV
static private $debug = null;
protected $local_event_gateway;
/**
* Helper method to log debug msg if debug mode is enabled.
*
* @param unknown $msg
*/
static public function debug_log($msg) {
if (self::$debug === true)
rcmail::console(__CLASS__.': '.$msg);
}
/**
* Helper method to log (if debug mode is enabled) and raise an user error.
*
* @param unknown $msg
*/
private function _raise_error($msg) {
self::debug_log($msg);
$this->rc->output->show_message($msg, 'error');
}
/**
* Default constructor
*
* @param unknown $cal
*/
public function __construct($cal) {
$this->cal = $cal;
$this->rc = $cal->rc;
$this->local_event_gateway = new RoundcubeEventGateway($this->rc);
$this->server_timezone = new DateTimeZone(date_default_timezone_get());
// read database config
$db = $this->rc->get_dbh();
$this->db_events = $this->rc->config->get('db_table_caldav_events', $db->table_name($this->db_events));
$this->db_calendars = $this->rc->config->get('db_table_caldav_calendars', $db->table_name($this->db_calendars));
$this->db_attachments = $this->rc->config->get('db_table_caldav_attachments', $db->table_name($this->db_attachments));
$this->crypt_key = $this->rc->config->get("calendar_crypt_key", "%E`c{2;<J2F^4_&._BxfQ<5Pf3qv!m{e");
// Set debug state
if (self::$debug === null)
self::$debug = $this->rc->config->get('calendar_caldav_debug', False);
$this->_read_calendars();
}
/**
* Read available calendars for the current user and store them internally
*/
protected function _read_calendars() {
$hidden = array_filter(explode(',', $this->rc->config->get('hidden_caldav_calendars', '')));
$default_cals = $this->rc->config->get('calendar_preinstalled_calendars', false);
if (!empty($this->rc->user->ID)) {
$calendar_ids = array();
$result = $this->rc->db->query("SELECT *, calendar_id AS id
FROM " . $this->db_calendars . "
WHERE user_id=?
ORDER BY name",
$this->rc->user->ID
);
while ($result && ($arr = $this->rc->db->fetch_assoc($result))) {
$arr['showalarms'] = intval($arr['showalarms']);
$arr['active'] = !in_array($arr['id'], $hidden);
$arr['name'] = html::quote($arr['name']);
$arr['listname'] = html::quote($arr['name']);
$arr['rights'] = 'lrswikxteav';
$arr['readonly'] = intval($arr['readonly']);
$arr['editable'] = true;
$arr['deletable'] = true;
$arr['caldav_pass'] = $this->_decrypt_pass($arr['caldav_pass']);
$this->calendars[$arr['calendar_id']] = $arr;
$calendar_ids[] = $this->rc->db->quote($arr['calendar_id']);
// If it is one of the special "auto-added" default calendars,
// then replace details from DB with ones from config.
foreach( $default_cals as $cal_name => $cal_data ) {
if( empty($cal_data) || !is_array($cal_data) ) continue;
$user = $this->rc->get_user_name();
$local = $this->rc->user->get_username('local');
$domain = $this->rc->user->get_username('domain');
// CCS encodes the at(@) sign in various responses so we need to as well so that various URL
// comparisons match up.
$cal_data['caldav_url'] = str_replace( "@", urlencode("@"), $cal_data['caldav_url']);
$cal_data['caldav_url'] = str_replace( "%u", $user, $cal_data['caldav_url'] );
$cal_data['caldav_url'] = str_replace( "%l", $local, $cal_data['caldav_url'] );
$cal_data['caldav_url'] = str_replace( "%d", $domain, $cal_data['caldav_url'] );
// This is a tricky comparison to do, as urlencoding is involved.
// As such, parse the URL for the path component and the bits before the path.
// URLdecode them to then make a valid comparison.
if( $cal_data['caldav_url'] === urldecode($arr['caldav_url']) || html::quote($cal_data['name']) === $arr['name'] ) {
// Replace the username/password with what is currently uname/pw
$cal_data = $this->_expand_user($cal_data);
$cal_data = $this->_expand_pass($cal_data);
$arr['caldav_user'] = $cal_data['caldav_user'];
$arr['caldav_pass'] = $cal_data['caldav_pass'];
$arr['caldav_url'] = $cal_data['caldav_url'];
}
}
// Init sync client
$cal_id = $arr['calendar_id'];
$this->sync_clients[$cal_id] = new caldav_sync($arr);
}
$this->calendar_ids = join(',', $calendar_ids);
}
}
/**
* Get a list of available calendars from this source
*
*
* @param integer Bitmask defining filter criterias
* @param unknown $filter (optional)
* @return array List of calendars
*/
public function list_calendars($filter = 0) {
$calendars = $this->calendars;
foreach ($calendars as $idx => $cal) {
// filter active calendars
if ($filter & self::FILTER_ACTIVE && !$cal['active']) {
unset($calendars[$idx]);
}
// filter read-only calendars
if ($filter & self::FILTER_WRITEABLE && $cal['readonly']) {
unset($calendars[$idx]);
}
}
// 'personal' is unsupported in this driver
return $calendars;
}
/**
* Extracts CalDAV calendar.
*
* @see database_driver::create_calendar()
* @param unknown $cal
* @return unknown
*/
public function create_calendar($cal) {
$result = false;
$cal['caldav_url'] = self::_encode_url($cal["caldav_url"]);
if (!isset($cal['color'])) $cal['color'] = 'cc0000';
$cal = $this->_expand_pass($cal);
$calendars = $this->_autodiscover_calendars($cal);
$cal_ids = array();
if ($calendars) {
$result = true;
foreach ($calendars as $calendar) {
// Skip already existent calendars
$result = $this->rc->db->query("SELECT * FROM ".$this->db_calendars." WHERE caldav_url LIKE ? AND user_id = ?", $calendar['href'], $this->rc->user->ID);
if ($this->rc->db->affected_rows($result)) {
continue;
}
$cal['caldav_url'] = self::_encode_url($calendar['href']);
// Respect $props['name'] if only a single calendar was found e.g. no auto-discovery.
if (sizeof($calendars) > 1 || !isset($cal['name']) || $cal['name'] == "")
$cal['name'] = $calendar['name'];
if (($obj_id = $this->_db_create_calendar($cal)) !== false) {
array_push($cal_ids, $obj_id);
} else $result = false;
}
}
// Sync newly created calendars
if ($cal_ids) {
// Re-read calendars to internal buffer.
$this->_read_calendars();
// Initial sync of newly created calendars.
foreach ($cal_ids as $cal_id) {
$this->_sync_calendar($cal_id);
}
}
return $result;
}
/**
* Create a new calendar assigned to the current user
*
* name: Calendar name
* color: The color of the calendar
* caldav_url: CalDAV calendar URL
* caldav_tag: CalDAV calendar ctag
* caldav_user: CalDAV authentication user
* caldav_pass: CalDAV authentication password
*
* @param array Hash array with calendar properties
* @param unknown $prop
* @return mixed ID of the calendar on success, False on error
*/
private function _db_create_calendar($prop) {
// Split it into two queries, as MySQL is 2dumb2do writeable views
// when multiple tables are involved. Not really looking to do
// a stored procedure for this stuff either.
$result = $this->rc->db->query(
"INSERT INTO calendars
(user_id, name, color, showalarms, driver)
VALUES ( ?, ?, ?, ?, ? )",
$this->rc->user->ID,
$prop['name'],
$prop['color'],
$prop['showalarms']?1:0,
'caldav',
);
if ($result) {
// Get the ID which was inserted. Since we in fact have all the data
// we need to query this, just do that instead of relying on a known
// unreliable PDO builtin.
$result = $this->rc->db->query("
SELECT calendar_id FROM calendars
WHERE user_id=? ORDER BY calendar_id DESC LIMIT 1",
$this->rc->user->ID,
);
$row = $this->rc->db->fetch_assoc($result);
if(!empty($row)) {
$result = $this->rc->db->query(
"INSERT INTO caldav_calendars
(calendar_id, readonly, caldav_url, caldav_tag, caldav_user, caldav_pass)
VALUES (?, ?, ?, ?, ?, ?)",
$row['calendar_id'],
$prop['readonly'] ?? 0,
$prop['caldav_url'],
isset($prop["caldav_tag"]) && $prop["caldav_tag"] ? $prop["caldav_tag"] : null,
isset($prop["caldav_user"]) && $prop["caldav_user"] ? $prop["caldav_user"] : null,
isset($prop["caldav_pass"]) && $prop["caldav_pass"] ? $this->_encrypt_pass($prop["caldav_pass"]) : null,
);
$error = $this->rc->db->dbh->errorInfo();
if($error[0] == '00000') return $row['calendar_id'];
}
}
return false;
}
/**
* Update properties of an existing calendar
*
* @see calendar_driver::edit_calendar()
* @param unknown $cal
* @return unknown
*/
public function edit_calendar($cal) {
# Has to be two queries because MySQL can't figure out writeable views
$query = $this->rc->db->query("UPDATE " . $this->db_calendars . "
SET name=?, color=?, showalarms=?
WHERE calendar_id=?
AND user_id=?",
$cal['name'],
$cal['color'],
$cal['showalarms']?1:0,
$cal['id'],
$this->rc->user->ID
);
$query = $this->rc->db->query("UPDATE caldav_calendars
SET readonly=?, caldav_url=?, caldav_tag=?, caldav_user=?
WHERE calendar_id=?",
$cal['readonly']?1:0,
$cal['caldav_url'],
isset($cal["caldav_tag"]) && $cal["caldav_tag"] ? $cal["caldav_tag"] : null,
isset($cal["caldav_user"]) && $cal["caldav_user"] ? $cal["caldav_user"] : null,
$cal['id'],
$this->rc->user->ID
);
// Change password if one was passed in
if (!empty($cal["caldav_pass"])) {
$cal = $this->_expand_pass($cal);
$query = $this->rc->db->query("UPDATE caldav_calendars
SET caldav_pass=?
WHERE calendar_id=?",
$this->_encrypt_pass($cal['caldav_pass']),
$cal['id'],
$this->rc->user->ID
);
}
return $this->rc->db->affected_rows($query);
}
/**
* Set active/subscribed state of a calendar
* Save a list of hidden calendars in user prefs
*
* @see calendar_driver::subscribe_calendar()
* @param unknown $prop
* @return unknown
*/
public function subscribe_calendar($prop) {
$hidden = array_flip(explode(',', $this->rc->config->get('hidden_caldav_calendars', '')));
if ($prop['active'])
unset($hidden[$prop['id']]);
else
$hidden[$prop['id']] = 1;
return $this->rc->user->save_prefs(array('hidden_caldav_calendars' => join(',', array_keys($hidden))));
}
/**
* Delete the given calendar with all its contents
*
* @see calendar_driver::delete_calendar()
* @param unknown $prop
* @return unknown
*/
public function delete_calendar($prop) {
if (!$this->calendars[$prop['id']])
return false;
// events and attachments will be deleted by foreign key cascade
$query = $this->rc->db->query(
"DELETE FROM caldav_calendars WHERE calendar_id=?",
$prop['id']
);
$query = $this->rc->db->query(
"DELETE FROM calendars WHERE calendar_id=?",
$prop['id']
);
if ($this->rc->config->get('calendar_default_calendar') == $prop['id'])
$this->rc->user->save_prefs(array('calendar_default_calendar' => null));
# On MySQL this will be 0 even on success, so check error from dbh.
$rows = $this->rc->db->affected_rows($query);
$error = $this->rc->db->dbh->errorInfo();
if ($error[0] != '00000') return 0;
return 1;
}
/**
* Search for shared or otherwise not listed calendars the user has access
*
* @param string Search string
* @param string Section/source to search
* @param unknown $query
* @param unknown $source
* @return array List of calendars
*/
public function search_calendars($query, $source) {
// not implemented
return array();
}
/**
* Add a single event to the database
*
* @see calendar_driver::new_event()
* @param array Hash array with event properties
* @param bool Force read-only calendars to create this event e.g. when syncing remote events.
* @param unknown $event
* @param unknown $force_readonly (optional)
* @return mixed New event ID on success, False on error
*/
public function new_event($event, $force_readonly=false) {
if (!$this->validate($event))
return false;
if (!empty($this->calendars)) {
if ($event['calendar'] && !$this->calendars[$event['calendar']])
return false;
if (!$event['calendar'])
$event['calendar'] = reset(array_keys($this->calendars));
$cal = $this->calendars[$event["calendar"]];
if ($force_readonly || !$cal["readonly"]) {
if ($event = $this->_save_preprocess($event)) {
$sync_client = $this->sync_clients[$event["calendar"]];
// Only push event if caldav_tag is not set to avoid pushing it twice
if (!isset($event["caldav_tag"])) {
$event = $sync_client->create_event($event);
if (!$event)
return null; // Error already handled
}
if ($event_id = $this->_insert_event($event)) {
$this->_update_recurring($event);
return $event_id;
}
}
}
}
return false;
}
/**
*
* @param unknown $event (reference)
* @return unknown
*/
private function _insert_event(&$event) {
$json = json_encode($event['attendees']);
$this->rc->db->query(sprintf(
"INSERT INTO " . $this->db_events . "
(calendar_id, created, changed, uid, recurrence_id, instance, isexception, %s, %s, all_day, recurrence,
title, description, location, categories, url, free_busy, priority, sensitivity, status, attendees, alarms, notifyat,
caldav_url, caldav_tag)
VALUES (?, %s, %s, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
$this->rc->db->quote_identifier('start'),
$this->rc->db->quote_identifier('end'),
$this->rc->db->now(),
$this->rc->db->now()
),
$event['calendar'],
strval($event['uid'] ?? null),
intval($event['recurrence_id'] ?? null),
strval($event['_instance'] ?? null),
intval($event['isexception'] ?? null),
$event['start']->format(self::DB_DATE_FORMAT),
$event['end']->format(self::DB_DATE_FORMAT),
intval($event['all_day'] ?? null),
$event['_recurrence'] ?? null,
strval($event['title'] ?? null),
strval($event['description'] ?? null),
strval($event['location'] ?? null),
( !empty($event['categories']) && is_array($event['categories']) ) ? join(',', $event['categories']) : $event['categories'] ?? 'Personal',
strval($event['url'] ?? null),
intval($event['free_busy'] ?? null),
intval($event['priority'] ?? null),
intval($event['sensitivity'] ?? null),
strval($event['status'] ?? null),
$json,
$event['alarms'] ?? null,
$event['notifyat'] ?? null,
$event['caldav_url'] ?? null,
$event['caldav_tag'] ?? null
);
$event_id = $this->rc->db->insert_id($this->db_events);
if ($event_id) {
$event['id'] = $event_id;
// add attachments
if (!empty($event['attachments'])) {
foreach ($event['attachments'] as $attachment) {
$this->add_attachment($attachment, $event_id);
unset($attachment);
}
}
return $event_id;
}
return false;
}
/**
* Update the event entry with the given data and sync with caldav server.
*
* @see caldav_driver::_db_edit_event()
* @param array Hash array with event properties
* @param array Internal use only, filled with non-modified event if this is second try after a calendar sync was enforced first.
* @param unknown $event
* @param unknown $old_event (optional)
* @return bool
*/
public function edit_event($event, $old_event = null) {
$sync_enforced = ($old_event != null);
$event_id = (int)$event["id"];
$cal_id = $event["calendar"];
$cal = $this->calendars[$cal_id];
if (!$cal["readonly"]) {
if ($old_event == null)
$old_event = $this->get_event($event);
if ($this->_db_edit_event($event)) {
// Re-load updated event and push to caldav.
$event = $this->get_event(array("id" => $event_id));
$sync_client = $this->sync_clients[$cal_id];
$success = $sync_client->update_event($event);
if ($success === true) {
self::debug_log("Successfully updated event \"$event_id\".");
// Trigger calendar sync to update ctags and etags.
$this->_sync_calendar($cal_id);
return true;
} else if ($success < 0 && $sync_enforced == false) {
self::debug_log("Event \"$event_id\", tag \"" . $event["caldav_tag"] . "\" not up to date, will update calendar first ...");
$this->_sync_calendar($cal_id);
return $this->edit_event($event, $old_event); // Re-try after re-sync
} else {
// Undo changes in events, return null (not true) to suppress further dialogs
if ($this->_db_edit_event($old_event))
return null;
}
}
}
return false;
}
/**
* Update an event entry with the given data
*
* @see calendar_driver::edit_event()
* @param array Hash array with event properties
* @param unknown $event
* @return bool
*/
private function _db_edit_event($event) {
if (!empty($this->calendars)) {
$update_master = false;
$update_recurring = true;
$old = $this->get_event($event);
$ret = true;
// check if update affects scheduling and update attendee status accordingly
$reschedule = $this->_check_scheduling($event, $old, true);
// increment sequence number
if (empty($event['sequence']) && $reschedule)
$event['sequence'] = max($event['sequence'], $old['sequence']) + 1;
// modify a recurring event, check submitted savemode to do the right things
if ($old['recurrence'] || $old['recurrence_id']) {
$master = $old['recurrence_id'] ? $this->get_event(array('id' => $old['recurrence_id'])) : $old;
// keep saved exceptions (not submitted by the client)
if (!empty($old['recurrence']['EXDATE']))
$event['recurrence']['EXDATE'] = $old['recurrence']['EXDATE'];
switch ($event['_savemode'] ?? 'all') {
case 'new':
$event['uid'] = $this->cal->generate_uid();
return $this->new_event($event) !== false;
case 'current':
// save as exception
$event['isexception'] = 1;
$update_recurring = false;
// set exception to first instance (= master)
if ($event['id'] == $master['id']) {
$event += $old;
$event['recurrence_id'] = $master['id'];
$event['_instance'] = libcalendaring::recurrence_instance_identifier($old);
$event['isexception'] = 1;
$event_id = $this->_insert_event($event);
return $event_id;
}
break;
case 'future':
if ($master['id'] != $event['id']) {
// set until-date on master event, then save this instance as new recurring event
$master['recurrence']['UNTIL'] = clone $event['start'];
$master['recurrence']['UNTIL']->sub(new DateInterval('P1D'));
unset($master['recurrence']['COUNT']);
$update_master = true;
// if recurrence COUNT, update value to the correct number of future occurences
if ($event['recurrence']['COUNT']) {
$fromdate = clone $event['start'];
$fromdate->setTimezone($this->server_timezone);
$sqlresult = $this->rc->db->query(sprintf(
"SELECT event_id FROM " . $this->db_events . "
WHERE calendar_id IN (%s)
AND %s >= ?
AND recurrence_id=?",
$this->calendar_ids,
$this->rc->db->quote_identifier('start')
),
$fromdate->format(self::DB_DATE_FORMAT),
$master['id']);
if ($count = $this->rc->db->num_rows($sqlresult))
$event['recurrence']['COUNT'] = $count;
}
$update_recurring = true;
$event['recurrence_id'] = 0;
$event['isexception'] = 0;
$event['_instance'] = '';
break;
}
// else: 'future' == 'all' if modifying the master event
default: // 'all' is default
$event['id'] = $master['id'];
$event['recurrence_id'] = 0;
// use start date from master but try to be smart on time or duration changes
$old_start_date = $old['start']->format('Y-m-d');
$old_start_time = $old['allday'] ? '' : $old['start']->format('H:i');
$old_duration = $old['end']->format('U') - $old['start']->format('U');
$new_start_date = $event['start']->format('Y-m-d');
$new_start_time = $event['allday'] ? '' : $event['start']->format('H:i');
$new_duration = $event['end']->format('U') - $event['start']->format('U');
$diff = $old_start_date != $new_start_date || $old_start_time != $new_start_time || $old_duration != $new_duration;
$date_shift = $old['start']->diff($event['start']);
// shifted or resized
if ($diff && ($old_start_date == $new_start_date || $old_duration == $new_duration)) {
$event['start'] = $master['start']->add($old['start']->diff($event['start']));
$event['end'] = clone $event['start'];
$event['end']->add(new DateInterval('PT' . $new_duration . 'S'));
} // dates did not change, use the ones from master
else if ($new_start_date . $new_start_time == $old_start_date . $old_start_time) {
$event['start'] = $master['start'];
$event['end'] = $master['end'];
}
// adjust recurrence-id when start changed and therefore the entire recurrence chain changes
if (is_array($event['recurrence']) && ($old_start_date != $new_start_date || $old_start_time != $new_start_time)
&& ($exceptions = $this->_load_exceptions($old))
) {
$recurrence_id_format = libcalendaring::recurrence_id_format($event);
foreach ($exceptions as $exception) {
$recurrence_id = rcube_utils::anytodatetime($exception['_instance'], $old['start']->getTimezone());
if (is_a($recurrence_id, 'DateTime') || is_a($recurrence_id, 'DateTimeImmutable')) {
$recurrence_id->add($date_shift);
$exception['_instance'] = $recurrence_id->format($recurrence_id_format);
$this->_update_event($exception, false);
}
}
}
$ret = $event['id']; // return master ID
break;
}
}
$success = $this->_update_event($event, $update_recurring);
if ($success && $update_master)
$this->_update_event($master, true);
return $success ? $ret : false;
}
return false;
}
/**
* Extended event editing with possible changes to the argument
*
* @param array Hash array with event properties
* @param string New participant status
* @param array List of hash arrays with updated attendees
* @param unknown $event (reference)
* @param unknown $status
* @param unknown $attendees
* @return boolean True on success, False on error
*/
public function edit_rsvp(&$event, $status, $attendees) {
$update_event = $event;
// apply changes to master (and all exceptions)
if ($event['_savemode'] == 'all' && $event['recurrence_id']) {
$update_event = $this->get_event(array('id' => $event['recurrence_id']));
$update_event['_savemode'] = $event['_savemode'];
calendar::merge_attendee_data($update_event, $attendees);
}
if ($ret = $this->update_attendees($update_event, $attendees)) {
// replace $event with effectively updated event (for iTip reply)
if ($ret !== true && $ret != $update_event['id'] && ($new_event = $this->get_event(array('id' => $ret)))) {
$event = $new_event;
} else {
$event = $update_event;
}
}
return $ret;
}
/**
* Update the participant status for the given attendees
*
* @see calendar_driver::update_attendees()
* @param unknown $event (reference)
* @param unknown $attendees
* @return unknown
*/
public function update_attendees(&$event, $attendees) {
$success = $this->edit_event($event, true);
// apply attendee updates to recurrence exceptions too
if ($success && $event['_savemode'] == 'all' && !empty($event['recurrence']) && empty($event['recurrence_id']) && ($exceptions = $this->_load_exceptions($event))) {
foreach ($exceptions as $exception) {
calendar::merge_attendee_data($exception, $attendees);
$this->_update_event($exception, false);
}
}
return $success;
}
/**
* Determine whether the current change affects scheduling and reset attendee status accordingly
*
* @param unknown $event (reference)
* @param unknown $old
* @param unknown $update (optional)
* @return unknown
*/
private function _check_scheduling(&$event, $old, $update = true) {
// skip this check when importing iCal/iTip events
if (isset($event['sequence']) || !empty($event['_method'])) {
return false;
}
$reschedule = false;
// iterate through the list of properties considered 'significant' for scheduling
foreach (self::$scheduling_properties as $prop) {
$a = $old[$prop];
$b = $event[$prop];
if ($event['allday'] && ($prop == 'start' || $prop == 'end') && ( ( $a instanceof DateTime && $b instanceof DateTime ) || ( $a instanceof DateTimeImmutable && $b instanceof DateTimeImmutable ) ) ) {
$a = $a->format('Y-m-d');
$b = $b->format('Y-m-d');
}
if ($prop == 'recurrence' && is_array($a) && is_array($b)) {
unset($a['EXCEPTIONS'], $b['EXCEPTIONS']);
$a = array_filter($a);
$b = array_filter($b);
// advanced rrule comparison: no rescheduling if series was shortened
if ($a['COUNT'] && $b['COUNT'] && $b['COUNT'] < $a['COUNT']) {
unset($a['COUNT'], $b['COUNT']);
} else if ($a['UNTIL'] && $b['UNTIL'] && $b['UNTIL'] < $a['UNTIL']) {
unset($a['UNTIL'], $b['UNTIL']);
}
}
if ($a != $b) {
$reschedule = true;
break;
}
}
// reset all attendee status to needs-action (#4360)
if ($update && $reschedule && is_array($event['attendees'])) {
$is_organizer = false;
$emails = $this->cal->get_user_emails();
$attendees = $event['attendees'];
foreach ($attendees as $i => $attendee) {
if ($attendee['role'] == 'ORGANIZER' && $attendee['email'] && in_array(strtolower($attendee['email']), $emails)) {
$is_organizer = true;
} else if ($attendee['role'] != 'ORGANIZER' && $attendee['role'] != 'NON-PARTICIPANT' && $attendee['status'] != 'DELEGATED') {
$attendees[$i]['status'] = 'NEEDS-ACTION';
$attendees[$i]['rsvp'] = true;
}
}
// update attendees only if I'm the organizer
if ($is_organizer || ($event['organizer'] && in_array(strtolower($event['organizer']['email']), $emails))) {
$event['attendees'] = $attendees;
}
}
return $reschedule;
}
/**
* Convert save data to be used in SQL statements
*
* @param unknown $event
* @return unknown
*/
private function _save_preprocess($event) {
// shift dates to server's timezone (except for all-day events)
if (!$event['allday']) {
$event['start'] = clone $event['start'];
$event['start']->setTimezone($this->server_timezone);
$event['end'] = clone $event['end'];
$event['end']->setTimezone($this->server_timezone);
}
// compose vcalendar-style recurrencue rule from structured data
$rrule = !empty($event['recurrence']) ? libcalendaring::to_rrule($event['recurrence']) : '';
$event['_recurrence'] = rtrim($rrule, ';');
$event['free_busy'] = intval($this->free_busy_map[strtolower($event['free_busy'])]);
$event['sensitivity'] = intval($this->sensitivity_map[strtolower($event['sensitivity'])]);
if ($event['free_busy'] == 'tentative') {
$event['status'] = 'TENTATIVE';
}
if (isset($event['allday'])) {
$event['all_day'] = $event['allday'] ? 1 : 0;
}
// compute absolute time to notify the user
$event['notifyat'] = $this->_get_notification($event);
if (!empty($event['valarms']) && is_array($event['valarms'])) {
$event['alarms'] = $this->serialize_alarms($event['valarms']);
}
// Ensure event attendees is ARRAY
if (empty($event['attendees']))
$event['attendees'] = [];
return $event;
}
/**
* Compute absolute time to notify the user
*
* @param unknown $event
* @return unknown
*/
private function _get_notification($event) {
if ($event['valarms'] ?? false && $event['start'] > new DateTime()) {
$alarm = libcalendaring::get_next_alarm($event);
if ($alarm['time'] && in_array($alarm['action'], $this->alarm_types))
return date('Y-m-d H:i:s', $alarm['time']);
}
return null;
}
/**
* Save the given event record to database
*
* @param array Event data
* @param boolean True if recurring events instances should be updated, too
* @param unknown $event
* @param unknown $update_recurring (optional)
* @return unknown
*/
protected function _update_event($event, $update_recurring = true) {
$event = $this->_save_preprocess($event);
$sql_set = array();
$set_cols = array('start', 'end', 'all_day', 'recurrence_id', 'isexception', 'sequence', 'title', 'description', 'location', 'categories', 'url', 'free_busy', 'priority', 'sensitivity', 'status', 'attendees', 'alarms', 'notifyat', 'caldav_url', 'caldav_tag');
foreach ($set_cols as $col) {
if (is_object($event[$col]) && ( is_a($event[$col], 'DateTime') || is_a($event[$col], 'DateTimeImmutable' ))) {
$sql_set[] = $this->rc->db->quote_identifier($col) . '=' . $this->rc->db->quote($event[$col]->format(self::DB_DATE_FORMAT));
}
else if (is_array($event[$col]))
$sql_set[] = $this->rc->db->quote_identifier($col) . '=' . $this->rc->db->quote(join(',', $event[$col]));
else if (array_key_exists($col, $event))
$sql_set[] = $this->rc->db->quote_identifier($col) . '=' . $this->rc->db->quote($event[$col]);
}
if ($event['_recurrence'])
$sql_set[] = $this->rc->db->quote_identifier('recurrence') . '=' . $this->rc->db->quote($event['_recurrence']);
if ($event['_instance'] ?? false)
$sql_set[] = $this->rc->db->quote_identifier('instance') . '=' . $this->rc->db->quote($event['_instance']);
if ($event['_fromcalendar'] ?? false && $event['_fromcalendar'] != $event['calendar'])
$sql_set[] = 'calendar_id=' . $this->rc->db->quote($event['calendar']);
$query = $this->rc->db->query(sprintf(
"UPDATE " . $this->db_events . "
SET changed=%s %s
WHERE event_id=?
AND calendar_id IN (" . $this->calendar_ids . ")",
$this->rc->db->now(),
($sql_set ? ', ' . join(', ', $sql_set) : '')
),
$event['id']
);
$success = $this->rc->db->affected_rows($query);
// add attachments
if ($success && !empty($event['attachments'])) {
foreach ($event['attachments'] as $attachment) {
$this->add_attachment($attachment, $event['id']);
unset($attachment);
}
}
// remove attachments
if ($success && !empty($event['deleted_attachments'])) {
foreach ($event['deleted_attachments'] as $attachment) {
$this->remove_attachment($attachment, $event['id']);
}
}
if ($success) {
unset($this->cache[$event['id']]);
if ($update_recurring)
$this->_update_recurring($event);
}
return $success;
}
/**
* Insert "fake" entries for recurring occurences of this event
*
* @param unknown $event
*/
private function _update_recurring($event) {
if (empty($this->calendars))
return;
if (!empty($event['recurrence'])) {
$exdata = array();
$exceptions = $this->_load_exceptions($event);
foreach ($exceptions as $exception) {
$exdate = substr($exception['_instance'], 0, 8);
$exdata[$exdate] = $exception;
}
}
// clear existing recurrence copies
$this->rc->db->query(
"DELETE FROM " . $this->db_events . "
WHERE recurrence_id=?
AND isexception=0
AND calendar_id IN (" . $this->calendar_ids . ")",
$event['id']
);
// create new fake entries
if (!empty($event['recurrence'])) {
// include library class
require_once $this->cal->home . '/lib/calendar_recurrence.php';
$recurrence = new calendar_recurrence($this->cal, $event);
$count = 0;
$event['allday'] = $event['all_day'];
$duration = $event['start']->diff($event['end']);
$recurrence_id_format = libcalendaring::recurrence_id_format($event);
while ($next_start = $recurrence->next_start()) {
$instance = $next_start->format($recurrence_id_format);
$datestr = substr($instance, 0, 8);
// skip exceptions
// TODO: merge updated data from master event
if (!empty($exdata[$datestr])) {
continue;
}
$next_start->setTimezone($this->server_timezone);
$next_end = clone $next_start;
$next_end->add($duration);
$notify_at = $this->_get_notification(array('alarms' => $event['alarms'] ?? null, 'start' => $next_start, 'end' => $next_end, 'status' => $event['status']));
$query = $this->rc->db->query(sprintf(
"INSERT INTO " . $this->db_events . "
(calendar_id, recurrence_id, created, changed, uid, instance, %s, %s, all_day, sequence, recurrence, title, description, location, categories, url, free_busy, priority, sensitivity, status, alarms, attendees, notifyat, caldav_url, caldav_tag)
SELECT calendar_id, ?, %s, %s, uid, ?, ?, ?, all_day, sequence, recurrence, title, description, location, categories, url, free_busy, priority, sensitivity, status, alarms, attendees, ?, caldav_url, caldav_tag
FROM " . $this->db_events . " WHERE event_id=? AND calendar_id IN (" . $this->calendar_ids . ")",
$this->rc->db->quote_identifier('start'),
$this->rc->db->quote_identifier('end'),
$this->rc->db->now(),
$this->rc->db->now()
),
$event['id'],
$instance,
$next_start->format(self::DB_DATE_FORMAT),
$next_end->format(self::DB_DATE_FORMAT),
$notify_at,
$event['id']
);
if (!$this->rc->db->affected_rows($query))
break;
// stop adding events for inifinite recurrence after 20 years
if (++$count >= 999 || (empty($recurrence->recurEnd) && empty($recurrence->recurCount) && $next_start->format('Y') > date('Y') + 20))
break;
}
// remove all exceptions after recurrence end
if ($next_end && !empty($exceptions)) {
$this->rc->db->query(
"DELETE FROM " . $this->db_events . "
WHERE `recurrence_id`=?
AND `isexception`=1
AND `start` > ?
AND `calendar_id` IN (" . $this->calendar_ids . ")",
$event['id'],
$next_end->format(self::DB_DATE_FORMAT)
);
}
}
}
/**
*
* @param unknown $event
* @param unknown $instance_id (optional)
* @return unknown
*/
private function _load_exceptions($event, $instance_id = null) {
$sql_add_where = '';
if (!empty($instance_id)) {
$sql_add_where = 'AND `instance`=?';
}
$result = $this->rc->db->query(
"SELECT * FROM " . $this->db_events . "
WHERE `recurrence_id`=?
AND `isexception`=1
AND `calendar_id` IN (" . $this->calendar_ids . ")
$sql_add_where
ORDER BY `instance`, `start`",
$event['id'],
$instance_id
);
$exceptions = array();
while ($result && ($sql_arr = $this->rc->db->fetch_assoc($result)) && $sql_arr['event_id']) {
$exception = $this->_read_postprocess($sql_arr);
$instance = $exception['_instance'] ?: $exception['start']->format($exception['allday'] ? 'Ymd' : 'Ymd\THis');
$exceptions[$instance] = $exception;
}
return $exceptions;
}
/**
* Move a single event
*
* @see calendar_driver::move_event()
* @param array Hash array with event properties
* @param unknown $event
* @return bool
*/
public function move_event($event) {
// let edit_event() do all the magic
return $this->edit_event($event + (array)$this->get_event($event));
}
/**
* Resize a single event
*
* @see calendar_driver::resize_event()
* @param array Hash array with event properties
* @param unknown $event
* @return bool
*/
public function resize_event($event) {
// let edit_event() do all the magic
return $this->edit_event($event + (array)$this->get_event($event));
}
/**
* Remove a single event from the database and from the CalDAV server.
*
*
* @see calendar_driver::remove_event()
* @param array Hash array with event properties
* @param boolean Remove record irreversible
* @param unknown $event
* @param unknown $force (optional)
* @return bool
*/
public function remove_event($event, $force = true) {
$this->rc->session->remove('calendar_event_undo');
$cal_id = (int)$event["calendar"];
$cal = $this->calendars[$cal_id];
if ($cal["readonly"])
return false;
// the local database is tightly coupled to this whole driver and it has all the logic for recurring events, so
// let's call it first then apply the updated master event to caldav.
list($new_master, $reaped) = $this->_db_remove_event($event);
$this->apply_master_update_to_caldav($new_master, $reaped);
return true;
}
/**
* Remove a single event from the database
*
*
* @param unknown $event
* @return array|bool
* @see calendar_driver::remove_event()
*/
public function _db_remove_event($event) {
if (!empty($this->calendars)) {
$event += (array)$this->get_event($event);
$master = $event;
$savemode = 'all';
// read master if deleting a recurring event
if ($event['recurrence'] || $event['recurrence_id']) {
$master = $event['recurrence_id'] ? $this->get_event(array('id' => $event['recurrence_id'])) : $event;
$savemode = $event['_savemode'];
}
// reap the master unless we figure out this is a sub-event.
$reap_the_master = true;
$is_sub_event = $master['id'] != $event['id'];
switch ($savemode) {
case self::CURRENT:
$reap_the_master = false;
// add exception to master event
$master['recurrence']['EXDATE'][] = $event['start'];
if ($is_sub_event) {
$this->local_event_gateway->delete_event($event);
}
break;
case self::FUTURE:
if ($is_sub_event) {
$reap_the_master = false;
$master['recurrence']['UNTIL'] = (clone $event['start'])->sub(new DateInterval('P1D'));
unset($master['recurrence']['COUNT']);
// delete this and all future instances
$fromdate = (clone $event['start'])->setTimezone($this->server_timezone);
$this->local_event_gateway->delete_after($master, $fromdate);
}
break;
default: // 'all' is default
//empty
break;
}
$master_is_invisible = !$this->is_master_active($master);
$no_sub_events = !$this->local_event_gateway->has_sub_events($master);
$no_affordances = $master_is_invisible && $no_sub_events;
if ($no_affordances) {
$reap_the_master = true;
}
if ($reap_the_master) {
$this->local_event_gateway->delete_event($master);
return [$master, true];
}
$this->_update_event($master, false);
return [$master, false];
}
return [[], false];
}
/**
* Return data of a specific event
*
* @param mixed Hash array with event properties or event UID
* @param integer Bitmask defining the scope to search events in
* @param boolean If true, recurrence exceptions shall be added
* @param unknown $event
* @param unknown $scope (optional)
* @param unknown $full (optional)
* @return array Hash array with event properties
*/
public function get_event($event, $scope = 0, $full = false) {
$id = is_array($event) ? ($event['id'] ?: $event['uid']) : $event;
$cal = is_array($event) ? $event['calendar'] : null;
$col = is_array($event) && is_numeric($id) ? 'event_id' : 'uid';
$where_add = '';
if (is_array($event) && !$event['id'] && !empty($event['_instance'])) {
$where_add = 'AND instance=' . $this->rc->db->quote($event['_instance']);
}
if ( array_key_exists($id, $this->cache) && $this->cache[$id] )
return $this->cache[$id];
if ($scope & self::FILTER_ACTIVE) {
$calendars = $this->calendars;
foreach ($calendars as $idx => $cal) {
if (!$cal['active']) {
unset($calendars[$idx]);
}
}
$cals = join(',', $calendars);
} else {
$cals = $this->calendar_ids;
}
$result = $this->rc->db->query(sprintf(
"SELECT e.*, (SELECT COUNT(attachment_id) FROM " . $this->db_attachments . "
WHERE event_id = e.event_id OR event_id = e.recurrence_id) AS _attachments
FROM " . $this->db_events . " AS e
WHERE e.calendar_id IN (%s)
AND e.$col=?
%s",
$cals,
$where_add
),
$id);
if ($result && ($sql_arr = $this->rc->db->fetch_assoc($result)) && $sql_arr['event_id']) {
$event = $this->_read_postprocess($sql_arr);
// also load recurrence exceptions
if (!empty($event['recurrence']) && $full) {
$event['recurrence']['EXCEPTIONS'] = array_values($this->_load_exceptions($event));
}
$this->cache[$id] = $event;
return $this->cache[$id];
}
return false;
}
/**
* Sync and returns event data
*
* @see calendar_driver::load_events()
* @param unknown $start
* @param unknown $end
* @param unknown $query (optional)
* @param unknown $calendars (optional)
* @param unknown $virtual (optional)
* @param unknown $modifiedsince (optional)
* @return unknown
*/
public function load_events($start, $end, $query = null, $calendars = null, $virtual = 1, $modifiedsince = null) {
if (empty($calendars))
$calendars = array_keys($this->calendars);
else if (!is_array($calendars))
$calendars = explode(',', strval($calendars));
// only allow to select from calendars of this use
$calendar_ids = array_intersect($calendars, array_keys($this->calendars));
// Make sure that the calendars are in sync.
foreach ($calendar_ids as $cal_id) {
if (!$this->_is_synced($cal_id)) {
$this->_sync_calendar($cal_id);
}
}
return $this->_db_load_events($start, $end, $query, $calendars, $virtual, $modifiedsince);
}
/**
* Get event data
*
* @see calendar_driver::load_events()
* @param unknown $start
* @param unknown $end
* @param unknown $query (optional)
* @param unknown $calendars (optional)
* @param unknown $virtual (optional)
* @param unknown $modifiedsince (optional)
* @return unknown
*/
private function _db_load_events($start, $end, $query = null, $calendars = null, $virtual = 1, $modifiedsince = null) {
$load_all_events = $start < 1;
if (empty($calendars))
$calendars = array_keys($this->calendars);
else if (!is_array($calendars))
$calendars = explode(',', strval($calendars));
// only allow to select from calendars of this use
$calendar_ids = array_map(array($this->rc->db, 'quote'), array_intersect($calendars, array_keys($this->calendars)));
// compose (slow) SQL query for searching
// FIXME: improve searching using a dedicated col and normalized values
$sql_add = '';
if ($query) {
foreach (array('title', 'location', 'description', 'categories', 'attendees') as $col)
$sql_query[] = $this->rc->db->ilike($col, '%' . $query . '%');
$sql_add = 'AND (' . join(' OR ', $sql_query) . ')';
}
if (!$virtual)
$sql_add .= ' AND e.recurrence_id = 0';
if ($modifiedsince)
$sql_add .= ' AND e.changed >= ' . $this->rc->db->quote(date('Y-m-d H:i:s', $modifiedsince));
$events = array();
if (!empty($calendar_ids)) {
$result = $this->rc->db->query(sprintf(
"SELECT e.*, (SELECT COUNT(attachment_id) FROM " . $this->db_attachments . "
WHERE event_id = e.event_id OR event_id = e.recurrence_id) AS _attachments
FROM " . $this->db_events . " e
WHERE e.calendar_id IN (%s)
AND e.start <= %s AND e.end >= %s
%s",
join(',', $calendar_ids),
$this->rc->db->fromunixtime($end),
$this->rc->db->fromunixtime($start),
$sql_add
));
while ($result && ($sql_arr = $this->rc->db->fetch_assoc($result))) {
$event = $this->_read_postprocess($sql_arr);
$add = true;
$is_recurring = !empty($event['recurrence']);
$is_master = !$event['recurrence_id'];
if ($is_recurring && $is_master) {
// load recurrence exceptions (i.e. for export)
if (!$virtual) {
$event['recurrence']['EXCEPTIONS'] = $this->_load_exceptions($event);
} // check for exception on first instance
else {
$add = $load_all_events ? true : $this->is_master_active($event);
$instance = libcalendaring::recurrence_instance_identifier($event);
$exceptions = $this->_load_exceptions($event, $instance);
if ($exceptions && is_array($exceptions[$instance])) {
$event = $exceptions[$instance];
$add = false;
}
}
}
if ($add)
$events[] = $event;
}
}
return $events;
}
/**
* Get number of events in the given calendar
*
* @param mixed List of calendar IDs to count events (either as array or comma-separated string)
* @param integer Date range start (unix timestamp)
* @param integer Date range end (unix timestamp)
* @param unknown $calendars
* @param unknown $start
* @param unknown $end (optional)
* @return array Hash array with counts grouped by calendar ID
*/
public function count_events($calendars, $start, $end = null) {
// not implemented
return array();
}
/**
* Convert sql record into a rcube style event object
*
* @param unknown $event
* @return unknown
*/
private function _read_postprocess($event) {
$free_busy_map = array_flip($this->free_busy_map);
$sensitivity_map = array_flip($this->sensitivity_map);
$event['id'] = $event['event_id'];
$event['start'] = new DateTime($event['start']);
$event['end'] = new DateTime($event['end']);
$event['allday'] = intval($event['all_day']);
$event['created'] = new DateTime($event['created']);
$event['changed'] = new DateTime($event['changed']);
$event['free_busy'] = $free_busy_map[$event['free_busy']];
$event['sensitivity'] = $sensitivity_map[$event['sensitivity']];
$event['calendar'] = $event['calendar_id'];
$event['recurrence_id'] = intval($event['recurrence_id']);
$event['isexception'] = intval($event['isexception']);
$cal = $this->calendars[$event['calendar_id']];
$event['editable'] = !$cal['readonly'];
// parse recurrence rule
if ($event['recurrence'] && preg_match_all('/([A-Z]+)=([^;]+);?/', $event['recurrence'], $m, PREG_SET_ORDER)) {
$event['recurrence'] = array();
foreach ($m as $rr) {
if (is_numeric($rr[2]))
$rr[2] = intval($rr[2]);
else if ($rr[1] == 'UNTIL')
$rr[2] = date_create($rr[2]);
else if ($rr[1] == 'RDATE')
$rr[2] = array_map('date_create', explode(',', $rr[2]));
else if ($rr[1] == 'EXDATE')
$rr[2] = array_map('date_create', explode(',', $rr[2]));
$event['recurrence'][$rr[1]] = $rr[2];
}
}
if ($event['recurrence_id']) {
libcalendaring::identify_recurrence_instance($event);
}
if (strlen($event['instance'])) {
$event['_instance'] = $event['instance'];
if (empty($event['recurrence_id'])) {
$event['recurrence_date'] = rcube_utils::anytodatetime($event['_instance'], $event['start']->getTimezone());
}
}
if ($event['_attachments'] > 0) {
$event['attachments'] = (array)$this->list_attachments($event);
}
// decode serialized event attendees
if (strlen($event['attendees'])) {
$event['attendees'] = json_decode($event['attendees'],true);
} else {
$event['attendees'] = array();
}
// decode serialized alarms
if ($event['alarms']) {
$event['valarms'] = $this->unserialize_alarms($event['alarms']);
}
unset($event['event_id'], $event['calendar_id'], $event['notifyat'], $event['all_day'], $event['instance'], $event['_attachments']);
return $event;
}
/**
* Get a list of pending alarms to be displayed to the user
*
* @see calendar_driver::pending_alarms()
* @param unknown $time
* @param unknown $calendars (optional)
* @return unknown
*/
public function pending_alarms($time, $calendars = null) {
if (empty($calendars))
$calendars = array_keys($this->calendars);
else if (is_string($calendars))
$calendars = explode(',', $calendars);
// only allow to select from calendars with activated alarms
$calendar_ids = array();
foreach ($calendars as $cid) {
if ($this->calendars[$cid] && $this->calendars[$cid]['showalarms'])
$calendar_ids[] = $cid;
}
$calendar_ids = array_map(array($this->rc->db, 'quote'), $calendar_ids);
$alarms = array();
if (!empty($calendar_ids)) {
$result = $this->rc->db->query(sprintf(
"SELECT * FROM " . $this->db_events . "
WHERE calendar_id IN (%s)
AND notifyat <= %s AND %s > %s",
join(',', $calendar_ids),
$this->rc->db->fromunixtime($time),
$this->rc->db->quote_identifier('end'),
$this->rc->db->fromunixtime($time)
));
while ($result && ($event = $this->rc->db->fetch_assoc($result)))
$alarms[] = $this->_read_postprocess($event);
}
return $alarms;
}
/**
* Feedback after showing/sending an alarm notification
*
* @see calendar_driver::dismiss_alarm()
* @param unknown $event_id
* @param unknown $snooze (optional)
* @return unknown
*/
public function dismiss_alarm($event_id, $snooze = 0) {
// set new notifyat time or unset if not snoozed
$notify_at = $snooze > 0 ? date(self::DB_DATE_FORMAT, time() + $snooze) : null;
$query = $this->rc->db->query(sprintf(
"UPDATE " . $this->db_events . "
SET changed=%s, notifyat=?
WHERE event_id=?
AND calendar_id IN (" . $this->calendar_ids . ")",
$this->rc->db->now()),
$notify_at,
$event_id
);
return $this->rc->db->affected_rows($query);
}
/**
* Save an attachment related to the given event
*
* @param unknown $attachment
* @param unknown $event_id
* @return unknown
*/
private function add_attachment($attachment, $event_id) {
if (isset($attachment['data']))
$data = $attachment['data'];
elseif (isset($attachment['path']) && $attachment['path'] != '')
$data = file_get_contents($attachment['path']);
else
return 0;
$query = $this->rc->db->query(
"INSERT INTO " . $this->db_attachments .
" (event_id, filename, mimetype, size, data)" .
" VALUES (?, ?, ?, ?, ?)",
$event_id,
$attachment['name'],
$attachment['mimetype'],
strlen($data),
base64_encode($data)
);
return $this->rc->db->affected_rows($query);
}
/**
* Remove a specific attachment from the given event
*
* @param unknown $attachment_id
* @param unknown $event_id
* @return unknown
*/
private function remove_attachment($attachment_id, $event_id) {
$query = $this->rc->db->query(
"DELETE FROM " . $this->db_attachments .
" WHERE attachment_id = ?" .
" AND event_id IN (SELECT event_id FROM " . $this->db_events .
" WHERE event_id = ?" .
" AND calendar_id IN (" . $this->calendar_ids . "))",
$attachment_id,
$event_id
);
return $this->rc->db->affected_rows($query);
}
/**
* List attachments of specified event
*
* @param unknown $event
* @return unknown
*/
public function list_attachments($event) {
$attachments = array();
if (!empty($this->calendar_ids)) {
$result = $this->rc->db->query(
"SELECT attachment_id AS id, filename AS name, mimetype, size " .
" FROM " . $this->db_attachments .
" WHERE event_id IN (SELECT event_id FROM " . $this->db_events .
" WHERE event_id=?" .
" AND calendar_id IN (" . $this->calendar_ids . "))".
" ORDER BY filename",
$event['recurrence_id'] ? $event['recurrence_id'] : $event['event_id']
);
while ($result && ($arr = $this->rc->db->fetch_assoc($result))) {
$attachments[] = $arr;
}
}
return $attachments;
}
/**
* Get attachment properties
*
* @param unknown $id
* @param unknown $event
* @return unknown
*/
public function get_attachment($id, $event) {
if (!empty($this->calendar_ids)) {
$result = $this->rc->db->query(
"SELECT attachment_id AS id, filename AS name, mimetype, size " .
" FROM " . $this->db_attachments .
" WHERE attachment_id=?".
" AND event_id=?",
$id,
$event['recurrence_id'] ? $event['recurrence_id'] : $event['id']
);
if ($result && ($arr = $this->rc->db->fetch_assoc($result))) {
return $arr;
}
}
return null;
}
/**
* Get attachment body
*
* @param unknown $id
* @param unknown $event
* @return unknown
*/
public function get_attachment_body($id, $event) {
if (!empty($this->calendar_ids)) {
$result = $this->rc->db->query(
"SELECT data " .
" FROM " . $this->db_attachments .
" WHERE attachment_id=?".
" AND event_id=?",
$id,
$event['id']
);
if ($result && ($arr = $this->rc->db->fetch_assoc($result))) {
return base64_decode($arr['data']);
}
}
return null;
}
/**
* Remove the given category
*
* @param unknown $name
* @return unknown
*/
public function remove_category($name) {
$query = $this->rc->db->query(
"UPDATE " . $this->db_events . "
SET categories=''
WHERE categories=?
AND calendar_id IN (" . $this->calendar_ids . ")",
$name
);
return $this->rc->db->affected_rows($query);
}
/**
* Update/replace a category
*
* @param unknown $oldname
* @param unknown $name
* @param unknown $color
* @return unknown
*/
public function replace_category($oldname, $name, $color) {
$query = $this->rc->db->query(
"UPDATE " . $this->db_events . "
SET categories=?
WHERE categories=?
AND calendar_id IN (" . $this->calendar_ids . ")",
$name,
$oldname
);
return $this->rc->db->affected_rows($query);
}
/**
* Helper method to serialize the list of alarms into a string
*
* @param unknown $valarms
* @return unknown
*/
private function serialize_alarms($valarms) {
foreach ((array)$valarms as $i => $alarm) {
if ($alarm['trigger'] instanceof DateTime || $alarm['trigger'] instanceof DateTimeImmutable) {
$valarms[$i]['trigger'] = '@' . $alarm['trigger']->format('c');
}
}
return $valarms ? json_encode($valarms) : null;
}
/**
* Helper method to decode a serialized list of alarms
*
* @param unknown $alarms
* @return unknown
*/
private function unserialize_alarms($alarms) {
// decode json serialized alarms
if ($alarms && $alarms[0] == '[') {
$valarms = json_decode($alarms, true);
foreach ($valarms as $i => $alarm) {
if ($alarm['trigger'][0] == '@') {
try {
$valarms[$i]['trigger'] = new DateTime(substr($alarm['trigger'], 1));
}
catch (Exception $e) {
unset($valarms[$i]);
}
}
}
}
// convert legacy alarms data
else if (strlen($alarms)) {
list($trigger, $action) = explode(':', $alarms, 2);
if ($trigger = libcalendaring::parse_alarm_value($trigger)) {
$valarms = array(array('action' => $action, 'trigger' => $trigger[3] ?: $trigger[0]));
}
}
return $valarms;
}
/**
* Handler for user_delete plugin hook
*
* @param unknown $args
*/
public function user_delete($args) {
$db = $this->rc->db;
$user = $args['user'];
$event_ids = array();
$events = $db->query(
"SELECT event_id FROM " . $this->db_events . " AS ev" .
" LEFT JOIN " . $this->db_calendars . " cal ON (ev.calendar_id = cal.calendar_id)".
" WHERE user_id=?",
$user->ID);
while ($row = $db->fetch_assoc($events)) {
$event_ids[] = $row['event_id'];
}
if (!empty($event_ids)) {
foreach (array($this->db_attachments, $this->db_events) as $table) {
$db->query(sprintf("DELETE FROM $table WHERE event_id IN (%s)", join(',', $event_ids)));
}
}
foreach (array($this->db_calendars, 'itipinvitations') as $table) {
$db->query("DELETE FROM $table WHERE user_id=?", $user->ID);
}
}
/**
* Callback function to produce driver-specific calendar create/edit form
*
*
* @param string Request action 'form-edit|form-new'
* @param array Calendar properties (e.g. id, color)
* @param array Edit form fields
* @param unknown $action
* @param unknown $calendar
* @param unknown $formfields
* @return string HTML content of the form
*/
public function calendar_form($action, $calendar, $formfields) {
// Make sure we have current attributes
$calendars = $this->calendars;
$calendar = array_key_exists($calendar['id'], $calendars) ? $this->calendars[$calendar["id"]] : [];
$form = array();
$hidden_fields[] = array( "name" => "driver", "value" => "caldav" );
// General tab
$form['props'] = array(
'name' => $this->rc->gettext('properties'),
);
// calendar name (default field) and caldav url
$input_caldav_url = new html_inputfield( array(
"name" => "caldav_url",
"id" => "caldav_url",
));
$formfields["caldav_url"] = array(
"label" => $this->cal->gettext("caldav_url"),
"value" => $input_caldav_url->show($calendar["caldav_url"]),
"id" => "caldav_url",
);
$form['props']['fieldsets']['location'] = array(
'name' => $this->rc->gettext('location'),
'content' => array(
'name' => $formfields['name'],
'caldav_url' => $formfields['caldav_url']
),
);
// calendar color, alarms (default field)
$form['props']['fieldsets']['settings'] = array(
'name' => $this->rc->gettext('settings'),
'style' => "table",
'content' => array(
'color' => $formfields['color'],
'showalarms' => $formfields['showalarms'],
),
);
// caldav auth properties
$form['auth'] = array(
'name' => $this->cal->gettext('auth'),
);
$input_caldav_user = new html_inputfield( array(
"name" => "caldav_user",
"id" => "caldav_user",
));
$formfields["caldav_user"] = array(
"label" => $this->cal->gettext("username"),
"value" => $input_caldav_user->show($calendar["caldav_user"]),
"id" => "caldav_user",
);
$input_caldav_pass = new html_passwordfield( array(
"name" => "caldav_pass",
"id" => "caldav_pass",
));
$formfields["caldav_pass"] = array(
"label" => $this->cal->gettext("password"),
"value" => $input_caldav_pass->show(null), // Don't send plain text password to GUI
"id" => "caldav_pass",
);
$form['auth']['fieldsets']['caldav_auth_digest'] = array(
'name' => $this->cal->gettext('caldav_auth_digest'),
'content' => array(
'caldav_user' => $formfields["caldav_user"],
'caldav_pass' => $formfields["caldav_pass"]
)
);
$this->form_html = '';
if (is_array($hidden_fields)) {
foreach ($hidden_fields as $field) {
$hiddenfield = new html_hiddenfield($field);
$this->form_html .= $hiddenfield->show() . "\n";
}
}
// Create form output
foreach ($form as $tab) {
if (!empty($tab['fieldsets']) && is_array($tab['fieldsets'])) {
$content = '';
foreach ($tab['fieldsets'] as $fieldset) {
$subcontent = $this->get_form_part($fieldset);
if ($subcontent) {
$content .= html::tag('fieldset', null, html::tag('legend', null, rcube::Q($fieldset['name'])) . $subcontent) ."\n";
}
}
}
else {
$content = $this->get_form_part($tab);
}
if ($content) {
$this->form_html .= html::tag('fieldset', null, html::tag('legend', null, rcube::Q($tab['name'])) . $content) ."\n";
}
}
// Parse form template for skin-dependent stuff
$this->rc->output->add_handler('calendarform', array($this, 'calendar_form_html'));
return $this->rc->output->parse('calendar.kolabform', false, false);
}
/**
* Handler for template object
*
* @return unknown
*/
public function calendar_form_html() {
return $this->form_html;
}
/**
* Helper function used in calendar_form_content(). Creates a part of the form.
*
* @param unknown $form
* @return unknown
*/
private function get_form_part($form) {
$content = '';
if ( is_array( $form['content'] ) && ! empty( $form['content'] ) ) {
if (isset($form["style"]) && $form["style"] == "table") {
$table = new html_table(array('cols' => 2));
foreach ($form['content'] as $col => $colprop) {
$label = !empty($colprop['label']) ? $colprop['label'] : $this->rc->gettext($col);
$table->add('title', html::label($colprop['id'], rcube::Q($label)));
$table->add(null, $colprop['value']);
}
$content = $table->show();
}
else {
foreach ( $form['content'] as $col => $colprop ) {
$label = ! empty( $colprop['label'] ) ? $colprop['label'] : $this->rc->gettext( $col );
$content .=
html::div("calendar-input",
html::label( $colprop['id'], rcube::Q( $label ) ) .
html::br() .
$colprop['value'] );
}
}
}
else {
$content = $form['content'];
}
return $content;
}
/**
* Encodes directory- and filenames using rawurlencode().
*
* @see http://stackoverflow.com/questions/7973790/urlencode-only-the-directory-and-file-names-of-a-url
* @param string Unencoded URL to be encoded.
* @param unknown $url
* @return Encoded URL.
*/
private static function _encode_url($url) {
// Don't encode if "%" is already used.
if (strstr($url, "%") === false) {
return preg_replace_callback('#://([^/]+)/([^?]+)#', function ($matches) {
return '://' . $matches[1] . '/' . join('/', array_map('rawurlencode', explode('/', $matches[2])));
}, $url);
}
else return $url;
}
/**
* Set RC (imap) password to the given calendar properties if their value is "%p".
*
*
* @param array List of properties
* @param array List of calendar properties to loop up
* @param unknown $props
* @param unknown $names (optional)
* @return array List of properties, with expanded 'caldav_pass' attribute
*/
private function _expand_pass($props, $names = array('caldav_pass')) {
foreach ($names as $name) {
if (isset($props[$name]) && $props[$name] === '%p')
$props[$name] = $this->rc->get_user_password();
}
return $props;
}
/**
* Replace "%u" with RC (imap) user in the given calendar properties.
*
*
* @param array List of properties
* @param array List of calendar properties to loop up
* @param unknown $props
* @param unknown $names (optional)
* @return array List of properties, with expanded 'caldav_pass' attribute
*/
private function _expand_user($props, $names = array('caldav_url', 'caldav_user')) {
foreach ($names as $name) {
if (isset($props[$name]))
$props[$name] = str_replace('%u', $this->rc->get_user_name(), $props[$name]);
$props[$name] = str_replace('%l', $this->rc->user->get_username('local'), $props[$name]);
$props[$name] = str_replace('%d', $this->rc->user->get_username('domain'), $props[$name]);
}
return $props;
}
/**
* Add default (pre-installation provisioned) calendar. If calendars from
* same url exist, insertion does not take place.
*
* caldav_url: Absolute URL to calendar server collection
* caldav_user: Username
* caldav_pass: Password
* color: Events color
* readonly: Calendar is readonly
* showAlarms:
*
* @param array $props
* @return bool false on creation error, true otherwise
*/
public function insert_default_calendar($props) {
$props = $this->_expand_user($props);
$props = $this->_expand_pass($props);
foreach ($this->list_calendars() as $cal) {
$vcal_info = $this->calendars[$cal['id']];
if ($vcal_info['caldav_url'] == self::_encode_url($props['caldav_url']) || $vcal_info['name'] === $props['name'] ) {
return true;
}
}
# Don't throw when default calendar insert fails
$return = true;
try {
$return = $this->create_calendar($props);
} catch (exception $e) {
# Don't do anything... even log the failure, as QA whined about it
# error_log($e->getTraceAsString());
}
return $return;
}
/**
* Returns true if the specified calendar is a preinstalled calendar, false otherwise.
*
* @param unknown $cal
* @return bool
*/
public function is_preinstalled_calendar($cal) {
$preinstalled_calendars = $this->rc->config->get('calendar_preinstalled_calendars', array());
if (is_array($preinstalled_calendars)) foreach ($preinstalled_calendars as $props) {
$props = $this->_expand_user($props);
if ($props['url'] == $cal['url'])
return true;
}
return false;
}
/**
* Auto discover calenders available to the user on the caldav server
* caldav_url: Absolute URL to CalDAV server
* caldav_user: Username
* caldav_pass: Password
* name: Calendar display name
* href: Absolute calendar URL
*
* @param array $props
* @return False on error or an array with the following calendar props:
*/
private function _autodiscover_calendars($props) {
$calendars = array();
$current_user_principal = array('{DAV:}current-user-principal');
$calendar_home_set = array('{urn:ietf:params:xml:ns:caldav}calendar-home-set');
$cal_attribs = array('{DAV:}resourcetype', '{DAV:}displayname');
require_once $this->cal->home.'/lib/caldav-client.php';
$caldav = new caldav_client($props["caldav_url"], $props["caldav_user"], $props["caldav_pass"], $props["ssl_verify"] ?? true);
$tokens = parse_url($props["caldav_url"]);
$base_uri = $tokens['scheme']."://".$tokens['host'].($tokens['port'] ? ":".$tokens['port'] : null);
$caldav_url = $props["caldav_url"];
$response = $caldav->prop_find($caldav_url, array_merge($current_user_principal, $cal_attribs), 0);
if (!$response) {
$this->_raise_error("Resource \"$caldav_url\" has no collections");
return false;
}
else if (array_key_exists('{DAV:}resourcetype', $response) &&
$response['{DAV:}resourcetype'] instanceof Sabre\DAV\Xml\Property\ResourceType
/*&& in_array('{urn:ietf:params:xml:ns:caldav}calendar',
$response['{DAV:}resourcetype']->getValue())*/) {
$name = '';
if (array_key_exists('{DAV:}displayname', $response)) {
$name = $response['{DAV:}displayname'];
}
array_push($calendars, array(
'name' => $name,
'href' => $caldav_url,
));
return $calendars;
// directly return given url as it is a calendar
}
// probe further for principal url and user home set
$caldav_url = $base_uri . $response[$current_user_principal[0]];
$response = $caldav->prop_find($caldav_url, $calendar_home_set, 0);
if (!$response) {
$this->_raise_error("Resource \"$caldav_url\" contains no calendars.");
return false;
}
$caldav_url = $base_uri . $response[$calendar_home_set[0]];
$response = $caldav->prop_find($caldav_url, $cal_attribs, 1);
foreach ($response as $collection => $attribs) {
$found = false;
$name = '';
foreach ($attribs as $key => $value) {
if ($key == '{DAV:}resourcetype' && is_object($value)) {
if ($value instanceof Sabre\DAV\Property\ResourceType) {
$values = $value->getValue();
if (in_array('{urn:ietf:params:xml:ns:caldav}calendar', $values))
$found = true;
}
}
else if ($key == '{DAV:}displayname') {
$name = $value;
}
}
if ($found) {
array_push($calendars, array(
'name' => $name,
'href' => $base_uri.$collection,
));
}
}
return $calendars;
}
/**
* Synchronizes events of given calendar.
*
* @param int Calendar ID to sync
* @param unknown $cal_id
*/
private function _sync_calendar($cal_id) {
self::debug_log("Syncing calendar id \"$cal_id\".");
$this->_num_events_removed_in_last_sync = 0;
$cal_sync = $this->sync_clients[$cal_id];
$events = array();
// Ignore recurrence events and read caldav props
foreach ($this->_load_all_events($cal_id) as $event) {
if (empty($event["recurrence_id"])) {
array_push($events, $event);
}
}
if( !empty($events) ) $updates = $cal_sync->get_updates($events);
if (!empty($updates)) {
list($updates, $synced_uids) = $updates;
$updated_event_uids = $this->_perform_updates($updates);
// Delete events that are not in sync or updated.
foreach ($events as $array_index => $event) {
// new CCS events in $events do not have an 'id' at this point, but one does exist
// so we could call get_event() to refresh the whole thing. Let's try to use the uid instead.
//$event = $this->get_event($event);
$event_uid = $event["uid"];
$not_updated = array_search($event_uid, $updated_event_uids) === false;
$not_in_sync = array_search($event_uid, $synced_uids) === false;
if ($not_updated && $not_in_sync) {
$this->_db_remove_event($event);
self::debug_log("Remove event \"". $event_uid ."\".");
++$this->_num_events_removed_in_last_sync;
}
}
// Update calendar ctag ...
$calendar = $this->calendars[$cal_id];
$calendar["caldav_tag"] = $cal_sync->get_ctag();
$this->edit_calendar($calendar);
}
self::debug_log("Successfully synced calendar id \"$cal_id\".");
}
/**
* Return all events from the given calendar.
*
* @param int Calendar id.
* @param unknown $cal_id
* @return array
*/
private function _load_all_events($cal_id) {
// Get the event with the maximum end time.
$query = "SELECT MAX(e.end) as end FROM ".$this->db_events." e " .
"WHERE e.calendar_id = ? ";
$result = $this->rc->db->query( $query, $cal_id);
if ($result && ($arr = $this->rc->db->fetch_assoc($result)) && !empty($arr["end"])) {
$end = new DateTime($arr["end"]);
// Don't use load_events() which is doing another sync while this method might be already invoked in an sync.
return $this->_db_load_events(0, $end->getTimestamp(), null, array($cal_id));
} else {
// Nothing in the DB, get em from the server
$cal_sync = $this->sync_clients[$cal_id];
$etags = $cal_sync->caldav->get_etags();
$urls = [];
foreach ( $etags as $etag ) {
$urls[] = $etag['url'];
}
$events = $cal_sync->caldav->get_events($urls);
return $events;
}
}
/**
* Performs caldav updates on given events.
*
* @param array Caldav and event properties to update. See caldav_sync::get_updates().
* @param unknown $updates
* @return array List of event uids.
*/
private function _perform_updates($updates) {
$event_uids = array();
$num_created = 0;
$num_updated = 0;
foreach ($updates as $update) {
// local event -> update event
if (isset($update["local_event"])) {
// Ensure data structure sanity
if ( !is_array($update["local_event"]) ) $update["local_event"] = [ 'attendees' => [] ];
if ( !array_key_exists( 'attendees', $update["local_event"] ) || !is_array( $update["local_event"]["attendees"] ) ) $update["local_event"]["attendees"] = [];
if ( !is_array($update["remote_event"]) ) $update["remote_event"] = [ 'attendees' => [] ];
if ( !array_key_exists( 'attendees', $update["remote_event"] ) || !is_array( $update["remote_event"]["attendees"] ) ) $update["remote_event"]["attendees"] = [];
// Overwrite local event attributes with new event, url + etag.
$event = array_merge((array)$update["local_event"], $update["remote_event"], array(
"caldav_url" => $update["url"],
"caldav_tag" => $update["etag"]));
# Locally saved event data is likely incorrect. Don't respect this data. Respect what the server replied instead.
$event["attendees"] = $update["remote_event"]["attendees"];
// let edit_event() do all the magic
if ($this->_db_edit_event($event)) {
$event_id = $event["id"];
array_push($event_uids, $event['uid']);
$num_updated ++;
}
else {
self::debug_log("Could not perform event update: ".print_r($update, true));
}
}
// no local event -> create event
else {
if ( !array_key_exists('remote_event', $update) || !is_array($update["remote_event"]) ) $update["remote_event"] = [ 'attendees' => [] ];
$event = array_merge($update["remote_event"], array(
"caldav_url" => $update["url"],
"caldav_tag" => $update["etag"]));
$event_id = $this->new_event($event, true);
if ($event_id) {
self::debug_log("Created event \"$event_id\".");
array_push($event_uids, $event['uid']);
$num_created ++;
}
else {
self::debug_log("Could not perform event creation: ".print_r($update, true));
}
}
}
self::debug_log("Created $num_created new events, updated $num_updated event.");
return $event_uids;
}
/**
* Determines whether the given calendar is in sync regarding
* calendar's ctag and the configured sync period.
*
* @param int Calender id.
* @param unknown $cal_id
* @return boolean True if calendar is in sync, true otherwise.
*/
private function _is_synced($cal_id) {
// Atomic sql: Check for exceeded sync period and update last_change.
// NOTE since this schema was originally mysql only, we have to format things like mysql would for time strings.
$now = date("Y-m-d H:i:s");
$result = $this->rc->db->query(
"UPDATE ".$this->db_calendars." ".
"SET caldav_last_change = ? WHERE calendar_id = ? AND ".
$this->_unix_timestamp('caldav_last_change') ." + ? <= ".$this->_unix_timestamp('NOW()'),
$now, $cal_id, $this->sync_period);
// Check whether Lance is N*Sync.
$log_prefix = "Calendar \"$cal_id\" ";
$log_suffix = "needs update";
$is_synced = 0;
if ( $result && $result->rowCount() > 0) {
$is_synced = $this->sync_clients[$cal_id]->is_synced();
if ( $is_synced ) $log_suffix = "appears to be in sync";
}
self::debug_log( $log_prefix . $log_suffix );
return $is_synced;
}
/**
* Returns db-specific timestamp queries for epoch format
*
* @param str column name or valid timestamp (e.g. NOW())
* @param unknown $field
* @return str db-specific timestamp query for epoch format
*/
private function _unix_timestamp($field) {
switch ($this->rc->db->db_provider) {
case 'postgres':
return "EXTRACT (EPOCH FROM $field)";
case 'sqlite':
$thing = ( $field == 'NOW()' ? 'now' : $field );
return "strftime('%s','$thing')";
default:
return "UNIX_TIMESTAMP($field)";
}
}
/**
*
* @param unknown $pass
* @return unknown
*/
private function _decrypt_pass($pass) {
$e = new Encryption();
return $e->decryptString($pass, $this->crypt_key);
}
/**
*
* @param unknown $pass
* @return unknown
*/
private function _encrypt_pass($pass) {
$e = new Encryption();
return $e->encryptString($pass, $this->crypt_key);
}
public function needs_refresh() {
return 0 < $this->_num_events_removed_in_last_sync;
}
public function is_master_active($event) {
$is_single = !array_key_exists('recurrence', $event) || empty($event['recurrence']);
$no_exclusions = $is_single || !array_key_exists(self::EXDATE, $event['recurrence']);
if ($no_exclusions) {
return true;
}
$fmt = libcalendaring::recurrence_id_format($event);
$excluded_instances = array_map(
function ($item) use ($fmt) {
return $item->format($fmt);
},
$event['recurrence'][self::EXDATE]);
$id = libcalendaring::recurrence_instance_identifier($event);
return false === array_search($id, $excluded_instances);
}
public function apply_master_update_to_caldav($master, $reaped) {
if (!$master) {
return;
}
$cal_id = $master['calendar'];
$sync_client = $this->sync_clients[$cal_id];
if ($reaped) {
$sync_client->remove_event($master);
} else {
$sync_client->update_event($master);
}
}
}
interface EventGateway
{
function delete_event($event);
function delete_after($master, $fromdate);
function has_sub_events($master);
}
class RoundcubeEventGateway implements EventGateway
{
private $rc;
/**
* @var string
*/
private $event_table;
public function __construct($rc) {
$this->rc = $rc;
$this->event_table = 'caldav_events';
}
function delete_event($event) {
$calendar_id = $event['calendar'];
$id = $event['id'];
$is_master = $event['recurrence_id'] < 1;
if ($is_master) {
$sql = sprintf(
'DELETE FROM %s WHERE %s=? AND (%s=? OR %s=?)',
$this->rc->db->quote($this->event_table, 'ident'),
$this->rc->db->quote('calendar_id', 'ident'),
$this->rc->db->quote('event_id', 'ident'),
$this->rc->db->quote('recurrence_id', 'ident'),
);
$stmt_result = $this->rc->db->query( $sql, $calendar_id, $id, $id );
} else {
$sql = sprintf(
'DELETE FROM %s WHERE %s=? AND %s=?',
$this->rc->db->quote($this->event_table, 'ident'),
$this->rc->db->quote('calendar_id', 'ident'),
$this->rc->db->quote('event_id', 'ident'),
);
$stmt_result = $this->rc->db->query( $sql, $calendar_id, $id );
}
$no_changes = $this->rc->db->affected_rows($stmt_result) < 1;
if ($no_changes) {
throw new RuntimeException('delete_event: no changes');
}
}
function delete_after($master, $fromdate) {
$calendar_id = $master['calendar'];
$sql = sprintf(
'DELETE FROM ? WHERE calendar_id=? AND ? <= %s AND recurrence_id=?',
$this->rc->db->quote_identifier('start')
);
$stmt_result = $this->rc->db->query(
$sql,
$this->event_table,
$calendar_id,
$fromdate->format(caldav_driver::DB_DATE_FORMAT),
$master['id']
);
$no_changes = $this->rc->db->affected_rows($stmt_result) < 1;
if ($no_changes) {
throw new RuntimeException('delete_event: no changes');
}
}
public function has_sub_events($master) {
$sql = sprintf(
'SELECT COUNT(*) FROM %s WHERE %s=?',
$this->rc->db->quote($this->event_table, 'ident'),
$this->rc->db->quote('recurrence_id', 'ident'),
);
$stmt_result = $this->rc->db->query($sql, $master['id']);
$ary = $this->rc->db->fetch_array($stmt_result);
if ($ary) {
return 0 < $ary[0];
}
throw new RuntimeException('counting sub events: db error');
}
}
Back to Directory
File Manager