nextcloud / server

apps/dav/appinfo/v2/publicremote.php

Indentation +79 added lines, -79 removed lines

@@ -53,27 +53,27 @@ 
 
 // Backends
 $authBackend = new PublicAuth(
-	$request,
-	Server::get(IManager::class),
-	$session,
-	Server::get(IThrottler::class),
-	Server::get(LoggerInterface::class),
-	Server::get(IURLGenerator::class),
+    $request,
+    Server::get(IManager::class),
+    $session,
+    Server::get(IThrottler::class),
+    Server::get(LoggerInterface::class),
+    Server::get(IURLGenerator::class),
 );
 $authPlugin = new \Sabre\DAV\Auth\Plugin($authBackend);
 
 $l10nFactory = Server::get(IFactory::class);
 $serverFactory = new ServerFactory(
-	Server::get(IConfig::class),
-	Server::get(LoggerInterface::class),
-	Server::get(IDBConnection::class),
-	Server::get(IUserSession::class),
-	Server::get(IMountManager::class),
-	Server::get(ITagManager::class),
-	$request,
-	Server::get(IPreview::class),
-	$eventDispatcher,
-	$l10nFactory->get('dav'),
+    Server::get(IConfig::class),
+    Server::get(LoggerInterface::class),
+    Server::get(IDBConnection::class),
+    Server::get(IUserSession::class),
+    Server::get(IMountManager::class),
+    Server::get(ITagManager::class),
+    $request,
+    Server::get(IPreview::class),
+    $eventDispatcher,
+    $l10nFactory->get('dav'),
 );
 
 
@@ -82,69 +82,69 @@ 
 
 /** @var string $baseuri defined in public.php */
 $server = $serverFactory->createServer(true, $baseuri, $requestUri, $authPlugin, function (\Sabre\DAV\Server $server) use ($baseuri, $requestUri, $authBackend, $linkCheckPlugin, $filesDropPlugin) {
-	// GET must be allowed for e.g. showing images and allowing Zip downloads
-	if ($server->httpRequest->getMethod() !== 'GET') {
-		// If this is *not* a GET request we only allow access to public DAV from AJAX or when Server2Server is allowed
-		$isAjax = in_array('XMLHttpRequest', explode(',', $_SERVER['HTTP_X_REQUESTED_WITH'] ?? ''));
-		$federatedShareProvider = Server::get(FederatedShareProvider::class);
-		if ($federatedShareProvider->isOutgoingServer2serverShareEnabled() === false && $isAjax === false) {
-			// this is what is thrown when trying to access a non-existing share
-			throw new NotAuthenticated();
-		}
-	}
-
-	$share = $authBackend->getShare();
-	$owner = $share->getShareOwner();
-	$isReadable = $share->getPermissions() & Constants::PERMISSION_READ;
-	$fileId = $share->getNodeId();
-
-	// FIXME: should not add storage wrappers outside of preSetup, need to find a better way
-	/** @psalm-suppress InternalMethod */
-	$previousLog = Filesystem::logWarningWhenAddingStorageWrapper(false);
-
-	/** @psalm-suppress MissingClosureParamType */
-	Filesystem::addStorageWrapper('sharePermissions', function ($mountPoint, $storage) use ($requestUri, $baseuri, $share) {
-		$mask = $share->getPermissions() | Constants::PERMISSION_SHARE;
-
-		// For chunked uploads it is necessary to have read and delete permission,
-		// so the temporary directory, chunks and destination file can be read and delete after the assembly.
-		if (str_starts_with(substr($requestUri, strlen($baseuri) - 1), '/uploads/')) {
-			$mask |= Constants::PERMISSION_READ | Constants::PERMISSION_DELETE;
-		}
-
-		return new PermissionsMask(['storage' => $storage, 'mask' => $mask]);
-	});
-
-	/** @psalm-suppress MissingClosureParamType */
-	Filesystem::addStorageWrapper('shareOwner', function ($mountPoint, $storage) use ($share) {
-		return new PublicOwnerWrapper(['storage' => $storage, 'owner' => $share->getShareOwner()]);
-	});
-
-	// Ensure that also private shares have the `getShare` method
-	/** @psalm-suppress MissingClosureParamType */
-	Filesystem::addStorageWrapper('getShare', function ($mountPoint, $storage) use ($share) {
-		return new PublicShareWrapper(['storage' => $storage, 'share' => $share]);
-	}, 0);
-
-	/** @psalm-suppress InternalMethod */
-	Filesystem::logWarningWhenAddingStorageWrapper($previousLog);
-
-	$rootFolder = Server::get(IRootFolder::class);
-	$userFolder = $rootFolder->getUserFolder($owner);
-	$node = $userFolder->getFirstNodeById($fileId);
-	if (!$node) {
-		throw new NotFound();
-	}
-	$linkCheckPlugin->setFileInfo($node);
-
-	// If not readable (files_drop) enable the filesdrop plugin
-	if (!$isReadable) {
-		$filesDropPlugin->enable();
-	}
-	$filesDropPlugin->setShare($share);
-
-	$view = new View($node->getPath());
-	return $view;
+    // GET must be allowed for e.g. showing images and allowing Zip downloads
+    if ($server->httpRequest->getMethod() !== 'GET') {
+        // If this is *not* a GET request we only allow access to public DAV from AJAX or when Server2Server is allowed
+        $isAjax = in_array('XMLHttpRequest', explode(',', $_SERVER['HTTP_X_REQUESTED_WITH'] ?? ''));
+        $federatedShareProvider = Server::get(FederatedShareProvider::class);
+        if ($federatedShareProvider->isOutgoingServer2serverShareEnabled() === false && $isAjax === false) {
+            // this is what is thrown when trying to access a non-existing share
+            throw new NotAuthenticated();
+        }
+    }
+
+    $share = $authBackend->getShare();
+    $owner = $share->getShareOwner();
+    $isReadable = $share->getPermissions() & Constants::PERMISSION_READ;
+    $fileId = $share->getNodeId();
+
+    // FIXME: should not add storage wrappers outside of preSetup, need to find a better way
+    /** @psalm-suppress InternalMethod */
+    $previousLog = Filesystem::logWarningWhenAddingStorageWrapper(false);
+
+    /** @psalm-suppress MissingClosureParamType */
+    Filesystem::addStorageWrapper('sharePermissions', function ($mountPoint, $storage) use ($requestUri, $baseuri, $share) {
+        $mask = $share->getPermissions() | Constants::PERMISSION_SHARE;
+
+        // For chunked uploads it is necessary to have read and delete permission,
+        // so the temporary directory, chunks and destination file can be read and delete after the assembly.
+        if (str_starts_with(substr($requestUri, strlen($baseuri) - 1), '/uploads/')) {
+            $mask |= Constants::PERMISSION_READ | Constants::PERMISSION_DELETE;
+        }
+
+        return new PermissionsMask(['storage' => $storage, 'mask' => $mask]);
+    });
+
+    /** @psalm-suppress MissingClosureParamType */
+    Filesystem::addStorageWrapper('shareOwner', function ($mountPoint, $storage) use ($share) {
+        return new PublicOwnerWrapper(['storage' => $storage, 'owner' => $share->getShareOwner()]);
+    });
+
+    // Ensure that also private shares have the `getShare` method
+    /** @psalm-suppress MissingClosureParamType */
+    Filesystem::addStorageWrapper('getShare', function ($mountPoint, $storage) use ($share) {
+        return new PublicShareWrapper(['storage' => $storage, 'share' => $share]);
+    }, 0);
+
+    /** @psalm-suppress InternalMethod */
+    Filesystem::logWarningWhenAddingStorageWrapper($previousLog);
+
+    $rootFolder = Server::get(IRootFolder::class);
+    $userFolder = $rootFolder->getUserFolder($owner);
+    $node = $userFolder->getFirstNodeById($fileId);
+    if (!$node) {
+        throw new NotFound();
+    }
+    $linkCheckPlugin->setFileInfo($node);
+
+    // If not readable (files_drop) enable the filesdrop plugin
+    if (!$isReadable) {
+        $filesDropPlugin->enable();
+    }
+    $filesDropPlugin->setShare($share);
+
+    $view = new View($node->getPath());
+    return $view;
 });
 
 $server->addPlugin($linkCheckPlugin);

Spacing +4 added lines, -4 removed lines

@@ -81,7 +81,7 @@ 
 $filesDropPlugin = new FilesDropPlugin();
 
 /** @var string $baseuri defined in public.php */
-$server = $serverFactory->createServer(true, $baseuri, $requestUri, $authPlugin, function (\Sabre\DAV\Server $server) use ($baseuri, $requestUri, $authBackend, $linkCheckPlugin, $filesDropPlugin) {
+$server = $serverFactory->createServer(true, $baseuri, $requestUri, $authPlugin, function(\Sabre\DAV\Server $server) use ($baseuri, $requestUri, $authBackend, $linkCheckPlugin, $filesDropPlugin) {
 	// GET must be allowed for e.g. showing images and allowing Zip downloads
 	if ($server->httpRequest->getMethod() !== 'GET') {
 		// If this is *not* a GET request we only allow access to public DAV from AJAX or when Server2Server is allowed
@@ -103,7 +103,7 @@ 
 	$previousLog = Filesystem::logWarningWhenAddingStorageWrapper(false);
 
 	/** @psalm-suppress MissingClosureParamType */
-	Filesystem::addStorageWrapper('sharePermissions', function ($mountPoint, $storage) use ($requestUri, $baseuri, $share) {
+	Filesystem::addStorageWrapper('sharePermissions', function($mountPoint, $storage) use ($requestUri, $baseuri, $share) {
 		$mask = $share->getPermissions() | Constants::PERMISSION_SHARE;
 
 		// For chunked uploads it is necessary to have read and delete permission,
@@ -116,13 +116,13 @@ 
 	});
 
 	/** @psalm-suppress MissingClosureParamType */
-	Filesystem::addStorageWrapper('shareOwner', function ($mountPoint, $storage) use ($share) {
+	Filesystem::addStorageWrapper('shareOwner', function($mountPoint, $storage) use ($share) {
 		return new PublicOwnerWrapper(['storage' => $storage, 'owner' => $share->getShareOwner()]);
 	});
 
 	// Ensure that also private shares have the `getShare` method
 	/** @psalm-suppress MissingClosureParamType */
-	Filesystem::addStorageWrapper('getShare', function ($mountPoint, $storage) use ($share) {
+	Filesystem::addStorageWrapper('getShare', function($mountPoint, $storage) use ($share) {
 		return new PublicShareWrapper(['storage' => $storage, 'share' => $share]);
 	}, 0);
 

apps/dav/tests/unit/Files/Sharing/FilesDropPluginTest.php

Indentation +202 added lines, -202 removed lines

@@ -20,212 +20,212 @@
 
 class FilesDropPluginTest extends TestCase {
 
-	private FilesDropPlugin $plugin;
+    private FilesDropPlugin $plugin;
 
-	private Folder&MockObject $node;
-	private IShare&MockObject $share;
-	private Server&MockObject $server;
-	private RequestInterface&MockObject $request;
-	private ResponseInterface&MockObject $response;
+    private Folder&MockObject $node;
+    private IShare&MockObject $share;
+    private Server&MockObject $server;
+    private RequestInterface&MockObject $request;
+    private ResponseInterface&MockObject $response;
 
-	protected function setUp(): void {
-		parent::setUp();
+    protected function setUp(): void {
+        parent::setUp();
 
-		$this->node = $this->createMock(Folder::class);
-		$this->node->method('getPath')
-			->willReturn('/files/token');
+        $this->node = $this->createMock(Folder::class);
+        $this->node->method('getPath')
+            ->willReturn('/files/token');
 
-		$this->share = $this->createMock(IShare::class);
-		$this->share->expects(self::any())
-			->method('getNode')
-			->willReturn($this->node);
-		$this->server = $this->createMock(Server::class);
-		$this->plugin = new FilesDropPlugin();
+        $this->share = $this->createMock(IShare::class);
+        $this->share->expects(self::any())
+            ->method('getNode')
+            ->willReturn($this->node);
+        $this->server = $this->createMock(Server::class);
+        $this->plugin = new FilesDropPlugin();
 
-		$this->request = $this->createMock(RequestInterface::class);
-		$this->response = $this->createMock(ResponseInterface::class);
+        $this->request = $this->createMock(RequestInterface::class);
+        $this->response = $this->createMock(ResponseInterface::class);
 
-		$attributes = $this->createMock(IAttributes::class);
-		$this->share->expects($this->any())
-			->method('getAttributes')
-			->willReturn($attributes);
-
-		$this->share
-			->method('getToken')
-			->willReturn('token');
-	}
-
-	public function testValid(): void {
-		$this->plugin->enable();
-		$this->plugin->setShare($this->share);
-
-		$this->request->method('getMethod')
-			->willReturn('PUT');
-
-		$this->request->method('getPath')
-			->willReturn('/files/token/file.txt');
-
-		$this->request->method('getBaseUrl')
-			->willReturn('https://example.com');
-
-		$this->node->expects(self::once())
-			->method('getNonExistingName')
-			->with('file.txt')
-			->willReturn('file.txt');
-
-		$this->request->expects($this->once())
-			->method('setUrl')
-			->with('https://example.com/files/token/file.txt');
-
-		$this->plugin->beforeMethod($this->request, $this->response);
-	}
-
-	public function testFileAlreadyExistsValid(): void {
-		$this->plugin->enable();
-		$this->plugin->setShare($this->share);
-
-		$this->request->method('getMethod')
-			->willReturn('PUT');
-
-		$this->request->method('getPath')
-			->willReturn('/files/token/file.txt');
-
-		$this->request->method('getBaseUrl')
-			->willReturn('https://example.com');
-
-		$this->node->method('getNonExistingName')
-			->with('file.txt')
-			->willReturn('file (2).txt');
-
-		$this->request->expects($this->once())
-			->method('setUrl')
-			->with($this->equalTo('https://example.com/files/token/file (2).txt'));
-
-		$this->plugin->beforeMethod($this->request, $this->response);
-	}
-
-	public function testMKCOL(): void {
-		$this->plugin->enable();
-		$this->plugin->setShare($this->share);
-
-		$this->request->method('getMethod')
-			->willReturn('MKCOL');
-
-		$this->expectNotToPerformAssertions();
-
-		$this->plugin->beforeMethod($this->request, $this->response);
-	}
-
-	public function testSubdirPut(): void {
-		$this->plugin->enable();
-		$this->plugin->setShare($this->share);
-
-		$this->request->method('getMethod')
-			->willReturn('PUT');
-
-		$this->request->method('hasHeader')
-			->with('X-NC-Nickname')
-			->willReturn(true);
-		$this->request->method('getHeader')
-			->with('X-NC-Nickname')
-			->willReturn('nickname');
-
-		$this->request->method('getPath')
-			->willReturn('/files/token/folder/file.txt');
-
-		$this->request->method('getBaseUrl')
-			->willReturn('https://example.com');
-
-		$nodeName = $this->createMock(Folder::class);
-		$nodeFolder = $this->createMock(Folder::class);
-		$nodeFolder->expects(self::once())
-			->method('getPath')
-			->willReturn('/files/token/nickname/folder');
-		$nodeFolder->method('getNonExistingName')
-			->with('file.txt')
-			->willReturn('file.txt');
-		$nodeName->expects(self::once())
-			->method('get')
-			->with('folder')
-			->willThrowException(new NotFoundException());
-		$nodeName->expects(self::once())
-			->method('newFolder')
-			->with('folder')
-			->willReturn($nodeFolder);
-
-		$this->node->expects(self::once())
-			->method('get')
-			->willThrowException(new NotFoundException());
-		$this->node->expects(self::once())
-			->method('newFolder')
-			->with('nickname')
-			->willReturn($nodeName);
-
-		$this->request->expects($this->once())
-			->method('setUrl')
-			->with($this->equalTo('https://example.com/files/token/nickname/folder/file.txt'));
-
-		$this->plugin->beforeMethod($this->request, $this->response);
-	}
-
-	public function testRecursiveFolderCreation(): void {
-		$this->plugin->enable();
-		$this->plugin->setShare($this->share);
-
-		$this->request->method('getMethod')
-			->willReturn('PUT');
-		$this->request->method('hasHeader')
-			->with('X-NC-Nickname')
-			->willReturn(true);
-		$this->request->method('getHeader')
-			->with('X-NC-Nickname')
-			->willReturn('nickname');
-
-		$this->request->method('getPath')
-			->willReturn('/files/token/folder/subfolder/file.txt');
-		$this->request->method('getBaseUrl')
-			->willReturn('https://example.com');
-
-		$this->request->expects($this->once())
-			->method('setUrl')
-			->with($this->equalTo('https://example.com/files/token/nickname/folder/subfolder/file.txt'));
-
-		$subfolder = $this->createMock(Folder::class);
-		$subfolder->expects(self::once())
-			->method('getNonExistingName')
-			->with('file.txt')
-			->willReturn('file.txt');
-		$subfolder->expects(self::once())
-			->method('getPath')
-			->willReturn('/files/token/nickname/folder/subfolder');
-
-		$folder = $this->createMock(Folder::class);
-		$folder->expects(self::once())
-			->method('get')
-			->with('subfolder')
-			->willReturn($subfolder);
-
-		$nickname = $this->createMock(Folder::class);
-		$nickname->expects(self::once())
-			->method('get')
-			->with('folder')
-			->willReturn($folder);
-
-		$this->node->method('get')
-			->with('nickname')
-			->willReturn($nickname);
-		$this->plugin->beforeMethod($this->request, $this->response);
-	}
-
-	public function testOnMkcol(): void {
-		$this->plugin->enable();
-		$this->plugin->setShare($this->share);
-
-		$this->response->expects($this->once())
-			->method('setStatus')
-			->with(201);
-
-		$response = $this->plugin->onMkcol($this->request, $this->response);
-		$this->assertFalse($response);
-	}
+        $attributes = $this->createMock(IAttributes::class);
+        $this->share->expects($this->any())
+            ->method('getAttributes')
+            ->willReturn($attributes);
+
+        $this->share
+            ->method('getToken')
+            ->willReturn('token');
+    }
+
+    public function testValid(): void {
+        $this->plugin->enable();
+        $this->plugin->setShare($this->share);
+
+        $this->request->method('getMethod')
+            ->willReturn('PUT');
+
+        $this->request->method('getPath')
+            ->willReturn('/files/token/file.txt');
+
+        $this->request->method('getBaseUrl')
+            ->willReturn('https://example.com');
+
+        $this->node->expects(self::once())
+            ->method('getNonExistingName')
+            ->with('file.txt')
+            ->willReturn('file.txt');
+
+        $this->request->expects($this->once())
+            ->method('setUrl')
+            ->with('https://example.com/files/token/file.txt');
+
+        $this->plugin->beforeMethod($this->request, $this->response);
+    }
+
+    public function testFileAlreadyExistsValid(): void {
+        $this->plugin->enable();
+        $this->plugin->setShare($this->share);
+
+        $this->request->method('getMethod')
+            ->willReturn('PUT');
+
+        $this->request->method('getPath')
+            ->willReturn('/files/token/file.txt');
+
+        $this->request->method('getBaseUrl')
+            ->willReturn('https://example.com');
+
+        $this->node->method('getNonExistingName')
+            ->with('file.txt')
+            ->willReturn('file (2).txt');
+
+        $this->request->expects($this->once())
+            ->method('setUrl')
+            ->with($this->equalTo('https://example.com/files/token/file (2).txt'));
+
+        $this->plugin->beforeMethod($this->request, $this->response);
+    }
+
+    public function testMKCOL(): void {
+        $this->plugin->enable();
+        $this->plugin->setShare($this->share);
+
+        $this->request->method('getMethod')
+            ->willReturn('MKCOL');
+
+        $this->expectNotToPerformAssertions();
+
+        $this->plugin->beforeMethod($this->request, $this->response);
+    }
+
+    public function testSubdirPut(): void {
+        $this->plugin->enable();
+        $this->plugin->setShare($this->share);
+
+        $this->request->method('getMethod')
+            ->willReturn('PUT');
+
+        $this->request->method('hasHeader')
+            ->with('X-NC-Nickname')
+            ->willReturn(true);
+        $this->request->method('getHeader')
+            ->with('X-NC-Nickname')
+            ->willReturn('nickname');
+
+        $this->request->method('getPath')
+            ->willReturn('/files/token/folder/file.txt');
+
+        $this->request->method('getBaseUrl')
+            ->willReturn('https://example.com');
+
+        $nodeName = $this->createMock(Folder::class);
+        $nodeFolder = $this->createMock(Folder::class);
+        $nodeFolder->expects(self::once())
+            ->method('getPath')
+            ->willReturn('/files/token/nickname/folder');
+        $nodeFolder->method('getNonExistingName')
+            ->with('file.txt')
+            ->willReturn('file.txt');
+        $nodeName->expects(self::once())
+            ->method('get')
+            ->with('folder')
+            ->willThrowException(new NotFoundException());
+        $nodeName->expects(self::once())
+            ->method('newFolder')
+            ->with('folder')
+            ->willReturn($nodeFolder);
+
+        $this->node->expects(self::once())
+            ->method('get')
+            ->willThrowException(new NotFoundException());
+        $this->node->expects(self::once())
+            ->method('newFolder')
+            ->with('nickname')
+            ->willReturn($nodeName);
+
+        $this->request->expects($this->once())
+            ->method('setUrl')
+            ->with($this->equalTo('https://example.com/files/token/nickname/folder/file.txt'));
+
+        $this->plugin->beforeMethod($this->request, $this->response);
+    }
+
+    public function testRecursiveFolderCreation(): void {
+        $this->plugin->enable();
+        $this->plugin->setShare($this->share);
+
+        $this->request->method('getMethod')
+            ->willReturn('PUT');
+        $this->request->method('hasHeader')
+            ->with('X-NC-Nickname')
+            ->willReturn(true);
+        $this->request->method('getHeader')
+            ->with('X-NC-Nickname')
+            ->willReturn('nickname');
+
+        $this->request->method('getPath')
+            ->willReturn('/files/token/folder/subfolder/file.txt');
+        $this->request->method('getBaseUrl')
+            ->willReturn('https://example.com');
+
+        $this->request->expects($this->once())
+            ->method('setUrl')
+            ->with($this->equalTo('https://example.com/files/token/nickname/folder/subfolder/file.txt'));
+
+        $subfolder = $this->createMock(Folder::class);
+        $subfolder->expects(self::once())
+            ->method('getNonExistingName')
+            ->with('file.txt')
+            ->willReturn('file.txt');
+        $subfolder->expects(self::once())
+            ->method('getPath')
+            ->willReturn('/files/token/nickname/folder/subfolder');
+
+        $folder = $this->createMock(Folder::class);
+        $folder->expects(self::once())
+            ->method('get')
+            ->with('subfolder')
+            ->willReturn($subfolder);
+
+        $nickname = $this->createMock(Folder::class);
+        $nickname->expects(self::once())
+            ->method('get')
+            ->with('folder')
+            ->willReturn($folder);
+
+        $this->node->method('get')
+            ->with('nickname')
+            ->willReturn($nickname);
+        $this->plugin->beforeMethod($this->request, $this->response);
+    }
+
+    public function testOnMkcol(): void {
+        $this->plugin->enable();
+        $this->plugin->setShare($this->share);
+
+        $this->response->expects($this->once())
+            ->method('setStatus')
+            ->with(201);
+
+        $response = $this->plugin->onMkcol($this->request, $this->response);
+        $this->assertFalse($response);
+    }
 }

apps/dav/lib/Files/Sharing/FilesDropPlugin.php

Indentation +195 added lines, -195 removed lines

@@ -20,199 +20,199 @@
  */
 class FilesDropPlugin extends ServerPlugin {
 
-	private ?IShare $share = null;
-	private bool $enabled = false;
-
-	public function setShare(IShare $share): void {
-		$this->share = $share;
-	}
-
-	public function enable(): void {
-		$this->enabled = true;
-	}
-
-	/**
-	 * This initializes the plugin.
-	 * It is ONLY initialized by the server on a file drop request.
-	 */
-	public function initialize(\Sabre\DAV\Server $server): void {
-		$server->on('beforeMethod:*', [$this, 'beforeMethod'], 999);
-		$server->on('method:MKCOL', [$this, 'onMkcol']);
-		$this->enabled = false;
-	}
-
-	public function onMkcol(RequestInterface $request, ResponseInterface $response) {
-		if ($this->isChunkedUpload($request)) {
-			return;
-		}
-
-		if (!$this->enabled || $this->share === null) {
-			return;
-		}
-
-		$node = $this->share->getNode();
-		if (!($node instanceof Folder)) {
-			return;
-		}
-
-		// If this is a folder creation request we need
-		// to fake a success so we can pretend every
-		// folder now exists.
-		$response->setStatus(201);
-		return false;
-	}
-
-	private function isChunkedUpload(RequestInterface $request): bool {
-		return str_starts_with(substr($request->getUrl(), strlen($request->getBaseUrl()) - 1), '/uploads/');
-	}
-
-	public function beforeMethod(RequestInterface $request, ResponseInterface $response) {
-		$isChunkedUpload = $this->isChunkedUpload($request);
-
-		// For the final MOVE request of a chunked upload it is necessary to modify the Destination header.
-		if ($isChunkedUpload && $request->getMethod() !== 'MOVE') {
-			return;
-		}
-
-		if (!$this->enabled || $this->share === null) {
-			return;
-		}
-
-		$node = $this->share->getNode();
-		if (!($node instanceof Folder)) {
-			return;
-		}
-
-		if ($request->getMethod() !== 'PUT' && $request->getMethod() !== 'MKCOL' && (!$isChunkedUpload || $request->getMethod() !== 'MOVE')) {
-			throw new MethodNotAllowed('Only PUT, MKCOL and MOVE are allowed on files drop');
-		}
-
-		// If this is a folder creation request
-		// let's stop there and let the onMkcol handle it
-		if ($request->getMethod() === 'MKCOL') {
-			return;
-		}
-
-		// Now if we create a file, we need to create the
-		// full path along the way. We'll only handle conflict
-		// resolution on file conflicts, but not on folders.
-
-		if ($isChunkedUpload) {
-			$destination = $request->getHeader('destination');
-			$baseUrl = $request->getBaseUrl();
-			// e.g files/dCP8yn3N86EK9sL/Folder/image.jpg
-			$path = substr($destination, strpos($destination, $baseUrl) + strlen($baseUrl));
-		} else {
-			// e.g files/dCP8yn3N86EK9sL/Folder/image.jpg
-			$path = $request->getPath();
-		}
-
-		$token = $this->share->getToken();
-
-		// e.g files/dCP8yn3N86EK9sL
-		$rootPath = substr($path, 0, strpos($path, $token) + strlen($token));
-		// e.g /Folder/image.jpg
-		$relativePath = substr($path, strlen($rootPath));
-		$isRootUpload = substr_count($relativePath, '/') === 1;
-
-		// Extract the attributes for the file request
-		$isFileRequest = false;
-		$attributes = $this->share->getAttributes();
-		if ($attributes !== null) {
-			$isFileRequest = $attributes->getAttribute('fileRequest', 'enabled') === true;
-		}
-
-		// Retrieve the nickname from the request
-		$nickname = $request->hasHeader('X-NC-Nickname')
-			? trim(urldecode($request->getHeader('X-NC-Nickname')))
-			: null;
-
-		// We need a valid nickname for file requests
-		if ($isFileRequest && !$nickname) {
-			throw new BadRequest('A nickname header is required for file requests');
-		}
-
-		// We're only allowing the upload of
-		// long path with subfolders if a nickname is set.
-		// This prevents confusion when uploading files and help
-		// classify them by uploaders.
-		if (!$nickname && !$isRootUpload) {
-			throw new BadRequest('A nickname header is required when uploading subfolders');
-		}
-
-		if ($nickname) {
-			try {
-				$node->verifyPath($nickname);
-			} catch (\Exception $e) {
-				// If the path is not valid, we throw an exception
-				throw new BadRequest('Invalid nickname: ' . $nickname);
-			}
-
-			// Forbid nicknames starting with a dot
-			if (str_starts_with($nickname, '.')) {
-				throw new BadRequest('Invalid nickname: ' . $nickname);
-			}
-
-			// If we have a nickname, let's put
-			// all files in the subfolder
-			$relativePath = '/' . $nickname . '/' . $relativePath;
-			$relativePath = str_replace('//', '/', $relativePath);
-		}
-
-		// Create the folders along the way
-		$folder = $node;
-		$pathSegments = $this->getPathSegments(dirname($relativePath));
-		foreach ($pathSegments as $pathSegment) {
-			if ($pathSegment === '') {
-				continue;
-			}
-
-			try {
-				// get the current folder
-				$currentFolder = $folder->get($pathSegment);
-				// check target is a folder
-				if ($currentFolder instanceof Folder) {
-					$folder = $currentFolder;
-				} else {
-					// otherwise look in the parent folder if we already create an unique folder name
-					foreach ($folder->getDirectoryListing() as $child) {
-						// we look for folders which match "NAME (SUFFIX)"
-						if ($child instanceof Folder && str_starts_with($child->getName(), $pathSegment)) {
-							$suffix = substr($child->getName(), strlen($pathSegment));
-							if (preg_match('/^ \(\d+\)$/', $suffix)) {
-								// we found the unique folder name and can use it
-								$folder = $child;
-								break;
-							}
-						}
-					}
-					// no folder found so we need to create a new unique folder name
-					if (!isset($child) || $child !== $folder) {
-						$folder = $folder->newFolder($folder->getNonExistingName($pathSegment));
-					}
-				}
-			} catch (NotFoundException) {
-				// the folder does simply not exist so we create it
-				$folder = $folder->newFolder($pathSegment);
-			}
-		}
-
-		// Finally handle conflicts on the end files
-		$uniqueName = $folder->getNonExistingName(basename($relativePath));
-		$relativePath = substr($folder->getPath(), strlen($node->getPath()));
-		$path = '/files/' . $token . '/' . $relativePath . '/' . $uniqueName;
-		$url = rtrim($request->getBaseUrl(), '/') . str_replace('//', '/', $path);
-		if ($isChunkedUpload) {
-			$request->setHeader('destination', $url);
-		} else {
-			$request->setUrl($url);
-		}
-	}
-
-	private function getPathSegments(string $path): array {
-		// Normalize slashes and remove trailing slash
-		$path = trim(str_replace('\\', '/', $path), '/');
-
-		return explode('/', $path);
-	}
+    private ?IShare $share = null;
+    private bool $enabled = false;
+
+    public function setShare(IShare $share): void {
+        $this->share = $share;
+    }
+
+    public function enable(): void {
+        $this->enabled = true;
+    }
+
+    /**
+     * This initializes the plugin.
+     * It is ONLY initialized by the server on a file drop request.
+     */
+    public function initialize(\Sabre\DAV\Server $server): void {
+        $server->on('beforeMethod:*', [$this, 'beforeMethod'], 999);
+        $server->on('method:MKCOL', [$this, 'onMkcol']);
+        $this->enabled = false;
+    }
+
+    public function onMkcol(RequestInterface $request, ResponseInterface $response) {
+        if ($this->isChunkedUpload($request)) {
+            return;
+        }
+
+        if (!$this->enabled || $this->share === null) {
+            return;
+        }
+
+        $node = $this->share->getNode();
+        if (!($node instanceof Folder)) {
+            return;
+        }
+
+        // If this is a folder creation request we need
+        // to fake a success so we can pretend every
+        // folder now exists.
+        $response->setStatus(201);
+        return false;
+    }
+
+    private function isChunkedUpload(RequestInterface $request): bool {
+        return str_starts_with(substr($request->getUrl(), strlen($request->getBaseUrl()) - 1), '/uploads/');
+    }
+
+    public function beforeMethod(RequestInterface $request, ResponseInterface $response) {
+        $isChunkedUpload = $this->isChunkedUpload($request);
+
+        // For the final MOVE request of a chunked upload it is necessary to modify the Destination header.
+        if ($isChunkedUpload && $request->getMethod() !== 'MOVE') {
+            return;
+        }
+
+        if (!$this->enabled || $this->share === null) {
+            return;
+        }
+
+        $node = $this->share->getNode();
+        if (!($node instanceof Folder)) {
+            return;
+        }
+
+        if ($request->getMethod() !== 'PUT' && $request->getMethod() !== 'MKCOL' && (!$isChunkedUpload || $request->getMethod() !== 'MOVE')) {
+            throw new MethodNotAllowed('Only PUT, MKCOL and MOVE are allowed on files drop');
+        }
+
+        // If this is a folder creation request
+        // let's stop there and let the onMkcol handle it
+        if ($request->getMethod() === 'MKCOL') {
+            return;
+        }
+
+        // Now if we create a file, we need to create the
+        // full path along the way. We'll only handle conflict
+        // resolution on file conflicts, but not on folders.
+
+        if ($isChunkedUpload) {
+            $destination = $request->getHeader('destination');
+            $baseUrl = $request->getBaseUrl();
+            // e.g files/dCP8yn3N86EK9sL/Folder/image.jpg
+            $path = substr($destination, strpos($destination, $baseUrl) + strlen($baseUrl));
+        } else {
+            // e.g files/dCP8yn3N86EK9sL/Folder/image.jpg
+            $path = $request->getPath();
+        }
+
+        $token = $this->share->getToken();
+
+        // e.g files/dCP8yn3N86EK9sL
+        $rootPath = substr($path, 0, strpos($path, $token) + strlen($token));
+        // e.g /Folder/image.jpg
+        $relativePath = substr($path, strlen($rootPath));
+        $isRootUpload = substr_count($relativePath, '/') === 1;
+
+        // Extract the attributes for the file request
+        $isFileRequest = false;
+        $attributes = $this->share->getAttributes();
+        if ($attributes !== null) {
+            $isFileRequest = $attributes->getAttribute('fileRequest', 'enabled') === true;
+        }
+
+        // Retrieve the nickname from the request
+        $nickname = $request->hasHeader('X-NC-Nickname')
+            ? trim(urldecode($request->getHeader('X-NC-Nickname')))
+            : null;
+
+        // We need a valid nickname for file requests
+        if ($isFileRequest && !$nickname) {
+            throw new BadRequest('A nickname header is required for file requests');
+        }
+
+        // We're only allowing the upload of
+        // long path with subfolders if a nickname is set.
+        // This prevents confusion when uploading files and help
+        // classify them by uploaders.
+        if (!$nickname && !$isRootUpload) {
+            throw new BadRequest('A nickname header is required when uploading subfolders');
+        }
+
+        if ($nickname) {
+            try {
+                $node->verifyPath($nickname);
+            } catch (\Exception $e) {
+                // If the path is not valid, we throw an exception
+                throw new BadRequest('Invalid nickname: ' . $nickname);
+            }
+
+            // Forbid nicknames starting with a dot
+            if (str_starts_with($nickname, '.')) {
+                throw new BadRequest('Invalid nickname: ' . $nickname);
+            }
+
+            // If we have a nickname, let's put
+            // all files in the subfolder
+            $relativePath = '/' . $nickname . '/' . $relativePath;
+            $relativePath = str_replace('//', '/', $relativePath);
+        }
+
+        // Create the folders along the way
+        $folder = $node;
+        $pathSegments = $this->getPathSegments(dirname($relativePath));
+        foreach ($pathSegments as $pathSegment) {
+            if ($pathSegment === '') {
+                continue;
+            }
+
+            try {
+                // get the current folder
+                $currentFolder = $folder->get($pathSegment);
+                // check target is a folder
+                if ($currentFolder instanceof Folder) {
+                    $folder = $currentFolder;
+                } else {
+                    // otherwise look in the parent folder if we already create an unique folder name
+                    foreach ($folder->getDirectoryListing() as $child) {
+                        // we look for folders which match "NAME (SUFFIX)"
+                        if ($child instanceof Folder && str_starts_with($child->getName(), $pathSegment)) {
+                            $suffix = substr($child->getName(), strlen($pathSegment));
+                            if (preg_match('/^ \(\d+\)$/', $suffix)) {
+                                // we found the unique folder name and can use it
+                                $folder = $child;
+                                break;
+                            }
+                        }
+                    }
+                    // no folder found so we need to create a new unique folder name
+                    if (!isset($child) || $child !== $folder) {
+                        $folder = $folder->newFolder($folder->getNonExistingName($pathSegment));
+                    }
+                }
+            } catch (NotFoundException) {
+                // the folder does simply not exist so we create it
+                $folder = $folder->newFolder($pathSegment);
+            }
+        }
+
+        // Finally handle conflicts on the end files
+        $uniqueName = $folder->getNonExistingName(basename($relativePath));
+        $relativePath = substr($folder->getPath(), strlen($node->getPath()));
+        $path = '/files/' . $token . '/' . $relativePath . '/' . $uniqueName;
+        $url = rtrim($request->getBaseUrl(), '/') . str_replace('//', '/', $path);
+        if ($isChunkedUpload) {
+            $request->setHeader('destination', $url);
+        } else {
+            $request->setUrl($url);
+        }
+    }
+
+    private function getPathSegments(string $path): array {
+        // Normalize slashes and remove trailing slash
+        $path = trim(str_replace('\\', '/', $path), '/');
+
+        return explode('/', $path);
+    }
 }

Spacing +5 added lines, -5 removed lines

@@ -145,17 +145,17 @@ 
 				$node->verifyPath($nickname);
 			} catch (\Exception $e) {
 				// If the path is not valid, we throw an exception
-				throw new BadRequest('Invalid nickname: ' . $nickname);
+				throw new BadRequest('Invalid nickname: '.$nickname);
 			}
 
 			// Forbid nicknames starting with a dot
 			if (str_starts_with($nickname, '.')) {
-				throw new BadRequest('Invalid nickname: ' . $nickname);
+				throw new BadRequest('Invalid nickname: '.$nickname);
 			}
 
 			// If we have a nickname, let's put
 			// all files in the subfolder
-			$relativePath = '/' . $nickname . '/' . $relativePath;
+			$relativePath = '/'.$nickname.'/'.$relativePath;
 			$relativePath = str_replace('//', '/', $relativePath);
 		}
 
@@ -200,8 +200,8 @@ 
 		// Finally handle conflicts on the end files
 		$uniqueName = $folder->getNonExistingName(basename($relativePath));
 		$relativePath = substr($folder->getPath(), strlen($node->getPath()));
-		$path = '/files/' . $token . '/' . $relativePath . '/' . $uniqueName;
-		$url = rtrim($request->getBaseUrl(), '/') . str_replace('//', '/', $path);
+		$path = '/files/'.$token.'/'.$relativePath.'/'.$uniqueName;
+		$url = rtrim($request->getBaseUrl(), '/').str_replace('//', '/', $path);
 		if ($isChunkedUpload) {
 			$request->setHeader('destination', $url);
 		} else {

build/integration/features/bootstrap/FilesDropContext.php

Indentation +68 added lines, -68 removed lines

@@ -11,72 +11,72 @@
 require __DIR__ . '/../../vendor/autoload.php';
 
 class FilesDropContext implements Context, SnippetAcceptingContext {
-	use WebDav;
-
-	/**
-	 * @When Dropping file :path with :content
-	 */
-	public function droppingFileWith($path, $content, $nickname = null) {
-		$client = new Client();
-		$options = [];
-		if (count($this->lastShareData->data->element) > 0) {
-			$token = $this->lastShareData->data[0]->token;
-		} else {
-			$token = $this->lastShareData->data[0]->token;
-		}
-
-		$base = substr($this->baseUrl, 0, -4);
-		$fullUrl = str_replace('//', '/', $base . "/public.php/dav/files/$token/$path");
-
-		$options['headers'] = [
-			'X-REQUESTED-WITH' => 'XMLHttpRequest',
-		];
-
-		if ($nickname) {
-			$options['headers']['X-NC-NICKNAME'] = $nickname;
-		}
-
-		$options['body'] = \GuzzleHttp\Psr7\Utils::streamFor($content);
-
-		try {
-			$this->response = $client->request('PUT', $fullUrl, $options);
-		} catch (\GuzzleHttp\Exception\ClientException $e) {
-			$this->response = $e->getResponse();
-		}
-	}
-
-
-	/**
-	 * @When Dropping file :path with :content as :nickName
-	 */
-	public function droppingFileWithAs($path, $content, $nickname) {
-		$this->droppingFileWith($path, $content, $nickname);
-	}
-
-
-	/**
-	 * @When Creating folder :folder in drop
-	 */
-	public function creatingFolderInDrop($folder) {
-		$client = new Client();
-		$options = [];
-		if (count($this->lastShareData->data->element) > 0) {
-			$token = $this->lastShareData->data[0]->token;
-		} else {
-			$token = $this->lastShareData->data[0]->token;
-		}
-
-		$base = substr($this->baseUrl, 0, -4);
-		$fullUrl = str_replace('//', '/', $base . "/public.php/dav/files/$token/$folder");
-
-		$options['headers'] = [
-			'X-REQUESTED-WITH' => 'XMLHttpRequest',
-		];
-
-		try {
-			$this->response = $client->request('MKCOL', $fullUrl, $options);
-		} catch (\GuzzleHttp\Exception\ClientException $e) {
-			$this->response = $e->getResponse();
-		}
-	}
+    use WebDav;
+
+    /**
+     * @When Dropping file :path with :content
+     */
+    public function droppingFileWith($path, $content, $nickname = null) {
+        $client = new Client();
+        $options = [];
+        if (count($this->lastShareData->data->element) > 0) {
+            $token = $this->lastShareData->data[0]->token;
+        } else {
+            $token = $this->lastShareData->data[0]->token;
+        }
+
+        $base = substr($this->baseUrl, 0, -4);
+        $fullUrl = str_replace('//', '/', $base . "/public.php/dav/files/$token/$path");
+
+        $options['headers'] = [
+            'X-REQUESTED-WITH' => 'XMLHttpRequest',
+        ];
+
+        if ($nickname) {
+            $options['headers']['X-NC-NICKNAME'] = $nickname;
+        }
+
+        $options['body'] = \GuzzleHttp\Psr7\Utils::streamFor($content);
+
+        try {
+            $this->response = $client->request('PUT', $fullUrl, $options);
+        } catch (\GuzzleHttp\Exception\ClientException $e) {
+            $this->response = $e->getResponse();
+        }
+    }
+
+
+    /**
+     * @When Dropping file :path with :content as :nickName
+     */
+    public function droppingFileWithAs($path, $content, $nickname) {
+        $this->droppingFileWith($path, $content, $nickname);
+    }
+
+
+    /**
+     * @When Creating folder :folder in drop
+     */
+    public function creatingFolderInDrop($folder) {
+        $client = new Client();
+        $options = [];
+        if (count($this->lastShareData->data->element) > 0) {
+            $token = $this->lastShareData->data[0]->token;
+        } else {
+            $token = $this->lastShareData->data[0]->token;
+        }
+
+        $base = substr($this->baseUrl, 0, -4);
+        $fullUrl = str_replace('//', '/', $base . "/public.php/dav/files/$token/$folder");
+
+        $options['headers'] = [
+            'X-REQUESTED-WITH' => 'XMLHttpRequest',
+        ];
+
+        try {
+            $this->response = $client->request('MKCOL', $fullUrl, $options);
+        } catch (\GuzzleHttp\Exception\ClientException $e) {
+            $this->response = $e->getResponse();
+        }
+    }
 }