Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nextcloud/server.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArthur Schiwon <blizzz@arthur-schiwon.de>2019-12-13 00:35:57 +0300
committerArthur Schiwon <blizzz@arthur-schiwon.de>2019-12-13 00:35:57 +0300
commit7af2c296bf8d72552b85a74a085e0bf33acb5330 (patch)
tree7d73ebd7d6d6304bbdb383bb542db279f4b8934a
parentd715cd88c1be53e363d260eb1cad19169cd057a5 (diff)
use Nodes API for zip streamingstable16-file-checkbox-download
Signed-off-by: Arthur Schiwon <blizzz@arthur-schiwon.de>
-rw-r--r--lib/private/Streamer.php47
1 files changed, 30 insertions, 17 deletions
diff --git a/lib/private/Streamer.php b/lib/private/Streamer.php
index 51c2c923c23..f56655e55ee 100644
--- a/lib/private/Streamer.php
+++ b/lib/private/Streamer.php
@@ -24,6 +24,12 @@
namespace OC;
+use OC\Files\Filesystem;
+use OCP\Files\File;
+use OCP\Files\Folder;
+use OCP\Files\InvalidPathException;
+use OCP\Files\NotFoundException;
+use OCP\Files\NotPermittedException;
use OCP\IRequest;
use ownCloud\TarStreamer\TarStreamer;
use ZipStreamer\ZipStreamer;
@@ -75,23 +81,25 @@ class Streamer {
$this->streamerInstance = new ZipStreamer(['zip64' => PHP_INT_SIZE !== 4]);
}
}
-
+
/**
* Send HTTP headers
- * @param string $name
+ * @param string $name
*/
public function sendHeaders($name){
$extension = $this->streamerInstance instanceof ZipStreamer ? '.zip' : '.tar';
$fullName = $name . $extension;
$this->streamerInstance->sendHeaders($fullName);
}
-
+
/**
* Stream directory recursively
- * @param string $dir
- * @param string $internalDir
+ *
+ * @throws NotFoundException
+ * @throws NotPermittedException
+ * @throws InvalidPathException
*/
- public function addDirRecursive($dir, $internalDir='') {
+ public function addDirRecursive(string $dir, string $internalDir = ''): void {
$dirname = basename($dir);
$rootDir = $internalDir . $dirname;
if (!empty($rootDir)) {
@@ -101,22 +109,27 @@ class Streamer {
// prevent absolute dirs
$internalDir = ltrim($internalDir, '/');
- $files= \OC\Files\Filesystem::getDirectoryContent($dir);
+ $userFolder = \OC::$server->getRootFolder()->get(Filesystem::getRoot());
+ /** @var Folder $dirNode */
+ $dirNode = $userFolder->get($rootDir);
+ $files = $dirNode->getDirectoryListing();
+
foreach($files as $file) {
- $filename = $file['name'];
- $file = $dir . '/' . $filename;
- if(\OC\Files\Filesystem::is_file($file)) {
- $filesize = \OC\Files\Filesystem::filesize($file);
- $fileTime = \OC\Files\Filesystem::filemtime($file);
- $fh = \OC\Files\Filesystem::fopen($file, 'r');
- $this->addFileFromStream($fh, $internalDir . $filename, $filesize, $fileTime);
+ if($file instanceof File) {
+ $fh = $file->fopen('r');
+ $this->addFileFromStream(
+ $fh,
+ $internalDir . $file->getName(),
+ $file->getSize(),
+ $file->getMTime()
+ );
fclose($fh);
- }elseif(\OC\Files\Filesystem::is_dir($file)) {
- $this->addDirRecursive($file, $internalDir);
+ } elseif ($file instanceof Folder) {
+ $this->addDirRecursive($file->getName(), $internalDir);
}
}
}
-
+
/**
* Add a file to the archive at the specified location and file name.
*