summaryrefslogtreecommitdiffstats
path: root/apps/dav/lib/Upload
diff options
context:
space:
mode:
authorJoas Schilling <nickvergessen@gmx.de>2016-05-12 09:42:40 +0200
committerThomas Müller <DeepDiver1975@users.noreply.github.com>2016-05-12 09:42:40 +0200
commitdd9ee10bc0699e5dcc17c3ef2181dcda01d9a69b (patch)
tree2d464fcc20ea330481e56487287aeae462ce5917 /apps/dav/lib/Upload
parent4a3311f430ec6e45c62b2ebde2cae71e943f3c81 (diff)
downloadnextcloud-server-dd9ee10bc0699e5dcc17c3ef2181dcda01d9a69b.tar.gz
nextcloud-server-dd9ee10bc0699e5dcc17c3ef2181dcda01d9a69b.zip
Move dav app to PSR-4 (#24527)
* Move Application to correct namespace and PSR-4 it * Move dav app to PSR-4
Diffstat (limited to 'apps/dav/lib/Upload')
-rw-r--r--apps/dav/lib/Upload/AssemblyStream.php234
-rw-r--r--apps/dav/lib/Upload/FutureFile.php103
-rw-r--r--apps/dav/lib/Upload/RootCollection.php23
-rw-r--r--apps/dav/lib/Upload/UploadFolder.php61
-rw-r--r--apps/dav/lib/Upload/UploadHome.php74
5 files changed, 495 insertions, 0 deletions
diff --git a/apps/dav/lib/Upload/AssemblyStream.php b/apps/dav/lib/Upload/AssemblyStream.php
new file mode 100644
index 00000000000..4b80a591ce4
--- /dev/null
+++ b/apps/dav/lib/Upload/AssemblyStream.php
@@ -0,0 +1,234 @@
+<?php
+
+namespace OCA\DAV\Upload;
+
+use Sabre\DAV\IFile;
+
+/**
+ * Class AssemblyStream
+ *
+ * The assembly stream is a virtual stream that wraps multiple chunks.
+ * Reading from the stream transparently accessed the underlying chunks and
+ * give a representation as if they were already merged together.
+ *
+ * @package OCA\DAV\Upload
+ */
+class AssemblyStream implements \Icewind\Streams\File {
+
+ /** @var resource */
+ private $context;
+
+ /** @var IFile[] */
+ private $nodes;
+
+ /** @var int */
+ private $pos = 0;
+
+ /** @var array */
+ private $sortedNodes;
+
+ /** @var int */
+ private $size;
+
+ /**
+ * @param string $path
+ * @param string $mode
+ * @param int $options
+ * @param string &$opened_path
+ * @return bool
+ */
+ public function stream_open($path, $mode, $options, &$opened_path) {
+ $this->loadContext('assembly');
+
+ // sort the nodes
+ $nodes = $this->nodes;
+ // http://stackoverflow.com/a/10985500
+ @usort($nodes, function(IFile $a, IFile $b) {
+ return strcmp($a->getName(), $b->getName());
+ });
+ $this->nodes = $nodes;
+
+ // build additional information
+ $this->sortedNodes = [];
+ $start = 0;
+ foreach($this->nodes as $node) {
+ $size = $node->getSize();
+ $name = $node->getName();
+ $this->sortedNodes[$name] = ['node' => $node, 'start' => $start, 'end' => $start + $size];
+ $start += $size;
+ $this->size = $start;
+ }
+ return true;
+ }
+
+ /**
+ * @param string $offset
+ * @param int $whence
+ * @return bool
+ */
+ public function stream_seek($offset, $whence = SEEK_SET) {
+ return false;
+ }
+
+ /**
+ * @return int
+ */
+ public function stream_tell() {
+ return $this->pos;
+ }
+
+ /**
+ * @param int $count
+ * @return string
+ */
+ public function stream_read($count) {
+
+ list($node, $posInNode) = $this->getNodeForPosition($this->pos);
+ if (is_null($node)) {
+ return null;
+ }
+ $stream = $this->getStream($node);
+
+ fseek($stream, $posInNode);
+ $data = fread($stream, $count);
+ $read = strlen($data);
+
+ // update position
+ $this->pos += $read;
+ return $data;
+ }
+
+ /**
+ * @param string $data
+ * @return int
+ */
+ public function stream_write($data) {
+ return false;
+ }
+
+ /**
+ * @param int $option
+ * @param int $arg1
+ * @param int $arg2
+ * @return bool
+ */
+ public function stream_set_option($option, $arg1, $arg2) {
+ return false;
+ }
+
+ /**
+ * @param int $size
+ * @return bool
+ */
+ public function stream_truncate($size) {
+ return false;
+ }
+
+ /**
+ * @return array
+ */
+ public function stream_stat() {
+ return [];
+ }
+
+ /**
+ * @param int $operation
+ * @return bool
+ */
+ public function stream_lock($operation) {
+ return false;
+ }
+
+ /**
+ * @return bool
+ */
+ public function stream_flush() {
+ return false;
+ }
+
+ /**
+ * @return bool
+ */
+ public function stream_eof() {
+ return $this->pos >= $this->size;
+ }
+
+ /**
+ * @return bool
+ */
+ public function stream_close() {
+ return true;
+ }
+
+
+ /**
+ * Load the source from the stream context and return the context options
+ *
+ * @param string $name
+ * @return array
+ * @throws \Exception
+ */
+ protected function loadContext($name) {
+ $context = stream_context_get_options($this->context);
+ if (isset($context[$name])) {
+ $context = $context[$name];
+ } else {
+ throw new \BadMethodCallException('Invalid context, "' . $name . '" options not set');
+ }
+ if (isset($context['nodes']) and is_array($context['nodes'])) {
+ $this->nodes = $context['nodes'];
+ } else {
+ throw new \BadMethodCallException('Invalid context, nodes not set');
+ }
+ return $context;
+ }
+
+ /**
+ * @param IFile[] $nodes
+ * @return resource
+ *
+ * @throws \BadMethodCallException
+ */
+ public static function wrap(array $nodes) {
+ $context = stream_context_create([
+ 'assembly' => [
+ 'nodes' => $nodes]
+ ]);
+ stream_wrapper_register('assembly', '\OCA\DAV\Upload\AssemblyStream');
+ try {
+ $wrapped = fopen('assembly://', 'r', null, $context);
+ } catch (\BadMethodCallException $e) {
+ stream_wrapper_unregister('assembly');
+ throw $e;
+ }
+ stream_wrapper_unregister('assembly');
+ return $wrapped;
+ }
+
+ /**
+ * @param $pos
+ * @return IFile | null
+ */
+ private function getNodeForPosition($pos) {
+ foreach($this->sortedNodes as $node) {
+ if ($pos >= $node['start'] && $pos < $node['end']) {
+ return [$node['node'], $pos - $node['start']];
+ }
+ }
+ return null;
+ }
+
+ /**
+ * @param IFile $node
+ * @return resource
+ */
+ private function getStream(IFile $node) {
+ $data = $node->get();
+ if (is_resource($data)) {
+ return $data;
+ }
+
+ return fopen('data://text/plain,' . $data,'r');
+ }
+
+}
diff --git a/apps/dav/lib/Upload/FutureFile.php b/apps/dav/lib/Upload/FutureFile.php
new file mode 100644
index 00000000000..aca81afc055
--- /dev/null
+++ b/apps/dav/lib/Upload/FutureFile.php
@@ -0,0 +1,103 @@
+<?php
+
+namespace OCA\DAV\Upload;
+
+use OCA\DAV\Connector\Sabre\Directory;
+use OCA\DAV\Upload\AssemblyStream;
+use Sabre\DAV\Exception\Forbidden;
+use Sabre\DAV\IFile;
+
+/**
+ * Class FutureFile
+ *
+ * The FutureFile is a SabreDav IFile which connects the chunked upload directory
+ * with the AssemblyStream, who does the final assembly job
+ *
+ * @package OCA\DAV\Upload
+ */
+class FutureFile implements \Sabre\DAV\IFile {
+
+ /** @var Directory */
+ private $root;
+ /** @var string */
+ private $name;
+
+ /**
+ * @param Directory $root
+ * @param string $name
+ */
+ function __construct(Directory $root, $name) {
+ $this->root = $root;
+ $this->name = $name;
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function put($data) {
+ throw new Forbidden('Permission denied to put into this file');
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function get() {
+ $nodes = $this->root->getChildren();
+ return AssemblyStream::wrap($nodes);
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function getContentType() {
+ return 'application/octet-stream';
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function getETag() {
+ return $this->root->getETag();
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function getSize() {
+ $children = $this->root->getChildren();
+ $sizes = array_map(function($node) {
+ /** @var IFile $node */
+ return $node->getSize();
+ }, $children);
+
+ return array_sum($sizes);
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function delete() {
+ $this->root->delete();
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function getName() {
+ return $this->name;
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function setName($name) {
+ throw new Forbidden('Permission denied to rename this file');
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function getLastModified() {
+ return $this->root->getLastModified();
+ }
+}
diff --git a/apps/dav/lib/Upload/RootCollection.php b/apps/dav/lib/Upload/RootCollection.php
new file mode 100644
index 00000000000..673a3734318
--- /dev/null
+++ b/apps/dav/lib/Upload/RootCollection.php
@@ -0,0 +1,23 @@
+<?php
+
+namespace OCA\DAV\Upload;
+
+use Sabre\DAVACL\AbstractPrincipalCollection;
+
+class RootCollection extends AbstractPrincipalCollection {
+
+ /**
+ * @inheritdoc
+ */
+ function getChildForPrincipal(array $principalInfo) {
+ return new UploadHome($principalInfo);
+ }
+
+ /**
+ * @inheritdoc
+ */
+ function getName() {
+ return 'uploads';
+ }
+
+}
diff --git a/apps/dav/lib/Upload/UploadFolder.php b/apps/dav/lib/Upload/UploadFolder.php
new file mode 100644
index 00000000000..01fbf1f8dc9
--- /dev/null
+++ b/apps/dav/lib/Upload/UploadFolder.php
@@ -0,0 +1,61 @@
+<?php
+
+namespace OCA\DAV\Upload;
+
+use OCA\DAV\Connector\Sabre\Directory;
+use Sabre\DAV\Exception\Forbidden;
+use Sabre\DAV\ICollection;
+
+class UploadFolder implements ICollection {
+
+ private $node;
+
+ function __construct(Directory $node) {
+ $this->node = $node;
+ }
+
+ function createFile($name, $data = null) {
+ // TODO: verify name - should be a simple number
+ $this->node->createFile($name, $data);
+ }
+
+ function createDirectory($name) {
+ throw new Forbidden('Permission denied to create file (filename ' . $name . ')');
+ }
+
+ function getChild($name) {
+ if ($name === '.file') {
+ return new FutureFile($this->node, '.file');
+ }
+ return $this->node->getChild($name);
+ }
+
+ function getChildren() {
+ $children = $this->node->getChildren();
+ $children[] = new FutureFile($this->node, '.file');
+ return $children;
+ }
+
+ function childExists($name) {
+ if ($name === '.file') {
+ return true;
+ }
+ return $this->node->childExists($name);
+ }
+
+ function delete() {
+ $this->node->delete();
+ }
+
+ function getName() {
+ return $this->node->getName();
+ }
+
+ function setName($name) {
+ throw new Forbidden('Permission denied to rename this folder');
+ }
+
+ function getLastModified() {
+ return $this->node->getLastModified();
+ }
+}
diff --git a/apps/dav/lib/Upload/UploadHome.php b/apps/dav/lib/Upload/UploadHome.php
new file mode 100644
index 00000000000..ae4dcfa4931
--- /dev/null
+++ b/apps/dav/lib/Upload/UploadHome.php
@@ -0,0 +1,74 @@
+<?php
+
+namespace OCA\DAV\Upload;
+
+use OC\Files\Filesystem;
+use OC\Files\View;
+use OCA\DAV\Connector\Sabre\Directory;
+use Sabre\DAV\Exception\Forbidden;
+use Sabre\DAV\ICollection;
+
+class UploadHome implements ICollection {
+ /**
+ * FilesHome constructor.
+ *
+ * @param array $principalInfo
+ */
+ public function __construct($principalInfo) {
+ $this->principalInfo = $principalInfo;
+ }
+
+ function createFile($name, $data = null) {
+ throw new Forbidden('Permission denied to create file (filename ' . $name . ')');
+ }
+
+ function createDirectory($name) {
+ $this->impl()->createDirectory($name);
+ }
+
+ function getChild($name) {
+ return new UploadFolder($this->impl()->getChild($name));
+ }
+
+ function getChildren() {
+ return array_map(function($node) {
+ return new UploadFolder($node);
+ }, $this->impl()->getChildren());
+ }
+
+ function childExists($name) {
+ return !is_null($this->getChild($name));
+ }
+
+ function delete() {
+ $this->impl()->delete();
+ }
+
+ function getName() {
+ return 'uploads';
+ }
+
+ function setName($name) {
+ throw new Forbidden('Permission denied to rename this folder');
+ }
+
+ function getLastModified() {
+ return $this->impl()->getLastModified();
+ }
+
+ /**
+ * @return Directory
+ */
+ private function impl() {
+ $rootView = new View();
+ $user = \OC::$server->getUserSession()->getUser();
+ Filesystem::initMountPoints($user->getUID());
+ if (!$rootView->file_exists('/' . $user->getUID() . '/uploads')) {
+ $rootView->mkdir('/' . $user->getUID() . '/uploads');
+ }
+ $view = new View('/' . $user->getUID() . '/uploads');
+ $rootInfo = $view->getFileInfo('');
+ $impl = new Directory($view, $rootInfo);
+ return $impl;
+ }
+}