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');
224 $calitem_params[
':first_instance_start'] = isset($range->from) ? $range->from->UTC() : null;
225 $calitem_params[
':last_instance_end'] = isset($range->until) ? $range->until->UTC() : null;
227 if ( $create_resource ) {
229 INSERT INTO calendar_item (
user_no,
dav_name, dav_id, dav_etag, uid, dtstamp,
230 dtstart, dtend, summary, location,
class, transp,
231 description, rrule, tz_id, last_modified,
url, priority,
233 first_instance_start, last_instance_end )
234 VALUES ( :
user_no, :
dav_name, currval(
'dav_id_seq'), :etag, :uid, :dtstamp,
235 :dtstart, $dtend, :summary, :location, :
class, :transp,
236 :description, :rrule, :tzid, :modified, :
url, :priority,
237 :created, :due, :percent_complete, :status, $collection_id,
238 :first_instance_start, :last_instance_end)
244 UPDATE calendar_item SET dav_etag=:etag, uid=:uid, dtstamp=:dtstamp,
245 dtstart=:dtstart, dtend=$dtend, summary=:summary, location=:location,
class=:
class, transp=:transp,
246 description=:description, rrule=:rrule, tz_id=:tzid, last_modified=:modified,
url=:
url, priority=:priority,
247 created=:created, due=:due, percent_complete=:percent_complete, status=:status,
248 first_instance_start=:first_instance_start, last_instance_end=:last_instance_end
257 $put_action_type = ($create_resource ?
'INSERT' :
'UPDATE');
258 if ( $log_action && function_exists(
'log_caldav_action') ) {
259 log_caldav_action( $put_action_type, $first->GetPValue(
'UID'), $user_no, $collection_id, $path );
261 else if ( $log_action ) {
262 dbg_error_log(
'PUT',
'No log_caldav_action( %s, %s, %s, %s, %s) can be called.',
263 $put_action_type, $first->GetPValue(
'UID'), $user_no, $collection_id, $path );
267 $qry =
new AwlQuery( $sql, $calitem_params );
268 if ( !$qry->Exec(
'PUT',__LINE__,__FILE__) ) {
269 rollback_on_error( $caldav_context, $user_no, $path);
272 $qry->QDo(
"SELECT write_sync_change( $collection_id, $sync_change, :dav_name)", array(
':dav_name' => $path ) );
273 if ( $existing_transaction_state == 0 ) $qry->Commit();
275 dbg_error_log(
'PUT',
'User: %d, ETag: %s, Path: %s', $session->user_no, $etag, $path);
278 return $segment_name;
296 function WriteMember( $resource, $create_resource, $segment_name = null, $log_action=
true ) {
298 dbg_error_log(
'PUT',
'"%s" is not a collection path', $this->
dav_name);
301 if ( ! is_object($resource) ) {
302 dbg_error_log(
'PUT',
'No data supplied!' );
306 if ( $resource instanceof vCalendar ) {
307 return $this->
WriteCalendarMember($resource,$create_resource,
true,$segment_name,$log_action);
309 else if ( $resource instanceof
VCard )
310 trace_bug(
"Calling undefined function WriteAddressbookMember!? Please report this to the davical project: davical-general@lists.sourceforge.net" );
311 return $this->WriteAddressbookMember($resource,$create_resource,$segment_name, $log_action);
313 return $segment_name;
324 $qry =
new AwlQuery(
'DELETE FROM calendar_alarm WHERE dav_id = '.$dav_id );
325 $qry->Exec(
'PUT',__LINE__,__FILE__);
327 $components = $vcal->GetComponents();
329 $qry->SetSql(
'INSERT INTO calendar_alarm ( dav_id, action, trigger, summary, description, component, next_trigger ) 330 VALUES( '.$dav_id.
', :action, :trigger, :summary, :description, :component, 331 :related::timestamp with time zone + :related_trigger::interval )' );
333 foreach( $components AS $component ) {
334 if ( $component->GetType() ==
'VTIMEZONE' )
continue;
335 $alarms = $component->GetComponents(
'VALARM');
336 if ( count($alarms) < 1 )
return;
338 foreach( $alarms AS $v ) {
339 $trigger = array_merge($v->GetProperties(
'TRIGGER'));
340 if ( $trigger == null )
continue;
341 $trigger = $trigger[0];
343 $related_trigger =
'0M';
344 $trigger_type = $trigger->GetParameterValue(
'VALUE');
345 if ( !isset($trigger_type) || $trigger_type ==
'DURATION' ) {
346 switch ( $trigger->GetParameterValue(
'RELATED') ) {
347 case 'DTEND': $related = $component->GetPValue(
'DTEND');
break;
348 case 'DUE': $related = $component->GetPValue(
'DUE');
break;
349 default: $related = $component->GetPValue(
'DTSTART');
351 $duration = $trigger->Value();
352 if ( !preg_match(
'{^-?P(:?\d+W)?(:?\d+D)?(:?T(:?\d+H)?(:?\d+M)?(:?\d+S)?)?$}', $duration ) )
continue;
353 $minus = (substr($duration,0,1) ==
'-');
354 $related_trigger = trim(preg_replace(
'#[PT-]#',
' ', $duration ));
355 if ($related_trigger ==
'') $related_trigger =
'0 seconds';
357 $related_trigger = preg_replace(
'{(\d+[WDHMS])}',
'-$1 ', $related_trigger );
360 $related_trigger = preg_replace(
'{(\d+[WDHMS])}',
'$1 ', $related_trigger );
364 if (
false === strtotime($trigger->Value()) )
continue;
366 $qry->Bind(
':action', $v->GetPValue(
'ACTION'));
367 $qry->Bind(
':trigger', $trigger->Render());
368 $qry->Bind(
':summary', $v->GetPValue(
'SUMMARY'));
369 $qry->Bind(
':description', $v->GetPValue(
'DESCRIPTION'));
370 $qry->Bind(
':component', $v->Render());
371 $qry->Bind(
':related', $related );
372 $qry->Bind(
':related_trigger', $related_trigger );
373 $qry->Exec(
'PUT',__LINE__,__FILE__);
387 $qry =
new AwlQuery(
'DELETE FROM calendar_attendee WHERE dav_id = '.$dav_id );
388 $qry->Exec(
'PUT',__LINE__,__FILE__);
390 $attendees = $vcal->GetAttendees();
391 if ( count($attendees) < 1 )
return;
393 $qry->SetSql(
'INSERT INTO calendar_attendee ( dav_id, status, partstat, cn, attendee, role, rsvp, property ) 394 VALUES( '.$dav_id.
', :status, :partstat, :cn, :attendee, :role, :rsvp, :property )' );
396 $processed = array();
397 foreach( $attendees AS $v ) {
398 $attendee = $v->Value();
399 if ( isset($processed[$attendee]) ) {
400 dbg_error_log(
'LOG',
'Duplicate attendee "%s" in resource "%d"', $attendee, $dav_id );
401 dbg_error_log(
'LOG',
'Original: "%s"', $processed[$attendee] );
402 dbg_error_log(
'LOG',
'Duplicate: "%s"', $v->Render() );
405 $qry->Bind(
':attendee', $attendee );
406 $qry->Bind(
':status', $v->GetParameterValue(
'STATUS') );
407 $qry->Bind(
':partstat', $v->GetParameterValue(
'PARTSTAT') );
408 $qry->Bind(
':cn', $v->GetParameterValue(
'CN') );
409 $qry->Bind(
':role', $v->GetParameterValue(
'ROLE') );
410 $qry->Bind(
':rsvp', $v->GetParameterValue(
'RSVP') );
411 $qry->Bind(
':property', $v->Render() );
412 $qry->Exec(
'PUT',__LINE__,__FILE__);
413 $processed[$attendee] = $v->Render();
425 global $session, $caldav_context;
428 $segment_name = str_replace( $this->
dav_name(),
'', $member_dav_name );
429 if ( strstr($segment_name,
'/') !==
false ) {
430 @dbg_error_log(
"DELETE",
"DELETE: Refused to delete member '%s' from calendar '%s'!", $member_dav_name, $this->
dav_name() );
435 $cache = getCacheInstance();
436 $myLock = $cache->acquireLock(
'collection-'.$this->
dav_name());
438 $qry =
new AwlQuery();
439 $params = array(
':dav_name' => $member_dav_name );
441 if ( $qry->QDo(
"SELECT write_sync_change(collection_id, 404, caldav_data.dav_name) FROM caldav_data WHERE dav_name = :dav_name", $params )
442 && $qry->QDo(
"DELETE FROM property WHERE dav_name = :dav_name", $params )
443 && $qry->QDo(
"DELETE FROM locks WHERE dav_name = :dav_name", $params )
444 && $qry->QDo(
"DELETE FROM caldav_data WHERE dav_name = :dav_name", $params ) ) {
445 @dbg_error_log(
"DELETE",
"DELETE: Calendar member %s deleted from calendar '%s'", $member_dav_name, $this->
dav_name() );
447 $cache->releaseLock($myLock);
452 $cache->releaseLock($myLock);
463 $params = array(
':collection_id' => $this->
collection_id() );
464 if ( $some_old_token == 0 || empty($some_old_token) ) {
466 SELECT calendar_item.*, caldav_data.*, addressbook_resource.*, 201 AS sync_status,
467 COALESCE(addressbook_resource.uid,calendar_item.uid) AS uid
469 LEFT JOIN calendar_item USING (dav_id)
470 LEFT JOIN addressbook_resource USING (dav_id)
472 ORDER BY caldav_data.collection_id, caldav_data.dav_id
476 $params[
':sync_token'] = $some_old_token;
478 SELECT calendar_item.*, caldav_data.*, addressbook_resource.*, sync_changes.*,
479 COALESCE(addressbook_resource.uid,calendar_item.uid) AS uid
483 LEFT JOIN addressbook_resource USING (dav_id)
486 ORDER BY sync_changes.collection_id, sync_changes.dav_id, sync_changes.sync_time
490 $qry =
new AwlQuery($sql, $params );
493 if ( $qry->Exec(
'WritableCollection') && $qry->rows() ) {
494 while( $change = $qry->Fetch() ) {
495 $changes[$change->uid] = $change;
WriteCalendarAlarms( $dav_id, vCalendar $vcal)
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)
whatChangedSince( $some_old_token)
sync_token( $cachedOK=true)
actualDeleteCalendarMember( $member_dav_name)
WriteCalendarAttendees( $dav_id, vCalendar $vcal)