@@ -93,7 +93,7 @@ |
||
| 93 | 93 | /** |
| 94 | 94 | * returns a list of all possible property names |
| 95 | 95 | * |
| 96 | - * @return array |
|
| 96 | + * @return string[] |
|
| 97 | 97 | */ |
| 98 | 98 | static public function getPropertyNames() { |
| 99 | 99 | return [ |
@@ -86,14 +86,14 @@ discard block |
||
| 86 | 86 | $this->logger = $logger; |
| 87 | 87 | |
| 88 | 88 | $methods = get_class_methods($this->comment); |
| 89 | - $methods = array_filter($methods, function($name){ |
|
| 89 | + $methods = array_filter($methods, function($name) { |
|
| 90 | 90 | return strpos($name, 'get') === 0; |
| 91 | 91 | }); |
| 92 | - foreach($methods as $getter) { |
|
| 93 | - if($getter === 'getMentions') { |
|
| 94 | - continue; // special treatment |
|
| 92 | + foreach ($methods as $getter) { |
|
| 93 | + if ($getter === 'getMentions') { |
|
| 94 | + continue; // special treatment |
|
| 95 | 95 | } |
| 96 | - $name = '{'.self::NS_OWNCLOUD.'}' . lcfirst(substr($getter, 3)); |
|
| 96 | + $name = '{'.self::NS_OWNCLOUD.'}'.lcfirst(substr($getter, 3)); |
|
| 97 | 97 | $this->properties[$name] = $getter; |
| 98 | 98 | } |
| 99 | 99 | $this->userManager = $userManager; |
@@ -132,7 +132,7 @@ discard block |
||
| 132 | 132 | |
| 133 | 133 | protected function checkWriteAccessOnComment() { |
| 134 | 134 | $user = $this->userSession->getUser(); |
| 135 | - if( $this->comment->getActorType() !== 'users' |
|
| 135 | + if ($this->comment->getActorType() !== 'users' |
|
| 136 | 136 | || is_null($user) |
| 137 | 137 | || $this->comment->getActorId() !== $user->getUID() |
| 138 | 138 | ) { |
@@ -196,9 +196,9 @@ discard block |
||
| 196 | 196 | return true; |
| 197 | 197 | } catch (\Exception $e) { |
| 198 | 198 | $this->logger->logException($e, ['app' => 'dav/comments']); |
| 199 | - if($e instanceof MessageTooLongException) { |
|
| 199 | + if ($e instanceof MessageTooLongException) { |
|
| 200 | 200 | $msg = 'Message exceeds allowed character limit of '; |
| 201 | - throw new BadRequest($msg . IComment::MAX_MESSAGE_LENGTH, 0, $e); |
|
| 201 | + throw new BadRequest($msg.IComment::MAX_MESSAGE_LENGTH, 0, $e); |
|
| 202 | 202 | } |
| 203 | 203 | throw $e; |
| 204 | 204 | } |
@@ -240,14 +240,14 @@ discard block |
||
| 240 | 240 | $properties = array_keys($this->properties); |
| 241 | 241 | |
| 242 | 242 | $result = []; |
| 243 | - foreach($properties as $property) { |
|
| 243 | + foreach ($properties as $property) { |
|
| 244 | 244 | $getter = $this->properties[$property]; |
| 245 | - if(method_exists($this->comment, $getter)) { |
|
| 245 | + if (method_exists($this->comment, $getter)) { |
|
| 246 | 246 | $result[$property] = $this->comment->$getter(); |
| 247 | 247 | } |
| 248 | 248 | } |
| 249 | 249 | |
| 250 | - if($this->comment->getActorType() === 'users') { |
|
| 250 | + if ($this->comment->getActorType() === 'users') { |
|
| 251 | 251 | $user = $this->userManager->get($this->comment->getActorId()); |
| 252 | 252 | $displayName = is_null($user) ? null : $user->getDisplayName(); |
| 253 | 253 | $result[self::PROPERTY_NAME_ACTOR_DISPLAYNAME] = $displayName; |
@@ -256,14 +256,14 @@ discard block |
||
| 256 | 256 | $result[self::PROPERTY_NAME_MENTIONS] = $this->composeMentionsPropertyValue(); |
| 257 | 257 | |
| 258 | 258 | $unread = null; |
| 259 | - $user = $this->userSession->getUser(); |
|
| 260 | - if(!is_null($user)) { |
|
| 259 | + $user = $this->userSession->getUser(); |
|
| 260 | + if (!is_null($user)) { |
|
| 261 | 261 | $readUntil = $this->commentsManager->getReadMark( |
| 262 | 262 | $this->comment->getObjectType(), |
| 263 | 263 | $this->comment->getObjectId(), |
| 264 | 264 | $user |
| 265 | 265 | ); |
| 266 | - if(is_null($readUntil)) { |
|
| 266 | + if (is_null($readUntil)) { |
|
| 267 | 267 | $unread = 'true'; |
| 268 | 268 | } else { |
| 269 | 269 | $unread = $this->comment->getCreationDateTime() > $readUntil; |
@@ -138,7 +138,7 @@ |
||
| 138 | 138 | * This will be used in the {DAV:}supported-report-set property. |
| 139 | 139 | * |
| 140 | 140 | * @param string $uri |
| 141 | - * @return array |
|
| 141 | + * @return string[] |
|
| 142 | 142 | */ |
| 143 | 143 | public function getSupportedReportSet($uri) { |
| 144 | 144 | return [self::REPORT_NAME]; |
@@ -84,7 +84,7 @@ discard block |
||
| 84 | 84 | */ |
| 85 | 85 | function initialize(Server $server) { |
| 86 | 86 | $this->server = $server; |
| 87 | - if(strpos($this->server->getRequestUri(), 'comments/') !== 0) { |
|
| 87 | + if (strpos($this->server->getRequestUri(), 'comments/') !== 0) { |
|
| 88 | 88 | return; |
| 89 | 89 | } |
| 90 | 90 | |
@@ -124,7 +124,7 @@ discard block |
||
| 124 | 124 | // having their own comments marked as unread |
| 125 | 125 | $node->setReadMarker(null); |
| 126 | 126 | |
| 127 | - $url = rtrim($request->getUrl(), '/') . '/' . urlencode($comment->getId()); |
|
| 127 | + $url = rtrim($request->getUrl(), '/').'/'.urlencode($comment->getId()); |
|
| 128 | 128 | |
| 129 | 129 | $response->setHeader('Content-Location', $url); |
| 130 | 130 | |
@@ -157,7 +157,7 @@ discard block |
||
| 157 | 157 | */ |
| 158 | 158 | public function onReport($reportName, $report, $uri) { |
| 159 | 159 | $node = $this->server->tree->getNodeForPath($uri); |
| 160 | - if(!$node instanceof EntityCollection || $reportName !== self::REPORT_NAME) { |
|
| 160 | + if (!$node instanceof EntityCollection || $reportName !== self::REPORT_NAME) { |
|
| 161 | 161 | throw new ReportNotSupported(); |
| 162 | 162 | } |
| 163 | 163 | $args = ['limit' => 0, 'offset' => 0, 'datetime' => null]; |
@@ -166,27 +166,27 @@ discard block |
||
| 166 | 166 | $this::REPORT_PARAM_OFFSET, |
| 167 | 167 | $this::REPORT_PARAM_TIMESTAMP |
| 168 | 168 | ]; |
| 169 | - $ns = '{' . $this::NS_OWNCLOUD . '}'; |
|
| 170 | - foreach($report as $parameter) { |
|
| 171 | - if(!in_array($parameter['name'], $acceptableParameters) || empty($parameter['value'])) { |
|
| 169 | + $ns = '{'.$this::NS_OWNCLOUD.'}'; |
|
| 170 | + foreach ($report as $parameter) { |
|
| 171 | + if (!in_array($parameter['name'], $acceptableParameters) || empty($parameter['value'])) { |
|
| 172 | 172 | continue; |
| 173 | 173 | } |
| 174 | 174 | $args[str_replace($ns, '', $parameter['name'])] = $parameter['value']; |
| 175 | 175 | } |
| 176 | 176 | |
| 177 | - if(!is_null($args['datetime'])) { |
|
| 177 | + if (!is_null($args['datetime'])) { |
|
| 178 | 178 | $args['datetime'] = new \DateTime($args['datetime']); |
| 179 | 179 | } |
| 180 | 180 | |
| 181 | 181 | $results = $node->findChildren($args['limit'], $args['offset'], $args['datetime']); |
| 182 | 182 | |
| 183 | 183 | $responses = []; |
| 184 | - foreach($results as $node) { |
|
| 185 | - $nodePath = $this->server->getRequestUri() . '/' . $node->comment->getId(); |
|
| 184 | + foreach ($results as $node) { |
|
| 185 | + $nodePath = $this->server->getRequestUri().'/'.$node->comment->getId(); |
|
| 186 | 186 | $resultSet = $this->server->getPropertiesForPath($nodePath, CommentNode::getPropertyNames()); |
| 187 | - if(isset($resultSet[0]) && isset($resultSet[0][200])) { |
|
| 187 | + if (isset($resultSet[0]) && isset($resultSet[0][200])) { |
|
| 188 | 188 | $responses[] = new Response( |
| 189 | - $this->server->getBaseUri() . $nodePath, |
|
| 189 | + $this->server->getBaseUri().$nodePath, |
|
| 190 | 190 | [200 => $resultSet[0][200]], |
| 191 | 191 | 200 |
| 192 | 192 | ); |
@@ -227,14 +227,14 @@ discard block |
||
| 227 | 227 | |
| 228 | 228 | $actorType = $data['actorType']; |
| 229 | 229 | $actorId = null; |
| 230 | - if($actorType === 'users') { |
|
| 230 | + if ($actorType === 'users') { |
|
| 231 | 231 | $user = $this->userSession->getUser(); |
| 232 | - if(!is_null($user)) { |
|
| 232 | + if (!is_null($user)) { |
|
| 233 | 233 | $actorId = $user->getUID(); |
| 234 | 234 | } |
| 235 | 235 | } |
| 236 | - if(is_null($actorId)) { |
|
| 237 | - throw new BadRequest('Invalid actor "' . $actorType .'"'); |
|
| 236 | + if (is_null($actorId)) { |
|
| 237 | + throw new BadRequest('Invalid actor "'.$actorType.'"'); |
|
| 238 | 238 | } |
| 239 | 239 | |
| 240 | 240 | try { |
@@ -247,7 +247,7 @@ discard block |
||
| 247 | 247 | throw new BadRequest('Invalid input values', 0, $e); |
| 248 | 248 | } catch (\OCP\Comments\MessageTooLongException $e) { |
| 249 | 249 | $msg = 'Message exceeds allowed character limit of '; |
| 250 | - throw new BadRequest($msg . \OCP\Comments\IComment::MAX_MESSAGE_LENGTH, 0, $e); |
|
| 250 | + throw new BadRequest($msg.\OCP\Comments\IComment::MAX_MESSAGE_LENGTH, 0, $e); |
|
| 251 | 251 | } |
| 252 | 252 | } |
| 253 | 253 | |
@@ -115,7 +115,7 @@ |
||
| 115 | 115 | /** |
| 116 | 116 | * Returns an array with all the child nodes |
| 117 | 117 | * |
| 118 | - * @return \Sabre\DAV\INode[] |
|
| 118 | + * @return CommentNode[] |
|
| 119 | 119 | */ |
| 120 | 120 | function getChildren() { |
| 121 | 121 | return $this->findChildren(); |
@@ -41,7 +41,7 @@ discard block |
||
| 41 | 41 | * @package OCA\DAV\Comments |
| 42 | 42 | */ |
| 43 | 43 | class EntityCollection extends RootCollection implements IProperties { |
| 44 | - const PROPERTY_NAME_READ_MARKER = '{http://owncloud.org/ns}readMarker'; |
|
| 44 | + const PROPERTY_NAME_READ_MARKER = '{http://owncloud.org/ns}readMarker'; |
|
| 45 | 45 | |
| 46 | 46 | /** @var string */ |
| 47 | 47 | protected $id; |
@@ -65,10 +65,10 @@ discard block |
||
| 65 | 65 | IUserSession $userSession, |
| 66 | 66 | ILogger $logger |
| 67 | 67 | ) { |
| 68 | - foreach(['id', 'name'] as $property) { |
|
| 68 | + foreach (['id', 'name'] as $property) { |
|
| 69 | 69 | $$property = trim($$property); |
| 70 | - if(empty($$property) || !is_string($$property)) { |
|
| 71 | - throw new \InvalidArgumentException('"' . $property . '" parameter must be non-empty string'); |
|
| 70 | + if (empty($$property) || !is_string($$property)) { |
|
| 71 | + throw new \InvalidArgumentException('"'.$property.'" parameter must be non-empty string'); |
|
| 72 | 72 | } |
| 73 | 73 | } |
| 74 | 74 | $this->id = $id; |
@@ -134,7 +134,7 @@ discard block |
||
| 134 | 134 | function findChildren($limit = 0, $offset = 0, \DateTime $datetime = null) { |
| 135 | 135 | $comments = $this->commentsManager->getForObject($this->name, $this->id, $limit, $offset, $datetime); |
| 136 | 136 | $result = []; |
| 137 | - foreach($comments as $comment) { |
|
| 137 | + foreach ($comments as $comment) { |
|
| 138 | 138 | $result[] = new CommentNode( |
| 139 | 139 | $this->commentsManager, |
| 140 | 140 | $comment, |
@@ -187,7 +187,7 @@ discard block |
||
| 187 | 187 | function getProperties($properties) { |
| 188 | 188 | $marker = null; |
| 189 | 189 | $user = $this->userSession->getUser(); |
| 190 | - if(!is_null($user)) { |
|
| 190 | + if (!is_null($user)) { |
|
| 191 | 191 | $marker = $this->commentsManager->getReadMark($this->name, $this->id, $user); |
| 192 | 192 | } |
| 193 | 193 | return [self::PROPERTY_NAME_READ_MARKER => $marker]; |
@@ -75,7 +75,7 @@ |
||
| 75 | 75 | private $cache = []; |
| 76 | 76 | |
| 77 | 77 | /** |
| 78 | - * @param Tree $tree node tree |
|
| 78 | + * @param ObjectTree $tree node tree |
|
| 79 | 79 | * @param IDBConnection $connection database connection |
| 80 | 80 | * @param IUser $user owner of the tree and properties |
| 81 | 81 | */ |
@@ -111,7 +111,7 @@ discard block |
||
| 111 | 111 | // we catch the exception to prevent breaking the whole list with a 404 |
| 112 | 112 | // (soft fail) |
| 113 | 113 | \OC::$server->getLogger()->warning( |
| 114 | - 'Could not get node for path: \"' . $path . '\" : ' . $e->getMessage(), |
|
| 114 | + 'Could not get node for path: \"'.$path.'\" : '.$e->getMessage(), |
|
| 115 | 115 | array('app' => 'files') |
| 116 | 116 | ); |
| 117 | 117 | return; |
@@ -170,7 +170,7 @@ discard block |
||
| 170 | 170 | $statement = $this->connection->prepare( |
| 171 | 171 | 'DELETE FROM `*PREFIX*properties` WHERE `userid` = ? AND `propertypath` = ?' |
| 172 | 172 | ); |
| 173 | - $statement->execute(array($this->user, '/' . $path)); |
|
| 173 | + $statement->execute(array($this->user, '/'.$path)); |
|
| 174 | 174 | $statement->closeCursor(); |
| 175 | 175 | |
| 176 | 176 | unset($this->cache[$path]); |
@@ -186,10 +186,10 @@ discard block |
||
| 186 | 186 | */ |
| 187 | 187 | public function move($source, $destination) { |
| 188 | 188 | $statement = $this->connection->prepare( |
| 189 | - 'UPDATE `*PREFIX*properties` SET `propertypath` = ?' . |
|
| 189 | + 'UPDATE `*PREFIX*properties` SET `propertypath` = ?'. |
|
| 190 | 190 | ' WHERE `userid` = ? AND `propertypath` = ?' |
| 191 | 191 | ); |
| 192 | - $statement->execute(array('/' . $destination, $this->user, '/' . $source)); |
|
| 192 | + $statement->execute(array('/'.$destination, $this->user, '/'.$source)); |
|
| 193 | 193 | $statement->closeCursor(); |
| 194 | 194 | } |
| 195 | 195 | |
@@ -250,13 +250,13 @@ discard block |
||
| 250 | 250 | private function updateProperties($node, $properties) { |
| 251 | 251 | $path = $node->getPath(); |
| 252 | 252 | |
| 253 | - $deleteStatement = 'DELETE FROM `*PREFIX*properties`' . |
|
| 253 | + $deleteStatement = 'DELETE FROM `*PREFIX*properties`'. |
|
| 254 | 254 | ' WHERE `userid` = ? AND `propertypath` = ? AND `propertyname` = ?'; |
| 255 | 255 | |
| 256 | - $insertStatement = 'INSERT INTO `*PREFIX*properties`' . |
|
| 256 | + $insertStatement = 'INSERT INTO `*PREFIX*properties`'. |
|
| 257 | 257 | ' (`userid`,`propertypath`,`propertyname`,`propertyvalue`) VALUES(?,?,?,?)'; |
| 258 | 258 | |
| 259 | - $updateStatement = 'UPDATE `*PREFIX*properties` SET `propertyvalue` = ?' . |
|
| 259 | + $updateStatement = 'UPDATE `*PREFIX*properties` SET `propertyvalue` = ?'. |
|
| 260 | 260 | ' WHERE `userid` = ? AND `propertypath` = ? AND `propertyname` = ?'; |
| 261 | 261 | |
| 262 | 262 | // TODO: use "insert or update" strategy ? |
@@ -329,7 +329,7 @@ discard block |
||
| 329 | 329 | |
| 330 | 330 | $result = $this->connection->executeQuery( |
| 331 | 331 | $sql, |
| 332 | - array($this->user, $this->connection->escapeLikeParameter(rtrim($path, '/')) . '/%', $requestedProperties), |
|
| 332 | + array($this->user, $this->connection->escapeLikeParameter(rtrim($path, '/')).'/%', $requestedProperties), |
|
| 333 | 333 | array(null, null, \Doctrine\DBAL\Connection::PARAM_STR_ARRAY) |
| 334 | 334 | ); |
| 335 | 335 | |
@@ -232,6 +232,9 @@ |
||
| 232 | 232 | return '"' . $this->info->getEtag() . '"'; |
| 233 | 233 | } |
| 234 | 234 | |
| 235 | + /** |
|
| 236 | + * @param string $path |
|
| 237 | + */ |
|
| 235 | 238 | private function getPartFileBasePath($path) { |
| 236 | 239 | $partFileInStorage = \OC::$server->getConfig()->getSystemValue('part_file_in_storage', true); |
| 237 | 240 | if ($partFileInStorage) { |
@@ -93,7 +93,7 @@ discard block |
||
| 93 | 93 | throw new Forbidden(); |
| 94 | 94 | } |
| 95 | 95 | } catch (StorageNotAvailableException $e) { |
| 96 | - throw new ServiceUnavailable("File is not updatable: " . $e->getMessage()); |
|
| 96 | + throw new ServiceUnavailable("File is not updatable: ".$e->getMessage()); |
|
| 97 | 97 | } |
| 98 | 98 | |
| 99 | 99 | // verify path of the target |
@@ -113,7 +113,7 @@ discard block |
||
| 113 | 113 | |
| 114 | 114 | if ($needsPartFile) { |
| 115 | 115 | // mark file as partial while uploading (ignored by the scanner) |
| 116 | - $partFilePath = $this->getPartFileBasePath($this->path) . '.ocTransferId' . rand() . '.part'; |
|
| 116 | + $partFilePath = $this->getPartFileBasePath($this->path).'.ocTransferId'.rand().'.part'; |
|
| 117 | 117 | } else { |
| 118 | 118 | // upload file directly as the final path |
| 119 | 119 | $partFilePath = $this->path; |
@@ -139,7 +139,7 @@ discard block |
||
| 139 | 139 | if (isset($_SERVER['CONTENT_LENGTH'])) { |
| 140 | 140 | $expected = $_SERVER['CONTENT_LENGTH']; |
| 141 | 141 | } |
| 142 | - throw new Exception('Error while copying file to target location (copied bytes: ' . $count . ', expected filesize: ' . $expected . ' )'); |
|
| 142 | + throw new Exception('Error while copying file to target location (copied bytes: '.$count.', expected filesize: '.$expected.' )'); |
|
| 143 | 143 | } |
| 144 | 144 | |
| 145 | 145 | // if content length is sent by client: |
@@ -148,7 +148,7 @@ discard block |
||
| 148 | 148 | if (isset($_SERVER['CONTENT_LENGTH']) && $_SERVER['REQUEST_METHOD'] === 'PUT') { |
| 149 | 149 | $expected = (int) $_SERVER['CONTENT_LENGTH']; |
| 150 | 150 | if ($count !== $expected) { |
| 151 | - throw new BadRequest('expected filesize ' . $expected . ' got ' . $count); |
|
| 151 | + throw new BadRequest('expected filesize '.$expected.' got '.$count); |
|
| 152 | 152 | } |
| 153 | 153 | } |
| 154 | 154 | |
@@ -184,7 +184,7 @@ discard block |
||
| 184 | 184 | $fileExists = $storage->file_exists($internalPath); |
| 185 | 185 | } |
| 186 | 186 | if (!$run || $renameOkay === false || $fileExists === false) { |
| 187 | - \OCP\Util::writeLog('webdav', 'renaming part file to final file failed ($run: ' . ( $run ? 'true' : 'false' ) . ', $renameOkay: ' . ( $renameOkay ? 'true' : 'false' ) . ', $fileExists: ' . ( $fileExists ? 'true' : 'false' ) . ')', \OCP\Util::ERROR); |
|
| 187 | + \OCP\Util::writeLog('webdav', 'renaming part file to final file failed ($run: '.($run ? 'true' : 'false').', $renameOkay: '.($renameOkay ? 'true' : 'false').', $fileExists: '.($fileExists ? 'true' : 'false').')', \OCP\Util::ERROR); |
|
| 188 | 188 | throw new Exception('Could not rename part file to final file'); |
| 189 | 189 | } |
| 190 | 190 | } catch (ForbiddenException $ex) { |
@@ -233,10 +233,10 @@ discard block |
||
| 233 | 233 | } |
| 234 | 234 | |
| 235 | 235 | } catch (StorageNotAvailableException $e) { |
| 236 | - throw new ServiceUnavailable("Failed to check file size: " . $e->getMessage()); |
|
| 236 | + throw new ServiceUnavailable("Failed to check file size: ".$e->getMessage()); |
|
| 237 | 237 | } |
| 238 | 238 | |
| 239 | - return '"' . $this->info->getEtag() . '"'; |
|
| 239 | + return '"'.$this->info->getEtag().'"'; |
|
| 240 | 240 | } |
| 241 | 241 | |
| 242 | 242 | private function getPartFileBasePath($path) { |
@@ -319,9 +319,9 @@ discard block |
||
| 319 | 319 | return $res; |
| 320 | 320 | } catch (GenericEncryptionException $e) { |
| 321 | 321 | // returning 503 will allow retry of the operation at a later point in time |
| 322 | - throw new ServiceUnavailable("Encryption not ready: " . $e->getMessage()); |
|
| 322 | + throw new ServiceUnavailable("Encryption not ready: ".$e->getMessage()); |
|
| 323 | 323 | } catch (StorageNotAvailableException $e) { |
| 324 | - throw new ServiceUnavailable("Failed to open file: " . $e->getMessage()); |
|
| 324 | + throw new ServiceUnavailable("Failed to open file: ".$e->getMessage()); |
|
| 325 | 325 | } catch (ForbiddenException $ex) { |
| 326 | 326 | throw new DAVForbiddenException($ex->getMessage(), $ex->getRetry()); |
| 327 | 327 | } catch (LockedException $e) { |
@@ -346,7 +346,7 @@ discard block |
||
| 346 | 346 | throw new Forbidden(); |
| 347 | 347 | } |
| 348 | 348 | } catch (StorageNotAvailableException $e) { |
| 349 | - throw new ServiceUnavailable("Failed to unlink: " . $e->getMessage()); |
|
| 349 | + throw new ServiceUnavailable("Failed to unlink: ".$e->getMessage()); |
|
| 350 | 350 | } catch (ForbiddenException $ex) { |
| 351 | 351 | throw new DAVForbiddenException($ex->getMessage(), $ex->getRetry()); |
| 352 | 352 | } catch (LockedException $e) { |
@@ -413,7 +413,7 @@ discard block |
||
| 413 | 413 | if ($bytesWritten !== $expected) { |
| 414 | 414 | $chunk_handler->remove($info['index']); |
| 415 | 415 | throw new BadRequest( |
| 416 | - 'expected filesize ' . $expected . ' got ' . $bytesWritten); |
|
| 416 | + 'expected filesize '.$expected.' got '.$bytesWritten); |
|
| 417 | 417 | } |
| 418 | 418 | } |
| 419 | 419 | } |
@@ -423,7 +423,7 @@ discard block |
||
| 423 | 423 | $needsPartFile = $this->needsPartFile($storage); |
| 424 | 424 | $partFile = null; |
| 425 | 425 | |
| 426 | - $targetPath = $path . '/' . $info['name']; |
|
| 426 | + $targetPath = $path.'/'.$info['name']; |
|
| 427 | 427 | /** @var \OC\Files\Storage\Storage $targetStorage */ |
| 428 | 428 | list($targetStorage, $targetInternalPath) = $this->fileView->resolvePath($targetPath); |
| 429 | 429 | |
@@ -439,7 +439,7 @@ discard block |
||
| 439 | 439 | |
| 440 | 440 | if ($needsPartFile) { |
| 441 | 441 | // we first assembly the target file as a part file |
| 442 | - $partFile = $this->getPartFileBasePath($path . '/' . $info['name']) . '.ocTransferId' . $info['transferid'] . '.part'; |
|
| 442 | + $partFile = $this->getPartFileBasePath($path.'/'.$info['name']).'.ocTransferId'.$info['transferid'].'.part'; |
|
| 443 | 443 | /** @var \OC\Files\Storage\Storage $targetStorage */ |
| 444 | 444 | list($partStorage, $partInternalPath) = $this->fileView->resolvePath($partFile); |
| 445 | 445 | |
@@ -558,10 +558,10 @@ discard block |
||
| 558 | 558 | } |
| 559 | 559 | if ($e instanceof GenericEncryptionException) { |
| 560 | 560 | // returning 503 will allow retry of the operation at a later point in time |
| 561 | - throw new ServiceUnavailable('Encryption not ready: ' . $e->getMessage(), 0, $e); |
|
| 561 | + throw new ServiceUnavailable('Encryption not ready: '.$e->getMessage(), 0, $e); |
|
| 562 | 562 | } |
| 563 | 563 | if ($e instanceof StorageNotAvailableException) { |
| 564 | - throw new ServiceUnavailable('Failed to write file contents: ' . $e->getMessage(), 0, $e); |
|
| 564 | + throw new ServiceUnavailable('Failed to write file contents: '.$e->getMessage(), 0, $e); |
|
| 565 | 565 | } |
| 566 | 566 | |
| 567 | 567 | throw new \Sabre\DAV\Exception($e->getMessage(), 0, $e); |
@@ -132,7 +132,7 @@ |
||
| 132 | 132 | * Returns the list of members for a group-principal |
| 133 | 133 | * |
| 134 | 134 | * @param string $principal |
| 135 | - * @return array |
|
| 135 | + * @return string[] |
|
| 136 | 136 | */ |
| 137 | 137 | function getGroupMemberSet($principal) { |
| 138 | 138 | // TODO: for now the group principal has only one member, the user itself |
@@ -369,7 +369,7 @@ |
||
| 369 | 369 | * @param string $path path to the file which should be updated |
| 370 | 370 | * @param string $uid of the user who performs the operation |
| 371 | 371 | * @param array $accessList who has access to the file contains the key 'users' and 'public' |
| 372 | - * @return boolean |
|
| 372 | + * @return null|boolean |
|
| 373 | 373 | */ |
| 374 | 374 | public function update($path, $uid, array $accessList) { |
| 375 | 375 | |
@@ -177,7 +177,7 @@ discard block |
||
| 177 | 177 | $this->isWriteOperation = false; |
| 178 | 178 | $this->writeCache = ''; |
| 179 | 179 | |
| 180 | - if($this->session->isReady() === false) { |
|
| 180 | + if ($this->session->isReady() === false) { |
|
| 181 | 181 | // if the master key is enabled we can initialize encryption |
| 182 | 182 | // with a empty password and user name |
| 183 | 183 | if ($this->util->isMasterKeyEnabled()) { |
@@ -198,7 +198,7 @@ discard block |
||
| 198 | 198 | // always use the version from the original file, also part files |
| 199 | 199 | // need to have a correct version number if they get moved over to the |
| 200 | 200 | // final location |
| 201 | - $this->version = (int)$this->keyManager->getVersion($this->stripPartFileExtension($path), new View()); |
|
| 201 | + $this->version = (int) $this->keyManager->getVersion($this->stripPartFileExtension($path), new View()); |
|
| 202 | 202 | |
| 203 | 203 | if ( |
| 204 | 204 | $mode === 'w' |
@@ -214,7 +214,7 @@ discard block |
||
| 214 | 214 | // if we read a part file we need to increase the version by 1 |
| 215 | 215 | // because the version number was also increased by writing |
| 216 | 216 | // the part file |
| 217 | - if(Scanner::isPartialFile($path)) { |
|
| 217 | + if (Scanner::isPartialFile($path)) { |
|
| 218 | 218 | $this->version = $this->version + 1; |
| 219 | 219 | } |
| 220 | 220 | } |
@@ -300,7 +300,7 @@ discard block |
||
| 300 | 300 | if ($this->writeCache) { |
| 301 | 301 | |
| 302 | 302 | // Concat writeCache to start of $data |
| 303 | - $data = $this->writeCache . $data; |
|
| 303 | + $data = $this->writeCache.$data; |
|
| 304 | 304 | |
| 305 | 305 | // Clear the write cache, ready for reuse - it has been |
| 306 | 306 | // flushed and its old contents processed |
@@ -402,7 +402,7 @@ discard block |
||
| 402 | 402 | try { |
| 403 | 403 | $publicKeys[$user] = $this->keyManager->getPublicKey($user); |
| 404 | 404 | } catch (PublicKeyMissingException $e) { |
| 405 | - $this->logger->warning('Could not encrypt file for ' . $user . ': ' . $e->getMessage()); |
|
| 405 | + $this->logger->warning('Could not encrypt file for '.$user.': '.$e->getMessage()); |
|
| 406 | 406 | } |
| 407 | 407 | } |
| 408 | 408 | } |
@@ -489,8 +489,8 @@ discard block |
||
| 489 | 489 | // error message because in this case it means that the file was |
| 490 | 490 | // shared with the user at a point where the user didn't had a |
| 491 | 491 | // valid private/public key |
| 492 | - $msg = 'Encryption module "' . $this->getDisplayName() . |
|
| 493 | - '" is not able to read ' . $path; |
|
| 492 | + $msg = 'Encryption module "'.$this->getDisplayName(). |
|
| 493 | + '" is not able to read '.$path; |
|
| 494 | 494 | $hint = $this->l->t('Can not read this file, probably this is a shared file. Please ask the file owner to reshare the file with you.'); |
| 495 | 495 | $this->logger->warning($msg); |
| 496 | 496 | throw new DecryptionFailedException($msg, $hint); |
@@ -532,7 +532,7 @@ discard block |
||
| 532 | 532 | $realPath = $path; |
| 533 | 533 | $parts = explode('/', $path); |
| 534 | 534 | if ($parts[2] === 'files_versions') { |
| 535 | - $realPath = '/' . $parts[1] . '/files/' . implode('/', array_slice($parts, 3)); |
|
| 535 | + $realPath = '/'.$parts[1].'/files/'.implode('/', array_slice($parts, 3)); |
|
| 536 | 536 | $length = strrpos($realPath, '.'); |
| 537 | 537 | $realPath = substr($realPath, 0, $length); |
| 538 | 538 | } |
@@ -488,7 +488,7 @@ |
||
| 488 | 488 | |
| 489 | 489 | |
| 490 | 490 | /** |
| 491 | - * @param $path |
|
| 491 | + * @param string $path |
|
| 492 | 492 | * @param $uid |
| 493 | 493 | * @return mixed |
| 494 | 494 | */ |
@@ -126,7 +126,7 @@ discard block |
||
| 126 | 126 | $this->recoveryKeyId = $this->config->getAppValue('encryption', |
| 127 | 127 | 'recoveryKeyId'); |
| 128 | 128 | if (empty($this->recoveryKeyId)) { |
| 129 | - $this->recoveryKeyId = 'recoveryKey_' . substr(md5(time()), 0, 8); |
|
| 129 | + $this->recoveryKeyId = 'recoveryKey_'.substr(md5(time()), 0, 8); |
|
| 130 | 130 | $this->config->setAppValue('encryption', |
| 131 | 131 | 'recoveryKeyId', |
| 132 | 132 | $this->recoveryKeyId); |
@@ -135,14 +135,14 @@ discard block |
||
| 135 | 135 | $this->publicShareKeyId = $this->config->getAppValue('encryption', |
| 136 | 136 | 'publicShareKeyId'); |
| 137 | 137 | if (empty($this->publicShareKeyId)) { |
| 138 | - $this->publicShareKeyId = 'pubShare_' . substr(md5(time()), 0, 8); |
|
| 138 | + $this->publicShareKeyId = 'pubShare_'.substr(md5(time()), 0, 8); |
|
| 139 | 139 | $this->config->setAppValue('encryption', 'publicShareKeyId', $this->publicShareKeyId); |
| 140 | 140 | } |
| 141 | 141 | |
| 142 | 142 | $this->masterKeyId = $this->config->getAppValue('encryption', |
| 143 | 143 | 'masterKeyId'); |
| 144 | 144 | if (empty($this->masterKeyId)) { |
| 145 | - $this->masterKeyId = 'master_' . substr(md5(time()), 0, 8); |
|
| 145 | + $this->masterKeyId = 'master_'.substr(md5(time()), 0, 8); |
|
| 146 | 146 | $this->config->setAppValue('encryption', 'masterKeyId', $this->masterKeyId); |
| 147 | 147 | } |
| 148 | 148 | |
@@ -160,13 +160,13 @@ discard block |
||
| 160 | 160 | |
| 161 | 161 | // Save public key |
| 162 | 162 | $this->keyStorage->setSystemUserKey( |
| 163 | - $this->publicShareKeyId . '.publicKey', $keyPair['publicKey'], |
|
| 163 | + $this->publicShareKeyId.'.publicKey', $keyPair['publicKey'], |
|
| 164 | 164 | Encryption::ID); |
| 165 | 165 | |
| 166 | 166 | // Encrypt private key empty passphrase |
| 167 | 167 | $encryptedKey = $this->crypt->encryptPrivateKey($keyPair['privateKey'], ''); |
| 168 | 168 | $header = $this->crypt->generateHeader(); |
| 169 | - $this->setSystemPrivateKey($this->publicShareKeyId, $header . $encryptedKey); |
|
| 169 | + $this->setSystemPrivateKey($this->publicShareKeyId, $header.$encryptedKey); |
|
| 170 | 170 | } |
| 171 | 171 | } |
| 172 | 172 | |
@@ -185,13 +185,13 @@ discard block |
||
| 185 | 185 | |
| 186 | 186 | // Save public key |
| 187 | 187 | $this->keyStorage->setSystemUserKey( |
| 188 | - $this->masterKeyId . '.publicKey', $keyPair['publicKey'], |
|
| 188 | + $this->masterKeyId.'.publicKey', $keyPair['publicKey'], |
|
| 189 | 189 | Encryption::ID); |
| 190 | 190 | |
| 191 | 191 | // Encrypt private key with system password |
| 192 | 192 | $encryptedKey = $this->crypt->encryptPrivateKey($keyPair['privateKey'], $this->getMasterKeyPassword(), $this->masterKeyId); |
| 193 | 193 | $header = $this->crypt->generateHeader(); |
| 194 | - $this->setSystemPrivateKey($this->masterKeyId, $header . $encryptedKey); |
|
| 194 | + $this->setSystemPrivateKey($this->masterKeyId, $header.$encryptedKey); |
|
| 195 | 195 | } |
| 196 | 196 | |
| 197 | 197 | if (!$this->session->isPrivateKeySet()) { |
@@ -218,7 +218,7 @@ discard block |
||
| 218 | 218 | * @return string |
| 219 | 219 | */ |
| 220 | 220 | public function getRecoveryKey() { |
| 221 | - return $this->keyStorage->getSystemUserKey($this->recoveryKeyId . '.publicKey', Encryption::ID); |
|
| 221 | + return $this->keyStorage->getSystemUserKey($this->recoveryKeyId.'.publicKey', Encryption::ID); |
|
| 222 | 222 | } |
| 223 | 223 | |
| 224 | 224 | /** |
@@ -235,7 +235,7 @@ discard block |
||
| 235 | 235 | * @return bool |
| 236 | 236 | */ |
| 237 | 237 | public function checkRecoveryPassword($password) { |
| 238 | - $recoveryKey = $this->keyStorage->getSystemUserKey($this->recoveryKeyId . '.privateKey', Encryption::ID); |
|
| 238 | + $recoveryKey = $this->keyStorage->getSystemUserKey($this->recoveryKeyId.'.privateKey', Encryption::ID); |
|
| 239 | 239 | $decryptedRecoveryKey = $this->crypt->decryptPrivateKey($recoveryKey, $password); |
| 240 | 240 | |
| 241 | 241 | if ($decryptedRecoveryKey) { |
@@ -259,7 +259,7 @@ discard block |
||
| 259 | 259 | $header = $this->crypt->generateHeader(); |
| 260 | 260 | |
| 261 | 261 | if ($encryptedKey) { |
| 262 | - $this->setPrivateKey($uid, $header . $encryptedKey); |
|
| 262 | + $this->setPrivateKey($uid, $header.$encryptedKey); |
|
| 263 | 263 | return true; |
| 264 | 264 | } |
| 265 | 265 | return false; |
@@ -281,7 +281,7 @@ discard block |
||
| 281 | 281 | $header = $this->crypt->generateHeader(); |
| 282 | 282 | |
| 283 | 283 | if ($encryptedKey) { |
| 284 | - $this->setSystemPrivateKey($this->getRecoveryKeyId(), $header . $encryptedKey); |
|
| 284 | + $this->setSystemPrivateKey($this->getRecoveryKeyId(), $header.$encryptedKey); |
|
| 285 | 285 | return true; |
| 286 | 286 | } |
| 287 | 287 | return false; |
@@ -341,7 +341,7 @@ discard block |
||
| 341 | 341 | * @return boolean |
| 342 | 342 | */ |
| 343 | 343 | public function setShareKey($path, $uid, $key) { |
| 344 | - $keyId = $uid . '.' . $this->shareKeyId; |
|
| 344 | + $keyId = $uid.'.'.$this->shareKeyId; |
|
| 345 | 345 | return $this->keyStorage->setFileKey($path, $keyId, $key, Encryption::ID); |
| 346 | 346 | } |
| 347 | 347 | |
@@ -357,7 +357,7 @@ discard block |
||
| 357 | 357 | $this->session->setStatus(Session::INIT_EXECUTED); |
| 358 | 358 | |
| 359 | 359 | try { |
| 360 | - if($this->util->isMasterKeyEnabled()) { |
|
| 360 | + if ($this->util->isMasterKeyEnabled()) { |
|
| 361 | 361 | $uid = $this->getMasterKeyId(); |
| 362 | 362 | $passPhrase = $this->getMasterKeyPassword(); |
| 363 | 363 | $privateKey = $this->getSystemPrivateKey($uid); |
@@ -371,7 +371,7 @@ discard block |
||
| 371 | 371 | return false; |
| 372 | 372 | } catch (\Exception $e) { |
| 373 | 373 | $this->log->warning( |
| 374 | - 'Could not decrypt the private key from user "' . $uid . '"" during login. ' . |
|
| 374 | + 'Could not decrypt the private key from user "'.$uid.'"" during login. '. |
|
| 375 | 375 | 'Assume password change on the user back-end. Error message: ' |
| 376 | 376 | . $e->getMessage() |
| 377 | 377 | ); |
@@ -432,7 +432,7 @@ discard block |
||
| 432 | 432 | // use public share key for public links |
| 433 | 433 | $uid = $this->getPublicShareKeyId(); |
| 434 | 434 | $shareKey = $this->getShareKey($path, $uid); |
| 435 | - $privateKey = $this->keyStorage->getSystemUserKey($this->publicShareKeyId . '.privateKey', Encryption::ID); |
|
| 435 | + $privateKey = $this->keyStorage->getSystemUserKey($this->publicShareKeyId.'.privateKey', Encryption::ID); |
|
| 436 | 436 | $privateKey = $this->crypt->decryptPrivateKey($privateKey); |
| 437 | 437 | } else { |
| 438 | 438 | $shareKey = $this->getShareKey($path, $uid); |
@@ -457,7 +457,7 @@ discard block |
||
| 457 | 457 | */ |
| 458 | 458 | public function getVersion($path, View $view) { |
| 459 | 459 | $fileInfo = $view->getFileInfo($path); |
| 460 | - if($fileInfo === false) { |
|
| 460 | + if ($fileInfo === false) { |
|
| 461 | 461 | return 0; |
| 462 | 462 | } |
| 463 | 463 | return $fileInfo->getEncryptedVersion(); |
@@ -471,9 +471,9 @@ discard block |
||
| 471 | 471 | * @param View $view |
| 472 | 472 | */ |
| 473 | 473 | public function setVersion($path, $version, View $view) { |
| 474 | - $fileInfo= $view->getFileInfo($path); |
|
| 474 | + $fileInfo = $view->getFileInfo($path); |
|
| 475 | 475 | |
| 476 | - if($fileInfo !== false) { |
|
| 476 | + if ($fileInfo !== false) { |
|
| 477 | 477 | $cache = $fileInfo->getStorage()->getCache(); |
| 478 | 478 | $cache->update($fileInfo->getId(), ['encrypted' => $version, 'encryptedVersion' => $version]); |
| 479 | 479 | } |
@@ -502,7 +502,7 @@ discard block |
||
| 502 | 502 | public function deleteShareKey($path, $keyId) { |
| 503 | 503 | return $this->keyStorage->deleteFileKey( |
| 504 | 504 | $path, |
| 505 | - $keyId . '.' . $this->shareKeyId, |
|
| 505 | + $keyId.'.'.$this->shareKeyId, |
|
| 506 | 506 | Encryption::ID); |
| 507 | 507 | } |
| 508 | 508 | |
@@ -513,7 +513,7 @@ discard block |
||
| 513 | 513 | * @return mixed |
| 514 | 514 | */ |
| 515 | 515 | public function getShareKey($path, $uid) { |
| 516 | - $keyId = $uid . '.' . $this->shareKeyId; |
|
| 516 | + $keyId = $uid.'.'.$this->shareKeyId; |
|
| 517 | 517 | return $this->keyStorage->getFileKey($path, $keyId, Encryption::ID); |
| 518 | 518 | } |
| 519 | 519 | |
@@ -575,7 +575,7 @@ discard block |
||
| 575 | 575 | * @return string |
| 576 | 576 | */ |
| 577 | 577 | public function getPublicShareKey() { |
| 578 | - return $this->keyStorage->getSystemUserKey($this->publicShareKeyId . '.publicKey', Encryption::ID); |
|
| 578 | + return $this->keyStorage->getSystemUserKey($this->publicShareKeyId.'.publicKey', Encryption::ID); |
|
| 579 | 579 | } |
| 580 | 580 | |
| 581 | 581 | /** |
@@ -645,7 +645,7 @@ discard block |
||
| 645 | 645 | * @return string returns openssl key |
| 646 | 646 | */ |
| 647 | 647 | public function getSystemPrivateKey($keyId) { |
| 648 | - return $this->keyStorage->getSystemUserKey($keyId . '.' . $this->privateKeyId, Encryption::ID); |
|
| 648 | + return $this->keyStorage->getSystemUserKey($keyId.'.'.$this->privateKeyId, Encryption::ID); |
|
| 649 | 649 | } |
| 650 | 650 | |
| 651 | 651 | /** |
@@ -655,7 +655,7 @@ discard block |
||
| 655 | 655 | */ |
| 656 | 656 | public function setSystemPrivateKey($keyId, $key) { |
| 657 | 657 | return $this->keyStorage->setSystemUserKey( |
| 658 | - $keyId . '.' . $this->privateKeyId, |
|
| 658 | + $keyId.'.'.$this->privateKeyId, |
|
| 659 | 659 | $key, |
| 660 | 660 | Encryption::ID); |
| 661 | 661 | } |
@@ -695,7 +695,7 @@ discard block |
||
| 695 | 695 | */ |
| 696 | 696 | public function getMasterKeyPassword() { |
| 697 | 697 | $password = $this->config->getSystemValue('secret'); |
| 698 | - if (empty($password)){ |
|
| 698 | + if (empty($password)) { |
|
| 699 | 699 | throw new \Exception('Can not get secret from Nextcloud instance'); |
| 700 | 700 | } |
| 701 | 701 | |
@@ -717,6 +717,6 @@ discard block |
||
| 717 | 717 | * @return string |
| 718 | 718 | */ |
| 719 | 719 | public function getPublicMasterKey() { |
| 720 | - return $this->keyStorage->getSystemUserKey($this->masterKeyId . '.publicKey', Encryption::ID); |
|
| 720 | + return $this->keyStorage->getSystemUserKey($this->masterKeyId.'.publicKey', Encryption::ID); |
|
| 721 | 721 | } |
| 722 | 722 | } |
@@ -391,7 +391,7 @@ discard block |
||
| 391 | 391 | /** |
| 392 | 392 | * store remote ID in federated reShare table |
| 393 | 393 | * |
| 394 | - * @param $shareId |
|
| 394 | + * @param integer $shareId |
|
| 395 | 395 | * @param $remoteId |
| 396 | 396 | */ |
| 397 | 397 | public function storeRemoteId($shareId, $remoteId) { |
@@ -729,7 +729,7 @@ discard block |
||
| 729 | 729 | /** |
| 730 | 730 | * get database row of a give share |
| 731 | 731 | * |
| 732 | - * @param $id |
|
| 732 | + * @param integer $id |
|
| 733 | 733 | * @return array |
| 734 | 734 | * @throws ShareNotFound |
| 735 | 735 | */ |
@@ -182,7 +182,7 @@ discard block |
||
| 182 | 182 | if ($remoteShare) { |
| 183 | 183 | try { |
| 184 | 184 | $ownerCloudId = $this->cloudIdManager->getCloudId($remoteShare['owner'], $remoteShare['remote']); |
| 185 | - $shareId = $this->addShareToDB($itemSource, $itemType, $shareWith, $sharedBy, $ownerCloudId->getId(), $permissions, 'tmp_token_' . time()); |
|
| 185 | + $shareId = $this->addShareToDB($itemSource, $itemType, $shareWith, $sharedBy, $ownerCloudId->getId(), $permissions, 'tmp_token_'.time()); |
|
| 186 | 186 | $share->setId($shareId); |
| 187 | 187 | list($token, $remoteId) = $this->askOwnerToReShare($shareWith, $share, $shareId); |
| 188 | 188 | // remote share was create successfully if we get a valid token as return |
@@ -254,11 +254,11 @@ discard block |
||
| 254 | 254 | $failure = true; |
| 255 | 255 | } |
| 256 | 256 | } catch (\Exception $e) { |
| 257 | - $this->logger->error('Failed to notify remote server of federated share, removing share (' . $e->getMessage() . ')'); |
|
| 257 | + $this->logger->error('Failed to notify remote server of federated share, removing share ('.$e->getMessage().')'); |
|
| 258 | 258 | $failure = true; |
| 259 | 259 | } |
| 260 | 260 | |
| 261 | - if($failure) { |
|
| 261 | + if ($failure) { |
|
| 262 | 262 | $this->removeShareFromTableById($shareId); |
| 263 | 263 | $message_t = $this->l->t('Sharing %s failed, could not find %s, maybe the server is currently unreachable or uses a self-signed certificate.', |
| 264 | 264 | [$share->getNode()->getName(), $share->getSharedWith()]); |
@@ -309,7 +309,7 @@ discard block |
||
| 309 | 309 | ->andWhere($query->expr()->eq('mountpoint', $query->createNamedParameter($share->getTarget()))); |
| 310 | 310 | $result = $query->execute()->fetchAll(); |
| 311 | 311 | |
| 312 | - if (isset($result[0]) && (int)$result[0]['remote_id'] > 0) { |
|
| 312 | + if (isset($result[0]) && (int) $result[0]['remote_id'] > 0) { |
|
| 313 | 313 | return $result[0]; |
| 314 | 314 | } |
| 315 | 315 | |
@@ -351,7 +351,7 @@ discard block |
||
| 351 | 351 | $qb->execute(); |
| 352 | 352 | $id = $qb->getLastInsertId(); |
| 353 | 353 | |
| 354 | - return (int)$id; |
|
| 354 | + return (int) $id; |
|
| 355 | 355 | } |
| 356 | 356 | |
| 357 | 357 | /** |
@@ -441,14 +441,14 @@ discard block |
||
| 441 | 441 | public function getRemoteId(IShare $share) { |
| 442 | 442 | $query = $this->dbConnection->getQueryBuilder(); |
| 443 | 443 | $query->select('remote_id')->from('federated_reshares') |
| 444 | - ->where($query->expr()->eq('share_id', $query->createNamedParameter((int)$share->getId()))); |
|
| 444 | + ->where($query->expr()->eq('share_id', $query->createNamedParameter((int) $share->getId()))); |
|
| 445 | 445 | $data = $query->execute()->fetch(); |
| 446 | 446 | |
| 447 | 447 | if (!is_array($data) || !isset($data['remote_id'])) { |
| 448 | 448 | throw new ShareNotFound(); |
| 449 | 449 | } |
| 450 | 450 | |
| 451 | - return (int)$data['remote_id']; |
|
| 451 | + return (int) $data['remote_id']; |
|
| 452 | 452 | } |
| 453 | 453 | |
| 454 | 454 | /** |
@@ -479,7 +479,7 @@ discard block |
||
| 479 | 479 | ->orderBy('id'); |
| 480 | 480 | |
| 481 | 481 | $cursor = $qb->execute(); |
| 482 | - while($data = $cursor->fetch()) { |
|
| 482 | + while ($data = $cursor->fetch()) { |
|
| 483 | 483 | $children[] = $this->createShareObject($data); |
| 484 | 484 | } |
| 485 | 485 | $cursor->closeCursor(); |
@@ -608,7 +608,7 @@ discard block |
||
| 608 | 608 | ); |
| 609 | 609 | } |
| 610 | 610 | |
| 611 | - $qb->innerJoin('s', 'filecache' ,'f', $qb->expr()->eq('s.file_source', 'f.fileid')); |
|
| 611 | + $qb->innerJoin('s', 'filecache', 'f', $qb->expr()->eq('s.file_source', 'f.fileid')); |
|
| 612 | 612 | $qb->andWhere($qb->expr()->eq('f.parent', $qb->createNamedParameter($node->getId()))); |
| 613 | 613 | |
| 614 | 614 | $qb->orderBy('id'); |
@@ -671,7 +671,7 @@ discard block |
||
| 671 | 671 | |
| 672 | 672 | $cursor = $qb->execute(); |
| 673 | 673 | $shares = []; |
| 674 | - while($data = $cursor->fetch()) { |
|
| 674 | + while ($data = $cursor->fetch()) { |
|
| 675 | 675 | $shares[] = $this->createShareObject($data); |
| 676 | 676 | } |
| 677 | 677 | $cursor->closeCursor(); |
@@ -723,7 +723,7 @@ discard block |
||
| 723 | 723 | ->execute(); |
| 724 | 724 | |
| 725 | 725 | $shares = []; |
| 726 | - while($data = $cursor->fetch()) { |
|
| 726 | + while ($data = $cursor->fetch()) { |
|
| 727 | 727 | $shares[] = $this->createShareObject($data); |
| 728 | 728 | } |
| 729 | 729 | $cursor->closeCursor(); |
@@ -762,7 +762,7 @@ discard block |
||
| 762 | 762 | |
| 763 | 763 | $cursor = $qb->execute(); |
| 764 | 764 | |
| 765 | - while($data = $cursor->fetch()) { |
|
| 765 | + while ($data = $cursor->fetch()) { |
|
| 766 | 766 | $shares[] = $this->createShareObject($data); |
| 767 | 767 | } |
| 768 | 768 | $cursor->closeCursor(); |
@@ -839,15 +839,15 @@ discard block |
||
| 839 | 839 | private function createShareObject($data) { |
| 840 | 840 | |
| 841 | 841 | $share = new Share($this->rootFolder, $this->userManager); |
| 842 | - $share->setId((int)$data['id']) |
|
| 843 | - ->setShareType((int)$data['share_type']) |
|
| 844 | - ->setPermissions((int)$data['permissions']) |
|
| 842 | + $share->setId((int) $data['id']) |
|
| 843 | + ->setShareType((int) $data['share_type']) |
|
| 844 | + ->setPermissions((int) $data['permissions']) |
|
| 845 | 845 | ->setTarget($data['file_target']) |
| 846 | - ->setMailSend((bool)$data['mail_send']) |
|
| 846 | + ->setMailSend((bool) $data['mail_send']) |
|
| 847 | 847 | ->setToken($data['token']); |
| 848 | 848 | |
| 849 | 849 | $shareTime = new \DateTime(); |
| 850 | - $shareTime->setTimestamp((int)$data['stime']); |
|
| 850 | + $shareTime->setTimestamp((int) $data['stime']); |
|
| 851 | 851 | $share->setShareTime($shareTime); |
| 852 | 852 | $share->setSharedWith($data['share_with']); |
| 853 | 853 | |
@@ -857,13 +857,13 @@ discard block |
||
| 857 | 857 | } else { |
| 858 | 858 | //OLD SHARE |
| 859 | 859 | $share->setSharedBy($data['uid_owner']); |
| 860 | - $path = $this->getNode($share->getSharedBy(), (int)$data['file_source']); |
|
| 860 | + $path = $this->getNode($share->getSharedBy(), (int) $data['file_source']); |
|
| 861 | 861 | |
| 862 | 862 | $owner = $path->getOwner(); |
| 863 | 863 | $share->setShareOwner($owner->getUID()); |
| 864 | 864 | } |
| 865 | 865 | |
| 866 | - $share->setNodeId((int)$data['file_source']); |
|
| 866 | + $share->setNodeId((int) $data['file_source']); |
|
| 867 | 867 | $share->setNodeType($data['item_type']); |
| 868 | 868 | |
| 869 | 869 | $share->setProviderId($this->identifier()); |