12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394 |
- <?php
- namespace OCA\DAV\BulkUpload;
- use OCA\DAV\Connector\Sabre\MtimeSanitizer;
- use OCP\AppFramework\Http;
- use OCP\Files\DavUtil;
- use OCP\Files\Folder;
- use Psr\Log\LoggerInterface;
- use Sabre\DAV\Server;
- use Sabre\DAV\ServerPlugin;
- use Sabre\HTTP\RequestInterface;
- use Sabre\HTTP\ResponseInterface;
- class BulkUploadPlugin extends ServerPlugin {
- public function __construct(
- private Folder $userFolder,
- private LoggerInterface $logger,
- ) {
- }
-
- public function initialize(Server $server): void {
- $server->on('method:POST', [$this, 'httpPost'], 10);
- }
-
- public function httpPost(RequestInterface $request, ResponseInterface $response): bool {
-
- if ($request->getPath() !== 'bulk') {
- return true;
- }
- $multiPartParser = new MultipartRequestParser($request, $this->logger);
- $writtenFiles = [];
- while (!$multiPartParser->isAtLastBoundary()) {
- try {
- [$headers, $content] = $multiPartParser->parseNextPart();
- } catch (\Exception $e) {
-
- $this->logger->error($e->getMessage());
- $response->setStatus(Http::STATUS_BAD_REQUEST);
- $response->setBody(json_encode($writtenFiles, JSON_THROW_ON_ERROR));
- return false;
- }
- try {
-
- if (isset($headers['x-file-mtime'])) {
- $mtime = MtimeSanitizer::sanitizeMtime($headers['x-file-mtime']);
- } elseif (isset($headers['x-oc-mtime'])) {
- $mtime = MtimeSanitizer::sanitizeMtime($headers['x-oc-mtime']);
- } else {
- $mtime = null;
- }
- $node = $this->userFolder->newFile($headers['x-file-path'], $content);
- $node->touch($mtime);
- $node = $this->userFolder->getFirstNodeById($node->getId());
- $writtenFiles[$headers['x-file-path']] = [
- 'error' => false,
- 'etag' => $node->getETag(),
- 'fileid' => DavUtil::getDavFileId($node->getId()),
- 'permissions' => DavUtil::getDavPermissions($node),
- ];
- } catch (\Exception $e) {
- $this->logger->error($e->getMessage(), ['path' => $headers['x-file-path']]);
- $writtenFiles[$headers['x-file-path']] = [
- 'error' => true,
- 'message' => $e->getMessage(),
- ];
- }
- }
- $response->setStatus(Http::STATUS_OK);
- $response->setBody(json_encode($writtenFiles, JSON_THROW_ON_ERROR));
- return false;
- }
- }
|