2 include_once(
'DAVResource.php');
11 private static function GetTZID( vComponent $comp ) {
12 $p = $comp->GetProperty(
'DTSTART');
13 if ( !isset($p) && $comp->GetType() ==
'VTODO' ) {
14 $p = $comp->GetProperty(
'DUE');
16 if ( !isset($p) )
return null;
17 return $p->GetParameterValue(
'TZID');
33 function WriteCalendarMember( vCalendar $vcal, $create_resource, $do_scheduling=
false, $segment_name = null, $log_action=
false ) {
35 dbg_error_log(
'PUT',
'"%s" is not a calendar or scheduling collection!', $this->
dav_name);
39 global $session, $caldav_context;
41 $resources = $vcal->GetComponents(
'VTIMEZONE',
false);
45 if ( !isset($resources[0]) ) {
46 dbg_error_log(
'PUT',
'No calendar content!');
47 rollback_on_error( $caldav_context, $user_no, $this->
dav_name.
'/'.$segment_name, translate(
'No calendar content'), 412 );
51 $first = $resources[0];
52 $resource_type = $first->GetType();
55 $uid = $vcal->GetUID();
56 if ( empty($segment_name) ) {
57 $segment_name = $uid.
'.ics';
59 $path = $this->
dav_name() . $segment_name;
61 $caldav_data = $vcal->Render();
62 $etag = md5($caldav_data);
65 $qry =
new AwlQuery();
66 $existing_transaction_state = $qry->TransactionState();
67 if ( $existing_transaction_state == 0 ) $qry->Begin();
70 if ( $create_resource ) {
71 $qry->QDo(
'SELECT nextval(\'dav_id_seq\') AS dav_id');
74 $qry->QDo(
'SELECT dav_id FROM caldav_data WHERE dav_name = :dav_name ', array(
':dav_name' => $path));
76 if ( $qry->rows() != 1 || !($row = $qry->Fetch()) ) {
77 if ( !$create_resource ) {
79 $qry->QDo(
'SELECT nextval(\'dav_id_seq\') AS dav_id');
80 if ( $qry->rows() != 1 || !($row = $qry->Fetch()) ) {
82 trace_bug(
'No dav_id for "%s" on %s!!!', $path, ($create_resource ?
'create':
'update'));
83 rollback_on_error( $caldav_context, $user_no, $path);
86 $create_resource =
true;
87 dbg_error_log(
'PUT',
'Unexpected need to create resource at "%s"', $path);
90 $dav_id = $row->dav_id;
92 $calitem_params = array(
94 ':user_no' => $user_no,
99 $dav_params = array_merge($calitem_params, array(
100 ':dav_data' => $caldav_data,
101 ':caldav_type' => $resource_type,
102 ':session_user' => $session->user_no,
103 ':weak_etag' => $weak_etag
107 if ( do_scheduling_requests($vcal, $create_resource ) ) {
108 $dav_params[
':dav_data'] = $vcal->Render(null,
true);
113 if ( $create_resource ) {
114 $sql =
'INSERT INTO caldav_data ( dav_id, user_no, dav_name, dav_etag, caldav_data, caldav_type, logged_user, created, modified, collection_id, weak_etag )
115 VALUES( :dav_id, :user_no, :dav_name, :etag, :dav_data, :caldav_type, :session_user, current_timestamp, current_timestamp, :collection_id, :weak_etag )';
116 $dav_params[
':collection_id'] = $collection_id;
119 $sql =
'UPDATE caldav_data SET caldav_data=:dav_data, dav_etag=:etag, caldav_type=:caldav_type, logged_user=:session_user,
120 modified=current_timestamp, weak_etag=:weak_etag WHERE dav_id=:dav_id';
122 if ( !$qry->QDo($sql,$dav_params) ) {
123 rollback_on_error( $caldav_context, $user_no, $path);
127 $dtstart = $first->GetPValue(
'DTSTART');
128 $calitem_params[
':dtstart'] = $dtstart;
129 if ( (!isset($dtstart) || $dtstart ==
'') && $first->GetPValue(
'DUE') !=
'' ) {
130 $dtstart = $first->GetPValue(
'DUE');
133 $dtend = $first->GetPValue(
'DTEND');
134 if ( isset($dtend) && $dtend !=
'' ) {
135 dbg_error_log(
'PUT',
' DTEND: "%s", DTSTART: "%s", DURATION: "%s"', $dtend, $dtstart, $first->GetPValue(
'DURATION') );
136 $calitem_params[
':dtend'] = $dtend;
141 if ( $first->GetPValue(
'DURATION') !=
'' AND $dtstart !=
'' ) {
142 $duration = preg_replace(
'#[PT]#',
'', $first->GetPValue(
'DURATION') );
143 if ($duration ==
'') $duration =
'0 seconds';
144 $dtend =
'(:dtstart::timestamp with time zone + :duration::interval)';
145 $calitem_params[
':duration'] = $duration;
147 elseif ( $first->GetType() ==
'VEVENT' ) {
161 $value_type = $first->GetProperty(
'DTSTART')->GetParameterValue(
'VALUE');
162 dbg_error_log(
'PUT',
'DTSTART without DTEND. DTSTART value type is %s', $value_type );
163 if ( isset($value_type) && $value_type ==
'DATE' )
164 $dtend =
'(:dtstart::timestamp with time zone::date + \'1 day\'::interval)';
170 $last_modified = $first->GetPValue(
'LAST-MODIFIED');
171 if ( !isset($last_modified) || $last_modified ==
'' ) {
172 $last_modified = gmdate(
'Ymd\THis\Z' );
174 $calitem_params[
':modified'] = $last_modified;
176 $dtstamp = $first->GetPValue(
'DTSTAMP');
177 if ( !isset($dtstamp) || $dtstamp ==
'' ) {
178 $dtstamp = $last_modified;
180 $calitem_params[
':dtstamp'] = $dtstamp;
182 $class = $first->GetPValue(
'CLASS');
187 if ( $this->
IsPublicOnly() || !isset($class) || $class ==
'' ) {
190 $calitem_params[
':class'] = $class;
193 $last_olson =
'Turkmenikikamukau';
194 $tzid = self::GetTZID($first);
195 if ( !empty($tzid) ) {
196 $tz = $vcal->GetTimeZone($tzid);
197 $olson = $vcal->GetOlsonName($tz);
199 if ( !empty($olson) && ($olson != $last_olson) ) {
200 dbg_error_log(
'PUT',
' Setting timezone to %s', $olson );
201 $qry->QDo(
'SET TIMEZONE TO \''.$olson.
"'" );
202 $last_olson = $olson;
206 $created = $first->GetPValue(
'CREATED');
207 if ( $created ==
'00001231T000000Z' ) $created =
'20001231T000000Z';
208 $calitem_params[
':created'] = $created;
210 $calitem_params[
':tzid'] = $tzid;
211 $calitem_params[
':uid'] = $uid;
212 $calitem_params[
':summary'] = $first->GetPValue(
'SUMMARY');
213 $calitem_params[
':location'] = $first->GetPValue(
'LOCATION');
214 $calitem_params[
':transp'] = $first->GetPValue(
'TRANSP');
215 $calitem_params[
':description'] = $first->GetPValue(
'DESCRIPTION');
216 $calitem_params[
':rrule'] = $first->GetPValue(
'RRULE');
217 $calitem_params[
':url'] = $first->GetPValue(
'URL');
218 $calitem_params[
':priority'] = $first->GetPValue(
'PRIORITY');
219 $calitem_params[
':due'] = $first->GetPValue(
'DUE');
220 $calitem_params[
':percent_complete'] = $first->GetPValue(
'PERCENT-COMPLETE');
221 $calitem_params[
':status'] = $first->GetPValue(
'STATUS');
222 if ( $create_resource ) {
224 INSERT INTO calendar_item (
user_no,
dav_name, dav_id, dav_etag, uid, dtstamp,
225 dtstart, dtend, summary, location,
class, transp,
226 description, rrule, tz_id, last_modified,
url, priority,
228 VALUES ( :
user_no, :
dav_name, currval(
'dav_id_seq'), :etag, :uid, :dtstamp,
229 :dtstart, $dtend, :summary, :location, :
class, :transp,
230 :description, :rrule, :tzid, :modified, :
url, :priority,
231 :created, :due, :percent_complete, :status, $collection_id )
237 UPDATE calendar_item SET dav_etag=:etag, uid=:uid, dtstamp=:dtstamp,
238 dtstart=:dtstart, dtend=$dtend, summary=:summary, location=:location,
class=:
class, transp=:transp,
239 description=:description, rrule=:rrule, tz_id=:tzid, last_modified=:modified,
url=:
url, priority=:priority,
240 created=:created, due=:due, percent_complete=:percent_complete, status=:status
249 $put_action_type = ($create_resource ?
'INSERT' :
'UPDATE');
250 if ( $log_action && function_exists(
'log_caldav_action') ) {
251 log_caldav_action( $put_action_type, $first->GetPValue(
'UID'), $user_no, $collection_id, $path );
253 else if ( $log_action ) {
254 dbg_error_log(
'PUT',
'No log_caldav_action( %s, %s, %s, %s, %s) can be called.',
255 $put_action_type, $first->GetPValue(
'UID'), $user_no, $collection_id, $path );
259 $qry =
new AwlQuery( $sql, $calitem_params );
260 if ( !$qry->Exec(
'PUT',__LINE__,__FILE__) ) {
261 rollback_on_error( $caldav_context, $user_no, $path);
264 $qry->QDo(
"SELECT write_sync_change( $collection_id, $sync_change, :dav_name)", array(
':dav_name' => $path ) );
265 if ( $existing_transaction_state == 0 ) $qry->Commit();
267 dbg_error_log(
'PUT',
'User: %d, ETag: %s, Path: %s', $session->user_no, $etag, $path);
270 return $segment_name;
288 function WriteMember( $resource, $create_resource, $segment_name = null, $log_action=
true ) {
290 dbg_error_log(
'PUT',
'"%s" is not a collection path', $this->
dav_name);
293 if ( ! is_object($resource) ) {
294 dbg_error_log(
'PUT',
'No data supplied!' );
298 if ( $resource instanceof vCalendar ) {
299 return $this->
WriteCalendarMember($resource,$create_resource,
true,$segment_name,$log_action);
301 else if ( $resource instanceof
VCard )
302 trace_bug(
"Calling undefined function WriteAddressbookMember!? Please report this to the davical project: davical-general@lists.sourceforge.net" );
303 return $this->WriteAddressbookMember($resource,$create_resource,$segment_name, $log_action);
305 return $segment_name;
316 $qry =
new AwlQuery(
'DELETE FROM calendar_alarm WHERE dav_id = '.$dav_id );
317 $qry->Exec(
'PUT',__LINE__,__FILE__);
319 $components = $vcal->GetComponents();
321 $qry->SetSql(
'INSERT INTO calendar_alarm ( dav_id, action, trigger, summary, description, component, next_trigger )
322 VALUES( '.$dav_id.
', :action, :trigger, :summary, :description, :component,
323 :related::timestamp with time zone + :related_trigger::interval )' );
325 foreach( $components AS $component ) {
326 if ( $component->GetType() ==
'VTIMEZONE' )
continue;
327 $alarms = $component->GetComponents(
'VALARM');
328 if ( count($alarms) < 1 )
return;
330 foreach( $alarms AS $v ) {
331 $trigger = array_merge($v->GetProperties(
'TRIGGER'));
332 if ( $trigger == null )
continue;
333 $trigger = $trigger[0];
335 $related_trigger =
'0M';
336 $trigger_type = $trigger->GetParameterValue(
'VALUE');
337 if ( !isset($trigger_type) || $trigger_type ==
'DURATION' ) {
338 switch ( $trigger->GetParameterValue(
'RELATED') ) {
339 case 'DTEND': $related = $component->GetPValue(
'DTEND');
break;
340 case 'DUE': $related = $component->GetPValue(
'DUE');
break;
341 default: $related = $component->GetPValue(
'DTSTART');
343 $duration = $trigger->Value();
344 if ( !preg_match(
'{^-?P(:?\d+W)?(:?\d+D)?(:?T(:?\d+H)?(:?\d+M)?(:?\d+S)?)?$}', $duration ) )
continue;
345 $minus = (substr($duration,0,1) ==
'-');
346 $related_trigger = trim(preg_replace(
'#[PT-]#',
' ', $duration ));
347 if ($related_trigger ==
'') $related_trigger =
'0 seconds';
349 $related_trigger = preg_replace(
'{(\d+[WDHMS])}',
'-$1 ', $related_trigger );
352 $related_trigger = preg_replace(
'{(\d+[WDHMS])}',
'$1 ', $related_trigger );
356 if (
false === strtotime($trigger->Value()) )
continue;
358 $qry->Bind(
':action', $v->GetPValue(
'ACTION'));
359 $qry->Bind(
':trigger', $trigger->Render());
360 $qry->Bind(
':summary', $v->GetPValue(
'SUMMARY'));
361 $qry->Bind(
':description', $v->GetPValue(
'DESCRIPTION'));
362 $qry->Bind(
':component', $v->Render());
363 $qry->Bind(
':related', $related );
364 $qry->Bind(
':related_trigger', $related_trigger );
365 $qry->Exec(
'PUT',__LINE__,__FILE__);
379 $qry =
new AwlQuery(
'DELETE FROM calendar_attendee WHERE dav_id = '.$dav_id );
380 $qry->Exec(
'PUT',__LINE__,__FILE__);
382 $attendees = $vcal->GetAttendees();
383 if ( count($attendees) < 1 )
return;
385 $qry->SetSql(
'INSERT INTO calendar_attendee ( dav_id, status, partstat, cn, attendee, role, rsvp, property )
386 VALUES( '.$dav_id.
', :status, :partstat, :cn, :attendee, :role, :rsvp, :property )' );
388 $processed = array();
389 foreach( $attendees AS $v ) {
390 $attendee = $v->Value();
391 if ( isset($processed[$attendee]) ) {
392 dbg_error_log(
'LOG',
'Duplicate attendee "%s" in resource "%d"', $attendee, $dav_id );
393 dbg_error_log(
'LOG',
'Original: "%s"', $processed[$attendee] );
394 dbg_error_log(
'LOG',
'Duplicate: "%s"', $v->Render() );
397 $qry->Bind(
':attendee', $attendee );
398 $qry->Bind(
':status', $v->GetParameterValue(
'STATUS') );
399 $qry->Bind(
':partstat', $v->GetParameterValue(
'PARTSTAT') );
400 $qry->Bind(
':cn', $v->GetParameterValue(
'CN') );
401 $qry->Bind(
':role', $v->GetParameterValue(
'ROLE') );
402 $qry->Bind(
':rsvp', $v->GetParameterValue(
'RSVP') );
403 $qry->Bind(
':property', $v->Render() );
404 $qry->Exec(
'PUT',__LINE__,__FILE__);
405 $processed[$attendee] = $v->Render();
417 global $session, $caldav_context;
420 $segment_name = str_replace( $this->
dav_name(),
'', $member_dav_name );
421 if ( strstr($segment_name,
'/') !==
false ) {
422 @dbg_error_log(
"DELETE",
"DELETE: Refused to delete member '%s' from calendar '%s'!", $member_dav_name, $this->
dav_name() );
427 $cache = getCacheInstance();
428 $myLock = $cache->acquireLock(
'collection-'.$this->
dav_name());
430 $qry =
new AwlQuery();
431 $params = array(
':dav_name' => $member_dav_name );
433 if ( $qry->QDo(
"SELECT write_sync_change(collection_id, 404, caldav_data.dav_name) FROM caldav_data WHERE dav_name = :dav_name", $params )
434 && $qry->QDo(
"DELETE FROM property WHERE dav_name = :dav_name", $params )
435 && $qry->QDo(
"DELETE FROM locks WHERE dav_name = :dav_name", $params )
436 && $qry->QDo(
"DELETE FROM caldav_data WHERE dav_name = :dav_name", $params ) ) {
437 @dbg_error_log(
"DELETE",
"DELETE: Calendar member %s deleted from calendar '%s'", $member_dav_name, $this->
dav_name() );
439 $cache->releaseLock($myLock);
444 $cache->releaseLock($myLock);
455 $params = array(
':collection_id' => $this->
collection_id() );
456 if ( $some_old_token == 0 || empty($some_old_token) ) {
458 SELECT calendar_item.*, caldav_data.*, addressbook_resource.*, 201 AS sync_status,
459 COALESCE(addressbook_resource.uid,calendar_item.uid) AS uid
461 LEFT JOIN calendar_item USING (dav_id)
462 LEFT JOIN addressbook_resource USING (dav_id)
464 ORDER BY caldav_data.collection_id, caldav_data.dav_id
468 $params[
':sync_token'] = $some_old_token;
470 SELECT calendar_item.*, caldav_data.*, addressbook_resource.*, sync_changes.*,
471 COALESCE(addressbook_resource.uid,calendar_item.uid) AS uid
475 LEFT JOIN addressbook_resource USING (dav_id)
478 ORDER BY sync_changes.collection_id, sync_changes.dav_id, sync_changes.sync_time
482 $qry =
new AwlQuery($sql, $params );
485 if ( $qry->Exec(
'WritableCollection') && $qry->rows() ) {
486 while( $change = $qry->Fetch() ) {
487 $changes[$change->uid] = $change;
whatChangedSince($some_old_token)
static GetTZID(vComponent $comp)
IsSchedulingCollection($type= 'any')
WriteCalendarMember(vCalendar $vcal, $create_resource, $do_scheduling=false, $segment_name=null, $log_action=false)
WriteMember($resource, $create_resource, $segment_name=null, $log_action=true)
sync_token($cachedOK=true)
WriteCalendarAttendees($dav_id, vCalendar $vcal)
actualDeleteCalendarMember($member_dav_name)
WriteCalendarAlarms($dav_id, vCalendar $vcal)