nextcloud / server

lib/public/BackgroundJob/IParallelAwareJob.php

Indentation +13 added lines, -13 removed lines

@@ -30,18 +30,18 @@
  * @since 27.0.0
  */
 interface IParallelAwareJob {
-	/**
-	 * Set this to false to prevent two Jobs from the same class from running in parallel
-	 *
-	 * @param bool $allow
-	 * @return void
-	 * @since 27.0.0
-	 */
-	public function setAllowParallelRuns(bool $allow): void;
+    /**
+     * Set this to false to prevent two Jobs from the same class from running in parallel
+     *
+     * @param bool $allow
+     * @return void
+     * @since 27.0.0
+     */
+    public function setAllowParallelRuns(bool $allow): void;
 
-	/**
-	 * @return bool
-	 * @since 27.0.0
-	 */
-	public function getAllowParallelRuns(): bool;
+    /**
+     * @return bool
+     * @since 27.0.0
+     */
+    public function getAllowParallelRuns(): bool;
 }

lib/public/Files/File.php

Indentation +63 added lines, -63 removed lines

@@ -35,73 +35,73 @@
  * @since 6.0.0
  */
 interface File extends Node {
-	/**
-	 * Get the content of the file as string
-	 *
-	 * @return string
-	 * @throws NotPermittedException
-	 * @throws GenericFileException
-	 * @throws LockedException
-	 * @since 6.0.0
-	 */
-	public function getContent();
+    /**
+     * Get the content of the file as string
+     *
+     * @return string
+     * @throws NotPermittedException
+     * @throws GenericFileException
+     * @throws LockedException
+     * @since 6.0.0
+     */
+    public function getContent();
 
-	/**
-	 * Write to the file from string data
-	 *
-	 * @param string|resource $data
-	 * @throws NotPermittedException
-	 * @throws GenericFileException
-	 * @throws LockedException
-	 * @since 6.0.0
-	 */
-	public function putContent($data);
+    /**
+     * Write to the file from string data
+     *
+     * @param string|resource $data
+     * @throws NotPermittedException
+     * @throws GenericFileException
+     * @throws LockedException
+     * @since 6.0.0
+     */
+    public function putContent($data);
 
-	/**
-	 * Get the mimetype of the file
-	 *
-	 * @return string
-	 * @since 6.0.0
-	 */
-	public function getMimeType();
+    /**
+     * Get the mimetype of the file
+     *
+     * @return string
+     * @since 6.0.0
+     */
+    public function getMimeType();
 
-	/**
-	 * Open the file as stream, resulting resource can be operated as stream like the result from php's own fopen
-	 *
-	 * @param string $mode
-	 * @return resource|false
-	 * @throws NotPermittedException
-	 * @throws LockedException
-	 * @since 6.0.0
-	 */
-	public function fopen($mode);
+    /**
+     * Open the file as stream, resulting resource can be operated as stream like the result from php's own fopen
+     *
+     * @param string $mode
+     * @return resource|false
+     * @throws NotPermittedException
+     * @throws LockedException
+     * @since 6.0.0
+     */
+    public function fopen($mode);
 
-	/**
-	 * Compute the hash of the file
-	 * Type of hash is set with $type and can be anything supported by php's hash_file
-	 *
-	 * @param string $type
-	 * @param bool $raw
-	 * @return string
-	 * @since 6.0.0
-	 */
-	public function hash($type, $raw = false);
+    /**
+     * Compute the hash of the file
+     * Type of hash is set with $type and can be anything supported by php's hash_file
+     *
+     * @param string $type
+     * @param bool $raw
+     * @return string
+     * @since 6.0.0
+     */
+    public function hash($type, $raw = false);
 
-	/**
-	 * Get the stored checksum for this file
-	 *
-	 * @return string
-	 * @since 9.0.0
-	 * @throws InvalidPathException
-	 * @throws NotFoundException
-	 */
-	public function getChecksum();
+    /**
+     * Get the stored checksum for this file
+     *
+     * @return string
+     * @since 9.0.0
+     * @throws InvalidPathException
+     * @throws NotFoundException
+     */
+    public function getChecksum();
 
-	/**
-	 * Get the extension of this file
-	 *
-	 * @return string
-	 * @since 15.0.0
-	 */
-	public function getExtension(): string;
+    /**
+     * Get the extension of this file
+     *
+     * @return string
+     * @since 15.0.0
+     */
+    public function getExtension(): string;
 }

lib/private/Files/Node/File.php

Indentation +117 added lines, -117 removed lines

@@ -33,129 +33,129 @@
 use OCP\Lock\LockedException;
 
 class File extends Node implements \OCP\Files\File {
-	/**
-	 * Creates a Folder that represents a non-existing path
-	 *
-	 * @param string $path path
-	 * @return NonExistingFile non-existing node
-	 */
-	protected function createNonExistingNode($path) {
-		return new NonExistingFile($this->root, $this->view, $path);
-	}
+    /**
+     * Creates a Folder that represents a non-existing path
+     *
+     * @param string $path path
+     * @return NonExistingFile non-existing node
+     */
+    protected function createNonExistingNode($path) {
+        return new NonExistingFile($this->root, $this->view, $path);
+    }
 
-	/**
-	 * @return string
-	 * @throws NotPermittedException
-	 * @throws GenericFileException
-	 * @throws LockedException
-	 */
-	public function getContent() {
-		if ($this->checkPermissions(\OCP\Constants::PERMISSION_READ)) {
-			$content = $this->view->file_get_contents($this->path);
-			if ($content === false) {
-				throw new GenericFileException();
-			}
-			return $content;
-		} else {
-			throw new NotPermittedException();
-		}
-	}
+    /**
+     * @return string
+     * @throws NotPermittedException
+     * @throws GenericFileException
+     * @throws LockedException
+     */
+    public function getContent() {
+        if ($this->checkPermissions(\OCP\Constants::PERMISSION_READ)) {
+            $content = $this->view->file_get_contents($this->path);
+            if ($content === false) {
+                throw new GenericFileException();
+            }
+            return $content;
+        } else {
+            throw new NotPermittedException();
+        }
+    }
 
-	/**
-	 * @param string|resource $data
-	 * @throws NotPermittedException
-	 * @throws GenericFileException
-	 * @throws LockedException
-	 */
-	public function putContent($data) {
-		if ($this->checkPermissions(\OCP\Constants::PERMISSION_UPDATE)) {
-			$this->sendHooks(['preWrite']);
-			if ($this->view->file_put_contents($this->path, $data) === false) {
-				throw new GenericFileException('file_put_contents failed');
-			}
-			$this->fileInfo = null;
-			$this->sendHooks(['postWrite']);
-		} else {
-			throw new NotPermittedException();
-		}
-	}
+    /**
+     * @param string|resource $data
+     * @throws NotPermittedException
+     * @throws GenericFileException
+     * @throws LockedException
+     */
+    public function putContent($data) {
+        if ($this->checkPermissions(\OCP\Constants::PERMISSION_UPDATE)) {
+            $this->sendHooks(['preWrite']);
+            if ($this->view->file_put_contents($this->path, $data) === false) {
+                throw new GenericFileException('file_put_contents failed');
+            }
+            $this->fileInfo = null;
+            $this->sendHooks(['postWrite']);
+        } else {
+            throw new NotPermittedException();
+        }
+    }
 
-	/**
-	 * @param string $mode
-	 * @return resource|false
-	 * @throws NotPermittedException
-	 * @throws LockedException
-	 */
-	public function fopen($mode) {
-		$preHooks = [];
-		$postHooks = [];
-		$requiredPermissions = \OCP\Constants::PERMISSION_READ;
-		switch ($mode) {
-			case 'r+':
-			case 'rb+':
-			case 'w+':
-			case 'wb+':
-			case 'x+':
-			case 'xb+':
-			case 'a+':
-			case 'ab+':
-			case 'w':
-			case 'wb':
-			case 'x':
-			case 'xb':
-			case 'a':
-			case 'ab':
-				$preHooks[] = 'preWrite';
-				$postHooks[] = 'postWrite';
-				$requiredPermissions |= \OCP\Constants::PERMISSION_UPDATE;
-				break;
-		}
+    /**
+     * @param string $mode
+     * @return resource|false
+     * @throws NotPermittedException
+     * @throws LockedException
+     */
+    public function fopen($mode) {
+        $preHooks = [];
+        $postHooks = [];
+        $requiredPermissions = \OCP\Constants::PERMISSION_READ;
+        switch ($mode) {
+            case 'r+':
+            case 'rb+':
+            case 'w+':
+            case 'wb+':
+            case 'x+':
+            case 'xb+':
+            case 'a+':
+            case 'ab+':
+            case 'w':
+            case 'wb':
+            case 'x':
+            case 'xb':
+            case 'a':
+            case 'ab':
+                $preHooks[] = 'preWrite';
+                $postHooks[] = 'postWrite';
+                $requiredPermissions |= \OCP\Constants::PERMISSION_UPDATE;
+                break;
+        }
 
-		if ($this->checkPermissions($requiredPermissions)) {
-			$this->sendHooks($preHooks);
-			$result = $this->view->fopen($this->path, $mode);
-			$this->sendHooks($postHooks);
-			return $result;
-		} else {
-			throw new NotPermittedException();
-		}
-	}
+        if ($this->checkPermissions($requiredPermissions)) {
+            $this->sendHooks($preHooks);
+            $result = $this->view->fopen($this->path, $mode);
+            $this->sendHooks($postHooks);
+            return $result;
+        } else {
+            throw new NotPermittedException();
+        }
+    }
 
-	/**
-	 * @throws NotPermittedException
-	 * @throws \OCP\Files\InvalidPathException
-	 * @throws \OCP\Files\NotFoundException
-	 */
-	public function delete() {
-		if ($this->checkPermissions(\OCP\Constants::PERMISSION_DELETE)) {
-			$this->sendHooks(['preDelete']);
-			$fileInfo = $this->getFileInfo();
-			$this->view->unlink($this->path);
-			$nonExisting = new NonExistingFile($this->root, $this->view, $this->path, $fileInfo);
-			$this->sendHooks(['postDelete'], [$nonExisting]);
-			$this->fileInfo = null;
-		} else {
-			throw new NotPermittedException();
-		}
-	}
+    /**
+     * @throws NotPermittedException
+     * @throws \OCP\Files\InvalidPathException
+     * @throws \OCP\Files\NotFoundException
+     */
+    public function delete() {
+        if ($this->checkPermissions(\OCP\Constants::PERMISSION_DELETE)) {
+            $this->sendHooks(['preDelete']);
+            $fileInfo = $this->getFileInfo();
+            $this->view->unlink($this->path);
+            $nonExisting = new NonExistingFile($this->root, $this->view, $this->path, $fileInfo);
+            $this->sendHooks(['postDelete'], [$nonExisting]);
+            $this->fileInfo = null;
+        } else {
+            throw new NotPermittedException();
+        }
+    }
 
-	/**
-	 * @param string $type
-	 * @param bool $raw
-	 * @return string
-	 */
-	public function hash($type, $raw = false) {
-		return $this->view->hash($type, $this->path, $raw);
-	}
+    /**
+     * @param string $type
+     * @param bool $raw
+     * @return string
+     */
+    public function hash($type, $raw = false) {
+        return $this->view->hash($type, $this->path, $raw);
+    }
 
-	/**
-	 * @inheritdoc
-	 */
-	public function getChecksum() {
-		return $this->getFileInfo()->getChecksum();
-	}
+    /**
+     * @inheritdoc
+     */
+    public function getChecksum() {
+        return $this->getFileInfo()->getChecksum();
+    }
 
-	public function getExtension(): string {
-		return $this->getFileInfo()->getExtension();
-	}
+    public function getExtension(): string {
+        return $this->getFileInfo()->getExtension();
+    }
 }

apps/dav/lib/Connector/Sabre/Exception/TooManyRequests.php

Indentation +22 added lines, -22 removed lines

@@ -30,26 +30,26 @@
 use Sabre\DAV\Server;
 
 class TooManyRequests extends NotAuthenticated {
-	public const NS_OWNCLOUD = 'http://owncloud.org/ns';
-
-	public function getHTTPCode() {
-		return 429;
-	}
-
-	/**
-	 * This method allows the exception to include additional information
-	 * into the WebDAV error response
-	 *
-	 * @param Server $server
-	 * @param DOMElement $errorNode
-	 * @return void
-	 */
-	public function serialize(Server $server, DOMElement $errorNode) {
-
-		// set ownCloud namespace
-		$errorNode->setAttribute('xmlns:o', self::NS_OWNCLOUD);
-
-		$error = $errorNode->ownerDocument->createElementNS('o:', 'o:hint', 'too many requests');
-		$errorNode->appendChild($error);
-	}
+    public const NS_OWNCLOUD = 'http://owncloud.org/ns';
+
+    public function getHTTPCode() {
+        return 429;
+    }
+
+    /**
+     * This method allows the exception to include additional information
+     * into the WebDAV error response
+     *
+     * @param Server $server
+     * @param DOMElement $errorNode
+     * @return void
+     */
+    public function serialize(Server $server, DOMElement $errorNode) {
+
+        // set ownCloud namespace
+        $errorNode->setAttribute('xmlns:o', self::NS_OWNCLOUD);
+
+        $error = $errorNode->ownerDocument->createElementNS('o:', 'o:hint', 'too many requests');
+        $errorNode->appendChild($error);
+    }
 }

lib/public/UserMigration/ISizeEstimationMigrator.php

Indentation +8 added lines, -8 removed lines

@@ -33,12 +33,12 @@
  * @since 25.0.0
  */
 interface ISizeEstimationMigrator {
-	/**
-	 * Returns an estimate of the exported data size in KiB.
-	 * Should be fast, favor performance over accuracy.
-	 *
-	 * @since 25.0.0
-	 * @since 27.0.0 return value may overflow from int to float
-	 */
-	public function getEstimatedExportSize(IUser $user): int|float;
+    /**
+     * Returns an estimate of the exported data size in KiB.
+     * Should be fast, favor performance over accuracy.
+     *
+     * @since 25.0.0
+     * @since 27.0.0 return value may overflow from int to float
+     */
+    public function getEstimatedExportSize(IUser $user): int|float;
 }

lib/public/Accounts/IAccountPropertyCollection.php

Indentation +53 added lines, -53 removed lines

@@ -37,64 +37,64 @@
  * @since 22.0.0
  */
 interface IAccountPropertyCollection extends JsonSerializable {
-	/**
-	 * returns the collection name
-	 *
-	 * @since 22.0.0
-	 */
-	public function getName(): string;
+    /**
+     * returns the collection name
+     *
+     * @since 22.0.0
+     */
+    public function getName(): string;
 
-	/**
-	 * set properties of this collection
-	 *
-	 * @param IAccountProperty[] $properties
-	 * @throws InvalidArgumentException
-	 * @since 22.0.0
-	 */
-	public function setProperties(array $properties): IAccountPropertyCollection;
+    /**
+     * set properties of this collection
+     *
+     * @param IAccountProperty[] $properties
+     * @throws InvalidArgumentException
+     * @since 22.0.0
+     */
+    public function setProperties(array $properties): IAccountPropertyCollection;
 
-	/**
-	 * @return IAccountProperty[]
-	 * @since 22.0.0
-	 */
-	public function getProperties(): array;
+    /**
+     * @return IAccountProperty[]
+     * @since 22.0.0
+     */
+    public function getProperties(): array;
 
-	/**
-	 * adds a property to this collection
-	 *
-	 * @throws InvalidArgumentException
-	 * @since 22.0.0
-	 */
-	public function addProperty(IAccountProperty $property): IAccountPropertyCollection;
+    /**
+     * adds a property to this collection
+     *
+     * @throws InvalidArgumentException
+     * @since 22.0.0
+     */
+    public function addProperty(IAccountProperty $property): IAccountPropertyCollection;
 
-	/**
-	 * adds a property to this collection with only specifying the value
-	 *
-	 * @throws InvalidArgumentException
-	 * @since 22.0.0
-	 */
-	public function addPropertyWithDefaults(string $value): IAccountPropertyCollection;
+    /**
+     * adds a property to this collection with only specifying the value
+     *
+     * @throws InvalidArgumentException
+     * @since 22.0.0
+     */
+    public function addPropertyWithDefaults(string $value): IAccountPropertyCollection;
 
-	/**
-	 * removes a property of this collection
-	 *
-	 * @since 22.0.0
-	 */
-	public function removeProperty(IAccountProperty $property): IAccountPropertyCollection;
+    /**
+     * removes a property of this collection
+     *
+     * @since 22.0.0
+     */
+    public function removeProperty(IAccountProperty $property): IAccountPropertyCollection;
 
-	/**
-	 * removes a property identified by its value
-	 *
-	 * @since 22.0.0
-	 */
-	public function removePropertyByValue(string $value): IAccountPropertyCollection;
+    /**
+     * removes a property identified by its value
+     *
+     * @since 22.0.0
+     */
+    public function removePropertyByValue(string $value): IAccountPropertyCollection;
 
-	/**
-	 * retrieves a property identified by its value. null, if none was found.
-	 *
-	 * Returns only the first property if there are more with the same value.
-	 *
-	 * @since 23.0.0
-	 */
-	public function getPropertyByValue(string $value): ?IAccountProperty;
+    /**
+     * retrieves a property identified by its value. null, if none was found.
+     *
+     * Returns only the first property if there are more with the same value.
+     *
+     * @since 23.0.0
+     */
+    public function getPropertyByValue(string $value): ?IAccountProperty;
 }

lib/public/DirectEditing/IEditor.php

Indentation +58 added lines, -58 removed lines

@@ -31,68 +31,68 @@
  * @since 18.0.0
  */
 interface IEditor {
-	/**
-	 * Return a unique identifier for the editor
-	 *
-	 * e.g. richdocuments
-	 *
-	 * @since 18.0.0
-	 * @return string
-	 */
-	public function getId(): string;
+    /**
+     * Return a unique identifier for the editor
+     *
+     * e.g. richdocuments
+     *
+     * @since 18.0.0
+     * @return string
+     */
+    public function getId(): string;
 
-	/**
-	 * Return a readable name for the editor
-	 *
-	 * e.g. Collabora Online
-	 *
-	 * @since 18.0.0
-	 * @return string
-	 */
-	public function getName(): string;
+    /**
+     * Return a readable name for the editor
+     *
+     * e.g. Collabora Online
+     *
+     * @since 18.0.0
+     * @return string
+     */
+    public function getName(): string;
 
-	/**
-	 * A list of mimetypes that should open the editor by default
-	 *
-	 * @since 18.0.0
-	 * @return string[]
-	 */
-	public function getMimetypes(): array;
+    /**
+     * A list of mimetypes that should open the editor by default
+     *
+     * @since 18.0.0
+     * @return string[]
+     */
+    public function getMimetypes(): array;
 
-	/**
-	 * A list of mimetypes that can be opened in the editor optionally
-	 *
-	 * @since 18.0.0
-	 * @return string[]
-	 */
-	public function getMimetypesOptional(): array;
+    /**
+     * A list of mimetypes that can be opened in the editor optionally
+     *
+     * @since 18.0.0
+     * @return string[]
+     */
+    public function getMimetypesOptional(): array;
 
-	/**
-	 * Return a list of file creation options to be presented to the user
-	 *
-	 * @since 18.0.0
-	 * @return ACreateFromTemplate[]|ACreateEmpty[]
-	 */
-	public function getCreators(): array;
+    /**
+     * Return a list of file creation options to be presented to the user
+     *
+     * @since 18.0.0
+     * @return ACreateFromTemplate[]|ACreateEmpty[]
+     */
+    public function getCreators(): array;
 
-	/**
-	 * Return if the view is able to securely view a file without downloading it to the browser
-	 *
-	 * @since 18.0.0
-	 * @return bool
-	 */
-	public function isSecure(): bool;
+    /**
+     * Return if the view is able to securely view a file without downloading it to the browser
+     *
+     * @since 18.0.0
+     * @return bool
+     */
+    public function isSecure(): bool;
 
-	/**
-	 * Return a template response for displaying the editor
-	 *
-	 * open can only be called once when the client requests the editor with a one-time-use token
-	 * For handling editing and later requests, editors need to implement their own token handling and take care of invalidation
-	 *
-	 * This behavior is similar to the current direct editing implementation in collabora where we generate a one-time token and switch over to the regular wopi token for the actual editing/saving process
-	 *
-	 * @since 18.0.0
-	 * @return Response
-	 */
-	public function open(IToken $token): Response;
+    /**
+     * Return a template response for displaying the editor
+     *
+     * open can only be called once when the client requests the editor with a one-time-use token
+     * For handling editing and later requests, editors need to implement their own token handling and take care of invalidation
+     *
+     * This behavior is similar to the current direct editing implementation in collabora where we generate a one-time token and switch over to the regular wopi token for the actual editing/saving process
+     *
+     * @since 18.0.0
+     * @return Response
+     */
+    public function open(IToken $token): Response;
 }

lib/private/Files/Cache/HomeCache.php

Indentation +32 added lines, -32 removed lines

@@ -31,38 +31,38 @@
 use OCP\Files\Cache\ICacheEntry;
 
 class HomeCache extends Cache {
-	/**
-	 * get the size of a folder and set it in the cache
-	 *
-	 * @param string $path
-	 * @param array|null|ICacheEntry $entry (optional) meta data of the folder
-	 * @return int|float
-	 */
-	public function calculateFolderSize($path, $entry = null) {
-		if ($path !== '/' and $path !== '' and $path !== 'files' and $path !== 'files_trashbin' and $path !== 'files_versions') {
-			return parent::calculateFolderSize($path, $entry);
-		} elseif ($path === '' or $path === '/') {
-			// since the size of / isn't used (the size of /files is used instead) there is no use in calculating it
-			return 0;
-		} else {
-			return $this->calculateFolderSizeInner($path, $entry, true);
-		}
-	}
+    /**
+     * get the size of a folder and set it in the cache
+     *
+     * @param string $path
+     * @param array|null|ICacheEntry $entry (optional) meta data of the folder
+     * @return int|float
+     */
+    public function calculateFolderSize($path, $entry = null) {
+        if ($path !== '/' and $path !== '' and $path !== 'files' and $path !== 'files_trashbin' and $path !== 'files_versions') {
+            return parent::calculateFolderSize($path, $entry);
+        } elseif ($path === '' or $path === '/') {
+            // since the size of / isn't used (the size of /files is used instead) there is no use in calculating it
+            return 0;
+        } else {
+            return $this->calculateFolderSizeInner($path, $entry, true);
+        }
+    }
 
-	/**
-	 * @param string $file
-	 * @return ICacheEntry
-	 */
-	public function get($file) {
-		$data = parent::get($file);
-		if ($file === '' or $file === '/') {
-			// only the size of the "files" dir counts
-			$filesData = parent::get('files');
+    /**
+     * @param string $file
+     * @return ICacheEntry
+     */
+    public function get($file) {
+        $data = parent::get($file);
+        if ($file === '' or $file === '/') {
+            // only the size of the "files" dir counts
+            $filesData = parent::get('files');
 
-			if (isset($filesData['size'])) {
-				$data['size'] = $filesData['size'];
-			}
-		}
-		return $data;
-	}
+            if (isset($filesData['size'])) {
+                $data['size'] = $filesData['size'];
+            }
+        }
+        return $data;
+    }
 }

lib/public/AppFramework/Db/TTransactional.php

Indentation +65 added lines, -65 removed lines

@@ -37,70 +37,70 @@
  * @since 24.0.0
  */
 trait TTransactional {
-	/**
-	 * Run an atomic database operation
-	 *
-	 * - Commit if no exceptions are thrown, return the callable result
-	 * - Revert otherwise and rethrows the exception
-	 *
-	 * @template T
-	 * @param callable $fn
-	 * @psalm-param callable():T $fn
-	 * @param IDBConnection $db
-	 *
-	 * @return mixed the result of the passed callable
-	 * @psalm-return T
-	 *
-	 * @throws Exception for possible errors of commit or rollback or the custom operations within the closure
-	 * @throws Throwable any other error caused by the closure
-	 *
-	 * @since 24.0.0
-	 * @see https://docs.nextcloud.com/server/latest/developer_manual/basics/storage/database.html#transactions
-	 */
-	protected function atomic(callable $fn, IDBConnection $db) {
-		$db->beginTransaction();
-		try {
-			$result = $fn();
-			$db->commit();
-			return $result;
-		} catch (Throwable $e) {
-			$db->rollBack();
-			throw $e;
-		}
-	}
+    /**
+     * Run an atomic database operation
+     *
+     * - Commit if no exceptions are thrown, return the callable result
+     * - Revert otherwise and rethrows the exception
+     *
+     * @template T
+     * @param callable $fn
+     * @psalm-param callable():T $fn
+     * @param IDBConnection $db
+     *
+     * @return mixed the result of the passed callable
+     * @psalm-return T
+     *
+     * @throws Exception for possible errors of commit or rollback or the custom operations within the closure
+     * @throws Throwable any other error caused by the closure
+     *
+     * @since 24.0.0
+     * @see https://docs.nextcloud.com/server/latest/developer_manual/basics/storage/database.html#transactions
+     */
+    protected function atomic(callable $fn, IDBConnection $db) {
+        $db->beginTransaction();
+        try {
+            $result = $fn();
+            $db->commit();
+            return $result;
+        } catch (Throwable $e) {
+            $db->rollBack();
+            throw $e;
+        }
+    }
 
-	/**
-	 * Wrapper around atomic() to retry after a retryable exception occurred
-	 *
-	 * Certain transactions might need to be retried. This is especially useful
-	 * in highly concurrent requests where a deadlocks is thrown by the database
-	 * without waiting for the lock to be freed (e.g. due to MySQL/MariaDB deadlock
-	 * detection)
-	 *
-	 * @template T
-	 * @param callable $fn
-	 * @psalm-param callable():T $fn
-	 * @param IDBConnection $db
-	 * @param int $maxRetries
-	 *
-	 * @return mixed the result of the passed callable
-	 * @psalm-return T
-	 *
-	 * @throws Exception for possible errors of commit or rollback or the custom operations within the closure
-	 * @throws Throwable any other error caused by the closure
-	 *
-	 * @since 27.0.0
-	 */
-	protected function atomicRetry(callable $fn, IDBConnection $db, int $maxRetries = 3): mixed {
-		for ($i = 0; $i < $maxRetries; $i++) {
-			try {
-				return $this->atomic($fn, $db);
-			} catch (DbalException $e) {
-				if (!$e->isRetryable() || $i === ($maxRetries - 1)) {
-					throw $e;
-				}
-				logger('core')->warning('Retrying operation after retryable exception.', [ 'exception' => $e ]);
-			}
-		}
-	}
+    /**
+     * Wrapper around atomic() to retry after a retryable exception occurred
+     *
+     * Certain transactions might need to be retried. This is especially useful
+     * in highly concurrent requests where a deadlocks is thrown by the database
+     * without waiting for the lock to be freed (e.g. due to MySQL/MariaDB deadlock
+     * detection)
+     *
+     * @template T
+     * @param callable $fn
+     * @psalm-param callable():T $fn
+     * @param IDBConnection $db
+     * @param int $maxRetries
+     *
+     * @return mixed the result of the passed callable
+     * @psalm-return T
+     *
+     * @throws Exception for possible errors of commit or rollback or the custom operations within the closure
+     * @throws Throwable any other error caused by the closure
+     *
+     * @since 27.0.0
+     */
+    protected function atomicRetry(callable $fn, IDBConnection $db, int $maxRetries = 3): mixed {
+        for ($i = 0; $i < $maxRetries; $i++) {
+            try {
+                return $this->atomic($fn, $db);
+            } catch (DbalException $e) {
+                if (!$e->isRetryable() || $i === ($maxRetries - 1)) {
+                    throw $e;
+                }
+                logger('core')->warning('Retrying operation after retryable exception.', [ 'exception' => $e ]);
+            }
+        }
+    }
 }