@@ -172,7 +172,7 @@ |
||
172 | 172 | public static function Open($mapistream, $truncatehtmlsafe = false) { |
173 | 173 | $context = stream_context_create([self::PROTOCOL => ['stream' => &$mapistream, 'truncatehtmlsafe' => $truncatehtmlsafe]]); |
174 | 174 | |
175 | - return fopen(self::PROTOCOL . '://', 'r', false, $context); |
|
175 | + return fopen(self::PROTOCOL.'://', 'r', false, $context); |
|
176 | 176 | } |
177 | 177 | } |
178 | 178 |
@@ -58,7 +58,7 @@ discard block |
||
58 | 58 | $folderidForBackendId = GSync::GetDeviceManager()->GetFolderIdForBackendId($this->folderidHex); |
59 | 59 | // Only append backend id if the mapping backendid<->folderid is available. |
60 | 60 | if ($folderidForBackendId != $this->folderidHex) { |
61 | - $this->prefix = $folderidForBackendId . ':'; |
|
61 | + $this->prefix = $folderidForBackendId.':'; |
|
62 | 62 | } |
63 | 63 | } else { |
64 | 64 | $storeprops = mapi_getprops($store, [PR_IPM_SUBTREE_ENTRYID, PR_IPM_PUBLIC_FOLDERS_ENTRYID]); |
@@ -294,7 +294,7 @@ discard block |
||
294 | 294 | |
295 | 295 | $sourcekeyprops = mapi_getprops($mapimessage, [PR_SOURCE_KEY]); |
296 | 296 | |
297 | - return $this->prefix . bin2hex($sourcekeyprops[PR_SOURCE_KEY]); |
|
297 | + return $this->prefix.bin2hex($sourcekeyprops[PR_SOURCE_KEY]); |
|
298 | 298 | } |
299 | 299 | |
300 | 300 | throw new StatusException(sprintf("ImportChangesICS->ImportMessageChange('%s','%s'): Error updating object: 0x%X", $id, get_class($message), mapi_last_hresult()), SYNC_STATUS_OBJECTNOTFOUND); |
@@ -501,10 +501,10 @@ discard block |
||
501 | 501 | // prepend the destination short folderid, if it exists |
502 | 502 | $destShortId = GSync::GetDeviceManager()->GetFolderIdForBackendId($newfolder); |
503 | 503 | if ($destShortId !== $newfolder) { |
504 | - $prefix = $destShortId . ':'; |
|
504 | + $prefix = $destShortId.':'; |
|
505 | 505 | } |
506 | 506 | |
507 | - return $prefix . bin2hex($sourcekeyprops[PR_SOURCE_KEY]); |
|
507 | + return $prefix.bin2hex($sourcekeyprops[PR_SOURCE_KEY]); |
|
508 | 508 | } |
509 | 509 | |
510 | 510 | return false; |
@@ -24,7 +24,7 @@ |
||
24 | 24 | $validateCert = new SyncValidateCert(); |
25 | 25 | $validateCert->Decode(self::$decoder); |
26 | 26 | $cert_der = base64_decode($validateCert->certificates[0]); |
27 | - $cert_pem = "-----BEGIN CERTIFICATE-----\n" . chunk_split(base64_encode($cert_der), 64, "\n") . "-----END CERTIFICATE-----\n"; |
|
27 | + $cert_pem = "-----BEGIN CERTIFICATE-----\n".chunk_split(base64_encode($cert_der), 64, "\n")."-----END CERTIFICATE-----\n"; |
|
28 | 28 | |
29 | 29 | $checkpurpose = (defined('CAINFO') && CAINFO) ? openssl_x509_checkpurpose($cert_pem, X509_PURPOSE_SMIME_SIGN, [CAINFO]) : openssl_x509_checkpurpose($cert_pem, X509_PURPOSE_SMIME_SIGN); |
30 | 30 | if (true === $checkpurpose) { |
@@ -50,7 +50,7 @@ discard block |
||
50 | 50 | } |
51 | 51 | |
52 | 52 | if (!$fetch && !$efc && !$move) { |
53 | - SLog::Write(LOGLEVEL_DEBUG, 'Unknown item operation:' . print_r($el, 1)); |
|
53 | + SLog::Write(LOGLEVEL_DEBUG, 'Unknown item operation:'.print_r($el, 1)); |
|
54 | 54 | self::$topCollector->AnnounceInformation('Unknown operation', true); |
55 | 55 | |
56 | 56 | return false; |
@@ -247,7 +247,7 @@ discard block |
||
247 | 247 | if (self::$decoder->getElementStartTag(SYNC_ITEMOPERATIONS_DELETESUBFOLDERS)) { |
248 | 248 | $operation['deletesubfolders'] = true; |
249 | 249 | if (($dsf = self::$decoder->getElementContent()) !== false) { |
250 | - $operation['deletesubfolders'] = (bool) $dsf; |
|
250 | + $operation['deletesubfolders'] = (bool)$dsf; |
|
251 | 251 | if (!self::$decoder->getElementEndTag()) { |
252 | 252 | return false; |
253 | 253 | } |
@@ -59,7 +59,7 @@ discard block |
||
59 | 59 | elseif (self::$decoder->getElementStartTag(SYNC_CONVERSATIONMODE)) { |
60 | 60 | $spa->SetConversationMode(true); |
61 | 61 | if (($conversationmode = self::$decoder->getElementContent()) !== false) { |
62 | - $spa->SetConversationMode((bool) $conversationmode); |
|
62 | + $spa->SetConversationMode((bool)$conversationmode); |
|
63 | 63 | if (!self::$decoder->getElementEndTag()) { |
64 | 64 | return false; |
65 | 65 | } |
@@ -181,14 +181,14 @@ discard block |
||
181 | 181 | $sc->AddParameter($spa, 'status', SYNC_GETITEMESTSTATUS_COLLECTIONINVALID); |
182 | 182 | } |
183 | 183 | |
184 | - self::$topCollector->AnnounceInformation('StateNotFoundException ' . $sc->GetParameter($spa, 'status'), true); |
|
184 | + self::$topCollector->AnnounceInformation('StateNotFoundException '.$sc->GetParameter($spa, 'status'), true); |
|
185 | 185 | } catch (StatusException $stex) { |
186 | 186 | if (SYNC_GETITEMESTSTATUS_COLLECTIONINVALID == $stex->getCode()) { |
187 | 187 | $sc->AddParameter($spa, 'status', SYNC_GETITEMESTSTATUS_COLLECTIONINVALID); |
188 | 188 | } else { |
189 | 189 | $sc->AddParameter($spa, 'status', SYNC_GETITEMESTSTATUS_SYNCSTATENOTPRIMED); |
190 | 190 | } |
191 | - self::$topCollector->AnnounceInformation('StatusException ' . $sc->GetParameter($spa, 'status'), true); |
|
191 | + self::$topCollector->AnnounceInformation('StatusException '.$sc->GetParameter($spa, 'status'), true); |
|
192 | 192 | } |
193 | 193 | } |
194 | 194 | } |
@@ -100,7 +100,7 @@ discard block |
||
100 | 100 | } |
101 | 101 | } catch (Exception $ex) { |
102 | 102 | // Log 10 KB of the WBXML data |
103 | - SLog::Write(LOGLEVEL_FATAL, 'WBXML 10K debug data: ' . Request::GetInputAsBase64(10240), false); |
|
103 | + SLog::Write(LOGLEVEL_FATAL, 'WBXML 10K debug data: '.Request::GetInputAsBase64(10240), false); |
|
104 | 104 | |
105 | 105 | throw $ex; |
106 | 106 | } |
@@ -108,7 +108,7 @@ discard block |
||
108 | 108 | // also log WBXML in happy case |
109 | 109 | if (SLog::IsWbxmlDebugEnabled()) { |
110 | 110 | // Log 4 KB in the happy case |
111 | - SLog::Write(LOGLEVEL_WBXML, 'WBXML-IN : ' . Request::GetInputAsBase64(4096), false); |
|
111 | + SLog::Write(LOGLEVEL_WBXML, 'WBXML-IN : '.Request::GetInputAsBase64(4096), false); |
|
112 | 112 | } |
113 | 113 | |
114 | 114 | return true; |
@@ -200,7 +200,7 @@ discard block |
||
200 | 200 | if (self::$decoder->getElementStartTag(SYNC_DELETESASMOVES)) { |
201 | 201 | $spa->SetDeletesAsMoves(true); |
202 | 202 | if (($dam = self::$decoder->getElementContent()) !== false) { |
203 | - $spa->SetDeletesAsMoves((bool) $dam); |
|
203 | + $spa->SetDeletesAsMoves((bool)$dam); |
|
204 | 204 | if (!self::$decoder->getElementEndTag()) { |
205 | 205 | return false; |
206 | 206 | } |
@@ -243,7 +243,7 @@ discard block |
||
243 | 243 | if (self::$decoder->getElementStartTag(SYNC_CONVERSATIONMODE)) { |
244 | 244 | $spa->SetConversationMode(true); |
245 | 245 | if (($conversationmode = self::$decoder->getElementContent()) !== false) { |
246 | - $spa->SetConversationMode((bool) $conversationmode); |
|
246 | + $spa->SetConversationMode((bool)$conversationmode); |
|
247 | 247 | if (!self::$decoder->getElementEndTag()) { |
248 | 248 | return false; |
249 | 249 | } |
@@ -609,7 +609,7 @@ discard block |
||
609 | 609 | |
610 | 610 | if (self::$decoder->getElementStartTag(SYNC_WINDOWSIZE)) { |
611 | 611 | $sc->SetGlobalWindowSize(self::$decoder->getElementContent()); |
612 | - SLog::Write(LOGLEVEL_DEBUG, 'Sync(): Global WindowSize requested: ' . $sc->GetGlobalWindowSize()); |
|
612 | + SLog::Write(LOGLEVEL_DEBUG, 'Sync(): Global WindowSize requested: '.$sc->GetGlobalWindowSize()); |
|
613 | 613 | if (!self::$decoder->getElementEndTag()) { // SYNC_WINDOWSIZE |
614 | 614 | return false; |
615 | 615 | } |
@@ -1172,7 +1172,7 @@ discard block |
||
1172 | 1172 | } |
1173 | 1173 | |
1174 | 1174 | // Stream outgoing changes |
1175 | - if (SYNC_STATUS_SUCCESS == $status && true == $sc->GetParameter($spa, 'getchanges') && $windowSize > 0 && (bool) $exporter) { |
|
1175 | + if (SYNC_STATUS_SUCCESS == $status && true == $sc->GetParameter($spa, 'getchanges') && $windowSize > 0 && (bool)$exporter) { |
|
1176 | 1176 | self::$topCollector->AnnounceInformation(sprintf('Streaming data of %d objects', (($changecount > $windowSize) ? $windowSize : $changecount))); |
1177 | 1177 | |
1178 | 1178 | // Output message changes per folder |
@@ -1222,7 +1222,7 @@ discard block |
||
1222 | 1222 | |
1223 | 1223 | // $progress is not an array when exporting the last message |
1224 | 1224 | // so we get the number to display from the streamimporter if it's available |
1225 | - if ((bool) $streamimporter) { |
|
1225 | + if ((bool)$streamimporter) { |
|
1226 | 1226 | $n = $streamimporter->GetImportedMessages(); |
1227 | 1227 | } |
1228 | 1228 | |
@@ -1239,7 +1239,7 @@ discard block |
||
1239 | 1239 | } |
1240 | 1240 | } |
1241 | 1241 | |
1242 | - self::$topCollector->AnnounceInformation(sprintf('Outgoing %d objects%s', $n, ($n >= $windowSize) ? ' of ' . $changecount : ''), $this->singleFolder); |
|
1242 | + self::$topCollector->AnnounceInformation(sprintf('Outgoing %d objects%s', $n, ($n >= $windowSize) ? ' of '.$changecount : ''), $this->singleFolder); |
|
1243 | 1243 | $this->saveMultiFolderInfo('outgoing', $n); |
1244 | 1244 | $this->saveMultiFolderInfo('queued', $changecount); |
1245 | 1245 | |
@@ -1502,7 +1502,7 @@ discard block |
||
1502 | 1502 | SLog::Write(LOGLEVEL_DEBUG, 'SMS sync are not supported. Ignoring message.'); |
1503 | 1503 | // TODO we should create the SMS |
1504 | 1504 | // return a fake serverid which we can identify later |
1505 | - $actiondata['clientids'][$clientid] = self::GSYNCIGNORESMS . $clientid; |
|
1505 | + $actiondata['clientids'][$clientid] = self::GSYNCIGNORESMS.$clientid; |
|
1506 | 1506 | $actiondata['statusids'][$clientid] = SYNC_STATUS_SUCCESS; |
1507 | 1507 | } |
1508 | 1508 | // check incoming message without logging WARN messages about errors |
@@ -1591,9 +1591,9 @@ discard block |
||
1591 | 1591 | * @return string |
1592 | 1592 | */ |
1593 | 1593 | private function getMultiFolderInfoLine($amountOfFolders) { |
1594 | - $s = $amountOfFolders . ' folders'; |
|
1594 | + $s = $amountOfFolders.' folders'; |
|
1595 | 1595 | if (isset($this->multiFolderInfo['incoming'])) { |
1596 | - $s .= ': ' . $this->multiFolderInfo['incoming'] . ' saved'; |
|
1596 | + $s .= ': '.$this->multiFolderInfo['incoming'].' saved'; |
|
1597 | 1597 | } |
1598 | 1598 | if (isset($this->multiFolderInfo['outgoing'], $this->multiFolderInfo['queued']) && $this->multiFolderInfo['outgoing'] > 0) { |
1599 | 1599 | $s .= sprintf(': Streamed %d out of %d', $this->multiFolderInfo['outgoing'], $this->multiFolderInfo['queued']); |
@@ -1601,10 +1601,10 @@ discard block |
||
1601 | 1601 | $s .= ': no changes'; |
1602 | 1602 | } else { |
1603 | 1603 | if (isset($this->multiFolderInfo['outgoing'])) { |
1604 | - $s .= '/' . $this->multiFolderInfo['outgoing'] . ' streamed'; |
|
1604 | + $s .= '/'.$this->multiFolderInfo['outgoing'].' streamed'; |
|
1605 | 1605 | } |
1606 | 1606 | if (isset($this->multiFolderInfo['queued'])) { |
1607 | - $s .= '/' . $this->multiFolderInfo['queued'] . ' queued'; |
|
1607 | + $s .= '/'.$this->multiFolderInfo['queued'].' queued'; |
|
1608 | 1608 | } |
1609 | 1609 | } |
1610 | 1610 | if (isset($this->multiFolderInfo['exception'])) { |
@@ -34,7 +34,7 @@ |
||
34 | 34 | SYNC_FOLDERHIERARCHY_TYPE => [self::STREAMER_VAR => 'type', |
35 | 35 | self::STREAMER_CHECKS => [self::STREAMER_CHECK_REQUIRED => 18, |
36 | 36 | self::STREAMER_CHECK_CMPHIGHER => 0, |
37 | - self::STREAMER_CHECK_CMPLOWER => 20, ], ], |
|
37 | + self::STREAMER_CHECK_CMPLOWER => 20, ], ], |
|
38 | 38 | |
39 | 39 | SYNC_FOLDERHIERARCHY_IGNORE_STORE => [self::STREAMER_VAR => 'Store', |
40 | 40 | self::STREAMER_TYPE => self::STREAMER_TYPE_IGNORE, ], |
@@ -39,7 +39,7 @@ discard block |
||
39 | 39 | * @return string |
40 | 40 | */ |
41 | 41 | public function __toString() { |
42 | - $str = get_class($this) . " (\n"; |
|
42 | + $str = get_class($this)." (\n"; |
|
43 | 43 | |
44 | 44 | $streamerVars = []; |
45 | 45 | foreach ($this->mapping as $k => $v) { |
@@ -59,14 +59,14 @@ discard block |
||
59 | 59 | |
60 | 60 | // self::STREAMER_ARRAY ? |
61 | 61 | if (is_array($v)) { |
62 | - $str .= "\t" . $strV . $k . '(Array) size: ' . count($v) . "\n"; |
|
62 | + $str .= "\t".$strV.$k.'(Array) size: '.count($v)."\n"; |
|
63 | 63 | foreach ($v as $value) { |
64 | - $str .= "\t\t" . Utils::PrintAsString($value) . "\n"; |
|
64 | + $str .= "\t\t".Utils::PrintAsString($value)."\n"; |
|
65 | 65 | } |
66 | 66 | } elseif ($v instanceof SyncObject) { |
67 | - $str .= "\t" . $strV . $k . ' => ' . str_replace("\n", "\n\t\t\t", $v->__toString()) . "\n"; |
|
67 | + $str .= "\t".$strV.$k.' => '.str_replace("\n", "\n\t\t\t", $v->__toString())."\n"; |
|
68 | 68 | } else { |
69 | - $str .= "\t" . $strV . $k . ' => ' . (isset($this->{$k}) ? Utils::PrintAsString($this->{$k}) : 'null') . "\n"; |
|
69 | + $str .= "\t".$strV.$k.' => '.(isset($this->{$k}) ? Utils::PrintAsString($this->{$k}) : 'null')."\n"; |
|
70 | 70 | } |
71 | 71 | } |
72 | 72 | $str .= ')'; |