nik/davical
1
0
Fork 0
mirror of https://gitlab.com/davical-project/davical.git synced 2026-05-24 02:24:39 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Collapse changes in sync-collection response.

Browse Source
This commit is contained in:
Andrew McMillan 2009-10-15 23:13:39 +13:00
parent 2ab1e94ecb
commit 5bab699e14
1 changed files with 59 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
inc/caldav-REPORT-sync-collection.php
View File

@ -1,4 +1,14 @@
<?php <?php
/**
* CalDAV Server - handle sync-collection report (draft-daboo-webdav-sync-01)
*
* @package davical
* @subpackage caldav
* @author Andrew McMillan <andrew@mcmillan.net.nz>
* @copyright Morphoss Ltd - http://www.morphoss.com/
* @license http://gnu.org/copyleft/gpl.html GNU GPL v2 or later
*/
require("DAVResource.php"); require("DAVResource.php");
$responses = array(); $responses = array();
@ -23,7 +33,7 @@ foreach( $props AS $k => $v ) {
function display_status( $status_code ) { function display_status( $status_code ) {
return sprintf( 'HTTP/1.1 %03d %s', intval($status_code), getStatusMessage($status_code) ); return sprintf( 'HTTP/1.1 %03d %s', intval($status_code), getStatusMessage($status_code) );
} }
$sql = "SELECT new_sync_token(?,?)"; $sql = "SELECT new_sync_token(?,?)";
$qry = new PgQuery($sql, $sync_token, $request->CollectionId()); $qry = new PgQuery($sql, $sync_token, $request->CollectionId());
if ( !$qry->Exec("REPORT",__LINE__,__FILE__) || $qry->rows <= 0 ) { if ( !$qry->Exec("REPORT",__LINE__,__FILE__) || $qry->rows <= 0 ) {
@ -38,31 +48,67 @@ SELECT *, 201 AS sync_status FROM collection
LEFT JOIN caldav_data USING (collection_id) LEFT JOIN caldav_data USING (collection_id)
LEFT JOIN calendar_item USING (dav_id) LEFT JOIN calendar_item USING (dav_id)
WHERE collection.collection_id = ? WHERE collection.collection_id = ?
ORDER BY collection.collection_id, caldav_data.dav_id
EOSQL; EOSQL;
$qry = new PgQuery($sql, $request->CollectionId()); $qry = new PgQuery($sql, $request->CollectionId());
} }
else { else {
$sql = <<<EOSQL $sql = <<<EOSQL
SELECT * FROM collection LEFT JOIN sync_changes USING(collection_id) SELECT * FROM collection LEFT JOIN sync_changes USING(collection_id)
LEFT JOIN calendar_item USING (dav_id) LEFT JOIN calendar_item USING (collection_id,dav_id)
LEFT JOIN caldav_data USING (dav_id) LEFT JOIN caldav_data USING (collection_id,dav_id)
WHERE collection.collection_id = ? WHERE collection.collection_id = ?
AND sync_time > (SELECT modification_time FROM sync_tokens WHERE sync_token = ?) AND sync_time > (SELECT modification_time FROM sync_tokens WHERE sync_token = ?)
ORDER BY collection.collection_id, sync_changes.dav_id, sync_changes.sync_time
EOSQL; EOSQL;
$qry = new PgQuery($sql, $request->CollectionId(), $sync_token); $qry = new PgQuery($sql, $request->CollectionId(), $sync_token);
} }
$last_dav_id = -1;
$first_status = 0;
if ( $qry->Exec("REPORT",__LINE__,__FILE__) ) { if ( $qry->Exec("REPORT",__LINE__,__FILE__) ) {
while( $object = $qry->Fetch() ) { while( $object = $qry->Fetch() ) {
$resultset = array( if ( $object->dav_id == $last_dav_id ) {
new XMLElement( 'href', ConstructURL($object->dav_name) ), /** The complex case: this is the second or subsequent for this dav_id */
new XMLElement( 'status', display_status($object->sync_status) ) if ( $object->sync_status == 404 ) {
); if ( $first_action == 201 ) {
if ( $status != 404 ) { array_pop($responses);
$dav_resource = new DAVResource($object); $last_dav_id = -1;
$resultset = array_merge( $resultset, $dav_resource->GetPropStat($proplist) ); $first_status = 0;
} }
$responses[] = new XMLElement( 'sync-response', $resultset ); else {
array_pop($responses);
$resultset = array(
new XMLElement( 'href', ConstructURL($object->dav_name) ),
new XMLElement( 'status', display_status($object->sync_status) )
);
$responses[] = new XMLElement( 'sync-response', $resultset );
$first_status = 404;
}
}
/** Else:
* the object existed at start and we have multiple modifications,
* or,
* the object didn't exist at start and we have subsequent modifications,
* but:
* in either case we simply stick with our first report.
*/
}
else {
/** The simple case: this is the first one for this dav_id */
$resultset = array(
new XMLElement( 'href', ConstructURL($object->dav_name) ),
new XMLElement( 'status', display_status($object->sync_status) )
);
if ( $object->sync_status != 404 ) {
$dav_resource = new DAVResource($object);
$resultset = array_merge( $resultset, $dav_resource->GetPropStat($proplist) );
}
$responses[] = new XMLElement( 'sync-response', $resultset );
$first_status = $object->sync_status;
$last_dav_id = $object->dav_id;
}
} }
$responses[] = new XMLElement( 'sync-token', $new_token ); $responses[] = new XMLElement( 'sync-token', $new_token );
} }