diff --git a/drivers/caldav/SQL/mysql.initial.sql b/drivers/caldav/SQL/mysql.initial.sql new file mode 100644 index 0000000..d60d482 --- /dev/null +++ b/drivers/caldav/SQL/mysql.initial.sql @@ -0,0 +1,92 @@ +/** + * CalDAV Client + * + * @version @package_version@ + * @author Daniel Morlock + * + * Copyright (C) Awesome IT GbR + * + * 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 . + */ + +CREATE TABLE IF NOT EXISTS `caldav_calendars` ( + `calendar_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, + `user_id` int(10) UNSIGNED NOT NULL DEFAULT '0', + `name` varchar(255) NOT NULL, + `color` varchar(8) NOT NULL, + `showalarms` tinyint(1) NOT NULL DEFAULT '1', + + `caldav_url` varchar(255) NOT NULL, + `caldav_tag` varchar(255) DEFAULT NULL, + `caldav_user` varchar(255) DEFAULT NULL, + `caldav_pass` varchar(1024) DEFAULT NULL, + `caldav_last_change` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + + PRIMARY KEY(`calendar_id`), + INDEX `caldav_user_name_idx` (`user_id`, `name`), + CONSTRAINT `fk_caldav_calendars_user_id` FOREIGN KEY (`user_id`) + REFERENCES `users`(`user_id`) ON DELETE CASCADE ON UPDATE CASCADE +) /*!40000 ENGINE=INNODB */ /*!40101 CHARACTER SET utf8 COLLATE utf8_general_ci */; + +CREATE TABLE IF NOT EXISTS `caldav_events` ( + `event_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, + `calendar_id` int(11) UNSIGNED NOT NULL DEFAULT '0', + `recurrence_id` int(11) UNSIGNED NOT NULL DEFAULT '0', + `uid` varchar(255) NOT NULL DEFAULT '', + `instance` varchar(16) NOT NULL DEFAULT '', + `isexception` tinyint(1) NOT NULL DEFAULT '0', + `created` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `changed` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `sequence` int(1) UNSIGNED NOT NULL DEFAULT '0', + `start` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `end` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `recurrence` varchar(255) DEFAULT NULL, + `title` varchar(255) NOT NULL, + `description` text NOT NULL, + `location` varchar(255) NOT NULL DEFAULT '', + `categories` varchar(255) NOT NULL DEFAULT '', + `url` varchar(255) NOT NULL DEFAULT '', + `all_day` tinyint(1) NOT NULL DEFAULT '0', + `free_busy` tinyint(1) NOT NULL DEFAULT '0', + `priority` tinyint(1) NOT NULL DEFAULT '0', + `sensitivity` tinyint(1) NOT NULL DEFAULT '0', + `status` varchar(32) NOT NULL DEFAULT '', + `alarms` text NULL DEFAULT NULL, + `attendees` text DEFAULT NULL, + `notifyat` datetime DEFAULT NULL, + + `caldav_url` varchar(255) NOT NULL, + `caldav_tag` varchar(255) DEFAULT NULL, + `caldav_last_change` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + + PRIMARY KEY(`event_id`), + INDEX `caldav_uid_idx` (`uid`), + INDEX `caldav_recurrence_idx` (`recurrence_id`), + INDEX `caldav_calendar_notify_idx` (`calendar_id`,`notifyat`), + CONSTRAINT `fk_caldav_events_calendar_id` FOREIGN KEY (`calendar_id`) + REFERENCES `caldav_calendars`(`calendar_id`) ON DELETE CASCADE ON UPDATE CASCADE +) /*!40000 ENGINE=INNODB */ /*!40101 CHARACTER SET utf8 COLLATE utf8_general_ci */; + +CREATE TABLE IF NOT EXISTS `caldav_attachments` ( + `attachment_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, + `event_id` int(11) UNSIGNED NOT NULL DEFAULT '0', + `filename` varchar(255) NOT NULL DEFAULT '', + `mimetype` varchar(255) NOT NULL DEFAULT '', + `size` int(11) NOT NULL DEFAULT '0', + `data` longtext NOT NULL, + PRIMARY KEY(`attachment_id`), + CONSTRAINT `fk_caldav_attachments_event_id` FOREIGN KEY (`event_id`) + REFERENCES `caldav_events`(`event_id`) ON DELETE CASCADE ON UPDATE CASCADE +) /*!40000 ENGINE=INNODB */ /*!40101 CHARACTER SET utf8 COLLATE utf8_general_ci */; +REPLACE INTO `system` (`name`, `value`) VALUES ('calendar-caldav-version', '2015022700'); \ No newline at end of file diff --git a/drivers/caldav/SQL/mysql/.keep_dir b/drivers/caldav/SQL/mysql/.keep_dir new file mode 100644 index 0000000..e69de29 diff --git a/drivers/caldav/SQL/mysql/2014081300.sql b/drivers/caldav/SQL/mysql/2014081300.sql new file mode 100644 index 0000000..f1a3c98 --- /dev/null +++ b/drivers/caldav/SQL/mysql/2014081300.sql @@ -0,0 +1,24 @@ +/** + * CalDAV Client + * + * @version @package_version@ + * @author Daniel Morlock + * + * Copyright (C) Awesome IT GbR + * + * 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 . + */ + +ALTER TABLE `caldav_props` change `user` `username` varchar(255); +ALTER TABLE `events` ADD `status` VARCHAR(32) NOT NULL DEFAULT '' AFTER `sensitivity`; \ No newline at end of file diff --git a/drivers/caldav/SQL/mysql/2015022500.sql b/drivers/caldav/SQL/mysql/2015022500.sql new file mode 100644 index 0000000..df0f613 --- /dev/null +++ b/drivers/caldav/SQL/mysql/2015022500.sql @@ -0,0 +1,125 @@ +/** + * CalDAV Client + * + * @version @package_version@ + * @author Daniel Morlock + * + * Copyright (C) Awesome IT GbR + * + * 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 . + */ + +/* Create new tables */ +CREATE TABLE IF NOT EXISTS `caldav_calendars` ( + `calendar_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, + `user_id` int(10) UNSIGNED NOT NULL DEFAULT '0', + `name` varchar(255) NOT NULL, + `color` varchar(8) NOT NULL, + `showalarms` tinyint(1) NOT NULL DEFAULT '1', + + `caldav_url` varchar(255) NOT NULL, + `caldav_tag` varchar(255) DEFAULT NULL, + `caldav_user` varchar(255) DEFAULT NULL, + `caldav_pass` varchar(1024) DEFAULT NULL, + `caldav_last_change` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + + PRIMARY KEY(`calendar_id`), + INDEX `caldav_user_name_idx` (`user_id`, `name`), + CONSTRAINT `fk_caldav_calendars_user_id` FOREIGN KEY (`user_id`) + REFERENCES `users`(`user_id`) ON DELETE CASCADE ON UPDATE CASCADE +) /*!40000 ENGINE=INNODB */ /*!40101 CHARACTER SET utf8 COLLATE utf8_general_ci */; + +CREATE TABLE IF NOT EXISTS `caldav_events` ( + `event_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, + `calendar_id` int(11) UNSIGNED NOT NULL DEFAULT '0', + `recurrence_id` int(11) UNSIGNED NOT NULL DEFAULT '0', + `uid` varchar(255) NOT NULL DEFAULT '', + `created` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `changed` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `sequence` int(1) UNSIGNED NOT NULL DEFAULT '0', + `start` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `end` datetime NOT NULL DEFAULT '1000-01-01 00:00:00', + `recurrence` varchar(255) DEFAULT NULL, + `title` varchar(255) NOT NULL, + `description` text NOT NULL, + `location` varchar(255) NOT NULL DEFAULT '', + `categories` varchar(255) NOT NULL DEFAULT '', + `url` varchar(255) NOT NULL DEFAULT '', + `all_day` tinyint(1) NOT NULL DEFAULT '0', + `free_busy` tinyint(1) NOT NULL DEFAULT '0', + `priority` tinyint(1) NOT NULL DEFAULT '0', + `sensitivity` tinyint(1) NOT NULL DEFAULT '0', + `status` varchar(32) NOT NULL DEFAULT '', + `alarms` varchar(255) DEFAULT NULL, + `attendees` text DEFAULT NULL, + `notifyat` datetime DEFAULT NULL, + + `caldav_url` varchar(255) NOT NULL, + `caldav_tag` varchar(255) DEFAULT NULL, + `caldav_last_change` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + + PRIMARY KEY(`event_id`), + INDEX `caldav_uid_idx` (`uid`), + INDEX `caldav_recurrence_idx` (`recurrence_id`), + INDEX `caldav_calendar_notify_idx` (`calendar_id`,`notifyat`), + CONSTRAINT `fk_caldav_events_calendar_id` FOREIGN KEY (`calendar_id`) + REFERENCES `calendars`(`calendar_id`) ON DELETE CASCADE ON UPDATE CASCADE +) /*!40000 ENGINE=INNODB */ /*!40101 CHARACTER SET utf8 COLLATE utf8_general_ci */; + +CREATE TABLE IF NOT EXISTS `caldav_attachments` ( + `attachment_id` int(11) UNSIGNED NOT NULL AUTO_INCREMENT, + `event_id` int(11) UNSIGNED NOT NULL DEFAULT '0', + `filename` varchar(255) NOT NULL DEFAULT '', + `mimetype` varchar(255) NOT NULL DEFAULT '', + `size` int(11) NOT NULL DEFAULT '0', + `data` longtext NOT NULL, + PRIMARY KEY(`attachment_id`), + CONSTRAINT `fk_caldav_attachments_event_id` FOREIGN KEY (`event_id`) + REFERENCES `events`(`event_id`) ON DELETE CASCADE ON UPDATE CASCADE +) /*!40000 ENGINE=INNODB */ /*!40101 CHARACTER SET utf8 COLLATE utf8_general_ci */; + +/* Migrate Data */ +INSERT INTO caldav_calendars SELECT calendar_id, user_id, `name`, color, showalarms, url as caldav_url, + tag as caldav_tag, username as caldav_user, pass as caldav_pass, + last_change as caldav_last_change +FROM calendars cal, caldav_props dav +WHERE dav.obj_id = cal.calendar_id +AND dav.obj_type = 'vcal'; + +INSERT INTO caldav_events SELECT e.*, dav.url as caldav_url, dav.tag as caldav_tag, dav.last_change as caldav_last_change +FROM `events` e, caldav_props dav +WHERE dav.obj_id = e.event_id +AND dav.obj_type = 'vevent'; + +INSERT INTO caldav_attachments SELECT * FROM attachments a +WHERE a.event_id IN ( + SELECT obj_id FROM caldav_props dav + WHERE dav.obj_type = 'vevent' +); + +/* Drop deprecated data */ +DELETE FROM `events` WHERE event_id IN ( + SELECT obj_id FROM caldav_props dav + WHERE dav.obj_type = 'vevent' +); +DELETE FROM calendars WHERE calendar_id IN ( + SELECT obj_id FROM caldav_props dav + WHERE dav.obj_type = 'vcal' +); +DELETE FROM attachments WHERE event_id IN ( + SELECT obj_id FROM caldav_props dav + WHERE dav.obj_type = 'vevent' +); +DROP TABLE caldav_props; + diff --git a/drivers/caldav/SQL/mysql/2015022700.sql b/drivers/caldav/SQL/mysql/2015022700.sql new file mode 100644 index 0000000..f44b49e --- /dev/null +++ b/drivers/caldav/SQL/mysql/2015022700.sql @@ -0,0 +1,14 @@ +-- add identifier for recurring instances and exceptions + +ALTER TABLE `caldav_events` ADD `instance` varchar(16) NOT NULL DEFAULT '' AFTER `uid`; +ALTER TABLE `caldav_events` ADD `isexception` tinyint(1) NOT NULL DEFAULT '0' AFTER `instance`; + +UPDATE `caldav_events` SET `instance` = DATE_FORMAT(`start`, '%Y%m%d') + WHERE `recurrence_id` != 0 AND `instance` = '' AND `all_day` = 1; + +UPDATE `caldav_events` SET `instance` = DATE_FORMAT(`start`, '%Y%m%dT%k%i%s') + WHERE `recurrence_id` != 0 AND `instance` = '' AND `all_day` = 0; + +-- extend alarms columns for multiple values + +ALTER TABLE `caldav_events` CHANGE `alarms` `alarms` TEXT NULL DEFAULT NULL; \ No newline at end of file diff --git a/drivers/caldav/SQL/postgres.initial.sql b/drivers/caldav/SQL/postgres.initial.sql new file mode 100644 index 0000000..f49da4e --- /dev/null +++ b/drivers/caldav/SQL/postgres.initial.sql @@ -0,0 +1,51 @@ +/** + * CalDAV Client + * + * @version @package_version@ + * @author Hugo Slabbert + * + * Copyright (C) 2014, Hugo Slabbert + * + * 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 . + */ + +CREATE TYPE caldav_type AS ENUM ('vcal','vevent','vtodo',''); + +CREATE TABLE IF NOT EXISTS caldav_props ( + obj_id int NOT NULL, + obj_type caldav_type NOT NULL, + url varchar(255) NOT NULL, + tag varchar(255) DEFAULT NULL, + username varchar(255) DEFAULT NULL, + pass varchar(1024) DEFAULT NULL, + last_change timestamp without time zone DEFAULT now() NOT NULL, + PRIMARY KEY (obj_id, obj_type) +); + +CREATE OR REPLACE FUNCTION upd_timestamp() RETURNS TRIGGER +LANGUAGE plpgsql +AS +$$ +BEGIN + NEW.last_change = CURRENT_TIMESTAMP; + RETURN NEW; +END; +$$; + +CREATE TRIGGER update_timestamp + BEFORE INSERT OR UPDATE + ON caldav_props + FOR EACH ROW + EXECUTE PROCEDURE upd_timestamp(); + diff --git a/drivers/caldav/caldav_driver.php b/drivers/caldav/caldav_driver.php new file mode 100644 index 0000000..b39aeff --- /dev/null +++ b/drivers/caldav/caldav_driver.php @@ -0,0 +1,2036 @@ + + * + * Copyright (C) Awesome IT GbR + * + * 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 . + */ + +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(); + private $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); + private $server_timezone; + + private $db_events = 'caldav_events'; + private $db_calendars = 'caldav_calendars'; + private $db_attachments = 'caldav_attachments'; + + // Crypt key for CalDAV auth + private $crypt_key; + + // Holds CalDAV sync clients + private $sync_clients = array(); + + // Min. time period to wait until CalDAV sync check. + private $sync_period = 10; // seconds + + // Indicates debug mode for CalDAV + static private $debug = null; + + /** + * Helper method to log debug msg if debug mode is enabled. + */ + 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. + */ + private function _raise_error($msg) + { + self::debug_log($msg); + $this->rc->output->show_message($msg, 'error'); + } + + /** + * Default constructor + */ + public function __construct($cal) + { + $this->cal = $cal; + $this->rc = $cal->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;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', ''))); + + 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['editable'] = 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']); + + // 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 + * + * @return array List of calendars + */ + public function list_calendars($filter = 0) + { + $calendars = $this->calendars; + + // filter active calendars + if ($filter & self::FILTER_ACTIVE) { + foreach ($calendars as $idx => $cal) { + if (!$cal['active']) { + unset($calendars[$idx]); + } + } + } + + // 'personal' is unsupported in this driver + + return $calendars; + } + + /** + * Extracts CalDAV calendar. + * + * @see database_driver::create_calendar() + */ + public function create_calendar($cal) + { + $result = false; + $cal['caldav_url'] = self::_encode_url($cal["caldav_url"]); + if(!isset($cal['color'])) $cal['color'] = 'cc0000'; + + $calendars = $this->_autodiscover_calendars($this->_expand_pass($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 user_id=? and caldav_url LIKE ?", $this->rc->user->ID, $calendar['href']); + 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 + * + * @param array Hash array with calendar properties + * 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 + * + * @return mixed ID of the calendar on success, False on error + */ + private function _db_create_calendar($prop) + { + $result = $this->rc->db->query( + "INSERT INTO " . $this->db_calendars . " + (user_id, name, color, showalarms, caldav_url, caldav_tag, caldav_user, caldav_pass) + VALUES (?, ?, ?, ?, ?, ?, ?, ?)", + $this->rc->user->ID, + $prop['name'], + $prop['color'], + $prop['showalarms']?1:0, + $prop['caldav_url'], + isset($prop["caldav_tag"]) ? $prop["caldav_tag"] : null, + isset($prop["caldav_user"]) ? $prop["caldav_user"] : null, + isset($prop["caldav_pass"]) ? $this->_encrypt_pass($prop["caldav_pass"]) : null + ); + + if ($result) + return $this->rc->db->insert_id($this->db_calendars); + + return false; + } + + /** + * Update properties of an existing calendar + * + * @see calendar_driver::edit_calendar() + */ + public function edit_calendar($cal) + { + $query = $this->rc->db->query("UPDATE " . $this->db_calendars . " + SET name=?, color=?, showalarms=?, caldav_url=?, caldav_tag=?, caldav_user=? + WHERE calendar_id=? + AND user_id=?", + $cal['name'], + $cal['color'], + $cal['showalarms']?1:0, + $cal['caldav_url'], + isset($cal["caldav_tag"]) ? $cal["caldav_tag"] : null, + isset($cal["caldav_user"]) ? $cal["caldav_user"] : null, + $cal['id'], + $this->rc->user->ID + ); + + // Change password if specified + if (isset($cal["caldav_pass"])) { + $query = $this->rc->db->query("UPDATE " . $this->db_calendars . " + SET caldav_pass=? + WHERE calendar_id=? + AND user_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() + */ + 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() + */ + 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 " . $this->db_calendars . " WHERE calendar_id=?", + $prop['id'] + ); + + return $this->rc->db->affected_rows($query); + } + + /** + * Search for shared or otherwise not listed calendars the user has access + * + * @param string Search string + * @param string Section/source to search + * @return array List of calendars + */ + public function search_calendars($query, $source) + { + // not implemented + return array(); + } + + /** + * Add a single event to the database + * + * @param array Hash array with event properties + * @see calendar_driver::new_event() + */ + public function new_event($event) + { + 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)); + + 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)) !== false) { + + if ($event_id = $this->_insert_event($event)) { + $this->_update_recurring($event); + } + } + } + + return $event_id; + } + + return false; + } + + /** + * + */ + private function _insert_event(&$event) + { + //$event = $this->_save_preprocess($event); + + $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']), + intval($event['recurrence_id']), + strval($event['_instance']), + intval($event['isexception']), + $event['start']->format(self::DB_DATE_FORMAT), + $event['end']->format(self::DB_DATE_FORMAT), + intval($event['all_day']), + $event['_recurrence'], + strval($event['title']), + strval($event['description']), + strval($event['location']), + join(',', (array)$event['categories']), + strval($event['url']), + intval($event['free_busy']), + intval($event['priority']), + intval($event['sensitivity']), + strval($event['status']), + $event['attendees'], + $event['alarms'], + $event['notifyat'], + $event['caldav_url'], + $event['caldav_tag'] + ); + + $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. + * + * @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. + * @see caldav_driver::_db_edit_event() + * @return bool + */ + public function edit_event($event, $old_event = null) + { + $sync_enforced = ($old_event != null); + $event_id = (int)$event["id"]; + $cal_id = $event["calendar"]; + + 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 + { + $this->_db_edit_event($old_event); + $this->_raise_error("Could not update event: Unexpected CalDAV error."); + + return false; + } + } + + return false; + } + + /** + * Update an event entry with the given data + * + * @param array Hash array with event properties + * @see calendar_driver::edit_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 ($old['recurrence']['EXDATE']) + $event['recurrence']['EXDATE'] = $old['recurrence']['EXDATE']; + + switch ($event['_savemode']) { + case 'new': + $event['uid'] = $this->cal->generate_uid(); + return $this->new_event($event); + + 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')) { + $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 + * @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() + */ + 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 + */ + 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 = $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 + */ + 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 = $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 (is_array($event['valarms'])) { + $event['alarms'] = $this->serialize_alarms($event['valarms']); + } + + // process event attendees + if (!empty($event['attendees'])) + $event['attendees'] = json_encode((array)$event['attendees']); + else + $event['attendees'] = ''; + + return $event; + } + + /** + * Compute absolute time to notify the user + */ + private function _get_notification($event) + { + if ($event['valarms'] && $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 + */ + private 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')) + $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']) + $sql_set[] = $this->rc->db->quote_identifier('instance') . '=' . $this->rc->db->quote($event['_instance']); + + if ($event['_fromcalendar'] && $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 + */ + 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 ($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'], '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 || (!$recurrence->recurEnd && !$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) + ); + } + } + } + + /** + * + */ + 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 + * + * @param array Hash array with event properties + * @see calendar_driver::move_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 + * + * @param array Hash array with event properties + * @see calendar_driver::resize_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. + * + * @param array Hash array with event properties + * @param boolean Remove record irreversible + * + * @see calendar_driver::remove_event() + * @return bool + */ + public function remove_event($event, $force = true) + { + $event_id = (int)$event["id"]; + $cal_id = (int)$event["calendar"]; + $event = $this->get_event($event); + + $sync_client = $this->sync_clients[$cal_id]; + $success = $sync_client->remove_event($event); + + if($success === true) + { + $this->_db_remove_event($event, $force); + self::debug_log("Successfully removed event \"$event_id\"."); + + // Trigger calendar sync to update ctags and etags. + $this->_sync_calendar($cal_id); + + return true; + } + + $this->_raise_error("Could not remove event: Unexpected CalDAV error."); + return false; + } + + /** + * Remove a single event from the database + * + * @param array Hash array with event properties + * @param boolean Remove record irreversible (@TODO) + * + * @see calendar_driver::remove_event() + * @return bool + */ + private function _db_remove_event($event, $force = true) + { + if (!empty($this->calendars)) { + $event += (array)$this->get_event($event); + $master = $event; + $update_master = false; + $savemode = 'all'; + $ret = true; + + // 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']; + } + + switch ($savemode) { + case 'current': + // add exception to master event + $master['recurrence']['EXDATE'][] = $event['start']; + $update_master = true; + + // just delete this single occurence + $query = $this->rc->db->query( + "DELETE FROM " . $this->db_events . " + WHERE calendar_id IN (" . $this->calendar_ids . ") + AND event_id=?", + $event['id'] + ); + break; + + case 'future': + if ($master['id'] != $event['id']) { + // set until-date on master event + $master['recurrence']['UNTIL'] = clone $event['start']; + $master['recurrence']['UNTIL']->sub(new DateInterval('P1D')); + unset($master['recurrence']['COUNT']); + $update_master = true; + + // delete this and all future instances + $fromdate = clone $event['start']; + $fromdate->setTimezone($this->server_timezone); + $query = $this->rc->db->query( + "DELETE FROM " . $this->db_events . " + WHERE calendar_id IN (" . $this->calendar_ids . ") + AND " . $this->rc->db->quote_identifier('start') . " >= ? + AND recurrence_id=?", + $fromdate->format(self::DB_DATE_FORMAT), + $master['id'] + ); + $ret = $master['id']; + break; + } + // else: future == all if modifying the master event + + default: // 'all' is default + $query = $this->rc->db->query( + "DELETE FROM " . $this->db_events . " + WHERE (event_id=? OR recurrence_id=?) + AND calendar_id IN (" . $this->calendar_ids . ")", + $master['id'], + $master['id'] + ); + break; + } + + $success = $this->rc->db->affected_rows($query); + if ($success && $update_master) + $this->_update_event($master, true); + + return $success ? $ret : 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 + * @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 ($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() + */ + 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() + */ + private function _db_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_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 + 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; + + if (!empty($event['recurrence']) && !$event['recurrence_id']) { + // load recurrence exceptions (i.e. for export) + if (!$virtual) { + $event['recurrence']['EXCEPTIONS'] = $this->_load_exceptions($event); + } // check for exception on first instance + else { + $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) + * @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 + */ + 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']); + + // 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'] = $this->unserialize_attendees($event['attendees']); + } 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() + */ + 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() + */ + 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 + */ + private function add_attachment($attachment, $event_id) + { + $data = $attachment['data'] ? $attachment['data'] : file_get_contents($attachment['path']); + + $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 + */ + 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 + */ + 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 + */ + 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 + */ + 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 + */ + 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 + */ + 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 + */ + private function serialize_alarms($valarms) + { + foreach ((array)$valarms as $i => $alarm) { + if ($alarm['trigger'] instanceof DateTime) { + $valarms[$i]['trigger'] = '@' . $alarm['trigger']->format('c'); + } + } + + return $valarms ? json_encode($valarms) : null; + } + + /** + * Helper method to decode a serialized list of alarms + */ + 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; + } + + /** + * Helper method to decode the attendees list from string + */ + private function unserialize_attendees($s_attendees) + { + $attendees = array(); + + // decode json serialized string + if ($s_attendees[0] == '[') { + $attendees = json_decode($s_attendees, true); + } // decode the old serialization format + else { + foreach (explode("\n", $event['attendees']) as $line) { + $att = array(); + foreach (rcube_utils::explode_quoted_string(';', $line) as $prop) { + list($key, $value) = explode("=", $prop); + $att[strtolower($key)] = stripslashes(trim($value, '""')); + } + $attendees[] = $att; + } + } + + return $attendees; + } + + /** + * Handler for user_delete plugin hook + */ + 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 + * + * @return string HTML content of the form + */ + public function calendar_form($action, $calendar, $formfields) + { + // Make sure we have current attributes + $calendar = $this->calendars[$calendar["id"]]; + + $input_caldav_url = new html_inputfield( array( + "name" => "caldav_url", + "id" => "caldav_url", + "size" => 20 + )); + + $formfields["caldav_url"] = array( + "label" => $this->cal->gettext("caldavurl"), + "value" => $input_caldav_url->show($calendar["caldav_url"]), + "id" => "caldav_url", + ); + + $input_caldav_user = new html_inputfield( array( + "name" => "caldav_user", + "id" => "caldav_user", + "size" => 20 + )); + + $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", + "size" => 20 + )); + + $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", + ); + + return parent::calendar_form($action, $calendar, $formfields); + } + + /** + * 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. + * @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; + } + + /** + * Expand all "%p" occurrences in 'caldav_pass' element of calendar object + * properties array with RC (imap) password. + * Other elements are left untouched. + * + * @param array List of properties + * @return array List of properties, with expanded 'caldav_pass' attribute + * + */ + private function _expand_pass($props) + { + if (isset($props['caldav_pass'])) + $props['caldav_pass'] = str_replace('%p', $this->rc->get_user_password(), $props['caldav_pass']); + + return $props; + } + + /** + * Auto discover calenders available to the user on the caldav server + * @param array $props + * caldav_url: Absolute URL to CalDAV server + * caldav_user: Username + * caldav_pass: Password + * @return False on error or an array with the following calendar props: + * name: Calendar display name + * href: Absolute calendar URL + */ + 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"]); + + $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 OldSabre\DAV\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 OldSabre\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 + */ + private function _sync_calendar($cal_id) + { + self::debug_log("Syncing calendar id \"$cal_id\"."); + + $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($event["recurrence_id"] == 0) { + array_push($events, $event); + } + } + + $updates = $cal_sync->get_updates($events); + if($updates) + { + list($updates, $synced_event_ids) = $updates; + $updated_event_ids = $this->_perform_updates($updates); + + // Delete events that are not in sync or updated. + foreach($events as $event) + { + if(array_search($event["id"], $updated_event_ids) === false && // No updated event + array_search($event["id"], $synced_event_ids) === false) // No in-sync event + { + // Assume: Event not in sync and not updated, so delete! + $this->_db_remove_event($event, true); + self::debug_log("Remove event \"".$event["id"]."\"."); + } + } + + // 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. + * @return array + */ + private function _load_all_events($cal_id) + { + // FIXME: This is kind of ugly but a way to get _all_ events without touching the database driver. + + // Get the event with the maximum end time. + $result = $this->rc->db->query( + "SELECT MAX(e.end) as end FROM ".$this->db_events." e ". + "WHERE e.calendar_id = ? ", $cal_id); + + if($result && ($arr = $this->rc->db->fetch_assoc($result))) { + $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 return array(); + } + + /** + * Performs caldav updates on given events. + * + * @param array Caldav and event properties to update. See caldav_sync::get_updates(). + * @return array List of event ids. + */ + private function _perform_updates($updates) + { + $event_ids = array(); + + $num_created = 0; + $num_updated = 0; + + foreach($updates as $update) + { + // local event -> update event + if(isset($update["local_event"])) + { + // 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"])); + + // let edit_event() do all the magic + if($this->_db_edit_event($event)) + { + $event_id = $event["id"]; + array_push($event_ids, $event_id); + $num_updated ++; + } + else + { + self::debug_log("Could not perform event update: ".print_r($update, true)); + } + } + + // no local event -> create event + else + { + $event = array_merge($update["remote_event"], array( + "caldav_url" => $update["url"], + "caldav_tag" => $update["etag"])); + + $event_id = $this->new_event($event); + if($event_id) + { + self::debug_log("Created event \"$event_id\"."); + array_push($event_ids, $event_id); + $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_ids; + } + + /** + * Determines whether the given calendar is in sync regarding + * calendar's ctag and the configured sync period. + * + * @param int Calender 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. + $query = $this->rc->db->query( + "UPDATE ".$this->db_calendars." ". + "SET caldav_last_change = NOW() WHERE calendar_id = ? AND ". + $this->_unix_timestamp('caldav_last_change') ." + ? <= ".$this->_unix_timestamp('NOW()'), + $cal_id, $this->sync_period); + + if($query->rowCount() > 0) + { + $is_synced = $this->sync_clients[$cal_id]->is_synced(); + self::debug_log("Calendar \"$cal_id\" ".($is_synced ? "is in sync" : "needs update")."."); + return $is_synced; + } + else + { + self::debug_log("Sync period active: Assuming calendar \"$cal_id\" to be in sync."); + return true; + } + } + + /** + * Returns db-specific timestamp queries for epoch format + * + * @param str column name or valid timestamp (e.g. NOW()) + * @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)"; + default: + return "UNIX_TIMESTAMP($field)"; + } + } + + private function _decrypt_pass($pass) { + $p = base64_decode($pass); + $e = new Encryption(MCRYPT_BlOWFISH, MCRYPT_MODE_CBC); + return $e->decrypt($p, $this->crypt_key); + } + + private function _encrypt_pass($pass) { + $e = new Encryption(MCRYPT_BlOWFISH, MCRYPT_MODE_CBC); + $p = $e->encrypt($pass, $this->crypt_key); + return base64_encode($p); + } +} diff --git a/drivers/caldav/caldav_sync.php b/drivers/caldav/caldav_sync.php new file mode 100644 index 0000000..efe92c2 --- /dev/null +++ b/drivers/caldav/caldav_sync.php @@ -0,0 +1,253 @@ + + * + * Copyright (C) Awesome IT GbR + * + * 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 . + */ + +require_once (dirname(__FILE__).'/../../lib/caldav-client.php'); + +class caldav_sync +{ + const ACTION_NONE = 1; + const ACTION_UPDATE = 2; + const ACTION_CREATE = 4; + + private $cal_id = null; + private $ctag = null; + private $username = null; + private $pass = null; + private $url = null; + + /** + * Default constructor for calendar synchronization adapter. + * + * @param array Hash array with caldav properties at least the following: + * id: Calendar ID + * caldav_url: Caldav calendar URL. + * caldav_user: Caldav http basic auth user. + * caldav_pass: Password für caldav user. + * caldav_tag: Caldav ctag for calendar. + */ + public function __construct($cal) + { + $this->cal_id = $cal["id"]; + $this->url = $cal["caldav_url"]; + $this->ctag = isset($cal["caldav_tag"]) ? $cal["caldav_tag"] : null; + $this->username = isset($cal["caldav_user"]) ? $cal["caldav_user"] : null; + $this->pass = isset($cal["caldav_pass"]) ? $cal["caldav_pass"] : null; + + $this->caldav = new caldav_client($this->url, $this->username, $this->pass); + } + + /** + * Getter for current calendar ctag. + * @return string + */ + public function get_ctag() + { + return $this->ctag; + } + + /** + * Determines whether current calendar needs to be synced + * regarding the CalDAV ctag. + * + * @return True if the current calendar ctag differs from the CalDAV tag which + * indicates that there are changes that must be synched. Returns false + * if the calendar is up to date, no sync necesarry. + */ + public function is_synced() + { + $is_synced = $this->ctag == $this->caldav->get_ctag() && $this->ctag; + caldav_driver::debug_log("Ctag indicates that calendar \"$this->cal_id\" ".($is_synced ? "is synced." : "needs update!")); + + return $is_synced; + } + + /** + * Synchronizes given events with caldav server and returns updates. + * + * @param array List of hash arrays with event properties, must include "caldav_url" and "tag". + * @return array Tuple containing the following lists: + * + * Caldav properties for events to be created or to be updated with the keys: + * url: Event ical URL relative to calendar URL + * etag: Remote etag of the event + * local_event: The local event in case of an update. + * remote_event: The current event retrieved from caldav server. + * + * A list of event ids that are in sync. + */ + public function get_updates($events) + { + $ctag = $this->caldav->get_ctag(); + + if($ctag) + { + $this->ctag = $ctag; + $etags = $this->caldav->get_etags(); + + list($updates, $synced_event_ids) = $this->_get_event_updates($events, $etags); + return array($this->_get_event_data($updates), $synced_event_ids); + } + else + { + caldav_driver::debug_log("Unkown error while fetching calendar ctag for calendar \"$this->cal_id\"!"); + } + + return null; + } + + /** + * Determines sync status and requried updates for the given events using given list of etags. + * + * @param array List of hash arrays with event properties, must include "caldav_url" and "caldav_tag". + * @param array List of current remote etags. + * @return array Tuple containing the following lists: + * + * Caldav properties for events to be created or to be updated with the keys: + * url: Event ical URL relative to calendar URL + * etag: Remote etag of the event + * local_event: The local event in case of an update. + * + * A list of event ids that are in sync. + */ + private function _get_event_updates($events, $etags) + { + $updates = array(); + $in_sync = array(); + + foreach ($etags as $etag) + { + $url = $etag["url"]; + $etag = $etag["etag"]; + $event_found = false; + foreach($events as $event) + { + if ($event["caldav_url"] == $url) + { + $event_found = true; + + if ($event["caldav_tag"] != $etag) + { + caldav_driver::debug_log("Event ".$event["uid"]." needs update."); + + array_push($updates, array( + "local_event" => $event, + "etag" => $etag, + "url" => $url + )); + } + else + { + array_push($in_sync, $event["id"]); + } + } + } + + if (!$event_found) + { + caldav_driver::debug_log("Found new event ".$url); + + array_push($updates, array( + "url" => $url, + "etag" => $etag + )); + } + } + + return array($updates, $in_sync); + } + + /** + * Fetches event data and attaches it to the given update properties. + * + * @param $updates List of update properties. + * @return array List of update properties with additional key "remote_event" containing the current caldav event. + */ + private function _get_event_data($updates) + { + $urls = array(); + + foreach ($updates as $update) + { + array_push($urls, $update["url"]); + } + + $events = $this->caldav->get_events($urls); + foreach($updates as &$update) + { + // Attach remote events to the appropriate updates. + // Note that this assumes unique event URL's! + $url = $update["url"]; + if($events[$url]) { + $update["remote_event"] = $events[$url]; + $update["remote_event"]["calendar"] = $this->cal_id; + } + } + + return $updates; + } + + /** + * Creates the given event on the CalDAV server. + * + * @param array Hash array with event properties. + * @return Event with updated "caldav_url" and "caldav_tag" attributes, false on error. + */ + public function create_event($event) + { + $props = array( + "caldav_url" => parse_url($this->url, PHP_URL_PATH)."/".$event["uid"].".ics", + "caldav_tag" => null + ); + + caldav_driver::debug_log("Push new event to url ".$props["caldav_url"]); + $result = $this->caldav->put_event($props["caldav_url"], $event); + + if($result == false || $result < 0) return false; + return array_merge($event, $props); + } + + /** + * Updates the given event on the CalDAV server. + * + * @param array Hash array with event properties to update, must include "uid", "caldav_url" and "caldav_tag". + * @return True on success, false on error, -1 if the given event/etag is not up to date. + */ + public function update_event($event) + { + caldav_driver::debug_log("Updating event uid \"".$event["uid"]."\"."); + return $this->caldav->put_event($event["caldav_url"], $event, $event["caldav_tag"]); + } + + /** + * Removes the given event from the caldav server. + * + * @param array Hash array with events properties, must include "caldav_url". + * @return True on success, false on error. + */ + public function remove_event($event) + { + caldav_driver::debug_log("Removing event uid \"".$event["uid"]."\"."); + return $this->caldav->remove_event($event["caldav_url"]); + } +}; +?>