grommunio / grommunio-sync

lib/grommunio/importer.php

Braces +10 added lines, -20 removed lines

@@ -60,13 +60,11 @@ 
 			if ($folderidForBackendId != $this->folderidHex) {
 				$this->prefix = $folderidForBackendId . ':';
 			}
-		}
-		else {
+		} else {
 			$storeprops = mapi_getprops($store, [PR_IPM_SUBTREE_ENTRYID, PR_IPM_PUBLIC_FOLDERS_ENTRYID]);
 			if (GSync::GetBackend()->GetImpersonatedUser() == 'system') {
 				$entryid = $storeprops[PR_IPM_PUBLIC_FOLDERS_ENTRYID];
-			}
-			else {
+			} else {
 				$entryid = $storeprops[PR_IPM_SUBTREE_ENTRYID];
 			}
 		}
@@ -88,8 +86,7 @@ 
 
 		if ($folderid) {
 			$this->importer = mapi_openproperty($folder, PR_COLLECTOR, IID_IExchangeImportContentsChanges, 0, 0);
-		}
-		else {
+		} else {
 			$this->importer = mapi_openproperty($folder, PR_COLLECTOR, IID_IExchangeImportHierarchyChanges, 0, 0);
 		}
 	}
@@ -127,8 +124,7 @@ 
 			// possible conflicting messages will be cached here
 			$this->memChanges = new ChangesMemoryWrapper();
 			$stat = mapi_importcontentschanges_config($this->importer, $stream, $flags);
-		}
-		else {
+		} else {
 			$stat = mapi_importhierarchychanges_config($this->importer, $stream, $flags);
 		}
 
@@ -201,8 +197,7 @@ 
 			$data = mapi_stream_read($this->statestream, 4096);
 			if (strlen($data)) {
 				$state .= $data;
-			}
-			else {
+			} else {
 				break;
 			}
 		}
@@ -395,8 +390,7 @@ 
 
 				return false;
 			}
-		}
-		else {
+		} else {
 			$flags = SYNC_NEW_MESSAGE;
 		}
 
@@ -436,8 +430,7 @@ 
 		$this->lazyLoadConflicts();
 		if ($this->memChanges->IsChanged($id)) {
 			SLog::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)) {
 			SLog::Write(LOGLEVEL_INFO, sprintf("ImportChangesICS->ImportMessageDeletion('%s'): Conflict detected. Data is already deleted. Request will be ignored.", $id));
 
 			return true;
@@ -658,12 +651,10 @@ 
 				$parentprops = mapi_getprops($this->store, [PR_IPM_SUBTREE_ENTRYID, PR_IPM_PUBLIC_FOLDERS_ENTRYID]);
 				if (GSync::GetBackend()->GetImpersonatedUser() == 'system' && isset($parentprops[PR_IPM_PUBLIC_FOLDERS_ENTRYID])) {
 					$parentfentryid = $parentprops[PR_IPM_PUBLIC_FOLDERS_ENTRYID];
-				}
-				elseif (isset($parentprops[PR_IPM_SUBTREE_ENTRYID])) {
+				} elseif (isset($parentprops[PR_IPM_SUBTREE_ENTRYID])) {
 					$parentfentryid = $parentprops[PR_IPM_SUBTREE_ENTRYID];
 				}
-			}
-			else {
+			} else {
 				$parentfentryid = mapi_msgstore_entryidfromsourcekey($this->store, hex2bin($parent));
 			}
 
@@ -726,8 +717,7 @@ 
 			$parentprops = mapi_getprops($this->store, [PR_IPM_SUBTREE_ENTRYID, PR_IPM_PUBLIC_FOLDERS_ENTRYID]);
 			if (GSync::GetBackend()->GetImpersonatedUser() == 'system') {
 				$parentfentryid = $parentprops[PR_IPM_PUBLIC_FOLDERS_ENTRYID];
-			}
-			else {
+			} else {
 				$parentfentryid = $parentprops[PR_IPM_SUBTREE_ENTRYID];
 			}
 			$mapifolder = mapi_msgstore_openentry($this->store, $parentfentryid);

lib/core/redisconnection.php

Braces +3 added lines, -6 removed lines

@@ -48,8 +48,7 @@ 
 	public function getKey($key) {
 		try {
 			return $this->redisObj->get($key);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			SLog::Write(LOGLEVEL_ERROR, sprintf("%s->getKey(): %s", get_class($this), $e->getMessage()));
 		}
 	}
@@ -61,8 +60,7 @@ 
 			}
 
 			return $this->redisObj->set($key, $value);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			SLog::Write(LOGLEVEL_ERROR, sprintf("%s->setKey(): %s", get_class($this), $e->getMessage()));
 		}
 	}
@@ -70,8 +68,7 @@ 
 	public function delKey($key) {
 		try {
 			return $this->redisObj->del($key);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			SLog::Write(LOGLEVEL_ERROR, sprintf("%s->delKey(): %s", get_class($this), $e->getMessage()));
 		}
 	}

lib/core/topcollector.php

Braces +1 added lines, -2 removed lines

@@ -148,8 +148,7 @@
 
 		if ($all == true) {
 			$this->getRedis()->delKey(self::TOPDATA);
-		}
-		else {
+		} else {
 			foreach ($this->getRawDeviceUserData(self::TOPDATA) as $compKey => $rawline) {
 				$line = json_decode($rawline, true);
 				// remove everything which terminated for 20 secs or is not updated for more than 120 secs

Spacing +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
 			"ended" => 0,
 			"push" => false,
 		];
-		$this->disabled = (bool) (defined('TOPCOLLECTOR_DISABLED') && constant('TOPCOLLECTOR_DISABLED') === true);
+		$this->disabled = (bool)(defined('TOPCOLLECTOR_DISABLED') && constant('TOPCOLLECTOR_DISABLED') === true);
 		$this->checkEnabledTime = time() - self::ENABLED_CACHETIME - 1;
 		$this->AnnounceInformation("initializing");
 	}

lib/core/changesmemorywrapper.php

Braces +2 added lines, -4 removed lines

@@ -86,8 +86,7 @@ 
 						SLog::Write(LOGLEVEL_INFO, sprintf("ChangesMemoryWrapper->Config(AdditionalFolders) : previously synchronized folder '%s' is not to be synched anymore. Sending delete to mobile.", $folder->displayname));
 						$this->ImportFolderDeletion($folder);
 					}
-				}
-				else {
+				} else {
 					$folderIdsOnClient[] = $sid;
 				}
 			}
@@ -187,8 +186,7 @@ 
 	public function ImportMessageDeletion($id, $asSoftDelete = false) {
 		if ($asSoftDelete === true) {
 			$this->changes[] = [self::SOFTDELETION, $id];
-		}
-		else {
+		} else {
 			$this->changes[] = [self::DELETION, $id];
 		}
 

lib/core/gsyncdefs.php

Spacing +1 added lines, -1 removed lines

@@ -984,7 +984,7 @@
 define("LOGLEVEL_DEVICEID", 64);
 define("LOGLEVEL_WBXMLSTACK", 128);
 
-define("LOGLEVEL_ALL", LOGLEVEL_FATAL | LOGLEVEL_ERROR | LOGLEVEL_WARN | LOGLEVEL_INFO | LOGLEVEL_DEBUG | LOGLEVEL_WBXML);
+define("LOGLEVEL_ALL", LOGLEVEL_FATAL|LOGLEVEL_ERROR|LOGLEVEL_WARN|LOGLEVEL_INFO|LOGLEVEL_DEBUG|LOGLEVEL_WBXML);
 
 define("BACKEND_DISCARD_DATA", 1);
 

lib/core/interprocessdata.php

Braces +3 added lines, -6 removed lines

@@ -36,8 +36,7 @@ 
 			// this method is not suitable for the TopCollector atm
 			$type = Request::GetDeviceID();
 			$this->ipcProvider = GSync::GetRedis();
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			// ipcProvider could not initialise
 			SLog::Write(LOGLEVEL_ERROR, sprintf("%s could not initialise IPC Redis provider: %s", get_class($this), $e->getMessage()));
 		}
@@ -193,8 +192,7 @@ 
 		elseif ($doCas == "replace") {
 			if (!$rawdata) {
 				$ok = ($this->ipcProvider->get()->hset($key, $compKey, json_encode($data)) !== false);
-			}
-			else {
+			} else {
 				$ok = $this->ipcProvider->CASHash($key, $compKey, $rawdata, json_encode($data));
 			}
 		}
@@ -270,8 +268,7 @@ 
 			}
 			if (!$subkey) {
 				$_data[$devid][$user] = $_data;
-			}
-			else {
+			} else {
 				if (!isset($_data[$devid][$user])) {
 					$_data[$devid][$user] = [];
 				}

lib/core/asdevice.php

Braces +7 added lines, -14 removed lines

@@ -83,8 +83,7 @@ 
 
 		if (!$stripHierarchyCache && $this->hierarchyCache !== false && $this->hierarchyCache instanceof ChangesMemoryWrapper) {
 			$this->hierarchyCache->StripData();
-		}
-		else {
+		} else {
 			unset($this->hierarchyCache);
 		}
 
@@ -245,8 +244,7 @@ 
 							$foundMessage = true;
 							if (count($this->ignoredMessageIds[$folderid]) == 1) {
 								unset($this->ignoredMessageIds[$folderid]);
-							}
-							else {
+							} else {
 								unset($this->ignoredMessageIds[$folderid][array_search($id, $this->ignoredMessageIds[$folderid])]);
 							}
 
@@ -314,8 +312,7 @@ 
 		if ($hierarchydata !== false && $hierarchydata instanceof ChangesMemoryWrapper) {
 			$this->hierarchyCache = $hierarchydata;
 			$this->hierarchyCache->CopyOldState();
-		}
-		else {
+		} else {
 			$this->hierarchyCache = new ChangesMemoryWrapper();
 		}
 
@@ -407,8 +404,7 @@ 
 				$this->backend2folderidCache = false;
 			}
 			$this->changed = true;
-		}
-		else {
+		} else {
 			$contentData = $this->contentData;
 
 			if (!isset($contentData[$folderid])) {
@@ -422,8 +418,7 @@ 
 
 			if ($uuid) {
 				$contentData[$folderid]->{self::FOLDERUUID} = $uuid;
-			}
-			else {
+			} else {
 				$contentData[$folderid]->{self::FOLDERUUID} = false;
 			}
 
@@ -678,8 +673,7 @@ 
 		}
 		if ($status !== false) {
 			$contentData[$folderid]->{self::FOLDERSYNCSTATUS} = $status;
-		}
-		elseif (isset($contentData[$folderid]->{self::FOLDERSYNCSTATUS})) {
+		} elseif (isset($contentData[$folderid]->{self::FOLDERSYNCSTATUS})) {
 			unset($contentData[$folderid]->{self::FOLDERSYNCSTATUS});
 		}
 
@@ -939,8 +933,7 @@ 
 		foreach ($this->additionalfolders as $keepFolder) {
 			if ($keepFolder['store'] !== $store) {
 				$newAF[$keepFolder['folderid']] = $keepFolder;
-			}
-			else {
+			} else {
 				$noDupsCheck[$keepFolder['folderid']] = true;
 			}
 		}

lib/core/loopdetection.php

Braces +11 added lines, -22 removed lines

@@ -264,8 +264,7 @@ 
 					if (isset($se['stat'], $se['stat']['hierarchy']) && $se['stat']['hierarchy'] == SYNC_FSSTATUS_SYNCKEYERROR) {
 						SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->ProcessLoopDetectionIsHierarchyResyncRequired(): a full FolderReSync was already requested. Resetting fail counter.");
 						$seenFailed = [];
-					}
-					else {
+					} else {
 						$seenFolderSync = true;
 						if (!empty($seenFailed)) {
 							SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->ProcessLoopDetectionIsHierarchyResyncRequired(): seen FolderSync after other failing command");
@@ -355,8 +354,7 @@ 
 			foreach ($stack as $entry) {
 				if ($entry['id'] != $updateentry['id']) {
 					$nstack[] = $entry;
-				}
-				else {
+				} else {
 					$nstack[] = $updateentry;
 					$found = true;
 				}
@@ -589,8 +587,7 @@ 
 			if (!isset($current["uuid"]) || $current["uuid"] != $uuid) {
 				SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->IsSyncStateObsolete(): yes, uuid changed or not set");
 				$obsolete = true;
-			}
-			else {
+			} else {
 				SLog::Write(LOGLEVEL_DEBUG, sprintf(
 					"LoopDetection->IsSyncStateObsolete(): check folderid: '%s' uuid '%s' counter: %d - last counter: %d with %d queued",
 					$folderid,
@@ -610,8 +607,7 @@ 
 					$obsolete = true;
 				}
 			}
-		}
-		else {
+		} else {
 			SLog::Write(LOGLEVEL_DEBUG, sprintf("LoopDetection->IsSyncStateObsolete(): check folderid: '%s' uuid '%s' counter: %d - no data found: not obsolete", $folderid, $uuid, $counter));
 		}
 
@@ -685,8 +681,7 @@ 
 					SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->Detect(): UUID changed and while items where sent to device - forcing loop mode");
 					$loop = true; // force loop mode
 					$current['queued'] = $queuedMessages;
-				}
-				else {
+				} else {
 					$current['queued'] = 0;
 				}
 
@@ -747,8 +742,7 @@ 
 							// return suggested new window size
 							$current['windowLimit'] = 25;
 							$loop = $current['windowLimit'];
-						}
-						else {
+						} else {
 							// case 3.1) we have just encountered a loop!
 							SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->Detect(): case 3.1 detected - loop detected, init loop mode");
 							if (isset($current['windowLimit'])) {
@@ -760,14 +754,12 @@ 
 							$current['maxCount'] = $counter + (($maxItems < $queuedMessages) ? $maxItems : $queuedMessages);
 							$loop = true;   // loop mode!!
 						}
-					}
-					elseif ($queuedMessages == 0) {
+					} elseif ($queuedMessages == 0) {
 						// case 3.2) there was a loop before but now the changes are GONE
 						SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->Detect(): case 3.2 detected - changes gone - clearing loop data");
 						$current['queued'] = 0;
 						unset($current['loopcount'], $current['ignored'], $current['maxCount'], $current['potential'], $current['windowLimit']);
-					}
-					else {
+					} else {
 						// case 3.3) still looping the same message! Increase counter
 						SLog::Write(LOGLEVEL_DEBUG, "LoopDetection->Detect(): case 3.3 detected - in loop mode, increase loop counter");
 						++$current['loopcount'];
@@ -916,14 +908,11 @@ 
 
 			if ($user == false && $devid == false) {
 				$loopdata = [];
-			}
-			elseif ($user == false && $devid != false) {
+			} elseif ($user == false && $devid != false) {
 				$loopdata[$devid] = [];
-			}
-			elseif ($user != false && $devid != false) {
+			} elseif ($user != false && $devid != false) {
 				$loopdata[$devid][$user] = [];
-			}
-			elseif ($user != false && $devid == false) {
+			} elseif ($user != false && $devid == false) {
 				SLog::Write(LOGLEVEL_WARN, sprintf("Not possible to reset loop detection data for user '%s' without a specifying a device id", $user));
 				$stat = false;
 			}

Spacing +2 added lines, -2 removed lines

@@ -758,7 +758,7 @@ 
 							$current['loopcount'] = 1;
 							// the MaxCount is the max number of messages exported before
 							$current['maxCount'] = $counter + (($maxItems < $queuedMessages) ? $maxItems : $queuedMessages);
-							$loop = true;   // loop mode!!
+							$loop = true; // loop mode!!
 						}
 					}
 					elseif ($queuedMessages == 0) {
@@ -778,7 +778,7 @@ 
 							$this->ignore_messageid = $current['potential'];
 						}
 						$current['maxCount'] = $counter + (($maxItems < $queuedMessages) ? $maxItems : $queuedMessages);
-						$loop = true;   // loop mode!!
+						$loop = true; // loop mode!!
 					}
 				}
 			}

lib/core/gsync.php

Braces +13 added lines, -26 removed lines

@@ -178,8 +178,7 @@ 
 
 		if (defined('BASE_PATH_CLI') && file_exists(BASE_PATH_CLI)) {
 			define('REAL_BASE_PATH', BASE_PATH_CLI);
-		}
-		else {
+		} else {
 			define('REAL_BASE_PATH', BASE_PATH);
 		}
 
@@ -212,8 +211,7 @@ 
 			if (LOG_SYSLOG_HOST && LOG_SYSLOG_PORT <= 0) {
 				throw new FatalMisconfigurationException("LOG_SYSLOG_HOST is defined but the LOG_SYSLOG_PORT does not seem to be valid.");
 			}
-		}
-		elseif (strtolower(LOGBACKEND) == 'filelog') {
+		} elseif (strtolower(LOGBACKEND) == 'filelog') {
 			define('LOGBACKEND_CLASS', 'FileLog');
 			if (!defined('LOGFILEDIR')) {
 				throw new FatalMisconfigurationException("The LOGFILEDIR is not configured. Check if the config.php file is in place.");
@@ -238,8 +236,7 @@ 
 			// check ownership on the (eventually) just created files
 			Utils::FixFileOwner(LOGFILE);
 			Utils::FixFileOwner(LOGERRORFILE);
-		}
-		else {
+		} else {
 			define('LOGBACKEND_CLASS', LOGBACKEND);
 		}
 
@@ -249,8 +246,7 @@ 
 			if (!@date_default_timezone_set(TIMEZONE)) {
 				throw new FatalMisconfigurationException(sprintf("The configured TIMEZONE '%s' is not valid. Please check supported timezones at http://www.php.net/manual/en/timezones.php", constant('TIMEZONE')));
 			}
-		}
-		elseif (!ini_get('date.timezone')) {
+		} elseif (!ini_get('date.timezone')) {
 			date_default_timezone_set('Europe/Vienna');
 		}
 
@@ -287,8 +283,7 @@ 
 
 		if (!defined('SYNC_CONTACTS_MAXPICTURESIZE')) {
 			define('SYNC_CONTACTS_MAXPICTURESIZE', 49152);
-		}
-		elseif ((!is_int(SYNC_CONTACTS_MAXPICTURESIZE) || SYNC_CONTACTS_MAXPICTURESIZE < 1)) {
+		} elseif ((!is_int(SYNC_CONTACTS_MAXPICTURESIZE) || SYNC_CONTACTS_MAXPICTURESIZE < 1)) {
 			throw new FatalMisconfigurationException("The SYNC_CONTACTS_MAXPICTURESIZE value must be a number higher than 0.");
 		}
 
@@ -298,14 +293,12 @@ 
 
 		if (!defined('PING_LOWER_BOUND_LIFETIME')) {
 			define('PING_LOWER_BOUND_LIFETIME', false);
-		}
-		elseif (PING_LOWER_BOUND_LIFETIME !== false && (!is_int(PING_LOWER_BOUND_LIFETIME) || PING_LOWER_BOUND_LIFETIME < 1 || PING_LOWER_BOUND_LIFETIME > 3540)) {
+		} elseif (PING_LOWER_BOUND_LIFETIME !== false && (!is_int(PING_LOWER_BOUND_LIFETIME) || PING_LOWER_BOUND_LIFETIME < 1 || PING_LOWER_BOUND_LIFETIME > 3540)) {
 			throw new FatalMisconfigurationException("The PING_LOWER_BOUND_LIFETIME value must be 'false' or a number between 1 and 3540 inclusively.");
 		}
 		if (!defined('PING_HIGHER_BOUND_LIFETIME')) {
 			define('PING_HIGHER_BOUND_LIFETIME', false);
-		}
-		elseif (PING_HIGHER_BOUND_LIFETIME !== false && (!is_int(PING_HIGHER_BOUND_LIFETIME) || PING_HIGHER_BOUND_LIFETIME < 1 || PING_HIGHER_BOUND_LIFETIME > 3540)) {
+		} elseif (PING_HIGHER_BOUND_LIFETIME !== false && (!is_int(PING_HIGHER_BOUND_LIFETIME) || PING_HIGHER_BOUND_LIFETIME < 1 || PING_HIGHER_BOUND_LIFETIME > 3540)) {
 			throw new FatalMisconfigurationException("The PING_HIGHER_BOUND_LIFETIME value must be 'false' or a number between 1 and 3540 inclusively.");
 		}
 		if (PING_HIGHER_BOUND_LIFETIME !== false && PING_LOWER_BOUND_LIFETIME !== false && PING_HIGHER_BOUND_LIFETIME < PING_LOWER_BOUND_LIFETIME) {
@@ -314,8 +307,7 @@ 
 
 		if (!defined('RETRY_AFTER_DELAY')) {
 			define('RETRY_AFTER_DELAY', 300);
-		}
-		elseif (RETRY_AFTER_DELAY !== false && (!is_int(RETRY_AFTER_DELAY) || RETRY_AFTER_DELAY < 1)) {
+		} elseif (RETRY_AFTER_DELAY !== false && (!is_int(RETRY_AFTER_DELAY) || RETRY_AFTER_DELAY < 1)) {
 			throw new FatalMisconfigurationException("The RETRY_AFTER_DELAY value must be 'false' or a number greater than 0.");
 		}
 
@@ -330,8 +322,7 @@ 
 		// the check on additional folders will not throw hard errors, as this is probably changed on live systems
 		if (isset($additionalFolders) && !is_array($additionalFolders)) {
 			SLog::Write(LOGLEVEL_ERROR, "GSync::CheckConfig(): The additional folders synchronization not available as array.");
-		}
-		else {
+		} else {
 			// check configured data
 			foreach ($additionalFolders as $af) {
 				if (!is_array($af) || !isset($af['store']) || !isset($af['folderid']) || !isset($af['name']) || !isset($af['type'])) {
@@ -478,11 +469,9 @@ 
 
 		if (is_file($subdirbackend)) {
 			$toLoad = $subdirbackend;
-		}
-		elseif (is_file($stdbackend)) {
+		} elseif (is_file($stdbackend)) {
 			$toLoad = $stdbackend;
-		}
-		else {
+		} else {
 			return false;
 		}
 
@@ -543,8 +532,7 @@ 
 	public static function GetAdditionalSyncFolderStore($backendid, $noDebug = false) {
 		if (isset(self::getAddSyncFolders()[$backendid]->Store)) {
 			$val = self::getAddSyncFolders()[$backendid]->Store;
-		}
-		else {
+		} else {
 			$val = self::GetDeviceManager()->GetAdditionalUserSyncFolder($backendid);
 			if (isset($val['store'])) {
 				$val = $val['store'];
@@ -593,8 +581,7 @@ 
 
 			if (isset($additionalFolders) && !is_array($additionalFolders)) {
 				SLog::Write(LOGLEVEL_ERROR, "GSync::getAddSyncFolders() : The additional folders synchronization not available as array.");
-			}
-			else {
+			} else {
 				foreach ($additionalFolders as $af) {
 					if (!is_array($af) || !isset($af['store']) || !isset($af['folderid']) || !isset($af['name']) || !isset($af['type'])) {
 						SLog::Write(LOGLEVEL_ERROR, "GSync::getAddSyncFolders() : the additional folder synchronization is not configured correctly. Missing parameters. Entry will be ignored.");

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
 	public const UNAUTHENTICATED = 1;
 	public const UNPROVISIONED = 2;
 	public const NOACTIVESYNCCOMMAND = 3;
-	public const WEBSERVICECOMMAND = 4;    // DEPRECATED
+	public const WEBSERVICECOMMAND = 4; // DEPRECATED
 	public const HIERARCHYCOMMAND = 5;
 	public const PLAININPUT = 6;
 	public const REQUESTHANDLER = 7;