Sync::importMessage()

Complexity

Conditions	29
Paths	296

Size

Total Lines	145
Code Lines	78

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
	private function importMessage($spa, &$actiondata, $todo, $message, $clientid, $serverid, $foldertype, $messageCount) {
		// the importer needs to be available!
		if ($this->importer == false) {
			throw new StatusException("Sync->importMessage(): importer not available", SYNC_STATUS_SERVERERROR);
		}

		// mark this state as used, e.g. for HeartBeat
		self::$deviceManager->SetHeartbeatStateIntegrity($spa->GetFolderId(), $spa->GetUuid(), $spa->GetUuidCounter());

		// Detect incoming loop
		// messages which were created/removed before will not have the same action executed again
		// if a message is edited we perform this action "again", as the message could have been changed on the mobile in the meantime
		$ignoreMessage = false;
		if ($actiondata["failstate"]) {
			// message was ADDED before, do NOT add it again
			if ($todo == SYNC_ADD && isset($actiondata["failstate"]["clientids"][$clientid])) {
				$ignoreMessage = true;

				// make sure no messages are sent back
				self::$deviceManager->SetWindowSize($spa->GetFolderId(), 0);

				$actiondata["clientids"][$clientid] = $actiondata["failstate"]["clientids"][$clientid];
				$actiondata["statusids"][$clientid] = $actiondata["failstate"]["statusids"][$clientid];

				SLog::Write(LOGLEVEL_INFO, sprintf("Mobile loop detected! Incoming new message '%s' was created on the server before. Replying with known new server id: %s", $clientid, $actiondata["clientids"][$clientid]));
			}

			// message was REMOVED before, do NOT attempt to remove it again
			if ($todo == SYNC_REMOVE && isset($actiondata["failstate"]["removeids"][$serverid])) {
				$ignoreMessage = true;

				// make sure no messages are sent back
				self::$deviceManager->SetWindowSize($spa->GetFolderId(), 0);

				$actiondata["removeids"][$serverid] = $actiondata["failstate"]["removeids"][$serverid];
				$actiondata["statusids"][$serverid] = $actiondata["failstate"]["statusids"][$serverid];

				SLog::Write(LOGLEVEL_INFO, sprintf("Mobile loop detected! Message '%s' was deleted by the mobile before. Replying with known status: %s", $clientid, $actiondata["statusids"][$serverid]));
			}
		}

		if (!$ignoreMessage) {
			switch ($todo) {
				case SYNC_MODIFY:
					self::$topCollector->AnnounceInformation(sprintf("Saving modified message %d", $messageCount));

					try {
						// ignore sms messages
						if ($foldertype == "SMS" || stripos($serverid, self::GSYNCIGNORESMS) !== false) {
							SLog::Write(LOGLEVEL_DEBUG, "SMS sync are not supported. Ignoring message.");
							// TODO we should update the SMS
							$actiondata["statusids"][$serverid] = SYNC_STATUS_SUCCESS;
						}
						// check incoming message without logging WARN messages about errors
						elseif (!($message instanceof SyncObject) || !$message->Check(true)) {

$message is always a sub-type of SyncObject.

							$actiondata["statusids"][$serverid] = SYNC_STATUS_CLIENTSERVERCONVERSATIONERROR;
						}
						else {
							// if there is just a read flag change, import it via ImportMessageReadFlag()
							if (isset($message->read) && !isset($message->flag) && $message->getCheckedParameters() < 3) {
								$response = $this->importer->ImportMessageReadFlag($serverid, $message->read);
							}
							else {
								$response = $this->importer->ImportMessageChange($serverid, $message);
							}

							$response->serverid = $serverid;
							$actiondata["modifyids"][$serverid] = $response;
							$actiondata["statusids"][$serverid] = SYNC_STATUS_SUCCESS;
						}
					}
					catch (StatusException $stex) {
						$actiondata["statusids"][$serverid] = $stex->getCode();
					}
					break;

				case SYNC_ADD:
					self::$topCollector->AnnounceInformation(sprintf("Creating new message from mobile %d", $messageCount));

					try {
						// mark the message as new message so SyncObject->Check() can differentiate
						$message->flags = SYNC_NEWMESSAGE;

						// ignore sms messages
						if ($foldertype == "SMS") {
							SLog::Write(LOGLEVEL_DEBUG, "SMS sync are not supported. Ignoring message.");
							// TODO we should create the SMS
							// return a fake serverid which we can identify later
							$actiondata["clientids"][$clientid] = self::GSYNCIGNORESMS . $clientid;
							$actiondata["statusids"][$clientid] = SYNC_STATUS_SUCCESS;
						}
						// check incoming message without logging WARN messages about errors
						elseif (!($message instanceof SyncObject) || !$message->Check(true)) {

$message is always a sub-type of SyncObject.

							$actiondata["clientids"][$clientid] = false;
							$actiondata["statusids"][$clientid] = SYNC_STATUS_CLIENTSERVERCONVERSATIONERROR;
						}
						else {
							$actiondata["clientids"][$clientid] = false;
							$actiondata["clientids"][$clientid] = $this->importer->ImportMessageChange(false, $message);
							$actiondata["statusids"][$clientid] = SYNC_STATUS_SUCCESS;
						}
					}
					catch (StatusException $stex) {
						$actiondata["statusids"][$clientid] = $stex->getCode();
					}
					break;

				case SYNC_REMOVE:
					self::$topCollector->AnnounceInformation(sprintf("Deleting message removed on mobile %d", $messageCount));

					try {
						$actiondata["removeids"][] = $serverid;
						// ignore sms messages
						if ($foldertype == "SMS" || stripos($serverid, self::GSYNCIGNORESMS) !== false) {
							SLog::Write(LOGLEVEL_DEBUG, "SMS sync are not supported. Ignoring message.");
							// TODO we should delete the SMS
							$actiondata["statusids"][$serverid] = SYNC_STATUS_SUCCESS;
						}
						else {
							// if message deletions are to be moved, move them
							if ($spa->GetDeletesAsMoves()) {

The method GetDeletesAsMoves() does not exist on SyncParameters. Since you implemented __call, consider adding a @method annotation.

								$folderid = self::$backend->GetWasteBasket();

								if ($folderid) {
									$actiondata["statusids"][$serverid] = SYNC_STATUS_SUCCESS;
									$this->importer->ImportMessageMove($serverid, $folderid);

									break;
								}

								SLog::Write(LOGLEVEL_WARN, "Message should be moved to WasteBasket, but the Backend did not return a destination ID. Message is hard deleted now!");
							}

							$this->importer->ImportMessageDeletion($serverid);
							$actiondata["statusids"][$serverid] = SYNC_STATUS_SUCCESS;
						}
					}
					catch (StatusException $stex) {
						if ($stex->getCode() != SYNC_MOVEITEMSSTATUS_SUCCESS) {
							$actiondata["statusids"][$serverid] = SYNC_STATUS_OBJECTNOTFOUND;
						}
					}
					break;
			}
			SLog::Write(LOGLEVEL_DEBUG, "Sync->importMessage(): message imported");
		}