public function getChangesForCalendar($calendarId, $syncToken, $syncLevel, $limit = null)
    {
        if (!is_array($calendarId)) {
            throw new \InvalidArgumentException('The value passed to $calendarId is expected to be an array with a calendarId and an instanceId');
        }
        list($calendarId, $instanceId) = $calendarId;

        // Current synctoken
        $stmt = $this->pdo->prepare('SELECT synctoken FROM '.$this->calendarTableName.' WHERE id = ?');
        $stmt->execute([$calendarId]);
        $currentToken = $stmt->fetchColumn(0);

        if (is_null($currentToken)) {
            return null;
        }

        $result = [
            'syncToken' => $currentToken,
            'added' => [],
            'modified' => [],
            'deleted' => [],
        ];

        if ($syncToken) {
            $query = 'SELECT uri, operation FROM '.$this->calendarChangesTableName.' WHERE synctoken >= ? AND synctoken < ? AND calendarid = ? ORDER BY synctoken';
            if ($limit > 0) {
                $query .= ' LIMIT '.(int) $limit;
            }

            // Fetching all changes
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$syncToken, $currentToken, $calendarId]);

            $changes = [];

            // This loop ensures that any duplicates are overwritten, only the
            // last change on a node is relevant.
            while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
                $changes[$row['uri']] = $row['operation'];
            }

            foreach ($changes as $uri => $operation) {
                switch ($operation) {
                    case 1:
                        $result['added'][] = $uri;
                        break;
                    case 2:
                        $result['modified'][] = $uri;
                        break;
                    case 3:
                        $result['deleted'][] = $uri;
                        break;
                }
            }
        } else {
            // No synctoken supplied, this is the initial sync.
            $query = 'SELECT uri FROM '.$this->calendarObjectTableName.' WHERE calendarid = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$calendarId]);

            $result['added'] = $stmt->fetchAll(\PDO::FETCH_COLUMN);
        }

        return $result;
    }
public function getChangesForCalendar($calendarId, $syncToken, $syncLevel, $limit = null)
    {
        if (!is_array($calendarId)) {
            throw new \InvalidArgumentException('The value passed to $calendarId is expected to be an array with a calendarId and an instanceId');
        }
        list($calendarId, $instanceId) = $calendarId;

        // Current synctoken
        $stmt = $this->pdo->prepare('SELECT synctoken FROM '.$this->calendarTableName.' WHERE id = ?');
        $stmt->execute([$calendarId]);
        $currentToken = $stmt->fetchColumn(0);

        if (is_null($currentToken)) {
            return null;
        }

        $result = [
            'syncToken' => $currentToken,
            'added' => [],
            'modified' => [],
            'deleted' => [],
        ];

        if ($syncToken) {
            $query = 'SELECT uri, operation FROM '.$this->calendarChangesTableName.' WHERE synctoken >= ? AND synctoken < ? AND calendarid = ? ORDER BY synctoken';
            if ($limit > 0) {
                $query .= ' LIMIT '.(int) $limit;
            }

            // Fetching all changes
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$syncToken, $currentToken, $calendarId]);

            $changes = [];

            // This loop ensures that any duplicates are overwritten, only the
            // last change on a node is relevant.
            while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) {
                $changes[$row['uri']] = $row['operation'];
            }

            foreach ($changes as $uri => $operation) {
                switch ($operation) {
                    case 1:
                        $result['added'][] = $uri;
                        break;
                    case 2:
                        $result['modified'][] = $uri;
                        break;
                    case 3:
                        $result['deleted'][] = $uri;
                        break;
                }
            }
        } else {
            // No synctoken supplied, this is the initial sync.
            $query = 'SELECT uri FROM '.$this->calendarObjectTableName.' WHERE calendarid = ?';
            $stmt = $this->pdo->prepare($query);
            $stmt->execute([$calendarId]);

            $result['added'] = $stmt->fetchAll(\PDO::FETCH_COLUMN);
        }

        return $result;
    }
public function getChangesForCalendar ( $ calendarId , $ syncToken , $ syncLevel , $ limit = null ) { if ( ! is_array ( $ calendarId ) ) { throw new \ InvalidArgumentException ( 'The value passed to $calendarId is expected to be an array with a calendarId and an instanceId' ) ; } list ( $ calendarId , $ instanceId ) = $ calendarId ; // Current synctoken $ stmt = $ this -> pdo -> prepare ( 'SELECT synctoken FROM ' . $ this -> calendarTableName . ' WHERE id = ?' ) ; $ stmt -> execute ( [ $ calendarId ] ) ; $ currentToken = $ stmt -> fetchColumn ( 0 ) ; if ( is_null ( $ currentToken ) ) { return null ; } $ result = [ 'syncToken' => $ currentToken , 'added' => [ ] , 'modified' => [ ] , 'deleted' => [ ] , ] ; if ( $ syncToken ) { $ query = 'SELECT uri, operation FROM ' . $ this -> calendarChangesTableName . ' WHERE synctoken >= ? AND synctoken < ? AND calendarid = ? ORDER BY synctoken' ; if ( $ limit > 0 ) { $ query .= ' LIMIT ' . ( int ) $ limit ; } // Fetching all changes $ stmt = $ this -> pdo -> prepare ( $ query ) ; $ stmt -> execute ( [ $ syncToken , $ currentToken , $ calendarId ] ) ; $ changes = [ ] ; // This loop ensures that any duplicates are overwritten, only the // last change on a node is relevant. while ( $ row = $ stmt -> fetch ( \ PDO :: FETCH_ASSOC ) ) { $ changes [ $ row [ 'uri' ] ] = $ row [ 'operation' ] ; } foreach ( $ changes as $ uri => $ operation ) { switch ( $ operation ) { case 1 : $ result [ 'added' ] [ ] = $ uri ; break ; case 2 : $ result [ 'modified' ] [ ] = $ uri ; break ; case 3 : $ result [ 'deleted' ] [ ] = $ uri ; break ; } } } else { // No synctoken supplied, this is the initial sync. $ query = 'SELECT uri FROM ' . $ this -> calendarObjectTableName . ' WHERE calendarid = ?' ; $ stmt = $ this -> pdo -> prepare ( $ query ) ; $ stmt -> execute ( [ $ calendarId ] ) ; $ result [ 'added' ] = $ stmt -> fetchAll ( \ PDO :: FETCH_COLUMN ) ; } return $ result ; }
The getChanges method returns all the changes that have happened, since
the specified syncToken in the specified calendar.

This function should return an array, such as the following:

[
'syncToken' => 'The current synctoken',
'added'   => [
'new.txt',
],
'modified'   => [
'modified.txt',
],
'deleted' => [
'foo.php.bak',
'old.txt'
]
];

The returned syncToken property should reflect the *current* syncToken
of the calendar, as reported in the {http://sabredav.org/ns}sync-token
property this is needed here too, to ensure the operation is atomic.

If the $syncToken argument is specified as null, this is an initial
sync, and all members should be reported.

The modified property is an array of nodenames that have changed since
the last token.

The deleted property is an array with nodenames, that have been deleted
from collection.

The $syncLevel argument is basically the 'depth' of the report. If it's
1, you only have to report changes that happened only directly in
immediate descendants. If it's 2, it should also include changes from
the nodes below the child collections. (grandchildren)

The $limit argument allows a client to specify how many results should
be returned at most. If the limit is not specified, it should be treated
as infinite.

If the limit (infinite or not) is higher than you're willing to return,
you should throw a Sabre\DAV\Exception\TooMuchMatches() exception.

If the syncToken is expired (due to data cleanup) or unknown, you must
return null.

The limit is 'suggestive'. You are free to ignore it.

@param mixed  $calendarId
@param string $syncToken
@param int    $syncLevel
@param int    $limit

@return array
The getChanges method returns all the changes that have happened since the specified syncToken in the specified calendar .