@@ -51,377 +51,377 @@ |
||
| 51 | 51 | * |
| 52 | 52 | */ |
| 53 | 53 | class OC_Files { |
| 54 | - public const FILE = 1; |
|
| 55 | - public const ZIP_FILES = 2; |
|
| 56 | - public const ZIP_DIR = 3; |
|
| 57 | - |
|
| 58 | - public const UPLOAD_MIN_LIMIT_BYTES = 1048576; // 1 MiB |
|
| 59 | - |
|
| 60 | - |
|
| 61 | - private static $multipartBoundary = ''; |
|
| 62 | - |
|
| 63 | - /** |
|
| 64 | - * @return string |
|
| 65 | - */ |
|
| 66 | - private static function getBoundary() { |
|
| 67 | - if (empty(self::$multipartBoundary)) { |
|
| 68 | - self::$multipartBoundary = md5(mt_rand()); |
|
| 69 | - } |
|
| 70 | - return self::$multipartBoundary; |
|
| 71 | - } |
|
| 72 | - |
|
| 73 | - /** |
|
| 74 | - * @param string $filename |
|
| 75 | - * @param string $name |
|
| 76 | - * @param array $rangeArray ('from'=>int,'to'=>int), ... |
|
| 77 | - */ |
|
| 78 | - private static function sendHeaders($filename, $name, array $rangeArray) { |
|
| 79 | - OC_Response::setContentDispositionHeader($name, 'attachment'); |
|
| 80 | - header('Content-Transfer-Encoding: binary', true); |
|
| 81 | - header('Pragma: public');// enable caching in IE |
|
| 82 | - header('Expires: 0'); |
|
| 83 | - header("Cache-Control: must-revalidate, post-check=0, pre-check=0"); |
|
| 84 | - $fileSize = \OC\Files\Filesystem::filesize($filename); |
|
| 85 | - $type = \OC::$server->getMimeTypeDetector()->getSecureMimeType(\OC\Files\Filesystem::getMimeType($filename)); |
|
| 86 | - if ($fileSize > -1) { |
|
| 87 | - if (!empty($rangeArray)) { |
|
| 88 | - http_response_code(206); |
|
| 89 | - header('Accept-Ranges: bytes', true); |
|
| 90 | - if (count($rangeArray) > 1) { |
|
| 91 | - $type = 'multipart/byteranges; boundary='.self::getBoundary(); |
|
| 92 | - // no Content-Length header here |
|
| 93 | - } else { |
|
| 94 | - header(sprintf('Content-Range: bytes %d-%d/%d', $rangeArray[0]['from'], $rangeArray[0]['to'], $fileSize), true); |
|
| 95 | - OC_Response::setContentLengthHeader($rangeArray[0]['to'] - $rangeArray[0]['from'] + 1); |
|
| 96 | - } |
|
| 97 | - } else { |
|
| 98 | - OC_Response::setContentLengthHeader($fileSize); |
|
| 99 | - } |
|
| 100 | - } |
|
| 101 | - header('Content-Type: '.$type, true); |
|
| 102 | - } |
|
| 103 | - |
|
| 104 | - /** |
|
| 105 | - * return the content of a file or return a zip file containing multiple files |
|
| 106 | - * |
|
| 107 | - * @param string $dir |
|
| 108 | - * @param string $files ; separated list of files to download |
|
| 109 | - * @param array $params ; 'head' boolean to only send header of the request ; 'range' http range header |
|
| 110 | - */ |
|
| 111 | - public static function get($dir, $files, $params = null) { |
|
| 112 | - OC_Util::setupFS(); |
|
| 113 | - $view = \OC\Files\Filesystem::getView(); |
|
| 114 | - $getType = self::FILE; |
|
| 115 | - $filename = $dir; |
|
| 116 | - try { |
|
| 117 | - if (is_array($files) && count($files) === 1) { |
|
| 118 | - $files = $files[0]; |
|
| 119 | - } |
|
| 120 | - |
|
| 121 | - if (!is_array($files)) { |
|
| 122 | - $filename = $dir . '/' . $files; |
|
| 123 | - if (!$view->is_dir($filename)) { |
|
| 124 | - self::getSingleFile($view, $dir, $files, is_null($params) ? [] : $params); |
|
| 125 | - return; |
|
| 126 | - } |
|
| 127 | - } |
|
| 128 | - |
|
| 129 | - $name = 'download'; |
|
| 130 | - if (is_array($files)) { |
|
| 131 | - $getType = self::ZIP_FILES; |
|
| 132 | - $basename = basename($dir); |
|
| 133 | - if ($basename) { |
|
| 134 | - $name = $basename; |
|
| 135 | - } |
|
| 136 | - |
|
| 137 | - $filename = $dir . '/' . $name; |
|
| 138 | - } else { |
|
| 139 | - $filename = $dir . '/' . $files; |
|
| 140 | - $getType = self::ZIP_DIR; |
|
| 141 | - // downloading root ? |
|
| 142 | - if ($files !== '') { |
|
| 143 | - $name = $files; |
|
| 144 | - } |
|
| 145 | - } |
|
| 146 | - |
|
| 147 | - self::lockFiles($view, $dir, $files); |
|
| 148 | - |
|
| 149 | - /* Calculate filesize and number of files */ |
|
| 150 | - if ($getType === self::ZIP_FILES) { |
|
| 151 | - $fileInfos = []; |
|
| 152 | - $fileSize = 0; |
|
| 153 | - foreach ($files as $file) { |
|
| 154 | - $fileInfo = \OC\Files\Filesystem::getFileInfo($dir . '/' . $file); |
|
| 155 | - $fileSize += $fileInfo->getSize(); |
|
| 156 | - $fileInfos[] = $fileInfo; |
|
| 157 | - } |
|
| 158 | - $numberOfFiles = self::getNumberOfFiles($fileInfos); |
|
| 159 | - } elseif ($getType === self::ZIP_DIR) { |
|
| 160 | - $fileInfo = \OC\Files\Filesystem::getFileInfo($dir . '/' . $files); |
|
| 161 | - $fileSize = $fileInfo->getSize(); |
|
| 162 | - $numberOfFiles = self::getNumberOfFiles([$fileInfo]); |
|
| 163 | - } |
|
| 164 | - |
|
| 165 | - $streamer = new Streamer(\OC::$server->getRequest(), $fileSize, $numberOfFiles); |
|
| 166 | - OC_Util::obEnd(); |
|
| 167 | - |
|
| 168 | - $streamer->sendHeaders($name); |
|
| 169 | - $executionTime = (int)OC::$server->get(IniGetWrapper::class)->getNumeric('max_execution_time'); |
|
| 170 | - if (strpos(@ini_get('disable_functions'), 'set_time_limit') === false) { |
|
| 171 | - @set_time_limit(0); |
|
| 172 | - } |
|
| 173 | - ignore_user_abort(true); |
|
| 174 | - |
|
| 175 | - if ($getType === self::ZIP_FILES) { |
|
| 176 | - foreach ($files as $file) { |
|
| 177 | - $file = $dir . '/' . $file; |
|
| 178 | - if (\OC\Files\Filesystem::is_file($file)) { |
|
| 179 | - $userFolder = \OC::$server->getRootFolder()->get(\OC\Files\Filesystem::getRoot()); |
|
| 180 | - $file = $userFolder->get($file); |
|
| 181 | - if ($file instanceof \OC\Files\Node\File) { |
|
| 182 | - try { |
|
| 183 | - $fh = $file->fopen('r'); |
|
| 184 | - } catch (\OCP\Files\NotPermittedException $e) { |
|
| 185 | - continue; |
|
| 186 | - } |
|
| 187 | - $fileSize = $file->getSize(); |
|
| 188 | - $fileTime = $file->getMTime(); |
|
| 189 | - } else { |
|
| 190 | - // File is not a file? … |
|
| 191 | - \OC::$server->getLogger()->debug( |
|
| 192 | - 'File given, but no Node available. Name {file}', |
|
| 193 | - [ 'app' => 'files', 'file' => $file ] |
|
| 194 | - ); |
|
| 195 | - continue; |
|
| 196 | - } |
|
| 197 | - $streamer->addFileFromStream($fh, $file->getName(), $fileSize, $fileTime); |
|
| 198 | - fclose($fh); |
|
| 199 | - } elseif (\OC\Files\Filesystem::is_dir($file)) { |
|
| 200 | - $streamer->addDirRecursive($file); |
|
| 201 | - } |
|
| 202 | - } |
|
| 203 | - } elseif ($getType === self::ZIP_DIR) { |
|
| 204 | - $file = $dir . '/' . $files; |
|
| 205 | - $streamer->addDirRecursive($file); |
|
| 206 | - } |
|
| 207 | - $streamer->finalize(); |
|
| 208 | - set_time_limit($executionTime); |
|
| 209 | - self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 210 | - } catch (\OCP\Lock\LockedException $ex) { |
|
| 211 | - self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 212 | - OC::$server->getLogger()->logException($ex); |
|
| 213 | - $l = \OC::$server->getL10N('lib'); |
|
| 214 | - $hint = method_exists($ex, 'getHint') ? $ex->getHint() : ''; |
|
| 215 | - \OC_Template::printErrorPage($l->t('File is currently busy, please try again later'), $hint, 200); |
|
| 216 | - } catch (\OCP\Files\ForbiddenException $ex) { |
|
| 217 | - self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 218 | - OC::$server->getLogger()->logException($ex); |
|
| 219 | - $l = \OC::$server->getL10N('lib'); |
|
| 220 | - \OC_Template::printErrorPage($l->t('Can\'t read file'), $ex->getMessage(), 200); |
|
| 221 | - } catch (\Exception $ex) { |
|
| 222 | - self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 223 | - OC::$server->getLogger()->logException($ex); |
|
| 224 | - $l = \OC::$server->getL10N('lib'); |
|
| 225 | - $hint = method_exists($ex, 'getHint') ? $ex->getHint() : ''; |
|
| 226 | - \OC_Template::printErrorPage($l->t('Can\'t read file'), $hint, 200); |
|
| 227 | - } |
|
| 228 | - } |
|
| 229 | - |
|
| 230 | - /** |
|
| 231 | - * @param string $rangeHeaderPos |
|
| 232 | - * @param int $fileSize |
|
| 233 | - * @return array $rangeArray ('from'=>int,'to'=>int), ... |
|
| 234 | - */ |
|
| 235 | - private static function parseHttpRangeHeader($rangeHeaderPos, $fileSize) { |
|
| 236 | - $rArray = explode(',', $rangeHeaderPos); |
|
| 237 | - $minOffset = 0; |
|
| 238 | - $ind = 0; |
|
| 239 | - |
|
| 240 | - $rangeArray = []; |
|
| 241 | - |
|
| 242 | - foreach ($rArray as $value) { |
|
| 243 | - $ranges = explode('-', $value); |
|
| 244 | - if (is_numeric($ranges[0])) { |
|
| 245 | - if ($ranges[0] < $minOffset) { // case: bytes=500-700,601-999 |
|
| 246 | - $ranges[0] = $minOffset; |
|
| 247 | - } |
|
| 248 | - if ($ind > 0 && $rangeArray[$ind - 1]['to'] + 1 == $ranges[0]) { // case: bytes=500-600,601-999 |
|
| 249 | - $ind--; |
|
| 250 | - $ranges[0] = $rangeArray[$ind]['from']; |
|
| 251 | - } |
|
| 252 | - } |
|
| 253 | - |
|
| 254 | - if (is_numeric($ranges[0]) && is_numeric($ranges[1]) && $ranges[0] < $fileSize && $ranges[0] <= $ranges[1]) { |
|
| 255 | - // case: x-x |
|
| 256 | - if ($ranges[1] >= $fileSize) { |
|
| 257 | - $ranges[1] = $fileSize - 1; |
|
| 258 | - } |
|
| 259 | - $rangeArray[$ind++] = [ 'from' => $ranges[0], 'to' => $ranges[1], 'size' => $fileSize ]; |
|
| 260 | - $minOffset = $ranges[1] + 1; |
|
| 261 | - if ($minOffset >= $fileSize) { |
|
| 262 | - break; |
|
| 263 | - } |
|
| 264 | - } elseif (is_numeric($ranges[0]) && $ranges[0] < $fileSize) { |
|
| 265 | - // case: x- |
|
| 266 | - $rangeArray[$ind++] = [ 'from' => $ranges[0], 'to' => $fileSize - 1, 'size' => $fileSize ]; |
|
| 267 | - break; |
|
| 268 | - } elseif (is_numeric($ranges[1])) { |
|
| 269 | - // case: -x |
|
| 270 | - if ($ranges[1] > $fileSize) { |
|
| 271 | - $ranges[1] = $fileSize; |
|
| 272 | - } |
|
| 273 | - $rangeArray[$ind++] = [ 'from' => $fileSize - $ranges[1], 'to' => $fileSize - 1, 'size' => $fileSize ]; |
|
| 274 | - break; |
|
| 275 | - } |
|
| 276 | - } |
|
| 277 | - return $rangeArray; |
|
| 278 | - } |
|
| 279 | - |
|
| 280 | - /** |
|
| 281 | - * @param View $view |
|
| 282 | - * @param string $name |
|
| 283 | - * @param string $dir |
|
| 284 | - * @param array $params ; 'head' boolean to only send header of the request ; 'range' http range header |
|
| 285 | - */ |
|
| 286 | - private static function getSingleFile($view, $dir, $name, $params) { |
|
| 287 | - $filename = $dir . '/' . $name; |
|
| 288 | - $file = null; |
|
| 289 | - |
|
| 290 | - try { |
|
| 291 | - $userFolder = \OC::$server->getRootFolder()->get(\OC\Files\Filesystem::getRoot()); |
|
| 292 | - $file = $userFolder->get($filename); |
|
| 293 | - if (!$file instanceof \OC\Files\Node\File || !$file->isReadable()) { |
|
| 294 | - http_response_code(403); |
|
| 295 | - die('403 Forbidden'); |
|
| 296 | - } |
|
| 297 | - $fileSize = $file->getSize(); |
|
| 298 | - } catch (\OCP\Files\NotPermittedException $e) { |
|
| 299 | - http_response_code(403); |
|
| 300 | - die('403 Forbidden'); |
|
| 301 | - } catch (\OCP\Files\InvalidPathException $e) { |
|
| 302 | - http_response_code(403); |
|
| 303 | - die('403 Forbidden'); |
|
| 304 | - } catch (\OCP\Files\NotFoundException $e) { |
|
| 305 | - http_response_code(404); |
|
| 306 | - $tmpl = new OC_Template('', '404', 'guest'); |
|
| 307 | - $tmpl->printPage(); |
|
| 308 | - exit(); |
|
| 309 | - } |
|
| 310 | - |
|
| 311 | - OC_Util::obEnd(); |
|
| 312 | - $view->lockFile($filename, ILockingProvider::LOCK_SHARED); |
|
| 313 | - |
|
| 314 | - $rangeArray = []; |
|
| 315 | - |
|
| 316 | - if (isset($params['range']) && substr($params['range'], 0, 6) === 'bytes=') { |
|
| 317 | - $rangeArray = self::parseHttpRangeHeader(substr($params['range'], 6), $fileSize); |
|
| 318 | - } |
|
| 319 | - |
|
| 320 | - self::sendHeaders($filename, $name, $rangeArray); |
|
| 321 | - |
|
| 322 | - if (isset($params['head']) && $params['head']) { |
|
| 323 | - return; |
|
| 324 | - } |
|
| 325 | - |
|
| 326 | - if (!empty($rangeArray)) { |
|
| 327 | - try { |
|
| 328 | - if (count($rangeArray) == 1) { |
|
| 329 | - $view->readfilePart($filename, $rangeArray[0]['from'], $rangeArray[0]['to']); |
|
| 330 | - } else { |
|
| 331 | - // check if file is seekable (if not throw UnseekableException) |
|
| 332 | - // we have to check it before body contents |
|
| 333 | - $view->readfilePart($filename, $rangeArray[0]['size'], $rangeArray[0]['size']); |
|
| 334 | - |
|
| 335 | - $type = \OC::$server->getMimeTypeDetector()->getSecureMimeType(\OC\Files\Filesystem::getMimeType($filename)); |
|
| 336 | - |
|
| 337 | - foreach ($rangeArray as $range) { |
|
| 338 | - echo "\r\n--".self::getBoundary()."\r\n". |
|
| 339 | - "Content-type: ".$type."\r\n". |
|
| 340 | - "Content-range: bytes ".$range['from']."-".$range['to']."/".$range['size']."\r\n\r\n"; |
|
| 341 | - $view->readfilePart($filename, $range['from'], $range['to']); |
|
| 342 | - } |
|
| 343 | - echo "\r\n--".self::getBoundary()."--\r\n"; |
|
| 344 | - } |
|
| 345 | - } catch (\OCP\Files\UnseekableException $ex) { |
|
| 346 | - // file is unseekable |
|
| 347 | - header_remove('Accept-Ranges'); |
|
| 348 | - header_remove('Content-Range'); |
|
| 349 | - http_response_code(200); |
|
| 350 | - self::sendHeaders($filename, $name, []); |
|
| 351 | - $view->readfile($filename); |
|
| 352 | - } |
|
| 353 | - } else { |
|
| 354 | - $view->readfile($filename); |
|
| 355 | - } |
|
| 356 | - } |
|
| 357 | - |
|
| 358 | - /** |
|
| 359 | - * Returns the total (recursive) number of files and folders in the given |
|
| 360 | - * FileInfos. |
|
| 361 | - * |
|
| 362 | - * @param \OCP\Files\FileInfo[] $fileInfos the FileInfos to count |
|
| 363 | - * @return int the total number of files and folders |
|
| 364 | - */ |
|
| 365 | - private static function getNumberOfFiles($fileInfos) { |
|
| 366 | - $numberOfFiles = 0; |
|
| 367 | - |
|
| 368 | - $view = new View(); |
|
| 369 | - |
|
| 370 | - while ($fileInfo = array_pop($fileInfos)) { |
|
| 371 | - $numberOfFiles++; |
|
| 372 | - |
|
| 373 | - if ($fileInfo->getType() === \OCP\Files\FileInfo::TYPE_FOLDER) { |
|
| 374 | - $fileInfos = array_merge($fileInfos, $view->getDirectoryContent($fileInfo->getPath())); |
|
| 375 | - } |
|
| 376 | - } |
|
| 377 | - |
|
| 378 | - return $numberOfFiles; |
|
| 379 | - } |
|
| 380 | - |
|
| 381 | - /** |
|
| 382 | - * @param View $view |
|
| 383 | - * @param string $dir |
|
| 384 | - * @param string[]|string $files |
|
| 385 | - */ |
|
| 386 | - public static function lockFiles($view, $dir, $files) { |
|
| 387 | - if (!is_array($files)) { |
|
| 388 | - $file = $dir . '/' . $files; |
|
| 389 | - $files = [$file]; |
|
| 390 | - } |
|
| 391 | - foreach ($files as $file) { |
|
| 392 | - $file = $dir . '/' . $file; |
|
| 393 | - $view->lockFile($file, ILockingProvider::LOCK_SHARED); |
|
| 394 | - if ($view->is_dir($file)) { |
|
| 395 | - $contents = $view->getDirectoryContent($file); |
|
| 396 | - $contents = array_map(function ($fileInfo) use ($file) { |
|
| 397 | - /** @var \OCP\Files\FileInfo $fileInfo */ |
|
| 398 | - return $file . '/' . $fileInfo->getName(); |
|
| 399 | - }, $contents); |
|
| 400 | - self::lockFiles($view, $dir, $contents); |
|
| 401 | - } |
|
| 402 | - } |
|
| 403 | - } |
|
| 404 | - |
|
| 405 | - /** |
|
| 406 | - * @param string $dir |
|
| 407 | - * @param $files |
|
| 408 | - * @param integer $getType |
|
| 409 | - * @param View $view |
|
| 410 | - * @param string $filename |
|
| 411 | - */ |
|
| 412 | - private static function unlockAllTheFiles($dir, $files, $getType, $view, $filename) { |
|
| 413 | - if ($getType === self::FILE) { |
|
| 414 | - $view->unlockFile($filename, ILockingProvider::LOCK_SHARED); |
|
| 415 | - } |
|
| 416 | - if ($getType === self::ZIP_FILES) { |
|
| 417 | - foreach ($files as $file) { |
|
| 418 | - $file = $dir . '/' . $file; |
|
| 419 | - $view->unlockFile($file, ILockingProvider::LOCK_SHARED); |
|
| 420 | - } |
|
| 421 | - } |
|
| 422 | - if ($getType === self::ZIP_DIR) { |
|
| 423 | - $file = $dir . '/' . $files; |
|
| 424 | - $view->unlockFile($file, ILockingProvider::LOCK_SHARED); |
|
| 425 | - } |
|
| 426 | - } |
|
| 54 | + public const FILE = 1; |
|
| 55 | + public const ZIP_FILES = 2; |
|
| 56 | + public const ZIP_DIR = 3; |
|
| 57 | + |
|
| 58 | + public const UPLOAD_MIN_LIMIT_BYTES = 1048576; // 1 MiB |
|
| 59 | + |
|
| 60 | + |
|
| 61 | + private static $multipartBoundary = ''; |
|
| 62 | + |
|
| 63 | + /** |
|
| 64 | + * @return string |
|
| 65 | + */ |
|
| 66 | + private static function getBoundary() { |
|
| 67 | + if (empty(self::$multipartBoundary)) { |
|
| 68 | + self::$multipartBoundary = md5(mt_rand()); |
|
| 69 | + } |
|
| 70 | + return self::$multipartBoundary; |
|
| 71 | + } |
|
| 72 | + |
|
| 73 | + /** |
|
| 74 | + * @param string $filename |
|
| 75 | + * @param string $name |
|
| 76 | + * @param array $rangeArray ('from'=>int,'to'=>int), ... |
|
| 77 | + */ |
|
| 78 | + private static function sendHeaders($filename, $name, array $rangeArray) { |
|
| 79 | + OC_Response::setContentDispositionHeader($name, 'attachment'); |
|
| 80 | + header('Content-Transfer-Encoding: binary', true); |
|
| 81 | + header('Pragma: public');// enable caching in IE |
|
| 82 | + header('Expires: 0'); |
|
| 83 | + header("Cache-Control: must-revalidate, post-check=0, pre-check=0"); |
|
| 84 | + $fileSize = \OC\Files\Filesystem::filesize($filename); |
|
| 85 | + $type = \OC::$server->getMimeTypeDetector()->getSecureMimeType(\OC\Files\Filesystem::getMimeType($filename)); |
|
| 86 | + if ($fileSize > -1) { |
|
| 87 | + if (!empty($rangeArray)) { |
|
| 88 | + http_response_code(206); |
|
| 89 | + header('Accept-Ranges: bytes', true); |
|
| 90 | + if (count($rangeArray) > 1) { |
|
| 91 | + $type = 'multipart/byteranges; boundary='.self::getBoundary(); |
|
| 92 | + // no Content-Length header here |
|
| 93 | + } else { |
|
| 94 | + header(sprintf('Content-Range: bytes %d-%d/%d', $rangeArray[0]['from'], $rangeArray[0]['to'], $fileSize), true); |
|
| 95 | + OC_Response::setContentLengthHeader($rangeArray[0]['to'] - $rangeArray[0]['from'] + 1); |
|
| 96 | + } |
|
| 97 | + } else { |
|
| 98 | + OC_Response::setContentLengthHeader($fileSize); |
|
| 99 | + } |
|
| 100 | + } |
|
| 101 | + header('Content-Type: '.$type, true); |
|
| 102 | + } |
|
| 103 | + |
|
| 104 | + /** |
|
| 105 | + * return the content of a file or return a zip file containing multiple files |
|
| 106 | + * |
|
| 107 | + * @param string $dir |
|
| 108 | + * @param string $files ; separated list of files to download |
|
| 109 | + * @param array $params ; 'head' boolean to only send header of the request ; 'range' http range header |
|
| 110 | + */ |
|
| 111 | + public static function get($dir, $files, $params = null) { |
|
| 112 | + OC_Util::setupFS(); |
|
| 113 | + $view = \OC\Files\Filesystem::getView(); |
|
| 114 | + $getType = self::FILE; |
|
| 115 | + $filename = $dir; |
|
| 116 | + try { |
|
| 117 | + if (is_array($files) && count($files) === 1) { |
|
| 118 | + $files = $files[0]; |
|
| 119 | + } |
|
| 120 | + |
|
| 121 | + if (!is_array($files)) { |
|
| 122 | + $filename = $dir . '/' . $files; |
|
| 123 | + if (!$view->is_dir($filename)) { |
|
| 124 | + self::getSingleFile($view, $dir, $files, is_null($params) ? [] : $params); |
|
| 125 | + return; |
|
| 126 | + } |
|
| 127 | + } |
|
| 128 | + |
|
| 129 | + $name = 'download'; |
|
| 130 | + if (is_array($files)) { |
|
| 131 | + $getType = self::ZIP_FILES; |
|
| 132 | + $basename = basename($dir); |
|
| 133 | + if ($basename) { |
|
| 134 | + $name = $basename; |
|
| 135 | + } |
|
| 136 | + |
|
| 137 | + $filename = $dir . '/' . $name; |
|
| 138 | + } else { |
|
| 139 | + $filename = $dir . '/' . $files; |
|
| 140 | + $getType = self::ZIP_DIR; |
|
| 141 | + // downloading root ? |
|
| 142 | + if ($files !== '') { |
|
| 143 | + $name = $files; |
|
| 144 | + } |
|
| 145 | + } |
|
| 146 | + |
|
| 147 | + self::lockFiles($view, $dir, $files); |
|
| 148 | + |
|
| 149 | + /* Calculate filesize and number of files */ |
|
| 150 | + if ($getType === self::ZIP_FILES) { |
|
| 151 | + $fileInfos = []; |
|
| 152 | + $fileSize = 0; |
|
| 153 | + foreach ($files as $file) { |
|
| 154 | + $fileInfo = \OC\Files\Filesystem::getFileInfo($dir . '/' . $file); |
|
| 155 | + $fileSize += $fileInfo->getSize(); |
|
| 156 | + $fileInfos[] = $fileInfo; |
|
| 157 | + } |
|
| 158 | + $numberOfFiles = self::getNumberOfFiles($fileInfos); |
|
| 159 | + } elseif ($getType === self::ZIP_DIR) { |
|
| 160 | + $fileInfo = \OC\Files\Filesystem::getFileInfo($dir . '/' . $files); |
|
| 161 | + $fileSize = $fileInfo->getSize(); |
|
| 162 | + $numberOfFiles = self::getNumberOfFiles([$fileInfo]); |
|
| 163 | + } |
|
| 164 | + |
|
| 165 | + $streamer = new Streamer(\OC::$server->getRequest(), $fileSize, $numberOfFiles); |
|
| 166 | + OC_Util::obEnd(); |
|
| 167 | + |
|
| 168 | + $streamer->sendHeaders($name); |
|
| 169 | + $executionTime = (int)OC::$server->get(IniGetWrapper::class)->getNumeric('max_execution_time'); |
|
| 170 | + if (strpos(@ini_get('disable_functions'), 'set_time_limit') === false) { |
|
| 171 | + @set_time_limit(0); |
|
| 172 | + } |
|
| 173 | + ignore_user_abort(true); |
|
| 174 | + |
|
| 175 | + if ($getType === self::ZIP_FILES) { |
|
| 176 | + foreach ($files as $file) { |
|
| 177 | + $file = $dir . '/' . $file; |
|
| 178 | + if (\OC\Files\Filesystem::is_file($file)) { |
|
| 179 | + $userFolder = \OC::$server->getRootFolder()->get(\OC\Files\Filesystem::getRoot()); |
|
| 180 | + $file = $userFolder->get($file); |
|
| 181 | + if ($file instanceof \OC\Files\Node\File) { |
|
| 182 | + try { |
|
| 183 | + $fh = $file->fopen('r'); |
|
| 184 | + } catch (\OCP\Files\NotPermittedException $e) { |
|
| 185 | + continue; |
|
| 186 | + } |
|
| 187 | + $fileSize = $file->getSize(); |
|
| 188 | + $fileTime = $file->getMTime(); |
|
| 189 | + } else { |
|
| 190 | + // File is not a file? … |
|
| 191 | + \OC::$server->getLogger()->debug( |
|
| 192 | + 'File given, but no Node available. Name {file}', |
|
| 193 | + [ 'app' => 'files', 'file' => $file ] |
|
| 194 | + ); |
|
| 195 | + continue; |
|
| 196 | + } |
|
| 197 | + $streamer->addFileFromStream($fh, $file->getName(), $fileSize, $fileTime); |
|
| 198 | + fclose($fh); |
|
| 199 | + } elseif (\OC\Files\Filesystem::is_dir($file)) { |
|
| 200 | + $streamer->addDirRecursive($file); |
|
| 201 | + } |
|
| 202 | + } |
|
| 203 | + } elseif ($getType === self::ZIP_DIR) { |
|
| 204 | + $file = $dir . '/' . $files; |
|
| 205 | + $streamer->addDirRecursive($file); |
|
| 206 | + } |
|
| 207 | + $streamer->finalize(); |
|
| 208 | + set_time_limit($executionTime); |
|
| 209 | + self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 210 | + } catch (\OCP\Lock\LockedException $ex) { |
|
| 211 | + self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 212 | + OC::$server->getLogger()->logException($ex); |
|
| 213 | + $l = \OC::$server->getL10N('lib'); |
|
| 214 | + $hint = method_exists($ex, 'getHint') ? $ex->getHint() : ''; |
|
| 215 | + \OC_Template::printErrorPage($l->t('File is currently busy, please try again later'), $hint, 200); |
|
| 216 | + } catch (\OCP\Files\ForbiddenException $ex) { |
|
| 217 | + self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 218 | + OC::$server->getLogger()->logException($ex); |
|
| 219 | + $l = \OC::$server->getL10N('lib'); |
|
| 220 | + \OC_Template::printErrorPage($l->t('Can\'t read file'), $ex->getMessage(), 200); |
|
| 221 | + } catch (\Exception $ex) { |
|
| 222 | + self::unlockAllTheFiles($dir, $files, $getType, $view, $filename); |
|
| 223 | + OC::$server->getLogger()->logException($ex); |
|
| 224 | + $l = \OC::$server->getL10N('lib'); |
|
| 225 | + $hint = method_exists($ex, 'getHint') ? $ex->getHint() : ''; |
|
| 226 | + \OC_Template::printErrorPage($l->t('Can\'t read file'), $hint, 200); |
|
| 227 | + } |
|
| 228 | + } |
|
| 229 | + |
|
| 230 | + /** |
|
| 231 | + * @param string $rangeHeaderPos |
|
| 232 | + * @param int $fileSize |
|
| 233 | + * @return array $rangeArray ('from'=>int,'to'=>int), ... |
|
| 234 | + */ |
|
| 235 | + private static function parseHttpRangeHeader($rangeHeaderPos, $fileSize) { |
|
| 236 | + $rArray = explode(',', $rangeHeaderPos); |
|
| 237 | + $minOffset = 0; |
|
| 238 | + $ind = 0; |
|
| 239 | + |
|
| 240 | + $rangeArray = []; |
|
| 241 | + |
|
| 242 | + foreach ($rArray as $value) { |
|
| 243 | + $ranges = explode('-', $value); |
|
| 244 | + if (is_numeric($ranges[0])) { |
|
| 245 | + if ($ranges[0] < $minOffset) { // case: bytes=500-700,601-999 |
|
| 246 | + $ranges[0] = $minOffset; |
|
| 247 | + } |
|
| 248 | + if ($ind > 0 && $rangeArray[$ind - 1]['to'] + 1 == $ranges[0]) { // case: bytes=500-600,601-999 |
|
| 249 | + $ind--; |
|
| 250 | + $ranges[0] = $rangeArray[$ind]['from']; |
|
| 251 | + } |
|
| 252 | + } |
|
| 253 | + |
|
| 254 | + if (is_numeric($ranges[0]) && is_numeric($ranges[1]) && $ranges[0] < $fileSize && $ranges[0] <= $ranges[1]) { |
|
| 255 | + // case: x-x |
|
| 256 | + if ($ranges[1] >= $fileSize) { |
|
| 257 | + $ranges[1] = $fileSize - 1; |
|
| 258 | + } |
|
| 259 | + $rangeArray[$ind++] = [ 'from' => $ranges[0], 'to' => $ranges[1], 'size' => $fileSize ]; |
|
| 260 | + $minOffset = $ranges[1] + 1; |
|
| 261 | + if ($minOffset >= $fileSize) { |
|
| 262 | + break; |
|
| 263 | + } |
|
| 264 | + } elseif (is_numeric($ranges[0]) && $ranges[0] < $fileSize) { |
|
| 265 | + // case: x- |
|
| 266 | + $rangeArray[$ind++] = [ 'from' => $ranges[0], 'to' => $fileSize - 1, 'size' => $fileSize ]; |
|
| 267 | + break; |
|
| 268 | + } elseif (is_numeric($ranges[1])) { |
|
| 269 | + // case: -x |
|
| 270 | + if ($ranges[1] > $fileSize) { |
|
| 271 | + $ranges[1] = $fileSize; |
|
| 272 | + } |
|
| 273 | + $rangeArray[$ind++] = [ 'from' => $fileSize - $ranges[1], 'to' => $fileSize - 1, 'size' => $fileSize ]; |
|
| 274 | + break; |
|
| 275 | + } |
|
| 276 | + } |
|
| 277 | + return $rangeArray; |
|
| 278 | + } |
|
| 279 | + |
|
| 280 | + /** |
|
| 281 | + * @param View $view |
|
| 282 | + * @param string $name |
|
| 283 | + * @param string $dir |
|
| 284 | + * @param array $params ; 'head' boolean to only send header of the request ; 'range' http range header |
|
| 285 | + */ |
|
| 286 | + private static function getSingleFile($view, $dir, $name, $params) { |
|
| 287 | + $filename = $dir . '/' . $name; |
|
| 288 | + $file = null; |
|
| 289 | + |
|
| 290 | + try { |
|
| 291 | + $userFolder = \OC::$server->getRootFolder()->get(\OC\Files\Filesystem::getRoot()); |
|
| 292 | + $file = $userFolder->get($filename); |
|
| 293 | + if (!$file instanceof \OC\Files\Node\File || !$file->isReadable()) { |
|
| 294 | + http_response_code(403); |
|
| 295 | + die('403 Forbidden'); |
|
| 296 | + } |
|
| 297 | + $fileSize = $file->getSize(); |
|
| 298 | + } catch (\OCP\Files\NotPermittedException $e) { |
|
| 299 | + http_response_code(403); |
|
| 300 | + die('403 Forbidden'); |
|
| 301 | + } catch (\OCP\Files\InvalidPathException $e) { |
|
| 302 | + http_response_code(403); |
|
| 303 | + die('403 Forbidden'); |
|
| 304 | + } catch (\OCP\Files\NotFoundException $e) { |
|
| 305 | + http_response_code(404); |
|
| 306 | + $tmpl = new OC_Template('', '404', 'guest'); |
|
| 307 | + $tmpl->printPage(); |
|
| 308 | + exit(); |
|
| 309 | + } |
|
| 310 | + |
|
| 311 | + OC_Util::obEnd(); |
|
| 312 | + $view->lockFile($filename, ILockingProvider::LOCK_SHARED); |
|
| 313 | + |
|
| 314 | + $rangeArray = []; |
|
| 315 | + |
|
| 316 | + if (isset($params['range']) && substr($params['range'], 0, 6) === 'bytes=') { |
|
| 317 | + $rangeArray = self::parseHttpRangeHeader(substr($params['range'], 6), $fileSize); |
|
| 318 | + } |
|
| 319 | + |
|
| 320 | + self::sendHeaders($filename, $name, $rangeArray); |
|
| 321 | + |
|
| 322 | + if (isset($params['head']) && $params['head']) { |
|
| 323 | + return; |
|
| 324 | + } |
|
| 325 | + |
|
| 326 | + if (!empty($rangeArray)) { |
|
| 327 | + try { |
|
| 328 | + if (count($rangeArray) == 1) { |
|
| 329 | + $view->readfilePart($filename, $rangeArray[0]['from'], $rangeArray[0]['to']); |
|
| 330 | + } else { |
|
| 331 | + // check if file is seekable (if not throw UnseekableException) |
|
| 332 | + // we have to check it before body contents |
|
| 333 | + $view->readfilePart($filename, $rangeArray[0]['size'], $rangeArray[0]['size']); |
|
| 334 | + |
|
| 335 | + $type = \OC::$server->getMimeTypeDetector()->getSecureMimeType(\OC\Files\Filesystem::getMimeType($filename)); |
|
| 336 | + |
|
| 337 | + foreach ($rangeArray as $range) { |
|
| 338 | + echo "\r\n--".self::getBoundary()."\r\n". |
|
| 339 | + "Content-type: ".$type."\r\n". |
|
| 340 | + "Content-range: bytes ".$range['from']."-".$range['to']."/".$range['size']."\r\n\r\n"; |
|
| 341 | + $view->readfilePart($filename, $range['from'], $range['to']); |
|
| 342 | + } |
|
| 343 | + echo "\r\n--".self::getBoundary()."--\r\n"; |
|
| 344 | + } |
|
| 345 | + } catch (\OCP\Files\UnseekableException $ex) { |
|
| 346 | + // file is unseekable |
|
| 347 | + header_remove('Accept-Ranges'); |
|
| 348 | + header_remove('Content-Range'); |
|
| 349 | + http_response_code(200); |
|
| 350 | + self::sendHeaders($filename, $name, []); |
|
| 351 | + $view->readfile($filename); |
|
| 352 | + } |
|
| 353 | + } else { |
|
| 354 | + $view->readfile($filename); |
|
| 355 | + } |
|
| 356 | + } |
|
| 357 | + |
|
| 358 | + /** |
|
| 359 | + * Returns the total (recursive) number of files and folders in the given |
|
| 360 | + * FileInfos. |
|
| 361 | + * |
|
| 362 | + * @param \OCP\Files\FileInfo[] $fileInfos the FileInfos to count |
|
| 363 | + * @return int the total number of files and folders |
|
| 364 | + */ |
|
| 365 | + private static function getNumberOfFiles($fileInfos) { |
|
| 366 | + $numberOfFiles = 0; |
|
| 367 | + |
|
| 368 | + $view = new View(); |
|
| 369 | + |
|
| 370 | + while ($fileInfo = array_pop($fileInfos)) { |
|
| 371 | + $numberOfFiles++; |
|
| 372 | + |
|
| 373 | + if ($fileInfo->getType() === \OCP\Files\FileInfo::TYPE_FOLDER) { |
|
| 374 | + $fileInfos = array_merge($fileInfos, $view->getDirectoryContent($fileInfo->getPath())); |
|
| 375 | + } |
|
| 376 | + } |
|
| 377 | + |
|
| 378 | + return $numberOfFiles; |
|
| 379 | + } |
|
| 380 | + |
|
| 381 | + /** |
|
| 382 | + * @param View $view |
|
| 383 | + * @param string $dir |
|
| 384 | + * @param string[]|string $files |
|
| 385 | + */ |
|
| 386 | + public static function lockFiles($view, $dir, $files) { |
|
| 387 | + if (!is_array($files)) { |
|
| 388 | + $file = $dir . '/' . $files; |
|
| 389 | + $files = [$file]; |
|
| 390 | + } |
|
| 391 | + foreach ($files as $file) { |
|
| 392 | + $file = $dir . '/' . $file; |
|
| 393 | + $view->lockFile($file, ILockingProvider::LOCK_SHARED); |
|
| 394 | + if ($view->is_dir($file)) { |
|
| 395 | + $contents = $view->getDirectoryContent($file); |
|
| 396 | + $contents = array_map(function ($fileInfo) use ($file) { |
|
| 397 | + /** @var \OCP\Files\FileInfo $fileInfo */ |
|
| 398 | + return $file . '/' . $fileInfo->getName(); |
|
| 399 | + }, $contents); |
|
| 400 | + self::lockFiles($view, $dir, $contents); |
|
| 401 | + } |
|
| 402 | + } |
|
| 403 | + } |
|
| 404 | + |
|
| 405 | + /** |
|
| 406 | + * @param string $dir |
|
| 407 | + * @param $files |
|
| 408 | + * @param integer $getType |
|
| 409 | + * @param View $view |
|
| 410 | + * @param string $filename |
|
| 411 | + */ |
|
| 412 | + private static function unlockAllTheFiles($dir, $files, $getType, $view, $filename) { |
|
| 413 | + if ($getType === self::FILE) { |
|
| 414 | + $view->unlockFile($filename, ILockingProvider::LOCK_SHARED); |
|
| 415 | + } |
|
| 416 | + if ($getType === self::ZIP_FILES) { |
|
| 417 | + foreach ($files as $file) { |
|
| 418 | + $file = $dir . '/' . $file; |
|
| 419 | + $view->unlockFile($file, ILockingProvider::LOCK_SHARED); |
|
| 420 | + } |
|
| 421 | + } |
|
| 422 | + if ($getType === self::ZIP_DIR) { |
|
| 423 | + $file = $dir . '/' . $files; |
|
| 424 | + $view->unlockFile($file, ILockingProvider::LOCK_SHARED); |
|
| 425 | + } |
|
| 426 | + } |
|
| 427 | 427 | } |