nextcloud / server

lib/private/Files/ObjectStore/S3ObjectTrait.php

Indentation +159 added lines, -159 removed lines

@@ -35,163 +35,163 @@
 use Psr\Http\Message\StreamInterface;
 
 trait S3ObjectTrait {
-	/**
-	 * Returns the connection
-	 *
-	 * @return S3Client connected client
-	 * @throws \Exception if connection could not be made
-	 */
-	abstract protected function getConnection();
-
-	abstract protected function getCertificateBundlePath(): ?string;
-	abstract protected function getSSECParameters(bool $copy = false): array;
-
-	/**
-	 * @param string $urn the unified resource name used to identify the object
-	 *
-	 * @return resource stream with the read data
-	 * @throws \Exception when something goes wrong, message will be logged
-	 * @since 7.0.0
-	 */
-	public function readObject($urn) {
-		$fh = SeekableHttpStream::open(function ($range) use ($urn) {
-			$command = $this->getConnection()->getCommand('GetObject', [
-				'Bucket' => $this->bucket,
-				'Key' => $urn,
-				'Range' => 'bytes=' . $range,
-			] + $this->getSSECParameters());
-			$request = \Aws\serialize($command);
-			$headers = [];
-			foreach ($request->getHeaders() as $key => $values) {
-				foreach ($values as $value) {
-					$headers[] = "$key: $value";
-				}
-			}
-			$opts = [
-				'http' => [
-					'protocol_version' => $request->getProtocolVersion(),
-					'header' => $headers,
-				]
-			];
-			$bundle = $this->getCertificateBundlePath();
-			if ($bundle) {
-				$opts['ssl'] = [
-					'cafile' => $bundle
-				];
-			}
-
-			if ($this->getProxy()) {
-				$opts['http']['proxy'] = $this->getProxy();
-				$opts['http']['request_fulluri'] = true;
-			}
-
-			$context = stream_context_create($opts);
-			return fopen($request->getUri(), 'r', false, $context);
-		});
-		if (!$fh) {
-			throw new \Exception("Failed to read object $urn");
-		}
-		return $fh;
-	}
-
-
-	/**
-	 * Single object put helper
-	 *
-	 * @param string $urn the unified resource name used to identify the object
-	 * @param StreamInterface $stream stream with the data to write
-	 * @param string|null $mimetype the mimetype to set for the remove object @since 22.0.0
-	 * @throws \Exception when something goes wrong, message will be logged
-	 */
-	protected function writeSingle(string $urn, StreamInterface $stream, string $mimetype = null): void {
-		$this->getConnection()->putObject([
-			'Bucket' => $this->bucket,
-			'Key' => $urn,
-			'Body' => $stream,
-			'ACL' => 'private',
-			'ContentType' => $mimetype,
-			'StorageClass' => $this->storageClass,
-		] + $this->getSSECParameters());
-	}
-
-
-	/**
-	 * Multipart upload helper that tries to avoid orphaned fragments in S3
-	 *
-	 * @param string $urn the unified resource name used to identify the object
-	 * @param StreamInterface $stream stream with the data to write
-	 * @param string|null $mimetype the mimetype to set for the remove object
-	 * @throws \Exception when something goes wrong, message will be logged
-	 */
-	protected function writeMultiPart(string $urn, StreamInterface $stream, string $mimetype = null): void {
-		$uploader = new MultipartUploader($this->getConnection(), $stream, [
-			'bucket' => $this->bucket,
-			'key' => $urn,
-			'part_size' => $this->uploadPartSize,
-			'params' => [
-				'ContentType' => $mimetype,
-				'StorageClass' => $this->storageClass,
-			] + $this->getSSECParameters(),
-		]);
-
-		try {
-			$uploader->upload();
-		} catch (S3MultipartUploadException $e) {
-			// if anything goes wrong with multipart, make sure that you don´t poison and
-			// slow down s3 bucket with orphaned fragments
-			$uploadInfo = $e->getState()->getId();
-			if ($e->getState()->isInitiated() && (array_key_exists('UploadId', $uploadInfo))) {
-				$this->getConnection()->abortMultipartUpload($uploadInfo);
-			}
-			throw new \OCA\DAV\Connector\Sabre\Exception\BadGateway("Error while uploading to S3 bucket", 0, $e);
-		}
-	}
-
-
-	/**
-	 * @param string $urn the unified resource name used to identify the object
-	 * @param resource $stream stream with the data to write
-	 * @param string|null $mimetype the mimetype to set for the remove object @since 22.0.0
-	 * @throws \Exception when something goes wrong, message will be logged
-	 * @since 7.0.0
-	 */
-	public function writeObject($urn, $stream, string $mimetype = null) {
-		$psrStream = Utils::streamFor($stream);
-
-		// ($psrStream->isSeekable() && $psrStream->getSize() !== null) evaluates to true for a On-Seekable stream
-		// so the optimisation does not apply
-		$buffer = new Psr7\Stream(fopen("php://memory", 'rwb+'));
-		Utils::copyToStream($psrStream, $buffer, $this->putSizeLimit);
-		$buffer->seek(0);
-		if ($buffer->getSize() < $this->putSizeLimit) {
-			// buffer is fully seekable, so use it directly for the small upload
-			$this->writeSingle($urn, $buffer, $mimetype);
-		} else {
-			$loadStream = new Psr7\AppendStream([$buffer, $psrStream]);
-			$this->writeMultiPart($urn, $loadStream, $mimetype);
-		}
-	}
-
-	/**
-	 * @param string $urn the unified resource name used to identify the object
-	 * @return void
-	 * @throws \Exception when something goes wrong, message will be logged
-	 * @since 7.0.0
-	 */
-	public function deleteObject($urn) {
-		$this->getConnection()->deleteObject([
-			'Bucket' => $this->bucket,
-			'Key' => $urn,
-		]);
-	}
-
-	public function objectExists($urn) {
-		return $this->getConnection()->doesObjectExist($this->bucket, $urn, $this->getSSECParameters());
-	}
-
-	public function copyObject($from, $to) {
-		$this->getConnection()->copy($this->getBucket(), $from, $this->getBucket(), $to, 'private', [
-			'params' => $this->getSSECParameters() + $this->getSSECParameters(true)
-		]);
-	}
+    /**
+     * Returns the connection
+     *
+     * @return S3Client connected client
+     * @throws \Exception if connection could not be made
+     */
+    abstract protected function getConnection();
+
+    abstract protected function getCertificateBundlePath(): ?string;
+    abstract protected function getSSECParameters(bool $copy = false): array;
+
+    /**
+     * @param string $urn the unified resource name used to identify the object
+     *
+     * @return resource stream with the read data
+     * @throws \Exception when something goes wrong, message will be logged
+     * @since 7.0.0
+     */
+    public function readObject($urn) {
+        $fh = SeekableHttpStream::open(function ($range) use ($urn) {
+            $command = $this->getConnection()->getCommand('GetObject', [
+                'Bucket' => $this->bucket,
+                'Key' => $urn,
+                'Range' => 'bytes=' . $range,
+            ] + $this->getSSECParameters());
+            $request = \Aws\serialize($command);
+            $headers = [];
+            foreach ($request->getHeaders() as $key => $values) {
+                foreach ($values as $value) {
+                    $headers[] = "$key: $value";
+                }
+            }
+            $opts = [
+                'http' => [
+                    'protocol_version' => $request->getProtocolVersion(),
+                    'header' => $headers,
+                ]
+            ];
+            $bundle = $this->getCertificateBundlePath();
+            if ($bundle) {
+                $opts['ssl'] = [
+                    'cafile' => $bundle
+                ];
+            }
+
+            if ($this->getProxy()) {
+                $opts['http']['proxy'] = $this->getProxy();
+                $opts['http']['request_fulluri'] = true;
+            }
+
+            $context = stream_context_create($opts);
+            return fopen($request->getUri(), 'r', false, $context);
+        });
+        if (!$fh) {
+            throw new \Exception("Failed to read object $urn");
+        }
+        return $fh;
+    }
+
+
+    /**
+     * Single object put helper
+     *
+     * @param string $urn the unified resource name used to identify the object
+     * @param StreamInterface $stream stream with the data to write
+     * @param string|null $mimetype the mimetype to set for the remove object @since 22.0.0
+     * @throws \Exception when something goes wrong, message will be logged
+     */
+    protected function writeSingle(string $urn, StreamInterface $stream, string $mimetype = null): void {
+        $this->getConnection()->putObject([
+            'Bucket' => $this->bucket,
+            'Key' => $urn,
+            'Body' => $stream,
+            'ACL' => 'private',
+            'ContentType' => $mimetype,
+            'StorageClass' => $this->storageClass,
+        ] + $this->getSSECParameters());
+    }
+
+
+    /**
+     * Multipart upload helper that tries to avoid orphaned fragments in S3
+     *
+     * @param string $urn the unified resource name used to identify the object
+     * @param StreamInterface $stream stream with the data to write
+     * @param string|null $mimetype the mimetype to set for the remove object
+     * @throws \Exception when something goes wrong, message will be logged
+     */
+    protected function writeMultiPart(string $urn, StreamInterface $stream, string $mimetype = null): void {
+        $uploader = new MultipartUploader($this->getConnection(), $stream, [
+            'bucket' => $this->bucket,
+            'key' => $urn,
+            'part_size' => $this->uploadPartSize,
+            'params' => [
+                'ContentType' => $mimetype,
+                'StorageClass' => $this->storageClass,
+            ] + $this->getSSECParameters(),
+        ]);
+
+        try {
+            $uploader->upload();
+        } catch (S3MultipartUploadException $e) {
+            // if anything goes wrong with multipart, make sure that you don´t poison and
+            // slow down s3 bucket with orphaned fragments
+            $uploadInfo = $e->getState()->getId();
+            if ($e->getState()->isInitiated() && (array_key_exists('UploadId', $uploadInfo))) {
+                $this->getConnection()->abortMultipartUpload($uploadInfo);
+            }
+            throw new \OCA\DAV\Connector\Sabre\Exception\BadGateway("Error while uploading to S3 bucket", 0, $e);
+        }
+    }
+
+
+    /**
+     * @param string $urn the unified resource name used to identify the object
+     * @param resource $stream stream with the data to write
+     * @param string|null $mimetype the mimetype to set for the remove object @since 22.0.0
+     * @throws \Exception when something goes wrong, message will be logged
+     * @since 7.0.0
+     */
+    public function writeObject($urn, $stream, string $mimetype = null) {
+        $psrStream = Utils::streamFor($stream);
+
+        // ($psrStream->isSeekable() && $psrStream->getSize() !== null) evaluates to true for a On-Seekable stream
+        // so the optimisation does not apply
+        $buffer = new Psr7\Stream(fopen("php://memory", 'rwb+'));
+        Utils::copyToStream($psrStream, $buffer, $this->putSizeLimit);
+        $buffer->seek(0);
+        if ($buffer->getSize() < $this->putSizeLimit) {
+            // buffer is fully seekable, so use it directly for the small upload
+            $this->writeSingle($urn, $buffer, $mimetype);
+        } else {
+            $loadStream = new Psr7\AppendStream([$buffer, $psrStream]);
+            $this->writeMultiPart($urn, $loadStream, $mimetype);
+        }
+    }
+
+    /**
+     * @param string $urn the unified resource name used to identify the object
+     * @return void
+     * @throws \Exception when something goes wrong, message will be logged
+     * @since 7.0.0
+     */
+    public function deleteObject($urn) {
+        $this->getConnection()->deleteObject([
+            'Bucket' => $this->bucket,
+            'Key' => $urn,
+        ]);
+    }
+
+    public function objectExists($urn) {
+        return $this->getConnection()->doesObjectExist($this->bucket, $urn, $this->getSSECParameters());
+    }
+
+    public function copyObject($from, $to) {
+        $this->getConnection()->copy($this->getBucket(), $from, $this->getBucket(), $to, 'private', [
+            'params' => $this->getSSECParameters() + $this->getSSECParameters(true)
+        ]);
+    }
 }

apps/files/lib/Command/Object/Put.php

Indentation +41 added lines, -41 removed lines

@@ -33,52 +33,52 @@
 use Symfony\Component\Console\Question\ConfirmationQuestion;
 
 class Put extends Command {
-	private ObjectUtil $objectUtils;
-	private IMimeTypeDetector $mimeTypeDetector;
+    private ObjectUtil $objectUtils;
+    private IMimeTypeDetector $mimeTypeDetector;
 
-	public function __construct(ObjectUtil $objectUtils, IMimeTypeDetector $mimeTypeDetector) {
-		$this->objectUtils = $objectUtils;
-		$this->mimeTypeDetector = $mimeTypeDetector;
-		parent::__construct();
-	}
+    public function __construct(ObjectUtil $objectUtils, IMimeTypeDetector $mimeTypeDetector) {
+        $this->objectUtils = $objectUtils;
+        $this->mimeTypeDetector = $mimeTypeDetector;
+        parent::__construct();
+    }
 
-	protected function configure(): void {
-		$this
-			->setName('files:object:put')
-			->setDescription('Write a file to the object store')
-			->addArgument('input', InputArgument::REQUIRED, "Source local path, use - to read from STDIN")
-			->addArgument('object', InputArgument::REQUIRED, "Object to write")
-			->addOption('bucket', 'b', InputOption::VALUE_REQUIRED, "Bucket where to store the object, only required in cases where it can't be determined from the config");;
-	}
+    protected function configure(): void {
+        $this
+            ->setName('files:object:put')
+            ->setDescription('Write a file to the object store')
+            ->addArgument('input', InputArgument::REQUIRED, "Source local path, use - to read from STDIN")
+            ->addArgument('object', InputArgument::REQUIRED, "Object to write")
+            ->addOption('bucket', 'b', InputOption::VALUE_REQUIRED, "Bucket where to store the object, only required in cases where it can't be determined from the config");;
+    }
 
-	public function execute(InputInterface $input, OutputInterface $output): int {
-		$object = $input->getArgument('object');
-		$inputName = (string)$input->getArgument('input');
-		$objectStore = $this->objectUtils->getObjectStore($input->getOption("bucket"), $output);
-		if (!$objectStore) {
-			return -1;
-		}
+    public function execute(InputInterface $input, OutputInterface $output): int {
+        $object = $input->getArgument('object');
+        $inputName = (string)$input->getArgument('input');
+        $objectStore = $this->objectUtils->getObjectStore($input->getOption("bucket"), $output);
+        if (!$objectStore) {
+            return -1;
+        }
 
-		if ($fileId = $this->objectUtils->objectExistsInDb($object)) {
-			$output->writeln("<error>Warning, object $object belongs to an existing file, overwriting the object contents can lead to unexpected behavior.</error>");
-			$output->writeln("You can use <info>occ files:put $inputName $fileId</info> to write to the file safely.");
-			$output->writeln("");
+        if ($fileId = $this->objectUtils->objectExistsInDb($object)) {
+            $output->writeln("<error>Warning, object $object belongs to an existing file, overwriting the object contents can lead to unexpected behavior.</error>");
+            $output->writeln("You can use <info>occ files:put $inputName $fileId</info> to write to the file safely.");
+            $output->writeln("");
 
-			/** @var QuestionHelper $helper */
-			$helper = $this->getHelper('question');
-			$question = new ConfirmationQuestion("Write to the object anyway? [y/N] ", false);
-			if (!$helper->ask($input, $output, $question)) {
-				return -1;
-			}
-		}
+            /** @var QuestionHelper $helper */
+            $helper = $this->getHelper('question');
+            $question = new ConfirmationQuestion("Write to the object anyway? [y/N] ", false);
+            if (!$helper->ask($input, $output, $question)) {
+                return -1;
+            }
+        }
 
-		$source = $inputName === '-' ? STDIN : fopen($inputName, 'r');
-		if (!$source) {
-			$output->writeln("<error>Failed to open $inputName</error>");
-			return 1;
-		}
-		$objectStore->writeObject($object, $source, $this->mimeTypeDetector->detectPath($inputName));
-		return 0;
-	}
+        $source = $inputName === '-' ? STDIN : fopen($inputName, 'r');
+        if (!$source) {
+            $output->writeln("<error>Failed to open $inputName</error>");
+            return 1;
+        }
+        $objectStore->writeObject($object, $source, $this->mimeTypeDetector->detectPath($inputName));
+        return 0;
+    }
 
 }

apps/files/lib/Command/Object/ObjectUtil.php

Indentation +70 added lines, -70 removed lines

@@ -30,81 +30,81 @@
 use Symfony\Component\Console\Output\OutputInterface;
 
 class ObjectUtil {
-	private IConfig $config;
-	private IDBConnection $connection;
+    private IConfig $config;
+    private IDBConnection $connection;
 
-	public function __construct(IConfig $config, IDBConnection $connection) {
-		$this->config = $config;
-		$this->connection = $connection;
-	}
+    public function __construct(IConfig $config, IDBConnection $connection) {
+        $this->config = $config;
+        $this->connection = $connection;
+    }
 
-	private function getObjectStoreConfig(): ?array {
-		$config = $this->config->getSystemValue('objectstore_multibucket');
-		if (is_array($config)) {
-			$config['multibucket'] = true;
-			return $config;
-		}
-		$config = $this->config->getSystemValue('objectstore');
-		if (is_array($config)) {
-			if (!isset($config['multibucket'])) {
-				$config['multibucket'] = false;
-			}
-			return $config;
-		} else {
-			return null;
-		}
-	}
+    private function getObjectStoreConfig(): ?array {
+        $config = $this->config->getSystemValue('objectstore_multibucket');
+        if (is_array($config)) {
+            $config['multibucket'] = true;
+            return $config;
+        }
+        $config = $this->config->getSystemValue('objectstore');
+        if (is_array($config)) {
+            if (!isset($config['multibucket'])) {
+                $config['multibucket'] = false;
+            }
+            return $config;
+        } else {
+            return null;
+        }
+    }
 
-	public function getObjectStore(?string $bucket, OutputInterface $output): ?IObjectStore {
-		$config = $this->getObjectStoreConfig();
-		if (!$config) {
-			$output->writeln("<error>Instance is not using primary object store</error>");
-			return null;
-		}
-		if ($config['multibucket'] && !$bucket) {
-			$output->writeln("<error>--bucket option required</error> because <info>multi bucket</info> is enabled.");
-			return null;
-		}
+    public function getObjectStore(?string $bucket, OutputInterface $output): ?IObjectStore {
+        $config = $this->getObjectStoreConfig();
+        if (!$config) {
+            $output->writeln("<error>Instance is not using primary object store</error>");
+            return null;
+        }
+        if ($config['multibucket'] && !$bucket) {
+            $output->writeln("<error>--bucket option required</error> because <info>multi bucket</info> is enabled.");
+            return null;
+        }
 
-		if (!isset($config['arguments'])) {
-			throw new \Exception("no arguments configured for object store configuration");
-		}
-		if (!isset($config['class'])) {
-			throw new \Exception("no class configured for object store configuration");
-		}
+        if (!isset($config['arguments'])) {
+            throw new \Exception("no arguments configured for object store configuration");
+        }
+        if (!isset($config['class'])) {
+            throw new \Exception("no class configured for object store configuration");
+        }
 
-		if ($bucket) {
-			// s3, swift
-			$config['arguments']['bucket'] = $bucket;
-			// azure
-			$config['arguments']['container'] = $bucket;
-		}
+        if ($bucket) {
+            // s3, swift
+            $config['arguments']['bucket'] = $bucket;
+            // azure
+            $config['arguments']['container'] = $bucket;
+        }
 
-		$store = new $config['class']($config['arguments']);
-		if (!$store instanceof IObjectStore) {
-			throw new \Exception("configured object store class is not an object store implementation");
-		}
-		return $store;
-	}
+        $store = new $config['class']($config['arguments']);
+        if (!$store instanceof IObjectStore) {
+            throw new \Exception("configured object store class is not an object store implementation");
+        }
+        return $store;
+    }
 
-	/**
-	 * Check if an object is referenced in the database
-	 */
-	public function objectExistsInDb(string $object): int|false {
-		if (str_starts_with($object, 'urn:oid:')) {
-			$fileId = (int)substr($object, strlen('urn:oid:'));
-			$query = $this->connection->getQueryBuilder();
-			$query->select('fileid')
-				->from('filecache')
-				->where($query->expr()->eq('fileid', $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT)));
-			$result = $query->executeQuery();
-			if ($result->fetchOne() !== false) {
-				return $fileId;
-			} else {
-				return false;
-			}
-		} else {
-			return false;
-		}
-	}
+    /**
+     * Check if an object is referenced in the database
+     */
+    public function objectExistsInDb(string $object): int|false {
+        if (str_starts_with($object, 'urn:oid:')) {
+            $fileId = (int)substr($object, strlen('urn:oid:'));
+            $query = $this->connection->getQueryBuilder();
+            $query->select('fileid')
+                ->from('filecache')
+                ->where($query->expr()->eq('fileid', $query->createNamedParameter($fileId, IQueryBuilder::PARAM_INT)));
+            $result = $query->executeQuery();
+            if ($result->fetchOne() !== false) {
+                return $fileId;
+            } else {
+                return false;
+            }
+        } else {
+            return false;
+        }
+    }
 }

apps/files/lib/Command/Object/Get.php

Indentation +40 added lines, -40 removed lines

@@ -31,50 +31,50 @@
 use Symfony\Component\Console\Output\OutputInterface;
 
 class Get extends Command {
-	private ObjectUtil $objectUtils;
+    private ObjectUtil $objectUtils;
 
-	public function __construct(ObjectUtil $objectUtils) {
-		$this->objectUtils = $objectUtils;
-		parent::__construct();
-	}
+    public function __construct(ObjectUtil $objectUtils) {
+        $this->objectUtils = $objectUtils;
+        parent::__construct();
+    }
 
-	protected function configure(): void {
-		$this
-			->setName('files:object:get')
-			->setDescription('Get the contents of an object')
-			->addArgument('object', InputArgument::REQUIRED, "Object to get")
-			->addArgument('output', InputArgument::REQUIRED, "Target local file to output to, use - for STDOUT")
-			->addOption('bucket', 'b', InputOption::VALUE_REQUIRED, "Bucket to get the object from, only required in cases where it can't be determined from the config");
-	}
+    protected function configure(): void {
+        $this
+            ->setName('files:object:get')
+            ->setDescription('Get the contents of an object')
+            ->addArgument('object', InputArgument::REQUIRED, "Object to get")
+            ->addArgument('output', InputArgument::REQUIRED, "Target local file to output to, use - for STDOUT")
+            ->addOption('bucket', 'b', InputOption::VALUE_REQUIRED, "Bucket to get the object from, only required in cases where it can't be determined from the config");
+    }
 
-	public function execute(InputInterface $input, OutputInterface $output): int {
-		$object = $input->getArgument('object');
-		$outputName = $input->getArgument('output');
-		$objectStore = $this->objectUtils->getObjectStore($input->getOption("bucket"), $output);
-		if (!$objectStore) {
-			return 1;
-		}
+    public function execute(InputInterface $input, OutputInterface $output): int {
+        $object = $input->getArgument('object');
+        $outputName = $input->getArgument('output');
+        $objectStore = $this->objectUtils->getObjectStore($input->getOption("bucket"), $output);
+        if (!$objectStore) {
+            return 1;
+        }
 
-		if (!$objectStore->objectExists($object)) {
-			$output->writeln("<error>Object $object does not exist</error>");
-			return 1;
-		} else {
-			try {
-				$source = $objectStore->readObject($object);
-			} catch (\Exception $e) {
-				$msg = $e->getMessage();
-				$output->writeln("<error>Failed to read $object from object store: $msg</error>");
-				return 1;
-			}
-			$target = $outputName === '-' ? STDOUT : fopen($outputName, 'w');
-			if (!$target) {
-				$output->writeln("<error>Failed to open $outputName for writing</error>");
-				return 1;
-			}
+        if (!$objectStore->objectExists($object)) {
+            $output->writeln("<error>Object $object does not exist</error>");
+            return 1;
+        } else {
+            try {
+                $source = $objectStore->readObject($object);
+            } catch (\Exception $e) {
+                $msg = $e->getMessage();
+                $output->writeln("<error>Failed to read $object from object store: $msg</error>");
+                return 1;
+            }
+            $target = $outputName === '-' ? STDOUT : fopen($outputName, 'w');
+            if (!$target) {
+                $output->writeln("<error>Failed to open $outputName for writing</error>");
+                return 1;
+            }
 
-			stream_copy_to_stream($source, $target);
-			return 0;
-		}
-	}
+            stream_copy_to_stream($source, $target);
+            return 0;
+        }
+    }
 
 }

apps/files/lib/Command/Object/Delete.php

Indentation +35 added lines, -35 removed lines

@@ -34,45 +34,45 @@
 use Symfony\Component\Console\Question\ConfirmationQuestion;
 
 class Delete extends Command {
-	private ObjectUtil $objectUtils;
+    private ObjectUtil $objectUtils;
 
-	public function __construct(ObjectUtil $objectUtils) {
-		$this->objectUtils = $objectUtils;
-		parent::__construct();
-	}
+    public function __construct(ObjectUtil $objectUtils) {
+        $this->objectUtils = $objectUtils;
+        parent::__construct();
+    }
 
-	protected function configure(): void {
-		$this
-			->setName('files:object:delete')
-			->setDescription('Delete an object from the object store')
-			->addArgument('object', InputArgument::REQUIRED, "Object to delete")
-			->addOption('bucket', 'b', InputOption::VALUE_REQUIRED, "Bucket to delete the object from, only required in cases where it can't be determined from the config");
-	}
+    protected function configure(): void {
+        $this
+            ->setName('files:object:delete')
+            ->setDescription('Delete an object from the object store')
+            ->addArgument('object', InputArgument::REQUIRED, "Object to delete")
+            ->addOption('bucket', 'b', InputOption::VALUE_REQUIRED, "Bucket to delete the object from, only required in cases where it can't be determined from the config");
+    }
 
-	public function execute(InputInterface $input, OutputInterface $output): int {
-		$object = $input->getArgument('object');
-		$objectStore = $this->objectUtils->getObjectStore($input->getOption("bucket"), $output);
-		if (!$objectStore) {
-			return -1;
-		}
+    public function execute(InputInterface $input, OutputInterface $output): int {
+        $object = $input->getArgument('object');
+        $objectStore = $this->objectUtils->getObjectStore($input->getOption("bucket"), $output);
+        if (!$objectStore) {
+            return -1;
+        }
 
-		if ($fileId = $this->objectUtils->objectExistsInDb($object)) {
-			$output->writeln("<error>Warning, object $object belongs to an existing file, deleting the object will lead to unexpected behavior if not replaced</error>");
-			$output->writeln("  Note: use <info>occ files:delete $fileId</info> to delete the file cleanly or <info>occ info:file $fileId</info> for more information about the file");
-			$output->writeln("");
-		}
+        if ($fileId = $this->objectUtils->objectExistsInDb($object)) {
+            $output->writeln("<error>Warning, object $object belongs to an existing file, deleting the object will lead to unexpected behavior if not replaced</error>");
+            $output->writeln("  Note: use <info>occ files:delete $fileId</info> to delete the file cleanly or <info>occ info:file $fileId</info> for more information about the file");
+            $output->writeln("");
+        }
 
-		if (!$objectStore->objectExists($object)) {
-			$output->writeln("<error>Object $object does not exist</error>");
-			return -1;
-		}
+        if (!$objectStore->objectExists($object)) {
+            $output->writeln("<error>Object $object does not exist</error>");
+            return -1;
+        }
 
-		/** @var QuestionHelper $helper */
-		$helper = $this->getHelper('question');
-		$question = new ConfirmationQuestion("Delete $object? [y/N] ", false);
-		if ($helper->ask($input, $output, $question)) {
-			$objectStore->deleteObject($object);
-		}
-		return 0;
-	}
+        /** @var QuestionHelper $helper */
+        $helper = $this->getHelper('question');
+        $question = new ConfirmationQuestion("Delete $object? [y/N] ", false);
+        if ($helper->ask($input, $output, $question)) {
+            $objectStore->deleteObject($object);
+        }
+        return 0;
+    }
 }