DAViCal
 All Classes Namespaces Functions Variables Pages
WritableCollection.php
1 <?php
2 include_once('DAVResource.php');
3 
5 
11  private static function GetTZID( vComponent $comp ) {
12  $p = $comp->GetProperty('DTSTART');
13  if ( !isset($p) && $comp->GetType() == 'VTODO' ) {
14  $p = $comp->GetProperty('DUE');
15  }
16  if ( !isset($p) ) return null;
17  return $p->GetParameterValue('TZID');
18  }
19 
33  function WriteCalendarMember( vCalendar $vcal, $create_resource, $do_scheduling=false, $segment_name = null, $log_action=false ) {
34  if ( !$this->IsSchedulingCollection() && !$this->IsCalendar() ) {
35  dbg_error_log( 'PUT', '"%s" is not a calendar or scheduling collection!', $this->dav_name);
36  return false;
37  }
38 
39  global $session, $caldav_context;
40 
41  $resources = $vcal->GetComponents('VTIMEZONE',false); // Not matching VTIMEZONE
42  $user_no = $this->user_no();
43  $collection_id = $this->collection_id();
44 
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 );
48  return false;
49  }
50  else {
51  $first = $resources[0];
52  $resource_type = $first->GetType();
53  }
54 
55  $uid = $vcal->GetUID();
56  if ( empty($segment_name) ) {
57  $segment_name = $uid.'.ics';
58  }
59  $path = $this->dav_name() . $segment_name;
60 
61  $caldav_data = $vcal->Render();
62  $etag = md5($caldav_data);
63  $weak_etag = null;
64 
65  $qry = new AwlQuery();
66  $existing_transaction_state = $qry->TransactionState();
67  if ( $existing_transaction_state == 0 ) $qry->Begin();
68 
69 
70  if ( $create_resource ) {
71  $qry->QDo('SELECT nextval(\'dav_id_seq\') AS dav_id');
72  }
73  else {
74  $qry->QDo('SELECT dav_id FROM caldav_data WHERE dav_name = :dav_name ', array(':dav_name' => $path));
75  }
76  if ( $qry->rows() != 1 || !($row = $qry->Fetch()) ) {
77  if ( !$create_resource ) {
78  // Looks like we will have to create it, even if the caller thought we wouldn't
79  $qry->QDo('SELECT nextval(\'dav_id_seq\') AS dav_id');
80  if ( $qry->rows() != 1 || !($row = $qry->Fetch()) ) {
81  // No dav_id? => We're toast!
82  trace_bug( 'No dav_id for "%s" on %s!!!', $path, ($create_resource ? 'create': 'update'));
83  rollback_on_error( $caldav_context, $user_no, $path);
84  return false;
85  }
86  $create_resource = true;
87  dbg_error_log( 'PUT', 'Unexpected need to create resource at "%s"', $path);
88  }
89  }
90  $dav_id = $row->dav_id;
91 
92  $calitem_params = array(
93  ':dav_name' => $path,
94  ':user_no' => $user_no,
95  ':etag' => $etag,
96  ':dav_id' => $dav_id
97  );
98 
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
104  ) );
105 
106  if ( !$this->IsSchedulingCollection() && $do_scheduling ) {
107  if ( do_scheduling_requests($vcal, $create_resource ) ) {
108  $dav_params[':dav_data'] = $vcal->Render(null, true);
109  $etag = null;
110  }
111  }
112 
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;
117  }
118  else {
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';
121  }
122  if ( !$qry->QDo($sql,$dav_params) ) {
123  rollback_on_error( $caldav_context, $user_no, $path);
124  return false;
125  }
126 
127  $dtstart = $first->GetPValue('DTSTART');
128  $calitem_params[':dtstart'] = $dtstart;
129  if ( (!isset($dtstart) || $dtstart == '') && $first->GetPValue('DUE') != '' ) {
130  $dtstart = $first->GetPValue('DUE');
131  }
132 
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;
137  $dtend = ':dtend';
138  }
139  else {
140  $dtend = 'NULL';
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;
146  }
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)';
165  else
166  $dtend = ':dtstart';
167  }
168  }
169 
170  $last_modified = $first->GetPValue('LAST-MODIFIED');
171  if ( !isset($last_modified) || $last_modified == '' ) {
172  $last_modified = gmdate( 'Ymd\THis\Z' );
173  }
174  $calitem_params[':modified'] = $last_modified;
175 
176  $dtstamp = $first->GetPValue('DTSTAMP');
177  if ( !isset($dtstamp) || $dtstamp == '' ) {
178  $dtstamp = $last_modified;
179  }
180  $calitem_params[':dtstamp'] = $dtstamp;
181 
182  $class = $first->GetPValue('CLASS');
183  /*
184  * It seems that some calendar clients don't set a class...
185  * RFC2445, 4.8.1.3: Default is PUBLIC
186  */
187  if ( $this->IsPublicOnly() || !isset($class) || $class == '' ) {
188  $class = 'PUBLIC';
189  }
190  $calitem_params[':class'] = $class;
191 
193  $last_olson = 'Turkmenikikamukau'; // I really hope this location doesn't exist!
194  $tzid = self::GetTZID($first);
195  if ( !empty($tzid) ) {
196  $tz = $vcal->GetTimeZone($tzid);
197  $olson = $vcal->GetOlsonName($tz);
198 
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;
203  }
204  }
205 
206  $created = $first->GetPValue('CREATED');
207  if ( $created == '00001231T000000Z' ) $created = '20001231T000000Z';
208  $calitem_params[':created'] = $created;
209 
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 ) {
223  $sql = <<<EOSQL
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,
227  created, due, percent_complete, status, collection_id )
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 )
232 EOSQL;
233  $sync_change = 201;
234  }
235  else {
236  $sql = <<<EOSQL
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
241  WHERE user_no=:user_no AND dav_name=:dav_name
242 EOSQL;
243  $sync_change = 200;
244  }
245 
246  if ( !$this->IsSchedulingCollection() ) {
247  $this->WriteCalendarAlarms($dav_id, $vcal);
248  $this->WriteCalendarAttendees($dav_id, $vcal);
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 );
252  }
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 );
256  }
257  }
258 
259  $qry = new AwlQuery( $sql, $calitem_params );
260  if ( !$qry->Exec('PUT',__LINE__,__FILE__) ) {
261  rollback_on_error( $caldav_context, $user_no, $path);
262  return false;
263  }
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();
266 
267  dbg_error_log( 'PUT', 'User: %d, ETag: %s, Path: %s', $session->user_no, $etag, $path);
268 
269 
270  return $segment_name;
271  }
272 
288  function WriteMember( $resource, $create_resource, $segment_name = null, $log_action=true ) {
289  if ( ! $this->IsCollection() ) {
290  dbg_error_log( 'PUT', '"%s" is not a collection path', $this->dav_name);
291  return false;
292  }
293  if ( ! is_object($resource) ) {
294  dbg_error_log( 'PUT', 'No data supplied!' );
295  return false;
296  }
297 
298  if ( $resource instanceof vCalendar ) {
299  return $this->WriteCalendarMember($resource,$create_resource,true,$segment_name,$log_action);
300  }
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);
304 
305  return $segment_name;
306  }
307 
308 
315  function WriteCalendarAlarms( $dav_id, vCalendar $vcal ) {
316  $qry = new AwlQuery('DELETE FROM calendar_alarm WHERE dav_id = '.$dav_id );
317  $qry->Exec('PUT',__LINE__,__FILE__);
318 
319  $components = $vcal->GetComponents();
320 
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 )' );
324  $qry->Prepare();
325  foreach( $components AS $component ) {
326  if ( $component->GetType() == 'VTIMEZONE' ) continue;
327  $alarms = $component->GetComponents('VALARM');
328  if ( count($alarms) < 1 ) return;
329 
330  foreach( $alarms AS $v ) {
331  $trigger = array_merge($v->GetProperties('TRIGGER'));
332  if ( $trigger == null ) continue; // Bogus data.
333  $trigger = $trigger[0];
334  $related = null;
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');
342  }
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';
348  if ( $minus ) {
349  $related_trigger = preg_replace( '{(\d+[WDHMS])}', '-$1 ', $related_trigger );
350  }
351  else {
352  $related_trigger = preg_replace( '{(\d+[WDHMS])}', '$1 ', $related_trigger );
353  }
354  }
355  else {
356  if ( false === strtotime($trigger->Value()) ) continue; // Invalid date.
357  }
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__);
366  }
367  }
368  }
369 
370 
378  function WriteCalendarAttendees( $dav_id, vCalendar $vcal ) {
379  $qry = new AwlQuery('DELETE FROM calendar_attendee WHERE dav_id = '.$dav_id );
380  $qry->Exec('PUT',__LINE__,__FILE__);
381 
382  $attendees = $vcal->GetAttendees();
383  if ( count($attendees) < 1 ) return;
384 
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 )' );
387  $qry->Prepare();
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() );
395  continue;
396  }
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();
406  }
407  }
408 
416  function actualDeleteCalendarMember( $member_dav_name ) {
417  global $session, $caldav_context;
418 
419  // A quick sanity check...
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() );
423  return false;
424  }
425 
426  // We need to serialise access to this process just for this collection
427  $cache = getCacheInstance();
428  $myLock = $cache->acquireLock('collection-'.$this->dav_name());
429 
430  $qry = new AwlQuery();
431  $params = array( ':dav_name' => $member_dav_name );
432 
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() );
438 
439  $cache->releaseLock($myLock);
440 
441  return true;
442  }
443 
444  $cache->releaseLock($myLock);
445  return false;
446 
447  }
448 
449 
454  public function whatChangedSince( $some_old_token ) {
455  $params = array( ':collection_id' => $this->collection_id() );
456  if ( $some_old_token == 0 || empty($some_old_token) ) {
457  $sql = <<<EOSQL
458  SELECT calendar_item.*, caldav_data.*, addressbook_resource.*, 201 AS sync_status,
459  COALESCE(addressbook_resource.uid,calendar_item.uid) AS uid
460  FROM caldav_data
461  LEFT JOIN calendar_item USING (dav_id)
462  LEFT JOIN addressbook_resource USING (dav_id)
463  WHERE caldav_data.collection_id = :collection_id
464  ORDER BY caldav_data.collection_id, caldav_data.dav_id
465 EOSQL;
466  }
467  else {
468  $params[':sync_token'] = $some_old_token;
469  $sql = <<<EOSQL
470  SELECT calendar_item.*, caldav_data.*, addressbook_resource.*, sync_changes.*,
471  COALESCE(addressbook_resource.uid,calendar_item.uid) AS uid
472  FROM sync_changes
473  LEFT JOIN caldav_data USING (collection_id,dav_id)
474  LEFT JOIN calendar_item USING (collection_id,dav_id)
475  LEFT JOIN addressbook_resource USING (dav_id)
476  WHERE sync_changes.collection_id = :collection_id
477  AND sync_time >= (SELECT modification_time FROM sync_tokens WHERE sync_token = :sync_token)
478  ORDER BY sync_changes.collection_id, sync_changes.dav_id, sync_changes.sync_time
479 EOSQL;
480 
481  }
482  $qry = new AwlQuery($sql, $params );
483 
484  $changes = array();
485  if ( $qry->Exec('WritableCollection') && $qry->rows() ) {
486  while( $change = $qry->Fetch() ) {
487  $changes[$change->uid] = $change;
488  }
489  }
490 
491  return $changes;
492  }
493 }
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)
Definition: vcard.php:9
WriteCalendarAlarms($dav_id, vCalendar $vcal)