grommunio / grommunio-sync

lib/grommunio/importer.php

Spacing +49 added lines, -49 removed lines

@@ -61,7 +61,7 @@ 
             $folderidForBackendId = ZPush::GetDeviceManager()->GetFolderIdForBackendId($this->folderidHex);
             // Only append backend id if the mapping backendid<->folderid is available.
             if ($folderidForBackendId != $this->folderidHex) {
-                $this->prefix = $folderidForBackendId . ':';
+                $this->prefix = $folderidForBackendId.':';
             }
         }
         else {
@@ -78,7 +78,7 @@ 
         if ($entryid)
             $folder = mapi_msgstore_openentry($store, $entryid);
 
-        if(!$folder) {
+        if (!$folder) {
             $this->importer = false;
 
             // We throw an general error SYNC_FSSTATUS_CODEUNKNOWN (12) which is also SYNC_STATUS_FOLDERHIERARCHYCHANGED (12)
@@ -89,10 +89,10 @@ 
         $this->mapiprovider = new MAPIProvider($this->session, $this->store);
 
         if ($folderid) {
-            $this->importer = mapi_openproperty($folder, PR_COLLECTOR, IID_IExchangeImportContentsChanges, 0 , 0);
+            $this->importer = mapi_openproperty($folder, PR_COLLECTOR, IID_IExchangeImportContentsChanges, 0, 0);
         }
         else {
-            $this->importer = mapi_openproperty($folder, PR_COLLECTOR, IID_IExchangeImportHierarchyChanges, 0 , 0);
+            $this->importer = mapi_openproperty($folder, PR_COLLECTOR, IID_IExchangeImportHierarchyChanges, 0, 0);
         }
     }
 
@@ -115,7 +115,7 @@ 
 
         // Put the state information in a stream that can be used by ICS
         $stream = mapi_stream_create();
-        if(strlen($state) == 0)
+        if (strlen($state) == 0)
             $state = hex2bin("0000000000000000");
 
         ZLog::Write(LOGLEVEL_DEBUG, sprintf("ImportChangesICS->Config(): initializing importer with state: 0x%s", bin2hex($state)));
@@ -147,7 +147,7 @@ 
      */
     public function ConfigContentParameters($contentparameters) {
         $filtertype = $contentparameters->GetFilterType();
-        switch($contentparameters->GetContentClass()) {
+        switch ($contentparameters->GetContentClass()) {
             case "Email":
                 $this->cutoffdate = ($filtertype) ? Utils::GetCutOffDate($filtertype) : false;
                 break;
@@ -173,22 +173,22 @@ 
      */
     public function GetState() {
         $error = false;
-        if(!isset($this->statestream) || $this->importer === false)
+        if (!isset($this->statestream) || $this->importer === false)
             $error = true;
 
         if ($error === false && $this->folderid !== false && function_exists("mapi_importcontentschanges_updatestate"))
-            if(mapi_importcontentschanges_updatestate($this->importer, $this->statestream) != true)
+            if (mapi_importcontentschanges_updatestate($this->importer, $this->statestream) != true)
                 $error = true;
 
         if ($error == true)
-            throw new StatusException(sprintf("ImportChangesICS->GetState(): Error, state not available or unable to update: 0x%X", mapi_last_hresult()), (($this->folderid)?SYNC_STATUS_FOLDERHIERARCHYCHANGED:SYNC_FSSTATUS_CODEUNKNOWN), null, LOGLEVEL_WARN);
+            throw new StatusException(sprintf("ImportChangesICS->GetState(): Error, state not available or unable to update: 0x%X", mapi_last_hresult()), (($this->folderid) ?SYNC_STATUS_FOLDERHIERARCHYCHANGED:SYNC_FSSTATUS_CODEUNKNOWN), null, LOGLEVEL_WARN);
 
         mapi_stream_seek($this->statestream, 0, STREAM_SEEK_SET);
 
         $state = "";
-        while(true) {
+        while (true) {
             $data = mapi_stream_read($this->statestream, 4096);
-            if(strlen($data))
+            if (strlen($data))
                 $state .= $data;
             else
                 break;
@@ -218,13 +218,13 @@ 
 
         // open the existing object
         $entryid = mapi_msgstore_entryidfromsourcekey($this->store, $this->folderid, hex2bin($messageid));
-        if(!$entryid) {
+        if (!$entryid) {
             ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->isModificationAllowed('%s'): Error, unable to resolve message id: 0x%X", $messageid, mapi_last_hresult()));
             return false;
         }
 
         $mapimessage = mapi_msgstore_openentry($this->store, $entryid);
-        if(!$mapimessage) {
+        if (!$mapimessage) {
             ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->isModificationAllowed('%s'): Error, unable to open entry id: 0x%X", $messageid, mapi_last_hresult()));
             return false;
         }
@@ -232,8 +232,8 @@ 
         // check the sync interval
         if ($this->cutoffdate !== false) {
             ZLog::Write(LOGLEVEL_DEBUG, sprintf("ImportChangesICS->isModificationAllowed('%s'): cut off date is: %s", $messageid, $this->cutoffdate));
-            if (  ($this->contentClass == "Email"    && !MAPIUtils::IsInEmailSyncInterval($this->store, $mapimessage, $this->cutoffdate)) ||
-                  ($this->contentClass == "Calendar" && !MAPIUtils::IsInCalendarSyncInterval($this->store, $mapimessage, $this->cutoffdate)) ) {
+            if (($this->contentClass == "Email" && !MAPIUtils::IsInEmailSyncInterval($this->store, $mapimessage, $this->cutoffdate)) ||
+                  ($this->contentClass == "Calendar" && !MAPIUtils::IsInCalendarSyncInterval($this->store, $mapimessage, $this->cutoffdate))) {
 
                 ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->isModificationAllowed('%s'): Message in %s is outside the sync interval. Data not saved.", $messageid, $this->contentClass));
                 return false;
@@ -312,13 +312,13 @@ 
             $started = time();
             $exported = 0;
             try {
-                while(is_array($exporter->Synchronize())) {
+                while (is_array($exporter->Synchronize())) {
                     $exported++;
 
                     // stop if this takes more than 15 seconds and there are more than 5 changes still to be exported
                     // within 20 seconds this should be finished or it will not be performed
-                    if ((time() - $started) > 15 && ($potConflicts - $exported) > 5 ) {
-                        ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->lazyLoadConflicts(): conflict detection cancelled as operation is too slow. In %d seconds only %d from %d changes were processed.",(time() - $started), $exported, $potConflicts));
+                    if ((time() - $started) > 15 && ($potConflicts - $exported) > 5) {
+                        ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->lazyLoadConflicts(): conflict detection cancelled as operation is too slow. In %d seconds only %d from %d changes were processed.", (time() - $started), $exported, $potConflicts));
                         $this->conflictsLoaded = true;
                         return false;
                     }
@@ -326,7 +326,7 @@ 
             }
             // something really bad happened while exporting changes
             catch (StatusException $stex) {
-                ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->lazyLoadConflicts(): got StatusException code %d while exporting changes. Ignore and mark conflicts as loaded.",$stex->getCode()));
+                ZLog::Write(LOGLEVEL_WARN, sprintf("ImportChangesICS->lazyLoadConflicts(): got StatusException code %d while exporting changes. Ignore and mark conflicts as loaded.", $stex->getCode()));
             }
             $this->conflictsLoaded = true;
         }
@@ -349,7 +349,7 @@ 
         $props[PR_PARENT_SOURCE_KEY] = $this->folderid;
 
         // set the PR_SOURCE_KEY if available or mark it as new message
-        if($id) {
+        if ($id) {
             list(, $sk) = Utils::SplitMessageId($id);
             $props[PR_SOURCE_KEY] = hex2bin($sk);
 
@@ -359,7 +359,7 @@ 
 
             // check for conflicts
             $this->lazyLoadConflicts();
-            if($this->memChanges->IsChanged($id)) {
+            if ($this->memChanges->IsChanged($id)) {
                 if ($this->flags & SYNC_CONFLICT_OVERWRITE_PIM) {
                     // in these cases the status SYNC_STATUS_CONFLICTCLIENTSERVEROBJECT should be returned, so the mobile client can inform the end user
                     throw new StatusException(sprintf("ImportChangesICS->ImportMessageChange('%s','%s'): Conflict detected. Data from PIM will be dropped! Server overwrites PIM. User is informed.", $id, get_class($message)), SYNC_STATUS_CONFLICTCLIENTSERVEROBJECT, null, LOGLEVEL_INFO);
@@ -368,7 +368,7 @@ 
                 else
                     ZLog::Write(LOGLEVEL_INFO, sprintf("ImportChangesICS->ImportMessageChange('%s','%s'): Conflict detected. Data from Server will be dropped! PIM overwrites server.", $id, get_class($message)));
             }
-            if($this->memChanges->IsDeleted($id)) {
+            if ($this->memChanges->IsDeleted($id)) {
                 ZLog::Write(LOGLEVEL_INFO, sprintf("ImportChangesICS->ImportMessageChange('%s','%s'): Conflict detected. Data from PIM will be dropped! Object was deleted on server.", $id, get_class($message)));
                 return false;
             }
@@ -376,16 +376,16 @@ 
         else
             $flags = SYNC_NEW_MESSAGE;
 
-        if(mapi_importcontentschanges_importmessagechange($this->importer, $props, $flags, $mapimessage)) {
+        if (mapi_importcontentschanges_importmessagechange($this->importer, $props, $flags, $mapimessage)) {
             $this->mapiprovider->SetMessage($mapimessage, $message);
             mapi_savechanges($mapimessage);
 
             if (mapi_last_hresult())
                 throw new StatusException(sprintf("ImportChangesICS->ImportMessageChange('%s','%s'): Error, mapi_savechanges() failed: 0x%X", $id, get_class($message), mapi_last_hresult()), SYNC_STATUS_SYNCCANNOTBECOMPLETED);
 
-            $sourcekeyprops = mapi_getprops($mapimessage, array (PR_SOURCE_KEY));
+            $sourcekeyprops = mapi_getprops($mapimessage, array(PR_SOURCE_KEY));
 
-            return $this->prefix . bin2hex($sourcekeyprops[PR_SOURCE_KEY]);
+            return $this->prefix.bin2hex($sourcekeyprops[PR_SOURCE_KEY]);
         }
         else
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageChange('%s','%s'): Error updating object: 0x%X", $id, get_class($message), mapi_last_hresult()), SYNC_STATUS_OBJECTNOTFOUND);
@@ -409,16 +409,16 @@ 
 
         // check for conflicts
         $this->lazyLoadConflicts();
-        if($this->memChanges->IsChanged($id)) {
+        if ($this->memChanges->IsChanged($id)) {
             ZLog::Write(LOGLEVEL_INFO, sprintf("ImportChangesICS->ImportMessageDeletion('%s'): Conflict detected. Data from Server will be dropped! PIM deleted object.", $id));
         }
-        elseif($this->memChanges->IsDeleted($id)) {
+        elseif ($this->memChanges->IsDeleted($id)) {
             ZLog::Write(LOGLEVEL_INFO, sprintf("ImportChangesICS->ImportMessageDeletion('%s'): Conflict detected. Data is already deleted. Request will be ignored.", $id));
             return true;
         }
 
         // do a 'soft' delete so people can un-delete if necessary
-        if(mapi_importcontentschanges_importmessagedeletion($this->importer, 1, array(hex2bin($sk))))
+        if (mapi_importcontentschanges_importmessagedeletion($this->importer, 1, array(hex2bin($sk))))
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageDeletion('%s'): Error updating object: 0x%X", $sk, mapi_last_hresult()), SYNC_STATUS_OBJECTNOTFOUND);
 
         return true;
@@ -437,7 +437,7 @@ 
      * @throws StatusException
      */
     public function ImportMessageReadFlag($id, $flags, $categories = array()) {
-        list($fsk,$sk) = Utils::SplitMessageId($id);
+        list($fsk, $sk) = Utils::SplitMessageId($id);
 
         // if $fsk is set, we convert it into a backend id.
         if ($fsk) {
@@ -463,9 +463,9 @@ 
             }
              */
 
-            $readstate = array ( "sourcekey" => hex2bin($sk), "flags" => $flags);
+            $readstate = array("sourcekey" => hex2bin($sk), "flags" => $flags);
 
-            if(!mapi_importcontentschanges_importperuserreadstatechange($this->importer, array($readstate) ))
+            if (!mapi_importcontentschanges_importperuserreadstatechange($this->importer, array($readstate)))
                 throw new StatusException(sprintf("ImportChangesICS->ImportMessageReadFlag('%s','%d'): Error setting read state: 0x%X", $id, $flags, mapi_last_hresult()), SYNC_STATUS_OBJECTNOTFOUND);
         }
         // yeah OL sucks - ZP-779
@@ -504,7 +504,7 @@ 
      */
     public function ImportMessageMove($id, $newfolder) {
         list(,$sk) = Utils::SplitMessageId($id);
-        if (strtolower($newfolder) == strtolower(bin2hex($this->folderid)) )
+        if (strtolower($newfolder) == strtolower(bin2hex($this->folderid)))
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, source and destination are equal", $id, $newfolder), SYNC_MOVEITEMSSTATUS_SAMESOURCEANDDEST);
 
         // Get the entryid of the message we're moving
@@ -516,7 +516,7 @@ 
             $srcmessage = mapi_msgstore_openentry($this->store, $entryid);
         }
 
-        if(!$entryid || !$srcmessage) {
+        if (!$entryid || !$srcmessage) {
             $code = SYNC_MOVEITEMSSTATUS_INVALIDSOURCEID;
             $mapiLastHresult = mapi_last_hresult();
             // if we move to the trash and the source message is not found, we can also just tell the mobile that we successfully moved to avoid errors (ZP-624)
@@ -537,11 +537,11 @@ 
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, unable to open store of destination folder", $sk, $newfolder), SYNC_MOVEITEMSSTATUS_INVALIDDESTID);
 
         $dstentryid = mapi_msgstore_entryidfromsourcekey($dststore, hex2bin($newfolder));
-        if(!$dstentryid)
+        if (!$dstentryid)
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, unable to resolve destination folder", $sk, $newfolder), SYNC_MOVEITEMSSTATUS_INVALIDDESTID);
 
         $dstfolder = mapi_msgstore_openentry($dststore, $dstentryid);
-        if(!$dstfolder)
+        if (!$dstfolder)
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, unable to open destination folder", $sk, $newfolder), SYNC_MOVEITEMSSTATUS_INVALIDDESTID);
 
         $newmessage = mapi_folder_createmessage($dstfolder);
@@ -554,7 +554,7 @@ 
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, copy to destination message failed: 0x%X", $sk, $newfolder, mapi_last_hresult()), SYNC_MOVEITEMSSTATUS_CANNOTMOVE);
 
         $srcfolderentryid = mapi_msgstore_entryidfromsourcekey($this->store, $this->folderid);
-        if(!$srcfolderentryid)
+        if (!$srcfolderentryid)
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, unable to resolve source folder", $sk, $newfolder), SYNC_MOVEITEMSSTATUS_INVALIDSOURCEID);
 
         $srcfolder = mapi_msgstore_openentry($this->store, $srcfolderentryid);
@@ -570,15 +570,15 @@ 
         if (!mapi_folder_deletemessages($srcfolder, array($entryid)))
             throw new StatusException(sprintf("ImportChangesICS->ImportMessageMove('%s','%s'): Error, delete of source message failed: 0x%X. Possible duplicates.", $sk, $newfolder, mapi_last_hresult()), SYNC_MOVEITEMSSTATUS_SOURCEORDESTLOCKED);
 
-        $sourcekeyprops = mapi_getprops($newmessage, array (PR_SOURCE_KEY));
+        $sourcekeyprops = mapi_getprops($newmessage, array(PR_SOURCE_KEY));
         if (isset($sourcekeyprops[PR_SOURCE_KEY]) && $sourcekeyprops[PR_SOURCE_KEY]) {
             $prefix = "";
             // prepend the destination short folderid, if it exists
             $destShortId = ZPush::GetDeviceManager()->GetFolderIdForBackendId($newfolder);
             if ($destShortId !== $newfolder) {
-                $prefix = $destShortId .":";
+                $prefix = $destShortId.":";
             }
-            return $prefix . bin2hex($sourcekeyprops[PR_SOURCE_KEY]);
+            return $prefix.bin2hex($sourcekeyprops[PR_SOURCE_KEY]);
         }
 
         return false;
@@ -599,7 +599,7 @@ 
      * @throws StatusException
      */
     public function ImportFolderChange($folder) {
-        $id = isset($folder->BackendId)?$folder->BackendId : false;
+        $id = isset($folder->BackendId) ? $folder->BackendId : false;
         $parent = $folder->parentid;
         $parent_org = $folder->parentid;
         $displayname = u2wi($folder->displayname);
@@ -637,7 +637,7 @@ 
 
             mapi_setprops($newfolder, array(PR_CONTAINER_CLASS => MAPIUtils::GetContainerClassFromFolderType($type)));
 
-            $props =  mapi_getprops($newfolder, array(PR_SOURCE_KEY));
+            $props = mapi_getprops($newfolder, array(PR_SOURCE_KEY));
             if (isset($props[PR_SOURCE_KEY])) {
                 $folder->BackendId = bin2hex($props[PR_SOURCE_KEY]);
                 $folderOrigin = DeviceManager::FLD_ORIGIN_USER;
@@ -665,7 +665,7 @@ 
         if (!$mfolder)
             throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, unable to open folder (open entry): 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_PARENTNOTFOUND);
 
-        $props =  mapi_getprops($mfolder, array(PR_SOURCE_KEY, PR_PARENT_SOURCE_KEY, PR_DISPLAY_NAME, PR_CONTAINER_CLASS));
+        $props = mapi_getprops($mfolder, array(PR_SOURCE_KEY, PR_PARENT_SOURCE_KEY, PR_DISPLAY_NAME, PR_CONTAINER_CLASS));
         if (!isset($props[PR_SOURCE_KEY]) || !isset($props[PR_PARENT_SOURCE_KEY]) || !isset($props[PR_DISPLAY_NAME]) || !isset($props[PR_CONTAINER_CLASS]))
             throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, folder data not available: 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_SERVERERROR);
 
@@ -688,23 +688,23 @@ 
         // a changed parent id means that the folder should be moved
         if (bin2hex($props[PR_PARENT_SOURCE_KEY]) !== $parent) {
             $sourceparentfentryid = mapi_msgstore_entryidfromsourcekey($this->store, $props[PR_PARENT_SOURCE_KEY]);
-            if(!$sourceparentfentryid)
+            if (!$sourceparentfentryid)
                 throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, unable to open parent source folder (no entry id): 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_PARENTNOTFOUND);
 
             $sourceparentfolder = mapi_msgstore_openentry($this->store, $sourceparentfentryid);
-            if(!$sourceparentfolder)
+            if (!$sourceparentfolder)
                 throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, unable to open parent source folder (open entry): 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_PARENTNOTFOUND);
 
             $destparentfentryid = mapi_msgstore_entryidfromsourcekey($this->store, hex2bin($parent));
-            if(!$sourceparentfentryid)
+            if (!$sourceparentfentryid)
                 throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, unable to open destination folder (no entry id): 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_SERVERERROR);
 
             $destfolder = mapi_msgstore_openentry($this->store, $destparentfentryid);
-            if(!$destfolder)
+            if (!$destfolder)
                 throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, unable to open destination folder (open entry): 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_SERVERERROR);
 
             // mapi_folder_copyfolder() fails if a folder with this name already exists -> MAPI_E_COLLISION
-            if(! mapi_folder_copyfolder($sourceparentfolder, $entryid, $destfolder, $displayname, FOLDER_MOVE))
+            if (!mapi_folder_copyfolder($sourceparentfolder, $entryid, $destfolder, $displayname, FOLDER_MOVE))
                 throw new StatusException(sprintf("ImportChangesICS->ImportFolderChange('%s','%s','%s'): Error, unable to move folder: 0x%X", Utils::PrintAsString($folder->serverid), $folder->parentid, $displayname, mapi_last_hresult()), SYNC_FSSTATUS_FOLDEREXISTS);
 
             // the parent changed, but we got a backendID as parent and have to return an AS folderid - the parent-backendId must be mapped at this point already
@@ -742,7 +742,7 @@ 
         ZLog::Write(LOGLEVEL_DEBUG, sprintf("ImportChangesICS->ImportFolderDeletion('%s','%s'): importing folder deletetion", $id, $parent));
 
         $folderentryid = mapi_msgstore_entryidfromsourcekey($this->store, hex2bin($id));
-        if(!$folderentryid)
+        if (!$folderentryid)
             throw new StatusException(sprintf("ImportChangesICS->ImportFolderDeletion('%s','%s'): Error, unable to resolve folder", $id, $parent, mapi_last_hresult()), SYNC_FSSTATUS_FOLDERDOESNOTEXIST);
 
         // get the folder type from the MAPIProvider
@@ -751,7 +751,7 @@ 
         if (Utils::IsSystemFolder($type) || $this->mapiprovider->IsMAPIDefaultFolder($folderentryid))
             throw new StatusException(sprintf("ImportChangesICS->ImportFolderDeletion('%s','%s'): Error deleting system/default folder", $id, $parent), SYNC_FSSTATUS_SYSTEMFOLDER);
 
-        $ret = mapi_importhierarchychanges_importfolderdeletion ($this->importer, 0, array(PR_SOURCE_KEY => hex2bin($id)));
+        $ret = mapi_importhierarchychanges_importfolderdeletion($this->importer, 0, array(PR_SOURCE_KEY => hex2bin($id)));
         if (!$ret)
             throw new StatusException(sprintf("ImportChangesICS->ImportFolderDeletion('%s','%s'): Error deleting folder: 0x%X", $id, $parent, mapi_last_hresult()), SYNC_FSSTATUS_SERVERERROR);