grommunio / grommunio-web

plugins/files/php/cssloader.php

Indentation +17 added lines, -17 removed lines

@@ -9,14 +9,14 @@ 
 
 // in source mode load the non minifyed css
 if (isset($_GET['source'])) {
-	$content .= file_get_contents("../resources/css/files-main.css");
-	$content .= file_get_contents("../resources/css/icons.css");
-	$content .= file_get_contents("../resources/css/navbar.css");
-	$content .= file_get_contents("../resources/css/pdfjspanel.css");
-	$content .= file_get_contents("../resources/css/webodfpanel.css");
+    $content .= file_get_contents("../resources/css/files-main.css");
+    $content .= file_get_contents("../resources/css/icons.css");
+    $content .= file_get_contents("../resources/css/navbar.css");
+    $content .= file_get_contents("../resources/css/pdfjspanel.css");
+    $content .= file_get_contents("../resources/css/webodfpanel.css");
 }
 else {
-	$content .= file_get_contents("../resources/css/files" . $debug . ".css");
+    $content .= file_get_contents("../resources/css/files" . $debug . ".css");
 }
 
 // try to load all backend form config javascript files
@@ -25,17 +25,17 @@ 
 
 // Populate the list of directories to check against
 if (($directoryHandle = opendir($BACKEND_PATH)) !== false) {
-	while (($backend = readdir($directoryHandle)) !== false) {
-		// Make sure we're not dealing with a file or a link to the parent directory
-		if (is_dir($BACKEND_PATH . $backend) && ($backend == '.' || $backend == '..') !== true) {
-			if (is_file($BACKEND_PATH . $backend . $BACKEND_CSS_LOADER)) {
-				include $BACKEND_PATH . $backend . $BACKEND_CSS_LOADER;
-				$class = "\\Files\\Backend\\{$backend}\\BackendCSSLoader";
-				$cssloader = new $class();
-				$content .= $cssloader->get_combined_css($_GET['debug']);
-			}
-		}
-	}
+    while (($backend = readdir($directoryHandle)) !== false) {
+        // Make sure we're not dealing with a file or a link to the parent directory
+        if (is_dir($BACKEND_PATH . $backend) && ($backend == '.' || $backend == '..') !== true) {
+            if (is_file($BACKEND_PATH . $backend . $BACKEND_CSS_LOADER)) {
+                include $BACKEND_PATH . $backend . $BACKEND_CSS_LOADER;
+                $class = "\\Files\\Backend\\{$backend}\\BackendCSSLoader";
+                $cssloader = new $class();
+                $content .= $cssloader->get_combined_css($_GET['debug']);
+            }
+        }
+    }
 }
 
 echo $content;

Braces +1 added lines, -2 removed lines

@@ -14,8 +14,7 @@
 	$content .= file_get_contents("../resources/css/navbar.css");
 	$content .= file_get_contents("../resources/css/pdfjspanel.css");
 	$content .= file_get_contents("../resources/css/webodfpanel.css");
-}
-else {
+} else {
 	$content .= file_get_contents("../resources/css/files" . $debug . ".css");
 }
 

plugins/files/php/class.filesbrowsermodule.php

Indentation +1321 added lines, -1321 removed lines

@@ -29,1330 +29,1330 @@
  * @extends ListModule
  */
 class FilesBrowserModule extends FilesListModule {
-	public const LOG_CONTEXT = "FilesBrowserModule"; // Context for the Logger
-
-	/**
-	 * Creates the notifiers for this module,
-	 * and register them to the Bus.
-	 */
-	public function createNotifiers() {
-		$GLOBALS["bus"]->registerNotifier('fileshierarchynotifier', REQUEST_ENTRYID);
-	}
-
-	/**
-	 * Executes all the actions in the $data variable.
-	 * Exception part is used for authentication errors also.
-	 *
-	 * @return bool true on success or false on failure
-	 */
-	public function execute() {
-		$result = false;
-
-		foreach ($this->data as $actionType => $actionData) {
-			if (isset($actionType)) {
-				try {
-					switch ($actionType) {
-						case "checkifexists":
-							$records = $actionData["records"];
-							$destination = isset($actionData["destination"]) ? $actionData["destination"] : false;
-							$result = $this->checkIfExists($records, $destination);
-							$response = [];
-							$response['status'] = true;
-							$response['duplicate'] = $result;
-							$this->addActionData($actionType, $response);
-							$GLOBALS["bus"]->addData($this->getResponseData());
-							break;
-
-						case "downloadtotmp":
-							$result = $this->downloadSelectedFilesToTmp($actionType, $actionData);
-							break;
-
-						case "createdir":
-							$this->save($actionData);
-							$result = true;
-							break;
-
-						case "rename":
-							$result = $this->rename($actionType, $actionData);
-							break;
-
-						case "uploadtobackend":
-							$result = $this->uploadToBackend($actionType, $actionData);
-							break;
-
-						case "save":
-							if ((isset($actionData["props"]["sharedid"]) || isset($actionData["props"]["isshared"])) && (!isset($actionData["props"]["deleted"]) || !isset($actionData["props"]["message_size"]))) {
-								// JUST IGNORE THIS REQUEST - we don't need to interact with the backend if a share was changed
-								$response['status'] = true;
-								$folder = [];
-								$folder[$actionData['entryid']] = [
-									'props' => $actionData["props"],
-									'entryid' => $actionData['entryid'],
-									'store_entryid' => 'files',
-									'parent_entryid' => $actionData['parent_entryid'],
-								];
-
-								$response['item'] = array_values($folder);
-								$this->addActionData("update", $response);
-								$GLOBALS["bus"]->addData($this->getResponseData());
-
-								break;
-							}
-
-							/*
+    public const LOG_CONTEXT = "FilesBrowserModule"; // Context for the Logger
+
+    /**
+     * Creates the notifiers for this module,
+     * and register them to the Bus.
+     */
+    public function createNotifiers() {
+        $GLOBALS["bus"]->registerNotifier('fileshierarchynotifier', REQUEST_ENTRYID);
+    }
+
+    /**
+     * Executes all the actions in the $data variable.
+     * Exception part is used for authentication errors also.
+     *
+     * @return bool true on success or false on failure
+     */
+    public function execute() {
+        $result = false;
+
+        foreach ($this->data as $actionType => $actionData) {
+            if (isset($actionType)) {
+                try {
+                    switch ($actionType) {
+                        case "checkifexists":
+                            $records = $actionData["records"];
+                            $destination = isset($actionData["destination"]) ? $actionData["destination"] : false;
+                            $result = $this->checkIfExists($records, $destination);
+                            $response = [];
+                            $response['status'] = true;
+                            $response['duplicate'] = $result;
+                            $this->addActionData($actionType, $response);
+                            $GLOBALS["bus"]->addData($this->getResponseData());
+                            break;
+
+                        case "downloadtotmp":
+                            $result = $this->downloadSelectedFilesToTmp($actionType, $actionData);
+                            break;
+
+                        case "createdir":
+                            $this->save($actionData);
+                            $result = true;
+                            break;
+
+                        case "rename":
+                            $result = $this->rename($actionType, $actionData);
+                            break;
+
+                        case "uploadtobackend":
+                            $result = $this->uploadToBackend($actionType, $actionData);
+                            break;
+
+                        case "save":
+                            if ((isset($actionData["props"]["sharedid"]) || isset($actionData["props"]["isshared"])) && (!isset($actionData["props"]["deleted"]) || !isset($actionData["props"]["message_size"]))) {
+                                // JUST IGNORE THIS REQUEST - we don't need to interact with the backend if a share was changed
+                                $response['status'] = true;
+                                $folder = [];
+                                $folder[$actionData['entryid']] = [
+                                    'props' => $actionData["props"],
+                                    'entryid' => $actionData['entryid'],
+                                    'store_entryid' => 'files',
+                                    'parent_entryid' => $actionData['parent_entryid'],
+                                ];
+
+                                $response['item'] = array_values($folder);
+                                $this->addActionData("update", $response);
+                                $GLOBALS["bus"]->addData($this->getResponseData());
+
+                                break;
+                            }
+
+                            /*
 							 * The "message_action" object has been set, check the action_type field for
 							 * the exact action which must be taken.
 							 * Supported actions:
 							 *   - move: move record to new folder
 							 */
-							if (isset($actionData["message_action"], $actionData["message_action"]["action_type"])) {
-								switch ($actionData["message_action"]["action_type"]) {
-									case "move" :
-										$result = $this->move($actionType, $actionData);
-										break;
-
-									default:
-										// check if we should create something new or edit an existing file/folder
-										if (isset($actionData["entryid"])) {
-											$result = $this->rename($actionType, $actionData);
-										}
-										else {
-											$result = $this->save($actionData);
-										}
-										break;
-								}
-							}
-							else {
-								// check if we should create something new or edit an existing file/folder
-								if (isset($actionData["entryid"])) {
-									$result = $this->rename($actionType, $actionData);
-								}
-								else {
-									$result = $this->save($actionData);
-								}
-							}
-							break;
-
-						case "delete":
-							$result = $this->delete($actionType, $actionData);
-							break;
-
-						case "list":
-							$result = $this->loadFiles($actionType, $actionData);
-							break;
-
-						case "loadsharingdetails":
-							$result = $this->getSharingInformation($actionType, $actionData);
-							break;
-
-						case "createnewshare":
-							$result = $this->createNewShare($actionType, $actionData);
-							break;
-
-						case "updateexistingshare":
-							$result = $this->updateExistingShare($actionType, $actionData);
-							break;
-
-						case "deleteexistingshare":
-							$result = $this->deleteExistingShare($actionType, $actionData);
-							break;
-
-						case "updatecache":
-							$result = $this->updateCache($actionType, $actionData);
-							break;
-
-						default:
-							$this->handleUnknownActionType($actionType);
-					}
-				}
-				catch (MAPIException $e) {
-					$this->sendFeedback(false, $this->errorDetailsFromException($e));
-				}
-				catch (AccountException $e) {
-					$this->sendFeedback(false, [
-						'type' => ERROR_GENERAL,
-						'info' => [
-							'title' => $e->getTitle(),
-							'original_message' => $e->getMessage(),
-							'display_message' => $e->getMessage(),
-						],
-					]);
-				}
-				catch (BackendException $e) {
-					$this->sendFeedback(false, [
-						'type' => ERROR_GENERAL,
-						'info' => [
-							'title' => $e->getTitle(),
-							'original_message' => $e->getMessage(),
-							'display_message' => $e->getMessage(),
-							'code' => $e->getCode(),
-						],
-					]);
-				}
-			}
-		}
-
-		return $result;
-	}
-
-	/**
-	 * loads content of current folder - list of folders and files from Files.
-	 *
-	 * @param string $actionType name of the current action
-	 * @param array  $actionData all parameters contained in this request
-	 *
-	 * @throws BackendException if the backend request fails
-	 *
-	 * @return bool
-	 */
-	public function loadFiles($actionType, $actionData) {
-		$nodeId = $actionData['id'];
-		$onlyFiles = isset($actionData['only_files']) ? $actionData['only_files'] : false;
-		$response = [];
-		$nodes = [];
-
-		$accountID = $this->accountIDFromNode($nodeId);
-
-		// check if we are in the ROOT (#R#). If so, display some kind of device/account view.
-		if (empty($accountID) || !$this->accountStore->getAccount($accountID)) {
-			$accounts = $this->accountStore->getAllAccounts();
-			foreach ($accounts as $account) { // we have to load all accounts and their folders
-				// skip accounts that are not valid
-				if ($account->getStatus() != \Files\Core\Account::STATUS_OK) {
-					continue;
-				}
-				// build the real node id for this folder
-				$realNodeId = $nodeId . $account->getId() . "/";
-
-				$nodes[$realNodeId] = ['props' => [
-					'id' => rawurldecode($realNodeId),
-					'folder_id' => rawurldecode($realNodeId),
-					'path' => $realNodeId,
-					'filename' => $account->getName(),
-					'message_size' => -1,
-					'lastmodified' => -1,
-					'message_class' => "IPM.Files",
-					'type' => 0,
-				],
-					'entryid' => $this->createId($realNodeId),
-					'store_entryid' => $this->createId($realNodeId),
-					'parent_entryid' => $this->createId($realNodeId),
-				];
-			}
-		}
-		else {
-			$account = $this->accountStore->getAccount($accountID);
-
-			// initialize the backend
-			$initializedBackend = $this->initializeBackend($account, true);
-
-			$starttime = microtime(true);
-			$nodes = $this->getFolderContent($nodeId, $initializedBackend, $onlyFiles);
-			Logger::debug(self::LOG_CONTEXT, "[loadfiles]: getFolderContent took: " . (microtime(true) - $starttime) . " seconds");
-
-			$nodes = $this->sortFolderContent($nodes, $actionData, false);
-		}
-
-		$response["item"] = array_values($nodes);
-
-		$response['page'] = ["start" => 0, "rowcount" => 50, "totalrowcount" => count($response["item"])];
-		$response['folder'] = ["content_count" => count($response["item"]), "content_unread" => 0];
-
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		return true;
-	}
-
-	/**
-	 * Forms the structure needed for frontend
-	 * for the list of folders and files.
-	 *
-	 * @param string                        $nodeId          the name of the current root directory
-	 * @param Files\Backend\AbstractBackend $backendInstance
-	 * @param bool                          $onlyFiles       if true, get only files
-	 *
-	 * @throws BackendException if the backend request fails
-	 *
-	 * @return array of nodes for current path folder
-	 */
-	public function getFolderContent($nodeId, $backendInstance, $onlyFiles = false) {
-		$nodes = [];
-
-		// relative node ID. We need to trim off the #R# and account ID
-		$relNodeId = substr($nodeId, strpos($nodeId, '/'));
-		$nodeIdPrefix = substr($nodeId, 0, strpos($nodeId, '/'));
-
-		$accountID = $backendInstance->getAccountID();
-
-		// remove the trailing slash for the cache key
-		$cachePath = rtrim($relNodeId, '/');
-		if ($cachePath === "") {
-			$cachePath = "/";
-		}
-
-		$dir = $this->getCache($accountID, $cachePath);
-		if (is_null($dir)) {
-			$dir = $backendInstance->ls($relNodeId);
-			$this->setCache($accountID, $cachePath, $dir);
-		}
-
-		// FIXME: There is something issue with getting sharing information from owncloud.
-		// check if backend supports sharing and load the information
-		if ($backendInstance->supports(\Files\Backend\BackendStore::FEATURE_SHARING)) {
-			Logger::debug(self::LOG_CONTEXT, "Checking for shared folders! ({$relNodeId})");
-
-			$time_start = microtime(true);
-
-			/** @var \Files\Backend\iFeatureSharing $backendInstance */
-			$sharingInfo = $backendInstance->getShares($relNodeId);
-			$time_end = microtime(true);
-			$time = $time_end - $time_start;
-
-			Logger::debug(self::LOG_CONTEXT, "Checking for shared took {$time} s!");
-		}
-
-		if ($dir) {
-			$updateCache = false;
-			foreach ($dir as $id => $node) {
-				$type = FILES_FILE;
-
-				if (strcmp($node['resourcetype'], "collection") == 0) { // we have a folder
-					$type = FILES_FOLDER;
-				}
-
-				if ($type === FILES_FOLDER && $onlyFiles) {
-					continue;
-				}
-
-				// Check if foldernames have a trailing slash, if not, add one!
-				if ($type === FILES_FOLDER && !StringUtil::endsWith($id, "/")) {
-					$id .= "/";
-				}
-
-				$realID = $nodeIdPrefix . $id;
-
-				Logger::debug(self::LOG_CONTEXT, "parsing: " . $id . " in base: " . $nodeId);
-
-				$filename = stringToUTF8Encode(basename($id));
-
-				$size = $node['getcontentlength'] === null ? -1 : intval($node['getcontentlength']);
-				$size = $type == FILES_FOLDER ? -1 : $size; // folder's dont have a size
-
-				$fileid = $node['fileid'] === "-1" ? -1 : intval($node['fileid']);
-
-				$shared = false;
-				$sharedid = [];
-				if (isset($sharingInfo) && count($sharingInfo[$relNodeId]) > 0) {
-					foreach ($sharingInfo[$relNodeId] as $sid => $sdetails) {
-						if ($sdetails["path"] == rtrim($id, "/")) {
-							$shared = true;
-							$sharedid[] = $sid;
-						}
-					}
-				}
-
-				$nodeId = stringToUTF8Encode($id);
-				$dirName = dirname($nodeId, 1);
-				if ($dirName === '/') {
-					$path = stringToUTF8Encode($nodeIdPrefix . $dirName);
-				}
-				else {
-					$path = stringToUTF8Encode($nodeIdPrefix . $dirName . '/');
-				}
-
-				if (!isset($node['entryid']) || !isset($node['parent_entryid']) || !isset($node['store_entryid'])) {
-					$entryid = $this->createId($realID);
-					$parentEntryid = $this->createId($path);
-					$storeEntryid = $this->createId($nodeIdPrefix . '/');
-
-					$dir[$id]['entryid'] = $entryid;
-					$dir[$id]['parent_entryid'] = $parentEntryid;
-					$dir[$id]['store_entryid'] = $storeEntryid;
-
-					$updateCache = true;
-				}
-				else {
-					$entryid = $node['entryid'];
-					$parentEntryid = $node['parent_entryid'];
-					$storeEntryid = $node['store_entryid'];
-				}
-
-				$nodes[$nodeId] = ['props' => [
-					'folder_id' => stringToUTF8Encode($realID),
-					'fileid' => $fileid,
-					'path' => $path,
-					'filename' => $filename,
-					'message_size' => $size,
-					'lastmodified' => strtotime($node['getlastmodified']) * 1000,
-					'message_class' => "IPM.Files",
-					'isshared' => $shared,
-					'sharedid' => $sharedid,
-					'object_type' => $type,
-					'type' => $type,
-				],
-					'entryid' => $entryid,
-					'parent_entryid' => $parentEntryid,
-					'store_entryid' => $storeEntryid,
-				];
-			}
-
-			// Update the cache.
-			if ($updateCache) {
-				$this->setCache($accountID, $cachePath, $dir);
-			}
-		}
-		else {
-			Logger::debug(self::LOG_CONTEXT, "dir was empty");
-		}
-
-		return $nodes;
-	}
-
-	/**
-	 * This functions sorts an array of nodes.
-	 *
-	 * @param array $nodes   array of nodes to sort
-	 * @param array $data    all parameters contained in the request
-	 * @param bool  $navtree parse for navtree or browser
-	 *
-	 * @return array of sorted nodes
-	 */
-	public function sortFolderContent($nodes, $data, $navtree = false) {
-		$sortednodes = [];
-
-		$sortkey = "filename";
-		$sortdir = "ASC";
-
-		if (isset($data['sort'])) {
-			$sortkey = $data['sort'][0]['field'];
-			$sortdir = $data['sort'][0]['direction'];
-		}
-
-		Logger::debug(self::LOG_CONTEXT, "sorting by " . $sortkey . " in direction: " . $sortdir);
-
-		if ($navtree) {
-			$sortednodes = ArrayUtil::sort_by_key($nodes, $sortkey, $sortdir);
-		}
-		else {
-			$sortednodes = ArrayUtil::sort_props_by_key($nodes, $sortkey, $sortdir);
-		}
-
-		return $sortednodes;
-	}
-
-	/**
-	 * Deletes the selected files on the backend server.
-	 *
-	 * @param string $actionType name of the current action
-	 * @param array  $actionData all parameters contained in this request
-	 *
-	 * @throws BackendException if the backend request fails
-	 *
-	 * @return bool
-	 */
-	private function delete($actionType, $actionData) {
-		// TODO: function is duplicate of class.hierarchylistmodule.php of delete function.
-		$result = false;
-		if (isset($actionData['records']) && is_array($actionData['records'])) {
-			foreach ($actionData['records'] as $record) {
-				$nodeId = $record['folder_id'];
-				$relNodeId = substr($nodeId, strpos($nodeId, '/'));
-
-				$account = $this->accountFromNode($nodeId);
-
-				// initialize the backend
-				$initializedBackend = $this->initializeBackend($account);
-
-				$result = $initializedBackend->delete($relNodeId);
-				Logger::debug(self::LOG_CONTEXT, "deleted: " . $nodeId . ", worked: " . $result);
-
-				// clear the cache
-				$this->deleteCache($account->getId(), dirname($relNodeId));
-				$GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_DELETE, [
-					"id" => $nodeId,
-					"folder_id" => $nodeId,
-					"entryid" => $record['entryid'],
-					"parent_entryid" => $record["parent_entryid"],
-					"store_entryid" => $record["store_entryid"],
-				]);
-			}
-
-			$response['status'] = true;
-			$this->addActionData($actionType, $response);
-			$GLOBALS["bus"]->addData($this->getResponseData());
-		}
-		else {
-			$nodeId = $actionData['folder_id'];
-
-			$relNodeId = substr($nodeId, strpos($nodeId, '/'));
-			$response = [];
-
-			$account = $this->accountFromNode($nodeId);
-			$accountId = $account->getId();
-			// initialize the backend
-			$initializedBackend = $this->initializeBackend($account);
-
-			try {
-				$result = $initializedBackend->delete($relNodeId);
-			}
-			catch (\Files\Backend\Exception $e) {
-				// TODO: this might fails because the file was already deleted.
-				// fire error message if any other error occurred.
-				Logger::debug(self::LOG_CONTEXT, "deleted a directory that was no longer available");
-			}
-			Logger::debug(self::LOG_CONTEXT, "deleted: " . $nodeId . ", worked: " . $result);
-
-			// Get old cached data.
-			$cachedDir = $this->getCache($accountId, dirname($relNodeId));
-			if (isset($cachedDir[$relNodeId]) && !empty($cachedDir[$relNodeId])) {
-				// Delete the folder from cached data.
-				unset($cachedDir[$relNodeId]);
-			}
-
-			// clear the cache of parent directory.
-			$this->deleteCache($accountId, dirname($relNodeId));
-			// clear the cache of selected directory.
-			$this->deleteCache($accountId, rtrim($relNodeId, '/'));
-
-			// Set data in cache.
-			$this->setCache($accountId, dirname($relNodeId), $cachedDir);
-
-			$response['status'] = $result ? true : false;
-			$this->addActionData($actionType, $response);
-			$GLOBALS["bus"]->addData($this->getResponseData());
-
-			$GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_DELETE, [
-				"entryid" => $actionData["entryid"],
-				"parent_entryid" => $actionData["parent_entryid"],
-				"store_entryid" => $actionData["store_entryid"],
-			]);
-		}
-
-		return true;
-	}
-
-	/**
-	 * Moves the selected files on the backend server.
-	 *
-	 * @param string $actionType name of the current action
-	 * @param array  $actionData all parameters contained in this request
-	 *
-	 * @return bool if the backend request failed
-	 */
-	private function move($actionType, $actionData) {
-		$dst = rtrim($actionData['message_action']["destination_folder_id"], '/');
-
-		$overwrite = isset($actionData['message_action']["overwrite"]) ? $actionData['message_action']["overwrite"] : true;
-		$isFolder = isset($actionData['message_action']["isFolder"]) ? $actionData['message_action']["isFolder"] : false;
-
-		$pathPostfix = "";
-		if (substr($actionData['folder_id'], -1) == '/') {
-			$pathPostfix = "/"; // we have a folder...
-		}
-
-		$source = rtrim($actionData['folder_id'], '/');
-		$fileName = basename($source);
-		$destination = $dst . '/' . basename($source);
-
-		// get dst and source account ids
-		// currently only moving within one account is supported
-		$srcAccountID = substr($actionData['folder_id'], 3, (strpos($actionData['folder_id'], '/') - 3)); // parse account id from node id
-		$dstAccountID = substr($actionData['message_action']["destination_folder_id"], 3, (strpos($actionData['message_action']["destination_folder_id"], '/') - 3)); // parse account id from node id
-
-		if ($srcAccountID !== $dstAccountID) {
-			$this->sendFeedback(false, [
-				'type' => ERROR_GENERAL,
-				'info' => [
-					'title' => _("Files Plugin"),
-					'original_message' => _("Moving between accounts is not implemented"),
-					'display_message' => _("Moving between accounts is not implemented"),
-				],
-			]);
-
-			return false;
-		}
-		$relDst = substr($destination, strpos($destination, '/'));
-		$relSrc = substr($source, strpos($source, '/'));
-
-		$account = $this->accountFromNode($source);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		$result = $initializedBackend->move($relSrc, $relDst, $overwrite);
-
-		$actionId = $account->getId();
-		// clear the cache
-		$this->deleteCache($actionId, dirname($relDst));
-
-		$cachedFolderName = $relSrc . $pathPostfix;
-		$this->deleteCache($actionId, $cachedFolderName);
-
-		$cached = $this->getCache($actionId, dirname($relSrc));
-		$this->deleteCache($actionId, dirname($relSrc));
-
-		if (isset($cached[$cachedFolderName]) && !empty($cached[$cachedFolderName])) {
-			unset($cached[$cachedFolderName]);
-			$this->setCache($actionId, dirname($relSrc), $cached);
-		}
-
-		$response['status'] = !$result ? false : true;
-
-		/* create the response object */
-		$folder = [
-			'props' => [
-				'folder_id' => ($destination . $pathPostfix),
-				'path' => $actionData['message_action']["destination_folder_id"],
-				'filename' => $fileName,
-				'display_name' => $fileName,
-				'object_type' => $isFolder ? FILES_FOLDER : FILES_FILE,
-				'deleted' => !$result ? false : true,
-			],
-			'entryid' => $this->createId($destination . $pathPostfix),
-			'store_entryid' => $actionData['store_entryid'],
-			'parent_entryid' => $actionData['message_action']['parent_entryid'],
-		];
-
-		$response['item'] = $folder;
-
-		$this->addActionData("update", $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		// Notify hierarchy only when folder was moved.
-		if ($isFolder) {
-			// Send notification to delete folder node in hierarchy.
-			$GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_DELETE, [
-				"entryid" => $actionData["entryid"],
-				"parent_entryid" => $actionData["parent_entryid"],
-				"store_entryid" => $actionData["store_entryid"],
-			]);
-
-			// Send notification to create new folder node in hierarchy.
-			$GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_SAVE, $folder);
-		}
-
-		return true;
-	}
-
-	/**
-	 * Renames the selected file on the backend server.
-	 *
-	 * @param string $actionType name of the current action
-	 * @param array  $actionData all parameters contained in this request
-	 *
-	 * @throws BackendException if the backend request fails
-	 *
-	 * @return bool
-	 */
-	public function rename($actionType, $actionData) {
-		$messageProps = $this->save($actionData);
-		$notifySubFolders = isset($actionData['message_action']['isFolder']) ? $actionData['message_action']['isFolder'] : true;
-		if (!empty($messageProps)) {
-			$GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_SAVE, $messageProps);
-			if ($notifySubFolders) {
-				$this->notifySubFolders($messageProps["props"]["folder_id"]);
-			}
-		}
-	}
-
-	/**
-	 * Check if given filename or folder already exists on server.
-	 *
-	 * @param array $records     which needs to be check for existence
-	 * @param array $destination where the given records needs to be moved, uploaded, or renamed
-	 *
-	 * @throws BackendException if the backend request fails
-	 *
-	 * @return bool True if duplicate found, false otherwise
-	 */
-	private function checkIfExists($records, $destination) {
-		$duplicate = false;
-
-		if (isset($records) && is_array($records)) {
-			if (!isset($destination) || $destination == false) {
-				$destination = reset($records);
-				$destination = $destination["id"]; // we can only check files in the same folder, so one request will be enough
-				Logger::debug(self::LOG_CONTEXT, "Resetting destination to check.");
-			}
-			Logger::debug(self::LOG_CONTEXT, "Checking: " . $destination);
-			$account = $this->accountFromNode($destination);
-
-			// initialize the backend
-			$initializedBackend = $this->initializeBackend($account);
-
-			$relDirname = substr($destination, strpos($destination, '/'));
-			Logger::debug(self::LOG_CONTEXT, "Getting content for: " . $relDirname);
-
-			try {
-				$lsdata = $initializedBackend->ls($relDirname); // we can only check files in the same folder, so one request will be enough
-			}
-			catch (Exception $e) {
-				// ignore - if file not found -> does not exist :)
-			}
-			if (isset($lsdata) && is_array($lsdata)) {
-				foreach ($records as $record) {
-					$relRecId = substr($record["id"], strpos($record["id"], '/'));
-					Logger::debug(self::LOG_CONTEXT, "Checking rec: " . $relRecId, "Core");
-					foreach ($lsdata as $argsid => $args) {
-						if (strcmp($args['resourcetype'], "collection") == 0 && $record["isFolder"] && strcmp(basename($argsid), basename($relRecId)) == 0) { // we have a folder
-							Logger::debug(self::LOG_CONTEXT, "Duplicate folder found: " . $argsid, "Core");
-							$duplicate = true;
-							break;
-						}
-						if (strcmp($args['resourcetype'], "collection") != 0 && !$record["isFolder"] && strcmp(basename($argsid), basename($relRecId)) == 0) {
-							Logger::debug(self::LOG_CONTEXT, "Duplicate file found: " . $argsid, "Core");
-							$duplicate = true;
-							break;
-						}
-						$duplicate = false;
-					}
-
-					if ($duplicate) {
-						Logger::debug(self::LOG_CONTEXT, "Duplicate entry: " . $relRecId, "Core");
-						break;
-					}
-				}
-			}
-		}
-
-		return $duplicate;
-	}
-
-	/**
-	 * Downloads file from the Files service and saves it in tmp
-	 * folder with unique name.
-	 *
-	 * @param array $actionData
-	 * @param mixed $actionType
-	 *
-	 * @throws BackendException if the backend request fails
-	 */
-	private function downloadSelectedFilesToTmp($actionType, $actionData) {
-		$ids = $actionData['ids'];
-		$dialogAttachmentId = $actionData['dialog_attachments'];
-		$response = [];
-
-		$attachment_state = new AttachmentState();
-		$attachment_state->open();
-
-		$account = $this->accountFromNode($ids[0]);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		foreach ($ids as $file) {
-			$filename = basename($file);
-			$tmpname = $attachment_state->getAttachmentTmpPath($filename);
-
-			// download file from the backend
-			$relRecId = substr($file, strpos($file, '/'));
-			$http_status = $initializedBackend->get_file($relRecId, $tmpname);
-
-			$filesize = filesize($tmpname);
-
-			Logger::debug(self::LOG_CONTEXT, "Downloading: " . $filename . " to: " . $tmpname);
-
-			$attach_id = uniqid();
-			$response['items'][] = [
-				'name' => $filename,
-				'size' => $filesize,
-				"attach_id" => $attach_id,
-				'tmpname' => PathUtil::getFilenameFromPath($tmpname),
-			];
-
-			$attachment_state->addAttachmentFile($dialogAttachmentId, PathUtil::getFilenameFromPath($tmpname), [
-				"name" => $filename,
-				"size" => $filesize,
-				"type" => PathUtil::get_mime($tmpname),
-				"attach_id" => $attach_id,
-				"sourcetype" => 'default',
-			]);
-
-			Logger::debug(self::LOG_CONTEXT, "filesize: " . $filesize);
-		}
-
-		$attachment_state->close();
-		$response['status'] = true;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-	}
-
-	/**
-	 * upload the tempfile to files.
-	 *
-	 * @param array $actionData
-	 * @param mixed $actionType
-	 *
-	 * @throws BackendException if the backend request fails
-	 */
-	private function uploadToBackend($actionType, $actionData) {
-		Logger::debug(self::LOG_CONTEXT, "preparing attachment");
-
-		$account = $this->accountFromNode($actionData["destdir"]);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		$result = true;
-
-		if ($actionData["type"] === "attachment") {
-			foreach ($actionData["items"] as $item) {
-				list($tmpname, $filename) = $this->prepareAttachmentForUpload($item);
-
-				$dirName = substr($actionData["destdir"], strpos($actionData["destdir"], '/'));
-				$filePath = $dirName . $filename;
-
-				Logger::debug(self::LOG_CONTEXT, "Uploading to: " . $filePath . " tmpfile: " . $tmpname);
-
-				$result = $result && $initializedBackend->put_file($filePath, $tmpname);
-				unlink($tmpname);
-
-				$this->updateDirCache($initializedBackend, $dirName, $filePath, $actionData);
-			}
-		}
-		elseif ($actionData["type"] === "mail") {
-			foreach ($actionData["items"] as $item) {
-				list($tmpname, $filename) = $this->prepareEmailForUpload($item);
-
-				$dirName = substr($actionData["destdir"], strpos($actionData["destdir"], '/'));
-				$filePath = $dirName . $filename;
-
-				Logger::debug(self::LOG_CONTEXT, "Uploading to: " . $filePath . " tmpfile: " . $tmpname);
-
-				$result = $result && $initializedBackend->put_file($filePath, $tmpname);
-				unlink($tmpname);
-
-				$this->updateDirCache($initializedBackend, $dirName, $filePath, $actionData);
-			}
-		}
-		else {
-			$this->sendFeedback(false, [
-				'type' => ERROR_GENERAL,
-				'info' => [
-					'title' => _("Files plugin"),
-					'original_message' => _("Unknown type - cannot save this file to the Files backend!"),
-					'display_message' => _("Unknown type - cannot save this file to the Files backend!"),
-				],
-			]);
-		}
-
-		$response = [];
-		$response['status'] = $result;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-	}
-
-	/**
-	 * Update the cache of selected directory.
-	 *
-	 * @param Files\Backend\AbstractBackend $backendInstance
-	 * @param string                        $dirName         The directory name
-	 * @param $filePath The file path
-	 * @param $actionData The action data
-	 *
-	 * @throws BackendException
-	 */
-	public function updateDirCache($backendInstance, $dirName, $filePath, $actionData) {
-		$cachePath = rtrim($dirName, '/');
-		if ($cachePath === "") {
-			$cachePath = "/";
-		}
-
-		$dir = $backendInstance->ls($cachePath);
-		$accountID = $this->accountIDFromNode($actionData["destdir"]);
-		$cacheDir = $this->getCache($accountID, $cachePath);
-		$cacheDir[$filePath] = $dir[$filePath];
-		$this->setCache($accountID, $cachePath, $cacheDir);
-	}
-
-	/**
-	 * This function will prepare an attachment for the upload to the backend.
-	 * It will store the attachment to the TMP folder and return its temporary
-	 * path and filename as array.
-	 *
-	 * @param $items
-	 * @param mixed $item
-	 *
-	 * @return array (tmpname, filename) or false on error
-	 */
-	private function prepareAttachmentForUpload($item) {
-		// Check which type isset
-		$openType = "attachment";
-
-		// Get store id
-		$storeid = false;
-		if (isset($item["store"])) {
-			$storeid = $item["store"];
-		}
-
-		// Get message entryid
-		$entryid = false;
-		if (isset($item["entryid"])) {
-			$entryid = $item["entryid"];
-		}
-
-		// Get number of attachment which should be opened.
-		$attachNum = false;
-		if (isset($item["attachNum"])) {
-			$attachNum = $item["attachNum"];
-		}
-
-		$tmpname = "";
-		$filename = "";
-
-		// Check if storeid and entryid isset
-		if ($storeid && $entryid) {
-			// Open the store
-			$store = $GLOBALS["mapisession"]->openMessageStore(hex2bin($storeid));
-
-			if ($store) {
-				// Open the message
-				$message = mapi_msgstore_openentry($store, hex2bin($entryid));
-
-				if ($message) {
-					$attachment = false;
-
-					// Check if attachNum isset
-					if ($attachNum) {
-						// Loop through the attachNums, message in message in message ...
-						for ($i = 0; $i < (count($attachNum) - 1); ++$i) {
-							// Open the attachment
-							$tempattach = mapi_message_openattach($message, (int) $attachNum[$i]);
-							if ($tempattach) {
-								// Open the object in the attachment
-								$message = mapi_attach_openobj($tempattach);
-							}
-						}
-
-						// Open the attachment
-						$attachment = mapi_message_openattach($message, (int) $attachNum[(count($attachNum) - 1)]);
-					}
-
-					// Check if the attachment is opened
-					if ($attachment) {
-						// Get the props of the attachment
-						$props = mapi_attach_getprops($attachment, [PR_ATTACH_LONG_FILENAME, PR_ATTACH_MIME_TAG, PR_DISPLAY_NAME, PR_ATTACH_METHOD]);
-						// Content Type
-						$contentType = "application/octet-stream";
-						// Filename
-						$filename = "ERROR";
-
-						// Set filename
-						if (isset($props[PR_ATTACH_LONG_FILENAME])) {
-							$filename = PathUtil::sanitizeFilename($props[PR_ATTACH_LONG_FILENAME]);
-						}
-						else {
-							if (isset($props[PR_ATTACH_FILENAME])) {
-								$filename = PathUtil::sanitizeFilename($props[PR_ATTACH_FILENAME]);
-							}
-							else {
-								if (isset($props[PR_DISPLAY_NAME])) {
-									$filename = PathUtil::sanitizeFilename($props[PR_DISPLAY_NAME]);
-								}
-							}
-						}
-
-						// Set content type
-						if (isset($props[PR_ATTACH_MIME_TAG])) {
-							$contentType = $props[PR_ATTACH_MIME_TAG];
-						}
-						else {
-							// Parse the extension of the filename to get the content type
-							if (strrpos($filename, ".") !== false) {
-								$extension = strtolower(substr($filename, strrpos($filename, ".")));
-								$contentType = "application/octet-stream";
-								if (is_readable("mimetypes.dat")) {
-									$fh = fopen("mimetypes.dat", "r");
-									$ext_found = false;
-									while (!feof($fh) && !$ext_found) {
-										$line = fgets($fh);
-										preg_match("/(\\.[a-z0-9]+)[ \t]+([^ \t\n\r]*)/i", $line, $result);
-										if ($extension == $result[1]) {
-											$ext_found = true;
-											$contentType = $result[2];
-										}
-									}
-									fclose($fh);
-								}
-							}
-						}
-
-						$tmpname = tempnam(TMP_PATH, stripslashes($filename));
-
-						// Open a stream to get the attachment data
-						$stream = mapi_openproperty($attachment, PR_ATTACH_DATA_BIN, IID_IStream, 0, 0);
-						$stat = mapi_stream_stat($stream);
-						// File length =  $stat["cb"]
-
-						Logger::debug(self::LOG_CONTEXT, "filesize: " . $stat["cb"]);
-
-						$fhandle = fopen($tmpname, 'w');
-						$buffer = null;
-						for ($i = 0; $i < $stat["cb"]; $i += BLOCK_SIZE) {
-							// Write stream
-							$buffer = mapi_stream_read($stream, BLOCK_SIZE);
-							fwrite($fhandle, $buffer, strlen($buffer));
-						}
-						fclose($fhandle);
-
-						Logger::debug(self::LOG_CONTEXT, "temp attachment written to " . $tmpname);
-
-						return [$tmpname, $filename];
-					}
-				}
-			}
-			else {
-				Logger::error(self::LOG_CONTEXT, "store could not be opened");
-			}
-		}
-		else {
-			Logger::error(self::LOG_CONTEXT, "wrong call, store and entryid have to be set");
-		}
-
-		return false;
-	}
-
-	/**
-	 * Store the email as eml to a temporary directory and return its temporary filename.
-	 *
-	 * @param {string} $actionType
-	 * @param {array} $actionData
-	 * @param mixed $item
-	 *
-	 * @return array (tmpname, filename) or false on error
-	 */
-	private function prepareEmailForUpload($item) {
-		// Get store id
-		$storeid = false;
-		if (isset($item["store"])) {
-			$storeid = $item["store"];
-		}
-
-		// Get message entryid
-		$entryid = false;
-		if (isset($item["entryid"])) {
-			$entryid = $item["entryid"];
-		}
-
-		$tmpname = "";
-		$filename = "";
-
-		$store = $GLOBALS['mapisession']->openMessageStore(hex2bin($storeid));
-		$message = mapi_msgstore_openentry($store, hex2bin($entryid));
-
-		// Decode smime signed messages on this message
-		parse_smime($store, $message);
-
-		if ($message && $store) {
-			// get message properties.
-			$messageProps = mapi_getprops($message, [PR_SUBJECT, PR_EC_IMAP_EMAIL, PR_MESSAGE_CLASS]);
-
-			$isSupportedMessage = (
-				(stripos($messageProps[PR_MESSAGE_CLASS], 'IPM.Note') === 0) ||
-				(stripos($messageProps[PR_MESSAGE_CLASS], 'Report.IPM.Note') === 0) ||
-				(stripos($messageProps[PR_MESSAGE_CLASS], 'IPM.Schedule') === 0)
-			);
-
-			if ($isSupportedMessage) {
-				// If RFC822-formatted stream is already available in PR_EC_IMAP_EMAIL property
-				// than directly use it, generate otherwise.
-				if (isset($messageProps[PR_EC_IMAP_EMAIL]) || propIsError(PR_EC_IMAP_EMAIL, $messageProps) == MAPI_E_NOT_ENOUGH_MEMORY) {
-					// Stream the message to properly get the PR_EC_IMAP_EMAIL property
-					$stream = mapi_openproperty($message, PR_EC_IMAP_EMAIL, IID_IStream, 0, 0);
-				}
-				else {
-					// Get addressbook for current session
-					$addrBook = $GLOBALS['mapisession']->getAddressbook();
-
-					// Read the message as RFC822-formatted e-mail stream.
-					$stream = mapi_inetmapi_imtoinet($GLOBALS['mapisession']->getSession(), $addrBook, $message, []);
-				}
-
-				if (!empty($messageProps[PR_SUBJECT])) {
-					$filename = PathUtil::sanitizeFilename($messageProps[PR_SUBJECT]) . '.eml';
-				}
-				else {
-					$filename = _('Untitled') . '.eml';
-				}
-
-				$tmpname = tempnam(TMP_PATH, "email2filez");
-
-				// Set the file length
-				$stat = mapi_stream_stat($stream);
-
-				$fhandle = fopen($tmpname, 'w');
-				$buffer = null;
-				for ($i = 0; $i < $stat["cb"]; $i += BLOCK_SIZE) {
-					// Write stream
-					$buffer = mapi_stream_read($stream, BLOCK_SIZE);
-					fwrite($fhandle, $buffer, strlen($buffer));
-				}
-				fclose($fhandle);
-
-				return [$tmpname, $filename];
-			}
-		}
-
-		return false;
-	}
-
-	/**
-	 * Get sharing information from the backend.
-	 *
-	 * @param $actionType
-	 * @param $actionData
-	 *
-	 * @return bool
-	 */
-	private function getSharingInformation($actionType, $actionData) {
-		$response = [];
-		$records = $actionData["records"];
-
-		if (count($records) < 1) {
-			$this->sendFeedback(false, [
-				'type' => ERROR_GENERAL,
-				'info' => [
-					'title' => _("Files Plugin"),
-					'original_message' => _("No record given!"),
-					'display_message' => _("No record given!"),
-				],
-			]);
-		}
-
-		$account = $this->accountFromNode($records[0]);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		$relRecords = [];
-		foreach ($records as $record) {
-			$relRecords[] = substr($record, strpos($record, '/')); // remove account id
-		}
-
-		try {
-			$sInfo = $initializedBackend->sharingDetails($relRecords);
-		}
-		catch (Exception $e) {
-			$response['status'] = false;
-			$response['header'] = _('Fetching sharing information failed');
-			$response['message'] = $e->getMessage();
-			$this->addActionData("error", $response);
-			$GLOBALS["bus"]->addData($this->getResponseData());
-
-			return false;
-		}
-
-		$sharingInfo = [];
-		foreach ($sInfo as $path => $details) {
-			$realPath = "#R#" . $account->getId() . $path;
-			$sharingInfo[$realPath] = $details; // add account id again
-		}
-
-		$response['status'] = true;
-		$response['shares'] = $sharingInfo;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		return true;
-	}
-
-	/**
-	 * Create a new share.
-	 *
-	 * @param $actionType
-	 * @param $actionData
-	 *
-	 * @return bool
-	 */
-	private function createNewShare($actionType, $actionData) {
-		$records = $actionData["records"];
-		$shareOptions = $actionData["options"];
-
-		if (count($records) < 1) {
-			$this->sendFeedback(false, [
-				'type' => ERROR_GENERAL,
-				'info' => [
-					'title' => _("Files Plugin"),
-					'original_message' => _("No record given!"),
-					'display_message' => _("No record given!"),
-				],
-			]);
-		}
-
-		$account = $this->accountFromNode($records[0]);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		$sharingRecords = [];
-		foreach ($records as $record) {
-			$path = substr($record, strpos($record, '/')); // remove account id
-			$sharingRecords[$path] = $shareOptions; // add options
-		}
-
-		try {
-			$sInfo = $initializedBackend->share($sharingRecords);
-		}
-		catch (Exception $e) {
-			$response['status'] = false;
-			$response['header'] = _('Sharing failed');
-			$response['message'] = $e->getMessage();
-			$this->addActionData("error", $response);
-			$GLOBALS["bus"]->addData($this->getResponseData());
-
-			return false;
-		}
-
-		$sharingInfo = [];
-		foreach ($sInfo as $path => $details) {
-			$realPath = "#R#" . $account->getId() . $path;
-			$sharingInfo[$realPath] = $details; // add account id again
-		}
-
-		$response = [];
-		$response['status'] = true;
-		$response['shares'] = $sharingInfo;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		return true;
-	}
-
-	/**
-	 * Update a existing share.
-	 *
-	 * @param $actionType
-	 * @param $actionData
-	 *
-	 * @return bool
-	 */
-	private function updateExistingShare($actionType, $actionData) {
-		$records = $actionData["records"];
-		$accountID = $actionData["accountid"];
-		$shareOptions = $actionData["options"];
-
-		if (count($records) < 1) {
-			$this->sendFeedback(false, [
-				'type' => ERROR_GENERAL,
-				'info' => [
-					'title' => _("Files Plugin"),
-					'original_message' => _("No record given!"),
-					'display_message' => _("No record given!"),
-				],
-			]);
-		}
-
-		$account = $this->accountStore->getAccount($accountID);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		$sharingRecords = [];
-		foreach ($records as $record) {
-			$sharingRecords[$record] = $shareOptions; // add options
-		}
-
-		try {
-			$sInfo = $initializedBackend->share($sharingRecords, true);
-		}
-		catch (Exception $e) {
-			$response['status'] = false;
-			$response['header'] = _('Updating share failed');
-			$response['message'] = $e->getMessage();
-			$this->addActionData("error", $response);
-			$GLOBALS["bus"]->addData($this->getResponseData());
-
-			return false;
-		}
-
-		$response = [];
-		$response['status'] = true;
-		$response['shares'] = $sInfo;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		return true;
-	}
-
-	/**
-	 * Delete one or more shares.
-	 *
-	 * @param $actionType
-	 * @param $actionData
-	 *
-	 * @return bool
-	 */
-	private function deleteExistingShare($actionType, $actionData) {
-		$records = $actionData["records"];
-		$accountID = $actionData["accountid"];
-
-		if (count($records) < 1) {
-			$this->sendFeedback(false, [
-				'type' => ERROR_GENERAL,
-				'info' => [
-					'title' => _("Files Plugin"),
-					'original_message' => _("No record given!"),
-					'display_message' => _("No record given!"),
-				],
-			]);
-		}
-
-		$account = $this->accountStore->getAccount($accountID);
-
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account);
-
-		try {
-			$sInfo = $initializedBackend->unshare($records);
-		}
-		catch (Exception $e) {
-			$response['status'] = false;
-			$response['header'] = _('Deleting share failed');
-			$response['message'] = $e->getMessage();
-			$this->addActionData("error", $response);
-			$GLOBALS["bus"]->addData($this->getResponseData());
-
-			return false;
-		}
-
-		$response = [];
-		$response['status'] = true;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		return true;
-	}
-
-	/**
-	 * Function will use to update the cache.
-	 *
-	 * @param string $actionType name of the current action
-	 * @param array  $actionData all parameters contained in this request
-	 *
-	 * @return bool true on success or false on failure
-	 */
-	public function updateCache($actionType, $actionData) {
-		$nodeId = $actionData['id'];
-		$accountID = $this->accountIDFromNode($nodeId);
-		$account = $this->accountStore->getAccount($accountID);
-		// initialize the backend
-		$initializedBackend = $this->initializeBackend($account, true);
-		$relNodeId = substr($nodeId, strpos($nodeId, '/'));
-
-		// remove the trailing slash for the cache key
-		$cachePath = rtrim($relNodeId, '/');
-		if ($cachePath === "") {
-			$cachePath = "/";
-		}
-		$dir = $initializedBackend->ls($relNodeId);
-		$this->setCache($accountID, $cachePath, $dir);
-
-		$response = [];
-		$response['status'] = true;
-		$this->addActionData($actionType, $response);
-		$GLOBALS["bus"]->addData($this->getResponseData());
-
-		return true;
-	}
+                            if (isset($actionData["message_action"], $actionData["message_action"]["action_type"])) {
+                                switch ($actionData["message_action"]["action_type"]) {
+                                    case "move" :
+                                        $result = $this->move($actionType, $actionData);
+                                        break;
+
+                                    default:
+                                        // check if we should create something new or edit an existing file/folder
+                                        if (isset($actionData["entryid"])) {
+                                            $result = $this->rename($actionType, $actionData);
+                                        }
+                                        else {
+                                            $result = $this->save($actionData);
+                                        }
+                                        break;
+                                }
+                            }
+                            else {
+                                // check if we should create something new or edit an existing file/folder
+                                if (isset($actionData["entryid"])) {
+                                    $result = $this->rename($actionType, $actionData);
+                                }
+                                else {
+                                    $result = $this->save($actionData);
+                                }
+                            }
+                            break;
+
+                        case "delete":
+                            $result = $this->delete($actionType, $actionData);
+                            break;
+
+                        case "list":
+                            $result = $this->loadFiles($actionType, $actionData);
+                            break;
+
+                        case "loadsharingdetails":
+                            $result = $this->getSharingInformation($actionType, $actionData);
+                            break;
+
+                        case "createnewshare":
+                            $result = $this->createNewShare($actionType, $actionData);
+                            break;
+
+                        case "updateexistingshare":
+                            $result = $this->updateExistingShare($actionType, $actionData);
+                            break;
+
+                        case "deleteexistingshare":
+                            $result = $this->deleteExistingShare($actionType, $actionData);
+                            break;
+
+                        case "updatecache":
+                            $result = $this->updateCache($actionType, $actionData);
+                            break;
+
+                        default:
+                            $this->handleUnknownActionType($actionType);
+                    }
+                }
+                catch (MAPIException $e) {
+                    $this->sendFeedback(false, $this->errorDetailsFromException($e));
+                }
+                catch (AccountException $e) {
+                    $this->sendFeedback(false, [
+                        'type' => ERROR_GENERAL,
+                        'info' => [
+                            'title' => $e->getTitle(),
+                            'original_message' => $e->getMessage(),
+                            'display_message' => $e->getMessage(),
+                        ],
+                    ]);
+                }
+                catch (BackendException $e) {
+                    $this->sendFeedback(false, [
+                        'type' => ERROR_GENERAL,
+                        'info' => [
+                            'title' => $e->getTitle(),
+                            'original_message' => $e->getMessage(),
+                            'display_message' => $e->getMessage(),
+                            'code' => $e->getCode(),
+                        ],
+                    ]);
+                }
+            }
+        }
+
+        return $result;
+    }
+
+    /**
+     * loads content of current folder - list of folders and files from Files.
+     *
+     * @param string $actionType name of the current action
+     * @param array  $actionData all parameters contained in this request
+     *
+     * @throws BackendException if the backend request fails
+     *
+     * @return bool
+     */
+    public function loadFiles($actionType, $actionData) {
+        $nodeId = $actionData['id'];
+        $onlyFiles = isset($actionData['only_files']) ? $actionData['only_files'] : false;
+        $response = [];
+        $nodes = [];
+
+        $accountID = $this->accountIDFromNode($nodeId);
+
+        // check if we are in the ROOT (#R#). If so, display some kind of device/account view.
+        if (empty($accountID) || !$this->accountStore->getAccount($accountID)) {
+            $accounts = $this->accountStore->getAllAccounts();
+            foreach ($accounts as $account) { // we have to load all accounts and their folders
+                // skip accounts that are not valid
+                if ($account->getStatus() != \Files\Core\Account::STATUS_OK) {
+                    continue;
+                }
+                // build the real node id for this folder
+                $realNodeId = $nodeId . $account->getId() . "/";
+
+                $nodes[$realNodeId] = ['props' => [
+                    'id' => rawurldecode($realNodeId),
+                    'folder_id' => rawurldecode($realNodeId),
+                    'path' => $realNodeId,
+                    'filename' => $account->getName(),
+                    'message_size' => -1,
+                    'lastmodified' => -1,
+                    'message_class' => "IPM.Files",
+                    'type' => 0,
+                ],
+                    'entryid' => $this->createId($realNodeId),
+                    'store_entryid' => $this->createId($realNodeId),
+                    'parent_entryid' => $this->createId($realNodeId),
+                ];
+            }
+        }
+        else {
+            $account = $this->accountStore->getAccount($accountID);
+
+            // initialize the backend
+            $initializedBackend = $this->initializeBackend($account, true);
+
+            $starttime = microtime(true);
+            $nodes = $this->getFolderContent($nodeId, $initializedBackend, $onlyFiles);
+            Logger::debug(self::LOG_CONTEXT, "[loadfiles]: getFolderContent took: " . (microtime(true) - $starttime) . " seconds");
+
+            $nodes = $this->sortFolderContent($nodes, $actionData, false);
+        }
+
+        $response["item"] = array_values($nodes);
+
+        $response['page'] = ["start" => 0, "rowcount" => 50, "totalrowcount" => count($response["item"])];
+        $response['folder'] = ["content_count" => count($response["item"]), "content_unread" => 0];
+
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        return true;
+    }
+
+    /**
+     * Forms the structure needed for frontend
+     * for the list of folders and files.
+     *
+     * @param string                        $nodeId          the name of the current root directory
+     * @param Files\Backend\AbstractBackend $backendInstance
+     * @param bool                          $onlyFiles       if true, get only files
+     *
+     * @throws BackendException if the backend request fails
+     *
+     * @return array of nodes for current path folder
+     */
+    public function getFolderContent($nodeId, $backendInstance, $onlyFiles = false) {
+        $nodes = [];
+
+        // relative node ID. We need to trim off the #R# and account ID
+        $relNodeId = substr($nodeId, strpos($nodeId, '/'));
+        $nodeIdPrefix = substr($nodeId, 0, strpos($nodeId, '/'));
+
+        $accountID = $backendInstance->getAccountID();
+
+        // remove the trailing slash for the cache key
+        $cachePath = rtrim($relNodeId, '/');
+        if ($cachePath === "") {
+            $cachePath = "/";
+        }
+
+        $dir = $this->getCache($accountID, $cachePath);
+        if (is_null($dir)) {
+            $dir = $backendInstance->ls($relNodeId);
+            $this->setCache($accountID, $cachePath, $dir);
+        }
+
+        // FIXME: There is something issue with getting sharing information from owncloud.
+        // check if backend supports sharing and load the information
+        if ($backendInstance->supports(\Files\Backend\BackendStore::FEATURE_SHARING)) {
+            Logger::debug(self::LOG_CONTEXT, "Checking for shared folders! ({$relNodeId})");
+
+            $time_start = microtime(true);
+
+            /** @var \Files\Backend\iFeatureSharing $backendInstance */
+            $sharingInfo = $backendInstance->getShares($relNodeId);
+            $time_end = microtime(true);
+            $time = $time_end - $time_start;
+
+            Logger::debug(self::LOG_CONTEXT, "Checking for shared took {$time} s!");
+        }
+
+        if ($dir) {
+            $updateCache = false;
+            foreach ($dir as $id => $node) {
+                $type = FILES_FILE;
+
+                if (strcmp($node['resourcetype'], "collection") == 0) { // we have a folder
+                    $type = FILES_FOLDER;
+                }
+
+                if ($type === FILES_FOLDER && $onlyFiles) {
+                    continue;
+                }
+
+                // Check if foldernames have a trailing slash, if not, add one!
+                if ($type === FILES_FOLDER && !StringUtil::endsWith($id, "/")) {
+                    $id .= "/";
+                }
+
+                $realID = $nodeIdPrefix . $id;
+
+                Logger::debug(self::LOG_CONTEXT, "parsing: " . $id . " in base: " . $nodeId);
+
+                $filename = stringToUTF8Encode(basename($id));
+
+                $size = $node['getcontentlength'] === null ? -1 : intval($node['getcontentlength']);
+                $size = $type == FILES_FOLDER ? -1 : $size; // folder's dont have a size
+
+                $fileid = $node['fileid'] === "-1" ? -1 : intval($node['fileid']);
+
+                $shared = false;
+                $sharedid = [];
+                if (isset($sharingInfo) && count($sharingInfo[$relNodeId]) > 0) {
+                    foreach ($sharingInfo[$relNodeId] as $sid => $sdetails) {
+                        if ($sdetails["path"] == rtrim($id, "/")) {
+                            $shared = true;
+                            $sharedid[] = $sid;
+                        }
+                    }
+                }
+
+                $nodeId = stringToUTF8Encode($id);
+                $dirName = dirname($nodeId, 1);
+                if ($dirName === '/') {
+                    $path = stringToUTF8Encode($nodeIdPrefix . $dirName);
+                }
+                else {
+                    $path = stringToUTF8Encode($nodeIdPrefix . $dirName . '/');
+                }
+
+                if (!isset($node['entryid']) || !isset($node['parent_entryid']) || !isset($node['store_entryid'])) {
+                    $entryid = $this->createId($realID);
+                    $parentEntryid = $this->createId($path);
+                    $storeEntryid = $this->createId($nodeIdPrefix . '/');
+
+                    $dir[$id]['entryid'] = $entryid;
+                    $dir[$id]['parent_entryid'] = $parentEntryid;
+                    $dir[$id]['store_entryid'] = $storeEntryid;
+
+                    $updateCache = true;
+                }
+                else {
+                    $entryid = $node['entryid'];
+                    $parentEntryid = $node['parent_entryid'];
+                    $storeEntryid = $node['store_entryid'];
+                }
+
+                $nodes[$nodeId] = ['props' => [
+                    'folder_id' => stringToUTF8Encode($realID),
+                    'fileid' => $fileid,
+                    'path' => $path,
+                    'filename' => $filename,
+                    'message_size' => $size,
+                    'lastmodified' => strtotime($node['getlastmodified']) * 1000,
+                    'message_class' => "IPM.Files",
+                    'isshared' => $shared,
+                    'sharedid' => $sharedid,
+                    'object_type' => $type,
+                    'type' => $type,
+                ],
+                    'entryid' => $entryid,
+                    'parent_entryid' => $parentEntryid,
+                    'store_entryid' => $storeEntryid,
+                ];
+            }
+
+            // Update the cache.
+            if ($updateCache) {
+                $this->setCache($accountID, $cachePath, $dir);
+            }
+        }
+        else {
+            Logger::debug(self::LOG_CONTEXT, "dir was empty");
+        }
+
+        return $nodes;
+    }
+
+    /**
+     * This functions sorts an array of nodes.
+     *
+     * @param array $nodes   array of nodes to sort
+     * @param array $data    all parameters contained in the request
+     * @param bool  $navtree parse for navtree or browser
+     *
+     * @return array of sorted nodes
+     */
+    public function sortFolderContent($nodes, $data, $navtree = false) {
+        $sortednodes = [];
+
+        $sortkey = "filename";
+        $sortdir = "ASC";
+
+        if (isset($data['sort'])) {
+            $sortkey = $data['sort'][0]['field'];
+            $sortdir = $data['sort'][0]['direction'];
+        }
+
+        Logger::debug(self::LOG_CONTEXT, "sorting by " . $sortkey . " in direction: " . $sortdir);
+
+        if ($navtree) {
+            $sortednodes = ArrayUtil::sort_by_key($nodes, $sortkey, $sortdir);
+        }
+        else {
+            $sortednodes = ArrayUtil::sort_props_by_key($nodes, $sortkey, $sortdir);
+        }
+
+        return $sortednodes;
+    }
+
+    /**
+     * Deletes the selected files on the backend server.
+     *
+     * @param string $actionType name of the current action
+     * @param array  $actionData all parameters contained in this request
+     *
+     * @throws BackendException if the backend request fails
+     *
+     * @return bool
+     */
+    private function delete($actionType, $actionData) {
+        // TODO: function is duplicate of class.hierarchylistmodule.php of delete function.
+        $result = false;
+        if (isset($actionData['records']) && is_array($actionData['records'])) {
+            foreach ($actionData['records'] as $record) {
+                $nodeId = $record['folder_id'];
+                $relNodeId = substr($nodeId, strpos($nodeId, '/'));
+
+                $account = $this->accountFromNode($nodeId);
+
+                // initialize the backend
+                $initializedBackend = $this->initializeBackend($account);
+
+                $result = $initializedBackend->delete($relNodeId);
+                Logger::debug(self::LOG_CONTEXT, "deleted: " . $nodeId . ", worked: " . $result);
+
+                // clear the cache
+                $this->deleteCache($account->getId(), dirname($relNodeId));
+                $GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_DELETE, [
+                    "id" => $nodeId,
+                    "folder_id" => $nodeId,
+                    "entryid" => $record['entryid'],
+                    "parent_entryid" => $record["parent_entryid"],
+                    "store_entryid" => $record["store_entryid"],
+                ]);
+            }
+
+            $response['status'] = true;
+            $this->addActionData($actionType, $response);
+            $GLOBALS["bus"]->addData($this->getResponseData());
+        }
+        else {
+            $nodeId = $actionData['folder_id'];
+
+            $relNodeId = substr($nodeId, strpos($nodeId, '/'));
+            $response = [];
+
+            $account = $this->accountFromNode($nodeId);
+            $accountId = $account->getId();
+            // initialize the backend
+            $initializedBackend = $this->initializeBackend($account);
+
+            try {
+                $result = $initializedBackend->delete($relNodeId);
+            }
+            catch (\Files\Backend\Exception $e) {
+                // TODO: this might fails because the file was already deleted.
+                // fire error message if any other error occurred.
+                Logger::debug(self::LOG_CONTEXT, "deleted a directory that was no longer available");
+            }
+            Logger::debug(self::LOG_CONTEXT, "deleted: " . $nodeId . ", worked: " . $result);
+
+            // Get old cached data.
+            $cachedDir = $this->getCache($accountId, dirname($relNodeId));
+            if (isset($cachedDir[$relNodeId]) && !empty($cachedDir[$relNodeId])) {
+                // Delete the folder from cached data.
+                unset($cachedDir[$relNodeId]);
+            }
+
+            // clear the cache of parent directory.
+            $this->deleteCache($accountId, dirname($relNodeId));
+            // clear the cache of selected directory.
+            $this->deleteCache($accountId, rtrim($relNodeId, '/'));
+
+            // Set data in cache.
+            $this->setCache($accountId, dirname($relNodeId), $cachedDir);
+
+            $response['status'] = $result ? true : false;
+            $this->addActionData($actionType, $response);
+            $GLOBALS["bus"]->addData($this->getResponseData());
+
+            $GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_DELETE, [
+                "entryid" => $actionData["entryid"],
+                "parent_entryid" => $actionData["parent_entryid"],
+                "store_entryid" => $actionData["store_entryid"],
+            ]);
+        }
+
+        return true;
+    }
+
+    /**
+     * Moves the selected files on the backend server.
+     *
+     * @param string $actionType name of the current action
+     * @param array  $actionData all parameters contained in this request
+     *
+     * @return bool if the backend request failed
+     */
+    private function move($actionType, $actionData) {
+        $dst = rtrim($actionData['message_action']["destination_folder_id"], '/');
+
+        $overwrite = isset($actionData['message_action']["overwrite"]) ? $actionData['message_action']["overwrite"] : true;
+        $isFolder = isset($actionData['message_action']["isFolder"]) ? $actionData['message_action']["isFolder"] : false;
+
+        $pathPostfix = "";
+        if (substr($actionData['folder_id'], -1) == '/') {
+            $pathPostfix = "/"; // we have a folder...
+        }
+
+        $source = rtrim($actionData['folder_id'], '/');
+        $fileName = basename($source);
+        $destination = $dst . '/' . basename($source);
+
+        // get dst and source account ids
+        // currently only moving within one account is supported
+        $srcAccountID = substr($actionData['folder_id'], 3, (strpos($actionData['folder_id'], '/') - 3)); // parse account id from node id
+        $dstAccountID = substr($actionData['message_action']["destination_folder_id"], 3, (strpos($actionData['message_action']["destination_folder_id"], '/') - 3)); // parse account id from node id
+
+        if ($srcAccountID !== $dstAccountID) {
+            $this->sendFeedback(false, [
+                'type' => ERROR_GENERAL,
+                'info' => [
+                    'title' => _("Files Plugin"),
+                    'original_message' => _("Moving between accounts is not implemented"),
+                    'display_message' => _("Moving between accounts is not implemented"),
+                ],
+            ]);
+
+            return false;
+        }
+        $relDst = substr($destination, strpos($destination, '/'));
+        $relSrc = substr($source, strpos($source, '/'));
+
+        $account = $this->accountFromNode($source);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        $result = $initializedBackend->move($relSrc, $relDst, $overwrite);
+
+        $actionId = $account->getId();
+        // clear the cache
+        $this->deleteCache($actionId, dirname($relDst));
+
+        $cachedFolderName = $relSrc . $pathPostfix;
+        $this->deleteCache($actionId, $cachedFolderName);
+
+        $cached = $this->getCache($actionId, dirname($relSrc));
+        $this->deleteCache($actionId, dirname($relSrc));
+
+        if (isset($cached[$cachedFolderName]) && !empty($cached[$cachedFolderName])) {
+            unset($cached[$cachedFolderName]);
+            $this->setCache($actionId, dirname($relSrc), $cached);
+        }
+
+        $response['status'] = !$result ? false : true;
+
+        /* create the response object */
+        $folder = [
+            'props' => [
+                'folder_id' => ($destination . $pathPostfix),
+                'path' => $actionData['message_action']["destination_folder_id"],
+                'filename' => $fileName,
+                'display_name' => $fileName,
+                'object_type' => $isFolder ? FILES_FOLDER : FILES_FILE,
+                'deleted' => !$result ? false : true,
+            ],
+            'entryid' => $this->createId($destination . $pathPostfix),
+            'store_entryid' => $actionData['store_entryid'],
+            'parent_entryid' => $actionData['message_action']['parent_entryid'],
+        ];
+
+        $response['item'] = $folder;
+
+        $this->addActionData("update", $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        // Notify hierarchy only when folder was moved.
+        if ($isFolder) {
+            // Send notification to delete folder node in hierarchy.
+            $GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_DELETE, [
+                "entryid" => $actionData["entryid"],
+                "parent_entryid" => $actionData["parent_entryid"],
+                "store_entryid" => $actionData["store_entryid"],
+            ]);
+
+            // Send notification to create new folder node in hierarchy.
+            $GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_SAVE, $folder);
+        }
+
+        return true;
+    }
+
+    /**
+     * Renames the selected file on the backend server.
+     *
+     * @param string $actionType name of the current action
+     * @param array  $actionData all parameters contained in this request
+     *
+     * @throws BackendException if the backend request fails
+     *
+     * @return bool
+     */
+    public function rename($actionType, $actionData) {
+        $messageProps = $this->save($actionData);
+        $notifySubFolders = isset($actionData['message_action']['isFolder']) ? $actionData['message_action']['isFolder'] : true;
+        if (!empty($messageProps)) {
+            $GLOBALS["bus"]->notify(REQUEST_ENTRYID, OBJECT_SAVE, $messageProps);
+            if ($notifySubFolders) {
+                $this->notifySubFolders($messageProps["props"]["folder_id"]);
+            }
+        }
+    }
+
+    /**
+     * Check if given filename or folder already exists on server.
+     *
+     * @param array $records     which needs to be check for existence
+     * @param array $destination where the given records needs to be moved, uploaded, or renamed
+     *
+     * @throws BackendException if the backend request fails
+     *
+     * @return bool True if duplicate found, false otherwise
+     */
+    private function checkIfExists($records, $destination) {
+        $duplicate = false;
+
+        if (isset($records) && is_array($records)) {
+            if (!isset($destination) || $destination == false) {
+                $destination = reset($records);
+                $destination = $destination["id"]; // we can only check files in the same folder, so one request will be enough
+                Logger::debug(self::LOG_CONTEXT, "Resetting destination to check.");
+            }
+            Logger::debug(self::LOG_CONTEXT, "Checking: " . $destination);
+            $account = $this->accountFromNode($destination);
+
+            // initialize the backend
+            $initializedBackend = $this->initializeBackend($account);
+
+            $relDirname = substr($destination, strpos($destination, '/'));
+            Logger::debug(self::LOG_CONTEXT, "Getting content for: " . $relDirname);
+
+            try {
+                $lsdata = $initializedBackend->ls($relDirname); // we can only check files in the same folder, so one request will be enough
+            }
+            catch (Exception $e) {
+                // ignore - if file not found -> does not exist :)
+            }
+            if (isset($lsdata) && is_array($lsdata)) {
+                foreach ($records as $record) {
+                    $relRecId = substr($record["id"], strpos($record["id"], '/'));
+                    Logger::debug(self::LOG_CONTEXT, "Checking rec: " . $relRecId, "Core");
+                    foreach ($lsdata as $argsid => $args) {
+                        if (strcmp($args['resourcetype'], "collection") == 0 && $record["isFolder"] && strcmp(basename($argsid), basename($relRecId)) == 0) { // we have a folder
+                            Logger::debug(self::LOG_CONTEXT, "Duplicate folder found: " . $argsid, "Core");
+                            $duplicate = true;
+                            break;
+                        }
+                        if (strcmp($args['resourcetype'], "collection") != 0 && !$record["isFolder"] && strcmp(basename($argsid), basename($relRecId)) == 0) {
+                            Logger::debug(self::LOG_CONTEXT, "Duplicate file found: " . $argsid, "Core");
+                            $duplicate = true;
+                            break;
+                        }
+                        $duplicate = false;
+                    }
+
+                    if ($duplicate) {
+                        Logger::debug(self::LOG_CONTEXT, "Duplicate entry: " . $relRecId, "Core");
+                        break;
+                    }
+                }
+            }
+        }
+
+        return $duplicate;
+    }
+
+    /**
+     * Downloads file from the Files service and saves it in tmp
+     * folder with unique name.
+     *
+     * @param array $actionData
+     * @param mixed $actionType
+     *
+     * @throws BackendException if the backend request fails
+     */
+    private function downloadSelectedFilesToTmp($actionType, $actionData) {
+        $ids = $actionData['ids'];
+        $dialogAttachmentId = $actionData['dialog_attachments'];
+        $response = [];
+
+        $attachment_state = new AttachmentState();
+        $attachment_state->open();
+
+        $account = $this->accountFromNode($ids[0]);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        foreach ($ids as $file) {
+            $filename = basename($file);
+            $tmpname = $attachment_state->getAttachmentTmpPath($filename);
+
+            // download file from the backend
+            $relRecId = substr($file, strpos($file, '/'));
+            $http_status = $initializedBackend->get_file($relRecId, $tmpname);
+
+            $filesize = filesize($tmpname);
+
+            Logger::debug(self::LOG_CONTEXT, "Downloading: " . $filename . " to: " . $tmpname);
+
+            $attach_id = uniqid();
+            $response['items'][] = [
+                'name' => $filename,
+                'size' => $filesize,
+                "attach_id" => $attach_id,
+                'tmpname' => PathUtil::getFilenameFromPath($tmpname),
+            ];
+
+            $attachment_state->addAttachmentFile($dialogAttachmentId, PathUtil::getFilenameFromPath($tmpname), [
+                "name" => $filename,
+                "size" => $filesize,
+                "type" => PathUtil::get_mime($tmpname),
+                "attach_id" => $attach_id,
+                "sourcetype" => 'default',
+            ]);
+
+            Logger::debug(self::LOG_CONTEXT, "filesize: " . $filesize);
+        }
+
+        $attachment_state->close();
+        $response['status'] = true;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+    }
+
+    /**
+     * upload the tempfile to files.
+     *
+     * @param array $actionData
+     * @param mixed $actionType
+     *
+     * @throws BackendException if the backend request fails
+     */
+    private function uploadToBackend($actionType, $actionData) {
+        Logger::debug(self::LOG_CONTEXT, "preparing attachment");
+
+        $account = $this->accountFromNode($actionData["destdir"]);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        $result = true;
+
+        if ($actionData["type"] === "attachment") {
+            foreach ($actionData["items"] as $item) {
+                list($tmpname, $filename) = $this->prepareAttachmentForUpload($item);
+
+                $dirName = substr($actionData["destdir"], strpos($actionData["destdir"], '/'));
+                $filePath = $dirName . $filename;
+
+                Logger::debug(self::LOG_CONTEXT, "Uploading to: " . $filePath . " tmpfile: " . $tmpname);
+
+                $result = $result && $initializedBackend->put_file($filePath, $tmpname);
+                unlink($tmpname);
+
+                $this->updateDirCache($initializedBackend, $dirName, $filePath, $actionData);
+            }
+        }
+        elseif ($actionData["type"] === "mail") {
+            foreach ($actionData["items"] as $item) {
+                list($tmpname, $filename) = $this->prepareEmailForUpload($item);
+
+                $dirName = substr($actionData["destdir"], strpos($actionData["destdir"], '/'));
+                $filePath = $dirName . $filename;
+
+                Logger::debug(self::LOG_CONTEXT, "Uploading to: " . $filePath . " tmpfile: " . $tmpname);
+
+                $result = $result && $initializedBackend->put_file($filePath, $tmpname);
+                unlink($tmpname);
+
+                $this->updateDirCache($initializedBackend, $dirName, $filePath, $actionData);
+            }
+        }
+        else {
+            $this->sendFeedback(false, [
+                'type' => ERROR_GENERAL,
+                'info' => [
+                    'title' => _("Files plugin"),
+                    'original_message' => _("Unknown type - cannot save this file to the Files backend!"),
+                    'display_message' => _("Unknown type - cannot save this file to the Files backend!"),
+                ],
+            ]);
+        }
+
+        $response = [];
+        $response['status'] = $result;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+    }
+
+    /**
+     * Update the cache of selected directory.
+     *
+     * @param Files\Backend\AbstractBackend $backendInstance
+     * @param string                        $dirName         The directory name
+     * @param $filePath The file path
+     * @param $actionData The action data
+     *
+     * @throws BackendException
+     */
+    public function updateDirCache($backendInstance, $dirName, $filePath, $actionData) {
+        $cachePath = rtrim($dirName, '/');
+        if ($cachePath === "") {
+            $cachePath = "/";
+        }
+
+        $dir = $backendInstance->ls($cachePath);
+        $accountID = $this->accountIDFromNode($actionData["destdir"]);
+        $cacheDir = $this->getCache($accountID, $cachePath);
+        $cacheDir[$filePath] = $dir[$filePath];
+        $this->setCache($accountID, $cachePath, $cacheDir);
+    }
+
+    /**
+     * This function will prepare an attachment for the upload to the backend.
+     * It will store the attachment to the TMP folder and return its temporary
+     * path and filename as array.
+     *
+     * @param $items
+     * @param mixed $item
+     *
+     * @return array (tmpname, filename) or false on error
+     */
+    private function prepareAttachmentForUpload($item) {
+        // Check which type isset
+        $openType = "attachment";
+
+        // Get store id
+        $storeid = false;
+        if (isset($item["store"])) {
+            $storeid = $item["store"];
+        }
+
+        // Get message entryid
+        $entryid = false;
+        if (isset($item["entryid"])) {
+            $entryid = $item["entryid"];
+        }
+
+        // Get number of attachment which should be opened.
+        $attachNum = false;
+        if (isset($item["attachNum"])) {
+            $attachNum = $item["attachNum"];
+        }
+
+        $tmpname = "";
+        $filename = "";
+
+        // Check if storeid and entryid isset
+        if ($storeid && $entryid) {
+            // Open the store
+            $store = $GLOBALS["mapisession"]->openMessageStore(hex2bin($storeid));
+
+            if ($store) {
+                // Open the message
+                $message = mapi_msgstore_openentry($store, hex2bin($entryid));
+
+                if ($message) {
+                    $attachment = false;
+
+                    // Check if attachNum isset
+                    if ($attachNum) {
+                        // Loop through the attachNums, message in message in message ...
+                        for ($i = 0; $i < (count($attachNum) - 1); ++$i) {
+                            // Open the attachment
+                            $tempattach = mapi_message_openattach($message, (int) $attachNum[$i]);
+                            if ($tempattach) {
+                                // Open the object in the attachment
+                                $message = mapi_attach_openobj($tempattach);
+                            }
+                        }
+
+                        // Open the attachment
+                        $attachment = mapi_message_openattach($message, (int) $attachNum[(count($attachNum) - 1)]);
+                    }
+
+                    // Check if the attachment is opened
+                    if ($attachment) {
+                        // Get the props of the attachment
+                        $props = mapi_attach_getprops($attachment, [PR_ATTACH_LONG_FILENAME, PR_ATTACH_MIME_TAG, PR_DISPLAY_NAME, PR_ATTACH_METHOD]);
+                        // Content Type
+                        $contentType = "application/octet-stream";
+                        // Filename
+                        $filename = "ERROR";
+
+                        // Set filename
+                        if (isset($props[PR_ATTACH_LONG_FILENAME])) {
+                            $filename = PathUtil::sanitizeFilename($props[PR_ATTACH_LONG_FILENAME]);
+                        }
+                        else {
+                            if (isset($props[PR_ATTACH_FILENAME])) {
+                                $filename = PathUtil::sanitizeFilename($props[PR_ATTACH_FILENAME]);
+                            }
+                            else {
+                                if (isset($props[PR_DISPLAY_NAME])) {
+                                    $filename = PathUtil::sanitizeFilename($props[PR_DISPLAY_NAME]);
+                                }
+                            }
+                        }
+
+                        // Set content type
+                        if (isset($props[PR_ATTACH_MIME_TAG])) {
+                            $contentType = $props[PR_ATTACH_MIME_TAG];
+                        }
+                        else {
+                            // Parse the extension of the filename to get the content type
+                            if (strrpos($filename, ".") !== false) {
+                                $extension = strtolower(substr($filename, strrpos($filename, ".")));
+                                $contentType = "application/octet-stream";
+                                if (is_readable("mimetypes.dat")) {
+                                    $fh = fopen("mimetypes.dat", "r");
+                                    $ext_found = false;
+                                    while (!feof($fh) && !$ext_found) {
+                                        $line = fgets($fh);
+                                        preg_match("/(\\.[a-z0-9]+)[ \t]+([^ \t\n\r]*)/i", $line, $result);
+                                        if ($extension == $result[1]) {
+                                            $ext_found = true;
+                                            $contentType = $result[2];
+                                        }
+                                    }
+                                    fclose($fh);
+                                }
+                            }
+                        }
+
+                        $tmpname = tempnam(TMP_PATH, stripslashes($filename));
+
+                        // Open a stream to get the attachment data
+                        $stream = mapi_openproperty($attachment, PR_ATTACH_DATA_BIN, IID_IStream, 0, 0);
+                        $stat = mapi_stream_stat($stream);
+                        // File length =  $stat["cb"]
+
+                        Logger::debug(self::LOG_CONTEXT, "filesize: " . $stat["cb"]);
+
+                        $fhandle = fopen($tmpname, 'w');
+                        $buffer = null;
+                        for ($i = 0; $i < $stat["cb"]; $i += BLOCK_SIZE) {
+                            // Write stream
+                            $buffer = mapi_stream_read($stream, BLOCK_SIZE);
+                            fwrite($fhandle, $buffer, strlen($buffer));
+                        }
+                        fclose($fhandle);
+
+                        Logger::debug(self::LOG_CONTEXT, "temp attachment written to " . $tmpname);
+
+                        return [$tmpname, $filename];
+                    }
+                }
+            }
+            else {
+                Logger::error(self::LOG_CONTEXT, "store could not be opened");
+            }
+        }
+        else {
+            Logger::error(self::LOG_CONTEXT, "wrong call, store and entryid have to be set");
+        }
+
+        return false;
+    }
+
+    /**
+     * Store the email as eml to a temporary directory and return its temporary filename.
+     *
+     * @param {string} $actionType
+     * @param {array} $actionData
+     * @param mixed $item
+     *
+     * @return array (tmpname, filename) or false on error
+     */
+    private function prepareEmailForUpload($item) {
+        // Get store id
+        $storeid = false;
+        if (isset($item["store"])) {
+            $storeid = $item["store"];
+        }
+
+        // Get message entryid
+        $entryid = false;
+        if (isset($item["entryid"])) {
+            $entryid = $item["entryid"];
+        }
+
+        $tmpname = "";
+        $filename = "";
+
+        $store = $GLOBALS['mapisession']->openMessageStore(hex2bin($storeid));
+        $message = mapi_msgstore_openentry($store, hex2bin($entryid));
+
+        // Decode smime signed messages on this message
+        parse_smime($store, $message);
+
+        if ($message && $store) {
+            // get message properties.
+            $messageProps = mapi_getprops($message, [PR_SUBJECT, PR_EC_IMAP_EMAIL, PR_MESSAGE_CLASS]);
+
+            $isSupportedMessage = (
+                (stripos($messageProps[PR_MESSAGE_CLASS], 'IPM.Note') === 0) ||
+                (stripos($messageProps[PR_MESSAGE_CLASS], 'Report.IPM.Note') === 0) ||
+                (stripos($messageProps[PR_MESSAGE_CLASS], 'IPM.Schedule') === 0)
+            );
+
+            if ($isSupportedMessage) {
+                // If RFC822-formatted stream is already available in PR_EC_IMAP_EMAIL property
+                // than directly use it, generate otherwise.
+                if (isset($messageProps[PR_EC_IMAP_EMAIL]) || propIsError(PR_EC_IMAP_EMAIL, $messageProps) == MAPI_E_NOT_ENOUGH_MEMORY) {
+                    // Stream the message to properly get the PR_EC_IMAP_EMAIL property
+                    $stream = mapi_openproperty($message, PR_EC_IMAP_EMAIL, IID_IStream, 0, 0);
+                }
+                else {
+                    // Get addressbook for current session
+                    $addrBook = $GLOBALS['mapisession']->getAddressbook();
+
+                    // Read the message as RFC822-formatted e-mail stream.
+                    $stream = mapi_inetmapi_imtoinet($GLOBALS['mapisession']->getSession(), $addrBook, $message, []);
+                }
+
+                if (!empty($messageProps[PR_SUBJECT])) {
+                    $filename = PathUtil::sanitizeFilename($messageProps[PR_SUBJECT]) . '.eml';
+                }
+                else {
+                    $filename = _('Untitled') . '.eml';
+                }
+
+                $tmpname = tempnam(TMP_PATH, "email2filez");
+
+                // Set the file length
+                $stat = mapi_stream_stat($stream);
+
+                $fhandle = fopen($tmpname, 'w');
+                $buffer = null;
+                for ($i = 0; $i < $stat["cb"]; $i += BLOCK_SIZE) {
+                    // Write stream
+                    $buffer = mapi_stream_read($stream, BLOCK_SIZE);
+                    fwrite($fhandle, $buffer, strlen($buffer));
+                }
+                fclose($fhandle);
+
+                return [$tmpname, $filename];
+            }
+        }
+
+        return false;
+    }
+
+    /**
+     * Get sharing information from the backend.
+     *
+     * @param $actionType
+     * @param $actionData
+     *
+     * @return bool
+     */
+    private function getSharingInformation($actionType, $actionData) {
+        $response = [];
+        $records = $actionData["records"];
+
+        if (count($records) < 1) {
+            $this->sendFeedback(false, [
+                'type' => ERROR_GENERAL,
+                'info' => [
+                    'title' => _("Files Plugin"),
+                    'original_message' => _("No record given!"),
+                    'display_message' => _("No record given!"),
+                ],
+            ]);
+        }
+
+        $account = $this->accountFromNode($records[0]);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        $relRecords = [];
+        foreach ($records as $record) {
+            $relRecords[] = substr($record, strpos($record, '/')); // remove account id
+        }
+
+        try {
+            $sInfo = $initializedBackend->sharingDetails($relRecords);
+        }
+        catch (Exception $e) {
+            $response['status'] = false;
+            $response['header'] = _('Fetching sharing information failed');
+            $response['message'] = $e->getMessage();
+            $this->addActionData("error", $response);
+            $GLOBALS["bus"]->addData($this->getResponseData());
+
+            return false;
+        }
+
+        $sharingInfo = [];
+        foreach ($sInfo as $path => $details) {
+            $realPath = "#R#" . $account->getId() . $path;
+            $sharingInfo[$realPath] = $details; // add account id again
+        }
+
+        $response['status'] = true;
+        $response['shares'] = $sharingInfo;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        return true;
+    }
+
+    /**
+     * Create a new share.
+     *
+     * @param $actionType
+     * @param $actionData
+     *
+     * @return bool
+     */
+    private function createNewShare($actionType, $actionData) {
+        $records = $actionData["records"];
+        $shareOptions = $actionData["options"];
+
+        if (count($records) < 1) {
+            $this->sendFeedback(false, [
+                'type' => ERROR_GENERAL,
+                'info' => [
+                    'title' => _("Files Plugin"),
+                    'original_message' => _("No record given!"),
+                    'display_message' => _("No record given!"),
+                ],
+            ]);
+        }
+
+        $account = $this->accountFromNode($records[0]);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        $sharingRecords = [];
+        foreach ($records as $record) {
+            $path = substr($record, strpos($record, '/')); // remove account id
+            $sharingRecords[$path] = $shareOptions; // add options
+        }
+
+        try {
+            $sInfo = $initializedBackend->share($sharingRecords);
+        }
+        catch (Exception $e) {
+            $response['status'] = false;
+            $response['header'] = _('Sharing failed');
+            $response['message'] = $e->getMessage();
+            $this->addActionData("error", $response);
+            $GLOBALS["bus"]->addData($this->getResponseData());
+
+            return false;
+        }
+
+        $sharingInfo = [];
+        foreach ($sInfo as $path => $details) {
+            $realPath = "#R#" . $account->getId() . $path;
+            $sharingInfo[$realPath] = $details; // add account id again
+        }
+
+        $response = [];
+        $response['status'] = true;
+        $response['shares'] = $sharingInfo;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        return true;
+    }
+
+    /**
+     * Update a existing share.
+     *
+     * @param $actionType
+     * @param $actionData
+     *
+     * @return bool
+     */
+    private function updateExistingShare($actionType, $actionData) {
+        $records = $actionData["records"];
+        $accountID = $actionData["accountid"];
+        $shareOptions = $actionData["options"];
+
+        if (count($records) < 1) {
+            $this->sendFeedback(false, [
+                'type' => ERROR_GENERAL,
+                'info' => [
+                    'title' => _("Files Plugin"),
+                    'original_message' => _("No record given!"),
+                    'display_message' => _("No record given!"),
+                ],
+            ]);
+        }
+
+        $account = $this->accountStore->getAccount($accountID);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        $sharingRecords = [];
+        foreach ($records as $record) {
+            $sharingRecords[$record] = $shareOptions; // add options
+        }
+
+        try {
+            $sInfo = $initializedBackend->share($sharingRecords, true);
+        }
+        catch (Exception $e) {
+            $response['status'] = false;
+            $response['header'] = _('Updating share failed');
+            $response['message'] = $e->getMessage();
+            $this->addActionData("error", $response);
+            $GLOBALS["bus"]->addData($this->getResponseData());
+
+            return false;
+        }
+
+        $response = [];
+        $response['status'] = true;
+        $response['shares'] = $sInfo;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        return true;
+    }
+
+    /**
+     * Delete one or more shares.
+     *
+     * @param $actionType
+     * @param $actionData
+     *
+     * @return bool
+     */
+    private function deleteExistingShare($actionType, $actionData) {
+        $records = $actionData["records"];
+        $accountID = $actionData["accountid"];
+
+        if (count($records) < 1) {
+            $this->sendFeedback(false, [
+                'type' => ERROR_GENERAL,
+                'info' => [
+                    'title' => _("Files Plugin"),
+                    'original_message' => _("No record given!"),
+                    'display_message' => _("No record given!"),
+                ],
+            ]);
+        }
+
+        $account = $this->accountStore->getAccount($accountID);
+
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account);
+
+        try {
+            $sInfo = $initializedBackend->unshare($records);
+        }
+        catch (Exception $e) {
+            $response['status'] = false;
+            $response['header'] = _('Deleting share failed');
+            $response['message'] = $e->getMessage();
+            $this->addActionData("error", $response);
+            $GLOBALS["bus"]->addData($this->getResponseData());
+
+            return false;
+        }
+
+        $response = [];
+        $response['status'] = true;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        return true;
+    }
+
+    /**
+     * Function will use to update the cache.
+     *
+     * @param string $actionType name of the current action
+     * @param array  $actionData all parameters contained in this request
+     *
+     * @return bool true on success or false on failure
+     */
+    public function updateCache($actionType, $actionData) {
+        $nodeId = $actionData['id'];
+        $accountID = $this->accountIDFromNode($nodeId);
+        $account = $this->accountStore->getAccount($accountID);
+        // initialize the backend
+        $initializedBackend = $this->initializeBackend($account, true);
+        $relNodeId = substr($nodeId, strpos($nodeId, '/'));
+
+        // remove the trailing slash for the cache key
+        $cachePath = rtrim($relNodeId, '/');
+        if ($cachePath === "") {
+            $cachePath = "/";
+        }
+        $dir = $initializedBackend->ls($relNodeId);
+        $this->setCache($accountID, $cachePath, $dir);
+
+        $response = [];
+        $response['status'] = true;
+        $this->addActionData($actionType, $response);
+        $GLOBALS["bus"]->addData($this->getResponseData());
+
+        return true;
+    }
 }

Braces +27 added lines, -54 removed lines

@@ -115,19 +115,16 @@ 
 										// check if we should create something new or edit an existing file/folder
 										if (isset($actionData["entryid"])) {
 											$result = $this->rename($actionType, $actionData);
-										}
-										else {
+										} else {
 											$result = $this->save($actionData);
 										}
 										break;
 								}
-							}
-							else {
+							} else {
 								// check if we should create something new or edit an existing file/folder
 								if (isset($actionData["entryid"])) {
 									$result = $this->rename($actionType, $actionData);
-								}
-								else {
+								} else {
 									$result = $this->save($actionData);
 								}
 							}
@@ -164,11 +161,9 @@ 
 						default:
 							$this->handleUnknownActionType($actionType);
 					}
-				}
-				catch (MAPIException $e) {
+				} catch (MAPIException $e) {
 					$this->sendFeedback(false, $this->errorDetailsFromException($e));
-				}
-				catch (AccountException $e) {
+				} catch (AccountException $e) {
 					$this->sendFeedback(false, [
 						'type' => ERROR_GENERAL,
 						'info' => [
@@ -177,8 +172,7 @@ 
 							'display_message' => $e->getMessage(),
 						],
 					]);
-				}
-				catch (BackendException $e) {
+				} catch (BackendException $e) {
 					$this->sendFeedback(false, [
 						'type' => ERROR_GENERAL,
 						'info' => [
@@ -239,8 +233,7 @@ 
 					'parent_entryid' => $this->createId($realNodeId),
 				];
 			}
-		}
-		else {
+		} else {
 			$account = $this->accountStore->getAccount($accountID);
 
 			// initialize the backend
@@ -356,8 +349,7 @@ 
 				$dirName = dirname($nodeId, 1);
 				if ($dirName === '/') {
 					$path = stringToUTF8Encode($nodeIdPrefix . $dirName);
-				}
-				else {
+				} else {
 					$path = stringToUTF8Encode($nodeIdPrefix . $dirName . '/');
 				}
 
@@ -371,8 +363,7 @@ 
 					$dir[$id]['store_entryid'] = $storeEntryid;
 
 					$updateCache = true;
-				}
-				else {
+				} else {
 					$entryid = $node['entryid'];
 					$parentEntryid = $node['parent_entryid'];
 					$storeEntryid = $node['store_entryid'];
@@ -401,8 +392,7 @@ 
 			if ($updateCache) {
 				$this->setCache($accountID, $cachePath, $dir);
 			}
-		}
-		else {
+		} else {
 			Logger::debug(self::LOG_CONTEXT, "dir was empty");
 		}
 
@@ -433,8 +423,7 @@ 
 
 		if ($navtree) {
 			$sortednodes = ArrayUtil::sort_by_key($nodes, $sortkey, $sortdir);
-		}
-		else {
+		} else {
 			$sortednodes = ArrayUtil::sort_props_by_key($nodes, $sortkey, $sortdir);
 		}
 
@@ -481,8 +470,7 @@ 
 			$response['status'] = true;
 			$this->addActionData($actionType, $response);
 			$GLOBALS["bus"]->addData($this->getResponseData());
-		}
-		else {
+		} else {
 			$nodeId = $actionData['folder_id'];
 
 			$relNodeId = substr($nodeId, strpos($nodeId, '/'));
@@ -495,8 +483,7 @@ 
 
 			try {
 				$result = $initializedBackend->delete($relNodeId);
-			}
-			catch (\Files\Backend\Exception $e) {
+			} catch (\Files\Backend\Exception $e) {
 				// TODO: this might fails because the file was already deleted.
 				// fire error message if any other error occurred.
 				Logger::debug(self::LOG_CONTEXT, "deleted a directory that was no longer available");
@@ -686,8 +673,7 @@ 
 
 			try {
 				$lsdata = $initializedBackend->ls($relDirname); // we can only check files in the same folder, so one request will be enough
-			}
-			catch (Exception $e) {
+			} catch (Exception $e) {
 				// ignore - if file not found -> does not exist :)
 			}
 			if (isset($lsdata) && is_array($lsdata)) {
@@ -810,8 +796,7 @@ 
 
 				$this->updateDirCache($initializedBackend, $dirName, $filePath, $actionData);
 			}
-		}
-		elseif ($actionData["type"] === "mail") {
+		} elseif ($actionData["type"] === "mail") {
 			foreach ($actionData["items"] as $item) {
 				list($tmpname, $filename) = $this->prepareEmailForUpload($item);
 
@@ -825,8 +810,7 @@ 
 
 				$this->updateDirCache($initializedBackend, $dirName, $filePath, $actionData);
 			}
-		}
-		else {
+		} else {
 			$this->sendFeedback(false, [
 				'type' => ERROR_GENERAL,
 				'info' => [
@@ -941,12 +925,10 @@ 
 						// Set filename
 						if (isset($props[PR_ATTACH_LONG_FILENAME])) {
 							$filename = PathUtil::sanitizeFilename($props[PR_ATTACH_LONG_FILENAME]);
-						}
-						else {
+						} else {
 							if (isset($props[PR_ATTACH_FILENAME])) {
 								$filename = PathUtil::sanitizeFilename($props[PR_ATTACH_FILENAME]);
-							}
-							else {
+							} else {
 								if (isset($props[PR_DISPLAY_NAME])) {
 									$filename = PathUtil::sanitizeFilename($props[PR_DISPLAY_NAME]);
 								}
@@ -956,8 +938,7 @@ 
 						// Set content type
 						if (isset($props[PR_ATTACH_MIME_TAG])) {
 							$contentType = $props[PR_ATTACH_MIME_TAG];
-						}
-						else {
+						} else {
 							// Parse the extension of the filename to get the content type
 							if (strrpos($filename, ".") !== false) {
 								$extension = strtolower(substr($filename, strrpos($filename, ".")));
@@ -1001,12 +982,10 @@ 
 						return [$tmpname, $filename];
 					}
 				}
-			}
-			else {
+			} else {
 				Logger::error(self::LOG_CONTEXT, "store could not be opened");
 			}
-		}
-		else {
+		} else {
 			Logger::error(self::LOG_CONTEXT, "wrong call, store and entryid have to be set");
 		}
 
@@ -1060,8 +1039,7 @@ 
 				if (isset($messageProps[PR_EC_IMAP_EMAIL]) || propIsError(PR_EC_IMAP_EMAIL, $messageProps) == MAPI_E_NOT_ENOUGH_MEMORY) {
 					// Stream the message to properly get the PR_EC_IMAP_EMAIL property
 					$stream = mapi_openproperty($message, PR_EC_IMAP_EMAIL, IID_IStream, 0, 0);
-				}
-				else {
+				} else {
 					// Get addressbook for current session
 					$addrBook = $GLOBALS['mapisession']->getAddressbook();
 
@@ -1071,8 +1049,7 @@ 
 
 				if (!empty($messageProps[PR_SUBJECT])) {
 					$filename = PathUtil::sanitizeFilename($messageProps[PR_SUBJECT]) . '.eml';
-				}
-				else {
+				} else {
 					$filename = _('Untitled') . '.eml';
 				}
 
@@ -1132,8 +1109,7 @@ 
 
 		try {
 			$sInfo = $initializedBackend->sharingDetails($relRecords);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			$response['status'] = false;
 			$response['header'] = _('Fetching sharing information failed');
 			$response['message'] = $e->getMessage();
@@ -1193,8 +1169,7 @@ 
 
 		try {
 			$sInfo = $initializedBackend->share($sharingRecords);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			$response['status'] = false;
 			$response['header'] = _('Sharing failed');
 			$response['message'] = $e->getMessage();
@@ -1255,8 +1230,7 @@ 
 
 		try {
 			$sInfo = $initializedBackend->share($sharingRecords, true);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			$response['status'] = false;
 			$response['header'] = _('Updating share failed');
 			$response['message'] = $e->getMessage();
@@ -1305,8 +1279,7 @@ 
 
 		try {
 			$sInfo = $initializedBackend->unshare($records);
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			$response['status'] = false;
 			$response['header'] = _('Deleting share failed');
 			$response['message'] = $e->getMessage();

plugins/passwd/php/plugin.passwd.php

Indentation +41 added lines, -41 removed lines

@@ -5,48 +5,48 @@
  * Allows to change user password from grommunio Web.
  */
 class Pluginpasswd extends Plugin {
-	public function __construct() {
-	}
+    public function __construct() {
+    }
 
-	/**
-	 * Function initializes the Plugin and registers all hooks.
-	 */
-	public function init() {
-		$this->registerHook('server.core.settings.init.before');
-	}
+    /**
+     * Function initializes the Plugin and registers all hooks.
+     */
+    public function init() {
+        $this->registerHook('server.core.settings.init.before');
+    }
 
-	/**
-	 * Function is executed when a hook is triggered by the PluginManager.
-	 *
-	 * @param string $eventID the id of the triggered hook
-	 * @param mixed  $data    object(s) related to the hook
-	 */
-	public function execute($eventID, &$data) {
-		switch ($eventID) {
-			case 'server.core.settings.init.before':
-				$this->injectPluginSettings($data);
-				break;
-		}
-	}
+    /**
+     * Function is executed when a hook is triggered by the PluginManager.
+     *
+     * @param string $eventID the id of the triggered hook
+     * @param mixed  $data    object(s) related to the hook
+     */
+    public function execute($eventID, &$data) {
+        switch ($eventID) {
+            case 'server.core.settings.init.before':
+                $this->injectPluginSettings($data);
+                break;
+        }
+    }
 
-	/**
-	 * Called when the core Settings class is initialized and ready to accept sysadmin default
-	 * settings. Registers the sysadmin defaults for the SugarCRM plugin.
-	 *
-	 * @param array $data Reference to the data of the triggered hook
-	 */
-	public function injectPluginSettings(&$data) {
-		$data['settingsObj']->addSysAdminDefaults([
-			'zarafa' => [
-				'v1' => [
-					'plugins' => [
-						'passwd' => [
-							'enable' => PLUGIN_PASSWD_USER_DEFAULT_ENABLE,
-							'enable_strict_check' => PLUGIN_PASSWD_STRICT_CHECK_ENABLE,
-						],
-					],
-				],
-			],
-		]);
-	}
+    /**
+     * Called when the core Settings class is initialized and ready to accept sysadmin default
+     * settings. Registers the sysadmin defaults for the SugarCRM plugin.
+     *
+     * @param array $data Reference to the data of the triggered hook
+     */
+    public function injectPluginSettings(&$data) {
+        $data['settingsObj']->addSysAdminDefaults([
+            'zarafa' => [
+                'v1' => [
+                    'plugins' => [
+                        'passwd' => [
+                            'enable' => PLUGIN_PASSWD_USER_DEFAULT_ENABLE,
+                            'enable_strict_check' => PLUGIN_PASSWD_STRICT_CHECK_ENABLE,
+                        ],
+                    ],
+                ],
+            ],
+        ]);
+    }
 }

plugins/passwd/php/class.passwdmodule.php

Indentation +151 added lines, -151 removed lines

@@ -4,170 +4,170 @@
  * Module that will be used to change passwords of the user.
  */
 class PasswdModule extends Module {
-	/**
-	 * Process the incoming events that were fire by the client.
-	 */
-	public function execute() {
-		foreach ($this->data as $actionType => $actionData) {
-			if (isset($actionType)) {
-				try {
-					switch ($actionType) {
-						case 'save':
-							$this->save($actionData);
-							break;
+    /**
+     * Process the incoming events that were fire by the client.
+     */
+    public function execute() {
+        foreach ($this->data as $actionType => $actionData) {
+            if (isset($actionType)) {
+                try {
+                    switch ($actionType) {
+                        case 'save':
+                            $this->save($actionData);
+                            break;
 
-						default:
-							$this->handleUnknownActionType($actionType);
-					}
-				}
-				catch (MAPIException $e) {
-					$this->sendFeedback(false, $this->errorDetailsFromException($e));
-				}
-			}
-		}
-	}
+                        default:
+                            $this->handleUnknownActionType($actionType);
+                    }
+                }
+                catch (MAPIException $e) {
+                    $this->sendFeedback(false, $this->errorDetailsFromException($e));
+                }
+            }
+        }
+    }
 
-	/**
-	 * Change the password of user. Do some calidation and call proper methods based on
-	 * zarafa setup.
-	 *
-	 * @param {Array} $data data sent by client
-	 */
-	public function save($data) {
-		$errorMessage = '';
+    /**
+     * Change the password of user. Do some calidation and call proper methods based on
+     * zarafa setup.
+     *
+     * @param {Array} $data data sent by client
+     */
+    public function save($data) {
+        $errorMessage = '';
 
-		// some sanity checks
-		if (empty($data)) {
-			$errorMessage = _('No data received.');
-		}
+        // some sanity checks
+        if (empty($data)) {
+            $errorMessage = _('No data received.');
+        }
 
-		if (empty($data['username'])) {
-			$errorMessage = _('Account is empty.');
-		}
+        if (empty($data['username'])) {
+            $errorMessage = _('Account is empty.');
+        }
 
-		if (empty($data['current_password'])) {
-			$errorMessage = _('Current password is empty.');
-		}
+        if (empty($data['current_password'])) {
+            $errorMessage = _('Current password is empty.');
+        }
 
-		if (empty($data['new_password']) || empty($data['new_password_repeat'])) {
-			$errorMessage = _('New password is empty.');
-		}
+        if (empty($data['new_password']) || empty($data['new_password_repeat'])) {
+            $errorMessage = _('New password is empty.');
+        }
 
-		if ($data['new_password'] !== $data['new_password_repeat']) {
-			$errorMessage = _('New passwords do not match.');
-		}
+        if ($data['new_password'] !== $data['new_password_repeat']) {
+            $errorMessage = _('New passwords do not match.');
+        }
 
-		if (empty($errorMessage)) {
-			$this->saveInDB($data);
-		}
-		else {
-			$this->sendFeedback(false, [
-				'type' => ERROR_ZARAFA,
-				'info' => [
-					'display_message' => $errorMessage,
-				],
-			]);
-		}
-	}
+        if (empty($errorMessage)) {
+            $this->saveInDB($data);
+        }
+        else {
+            $this->sendFeedback(false, [
+                'type' => ERROR_ZARAFA,
+                'info' => [
+                    'display_message' => $errorMessage,
+                ],
+            ]);
+        }
+    }
 
-	/**
-	 * Function will try to change user's password via MAPI in SOAP connection.
-	 *
-	 * @param {Array} $data data sent by client
-	 */
-	public function saveInDB($data) {
-		$errorMessage = '';
-		$userName = $data['username'];
-		$newPassword = $data['new_password'];
-		$sessionPass = '';
+    /**
+     * Function will try to change user's password via MAPI in SOAP connection.
+     *
+     * @param {Array} $data data sent by client
+     */
+    public function saveInDB($data) {
+        $errorMessage = '';
+        $userName = $data['username'];
+        $newPassword = $data['new_password'];
+        $sessionPass = '';
 
-		// get current session password
-		// if this plugin is used on a webapp version with EncryptionStore,
-		// $_SESSION['password'] is no longer available. Uses EncryptionStore
-		// in this case.
-		if (class_exists("EncryptionStore")) {
-			$encryptionStore = EncryptionStore::getInstance();
-			$sessionPass = $encryptionStore->get("password");
-		}
+        // get current session password
+        // if this plugin is used on a webapp version with EncryptionStore,
+        // $_SESSION['password'] is no longer available. Uses EncryptionStore
+        // in this case.
+        if (class_exists("EncryptionStore")) {
+            $encryptionStore = EncryptionStore::getInstance();
+            $sessionPass = $encryptionStore->get("password");
+        }
 
-		if ($data['current_password'] !== $sessionPass) {
-			$errorMessage = _('Current password does not match.');
-		}
-		elseif (defined('PLUGIN_PASSWD_USE_ZCORE') && PLUGIN_PASSWD_USE_ZCORE) {
-			try {
-				$result = nsp_setuserpasswd($userName, $sessionPass, $newPassword);
-				// password changed successfully
-				if ($result) {
-					$this->sendFeedback(true, [
-						'info' => [
-							'display_message' => _('Password is changed successfully.'),
-						],
-					]);
-					// write new password to session because we don't want user to re-authenticate
-					session_start();
-					$encryptionStore = EncryptionStore::getInstance();
-					$encryptionStore->add('password', $newPassword);
-					session_write_close();
+        if ($data['current_password'] !== $sessionPass) {
+            $errorMessage = _('Current password does not match.');
+        }
+        elseif (defined('PLUGIN_PASSWD_USE_ZCORE') && PLUGIN_PASSWD_USE_ZCORE) {
+            try {
+                $result = nsp_setuserpasswd($userName, $sessionPass, $newPassword);
+                // password changed successfully
+                if ($result) {
+                    $this->sendFeedback(true, [
+                        'info' => [
+                            'display_message' => _('Password is changed successfully.'),
+                        ],
+                    ]);
+                    // write new password to session because we don't want user to re-authenticate
+                    session_start();
+                    $encryptionStore = EncryptionStore::getInstance();
+                    $encryptionStore->add('password', $newPassword);
+                    session_write_close();
 
-					return;
-				}
-			}
-			catch (MAPIException $e) {
-				if (mapi_last_hresult() == MAPI_E_NO_ACCESS) {
-					$errorMessage = _('Your password is wrong or you have insufficient permission to change password');
-				}
-			}
-			if (empty($errorMessage)) {
-				$errorMessage = _('Password is not changed.');
-			}
-		}
-		else {
-			$url = (defined('PLUGIN_PASSWD_ADMIN_API_ENDPOINT') && PLUGIN_PASSWD_ADMIN_API_ENDPOINT) ?
-				PLUGIN_PASSWD_ADMIN_API_ENDPOINT :
-				'http://[::1]:8080/api/v1/passwd';
-			$result = file_get_contents($url, false, stream_context_create([
-				'http' => [
-					'header' => [
-						'Content-type: application/json',
-					],
-					'method' => 'PUT',
-					'content' => json_encode([
-						"user" => $userName,
-						"old" => $data['current_password'],
-						"new" => $newPassword,
-					]),
-				],
-			]));
+                    return;
+                }
+            }
+            catch (MAPIException $e) {
+                if (mapi_last_hresult() == MAPI_E_NO_ACCESS) {
+                    $errorMessage = _('Your password is wrong or you have insufficient permission to change password');
+                }
+            }
+            if (empty($errorMessage)) {
+                $errorMessage = _('Password is not changed.');
+            }
+        }
+        else {
+            $url = (defined('PLUGIN_PASSWD_ADMIN_API_ENDPOINT') && PLUGIN_PASSWD_ADMIN_API_ENDPOINT) ?
+                PLUGIN_PASSWD_ADMIN_API_ENDPOINT :
+                'http://[::1]:8080/api/v1/passwd';
+            $result = file_get_contents($url, false, stream_context_create([
+                'http' => [
+                    'header' => [
+                        'Content-type: application/json',
+                    ],
+                    'method' => 'PUT',
+                    'content' => json_encode([
+                        "user" => $userName,
+                        "old" => $data['current_password'],
+                        "new" => $newPassword,
+                    ]),
+                ],
+            ]));
 
-			if ($result === false) {
-				$errorMessage = _('Error changing password. Please contact the system administrator.');
-			}
-			else {
-				$this->sendFeedback(true, [
-					'info' => [
-						'display_message' => _('Password has been changed successfully.'),
-					],
-				]);
-				// write new password to session because we don't want user to re-authenticate
-				session_start();
-				$encryptionStore = EncryptionStore::getInstance();
-				$encryptionStore->add('password', $newPassword);
-				session_write_close();
+            if ($result === false) {
+                $errorMessage = _('Error changing password. Please contact the system administrator.');
+            }
+            else {
+                $this->sendFeedback(true, [
+                    'info' => [
+                        'display_message' => _('Password has been changed successfully.'),
+                    ],
+                ]);
+                // write new password to session because we don't want user to re-authenticate
+                session_start();
+                $encryptionStore = EncryptionStore::getInstance();
+                $encryptionStore->add('password', $newPassword);
+                session_write_close();
 
-				return;
-			}
-			if (empty($errorMessage)) {
-				$errorMessage = _('Password is not changed.');
-			}
-		}
+                return;
+            }
+            if (empty($errorMessage)) {
+                $errorMessage = _('Password is not changed.');
+            }
+        }
 
-		if (!empty($errorMessage)) {
-			$this->sendFeedback(false, [
-				'type' => ERROR_ZARAFA,
-				'info' => [
-					'display_message' => $errorMessage,
-				],
-			]);
-		}
-	}
+        if (!empty($errorMessage)) {
+            $this->sendFeedback(false, [
+                'type' => ERROR_ZARAFA,
+                'info' => [
+                    'display_message' => $errorMessage,
+                ],
+            ]);
+        }
+    }
 }

Braces +6 added lines, -12 removed lines

@@ -19,8 +19,7 @@ 
 						default:
 							$this->handleUnknownActionType($actionType);
 					}
-				}
-				catch (MAPIException $e) {
+				} catch (MAPIException $e) {
 					$this->sendFeedback(false, $this->errorDetailsFromException($e));
 				}
 			}
@@ -59,8 +58,7 @@ 
 
 		if (empty($errorMessage)) {
 			$this->saveInDB($data);
-		}
-		else {
+		} else {
 			$this->sendFeedback(false, [
 				'type' => ERROR_ZARAFA,
 				'info' => [
@@ -92,8 +90,7 @@ 
 
 		if ($data['current_password'] !== $sessionPass) {
 			$errorMessage = _('Current password does not match.');
-		}
-		elseif (defined('PLUGIN_PASSWD_USE_ZCORE') && PLUGIN_PASSWD_USE_ZCORE) {
+		} elseif (defined('PLUGIN_PASSWD_USE_ZCORE') && PLUGIN_PASSWD_USE_ZCORE) {
 			try {
 				$result = nsp_setuserpasswd($userName, $sessionPass, $newPassword);
 				// password changed successfully
@@ -111,8 +108,7 @@ 
 
 					return;
 				}
-			}
-			catch (MAPIException $e) {
+			} catch (MAPIException $e) {
 				if (mapi_last_hresult() == MAPI_E_NO_ACCESS) {
 					$errorMessage = _('Your password is wrong or you have insufficient permission to change password');
 				}
@@ -120,8 +116,7 @@ 
 			if (empty($errorMessage)) {
 				$errorMessage = _('Password is not changed.');
 			}
-		}
-		else {
+		} else {
 			$url = (defined('PLUGIN_PASSWD_ADMIN_API_ENDPOINT') && PLUGIN_PASSWD_ADMIN_API_ENDPOINT) ?
 				PLUGIN_PASSWD_ADMIN_API_ENDPOINT :
 				'http://[::1]:8080/api/v1/passwd';
@@ -141,8 +136,7 @@ 
 
 			if ($result === false) {
 				$errorMessage = _('Error changing password. Please contact the system administrator.');
-			}
-			else {
+			} else {
 				$this->sendFeedback(true, [
 					'info' => [
 						'display_message' => _('Password has been changed successfully.'),

plugins/mdm/php/class.pluginmdmmodule.php

Indentation +962 added lines, -962 removed lines

@@ -7,331 +7,331 @@ 
  * PluginMDMModule Module.
  */
 class PluginMDMModule extends Module {
-	// content data
-	public const FOLDERUUID = 1;
-	public const FOLDERTYPE = 2;
-	public const FOLDERBACKENDID = 5;
-
-	/**
-	 * Constructor.
-	 *
-	 * @param int   $id   unique id
-	 * @param array $data list of all actions
-	 */
-	public function __construct($id, $data) {
-		parent::__construct($id, $data);
-		$this->stateFolder = null;
-		$this->deviceStates = [];
-		$this->devices = [];
-		$this->setupDevices();
-	}
-
-	/**
-	 * Function sets up the array with the user's devices.
-	 */
-	public function setupDevices() {
-		$devices = [];
-		$stateFolder = $this->getStoreStateFolder();
-		if ($stateFolder) {
-			$store = $GLOBALS["mapisession"]->getDefaultMessageStore();
-			$username = $GLOBALS["mapisession"]->getUserName();
-			$hierarchyTable = mapi_folder_gethierarchytable($stateFolder, CONVENIENT_DEPTH | MAPI_DEFERRED_ERRORS);
-			$rows = mapi_table_queryallrows($hierarchyTable, [PR_ENTRYID, PR_DISPLAY_NAME]);
-			foreach ($rows as $row) {
-				$deviceStateFolder = mapi_msgstore_openentry($store, $row[PR_ENTRYID]);
-				if (mapi_last_hresult() == 0) {
-					$this->deviceStates[$row[PR_DISPLAY_NAME]] = $deviceStateFolder;
-
-					$deviceStateFolderContents = mapi_folder_getcontentstable($deviceStateFolder, MAPI_ASSOCIATED);
-					$restriction = $this->getStateMessageRestriction("devicedata");
-					mapi_table_restrict($deviceStateFolderContents, $restriction);
-					if (mapi_table_getrowcount($deviceStateFolderContents) == 1) {
-						$rows = mapi_table_queryrows($deviceStateFolderContents, [PR_ENTRYID], 0, 1);
-						$message = mapi_msgstore_openentry($store, $rows[0][PR_ENTRYID]);
-						$state = base64_decode(streamProperty($message, PR_BODY));
-						$unserializedState = json_decode($state);
-						// fallback for "old-style" states
-						if (isset($unserializedState->data->devices)) {
-							$devices[$unserializedState->data->devices->{$username}->data->deviceid] = $unserializedState->data->devices->{$username}->data;
-						}
-						else {
-							$devices[$unserializedState->data->deviceid] = $unserializedState->data;
-						}
-					}
-				}
-			}
-		}
-		$this->devices = $devices;
-	}
-
-	/**
-	 * Function which triggers full resync of a device.
-	 *
-	 * @param string $deviceid of phone which has to be resynced
-	 *
-	 * @return json $response object contains the response of the soap request from grommunio-sync
-	 */
-	public function resyncDevice($deviceid) {
-		$deviceStateFolder = $this->deviceStates[$deviceid];
-		if ($deviceStateFolder) {
-			try {
-				// get the device data message and empty the folder contents
-				// create a new message in the folder and copy the device data message to it
-				// preventing the devicedata removal for resync
-				$deviceStateFolderContents = mapi_folder_getcontentstable($deviceStateFolder, MAPI_ASSOCIATED);
-				$restriction = $this->getStateMessageRestriction("devicedata");
-				mapi_table_restrict($deviceStateFolderContents, $restriction);
-				if (mapi_table_getrowcount($deviceStateFolderContents) == 1) {
-					$rows = mapi_table_queryrows($deviceStateFolderContents, [PR_ENTRYID], 0, 1);
-					$store = $GLOBALS["mapisession"]->getDefaultMessageStore();
-					$message = mapi_msgstore_openentry($store, $rows[0][PR_ENTRYID]);
-					mapi_folder_emptyfolder($deviceStateFolder, DEL_ASSOCIATED);
-
-					$devicedata = mapi_folder_createmessage($deviceStateFolder, MAPI_ASSOCIATED);
-					mapi_copyto($message, [], [], $devicedata);
-					mapi_setprops($devicedata, [PR_MESSAGE_CLASS => 'IPM.Note.GrommunioState']);
-					mapi_savechanges($devicedata);
-
-					return true;
-				}
-			}
-			catch (Exception $e) {
-				error_log(sprintf("mdm plugin resyncDevice Exception: %s", $e));
-
-				return false;
-			}
-		}
-		error_log(sprintf("mdm plugin resyncDevice device state folder %s", $deviceStateFolder));
-
-		return false;
-	}
-
-	/**
-	 * Function which triggers remote wipe of a device.
-	 *
-	 * @param string $deviceid of phone which has to be wiped
-	 * @param string $password user password
-	 *
-	 * @return json $response object contains the response of the soap request from grommunio-sync
-	 */
-	public function wipeDevice($deviceid, $password) {
-		$opts = ['http' => [
-			'method' => 'POST',
-			'header' => 'Content-Type: application/json',
-			'ignore_errors' => true,
-			'content' => json_encode(
-				[
-					'password' => $password,
-					'remoteIP' => '[::1]',
-					'status' => SYNC_PROVISION_RWSTATUS_PENDING,
-					'time' => time(),
-				]
-			),
-		],
-		];
-		$ret = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid, false, stream_context_create($opts));
-
-		return $ret;
-	}
-
-	/**
-	 * Function which triggers removal of a device.
-	 *
-	 * @param string $deviceid of phone which has to be wiped
-	 * @param string $password user password
-	 *
-	 * @return json $response object contains the response of the soap request from grommunio-sync
-	 */
-	public function removeDevice($deviceid, $password) {
-		// TODO remove the device from device / user list
-		$deviceStateFolder = $this->deviceStates[$deviceid];
-		$stateFolder = $this->getStoreStateFolder();
-		if ($stateFolder && $deviceStateFolder) {
-			$props = mapi_getprops($deviceStateFolder, [PR_ENTRYID]);
-
-			try {
-				mapi_folder_deletefolder($stateFolder, $props[PR_ENTRYID], DEL_MESSAGES);
-				$opts = ['http' => [
-					'method' => 'POST',
-					'header' => 'Content-Type: application/json',
-					'ignore_errors' => true,
-					'content' => json_encode(
-						[
-							'password' => $password,
-							'remoteIP' => '[::1]',
-							'status' => SYNC_PROVISION_RWSTATUS_NA,
-							'time' => time(),
-						]
-					),
-				],
-				];
-				$ret = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid, false, stream_context_create($opts));
-
-				return $ret;
-			}
-			catch (Exception $e) {
-				error_log(sprintf("mdm plugin removeDevice Exception: %s", $e));
-
-				return false;
-			}
-		}
-		error_log(sprintf(
-			"mdm plugin removeDevice state folder %s device state folder %s",
-			$stateFolder,
-			$deviceStateFolder
-		));
-
-		return false;
-	}
-
-	/**
-	 * Function to get details of the given device.
-	 *
-	 * @param string $deviceid id of device
-	 *
-	 * @return array contains device props
-	 */
-	public function getDeviceDetails($deviceid) {
-		$device = [];
-		$device['props'] = $this->getDeviceProps($this->devices[$deviceid]);
-		$device['sharedfolders'] = ['item' => $this->getAdditionalFolderList($deviceid)];
-
-		return $device;
-	}
-
-	/**
-	 * Executes all the actions in the $data variable.
-	 *
-	 * @return bool true on success of false on fialure
-	 */
-	public function execute() {
-		foreach ($this->data as $actionType => $actionData) {
-			if (isset($actionType)) {
-				try {
-					switch ($actionType) {
-						case 'wipe':
-							$this->wipeDevice($actionData['deviceid'], $actionData['password']);
-							$this->addActionData('wipe', [
-								'type' => 3,
-								'wipe' => $this->wipeDevice($actionData['deviceid'], $actionData['password']),
-							]);
-							$GLOBALS['bus']->addData($this->getResponseData());
-							break;
-
-						case 'resync':
-							$this->addActionData('resync', [
-								'type' => 3,
-								'resync' => $this->resyncDevice($actionData['deviceid']),
-							]);
-							$GLOBALS['bus']->addData($this->getResponseData());
-							break;
-
-						case 'remove':
-							$this->addActionData('remove', [
-								'type' => 3,
-								'remove' => $this->removeDevice($actionData['deviceid'], $actionData['password']),
-							]);
-							$GLOBALS['bus']->addData($this->getResponseData());
-							break;
-
-						case 'list':
-							$items = [];
-							$data['page'] = [];
-
-							foreach ($this->devices as $device) {
-								array_push($items, ['props' => $this->getDeviceProps($device)]);
-							}
-							$data['page']['start'] = 0;
-							$data['page']['rowcount'] = count($this->devices);
-							$data['page']['totalrowcount'] = $data['page']['rowcount'];
-							$data = array_merge($data, ['item' => $items]);
-							$this->addActionData('list', $data);
-							$GLOBALS['bus']->addData($this->getResponseData());
-							break;
-
-						case 'open':
-							$device = $this->getDeviceDetails($actionData["entryid"]);
-							$item = ["item" => $device];
-							$this->addActionData('item', $item);
-							$GLOBALS['bus']->addData($this->getResponseData());
-							break;
-
-						case 'save':
-							$this->saveDevice($actionData)
-							;
-							$device = $this->getDeviceDetails($actionData["entryid"]);
-							$item = ["item" => $device];
-							$this->addActionData('update', $item);
-							$GLOBALS['bus']->addData($this->getResponseData());
-							break;
-
-						default:
-							$this->handleUnknownActionType($actionType);
-					}
-				}
-				catch (Exception $e) {
-					$title = _('Mobile device management plugin');
-					$display_message = sprintf(_('Unexpected error occurred. Please contact your system administrator. Error code: %s'), $e->getMessage());
-					$this->sendFeedback(true, ["type" => ERROR_GENERAL, "info" => ['title' => $title, 'display_message' => $display_message]]);
-				}
-			}
-		}
-	}
-
-	/**
-	 * Function which is use to get device properties.
-	 *
-	 * @param object $device array of device properties
-	 *
-	 * @return array
-	 */
-	public function getDeviceProps($device) {
-		$item = [];
-		$propsList = ['devicetype', 'deviceos', 'devicefriendlyname', 'useragent', 'asversion', 'firstsynctime',
-			'lastsynctime', 'lastupdatetime', 'policyname', ];
-
-		$item['entryid'] = $device->deviceid;
-		$item['message_class'] = "IPM.MDM";
-		foreach ($propsList as $prop) {
-			if (isset($device->{$prop})) {
-				$item[$prop] = $device->{$prop};
-			}
-		}
-		$item['wipestatus'] = $this->getProvisioningWipeStatus($device->deviceid);
-
-		return array_merge($item, $this->getSyncFoldersProps($device));
-	}
-
-	/**
-	 * Function which is use to gather some statistics about synchronized folders.
-	 *
-	 * @param array $device array of device props
-	 *
-	 * @return array $syncFoldersProps has list of properties related to synchronized folders
-	 */
-	public function getSyncFoldersProps($device) {
-		$synchedFolderTypes = [];
-		$synchronizedFolders = 0;
-
-		foreach ($device->contentdata as $folderid => $folderdata) {
-			if (isset($folderdata->{self::FOLDERUUID})) {
-				$type = $folderdata->{self::FOLDERTYPE};
-
-				$folderType = $this->getSyncFolderType($type);
-				if (isset($synchedFolderTypes[$folderType])) {
-					++$synchedFolderTypes[$folderType];
-				}
-				else {
-					$synchedFolderTypes[$folderType] = 1;
-				}
-			}
-		}
-		$syncFoldersProps = [];
-		foreach ($synchedFolderTypes as $key => $value) {
-			$synchronizedFolders += $value;
-			$syncFoldersProps[strtolower($key) . 'folder'] = $value;
-		}
-		/*
+    // content data
+    public const FOLDERUUID = 1;
+    public const FOLDERTYPE = 2;
+    public const FOLDERBACKENDID = 5;
+
+    /**
+     * Constructor.
+     *
+     * @param int   $id   unique id
+     * @param array $data list of all actions
+     */
+    public function __construct($id, $data) {
+        parent::__construct($id, $data);
+        $this->stateFolder = null;
+        $this->deviceStates = [];
+        $this->devices = [];
+        $this->setupDevices();
+    }
+
+    /**
+     * Function sets up the array with the user's devices.
+     */
+    public function setupDevices() {
+        $devices = [];
+        $stateFolder = $this->getStoreStateFolder();
+        if ($stateFolder) {
+            $store = $GLOBALS["mapisession"]->getDefaultMessageStore();
+            $username = $GLOBALS["mapisession"]->getUserName();
+            $hierarchyTable = mapi_folder_gethierarchytable($stateFolder, CONVENIENT_DEPTH | MAPI_DEFERRED_ERRORS);
+            $rows = mapi_table_queryallrows($hierarchyTable, [PR_ENTRYID, PR_DISPLAY_NAME]);
+            foreach ($rows as $row) {
+                $deviceStateFolder = mapi_msgstore_openentry($store, $row[PR_ENTRYID]);
+                if (mapi_last_hresult() == 0) {
+                    $this->deviceStates[$row[PR_DISPLAY_NAME]] = $deviceStateFolder;
+
+                    $deviceStateFolderContents = mapi_folder_getcontentstable($deviceStateFolder, MAPI_ASSOCIATED);
+                    $restriction = $this->getStateMessageRestriction("devicedata");
+                    mapi_table_restrict($deviceStateFolderContents, $restriction);
+                    if (mapi_table_getrowcount($deviceStateFolderContents) == 1) {
+                        $rows = mapi_table_queryrows($deviceStateFolderContents, [PR_ENTRYID], 0, 1);
+                        $message = mapi_msgstore_openentry($store, $rows[0][PR_ENTRYID]);
+                        $state = base64_decode(streamProperty($message, PR_BODY));
+                        $unserializedState = json_decode($state);
+                        // fallback for "old-style" states
+                        if (isset($unserializedState->data->devices)) {
+                            $devices[$unserializedState->data->devices->{$username}->data->deviceid] = $unserializedState->data->devices->{$username}->data;
+                        }
+                        else {
+                            $devices[$unserializedState->data->deviceid] = $unserializedState->data;
+                        }
+                    }
+                }
+            }
+        }
+        $this->devices = $devices;
+    }
+
+    /**
+     * Function which triggers full resync of a device.
+     *
+     * @param string $deviceid of phone which has to be resynced
+     *
+     * @return json $response object contains the response of the soap request from grommunio-sync
+     */
+    public function resyncDevice($deviceid) {
+        $deviceStateFolder = $this->deviceStates[$deviceid];
+        if ($deviceStateFolder) {
+            try {
+                // get the device data message and empty the folder contents
+                // create a new message in the folder and copy the device data message to it
+                // preventing the devicedata removal for resync
+                $deviceStateFolderContents = mapi_folder_getcontentstable($deviceStateFolder, MAPI_ASSOCIATED);
+                $restriction = $this->getStateMessageRestriction("devicedata");
+                mapi_table_restrict($deviceStateFolderContents, $restriction);
+                if (mapi_table_getrowcount($deviceStateFolderContents) == 1) {
+                    $rows = mapi_table_queryrows($deviceStateFolderContents, [PR_ENTRYID], 0, 1);
+                    $store = $GLOBALS["mapisession"]->getDefaultMessageStore();
+                    $message = mapi_msgstore_openentry($store, $rows[0][PR_ENTRYID]);
+                    mapi_folder_emptyfolder($deviceStateFolder, DEL_ASSOCIATED);
+
+                    $devicedata = mapi_folder_createmessage($deviceStateFolder, MAPI_ASSOCIATED);
+                    mapi_copyto($message, [], [], $devicedata);
+                    mapi_setprops($devicedata, [PR_MESSAGE_CLASS => 'IPM.Note.GrommunioState']);
+                    mapi_savechanges($devicedata);
+
+                    return true;
+                }
+            }
+            catch (Exception $e) {
+                error_log(sprintf("mdm plugin resyncDevice Exception: %s", $e));
+
+                return false;
+            }
+        }
+        error_log(sprintf("mdm plugin resyncDevice device state folder %s", $deviceStateFolder));
+
+        return false;
+    }
+
+    /**
+     * Function which triggers remote wipe of a device.
+     *
+     * @param string $deviceid of phone which has to be wiped
+     * @param string $password user password
+     *
+     * @return json $response object contains the response of the soap request from grommunio-sync
+     */
+    public function wipeDevice($deviceid, $password) {
+        $opts = ['http' => [
+            'method' => 'POST',
+            'header' => 'Content-Type: application/json',
+            'ignore_errors' => true,
+            'content' => json_encode(
+                [
+                    'password' => $password,
+                    'remoteIP' => '[::1]',
+                    'status' => SYNC_PROVISION_RWSTATUS_PENDING,
+                    'time' => time(),
+                ]
+            ),
+        ],
+        ];
+        $ret = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid, false, stream_context_create($opts));
+
+        return $ret;
+    }
+
+    /**
+     * Function which triggers removal of a device.
+     *
+     * @param string $deviceid of phone which has to be wiped
+     * @param string $password user password
+     *
+     * @return json $response object contains the response of the soap request from grommunio-sync
+     */
+    public function removeDevice($deviceid, $password) {
+        // TODO remove the device from device / user list
+        $deviceStateFolder = $this->deviceStates[$deviceid];
+        $stateFolder = $this->getStoreStateFolder();
+        if ($stateFolder && $deviceStateFolder) {
+            $props = mapi_getprops($deviceStateFolder, [PR_ENTRYID]);
+
+            try {
+                mapi_folder_deletefolder($stateFolder, $props[PR_ENTRYID], DEL_MESSAGES);
+                $opts = ['http' => [
+                    'method' => 'POST',
+                    'header' => 'Content-Type: application/json',
+                    'ignore_errors' => true,
+                    'content' => json_encode(
+                        [
+                            'password' => $password,
+                            'remoteIP' => '[::1]',
+                            'status' => SYNC_PROVISION_RWSTATUS_NA,
+                            'time' => time(),
+                        ]
+                    ),
+                ],
+                ];
+                $ret = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid, false, stream_context_create($opts));
+
+                return $ret;
+            }
+            catch (Exception $e) {
+                error_log(sprintf("mdm plugin removeDevice Exception: %s", $e));
+
+                return false;
+            }
+        }
+        error_log(sprintf(
+            "mdm plugin removeDevice state folder %s device state folder %s",
+            $stateFolder,
+            $deviceStateFolder
+        ));
+
+        return false;
+    }
+
+    /**
+     * Function to get details of the given device.
+     *
+     * @param string $deviceid id of device
+     *
+     * @return array contains device props
+     */
+    public function getDeviceDetails($deviceid) {
+        $device = [];
+        $device['props'] = $this->getDeviceProps($this->devices[$deviceid]);
+        $device['sharedfolders'] = ['item' => $this->getAdditionalFolderList($deviceid)];
+
+        return $device;
+    }
+
+    /**
+     * Executes all the actions in the $data variable.
+     *
+     * @return bool true on success of false on fialure
+     */
+    public function execute() {
+        foreach ($this->data as $actionType => $actionData) {
+            if (isset($actionType)) {
+                try {
+                    switch ($actionType) {
+                        case 'wipe':
+                            $this->wipeDevice($actionData['deviceid'], $actionData['password']);
+                            $this->addActionData('wipe', [
+                                'type' => 3,
+                                'wipe' => $this->wipeDevice($actionData['deviceid'], $actionData['password']),
+                            ]);
+                            $GLOBALS['bus']->addData($this->getResponseData());
+                            break;
+
+                        case 'resync':
+                            $this->addActionData('resync', [
+                                'type' => 3,
+                                'resync' => $this->resyncDevice($actionData['deviceid']),
+                            ]);
+                            $GLOBALS['bus']->addData($this->getResponseData());
+                            break;
+
+                        case 'remove':
+                            $this->addActionData('remove', [
+                                'type' => 3,
+                                'remove' => $this->removeDevice($actionData['deviceid'], $actionData['password']),
+                            ]);
+                            $GLOBALS['bus']->addData($this->getResponseData());
+                            break;
+
+                        case 'list':
+                            $items = [];
+                            $data['page'] = [];
+
+                            foreach ($this->devices as $device) {
+                                array_push($items, ['props' => $this->getDeviceProps($device)]);
+                            }
+                            $data['page']['start'] = 0;
+                            $data['page']['rowcount'] = count($this->devices);
+                            $data['page']['totalrowcount'] = $data['page']['rowcount'];
+                            $data = array_merge($data, ['item' => $items]);
+                            $this->addActionData('list', $data);
+                            $GLOBALS['bus']->addData($this->getResponseData());
+                            break;
+
+                        case 'open':
+                            $device = $this->getDeviceDetails($actionData["entryid"]);
+                            $item = ["item" => $device];
+                            $this->addActionData('item', $item);
+                            $GLOBALS['bus']->addData($this->getResponseData());
+                            break;
+
+                        case 'save':
+                            $this->saveDevice($actionData)
+                            ;
+                            $device = $this->getDeviceDetails($actionData["entryid"]);
+                            $item = ["item" => $device];
+                            $this->addActionData('update', $item);
+                            $GLOBALS['bus']->addData($this->getResponseData());
+                            break;
+
+                        default:
+                            $this->handleUnknownActionType($actionType);
+                    }
+                }
+                catch (Exception $e) {
+                    $title = _('Mobile device management plugin');
+                    $display_message = sprintf(_('Unexpected error occurred. Please contact your system administrator. Error code: %s'), $e->getMessage());
+                    $this->sendFeedback(true, ["type" => ERROR_GENERAL, "info" => ['title' => $title, 'display_message' => $display_message]]);
+                }
+            }
+        }
+    }
+
+    /**
+     * Function which is use to get device properties.
+     *
+     * @param object $device array of device properties
+     *
+     * @return array
+     */
+    public function getDeviceProps($device) {
+        $item = [];
+        $propsList = ['devicetype', 'deviceos', 'devicefriendlyname', 'useragent', 'asversion', 'firstsynctime',
+            'lastsynctime', 'lastupdatetime', 'policyname', ];
+
+        $item['entryid'] = $device->deviceid;
+        $item['message_class'] = "IPM.MDM";
+        foreach ($propsList as $prop) {
+            if (isset($device->{$prop})) {
+                $item[$prop] = $device->{$prop};
+            }
+        }
+        $item['wipestatus'] = $this->getProvisioningWipeStatus($device->deviceid);
+
+        return array_merge($item, $this->getSyncFoldersProps($device));
+    }
+
+    /**
+     * Function which is use to gather some statistics about synchronized folders.
+     *
+     * @param array $device array of device props
+     *
+     * @return array $syncFoldersProps has list of properties related to synchronized folders
+     */
+    public function getSyncFoldersProps($device) {
+        $synchedFolderTypes = [];
+        $synchronizedFolders = 0;
+
+        foreach ($device->contentdata as $folderid => $folderdata) {
+            if (isset($folderdata->{self::FOLDERUUID})) {
+                $type = $folderdata->{self::FOLDERTYPE};
+
+                $folderType = $this->getSyncFolderType($type);
+                if (isset($synchedFolderTypes[$folderType])) {
+                    ++$synchedFolderTypes[$folderType];
+                }
+                else {
+                    $synchedFolderTypes[$folderType] = 1;
+                }
+            }
+        }
+        $syncFoldersProps = [];
+        foreach ($synchedFolderTypes as $key => $value) {
+            $synchronizedFolders += $value;
+            $syncFoldersProps[strtolower($key) . 'folder'] = $value;
+        }
+        /*
 		TODO getAdditionalFolderList
 		$client = $this->getSoapClient();
 		$items = $client->AdditionalFolderList($device['deviceid']);
@@ -339,641 +339,641 @@ 
 		$syncFoldersProps["shortfolderids"] = $device['hasfolderidmapping'] ? _("Yes") : _("No");
 		$syncFoldersProps['synchronizedfolders'] = $synchronizedFolders + count($items);
 		*/
-		$syncFoldersProps['synchronizedfolders'] = $synchronizedFolders;
-
-		return $syncFoldersProps;
-	}
-
-	/**
-	 * Function which is use to get general type like Mail,Calendar,Contacts,etc. from folder type.
-	 *
-	 * @param int    $type foldertype for a folder already known to the mobile
-	 * @param string $name folder name
-	 *
-	 * @return string general folder type
-	 */
-	public function getSyncFolderType($type) {
-		switch ($type) {
-			case SYNC_FOLDER_TYPE_APPOINTMENT:
-			case SYNC_FOLDER_TYPE_USER_APPOINTMENT:
-					$folderType = "Calendars";
-				break;
-
-			case SYNC_FOLDER_TYPE_CONTACT:
-			case SYNC_FOLDER_TYPE_USER_CONTACT:
-				$folderType = "Contacts";
-				break;
-
-			case SYNC_FOLDER_TYPE_TASK:
-			case SYNC_FOLDER_TYPE_USER_TASK:
-				$folderType = "Tasks";
-				break;
-
-			case SYNC_FOLDER_TYPE_NOTE:
-			case SYNC_FOLDER_TYPE_USER_NOTE:
-				$folderType = "Notes";
-				break;
-
-			default:
-				$folderType = "Emails";
-				break;
-		}
-
-		return $folderType;
-	}
-
-	/**
-	 * Function which is use to get list of additional folders which was shared with given device.
-	 *
-	 * @param string $devid device id
-	 *
-	 * @return array has list of properties related to shared folders
-	 */
-	public function getAdditionalFolderList($devid) {
-		return [];
-		// TODO implement
-		$stores = $GLOBALS["mapisession"]->getAllMessageStores();
-		$client = $this->getSoapClient();
-		$items = $client->AdditionalFolderList($devid);
-		$data = [];
-		foreach ($items as $item) {
-			foreach ($stores as $store) {
-				try {
-					$entryid = mapi_msgstore_entryidfromsourcekey($store, hex2bin($item->folderid));
-				}
-				catch (MAPIException $me) {
-					continue;
-				}
-			}
-			if (isset($entryid)) {
-				$item->entryid = bin2hex($entryid);
-			}
-			array_push($data, ["props" => $item]);
-		}
-
-		return $data;
-	}
-
-	/**
-	 * Function which is use to remove additional folder which was shared with given device.
-	 *
-	 * @param string $entryId  id of device
-	 * @param string $folderid id of folder which will remove from device
-	 */
-	public function additionalFolderRemove($entryId, $folderid) {
-		$client = $this->getSoapClient();
-		$client->AdditionalFolderRemove($entryId, $folderid);
-	}
-
-	/**
-	 * Function which is use to add additional folder which will share with given device.
-	 *
-	 * @param string $entryId id of device
-	 * @param array  $folder  folder which will share with device
-	 */
-	public function additionalFolderAdd($entryId, $folder) {
-		$client = $this->getSoapClient();
-		$containerClass = isset($folder[PR_CONTAINER_CLASS]) ? $folder[PR_CONTAINER_CLASS] : "IPF.Note";
-		$folderId = bin2hex($folder[PR_SOURCE_KEY]);
-		$userName = $folder["user"];
-		$folderName = $userName === "SYSTEM" ? $folder[PR_DISPLAY_NAME] : $folder[PR_DISPLAY_NAME] . " - " . $userName;
-		$folderType = $this->getFolderTypeFromContainerClass($containerClass);
-		$client->AdditionalFolderAdd($entryId, $userName, $folderId, $folderName, $folderType, FLD_FLAGS_REPLYASUSER);
-	}
-
-	/**
-	 * Function which use to save the device.
-	 * It will use to add or remove folders in the device.
-	 *
-	 * @param array $data array of added and removed folders
-	 */
-	public function saveDevice($data) {
-		$entryid = $data["entryid"];
-		if (isset($data['sharedfolders'])) {
-			if (isset($data['sharedfolders']['remove'])) {
-				$deletedFolders = $data['sharedfolders']['remove'];
-				foreach ($deletedFolders as $folder) {
-					$this->additionalFolderRemove($entryid, $folder["folderid"]);
-				}
-			}
-			if (isset($data['sharedfolders']['add'])) {
-				$addFolders = $data['sharedfolders']['add'];
-				$hierarchyFolders = $this->getHierarchyList();
-				foreach ($addFolders as $folder) {
-					foreach ($hierarchyFolders as $hierarchyFolder) {
-						$folderEntryid = bin2hex($hierarchyFolder[PR_ENTRYID]);
-						if ($folderEntryid === $folder["entryid"]) {
-							$this->additionalFolderAdd($entryid, $hierarchyFolder);
-
-							continue 2;
-						}
-					}
-				}
-			}
-		}
-	}
-
-	/**
-	 * Gets the hierarchy list of all required stores.
-	 * Function which is use to get the hierarchy list with PR_SOURCE_KEY.
-	 *
-	 * @return array the array of all hierarchy folders
-	 */
-	public function getHierarchyList() {
-		$storeList = $GLOBALS["mapisession"]->getAllMessageStores();
-		$properties = $GLOBALS["properties"]->getFolderListProperties();
-		$otherUsers = $GLOBALS["mapisession"]->retrieveOtherUsersFromSettings();
-		$properties["source_key"] = PR_SOURCE_KEY;
-		$openWholeStore = true;
-		$storeData = [];
-
-		foreach ($storeList as $store) {
-			$msgstore_props = mapi_getprops($store, [PR_MDB_PROVIDER, PR_ENTRYID, PR_IPM_SUBTREE_ENTRYID, PR_USER_NAME]);
-			$storeType = $msgstore_props[PR_MDB_PROVIDER];
-
-			if ($storeType == ZARAFA_SERVICE_GUID) {
-				continue;
-			}
-			if ($storeType == ZARAFA_STORE_DELEGATE_GUID) {
-				$storeUserName = $GLOBALS["mapisession"]->getUserNameOfStore($msgstore_props[PR_ENTRYID]);
-			}
-			elseif ($storeType == ZARAFA_STORE_PUBLIC_GUID) {
-				$storeUserName = "SYSTEM";
-			}
-			else {
-				$storeUserName = $msgstore_props[PR_USER_NAME];
-			}
-
-			if (is_array($otherUsers)) {
-				if (isset($otherUsers[$storeUserName])) {
-					$sharedFolders = $otherUsers[$storeUserName];
-					if (!isset($otherUsers[$storeUserName]['all'])) {
-						$openWholeStore = false;
-						$a = $this->getSharedFolderList($store, $sharedFolders, $properties, $storeUserName);
-						$storeData = array_merge($storeData, $a);
-					}
-				}
-			}
-
-			if ($openWholeStore) {
-				if (isset($msgstore_props[PR_IPM_SUBTREE_ENTRYID])) {
-					$subtreeFolderEntryID = $msgstore_props[PR_IPM_SUBTREE_ENTRYID];
-
-					try {
-						$subtreeFolder = mapi_msgstore_openentry($store, $subtreeFolderEntryID);
-					}
-					catch (MAPIException $e) {
-						// We've handled the event
-						$e->setHandled();
-					}
-
-					if ($storeType != ZARAFA_STORE_PUBLIC_GUID) {
-						$this->getSubFolders($subtreeFolder, $store, $properties, $storeData, $storeUserName);
-					}
-					else {
-						$this->getSubFoldersPublic($subtreeFolder, $store, $properties, $storeData, $storeUserName);
-					}
-				}
-			}
-		}
-
-		return $storeData;
-	}
-
-	/**
-	 * Helper function to get the shared folder list.
-	 *
-	 * @param object $store         message Store Object
-	 * @param object $sharedFolders mapi Folder Object
-	 * @param array  $properties    MAPI property mappings for folders
-	 * @param string $storeUserName owner name of store
-	 *
-	 * @return array shared folders list
-	 */
-	public function getSharedFolderList($store, $sharedFolders, $properties, $storeUserName) {
-		$msgstore_props = mapi_getprops($store, [PR_ENTRYID, PR_DISPLAY_NAME, PR_IPM_SUBTREE_ENTRYID, PR_IPM_OUTBOX_ENTRYID, PR_IPM_SENTMAIL_ENTRYID, PR_IPM_WASTEBASKET_ENTRYID, PR_MDB_PROVIDER, PR_IPM_PUBLIC_FOLDERS_ENTRYID, PR_IPM_FAVORITES_ENTRYID, PR_OBJECT_TYPE, PR_STORE_SUPPORT_MASK, PR_MAILBOX_OWNER_ENTRYID, PR_MAILBOX_OWNER_NAME, PR_USER_ENTRYID, PR_USER_NAME, PR_QUOTA_WARNING_THRESHOLD, PR_QUOTA_SEND_THRESHOLD, PR_QUOTA_RECEIVE_THRESHOLD, PR_MESSAGE_SIZE_EXTENDED, PR_MAPPING_SIGNATURE, PR_COMMON_VIEWS_ENTRYID, PR_FINDER_ENTRYID]);
-		$storeData = [];
-		$folders = [];
-
-		try {
-			$inbox = mapi_msgstore_getreceivefolder($store);
-			$inboxProps = mapi_getprops($inbox, [PR_ENTRYID]);
-		}
-		catch (MAPIException $e) {
-			// don't propagate this error to parent handlers, if store doesn't support it
-			if ($e->getCode() === MAPI_E_NO_SUPPORT) {
-				$e->setHandled();
-			}
-		}
-
-		$root = mapi_msgstore_openentry($store, null);
-		$rootProps = mapi_getprops($root, [PR_IPM_APPOINTMENT_ENTRYID, PR_IPM_CONTACT_ENTRYID, PR_IPM_DRAFTS_ENTRYID, PR_IPM_JOURNAL_ENTRYID, PR_IPM_NOTE_ENTRYID, PR_IPM_TASK_ENTRYID, PR_ADDITIONAL_REN_ENTRYIDS]);
-
-		$additional_ren_entryids = [];
-		if (isset($rootProps[PR_ADDITIONAL_REN_ENTRYIDS])) {
-			$additional_ren_entryids = $rootProps[PR_ADDITIONAL_REN_ENTRYIDS];
-		}
-
-		$defaultfolders = [
-			"default_folder_inbox" => ["inbox" => PR_ENTRYID],
-			"default_folder_outbox" => ["store" => PR_IPM_OUTBOX_ENTRYID],
-			"default_folder_sent" => ["store" => PR_IPM_SENTMAIL_ENTRYID],
-			"default_folder_wastebasket" => ["store" => PR_IPM_WASTEBASKET_ENTRYID],
-			"default_folder_favorites" => ["store" => PR_IPM_FAVORITES_ENTRYID],
-			"default_folder_publicfolders" => ["store" => PR_IPM_PUBLIC_FOLDERS_ENTRYID],
-			"default_folder_calendar" => ["root" => PR_IPM_APPOINTMENT_ENTRYID],
-			"default_folder_contact" => ["root" => PR_IPM_CONTACT_ENTRYID],
-			"default_folder_drafts" => ["root" => PR_IPM_DRAFTS_ENTRYID],
-			"default_folder_journal" => ["root" => PR_IPM_JOURNAL_ENTRYID],
-			"default_folder_note" => ["root" => PR_IPM_NOTE_ENTRYID],
-			"default_folder_task" => ["root" => PR_IPM_TASK_ENTRYID],
-			"default_folder_junk" => ["additional" => 4],
-			"default_folder_syncissues" => ["additional" => 1],
-			"default_folder_conflicts" => ["additional" => 0],
-			"default_folder_localfailures" => ["additional" => 2],
-			"default_folder_serverfailures" => ["additional" => 3],
-		];
-
-		foreach ($defaultfolders as $key => $prop) {
-			$tag = reset($prop);
-			$from = key($prop);
-
-			switch ($from) {
-				case "inbox":
-					if (isset($inboxProps[$tag])) {
-						$storeData["props"][$key] = bin2hex($inboxProps[$tag]);
-					}
-					break;
-
-				case "store":
-					if (isset($msgstore_props[$tag])) {
-						$storeData["props"][$key] = bin2hex($msgstore_props[$tag]);
-					}
-					break;
-
-				case "root":
-					if (isset($rootProps[$tag])) {
-						$storeData["props"][$key] = bin2hex($rootProps[$tag]);
-					}
-					break;
-
-				case "additional":
-					if (isset($additional_ren_entryids[$tag])) {
-						$storeData["props"][$key] = bin2hex($additional_ren_entryids[$tag]);
-					}
-					break;
-			}
-		}
-
-		$store_access = true;
-		$openSubFolders = false;
-		foreach ($sharedFolders as $type => $sharedFolder) {
-			$openSubFolders = ($sharedFolder["show_subfolders"] == true);
-			$folderEntryID = hex2bin($storeData["props"]["default_folder_" . $sharedFolder["folder_type"]]);
-
-			try {
-				// load folder props
-				$folder = mapi_msgstore_openentry($store, $folderEntryID);
-			}
-			catch (MAPIException $e) {
-				// Indicate that we don't have access to the store,
-				// so no more attempts to read properties or open entries.
-				$store_access = false;
-
-				// We've handled the event
-				$e->setHandled();
-			}
-		}
-
-		if ($store_access === true) {
-			$folderProps = mapi_getprops($folder, $properties);
-			$folderProps["user"] = $storeUserName;
-			array_push($folders, $folderProps);
-
-			// If folder has sub folders then add its.
-			if ($openSubFolders === true) {
-				if ($folderProps[PR_SUBFOLDERS] != false) {
-					$subFoldersData = [];
-					$this->getSubFolders($folder, $store, $properties, $subFoldersData, $storeUserName);
-					$folders = array_merge($folders, $subFoldersData);
-				}
-			}
-		}
-
-		return $folders;
-	}
-
-	/**
-	 * Helper function to get the sub folders of a given folder.
-	 *
-	 * @param object $folder        mapi Folder Object
-	 * @param object $store         Message Store Object
-	 * @param array  $properties    MAPI property mappings for folders
-	 * @param array  $storeData     Reference to an array. The folder properties are added to this array.
-	 * @param string $storeUserName owner name of store
-	 */
-	public function getSubFolders($folder, $store, $properties, &$storeData, $storeUserName) {
-		/**
-		 * remove hidden folders, folders with PR_ATTR_HIDDEN property set
-		 * should not be shown to the client.
-		 */
-		$restriction = [RES_OR, [
-			[RES_PROPERTY,
-				[
-					RELOP => RELOP_EQ,
-					ULPROPTAG => PR_ATTR_HIDDEN,
-					VALUE => [PR_ATTR_HIDDEN => false],
-				],
-			],
-			[RES_NOT,
-				[
-					[RES_EXIST,
-						[
-							ULPROPTAG => PR_ATTR_HIDDEN,
-						],
-					],
-				],
-			],
-		]];
-
-		$expand = [
-			[
-				'folder' => $folder,
-				'props' => mapi_getprops($folder, [PR_ENTRYID, PR_SUBFOLDERS]),
-			],
-		];
-
-		// Start looping through the $expand array, during each loop we grab the first item in
-		// the array and obtain the hierarchy table for that particular folder. If one of those
-		// subfolders has subfolders of its own, it will be appended to $expand again to ensure
-		// it will be expanded later.
-		while (!empty($expand)) {
-			$item = array_shift($expand);
-			$columns = $properties;
-
-			$hierarchyTable = mapi_folder_gethierarchytable($item['folder'], MAPI_DEFERRED_ERRORS);
-			mapi_table_restrict($hierarchyTable, $restriction, TBL_BATCH);
-
-			mapi_table_setcolumns($hierarchyTable, $columns);
-			$columns = null;
-
-			// Load the hierarchy in small batches
-			$batchcount = 100;
-			do {
-				$rows = mapi_table_queryrows($hierarchyTable, $columns, 0, $batchcount);
-
-				foreach ($rows as $subfolder) {
-					// If the subfolders has subfolders of its own, append the folder
-					// to the $expand array, so it can be expanded in the next loop.
-					if ($subfolder[PR_SUBFOLDERS]) {
-						$folderObject = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
-						array_push($expand, ['folder' => $folderObject, 'props' => $subfolder]);
-					}
-					$subfolder["user"] = $storeUserName;
-					// Add the folder to the return list.
-					array_push($storeData, $subfolder);
-				}
-
-				// When the server returned a different number of rows then was requested,
-				// we have reached the end of the table and we should exit the loop.
-			}
-			while (count($rows) === $batchcount);
-		}
-	}
-
-	/**
-	 * Helper function to get the subfolders of a Public Store.
-	 *
-	 * @param object $folder        mapi Folder Object
-	 * @param object $store         Message Store Object
-	 * @param array  $properties    MAPI property mappings for folders
-	 * @param array  $storeData     Reference to an array. The folder properties are added to this array.
-	 * @param string $storeUserName owner name of store
-	 */
-	public function getSubFoldersPublic($folder, $store, $properties, &$storeData, $storeUserName) {
-		$expand = [
-			[
-				'folder' => $folder,
-				'props' => mapi_getprops($folder, [PR_ENTRYID, PR_SUBFOLDERS]),
-			],
-		];
-
-		/**
-		 * remove hidden folders, folders with PR_ATTR_HIDDEN property set
-		 * should not be shown to the client.
-		 */
-		$restriction = [RES_OR, [
-			[RES_PROPERTY,
-				[
-					RELOP => RELOP_EQ,
-					ULPROPTAG => PR_ATTR_HIDDEN,
-					VALUE => [PR_ATTR_HIDDEN => false],
-				],
-			],
-			[RES_NOT,
-				[
-					[RES_EXIST,
-						[
-							ULPROPTAG => PR_ATTR_HIDDEN,
-						],
-					],
-				],
-			],
-		]];
-
-		// CONVENIENT_DEPTH doesn't work on the IPM_SUBTREE, hence we will be recursively
-		// walking through the hierarchy. However, we have some special folders like the
-		// "Favorites" and "Public Folders" from where we can switch to using
-		// CONVENIENT_DEPTH. Obtain these special cases here.
-		$specialEntryids = mapi_getprops($store, [
-			PR_IPM_FAVORITES_ENTRYID,
-			PR_IPM_PUBLIC_FOLDERS_ENTRYID,
-		]);
-
-		// Start looping through the $expand array, during each loop we grab the first item in
-		// the array and obtain the hierarchy table for that particular folder. If one of those
-		// subfolders has subfolders of its own, it will be appended to $expand again to ensure
-		// it will be expanded later.
-		while (!empty($expand)) {
-			$item = array_shift($expand);
-			$columns = $properties;
-			$hierarchyTable = mapi_folder_gethierarchytable($item['folder'], MAPI_DEFERRED_ERRORS);
-
-			mapi_table_restrict($hierarchyTable, $restriction, TBL_BATCH);
-
-			mapi_table_setcolumns($hierarchyTable, $columns);
-			$columns = null;
-
-			// Load the hierarchy in small batches
-			$batchcount = 100;
-			do {
-				$rows = mapi_table_queryrows($hierarchyTable, $columns, 0, $batchcount);
-
-				foreach ($rows as $subfolder) {
-					$specialFolder = false;
-
-					// Check if this folder is special...
-					if (!empty($specialEntryids)) {
-						foreach ($specialEntryids as $key => $value) {
-							// No need to do compareEntryId(), the special folders have static
-							// entryids, and can be compared using ===.
-							if (bin2hex($subfolder[PR_ENTRYID]) === bin2hex($value)) {
-								$specialFolder = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
-								$subfolder = mapi_getprops($specialFolder, $properties);
-
-								// We found the folder, no need to loop over it next time.
-								unset($specialEntryids[$key]);
-								break;
-							}
-						}
-					}
-
-					// If the subfolders has subfolders of its own, append the folder
-					// to the $expand array, so it can be expanded in the next loop.
-					if ($subfolder[PR_SUBFOLDERS]) {
-						if ($specialFolder) {
-							// Special folders can be redirected again to getSubFolders(),
-							$this->getSubFolders($specialFolder, $store, $properties, $storeData, $storeUserName);
-						}
-						else {
-							$folderObject = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
-							array_push($expand, ['folder' => $folderObject, 'props' => $subfolder]);
-						}
-					}
-
-					$subfolder["user"] = $storeUserName;
-					// Add the folder to the return list.
-					array_push($storeData, $subfolder);
-				}
-
-				// When the server returned a different number of rows then was requested,
-				// we have reached the end of the table and we should exit the loop.
-			}
-			while (count($rows) === $batchcount);
-		}
-	}
-
-	/**
-	 * Function which is use get folder types from the container class.
-	 *
-	 * @param string $containerClass container class of folder
-	 *
-	 * @return int folder type
-	 */
-	public function getFolderTypeFromContainerClass($containerClass) {
-		switch ($containerClass) {
-			case "IPF.Note":
-				return SYNC_FOLDER_TYPE_USER_MAIL;
-
-			case "IPF.Appointment":
-				return SYNC_FOLDER_TYPE_USER_APPOINTMENT;
-
-			case "IPF.Contact":
-				return SYNC_FOLDER_TYPE_USER_CONTACT;
-
-			case "IPF.StickyNote":
-				return SYNC_FOLDER_TYPE_USER_NOTE;
-
-			case "IPF.Task":
-				return SYNC_FOLDER_TYPE_USER_TASK;
-
-			case "IPF.Journal":
-				return SYNC_FOLDER_TYPE_USER_JOURNAL;
-
-			default:
-				return SYNC_FOLDER_TYPE_UNKNOWN;
-		}
-	}
-
-	/**
-	 * Returns MAPIFolder object which contains the state information.
-	 * Creates this folder if it is not available yet.
-	 *
-	 * @param string $devid the device id
-	 *
-	 * @return MAPIFolder
-	 */
-	public function getStoreStateFolder() {
-		if (!$this->stateFolder) {
-			$store = $GLOBALS["mapisession"]->getDefaultMessageStore();
-			$rootFolder = mapi_msgstore_openentry($store);
-			$hierarchy = mapi_folder_gethierarchytable($rootFolder, CONVENIENT_DEPTH | MAPI_DEFERRED_ERRORS);
-			$restriction = $this->getStateFolderRestriction(PLUGIN_MDM_STORE_STATE_FOLDER);
-			mapi_table_restrict($hierarchy, $restriction);
-			if (mapi_table_getrowcount($hierarchy) == 1) {
-				$rows = mapi_table_queryrows($hierarchy, [PR_ENTRYID], 0, 1);
-				$this->stateFolder = mapi_msgstore_openentry($store, $rows[0][PR_ENTRYID]);
-			}
-		}
-
-		return $this->stateFolder;
-	}
-
-	/**
-	 * Returns the restriction for the state folder name.
-	 *
-	 * @param string $folderName the state folder name
-	 *
-	 * @return array
-	 */
-	public function getStateFolderRestriction($folderName) {
-		return [RES_AND, [
-			[RES_PROPERTY,
-				[RELOP => RELOP_EQ,
-					ULPROPTAG => PR_DISPLAY_NAME,
-					VALUE => $folderName,
-				],
-			],
-			[RES_PROPERTY,
-				[RELOP => RELOP_EQ,
-					ULPROPTAG => PR_ATTR_HIDDEN,
-					VALUE => true,
-				],
-			],
-		]];
-	}
-
-	/**
-	 * Returns the restriction for the associated message in the state folder.
-	 *
-	 * @param string $messageName the message name
-	 *
-	 * @return array
-	 */
-	public function getStateMessageRestriction($messageName) {
-		return [RES_AND, [
-			[RES_PROPERTY,
-				[RELOP => RELOP_EQ,
-					ULPROPTAG => PR_DISPLAY_NAME,
-					VALUE => $messageName,
-				],
-			],
-			[RES_PROPERTY,
-				[RELOP => RELOP_EQ,
-					ULPROPTAG => PR_MESSAGE_CLASS,
-					VALUE => 'IPM.Note.GrommunioState',
-				],
-			],
-		]];
-	}
-
-	/**
-	 * Returns the status of the remote wipe policy.
-	 *
-	 * @param mixed $deviceid
-	 *
-	 * @return int returns the current status of the device - SYNC_PROVISION_RWSTATUS_*
-	 */
-	public function getProvisioningWipeStatus($deviceid) {
-		// retrieve the WIPE STATUS from the Admin API
-		$api_response = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid);
-		if ($api_response) {
-			$data = json_decode($api_response, true);
-			if (isset($data['data'][$deviceid]["status"])) {
-				return $data['data'][$deviceid]["status"];
-			}
-		}
-
-		return SYNC_PROVISION_RWSTATUS_NA;
-	}
+        $syncFoldersProps['synchronizedfolders'] = $synchronizedFolders;
+
+        return $syncFoldersProps;
+    }
+
+    /**
+     * Function which is use to get general type like Mail,Calendar,Contacts,etc. from folder type.
+     *
+     * @param int    $type foldertype for a folder already known to the mobile
+     * @param string $name folder name
+     *
+     * @return string general folder type
+     */
+    public function getSyncFolderType($type) {
+        switch ($type) {
+            case SYNC_FOLDER_TYPE_APPOINTMENT:
+            case SYNC_FOLDER_TYPE_USER_APPOINTMENT:
+                    $folderType = "Calendars";
+                break;
+
+            case SYNC_FOLDER_TYPE_CONTACT:
+            case SYNC_FOLDER_TYPE_USER_CONTACT:
+                $folderType = "Contacts";
+                break;
+
+            case SYNC_FOLDER_TYPE_TASK:
+            case SYNC_FOLDER_TYPE_USER_TASK:
+                $folderType = "Tasks";
+                break;
+
+            case SYNC_FOLDER_TYPE_NOTE:
+            case SYNC_FOLDER_TYPE_USER_NOTE:
+                $folderType = "Notes";
+                break;
+
+            default:
+                $folderType = "Emails";
+                break;
+        }
+
+        return $folderType;
+    }
+
+    /**
+     * Function which is use to get list of additional folders which was shared with given device.
+     *
+     * @param string $devid device id
+     *
+     * @return array has list of properties related to shared folders
+     */
+    public function getAdditionalFolderList($devid) {
+        return [];
+        // TODO implement
+        $stores = $GLOBALS["mapisession"]->getAllMessageStores();
+        $client = $this->getSoapClient();
+        $items = $client->AdditionalFolderList($devid);
+        $data = [];
+        foreach ($items as $item) {
+            foreach ($stores as $store) {
+                try {
+                    $entryid = mapi_msgstore_entryidfromsourcekey($store, hex2bin($item->folderid));
+                }
+                catch (MAPIException $me) {
+                    continue;
+                }
+            }
+            if (isset($entryid)) {
+                $item->entryid = bin2hex($entryid);
+            }
+            array_push($data, ["props" => $item]);
+        }
+
+        return $data;
+    }
+
+    /**
+     * Function which is use to remove additional folder which was shared with given device.
+     *
+     * @param string $entryId  id of device
+     * @param string $folderid id of folder which will remove from device
+     */
+    public function additionalFolderRemove($entryId, $folderid) {
+        $client = $this->getSoapClient();
+        $client->AdditionalFolderRemove($entryId, $folderid);
+    }
+
+    /**
+     * Function which is use to add additional folder which will share with given device.
+     *
+     * @param string $entryId id of device
+     * @param array  $folder  folder which will share with device
+     */
+    public function additionalFolderAdd($entryId, $folder) {
+        $client = $this->getSoapClient();
+        $containerClass = isset($folder[PR_CONTAINER_CLASS]) ? $folder[PR_CONTAINER_CLASS] : "IPF.Note";
+        $folderId = bin2hex($folder[PR_SOURCE_KEY]);
+        $userName = $folder["user"];
+        $folderName = $userName === "SYSTEM" ? $folder[PR_DISPLAY_NAME] : $folder[PR_DISPLAY_NAME] . " - " . $userName;
+        $folderType = $this->getFolderTypeFromContainerClass($containerClass);
+        $client->AdditionalFolderAdd($entryId, $userName, $folderId, $folderName, $folderType, FLD_FLAGS_REPLYASUSER);
+    }
+
+    /**
+     * Function which use to save the device.
+     * It will use to add or remove folders in the device.
+     *
+     * @param array $data array of added and removed folders
+     */
+    public function saveDevice($data) {
+        $entryid = $data["entryid"];
+        if (isset($data['sharedfolders'])) {
+            if (isset($data['sharedfolders']['remove'])) {
+                $deletedFolders = $data['sharedfolders']['remove'];
+                foreach ($deletedFolders as $folder) {
+                    $this->additionalFolderRemove($entryid, $folder["folderid"]);
+                }
+            }
+            if (isset($data['sharedfolders']['add'])) {
+                $addFolders = $data['sharedfolders']['add'];
+                $hierarchyFolders = $this->getHierarchyList();
+                foreach ($addFolders as $folder) {
+                    foreach ($hierarchyFolders as $hierarchyFolder) {
+                        $folderEntryid = bin2hex($hierarchyFolder[PR_ENTRYID]);
+                        if ($folderEntryid === $folder["entryid"]) {
+                            $this->additionalFolderAdd($entryid, $hierarchyFolder);
+
+                            continue 2;
+                        }
+                    }
+                }
+            }
+        }
+    }
+
+    /**
+     * Gets the hierarchy list of all required stores.
+     * Function which is use to get the hierarchy list with PR_SOURCE_KEY.
+     *
+     * @return array the array of all hierarchy folders
+     */
+    public function getHierarchyList() {
+        $storeList = $GLOBALS["mapisession"]->getAllMessageStores();
+        $properties = $GLOBALS["properties"]->getFolderListProperties();
+        $otherUsers = $GLOBALS["mapisession"]->retrieveOtherUsersFromSettings();
+        $properties["source_key"] = PR_SOURCE_KEY;
+        $openWholeStore = true;
+        $storeData = [];
+
+        foreach ($storeList as $store) {
+            $msgstore_props = mapi_getprops($store, [PR_MDB_PROVIDER, PR_ENTRYID, PR_IPM_SUBTREE_ENTRYID, PR_USER_NAME]);
+            $storeType = $msgstore_props[PR_MDB_PROVIDER];
+
+            if ($storeType == ZARAFA_SERVICE_GUID) {
+                continue;
+            }
+            if ($storeType == ZARAFA_STORE_DELEGATE_GUID) {
+                $storeUserName = $GLOBALS["mapisession"]->getUserNameOfStore($msgstore_props[PR_ENTRYID]);
+            }
+            elseif ($storeType == ZARAFA_STORE_PUBLIC_GUID) {
+                $storeUserName = "SYSTEM";
+            }
+            else {
+                $storeUserName = $msgstore_props[PR_USER_NAME];
+            }
+
+            if (is_array($otherUsers)) {
+                if (isset($otherUsers[$storeUserName])) {
+                    $sharedFolders = $otherUsers[$storeUserName];
+                    if (!isset($otherUsers[$storeUserName]['all'])) {
+                        $openWholeStore = false;
+                        $a = $this->getSharedFolderList($store, $sharedFolders, $properties, $storeUserName);
+                        $storeData = array_merge($storeData, $a);
+                    }
+                }
+            }
+
+            if ($openWholeStore) {
+                if (isset($msgstore_props[PR_IPM_SUBTREE_ENTRYID])) {
+                    $subtreeFolderEntryID = $msgstore_props[PR_IPM_SUBTREE_ENTRYID];
+
+                    try {
+                        $subtreeFolder = mapi_msgstore_openentry($store, $subtreeFolderEntryID);
+                    }
+                    catch (MAPIException $e) {
+                        // We've handled the event
+                        $e->setHandled();
+                    }
+
+                    if ($storeType != ZARAFA_STORE_PUBLIC_GUID) {
+                        $this->getSubFolders($subtreeFolder, $store, $properties, $storeData, $storeUserName);
+                    }
+                    else {
+                        $this->getSubFoldersPublic($subtreeFolder, $store, $properties, $storeData, $storeUserName);
+                    }
+                }
+            }
+        }
+
+        return $storeData;
+    }
+
+    /**
+     * Helper function to get the shared folder list.
+     *
+     * @param object $store         message Store Object
+     * @param object $sharedFolders mapi Folder Object
+     * @param array  $properties    MAPI property mappings for folders
+     * @param string $storeUserName owner name of store
+     *
+     * @return array shared folders list
+     */
+    public function getSharedFolderList($store, $sharedFolders, $properties, $storeUserName) {
+        $msgstore_props = mapi_getprops($store, [PR_ENTRYID, PR_DISPLAY_NAME, PR_IPM_SUBTREE_ENTRYID, PR_IPM_OUTBOX_ENTRYID, PR_IPM_SENTMAIL_ENTRYID, PR_IPM_WASTEBASKET_ENTRYID, PR_MDB_PROVIDER, PR_IPM_PUBLIC_FOLDERS_ENTRYID, PR_IPM_FAVORITES_ENTRYID, PR_OBJECT_TYPE, PR_STORE_SUPPORT_MASK, PR_MAILBOX_OWNER_ENTRYID, PR_MAILBOX_OWNER_NAME, PR_USER_ENTRYID, PR_USER_NAME, PR_QUOTA_WARNING_THRESHOLD, PR_QUOTA_SEND_THRESHOLD, PR_QUOTA_RECEIVE_THRESHOLD, PR_MESSAGE_SIZE_EXTENDED, PR_MAPPING_SIGNATURE, PR_COMMON_VIEWS_ENTRYID, PR_FINDER_ENTRYID]);
+        $storeData = [];
+        $folders = [];
+
+        try {
+            $inbox = mapi_msgstore_getreceivefolder($store);
+            $inboxProps = mapi_getprops($inbox, [PR_ENTRYID]);
+        }
+        catch (MAPIException $e) {
+            // don't propagate this error to parent handlers, if store doesn't support it
+            if ($e->getCode() === MAPI_E_NO_SUPPORT) {
+                $e->setHandled();
+            }
+        }
+
+        $root = mapi_msgstore_openentry($store, null);
+        $rootProps = mapi_getprops($root, [PR_IPM_APPOINTMENT_ENTRYID, PR_IPM_CONTACT_ENTRYID, PR_IPM_DRAFTS_ENTRYID, PR_IPM_JOURNAL_ENTRYID, PR_IPM_NOTE_ENTRYID, PR_IPM_TASK_ENTRYID, PR_ADDITIONAL_REN_ENTRYIDS]);
+
+        $additional_ren_entryids = [];
+        if (isset($rootProps[PR_ADDITIONAL_REN_ENTRYIDS])) {
+            $additional_ren_entryids = $rootProps[PR_ADDITIONAL_REN_ENTRYIDS];
+        }
+
+        $defaultfolders = [
+            "default_folder_inbox" => ["inbox" => PR_ENTRYID],
+            "default_folder_outbox" => ["store" => PR_IPM_OUTBOX_ENTRYID],
+            "default_folder_sent" => ["store" => PR_IPM_SENTMAIL_ENTRYID],
+            "default_folder_wastebasket" => ["store" => PR_IPM_WASTEBASKET_ENTRYID],
+            "default_folder_favorites" => ["store" => PR_IPM_FAVORITES_ENTRYID],
+            "default_folder_publicfolders" => ["store" => PR_IPM_PUBLIC_FOLDERS_ENTRYID],
+            "default_folder_calendar" => ["root" => PR_IPM_APPOINTMENT_ENTRYID],
+            "default_folder_contact" => ["root" => PR_IPM_CONTACT_ENTRYID],
+            "default_folder_drafts" => ["root" => PR_IPM_DRAFTS_ENTRYID],
+            "default_folder_journal" => ["root" => PR_IPM_JOURNAL_ENTRYID],
+            "default_folder_note" => ["root" => PR_IPM_NOTE_ENTRYID],
+            "default_folder_task" => ["root" => PR_IPM_TASK_ENTRYID],
+            "default_folder_junk" => ["additional" => 4],
+            "default_folder_syncissues" => ["additional" => 1],
+            "default_folder_conflicts" => ["additional" => 0],
+            "default_folder_localfailures" => ["additional" => 2],
+            "default_folder_serverfailures" => ["additional" => 3],
+        ];
+
+        foreach ($defaultfolders as $key => $prop) {
+            $tag = reset($prop);
+            $from = key($prop);
+
+            switch ($from) {
+                case "inbox":
+                    if (isset($inboxProps[$tag])) {
+                        $storeData["props"][$key] = bin2hex($inboxProps[$tag]);
+                    }
+                    break;
+
+                case "store":
+                    if (isset($msgstore_props[$tag])) {
+                        $storeData["props"][$key] = bin2hex($msgstore_props[$tag]);
+                    }
+                    break;
+
+                case "root":
+                    if (isset($rootProps[$tag])) {
+                        $storeData["props"][$key] = bin2hex($rootProps[$tag]);
+                    }
+                    break;
+
+                case "additional":
+                    if (isset($additional_ren_entryids[$tag])) {
+                        $storeData["props"][$key] = bin2hex($additional_ren_entryids[$tag]);
+                    }
+                    break;
+            }
+        }
+
+        $store_access = true;
+        $openSubFolders = false;
+        foreach ($sharedFolders as $type => $sharedFolder) {
+            $openSubFolders = ($sharedFolder["show_subfolders"] == true);
+            $folderEntryID = hex2bin($storeData["props"]["default_folder_" . $sharedFolder["folder_type"]]);
+
+            try {
+                // load folder props
+                $folder = mapi_msgstore_openentry($store, $folderEntryID);
+            }
+            catch (MAPIException $e) {
+                // Indicate that we don't have access to the store,
+                // so no more attempts to read properties or open entries.
+                $store_access = false;
+
+                // We've handled the event
+                $e->setHandled();
+            }
+        }
+
+        if ($store_access === true) {
+            $folderProps = mapi_getprops($folder, $properties);
+            $folderProps["user"] = $storeUserName;
+            array_push($folders, $folderProps);
+
+            // If folder has sub folders then add its.
+            if ($openSubFolders === true) {
+                if ($folderProps[PR_SUBFOLDERS] != false) {
+                    $subFoldersData = [];
+                    $this->getSubFolders($folder, $store, $properties, $subFoldersData, $storeUserName);
+                    $folders = array_merge($folders, $subFoldersData);
+                }
+            }
+        }
+
+        return $folders;
+    }
+
+    /**
+     * Helper function to get the sub folders of a given folder.
+     *
+     * @param object $folder        mapi Folder Object
+     * @param object $store         Message Store Object
+     * @param array  $properties    MAPI property mappings for folders
+     * @param array  $storeData     Reference to an array. The folder properties are added to this array.
+     * @param string $storeUserName owner name of store
+     */
+    public function getSubFolders($folder, $store, $properties, &$storeData, $storeUserName) {
+        /**
+         * remove hidden folders, folders with PR_ATTR_HIDDEN property set
+         * should not be shown to the client.
+         */
+        $restriction = [RES_OR, [
+            [RES_PROPERTY,
+                [
+                    RELOP => RELOP_EQ,
+                    ULPROPTAG => PR_ATTR_HIDDEN,
+                    VALUE => [PR_ATTR_HIDDEN => false],
+                ],
+            ],
+            [RES_NOT,
+                [
+                    [RES_EXIST,
+                        [
+                            ULPROPTAG => PR_ATTR_HIDDEN,
+                        ],
+                    ],
+                ],
+            ],
+        ]];
+
+        $expand = [
+            [
+                'folder' => $folder,
+                'props' => mapi_getprops($folder, [PR_ENTRYID, PR_SUBFOLDERS]),
+            ],
+        ];
+
+        // Start looping through the $expand array, during each loop we grab the first item in
+        // the array and obtain the hierarchy table for that particular folder. If one of those
+        // subfolders has subfolders of its own, it will be appended to $expand again to ensure
+        // it will be expanded later.
+        while (!empty($expand)) {
+            $item = array_shift($expand);
+            $columns = $properties;
+
+            $hierarchyTable = mapi_folder_gethierarchytable($item['folder'], MAPI_DEFERRED_ERRORS);
+            mapi_table_restrict($hierarchyTable, $restriction, TBL_BATCH);
+
+            mapi_table_setcolumns($hierarchyTable, $columns);
+            $columns = null;
+
+            // Load the hierarchy in small batches
+            $batchcount = 100;
+            do {
+                $rows = mapi_table_queryrows($hierarchyTable, $columns, 0, $batchcount);
+
+                foreach ($rows as $subfolder) {
+                    // If the subfolders has subfolders of its own, append the folder
+                    // to the $expand array, so it can be expanded in the next loop.
+                    if ($subfolder[PR_SUBFOLDERS]) {
+                        $folderObject = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
+                        array_push($expand, ['folder' => $folderObject, 'props' => $subfolder]);
+                    }
+                    $subfolder["user"] = $storeUserName;
+                    // Add the folder to the return list.
+                    array_push($storeData, $subfolder);
+                }
+
+                // When the server returned a different number of rows then was requested,
+                // we have reached the end of the table and we should exit the loop.
+            }
+            while (count($rows) === $batchcount);
+        }
+    }
+
+    /**
+     * Helper function to get the subfolders of a Public Store.
+     *
+     * @param object $folder        mapi Folder Object
+     * @param object $store         Message Store Object
+     * @param array  $properties    MAPI property mappings for folders
+     * @param array  $storeData     Reference to an array. The folder properties are added to this array.
+     * @param string $storeUserName owner name of store
+     */
+    public function getSubFoldersPublic($folder, $store, $properties, &$storeData, $storeUserName) {
+        $expand = [
+            [
+                'folder' => $folder,
+                'props' => mapi_getprops($folder, [PR_ENTRYID, PR_SUBFOLDERS]),
+            ],
+        ];
+
+        /**
+         * remove hidden folders, folders with PR_ATTR_HIDDEN property set
+         * should not be shown to the client.
+         */
+        $restriction = [RES_OR, [
+            [RES_PROPERTY,
+                [
+                    RELOP => RELOP_EQ,
+                    ULPROPTAG => PR_ATTR_HIDDEN,
+                    VALUE => [PR_ATTR_HIDDEN => false],
+                ],
+            ],
+            [RES_NOT,
+                [
+                    [RES_EXIST,
+                        [
+                            ULPROPTAG => PR_ATTR_HIDDEN,
+                        ],
+                    ],
+                ],
+            ],
+        ]];
+
+        // CONVENIENT_DEPTH doesn't work on the IPM_SUBTREE, hence we will be recursively
+        // walking through the hierarchy. However, we have some special folders like the
+        // "Favorites" and "Public Folders" from where we can switch to using
+        // CONVENIENT_DEPTH. Obtain these special cases here.
+        $specialEntryids = mapi_getprops($store, [
+            PR_IPM_FAVORITES_ENTRYID,
+            PR_IPM_PUBLIC_FOLDERS_ENTRYID,
+        ]);
+
+        // Start looping through the $expand array, during each loop we grab the first item in
+        // the array and obtain the hierarchy table for that particular folder. If one of those
+        // subfolders has subfolders of its own, it will be appended to $expand again to ensure
+        // it will be expanded later.
+        while (!empty($expand)) {
+            $item = array_shift($expand);
+            $columns = $properties;
+            $hierarchyTable = mapi_folder_gethierarchytable($item['folder'], MAPI_DEFERRED_ERRORS);
+
+            mapi_table_restrict($hierarchyTable, $restriction, TBL_BATCH);
+
+            mapi_table_setcolumns($hierarchyTable, $columns);
+            $columns = null;
+
+            // Load the hierarchy in small batches
+            $batchcount = 100;
+            do {
+                $rows = mapi_table_queryrows($hierarchyTable, $columns, 0, $batchcount);
+
+                foreach ($rows as $subfolder) {
+                    $specialFolder = false;
+
+                    // Check if this folder is special...
+                    if (!empty($specialEntryids)) {
+                        foreach ($specialEntryids as $key => $value) {
+                            // No need to do compareEntryId(), the special folders have static
+                            // entryids, and can be compared using ===.
+                            if (bin2hex($subfolder[PR_ENTRYID]) === bin2hex($value)) {
+                                $specialFolder = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
+                                $subfolder = mapi_getprops($specialFolder, $properties);
+
+                                // We found the folder, no need to loop over it next time.
+                                unset($specialEntryids[$key]);
+                                break;
+                            }
+                        }
+                    }
+
+                    // If the subfolders has subfolders of its own, append the folder
+                    // to the $expand array, so it can be expanded in the next loop.
+                    if ($subfolder[PR_SUBFOLDERS]) {
+                        if ($specialFolder) {
+                            // Special folders can be redirected again to getSubFolders(),
+                            $this->getSubFolders($specialFolder, $store, $properties, $storeData, $storeUserName);
+                        }
+                        else {
+                            $folderObject = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
+                            array_push($expand, ['folder' => $folderObject, 'props' => $subfolder]);
+                        }
+                    }
+
+                    $subfolder["user"] = $storeUserName;
+                    // Add the folder to the return list.
+                    array_push($storeData, $subfolder);
+                }
+
+                // When the server returned a different number of rows then was requested,
+                // we have reached the end of the table and we should exit the loop.
+            }
+            while (count($rows) === $batchcount);
+        }
+    }
+
+    /**
+     * Function which is use get folder types from the container class.
+     *
+     * @param string $containerClass container class of folder
+     *
+     * @return int folder type
+     */
+    public function getFolderTypeFromContainerClass($containerClass) {
+        switch ($containerClass) {
+            case "IPF.Note":
+                return SYNC_FOLDER_TYPE_USER_MAIL;
+
+            case "IPF.Appointment":
+                return SYNC_FOLDER_TYPE_USER_APPOINTMENT;
+
+            case "IPF.Contact":
+                return SYNC_FOLDER_TYPE_USER_CONTACT;
+
+            case "IPF.StickyNote":
+                return SYNC_FOLDER_TYPE_USER_NOTE;
+
+            case "IPF.Task":
+                return SYNC_FOLDER_TYPE_USER_TASK;
+
+            case "IPF.Journal":
+                return SYNC_FOLDER_TYPE_USER_JOURNAL;
+
+            default:
+                return SYNC_FOLDER_TYPE_UNKNOWN;
+        }
+    }
+
+    /**
+     * Returns MAPIFolder object which contains the state information.
+     * Creates this folder if it is not available yet.
+     *
+     * @param string $devid the device id
+     *
+     * @return MAPIFolder
+     */
+    public function getStoreStateFolder() {
+        if (!$this->stateFolder) {
+            $store = $GLOBALS["mapisession"]->getDefaultMessageStore();
+            $rootFolder = mapi_msgstore_openentry($store);
+            $hierarchy = mapi_folder_gethierarchytable($rootFolder, CONVENIENT_DEPTH | MAPI_DEFERRED_ERRORS);
+            $restriction = $this->getStateFolderRestriction(PLUGIN_MDM_STORE_STATE_FOLDER);
+            mapi_table_restrict($hierarchy, $restriction);
+            if (mapi_table_getrowcount($hierarchy) == 1) {
+                $rows = mapi_table_queryrows($hierarchy, [PR_ENTRYID], 0, 1);
+                $this->stateFolder = mapi_msgstore_openentry($store, $rows[0][PR_ENTRYID]);
+            }
+        }
+
+        return $this->stateFolder;
+    }
+
+    /**
+     * Returns the restriction for the state folder name.
+     *
+     * @param string $folderName the state folder name
+     *
+     * @return array
+     */
+    public function getStateFolderRestriction($folderName) {
+        return [RES_AND, [
+            [RES_PROPERTY,
+                [RELOP => RELOP_EQ,
+                    ULPROPTAG => PR_DISPLAY_NAME,
+                    VALUE => $folderName,
+                ],
+            ],
+            [RES_PROPERTY,
+                [RELOP => RELOP_EQ,
+                    ULPROPTAG => PR_ATTR_HIDDEN,
+                    VALUE => true,
+                ],
+            ],
+        ]];
+    }
+
+    /**
+     * Returns the restriction for the associated message in the state folder.
+     *
+     * @param string $messageName the message name
+     *
+     * @return array
+     */
+    public function getStateMessageRestriction($messageName) {
+        return [RES_AND, [
+            [RES_PROPERTY,
+                [RELOP => RELOP_EQ,
+                    ULPROPTAG => PR_DISPLAY_NAME,
+                    VALUE => $messageName,
+                ],
+            ],
+            [RES_PROPERTY,
+                [RELOP => RELOP_EQ,
+                    ULPROPTAG => PR_MESSAGE_CLASS,
+                    VALUE => 'IPM.Note.GrommunioState',
+                ],
+            ],
+        ]];
+    }
+
+    /**
+     * Returns the status of the remote wipe policy.
+     *
+     * @param mixed $deviceid
+     *
+     * @return int returns the current status of the device - SYNC_PROVISION_RWSTATUS_*
+     */
+    public function getProvisioningWipeStatus($deviceid) {
+        // retrieve the WIPE STATUS from the Admin API
+        $api_response = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid);
+        if ($api_response) {
+            $data = json_decode($api_response, true);
+            if (isset($data['data'][$deviceid]["status"])) {
+                return $data['data'][$deviceid]["status"];
+            }
+        }
+
+        return SYNC_PROVISION_RWSTATUS_NA;
+    }
 }

Braces +13 added lines, -26 removed lines

@@ -53,8 +53,7 @@ 
 						// fallback for "old-style" states
 						if (isset($unserializedState->data->devices)) {
 							$devices[$unserializedState->data->devices->{$username}->data->deviceid] = $unserializedState->data->devices->{$username}->data;
-						}
-						else {
+						} else {
 							$devices[$unserializedState->data->deviceid] = $unserializedState->data;
 						}
 					}
@@ -94,8 +93,7 @@ 
 
 					return true;
 				}
-			}
-			catch (Exception $e) {
+			} catch (Exception $e) {
 				error_log(sprintf("mdm plugin resyncDevice Exception: %s", $e));
 
 				return false;
@@ -168,8 +166,7 @@ 
 				$ret = file_get_contents(PLUGIN_MDM_ADMIN_API_WIPE_ENDPOINT . $GLOBALS["mapisession"]->getUserName() . "?devices=" . $deviceid, false, stream_context_create($opts));
 
 				return $ret;
-			}
-			catch (Exception $e) {
+			} catch (Exception $e) {
 				error_log(sprintf("mdm plugin removeDevice Exception: %s", $e));
 
 				return false;
@@ -268,8 +265,7 @@ 
 						default:
 							$this->handleUnknownActionType($actionType);
 					}
-				}
-				catch (Exception $e) {
+				} catch (Exception $e) {
 					$title = _('Mobile device management plugin');
 					$display_message = sprintf(_('Unexpected error occurred. Please contact your system administrator. Error code: %s'), $e->getMessage());
 					$this->sendFeedback(true, ["type" => ERROR_GENERAL, "info" => ['title' => $title, 'display_message' => $display_message]]);
@@ -320,8 +316,7 @@ 
 				$folderType = $this->getSyncFolderType($type);
 				if (isset($synchedFolderTypes[$folderType])) {
 					++$synchedFolderTypes[$folderType];
-				}
-				else {
+				} else {
 					$synchedFolderTypes[$folderType] = 1;
 				}
 			}
@@ -400,8 +395,7 @@ 
 			foreach ($stores as $store) {
 				try {
 					$entryid = mapi_msgstore_entryidfromsourcekey($store, hex2bin($item->folderid));
-				}
-				catch (MAPIException $me) {
+				} catch (MAPIException $me) {
 					continue;
 				}
 			}
@@ -496,11 +490,9 @@ 
 			}
 			if ($storeType == ZARAFA_STORE_DELEGATE_GUID) {
 				$storeUserName = $GLOBALS["mapisession"]->getUserNameOfStore($msgstore_props[PR_ENTRYID]);
-			}
-			elseif ($storeType == ZARAFA_STORE_PUBLIC_GUID) {
+			} elseif ($storeType == ZARAFA_STORE_PUBLIC_GUID) {
 				$storeUserName = "SYSTEM";
-			}
-			else {
+			} else {
 				$storeUserName = $msgstore_props[PR_USER_NAME];
 			}
 
@@ -521,16 +513,14 @@ 
 
 					try {
 						$subtreeFolder = mapi_msgstore_openentry($store, $subtreeFolderEntryID);
-					}
-					catch (MAPIException $e) {
+					} catch (MAPIException $e) {
 						// We've handled the event
 						$e->setHandled();
 					}
 
 					if ($storeType != ZARAFA_STORE_PUBLIC_GUID) {
 						$this->getSubFolders($subtreeFolder, $store, $properties, $storeData, $storeUserName);
-					}
-					else {
+					} else {
 						$this->getSubFoldersPublic($subtreeFolder, $store, $properties, $storeData, $storeUserName);
 					}
 				}
@@ -558,8 +548,7 @@ 
 		try {
 			$inbox = mapi_msgstore_getreceivefolder($store);
 			$inboxProps = mapi_getprops($inbox, [PR_ENTRYID]);
-		}
-		catch (MAPIException $e) {
+		} catch (MAPIException $e) {
 			// don't propagate this error to parent handlers, if store doesn't support it
 			if ($e->getCode() === MAPI_E_NO_SUPPORT) {
 				$e->setHandled();
@@ -634,8 +623,7 @@ 
 			try {
 				// load folder props
 				$folder = mapi_msgstore_openentry($store, $folderEntryID);
-			}
-			catch (MAPIException $e) {
+			} catch (MAPIException $e) {
 				// Indicate that we don't have access to the store,
 				// so no more attempts to read properties or open entries.
 				$store_access = false;
@@ -834,8 +822,7 @@ 
 						if ($specialFolder) {
 							// Special folders can be redirected again to getSubFolders(),
 							$this->getSubFolders($specialFolder, $store, $properties, $storeData, $storeUserName);
-						}
-						else {
+						} else {
 							$folderObject = mapi_msgstore_openentry($store, $subfolder[PR_ENTRYID]);
 							array_push($expand, ['folder' => $folderObject, 'props' => $subfolder]);
 						}

plugins/mdm/php/plugin.mdm.php

Indentation +38 added lines, -38 removed lines

@@ -3,44 +3,44 @@
  * Handles plugin registration.
  */
 class PluginMDM extends Plugin {
-	/**
-	 * Called to initialize the plugin and register for hooks.
-	 */
-	public function init() {
-		$this->registerHook('server.core.settings.init.before');
-	}
+    /**
+     * Called to initialize the plugin and register for hooks.
+     */
+    public function init() {
+        $this->registerHook('server.core.settings.init.before');
+    }
 
-	/**
-	 * Function is executed when a hook is triggered by the PluginManager.
-	 *
-	 * @param string $eventID Identifier of the hook
-	 * @param array  $data    Reference to the data of the triggered hook
-	 */
-	public function execute($eventID, &$data) {
-		switch ($eventID) {
-			case 'server.core.settings.init.before':
-				$this->onBeforeSettingsInit($data);
-				break;
-		}
-	}
+    /**
+     * Function is executed when a hook is triggered by the PluginManager.
+     *
+     * @param string $eventID Identifier of the hook
+     * @param array  $data    Reference to the data of the triggered hook
+     */
+    public function execute($eventID, &$data) {
+        switch ($eventID) {
+            case 'server.core.settings.init.before':
+                $this->onBeforeSettingsInit($data);
+                break;
+        }
+    }
 
-	/**
-	 * Called when the core Settings class is initialized and ready to accept sysadmin default
-	 * settings. Registers the sysadmin defaults for the StatsLogging plugin.
-	 *
-	 * @param array $data Reference to the data of the triggered hook
-	 */
-	public function onBeforeSettingsInit(&$data) {
-		$data['settingsObj']->addSysAdminDefaults([
-			'zarafa' => [
-				'v1' => [
-					'plugins' => [
-						'mdm' => [
-							'enable' => PLUGIN_MDM_USER_DEFAULT_ENABLE_MDM,
-						],
-					],
-				],
-			],
-		]);
-	}
+    /**
+     * Called when the core Settings class is initialized and ready to accept sysadmin default
+     * settings. Registers the sysadmin defaults for the StatsLogging plugin.
+     *
+     * @param array $data Reference to the data of the triggered hook
+     */
+    public function onBeforeSettingsInit(&$data) {
+        $data['settingsObj']->addSysAdminDefaults([
+            'zarafa' => [
+                'v1' => [
+                    'plugins' => [
+                        'mdm' => [
+                            'enable' => PLUGIN_MDM_USER_DEFAULT_ENABLE_MDM,
+                        ],
+                    ],
+                ],
+            ],
+        ]);
+    }
 }

plugins/chat/php/plugin.chat.php

Indentation +41 added lines, -41 removed lines

@@ -4,48 +4,48 @@
  * Plugin that adds Chat to grommunio Web.
  */
 class PluginChat extends Plugin {
-	/**
-	 * Function initializes the Plugin and registers all hooks.
-	 */
-	public function init() {
-		$this->registerHook('server.core.settings.init.before');
-	}
+    /**
+     * Function initializes the Plugin and registers all hooks.
+     */
+    public function init() {
+        $this->registerHook('server.core.settings.init.before');
+    }
 
-	/**
-	 * Function is executed when a hook is triggered by the PluginManager.
-	 *
-	 * @param string $eventID the id of the triggered hook
-	 * @param mixed  $data    object(s) related to the hook
-	 */
-	public function execute($eventID, &$data) {
-		switch ($eventID) {
-			case 'server.core.settings.init.before':
-				$this->injectPluginSettings($data);
-				break;
-		}
-	}
+    /**
+     * Function is executed when a hook is triggered by the PluginManager.
+     *
+     * @param string $eventID the id of the triggered hook
+     * @param mixed  $data    object(s) related to the hook
+     */
+    public function execute($eventID, &$data) {
+        switch ($eventID) {
+            case 'server.core.settings.init.before':
+                $this->injectPluginSettings($data);
+                break;
+        }
+    }
 
-	/**
-	 * Called when the core Settings class is initialized and ready to accept sysadmin default
-	 * settings. Registers the sysadmin defaults for the desktopnotifications plugin.
-	 *
-	 * @param array $data Reference to the data of the triggered hook
-	 */
-	public function injectPluginSettings(&$data) {
-		$pluginData = [
-			'enable' => PLUGIN_CHAT_USER_DEFAULT_ENABLE,
-			'url' => PLUGIN_CHAT_URL,
-			'autostart' => PLUGIN_CHAT_AUTOSTART,
-		];
+    /**
+     * Called when the core Settings class is initialized and ready to accept sysadmin default
+     * settings. Registers the sysadmin defaults for the desktopnotifications plugin.
+     *
+     * @param array $data Reference to the data of the triggered hook
+     */
+    public function injectPluginSettings(&$data) {
+        $pluginData = [
+            'enable' => PLUGIN_CHAT_USER_DEFAULT_ENABLE,
+            'url' => PLUGIN_CHAT_URL,
+            'autostart' => PLUGIN_CHAT_AUTOSTART,
+        ];
 
-		$data['settingsObj']->addSysAdminDefaults([
-			'zarafa' => [
-				'v1' => [
-					'plugins' => [
-						'chat' => $pluginData,
-					],
-				],
-			],
-		]);
-	}
+        $data['settingsObj']->addSysAdminDefaults([
+            'zarafa' => [
+                'v1' => [
+                    'plugins' => [
+                        'chat' => $pluginData,
+                    ],
+                ],
+            ],
+        ]);
+    }
 }

plugins/filesbackendOwncloud/php/class.backend.php

Indentation +577 added lines, -577 removed lines

@@ -29,586 +29,586 @@
  * @extends AbstractBackend
  */
 class Backend extends \Files\Backend\Webdav\Backend implements iFeatureSharing {
-	/**
-	 * @var ocsclient the OCS Api client
-	 */
-	public $ocs_client;
-
-	/**
-	 * @constructor
-	 */
-	public function __construct() {
-		// initialization
-		$this->debug = PLUGIN_FILESBROWSER_LOGLEVEL === "DEBUG" ? true : false;
-
-		$this->init_form();
-
-		// set backend description
-		$this->backendDescription = _("With this backend, you can connect to any ownCloud server.");
-
-		// set backend display name
-		$this->backendDisplayName = "ownCloud";
-
-		// set backend version
-		// TODO: this should be changed on every release
-		$this->backendVersion = "3.0";
-
-		// Backend name used in translations
-		$this->backendTransName = _('Files ownCloud Backend: ');
-	}
-
-	/**
-	 * Initialise form fields.
-	 */
-	private function init_form() {
-		$this->formConfig = [
-			"labelAlign" => "left",
-			"columnCount" => 1,
-			"labelWidth" => 80,
-			"defaults" => [
-				"width" => 292,
-			],
-		];
-
-		$this->formFields = [
-			[
-				"name" => "server_address",
-				"fieldLabel" => _('Server address'),
-				"editor" => [
-					"allowBlank" => false,
-				],
-			],
-			[
-				"name" => "server_port",
-				"fieldLabel" => _('Server port'),
-				"editor" => [
-					"ref" => "../../portField",
-					"allowBlank" => false,
-				],
-			],
-			[
-				"name" => "server_ssl",
-				"fieldLabel" => _('Use SSL'),
-				"editor" => [
-					"xtype" => "checkbox",
-					"listeners" => [
-						"check" => "Zarafa.plugins.files.data.Actions.onCheckSSL", // this javascript function will be called!
-					],
-				],
-			],
-			[
-				"name" => "server_path",
-				"fieldLabel" => _('Webdav base path'),
-				"editor" => [
-					"allowBlank" => false,
-				],
-			],
-			[
-				"name" => "user",
-				"fieldLabel" => _('Username'),
-				"editor" => [
-					"ref" => "../../usernameField",
-				],
-			],
-			[
-				"name" => "password",
-				"fieldLabel" => _('Password'),
-				"editor" => [
-					"ref" => "../../passwordField",
-					"inputType" => "password",
-				],
-			],
-			[
-				"name" => "use_grommunio_credentials",
-				"fieldLabel" => _('Use grommunio credentials'),
-				"editor" => [
-					"xtype" => "checkbox",
-					"listeners" => [
-						"check" => "Zarafa.plugins.files.data.Actions.onCheckCredentials", // this javascript function will be called!
-					],
-				],
-			],
-		];
-
-		$this->metaConfig = [
-			"success" => true,
-			"metaData" => [
-				"fields" => $this->formFields,
-				"formConfig" => $this->formConfig,
-			],
-			"data" => [ // here we can specify the default values.
-				"server_address" => $_SERVER['HTTP_HOST'],
-				"server_ssl" => true,
-				"server_port" => "443",
-				"server_path" => "/files/remote.php/webdav",
-				"use_grommunio_credentials" => true,
-			],
-		];
-	}
-
-	/**
-	 * Opens the connection to the webdav server.
-	 *
-	 * @throws BackendException if connection is not successful
-	 *
-	 * @return bool true if action succeeded
-	 */
-	public function open() {
-		// check if curl is available
-		$serverHasCurl = function_exists('curl_version');
-		if (!$serverHasCurl) {
-			$e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_NO_CURL), 500);
-			$e->setTitle($this->backendTransName . _('php-curl is not available'));
-
-			throw $e;
-		}
-
-		$davsettings = [
-			'baseUri' => $this->webdavUrl(),
-			'userName' => $this->user,
-			'password' => $this->pass,
-			'authType' => \Sabre\DAV\Client::AUTH_BASIC,
-		];
-
-		try {
-			$this->sabre_client = new FilesWebDavClient($davsettings);
-			$this->sabre_client->addCurlSetting(CURLOPT_SSL_VERIFYPEER, !$this->allowselfsigned);
-
-			$this->ocs_client = new ocsclient($this->getOwncloudBaseURL(), $this->user, $this->pass, $this->allowselfsigned);
-
-			return true;
-		}
-		catch (\Exception $e) {
-			$this->log('Failed to open: ' . $e->getMessage());
-			if (intval($e->getHTTPCode()) == 401) {
-				$e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_UNAUTHORIZED), $e->getHTTPCode());
-				$e->setTitle($this->backendTransName . _('Access denied'));
-
-				throw $e;
-			}
-			$e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_UNREACHABLE), $e->getHTTPCode());
-			$e->setTitle($this->backendTransName . _('Connection failed'));
-
-			throw $e;
-		}
-	}
-
-	/**
-	 * /**
-	 * Copy a collection on webdav server
-	 * Duplicates a collection on the webdav server (serverside).
-	 * All work is done on the webdav server. If you set param overwrite as true,
-	 * the target will be overwritten.
-	 *
-	 * @param string $src_path  Source path
-	 * @param string $dst_path  Destination path
-	 * @param bool   $overwrite Overwrite if collection exists in $dst_path
-	 * @param bool   $coll      set this to true if you want to copy a folder
-	 *
-	 * @throws BackendException if request is not successful
-	 *
-	 * @return bool true if action succeeded
-	 */
-	private function copy($src_path, $dst_path, $overwrite, $coll) {
-		$time_start = microtime(true);
-		$src_path = $this->removeSlash($src_path);
-		$dst_path = $this->webdavUrl() . $this->removeSlash($dst_path);
-		$this->log("[COPY] start for dir: {$src_path} -> {$dst_path}");
-		if ($overwrite) {
-			$overwrite = 'T';
-		}
-		else {
-			$overwrite = 'F';
-		}
-
-		$settings = ["Destination" => $dst_path, 'Overwrite' => $overwrite];
-		if ($coll) {
-			$settings = ["Destination" => $dst_path, 'Depth' => 'Infinity'];
-		}
-
-		try {
-			$response = $this->sabre_client->request("COPY", $src_path, null, $settings);
-			$time_end = microtime(true);
-			$time = $time_end - $time_start;
-			$this->log("[COPY] done in {$time} seconds: " . $response['statusCode']);
-
-			return true;
-		}
-		catch (ClientException $e) {
-			$e = new BackendException($this->parseErrorCodeToMessage($e->getCode()), $e->getCode());
-			$e->setTitle($this->backendTransName . _('Sabre error'));
-
-			throw $e;
-		}
-		catch (Exception $e) {
-			$this->log('[COPY] fatal: ' . $e->getMessage());
-			$e = new BackendException($this->parseErrorCodeToMessage($e->getHTTPCode()), $e->getHTTPCode());
-			$e->setTitle($this->backendTransName . _('Copying failed'));
-
-			throw $e;
-		}
-	}
-
-	/**
-	 * This function will return a user friendly error string.
-	 *
-	 * @param number $error_code A error code
-	 *
-	 * @return string userfriendly error message
-	 */
-	private function parseErrorCodeToMessage($error_code) {
-		$error = intval($error_code);
-
-		$msg = _('Unknown error');
-		$contactAdmin = _('Please contact your system administrator.');
-
-		switch ($error) {
-			case CURLE_BAD_PASSWORD_ENTERED:
-			case self::WD_ERR_UNAUTHORIZED:
-				$msg = _('Unauthorized. Wrong username or password.');
-				break;
-
-			case CURLE_SSL_CONNECT_ERROR:
-			case CURLE_COULDNT_RESOLVE_HOST:
-			case CURLE_COULDNT_CONNECT:
-			case CURLE_OPERATION_TIMEOUTED:
-			case self::WD_ERR_UNREACHABLE:
-				$msg = _('File server is not reachable. Please verify the file server URL.');
-				break;
-
-			case self::WD_ERR_FORBIDDEN:
-				$msg = _('You don\'t have enough permissions to view this file or folder.');
-				break;
-
-			case self::WD_ERR_NOTFOUND:
-				$msg = _('The file or folder is not available anymore.');
-				break;
-
-			case self::WD_ERR_TIMEOUT:
-				$msg = _('Connection to the file server timed out. Please check again later.');
-				break;
-
-			case self::WD_ERR_LOCKED:
-				$msg = _('This file is locked by another user. Please try again later.');
-				break;
-
-			case self::WD_ERR_FAILED_DEPENDENCY:
-				$msg = _('The request failed.') . ' ' . $contactAdmin;
-				break;
-
-			case self::WD_ERR_INTERNAL:
-				// This is a general error, might be thrown due to a wrong IP, but we don't know.
-				$msg = _('The file server encountered an internal problem.') . ' ' . $contactAdmin;
-				break;
-
-			case self::WD_ERR_TMP:
-				$msg = _('We could not write to temporary directory.') . ' ' . $contactAdmin;
-				break;
-
-			case self::WD_ERR_FEATURES:
-				$msg = _('We could not retrieve list of server features.') . ' ' . $contactAdmin;
-				break;
-
-			case self::WD_ERR_NO_CURL:
-				$msg = _('PHP-Curl is not available.') . ' ' . $contactAdmin;
-				break;
-		}
-
-		return $msg;
-	}
-
-	/**
-	 * a simple php error_log wrapper.
-	 *
-	 * @param string $err_string error message
-	 */
-	private function log($err_string) {
-		if ($this->debug) {
-			error_log("[BACKEND_OWNCLOUD]: " . $err_string);
-		}
-	}
-
-	/**
-	 * Get the base URL of Owncloud.
-	 * For example: http://demo.owncloud.com/owncloud.
-	 *
-	 * @return string
-	 */
-	private function getOwncloudBaseURL() {
-		$webdavurl = $this->webdavUrl();
-
-		return substr($webdavurl, 0, strlen($webdavurl) - strlen("/remote.php/webdav/"));
-	}
-
-	/**
-	 * ============================ FEATURE FUNCTIONS ========================.
-	 */
-
-	/**
-	 * Return the version string of the server backend.
-	 *
-	 * @return string
-	 */
-	public function getServerVersion() {
-		// check if curl is available
-		$serverHasCurl = function_exists('curl_version');
-		if (!$serverHasCurl) {
-			throw new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_NO_CURL), 500);
-		}
-
-		$url = $this->getOwncloudBaseURL() . "/status.php";
-
-		// try to get the contents of the owncloud status page
-		$ch = curl_init();
-		curl_setopt($ch, CURLOPT_AUTOREFERER, true);
-		curl_setopt($ch, CURLOPT_TIMEOUT, 3); // timeout of 3 seconds
-		curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
-		curl_setopt($ch, CURLOPT_URL, $url);
-		curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
-		if ($this->allowselfsigned) {
-			curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
-			curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
-		}
-		$versiondata = curl_exec($ch);
-		$httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
-		curl_close($ch);
-
-		if ($httpcode && $httpcode == "200" && $versiondata) {
-			$versions = json_decode($versiondata);
-			$version = $versions->versionstring;
-		}
-		else {
-			$version = "Undetected (no ownCloud?)";
-		}
-
-		return $version;
-	}
-
-	/**
-	 * Get all shares in the specified folder.
-	 *
-	 * The response array will look like:
-	 *
-	 * array(
-	 *  path1 => array(
-	 *      id1 => details1,
-	 *      id2 => details2
-	 *  ),
-	 *  path2 => array(
-	 *      id1 => ....
-	 *  )
-	 * )
-	 *
-	 * @param $path
-	 *
-	 * @return array
-	 */
-	public function getShares($path) {
-		$result = [];
-
-		$this->log('[GETSHARES]: loading shares for folder: ' . $path);
-
-		try {
-			$this->ocs_client->loadShares($path);
-		}
-		catch (ConnectionException $e) {
-			$this->log('[GETSHARES]: connection exception while loading shares: ' . $e->getMessage() . " " . $e->getCode());
-		}
-		$shares = $this->ocs_client->getAllShares();
-
-		$this->log('[GETSHARES]: found ' . count($shares) . ' shares for folder: ' . $path);
-
-		$result[$path] = [];
-		if ($shares !== false) {
-			foreach ($shares as $id => $options) {
-				$result[$path][$id] = [
-					"shared" => true,
-					"id" => $options->getId(),
-					"path" => $options->getPath(),
-					"shareType" => $options->getShareType(),
-					"permissions" => $options->getPermissions(),
-					"expiration" => $options->getExpiration(),
-					"token" => $options->getToken(),
-					"url" => $options->getUrl(),
-					"shareWith" => $options->getShareWith(),
-					"shareWithDisplayname" => $options->getShareWithDisplayname(),
-				];
-			}
-		}
-
-		return $result;
-	}
-
-	/**
-	 * Get details about the shared files/folders.
-	 *
-	 * The response array will look like:
-	 *
-	 * array(
-	 *  path1 => array(
-	 *      id1 => details1,
-	 *      id2 => details2
-	 *  ),
-	 *  path2 => array(
-	 *      id1 => ....
-	 *  )
-	 * )
-	 *
-	 * @param $patharray Simple array with path's to files or folders
-	 *
-	 * @return array
-	 */
-	public function sharingDetails($patharray) {
-		$result = [];
-
-		// performance optimization
-		// fetch all shares - so we only need one request
-		if (count($patharray) > 1) {
-			try {
-				$this->ocs_client->loadShares();
-			}
-			catch (ConnectionException $e) {
-				$this->log('[SHARINGDETAILS]: connection exception while loading shares: ' . $e->getMessage() . " " . $e->getCode());
-			}
-
-			/** @var ocsshare[] $shares */
-			$shares = $this->ocs_client->getAllShares();
-			foreach ($patharray as $path) {
-				$result[$path] = [];
-				foreach ($shares as $id => $details) {
-					if ($details->getPath() == $path) {
-						$result[$path][$id] = [
-							"shared" => true,
-							"id" => $details->getId(),
-							"shareType" => $details->getShareType(),
-							"permissions" => $details->getPermissions(),
-							"expiration" => $details->getExpiration(),
-							"token" => $details->getToken(),
-							"url" => $details->getUrl(),
-							"shareWith" => $details->getShareWith(),
-							"shareWithDisplayname" => $details->getShareWithDisplayname(),
-						];
-					}
-				}
-			}
-		}
-		else {
-			if (count($patharray) == 1) {
-				try {
-					$shares = $this->ocs_client->loadShareByPath($patharray[0]);
-				}
-				catch (FileNotFoundException $e) {
-					$shares = false;
-				}
-
-				$result[$patharray[0]] = [];
-
-				if ($shares !== false) {
-					foreach ($shares as $id => $share) {
-						$result[$patharray[0]][$id] = [
-							"shared" => true,
-							"id" => $share->getId(),
-							"shareType" => $share->getShareType(),
-							"permissions" => $share->getPermissions(),
-							"expiration" => $share->getExpiration(),
-							"token" => $share->getToken(),
-							"url" => $share->getUrl(),
-							"shareWith" => $share->getShareWith(),
-							"shareWithDisplayname" => $share->getShareWithDisplayName(),
-						];
-					}
-				}
-			}
-			else {
-				return false; // $patharray was empty...
-			}
-		}
-
-		return $result;
-	}
-
-	/**
-	 * Share one or multiple files.
-	 * As the sharing dialog might differ for different backends, it is implemented as
-	 * MetaForm - meaning that the argumentnames/count might differ.
-	 * That's the cause why this function uses an array as parameter.
-	 *
-	 * $shareparams should look somehow like this:
-	 *
-	 * array(
-	 *      "path1" => options1,
-	 *      "path2" => options2
-	 *
-	 *      or
-	 *
-	 *      "id1" => options1 (ONLY if $update = true)
-	 * )
-	 *
-	 * @param $shareparams
-	 * @param bool $update
-	 *
-	 * @return bool
-	 */
-	public function share($shareparams, $update = false) {
-		$result = [];
-		if (count($shareparams) > 0) {
-			/** @var string $path */
-			foreach ($shareparams as $path => $options) {
-				$path = rtrim($path, "/");
-				$this->log('path: ' . $path);
-				if (!$update) {
-					$share = $this->ocs_client->createShare($path, $options);
-					$result[$path] = [
-						"shared" => true,
-						"id" => $share->getId(),
-						"token" => $share->getToken(),
-						"url" => $share->getUrl(),
-					];
-				}
-				else {
-					foreach ($options as $key => $value) {
-						$this->ocs_client->updateShare($path, $key, $value);
-					}
-					$result[$path] = [
-						"shared" => true,
-						"id" => $path,
-					];
-				}
-			}
-		}
-		else {
-			$this->log('No share params given');
-
-			return false; // no shareparams...
-		}
-
-		return $result;
-	}
-
-	/**
-	 * Disable sharing for the given files/folders.
-	 *
-	 * @param $idarray
-	 *
-	 * @throws \OCSAPI\Exception\ConnectionException
-	 *
-	 * @return bool
-	 */
-	public function unshare($idarray) {
-		foreach ($idarray as $id) {
-			$this->ocs_client->deleteShare($id);
-		}
-
-		return true;
-	}
-
-	/*
+    /**
+     * @var ocsclient the OCS Api client
+     */
+    public $ocs_client;
+
+    /**
+     * @constructor
+     */
+    public function __construct() {
+        // initialization
+        $this->debug = PLUGIN_FILESBROWSER_LOGLEVEL === "DEBUG" ? true : false;
+
+        $this->init_form();
+
+        // set backend description
+        $this->backendDescription = _("With this backend, you can connect to any ownCloud server.");
+
+        // set backend display name
+        $this->backendDisplayName = "ownCloud";
+
+        // set backend version
+        // TODO: this should be changed on every release
+        $this->backendVersion = "3.0";
+
+        // Backend name used in translations
+        $this->backendTransName = _('Files ownCloud Backend: ');
+    }
+
+    /**
+     * Initialise form fields.
+     */
+    private function init_form() {
+        $this->formConfig = [
+            "labelAlign" => "left",
+            "columnCount" => 1,
+            "labelWidth" => 80,
+            "defaults" => [
+                "width" => 292,
+            ],
+        ];
+
+        $this->formFields = [
+            [
+                "name" => "server_address",
+                "fieldLabel" => _('Server address'),
+                "editor" => [
+                    "allowBlank" => false,
+                ],
+            ],
+            [
+                "name" => "server_port",
+                "fieldLabel" => _('Server port'),
+                "editor" => [
+                    "ref" => "../../portField",
+                    "allowBlank" => false,
+                ],
+            ],
+            [
+                "name" => "server_ssl",
+                "fieldLabel" => _('Use SSL'),
+                "editor" => [
+                    "xtype" => "checkbox",
+                    "listeners" => [
+                        "check" => "Zarafa.plugins.files.data.Actions.onCheckSSL", // this javascript function will be called!
+                    ],
+                ],
+            ],
+            [
+                "name" => "server_path",
+                "fieldLabel" => _('Webdav base path'),
+                "editor" => [
+                    "allowBlank" => false,
+                ],
+            ],
+            [
+                "name" => "user",
+                "fieldLabel" => _('Username'),
+                "editor" => [
+                    "ref" => "../../usernameField",
+                ],
+            ],
+            [
+                "name" => "password",
+                "fieldLabel" => _('Password'),
+                "editor" => [
+                    "ref" => "../../passwordField",
+                    "inputType" => "password",
+                ],
+            ],
+            [
+                "name" => "use_grommunio_credentials",
+                "fieldLabel" => _('Use grommunio credentials'),
+                "editor" => [
+                    "xtype" => "checkbox",
+                    "listeners" => [
+                        "check" => "Zarafa.plugins.files.data.Actions.onCheckCredentials", // this javascript function will be called!
+                    ],
+                ],
+            ],
+        ];
+
+        $this->metaConfig = [
+            "success" => true,
+            "metaData" => [
+                "fields" => $this->formFields,
+                "formConfig" => $this->formConfig,
+            ],
+            "data" => [ // here we can specify the default values.
+                "server_address" => $_SERVER['HTTP_HOST'],
+                "server_ssl" => true,
+                "server_port" => "443",
+                "server_path" => "/files/remote.php/webdav",
+                "use_grommunio_credentials" => true,
+            ],
+        ];
+    }
+
+    /**
+     * Opens the connection to the webdav server.
+     *
+     * @throws BackendException if connection is not successful
+     *
+     * @return bool true if action succeeded
+     */
+    public function open() {
+        // check if curl is available
+        $serverHasCurl = function_exists('curl_version');
+        if (!$serverHasCurl) {
+            $e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_NO_CURL), 500);
+            $e->setTitle($this->backendTransName . _('php-curl is not available'));
+
+            throw $e;
+        }
+
+        $davsettings = [
+            'baseUri' => $this->webdavUrl(),
+            'userName' => $this->user,
+            'password' => $this->pass,
+            'authType' => \Sabre\DAV\Client::AUTH_BASIC,
+        ];
+
+        try {
+            $this->sabre_client = new FilesWebDavClient($davsettings);
+            $this->sabre_client->addCurlSetting(CURLOPT_SSL_VERIFYPEER, !$this->allowselfsigned);
+
+            $this->ocs_client = new ocsclient($this->getOwncloudBaseURL(), $this->user, $this->pass, $this->allowselfsigned);
+
+            return true;
+        }
+        catch (\Exception $e) {
+            $this->log('Failed to open: ' . $e->getMessage());
+            if (intval($e->getHTTPCode()) == 401) {
+                $e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_UNAUTHORIZED), $e->getHTTPCode());
+                $e->setTitle($this->backendTransName . _('Access denied'));
+
+                throw $e;
+            }
+            $e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_UNREACHABLE), $e->getHTTPCode());
+            $e->setTitle($this->backendTransName . _('Connection failed'));
+
+            throw $e;
+        }
+    }
+
+    /**
+     * /**
+     * Copy a collection on webdav server
+     * Duplicates a collection on the webdav server (serverside).
+     * All work is done on the webdav server. If you set param overwrite as true,
+     * the target will be overwritten.
+     *
+     * @param string $src_path  Source path
+     * @param string $dst_path  Destination path
+     * @param bool   $overwrite Overwrite if collection exists in $dst_path
+     * @param bool   $coll      set this to true if you want to copy a folder
+     *
+     * @throws BackendException if request is not successful
+     *
+     * @return bool true if action succeeded
+     */
+    private function copy($src_path, $dst_path, $overwrite, $coll) {
+        $time_start = microtime(true);
+        $src_path = $this->removeSlash($src_path);
+        $dst_path = $this->webdavUrl() . $this->removeSlash($dst_path);
+        $this->log("[COPY] start for dir: {$src_path} -> {$dst_path}");
+        if ($overwrite) {
+            $overwrite = 'T';
+        }
+        else {
+            $overwrite = 'F';
+        }
+
+        $settings = ["Destination" => $dst_path, 'Overwrite' => $overwrite];
+        if ($coll) {
+            $settings = ["Destination" => $dst_path, 'Depth' => 'Infinity'];
+        }
+
+        try {
+            $response = $this->sabre_client->request("COPY", $src_path, null, $settings);
+            $time_end = microtime(true);
+            $time = $time_end - $time_start;
+            $this->log("[COPY] done in {$time} seconds: " . $response['statusCode']);
+
+            return true;
+        }
+        catch (ClientException $e) {
+            $e = new BackendException($this->parseErrorCodeToMessage($e->getCode()), $e->getCode());
+            $e->setTitle($this->backendTransName . _('Sabre error'));
+
+            throw $e;
+        }
+        catch (Exception $e) {
+            $this->log('[COPY] fatal: ' . $e->getMessage());
+            $e = new BackendException($this->parseErrorCodeToMessage($e->getHTTPCode()), $e->getHTTPCode());
+            $e->setTitle($this->backendTransName . _('Copying failed'));
+
+            throw $e;
+        }
+    }
+
+    /**
+     * This function will return a user friendly error string.
+     *
+     * @param number $error_code A error code
+     *
+     * @return string userfriendly error message
+     */
+    private function parseErrorCodeToMessage($error_code) {
+        $error = intval($error_code);
+
+        $msg = _('Unknown error');
+        $contactAdmin = _('Please contact your system administrator.');
+
+        switch ($error) {
+            case CURLE_BAD_PASSWORD_ENTERED:
+            case self::WD_ERR_UNAUTHORIZED:
+                $msg = _('Unauthorized. Wrong username or password.');
+                break;
+
+            case CURLE_SSL_CONNECT_ERROR:
+            case CURLE_COULDNT_RESOLVE_HOST:
+            case CURLE_COULDNT_CONNECT:
+            case CURLE_OPERATION_TIMEOUTED:
+            case self::WD_ERR_UNREACHABLE:
+                $msg = _('File server is not reachable. Please verify the file server URL.');
+                break;
+
+            case self::WD_ERR_FORBIDDEN:
+                $msg = _('You don\'t have enough permissions to view this file or folder.');
+                break;
+
+            case self::WD_ERR_NOTFOUND:
+                $msg = _('The file or folder is not available anymore.');
+                break;
+
+            case self::WD_ERR_TIMEOUT:
+                $msg = _('Connection to the file server timed out. Please check again later.');
+                break;
+
+            case self::WD_ERR_LOCKED:
+                $msg = _('This file is locked by another user. Please try again later.');
+                break;
+
+            case self::WD_ERR_FAILED_DEPENDENCY:
+                $msg = _('The request failed.') . ' ' . $contactAdmin;
+                break;
+
+            case self::WD_ERR_INTERNAL:
+                // This is a general error, might be thrown due to a wrong IP, but we don't know.
+                $msg = _('The file server encountered an internal problem.') . ' ' . $contactAdmin;
+                break;
+
+            case self::WD_ERR_TMP:
+                $msg = _('We could not write to temporary directory.') . ' ' . $contactAdmin;
+                break;
+
+            case self::WD_ERR_FEATURES:
+                $msg = _('We could not retrieve list of server features.') . ' ' . $contactAdmin;
+                break;
+
+            case self::WD_ERR_NO_CURL:
+                $msg = _('PHP-Curl is not available.') . ' ' . $contactAdmin;
+                break;
+        }
+
+        return $msg;
+    }
+
+    /**
+     * a simple php error_log wrapper.
+     *
+     * @param string $err_string error message
+     */
+    private function log($err_string) {
+        if ($this->debug) {
+            error_log("[BACKEND_OWNCLOUD]: " . $err_string);
+        }
+    }
+
+    /**
+     * Get the base URL of Owncloud.
+     * For example: http://demo.owncloud.com/owncloud.
+     *
+     * @return string
+     */
+    private function getOwncloudBaseURL() {
+        $webdavurl = $this->webdavUrl();
+
+        return substr($webdavurl, 0, strlen($webdavurl) - strlen("/remote.php/webdav/"));
+    }
+
+    /**
+     * ============================ FEATURE FUNCTIONS ========================.
+     */
+
+    /**
+     * Return the version string of the server backend.
+     *
+     * @return string
+     */
+    public function getServerVersion() {
+        // check if curl is available
+        $serverHasCurl = function_exists('curl_version');
+        if (!$serverHasCurl) {
+            throw new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_NO_CURL), 500);
+        }
+
+        $url = $this->getOwncloudBaseURL() . "/status.php";
+
+        // try to get the contents of the owncloud status page
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_AUTOREFERER, true);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 3); // timeout of 3 seconds
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
+        if ($this->allowselfsigned) {
+            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
+            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
+        }
+        $versiondata = curl_exec($ch);
+        $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        curl_close($ch);
+
+        if ($httpcode && $httpcode == "200" && $versiondata) {
+            $versions = json_decode($versiondata);
+            $version = $versions->versionstring;
+        }
+        else {
+            $version = "Undetected (no ownCloud?)";
+        }
+
+        return $version;
+    }
+
+    /**
+     * Get all shares in the specified folder.
+     *
+     * The response array will look like:
+     *
+     * array(
+     *  path1 => array(
+     *      id1 => details1,
+     *      id2 => details2
+     *  ),
+     *  path2 => array(
+     *      id1 => ....
+     *  )
+     * )
+     *
+     * @param $path
+     *
+     * @return array
+     */
+    public function getShares($path) {
+        $result = [];
+
+        $this->log('[GETSHARES]: loading shares for folder: ' . $path);
+
+        try {
+            $this->ocs_client->loadShares($path);
+        }
+        catch (ConnectionException $e) {
+            $this->log('[GETSHARES]: connection exception while loading shares: ' . $e->getMessage() . " " . $e->getCode());
+        }
+        $shares = $this->ocs_client->getAllShares();
+
+        $this->log('[GETSHARES]: found ' . count($shares) . ' shares for folder: ' . $path);
+
+        $result[$path] = [];
+        if ($shares !== false) {
+            foreach ($shares as $id => $options) {
+                $result[$path][$id] = [
+                    "shared" => true,
+                    "id" => $options->getId(),
+                    "path" => $options->getPath(),
+                    "shareType" => $options->getShareType(),
+                    "permissions" => $options->getPermissions(),
+                    "expiration" => $options->getExpiration(),
+                    "token" => $options->getToken(),
+                    "url" => $options->getUrl(),
+                    "shareWith" => $options->getShareWith(),
+                    "shareWithDisplayname" => $options->getShareWithDisplayname(),
+                ];
+            }
+        }
+
+        return $result;
+    }
+
+    /**
+     * Get details about the shared files/folders.
+     *
+     * The response array will look like:
+     *
+     * array(
+     *  path1 => array(
+     *      id1 => details1,
+     *      id2 => details2
+     *  ),
+     *  path2 => array(
+     *      id1 => ....
+     *  )
+     * )
+     *
+     * @param $patharray Simple array with path's to files or folders
+     *
+     * @return array
+     */
+    public function sharingDetails($patharray) {
+        $result = [];
+
+        // performance optimization
+        // fetch all shares - so we only need one request
+        if (count($patharray) > 1) {
+            try {
+                $this->ocs_client->loadShares();
+            }
+            catch (ConnectionException $e) {
+                $this->log('[SHARINGDETAILS]: connection exception while loading shares: ' . $e->getMessage() . " " . $e->getCode());
+            }
+
+            /** @var ocsshare[] $shares */
+            $shares = $this->ocs_client->getAllShares();
+            foreach ($patharray as $path) {
+                $result[$path] = [];
+                foreach ($shares as $id => $details) {
+                    if ($details->getPath() == $path) {
+                        $result[$path][$id] = [
+                            "shared" => true,
+                            "id" => $details->getId(),
+                            "shareType" => $details->getShareType(),
+                            "permissions" => $details->getPermissions(),
+                            "expiration" => $details->getExpiration(),
+                            "token" => $details->getToken(),
+                            "url" => $details->getUrl(),
+                            "shareWith" => $details->getShareWith(),
+                            "shareWithDisplayname" => $details->getShareWithDisplayname(),
+                        ];
+                    }
+                }
+            }
+        }
+        else {
+            if (count($patharray) == 1) {
+                try {
+                    $shares = $this->ocs_client->loadShareByPath($patharray[0]);
+                }
+                catch (FileNotFoundException $e) {
+                    $shares = false;
+                }
+
+                $result[$patharray[0]] = [];
+
+                if ($shares !== false) {
+                    foreach ($shares as $id => $share) {
+                        $result[$patharray[0]][$id] = [
+                            "shared" => true,
+                            "id" => $share->getId(),
+                            "shareType" => $share->getShareType(),
+                            "permissions" => $share->getPermissions(),
+                            "expiration" => $share->getExpiration(),
+                            "token" => $share->getToken(),
+                            "url" => $share->getUrl(),
+                            "shareWith" => $share->getShareWith(),
+                            "shareWithDisplayname" => $share->getShareWithDisplayName(),
+                        ];
+                    }
+                }
+            }
+            else {
+                return false; // $patharray was empty...
+            }
+        }
+
+        return $result;
+    }
+
+    /**
+     * Share one or multiple files.
+     * As the sharing dialog might differ for different backends, it is implemented as
+     * MetaForm - meaning that the argumentnames/count might differ.
+     * That's the cause why this function uses an array as parameter.
+     *
+     * $shareparams should look somehow like this:
+     *
+     * array(
+     *      "path1" => options1,
+     *      "path2" => options2
+     *
+     *      or
+     *
+     *      "id1" => options1 (ONLY if $update = true)
+     * )
+     *
+     * @param $shareparams
+     * @param bool $update
+     *
+     * @return bool
+     */
+    public function share($shareparams, $update = false) {
+        $result = [];
+        if (count($shareparams) > 0) {
+            /** @var string $path */
+            foreach ($shareparams as $path => $options) {
+                $path = rtrim($path, "/");
+                $this->log('path: ' . $path);
+                if (!$update) {
+                    $share = $this->ocs_client->createShare($path, $options);
+                    $result[$path] = [
+                        "shared" => true,
+                        "id" => $share->getId(),
+                        "token" => $share->getToken(),
+                        "url" => $share->getUrl(),
+                    ];
+                }
+                else {
+                    foreach ($options as $key => $value) {
+                        $this->ocs_client->updateShare($path, $key, $value);
+                    }
+                    $result[$path] = [
+                        "shared" => true,
+                        "id" => $path,
+                    ];
+                }
+            }
+        }
+        else {
+            $this->log('No share params given');
+
+            return false; // no shareparams...
+        }
+
+        return $result;
+    }
+
+    /**
+     * Disable sharing for the given files/folders.
+     *
+     * @param $idarray
+     *
+     * @throws \OCSAPI\Exception\ConnectionException
+     *
+     * @return bool
+     */
+    public function unshare($idarray) {
+        foreach ($idarray as $id) {
+            $this->ocs_client->deleteShare($id);
+        }
+
+        return true;
+    }
+
+    /*
 	 * Get Recipients that could be shared with, matching the search string
 	 *
 	 * @param $search Searchstring to use
 	 * @return The response from the osc client API
 	 */
-	public function getRecipients($search) {
-		return $this->ocs_client->getRecipients($search);
-	}
+    public function getRecipients($search) {
+        return $this->ocs_client->getRecipients($search);
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -136,7 +136,7 @@
 				"fields" => $this->formFields,
 				"formConfig" => $this->formConfig,
 			],
-			"data" => [ // here we can specify the default values.
+			"data" => [// here we can specify the default values.
 				"server_address" => $_SERVER['HTTP_HOST'],
 				"server_ssl" => true,
 				"server_port" => "443",

Braces +12 added lines, -24 removed lines

@@ -177,8 +177,7 @@ 
 			$this->ocs_client = new ocsclient($this->getOwncloudBaseURL(), $this->user, $this->pass, $this->allowselfsigned);
 
 			return true;
-		}
-		catch (\Exception $e) {
+		} catch (\Exception $e) {
 			$this->log('Failed to open: ' . $e->getMessage());
 			if (intval($e->getHTTPCode()) == 401) {
 				$e = new BackendException($this->parseErrorCodeToMessage(self::WD_ERR_UNAUTHORIZED), $e->getHTTPCode());
@@ -216,8 +215,7 @@ 
 		$this->log("[COPY] start for dir: {$src_path} -> {$dst_path}");
 		if ($overwrite) {
 			$overwrite = 'T';
-		}
-		else {
+		} else {
 			$overwrite = 'F';
 		}
 
@@ -233,14 +231,12 @@ 
 			$this->log("[COPY] done in {$time} seconds: " . $response['statusCode']);
 
 			return true;
-		}
-		catch (ClientException $e) {
+		} catch (ClientException $e) {
 			$e = new BackendException($this->parseErrorCodeToMessage($e->getCode()), $e->getCode());
 			$e->setTitle($this->backendTransName . _('Sabre error'));
 
 			throw $e;
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			$this->log('[COPY] fatal: ' . $e->getMessage());
 			$e = new BackendException($this->parseErrorCodeToMessage($e->getHTTPCode()), $e->getHTTPCode());
 			$e->setTitle($this->backendTransName . _('Copying failed'));
@@ -376,8 +372,7 @@ 
 		if ($httpcode && $httpcode == "200" && $versiondata) {
 			$versions = json_decode($versiondata);
 			$version = $versions->versionstring;
-		}
-		else {
+		} else {
 			$version = "Undetected (no ownCloud?)";
 		}
 
@@ -410,8 +405,7 @@ 
 
 		try {
 			$this->ocs_client->loadShares($path);
-		}
-		catch (ConnectionException $e) {
+		} catch (ConnectionException $e) {
 			$this->log('[GETSHARES]: connection exception while loading shares: ' . $e->getMessage() . " " . $e->getCode());
 		}
 		$shares = $this->ocs_client->getAllShares();
@@ -466,8 +460,7 @@ 
 		if (count($patharray) > 1) {
 			try {
 				$this->ocs_client->loadShares();
-			}
-			catch (ConnectionException $e) {
+			} catch (ConnectionException $e) {
 				$this->log('[SHARINGDETAILS]: connection exception while loading shares: ' . $e->getMessage() . " " . $e->getCode());
 			}
 
@@ -491,13 +484,11 @@ 
 					}
 				}
 			}
-		}
-		else {
+		} else {
 			if (count($patharray) == 1) {
 				try {
 					$shares = $this->ocs_client->loadShareByPath($patharray[0]);
-				}
-				catch (FileNotFoundException $e) {
+				} catch (FileNotFoundException $e) {
 					$shares = false;
 				}
 
@@ -518,8 +509,7 @@ 
 						];
 					}
 				}
-			}
-			else {
+			} else {
 				return false; // $patharray was empty...
 			}
 		}
@@ -564,8 +554,7 @@ 
 						"token" => $share->getToken(),
 						"url" => $share->getUrl(),
 					];
-				}
-				else {
+				} else {
 					foreach ($options as $key => $value) {
 						$this->ocs_client->updateShare($path, $key, $value);
 					}
@@ -575,8 +564,7 @@ 
 					];
 				}
 			}
-		}
-		else {
+		} else {
 			$this->log('No share params given');
 
 			return false; // no shareparams...

plugins/filesbackendOwncloud/php/lib/ocsapi/class.ocsclient.php

Indentation +611 added lines, -611 removed lines

@@ -30,615 +30,615 @@
  * @class   ocsclient
  */
 class ocsclient {
-	/**
-	 * OCS Sharing API.
-	 */
-	public const OCS_PATH = "/ocs/v1.php/apps/files_sharing/api/v1";
-	public const OCS_TIMEOUT = 10;
-
-	/**
-	 * @var string Server base URL
-	 */
-	private $baseurl = "";
-
-	/**
-	 * @var string Username
-	 */
-	private $user = "";
-
-	/**
-	 * @var string Password
-	 */
-	private $pass = "";
-
-	/**
-	 * @var bool Allow self signed certs
-	 */
-	private $allowSelfSignedCerts = false;
-
-	/**
-	 * @var bool Defines if the store has been loaded
-	 */
-	private $loaded = false;
-
-	/**
-	 * @var ocsshare[] this will hold an array of ocsshares - index is the share ID
-	 */
-	private $shares;
-
-	/**
-	 * @var array default curl options used for all requests
-	 */
-	private $curlDefaultOptions = [
-		CURLOPT_AUTOREFERER => true,
-		CURLOPT_TIMEOUT => self::OCS_TIMEOUT,
-		CURLOPT_RETURNTRANSFER => 1,
-		CURLOPT_FOLLOWLOCATION => true,
-		CURLOPT_HTTPHEADER => ['OCS-APIREQUEST: true'],
-	];
-
-	/**
-	 * @var array curl SSL verify options for self signed certificates
-	 */
-	private $curlSSLVerifyOptions = [
-		CURLOPT_SSL_VERIFYHOST => 0,
-		CURLOPT_SSL_VERIFYPEER => 0,
-	];
-
-	/**
-	 * Constructor.
-	 *
-	 * @param $baseurl
-	 * @param $user
-	 * @param $pass
-	 * @param $allowSelfSignedCerts
-	 *
-	 * @throws ConnectionException
-	 */
-	public function __construct($baseurl, $user, $pass, $allowSelfSignedCerts = false) {
-		// check if curl is available
-		$serverHasCurl = function_exists('curl_version');
-		if (!$serverHasCurl) {
-			throw new ConnectionException("Curl not found!");
-		}
-
-		$this->baseurl = $baseurl;
-		$this->user = $user;
-		$this->pass = $pass;
-		$this->allowSelfSignedCerts = $allowSelfSignedCerts;
-
-		$this->shares = [];
-		$this->sharesByPath = [];
-	}
-
-	/**
-	 * Get the base URL for OCS.
-	 *
-	 * @return string
-	 */
-	private function getOCSUrl() {
-		return $this->baseurl . self::OCS_PATH . "/shares";
-	}
-
-	/**
-	 * Shortcut for curl get requests.
-	 *
-	 * @param $url string URL for the request
-	 *
-	 * @return curl response data
-	 */
-	private function doCurlGetRequest($url) {
-		return $this->doCurlRequest($url, []);
-	}
-
-	/**
-	 * Execute curl request with parameters.
-	 *
-	 * @param $url string URL for the request
-	 * @param mixed $curlOptions
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return curl responsedata
-	 */
-	private function doCurlRequest($url, $curlOptions) {
-		$ch = curl_init();
-
-		curl_setopt($ch, CURLOPT_URL, $url);
-		curl_setopt_array($ch, $this->curlDefaultOptions);
-		if ($this->allowSelfSignedCerts) {
-			curl_setopt_array($ch, $this->curlSSLVerifyOptions);
-		}
-		curl_setopt($ch, CURLOPT_USERPWD, $this->user . ":" . $this->pass);
-		if (!empty($curlOptions)) {
-			curl_setopt_array($ch, $curlOptions);
-		}
-
-		$responsedata = curl_exec($ch);
-		$httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
-
-		if ($httpcode == 0) {
-			$message = curl_errno($ch);
-		}
-		else {
-			$message = $httpcode;
-		}
-		curl_close($ch);
-
-		if ($httpcode && $httpcode == "200") {
-			$this->loaded = true;
-
-			return $responsedata;
-		}
-		$this->loaded = false;
-		if ($httpcode == "0") {
-			throw new ConnectionException($message, $httpcode);
-		}
-
-		throw new ConnectionException($httpcode);
-	}
-
-	/**
-	 * Loads the shares for a specific folder.
-	 * If $path is empty all shares will loaded.
-	 *
-	 * @param string $path
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 */
-	public function loadShares($path = "") {
-		// reset all loaded shares first
-		$this->reset();
-
-		if (empty($path)) {
-			$url = $this->getOCSUrl();
-		}
-		else {
-			$url = $this->getOCSUrl() . "?path=" . urlencode($path) . "&subfiles=true";
-		}
-		$this->parseListingResponse($this->doCurlGetRequest($url));
-		$this->loaded = true;
-	}
-
-	/**
-	 * Loads only one specific share defined by ID.
-	 *
-	 * @param $id
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return ocsshare or FALSE
-	 */
-	public function loadShareByID($id) {
-		$url = $this->getOCSUrl() . "/" . $id;
-		$this->parseListingResponse($this->doCurlGetRequest($url));
-		$this->loaded = true;
-		if (isset($this->shares[$id])) {
-			return $this->shares[$id];
-		}
-
-		return false;
-	}
-
-	/**
-	 * Loads one or more shares defined by path.
-	 *
-	 * @param $path
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return ocsshare[] or FALSE
-	 */
-	public function loadShareByPath($path) {
-		$path = rtrim($path, "/");
-		$url = $this->getOCSUrl() . "?path=" . urlencode($path);
-		$this->parseListingResponse($this->doCurlGetRequest($url));
-		$this->loaded = true;
-		$shares = [];
-		foreach ($this->shares as $id => $details) {
-			if ($details->getPath() == $path) {
-				$shares[$id] = $details;
-			}
-		}
-		if (count($shares) > 0) {
-			return $shares;
-		}
-
-		return false;
-	}
-
-	/**
-	 * Gets all groups and users we can share with.
-	 *
-	 * @param mixed $search
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return [] or FALSE
-	 */
-	public function getRecipients($search) {
-		$url = $this->baseurl . self::OCS_PATH . "/sharees?itemType=file&search=" . urlencode($search);
-
-		$ch = curl_init();
-		curl_setopt($ch, CURLOPT_URL, $url);
-		curl_setopt_array($ch, $this->curlDefaultOptions);
-		if ($this->allowSelfSignedCerts) {
-			curl_setopt_array($ch, $this->curlSSLVerifyOptions);
-		}
-		curl_setopt($ch, CURLOPT_USERPWD, $this->user . ":" . $this->pass);
-		$responsedata = curl_exec($ch);
-		$httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
-		curl_close($ch);
-
-		if ($httpcode === 200) {
-			try {
-				$xmldata = new \SimpleXMLElement($responsedata);
-			}
-			catch (\Exception $e) {
-				throw new InvalidResponseException($responsedata);
-			}
-
-			if (!$xmldata || !isset($xmldata->meta) || !$this->parseResponseMeta($xmldata->meta) || !isset($xmldata->data)) {
-				return false;
-			}
-
-			return $this->parseRecipientData($xmldata->data);
-		}
-
-		throw new ConnectionException($httpcode);
-	}
-
-	/**
-	 * Get all loaded shares. Will return FALSE if the store is not loaded yet.
-	 *
-	 * @return ocsshare or FALSE
-	 */
-	public function getAllShares() {
-		if (!$this->loaded) {
-			return false;
-		}
-
-		return $this->shares;
-	}
-
-	/**
-	 * Returns one ocsshare specified by ID. Or FALSE if the ID was not found or store is not loaded yet.
-	 *
-	 * @param $id
-	 *
-	 * @return ocsshare or bool
-	 */
-	public function getShareByID($id) {
-		if (!$this->loaded) {
-			return false;
-		}
-
-		if (isset($this->shares[$id])) {
-			return $this->shares[$id];
-		}
-
-		return false;
-	}
-
-	/**
-	 * Returns one or many ocsshare specified by Path. Or FALSE if path was not found or store is not loaded yet.
-	 *
-	 * @param $path
-	 *
-	 * @return ocsshare[] or bool
-	 */
-	public function getShareByPath($path) {
-		if (!$this->loaded) {
-			return false;
-		}
-
-		$shares = [];
-
-		foreach ($this->shares as $id => $details) {
-			if ($details->getPath() == $path) {
-				$shares[$id] = $details;
-			}
-		}
-
-		if (count($shares) > 0) {
-			return $shares;
-		}
-
-		return false;
-	}
-
-	/**
-	 * Create a new share on the server.
-	 * Optionnames in $options should match Owncloud option names.
-	 * See: https://doc.owncloud.org/server/8.0/developer_manual/core/ocs-share-api.html.
-	 *
-	 * Options has to include shareType (int),  ‘0’ = user; ‘1’ = group; ‘3’ = public link;
-	 * and shareWith for shareType 0 or 1.
-	 *
-	 * @param $path
-	 * @param $options
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return ocsshare
-	 */
-	public function createShare($path, $options) {
-		$url = $this->getOCSUrl();
-
-		// post variables
-		$fields = [
-			'path' => urlencode($path),
-		];
-
-		foreach ($options as $key => $value) {
-			$fields[$key] = urlencode($value);
-		}
-		// url-ify the data for the POST
-		$fields_string = "";
-		foreach ($fields as $key => $value) {
-			$fields_string .= $key . '=' . $value . '&';
-		}
-		rtrim($fields_string, '&');
-		$curlExtraOptions = [
-			CURLOPT_POST => 1,
-			CURLOPT_POSTFIELDS => $fields_string,
-		];
-
-		return $this->parseModificationResponse($this->doCurlRequest($url, $curlExtraOptions));
-	}
-
-	/**
-	 * Update one value of the given share. ATTENTION: updating the password will change the share id.
-	 *
-	 * @param $id
-	 * @param $key
-	 * @param $value
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return ocsshare Returns a empty share
-	 */
-	public function updateShare($id, $key, $value) {
-		$url = $this->getOCSUrl() . "/" . $id;
-
-		// post variables
-		$fields_string = $key . '=' . urlencode($value);
-		$curlExtraOptions = [
-			CURLOPT_CUSTOMREQUEST => "PUT",
-			CURLOPT_POSTFIELDS => $fields_string,
-		];
-
-		return $this->parseModificationResponse($this->doCurlRequest($url, $curlExtraOptions));
-	}
-
-	/**
-	 * Clear all loaded shares.
-	 */
-	public function reset() {
-		unset($this->sharesByPath);
-		$this->sharesByPath = [];
-
-		unset($this->shares);
-		$this->shares = [];
-	}
-
-	/**
-	 * Delete the given share.
-	 *
-	 * @param $id
-	 *
-	 * @throws ConnectionException
-	 * @throws InvalidResponseException
-	 *
-	 * @return ocsshare Returns a empty share
-	 */
-	public function deleteShare($id) {
-		$url = $this->getOCSUrl() . "/" . $id;
-
-		$curlExtraOptions = [
-			CURLOPT_CUSTOMREQUEST => "DELETE",
-		];
-
-		return $this->parseModificationResponse($this->doCurlRequest($url, $curlExtraOptions));
-	}
-
-	/**
-	 * Parse the response of a create or modify request.
-	 *
-	 * @param $response
-	 *
-	 * @throws FileNotFoundException
-	 * @throws InvalidArgumentException
-	 * @throws InvalidRequestException
-	 * @throws InvalidResponseException
-	 * @throws PermissionDeniedException
-	 *
-	 * @return ocsshare
-	 */
-	private function parseModificationResponse($response) {
-		if ($response) {
-			try {
-				$xmldata = new \SimpleXMLElement($response);
-			}
-			catch (\Exception $e) {
-				throw new InvalidResponseException($response);
-			}
-
-			if ($xmldata) {
-				$ok = false;
-				if (isset($xmldata->meta)) {
-					$ok = $this->parseResponseMeta($xmldata->meta);
-				}
-
-				if ($ok) {
-					// create a new ocsshare
-					if (isset($xmldata->data)) {
-						return new ocsshare($xmldata->data);
-					}
-
-					return false;
-				}
-			}
-		}
-		else {
-			throw new InvalidResponseException($response);
-		}
-
-		return false;
-	}
-
-	/**
-	 * Parse the request response.
-	 *
-	 * @param $response
-	 *
-	 * @throws FileNotFoundException
-	 * @throws InvalidArgumentException
-	 * @throws InvalidRequestException
-	 * @throws InvalidResponseException
-	 * @throws PermissionDeniedException
-	 */
-	private function parseListingResponse($response) {
-		if (!$response) {
-			throw new InvalidResponseException($response);
-		}
-
-		try {
-			$xmldata = new \SimpleXMLElement($response);
-		}
-		catch (\Exception $e) {
-			throw new InvalidResponseException($response);
-		}
-
-		if ($xmldata) {
-			$ok = false;
-			if (isset($xmldata->meta)) {
-				$ok = $this->parseResponseMeta($xmldata->meta);
-			}
-
-			if ($ok) {
-				if (isset($xmldata->data)) {
-					$this->parseResponseData($xmldata->data);
-				}
-			}
-		}
-	}
-
-	/**
-	 * Parse the response meta block and its error codes.
-	 *
-	 * @param $response
-	 *
-	 * @throws FileNotFoundException
-	 * @throws InvalidArgumentException
-	 * @throws InvalidRequestException
-	 * @throws InvalidResponseException
-	 * @throws PermissionDeniedException
-	 *
-	 * @return bool
-	 */
-	private function parseResponseMeta($response) {
-		if ($response) {
-			$statuscode = intval($response->statuscode);
-			$message = $response->message;
-
-			// check status code - it must be 100, otherwise it failed
-			if ($statuscode == 100) {
-				return true;
-			}
-
-			switch ($statuscode) {
-				case 400:
-					throw new InvalidArgumentException($message);
-					break;
-
-				case 403:
-					throw new PermissionDeniedException($message);
-					break;
-
-				case 404:
-					throw new FileNotFoundException($message);
-					break;
-
-				case 999:
-					throw new InvalidRequestException($message);
-					break;
-
-				default:
-					throw new InvalidResponseException($message);
-			}
-		}
-		else {
-			throw new InvalidResponseException("Response contains no meta block.");
-		}
-	}
-
-	/**
-	 * Parse the response data block.
-	 *
-	 * @param SimpleXMLElement $response from owncloud server
-	 */
-	private function parseResponseData($response) {
-		// parse each element in the data section
-		foreach ($response->element as $element) {
-			$parsedShare = new ocsshare($element);
-			$parsedShare->generateShareURL($this->baseurl);
-
-			$this->shares[$parsedShare->getId()] = $parsedShare;
-		}
-	}
-
-	/**
-	 * Parse the response data for recipients.
-	 * Converts the xml response data to an array,
-	 *  [[label, shareWith, shareType], ...]
-	 * where
-	 *  - label is the display name
-	 *  - shareWith is the user or group id
-	 *  - shareType is type of the recipient: user or group.
-	 *
-	 * @param SimpleXMLElement $response the response data from the request
-	 *
-	 * @return array array of recipients
-	 */
-	private function parseRecipientData($response) {
-		$result = [];
-		foreach ($response->exact->users->element as $user) {
-			$result[] = [
-				$user->label->__toString(),
-				$user->value->shareWith->__toString(),
-				$user->value->shareType->__toString(),
-			];
-		}
-		foreach ($response->users->element as $user) {
-			$result[] = [
-				$user->label->__toString(),
-				$user->value->shareWith->__toString(),
-				$user->value->shareType->__toString(),
-			];
-		}
-		foreach ($response->exact->groups->element as $group) {
-			$result[] = [
-				$group->label->__toString(),
-				$group->value->shareWith->__toString(),
-				$group->value->shareType->__toString(),
-			];
-		}
-		foreach ($response->groups->element as $group) {
-			$result[] = [
-				$group->label->__toString(),
-				$group->value->shareWith->__toString(),
-				$group->value->shareType->__toString(),
-			];
-		}
-
-		return $result;
-	}
+    /**
+     * OCS Sharing API.
+     */
+    public const OCS_PATH = "/ocs/v1.php/apps/files_sharing/api/v1";
+    public const OCS_TIMEOUT = 10;
+
+    /**
+     * @var string Server base URL
+     */
+    private $baseurl = "";
+
+    /**
+     * @var string Username
+     */
+    private $user = "";
+
+    /**
+     * @var string Password
+     */
+    private $pass = "";
+
+    /**
+     * @var bool Allow self signed certs
+     */
+    private $allowSelfSignedCerts = false;
+
+    /**
+     * @var bool Defines if the store has been loaded
+     */
+    private $loaded = false;
+
+    /**
+     * @var ocsshare[] this will hold an array of ocsshares - index is the share ID
+     */
+    private $shares;
+
+    /**
+     * @var array default curl options used for all requests
+     */
+    private $curlDefaultOptions = [
+        CURLOPT_AUTOREFERER => true,
+        CURLOPT_TIMEOUT => self::OCS_TIMEOUT,
+        CURLOPT_RETURNTRANSFER => 1,
+        CURLOPT_FOLLOWLOCATION => true,
+        CURLOPT_HTTPHEADER => ['OCS-APIREQUEST: true'],
+    ];
+
+    /**
+     * @var array curl SSL verify options for self signed certificates
+     */
+    private $curlSSLVerifyOptions = [
+        CURLOPT_SSL_VERIFYHOST => 0,
+        CURLOPT_SSL_VERIFYPEER => 0,
+    ];
+
+    /**
+     * Constructor.
+     *
+     * @param $baseurl
+     * @param $user
+     * @param $pass
+     * @param $allowSelfSignedCerts
+     *
+     * @throws ConnectionException
+     */
+    public function __construct($baseurl, $user, $pass, $allowSelfSignedCerts = false) {
+        // check if curl is available
+        $serverHasCurl = function_exists('curl_version');
+        if (!$serverHasCurl) {
+            throw new ConnectionException("Curl not found!");
+        }
+
+        $this->baseurl = $baseurl;
+        $this->user = $user;
+        $this->pass = $pass;
+        $this->allowSelfSignedCerts = $allowSelfSignedCerts;
+
+        $this->shares = [];
+        $this->sharesByPath = [];
+    }
+
+    /**
+     * Get the base URL for OCS.
+     *
+     * @return string
+     */
+    private function getOCSUrl() {
+        return $this->baseurl . self::OCS_PATH . "/shares";
+    }
+
+    /**
+     * Shortcut for curl get requests.
+     *
+     * @param $url string URL for the request
+     *
+     * @return curl response data
+     */
+    private function doCurlGetRequest($url) {
+        return $this->doCurlRequest($url, []);
+    }
+
+    /**
+     * Execute curl request with parameters.
+     *
+     * @param $url string URL for the request
+     * @param mixed $curlOptions
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return curl responsedata
+     */
+    private function doCurlRequest($url, $curlOptions) {
+        $ch = curl_init();
+
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt_array($ch, $this->curlDefaultOptions);
+        if ($this->allowSelfSignedCerts) {
+            curl_setopt_array($ch, $this->curlSSLVerifyOptions);
+        }
+        curl_setopt($ch, CURLOPT_USERPWD, $this->user . ":" . $this->pass);
+        if (!empty($curlOptions)) {
+            curl_setopt_array($ch, $curlOptions);
+        }
+
+        $responsedata = curl_exec($ch);
+        $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+
+        if ($httpcode == 0) {
+            $message = curl_errno($ch);
+        }
+        else {
+            $message = $httpcode;
+        }
+        curl_close($ch);
+
+        if ($httpcode && $httpcode == "200") {
+            $this->loaded = true;
+
+            return $responsedata;
+        }
+        $this->loaded = false;
+        if ($httpcode == "0") {
+            throw new ConnectionException($message, $httpcode);
+        }
+
+        throw new ConnectionException($httpcode);
+    }
+
+    /**
+     * Loads the shares for a specific folder.
+     * If $path is empty all shares will loaded.
+     *
+     * @param string $path
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     */
+    public function loadShares($path = "") {
+        // reset all loaded shares first
+        $this->reset();
+
+        if (empty($path)) {
+            $url = $this->getOCSUrl();
+        }
+        else {
+            $url = $this->getOCSUrl() . "?path=" . urlencode($path) . "&subfiles=true";
+        }
+        $this->parseListingResponse($this->doCurlGetRequest($url));
+        $this->loaded = true;
+    }
+
+    /**
+     * Loads only one specific share defined by ID.
+     *
+     * @param $id
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return ocsshare or FALSE
+     */
+    public function loadShareByID($id) {
+        $url = $this->getOCSUrl() . "/" . $id;
+        $this->parseListingResponse($this->doCurlGetRequest($url));
+        $this->loaded = true;
+        if (isset($this->shares[$id])) {
+            return $this->shares[$id];
+        }
+
+        return false;
+    }
+
+    /**
+     * Loads one or more shares defined by path.
+     *
+     * @param $path
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return ocsshare[] or FALSE
+     */
+    public function loadShareByPath($path) {
+        $path = rtrim($path, "/");
+        $url = $this->getOCSUrl() . "?path=" . urlencode($path);
+        $this->parseListingResponse($this->doCurlGetRequest($url));
+        $this->loaded = true;
+        $shares = [];
+        foreach ($this->shares as $id => $details) {
+            if ($details->getPath() == $path) {
+                $shares[$id] = $details;
+            }
+        }
+        if (count($shares) > 0) {
+            return $shares;
+        }
+
+        return false;
+    }
+
+    /**
+     * Gets all groups and users we can share with.
+     *
+     * @param mixed $search
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return [] or FALSE
+     */
+    public function getRecipients($search) {
+        $url = $this->baseurl . self::OCS_PATH . "/sharees?itemType=file&search=" . urlencode($search);
+
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt_array($ch, $this->curlDefaultOptions);
+        if ($this->allowSelfSignedCerts) {
+            curl_setopt_array($ch, $this->curlSSLVerifyOptions);
+        }
+        curl_setopt($ch, CURLOPT_USERPWD, $this->user . ":" . $this->pass);
+        $responsedata = curl_exec($ch);
+        $httpcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        curl_close($ch);
+
+        if ($httpcode === 200) {
+            try {
+                $xmldata = new \SimpleXMLElement($responsedata);
+            }
+            catch (\Exception $e) {
+                throw new InvalidResponseException($responsedata);
+            }
+
+            if (!$xmldata || !isset($xmldata->meta) || !$this->parseResponseMeta($xmldata->meta) || !isset($xmldata->data)) {
+                return false;
+            }
+
+            return $this->parseRecipientData($xmldata->data);
+        }
+
+        throw new ConnectionException($httpcode);
+    }
+
+    /**
+     * Get all loaded shares. Will return FALSE if the store is not loaded yet.
+     *
+     * @return ocsshare or FALSE
+     */
+    public function getAllShares() {
+        if (!$this->loaded) {
+            return false;
+        }
+
+        return $this->shares;
+    }
+
+    /**
+     * Returns one ocsshare specified by ID. Or FALSE if the ID was not found or store is not loaded yet.
+     *
+     * @param $id
+     *
+     * @return ocsshare or bool
+     */
+    public function getShareByID($id) {
+        if (!$this->loaded) {
+            return false;
+        }
+
+        if (isset($this->shares[$id])) {
+            return $this->shares[$id];
+        }
+
+        return false;
+    }
+
+    /**
+     * Returns one or many ocsshare specified by Path. Or FALSE if path was not found or store is not loaded yet.
+     *
+     * @param $path
+     *
+     * @return ocsshare[] or bool
+     */
+    public function getShareByPath($path) {
+        if (!$this->loaded) {
+            return false;
+        }
+
+        $shares = [];
+
+        foreach ($this->shares as $id => $details) {
+            if ($details->getPath() == $path) {
+                $shares[$id] = $details;
+            }
+        }
+
+        if (count($shares) > 0) {
+            return $shares;
+        }
+
+        return false;
+    }
+
+    /**
+     * Create a new share on the server.
+     * Optionnames in $options should match Owncloud option names.
+     * See: https://doc.owncloud.org/server/8.0/developer_manual/core/ocs-share-api.html.
+     *
+     * Options has to include shareType (int),  ‘0’ = user; ‘1’ = group; ‘3’ = public link;
+     * and shareWith for shareType 0 or 1.
+     *
+     * @param $path
+     * @param $options
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return ocsshare
+     */
+    public function createShare($path, $options) {
+        $url = $this->getOCSUrl();
+
+        // post variables
+        $fields = [
+            'path' => urlencode($path),
+        ];
+
+        foreach ($options as $key => $value) {
+            $fields[$key] = urlencode($value);
+        }
+        // url-ify the data for the POST
+        $fields_string = "";
+        foreach ($fields as $key => $value) {
+            $fields_string .= $key . '=' . $value . '&';
+        }
+        rtrim($fields_string, '&');
+        $curlExtraOptions = [
+            CURLOPT_POST => 1,
+            CURLOPT_POSTFIELDS => $fields_string,
+        ];
+
+        return $this->parseModificationResponse($this->doCurlRequest($url, $curlExtraOptions));
+    }
+
+    /**
+     * Update one value of the given share. ATTENTION: updating the password will change the share id.
+     *
+     * @param $id
+     * @param $key
+     * @param $value
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return ocsshare Returns a empty share
+     */
+    public function updateShare($id, $key, $value) {
+        $url = $this->getOCSUrl() . "/" . $id;
+
+        // post variables
+        $fields_string = $key . '=' . urlencode($value);
+        $curlExtraOptions = [
+            CURLOPT_CUSTOMREQUEST => "PUT",
+            CURLOPT_POSTFIELDS => $fields_string,
+        ];
+
+        return $this->parseModificationResponse($this->doCurlRequest($url, $curlExtraOptions));
+    }
+
+    /**
+     * Clear all loaded shares.
+     */
+    public function reset() {
+        unset($this->sharesByPath);
+        $this->sharesByPath = [];
+
+        unset($this->shares);
+        $this->shares = [];
+    }
+
+    /**
+     * Delete the given share.
+     *
+     * @param $id
+     *
+     * @throws ConnectionException
+     * @throws InvalidResponseException
+     *
+     * @return ocsshare Returns a empty share
+     */
+    public function deleteShare($id) {
+        $url = $this->getOCSUrl() . "/" . $id;
+
+        $curlExtraOptions = [
+            CURLOPT_CUSTOMREQUEST => "DELETE",
+        ];
+
+        return $this->parseModificationResponse($this->doCurlRequest($url, $curlExtraOptions));
+    }
+
+    /**
+     * Parse the response of a create or modify request.
+     *
+     * @param $response
+     *
+     * @throws FileNotFoundException
+     * @throws InvalidArgumentException
+     * @throws InvalidRequestException
+     * @throws InvalidResponseException
+     * @throws PermissionDeniedException
+     *
+     * @return ocsshare
+     */
+    private function parseModificationResponse($response) {
+        if ($response) {
+            try {
+                $xmldata = new \SimpleXMLElement($response);
+            }
+            catch (\Exception $e) {
+                throw new InvalidResponseException($response);
+            }
+
+            if ($xmldata) {
+                $ok = false;
+                if (isset($xmldata->meta)) {
+                    $ok = $this->parseResponseMeta($xmldata->meta);
+                }
+
+                if ($ok) {
+                    // create a new ocsshare
+                    if (isset($xmldata->data)) {
+                        return new ocsshare($xmldata->data);
+                    }
+
+                    return false;
+                }
+            }
+        }
+        else {
+            throw new InvalidResponseException($response);
+        }
+
+        return false;
+    }
+
+    /**
+     * Parse the request response.
+     *
+     * @param $response
+     *
+     * @throws FileNotFoundException
+     * @throws InvalidArgumentException
+     * @throws InvalidRequestException
+     * @throws InvalidResponseException
+     * @throws PermissionDeniedException
+     */
+    private function parseListingResponse($response) {
+        if (!$response) {
+            throw new InvalidResponseException($response);
+        }
+
+        try {
+            $xmldata = new \SimpleXMLElement($response);
+        }
+        catch (\Exception $e) {
+            throw new InvalidResponseException($response);
+        }
+
+        if ($xmldata) {
+            $ok = false;
+            if (isset($xmldata->meta)) {
+                $ok = $this->parseResponseMeta($xmldata->meta);
+            }
+
+            if ($ok) {
+                if (isset($xmldata->data)) {
+                    $this->parseResponseData($xmldata->data);
+                }
+            }
+        }
+    }
+
+    /**
+     * Parse the response meta block and its error codes.
+     *
+     * @param $response
+     *
+     * @throws FileNotFoundException
+     * @throws InvalidArgumentException
+     * @throws InvalidRequestException
+     * @throws InvalidResponseException
+     * @throws PermissionDeniedException
+     *
+     * @return bool
+     */
+    private function parseResponseMeta($response) {
+        if ($response) {
+            $statuscode = intval($response->statuscode);
+            $message = $response->message;
+
+            // check status code - it must be 100, otherwise it failed
+            if ($statuscode == 100) {
+                return true;
+            }
+
+            switch ($statuscode) {
+                case 400:
+                    throw new InvalidArgumentException($message);
+                    break;
+
+                case 403:
+                    throw new PermissionDeniedException($message);
+                    break;
+
+                case 404:
+                    throw new FileNotFoundException($message);
+                    break;
+
+                case 999:
+                    throw new InvalidRequestException($message);
+                    break;
+
+                default:
+                    throw new InvalidResponseException($message);
+            }
+        }
+        else {
+            throw new InvalidResponseException("Response contains no meta block.");
+        }
+    }
+
+    /**
+     * Parse the response data block.
+     *
+     * @param SimpleXMLElement $response from owncloud server
+     */
+    private function parseResponseData($response) {
+        // parse each element in the data section
+        foreach ($response->element as $element) {
+            $parsedShare = new ocsshare($element);
+            $parsedShare->generateShareURL($this->baseurl);
+
+            $this->shares[$parsedShare->getId()] = $parsedShare;
+        }
+    }
+
+    /**
+     * Parse the response data for recipients.
+     * Converts the xml response data to an array,
+     *  [[label, shareWith, shareType], ...]
+     * where
+     *  - label is the display name
+     *  - shareWith is the user or group id
+     *  - shareType is type of the recipient: user or group.
+     *
+     * @param SimpleXMLElement $response the response data from the request
+     *
+     * @return array array of recipients
+     */
+    private function parseRecipientData($response) {
+        $result = [];
+        foreach ($response->exact->users->element as $user) {
+            $result[] = [
+                $user->label->__toString(),
+                $user->value->shareWith->__toString(),
+                $user->value->shareType->__toString(),
+            ];
+        }
+        foreach ($response->users->element as $user) {
+            $result[] = [
+                $user->label->__toString(),
+                $user->value->shareWith->__toString(),
+                $user->value->shareType->__toString(),
+            ];
+        }
+        foreach ($response->exact->groups->element as $group) {
+            $result[] = [
+                $group->label->__toString(),
+                $group->value->shareWith->__toString(),
+                $group->value->shareType->__toString(),
+            ];
+        }
+        foreach ($response->groups->element as $group) {
+            $result[] = [
+                $group->label->__toString(),
+                $group->value->shareWith->__toString(),
+                $group->value->shareType->__toString(),
+            ];
+        }
+
+        return $result;
+    }
 }

Braces +7 added lines, -14 removed lines

@@ -160,8 +160,7 @@ 
 
 		if ($httpcode == 0) {
 			$message = curl_errno($ch);
-		}
-		else {
+		} else {
 			$message = $httpcode;
 		}
 		curl_close($ch);
@@ -194,8 +193,7 @@ 
 
 		if (empty($path)) {
 			$url = $this->getOCSUrl();
-		}
-		else {
+		} else {
 			$url = $this->getOCSUrl() . "?path=" . urlencode($path) . "&subfiles=true";
 		}
 		$this->parseListingResponse($this->doCurlGetRequest($url));
@@ -278,8 +276,7 @@ 
 		if ($httpcode === 200) {
 			try {
 				$xmldata = new \SimpleXMLElement($responsedata);
-			}
-			catch (\Exception $e) {
+			} catch (\Exception $e) {
 				throw new InvalidResponseException($responsedata);
 			}
 
@@ -466,8 +463,7 @@ 
 		if ($response) {
 			try {
 				$xmldata = new \SimpleXMLElement($response);
-			}
-			catch (\Exception $e) {
+			} catch (\Exception $e) {
 				throw new InvalidResponseException($response);
 			}
 
@@ -486,8 +482,7 @@ 
 					return false;
 				}
 			}
-		}
-		else {
+		} else {
 			throw new InvalidResponseException($response);
 		}
 
@@ -512,8 +507,7 @@ 
 
 		try {
 			$xmldata = new \SimpleXMLElement($response);
-		}
-		catch (\Exception $e) {
+		} catch (\Exception $e) {
 			throw new InvalidResponseException($response);
 		}
 
@@ -574,8 +568,7 @@ 
 				default:
 					throw new InvalidResponseException($message);
 			}
-		}
-		else {
+		} else {
 			throw new InvalidResponseException("Response contains no meta block.");
 		}
 	}