nextcloud / server

tests/lib/Preview/PreviewMapperTest.php

Indentation +62 added lines, -62 removed lines

@@ -19,76 +19,76 @@
 
 #[\PHPUnit\Framework\Attributes\Group('DB')]
 class PreviewMapperTest extends TestCase {
-	private PreviewMapper $previewMapper;
-	private IDBConnection $connection;
-	private IGenerator $snowflake;
+    private PreviewMapper $previewMapper;
+    private IDBConnection $connection;
+    private IGenerator $snowflake;
 
-	public function setUp(): void {
-		$this->previewMapper = Server::get(PreviewMapper::class);
-		$this->connection = Server::get(IDBConnection::class);
-		$this->snowflake = Server::get(IGenerator::class);
+    public function setUp(): void {
+        $this->previewMapper = Server::get(PreviewMapper::class);
+        $this->connection = Server::get(IDBConnection::class);
+        $this->snowflake = Server::get(IGenerator::class);
 
-		$qb = $this->connection->getQueryBuilder();
-		$qb->delete('preview_locations')->executeStatement();
+        $qb = $this->connection->getQueryBuilder();
+        $qb->delete('preview_locations')->executeStatement();
 
-		$qb = $this->connection->getQueryBuilder();
-		$qb->delete('preview_versions')->executeStatement();
+        $qb = $this->connection->getQueryBuilder();
+        $qb->delete('preview_versions')->executeStatement();
 
-		$qb = $this->connection->getQueryBuilder();
-		$qb->delete('previews')->executeStatement();
-	}
+        $qb = $this->connection->getQueryBuilder();
+        $qb->delete('previews')->executeStatement();
+    }
 
-	public function testGetAvailablePreviews(): void {
-		// Empty
-		$this->assertEquals([], $this->previewMapper->getAvailablePreviews([]));
+    public function testGetAvailablePreviews(): void {
+        // Empty
+        $this->assertEquals([], $this->previewMapper->getAvailablePreviews([]));
 
-		// No preview available
-		$this->assertEquals([42 => []], $this->previewMapper->getAvailablePreviews([42]));
+        // No preview available
+        $this->assertEquals([42 => []], $this->previewMapper->getAvailablePreviews([42]));
 
-		$this->createPreviewForFileId(42);
-		$previews = $this->previewMapper->getAvailablePreviews([42]);
-		$this->assertNotEmpty($previews[42]);
-		$this->assertNull($previews[42][0]->getLocationId());
-		$this->assertNull($previews[42][0]->getBucketName());
-		$this->assertNull($previews[42][0]->getObjectStoreName());
+        $this->createPreviewForFileId(42);
+        $previews = $this->previewMapper->getAvailablePreviews([42]);
+        $this->assertNotEmpty($previews[42]);
+        $this->assertNull($previews[42][0]->getLocationId());
+        $this->assertNull($previews[42][0]->getBucketName());
+        $this->assertNull($previews[42][0]->getObjectStoreName());
 
-		$this->createPreviewForFileId(43, 2);
-		$previews = $this->previewMapper->getAvailablePreviews([43]);
-		$this->assertNotEmpty($previews[43]);
-		$this->assertEquals('preview-2', $previews[43][0]->getBucketName());
-		$this->assertEquals('default', $previews[43][0]->getObjectStoreName());
-	}
+        $this->createPreviewForFileId(43, 2);
+        $previews = $this->previewMapper->getAvailablePreviews([43]);
+        $this->assertNotEmpty($previews[43]);
+        $this->assertEquals('preview-2', $previews[43][0]->getBucketName());
+        $this->assertEquals('default', $previews[43][0]->getObjectStoreName());
+    }
 
-	private function createPreviewForFileId(int $fileId, ?int $bucket = null): void {
-		$locationId = null;
-		if ($bucket) {
-			$qb = $this->connection->getQueryBuilder();
-			$locationId = $this->snowflake->nextId();
-			$qb->insert('preview_locations')
-				->values([
-					'id' => $locationId,
-					'bucket_name' => $qb->createNamedParameter('preview-' . $bucket),
-					'object_store_name' => $qb->createNamedParameter('default'),
-				]);
-			$qb->executeStatement();
-		}
-		$preview = new Preview();
-		$preview->setId($this->snowflake->nextId());
-		$preview->setFileId($fileId);
-		$preview->setStorageId(1);
-		$preview->setCropped(true);
-		$preview->setMax(true);
-		$preview->setWidth(100);
-		$preview->setSourceMimeType('image/jpeg');
-		$preview->setHeight(100);
-		$preview->setSize(100);
-		$preview->setMtime(time());
-		$preview->setMimetype('image/jpeg');
-		$preview->setEtag('abcdefg');
+    private function createPreviewForFileId(int $fileId, ?int $bucket = null): void {
+        $locationId = null;
+        if ($bucket) {
+            $qb = $this->connection->getQueryBuilder();
+            $locationId = $this->snowflake->nextId();
+            $qb->insert('preview_locations')
+                ->values([
+                    'id' => $locationId,
+                    'bucket_name' => $qb->createNamedParameter('preview-' . $bucket),
+                    'object_store_name' => $qb->createNamedParameter('default'),
+                ]);
+            $qb->executeStatement();
+        }
+        $preview = new Preview();
+        $preview->setId($this->snowflake->nextId());
+        $preview->setFileId($fileId);
+        $preview->setStorageId(1);
+        $preview->setCropped(true);
+        $preview->setMax(true);
+        $preview->setWidth(100);
+        $preview->setSourceMimeType('image/jpeg');
+        $preview->setHeight(100);
+        $preview->setSize(100);
+        $preview->setMtime(time());
+        $preview->setMimetype('image/jpeg');
+        $preview->setEtag('abcdefg');
 
-		if ($locationId !== null) {
-			$preview->setLocationId($locationId);
-		}
-		$this->previewMapper->insert($preview);
-	}
+        if ($locationId !== null) {
+            $preview->setLocationId($locationId);
+        }
+        $this->previewMapper->insert($preview);
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -67,7 +67,7 @@
 			$qb->insert('preview_locations')
 				->values([
 					'id' => $locationId,
-					'bucket_name' => $qb->createNamedParameter('preview-' . $bucket),
+					'bucket_name' => $qb->createNamedParameter('preview-'.$bucket),
 					'object_store_name' => $qb->createNamedParameter('default'),
 				]);
 			$qb->executeStatement();

tests/lib/Preview/MovePreviewJobTest.php

Indentation +191 added lines, -191 removed lines

@@ -32,195 +32,195 @@
 
 #[\PHPUnit\Framework\Attributes\Group('DB')]
 class MovePreviewJobTest extends TestCase {
-	private IAppData $previewAppData;
-	private PreviewMapper $previewMapper;
-	private IAppConfig&MockObject $appConfig;
-	private IConfig $config;
-	private StorageFactory $storageFactory;
-	private PreviewService $previewService;
-	private IDBConnection $db;
-	private IMimeTypeLoader&MockObject $mimeTypeLoader;
-	private IMimeTypeDetector&MockObject $mimeTypeDetector;
-	private LoggerInterface&MockObject $logger;
-
-	public function setUp(): void {
-		parent::setUp();
-		$this->previewAppData = Server::get(IAppDataFactory::class)->get('preview');
-		$this->previewMapper = Server::get(PreviewMapper::class);
-		$this->config = Server::get(IConfig::class);
-		$this->appConfig = $this->createMock(IAppConfig::class);
-		$this->appConfig->expects($this->any())
-			->method('getValueBool')
-			->willReturn(false);
-		$this->appConfig->expects($this->any())
-			->method('setValueBool')
-			->willReturn(true);
-		$this->storageFactory = Server::get(StorageFactory::class);
-		$this->previewService = Server::get(PreviewService::class);
-		$this->db = Server::get(IDBConnection::class);
-
-		$qb = $this->db->getQueryBuilder();
-		$qb->delete('filecache')
-			->where($qb->expr()->eq('fileid', $qb->createNamedParameter(5)))
-			->executeStatement();
-
-		$qb = $this->db->getQueryBuilder();
-		$qb->insert('filecache')
-			->values([
-				'fileid' => $qb->createNamedParameter(5),
-				'storage' => $qb->createNamedParameter(1),
-				'path' => $qb->createNamedParameter('test/abc'),
-				'path_hash' => $qb->createNamedParameter(md5('test')),
-				'parent' => $qb->createNamedParameter(0),
-				'name' => $qb->createNamedParameter('abc'),
-				'mimetype' => $qb->createNamedParameter(42),
-				'size' => $qb->createNamedParameter(1000),
-				'mtime' => $qb->createNamedParameter(1000),
-				'storage_mtime' => $qb->createNamedParameter(1000),
-				'encrypted' => $qb->createNamedParameter(0),
-				'unencrypted_size' => $qb->createNamedParameter(0),
-				'etag' => $qb->createNamedParameter('abcdefg'),
-				'permissions' => $qb->createNamedParameter(0),
-				'checksum' => $qb->createNamedParameter('abcdefg'),
-			])->executeStatement();
-
-		$this->mimeTypeDetector = $this->createMock(IMimeTypeDetector::class);
-		$this->mimeTypeDetector->method('detectPath')->willReturn('image/png');
-		$this->mimeTypeLoader = $this->createMock(IMimeTypeLoader::class);
-		$this->mimeTypeLoader->method('getId')->with('image/png')->willReturn(42);
-		$this->mimeTypeLoader->method('getMimetypeById')->with(42)->willReturn('image/png');
-		$this->logger = $this->createMock(LoggerInterface::class);
-	}
-
-	public function tearDown(): void {
-		foreach ($this->previewAppData->getDirectoryListing() as $folder) {
-			$folder->delete();
-		}
-		$this->previewService->deleteAll();
-
-		$qb = $this->db->getQueryBuilder();
-		$qb->delete('filecache')
-			->where($qb->expr()->eq('fileid', $qb->createNamedParameter(5)))
-			->executeStatement();
-	}
-
-	#[TestDox('Test the migration from the legacy flat hierarchy to the new database format')]
-	public function testMigrationLegacyPath(): void {
-		$folder = $this->previewAppData->newFolder('5');
-		$folder->newFile('64-64-crop.jpg', 'abcdefg');
-		$folder->newFile('128-128-crop.png', 'abcdefg');
-		$this->assertEquals(1, count($this->previewAppData->getDirectoryListing()));
-		$this->assertEquals(2, count($folder->getDirectoryListing()));
-		$this->assertEquals(0, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
-
-		$job = new MovePreviewJob(
-			Server::get(ITimeFactory::class),
-			$this->appConfig,
-			$this->config,
-			$this->previewMapper,
-			$this->storageFactory,
-			Server::get(IDBConnection::class),
-			Server::get(IRootFolder::class),
-			$this->mimeTypeDetector,
-			$this->mimeTypeLoader,
-			$this->logger,
-			Server::get(IGenerator::class),
-			Server::get(IAppDataFactory::class),
-		);
-		$this->invokePrivate($job, 'run', [[]]);
-		$this->assertEquals(0, count($this->previewAppData->getDirectoryListing()));
-		$this->assertEquals(2, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
-	}
-
-	private static function getInternalFolder(string $name): string {
-		return implode('/', str_split(substr(md5($name), 0, 7))) . '/' . $name;
-	}
-
-	#[TestDox("Test the migration from the 'new' nested hierarchy to the database format")]
-	public function testMigrationPath(): void {
-		$folder = $this->previewAppData->newFolder(self::getInternalFolder((string)5));
-		$folder->newFile('64-64-crop.jpg', 'abcdefg');
-		$folder->newFile('128-128-crop.png', 'abcdefg');
-
-		$folder = $this->previewAppData->getFolder(self::getInternalFolder((string)5));
-		$this->assertEquals(2, count($folder->getDirectoryListing()));
-		$this->assertEquals(0, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
-
-		$job = new MovePreviewJob(
-			Server::get(ITimeFactory::class),
-			$this->appConfig,
-			$this->config,
-			$this->previewMapper,
-			$this->storageFactory,
-			Server::get(IDBConnection::class),
-			Server::get(IRootFolder::class),
-			$this->mimeTypeDetector,
-			$this->mimeTypeLoader,
-			$this->logger,
-			Server::get(IGenerator::class),
-			Server::get(IAppDataFactory::class)
-		);
-		$this->invokePrivate($job, 'run', [[]]);
-		$this->assertEquals(0, count($this->previewAppData->getDirectoryListing()));
-		$this->assertEquals(2, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
-	}
-
-	#[TestDox("Test the migration from the 'new' nested hierarchy to the database format")]
-	public function testMigrationPathWithVersion(): void {
-		$folder = $this->previewAppData->newFolder(self::getInternalFolder((string)5));
-		// No version
-		$folder->newFile('128-128-crop.png', 'abcdefg');
-		$folder->newFile('256-256-max.png', 'abcdefg');
-		$folder->newFile('128-128.png', 'abcdefg');
-
-		// Version 1000
-		$folder->newFile('1000-128-128-crop.png', 'abcdefg');
-		$folder->newFile('1000-256-256-max.png', 'abcdefg');
-		$folder->newFile('1000-128-128.png', 'abcdefg');
-
-		// Version 1001
-		$folder->newFile('1001-128-128-crop.png', 'abcdefg');
-		$folder->newFile('1001-256-256-max.png', 'abcdefg');
-		$folder->newFile('1001-128-128.png', 'abcdefg');
-
-		$folder = $this->previewAppData->getFolder(self::getInternalFolder((string)5));
-		$this->assertEquals(9, count($folder->getDirectoryListing()));
-		$this->assertEquals(0, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
-
-		$job = new MovePreviewJob(
-			Server::get(ITimeFactory::class),
-			$this->appConfig,
-			$this->config,
-			$this->previewMapper,
-			$this->storageFactory,
-			Server::get(IDBConnection::class),
-			Server::get(IRootFolder::class),
-			$this->mimeTypeDetector,
-			$this->mimeTypeLoader,
-			$this->logger,
-			Server::get(IGenerator::class),
-			Server::get(IAppDataFactory::class)
-		);
-		$this->invokePrivate($job, 'run', [[]]);
-		$previews = iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5));
-		$this->assertEquals(9, count($previews));
-		$this->assertEquals(0, count($this->previewAppData->getDirectoryListing()));
-
-		$nameVersionMapping = [];
-		foreach ($previews as $preview) {
-			$nameVersionMapping[$preview->getName($this->mimeTypeLoader)] = $preview->getVersion();
-		}
-
-		$this->assertEquals([
-			'1000-128-128-crop.png' => 1000,
-			'1000-128-128.png' => 1000,
-			'1000-256-256-max.png' => 1000,
-			'1001-128-128-crop.png' => 1001,
-			'1001-128-128.png' => 1001,
-			'1001-256-256-max.png' => 1001,
-			'128-128-crop.png' => null,
-			'128-128.png' => null,
-			'256-256-max.png' => null,
-		], $nameVersionMapping);
-	}
+    private IAppData $previewAppData;
+    private PreviewMapper $previewMapper;
+    private IAppConfig&MockObject $appConfig;
+    private IConfig $config;
+    private StorageFactory $storageFactory;
+    private PreviewService $previewService;
+    private IDBConnection $db;
+    private IMimeTypeLoader&MockObject $mimeTypeLoader;
+    private IMimeTypeDetector&MockObject $mimeTypeDetector;
+    private LoggerInterface&MockObject $logger;
+
+    public function setUp(): void {
+        parent::setUp();
+        $this->previewAppData = Server::get(IAppDataFactory::class)->get('preview');
+        $this->previewMapper = Server::get(PreviewMapper::class);
+        $this->config = Server::get(IConfig::class);
+        $this->appConfig = $this->createMock(IAppConfig::class);
+        $this->appConfig->expects($this->any())
+            ->method('getValueBool')
+            ->willReturn(false);
+        $this->appConfig->expects($this->any())
+            ->method('setValueBool')
+            ->willReturn(true);
+        $this->storageFactory = Server::get(StorageFactory::class);
+        $this->previewService = Server::get(PreviewService::class);
+        $this->db = Server::get(IDBConnection::class);
+
+        $qb = $this->db->getQueryBuilder();
+        $qb->delete('filecache')
+            ->where($qb->expr()->eq('fileid', $qb->createNamedParameter(5)))
+            ->executeStatement();
+
+        $qb = $this->db->getQueryBuilder();
+        $qb->insert('filecache')
+            ->values([
+                'fileid' => $qb->createNamedParameter(5),
+                'storage' => $qb->createNamedParameter(1),
+                'path' => $qb->createNamedParameter('test/abc'),
+                'path_hash' => $qb->createNamedParameter(md5('test')),
+                'parent' => $qb->createNamedParameter(0),
+                'name' => $qb->createNamedParameter('abc'),
+                'mimetype' => $qb->createNamedParameter(42),
+                'size' => $qb->createNamedParameter(1000),
+                'mtime' => $qb->createNamedParameter(1000),
+                'storage_mtime' => $qb->createNamedParameter(1000),
+                'encrypted' => $qb->createNamedParameter(0),
+                'unencrypted_size' => $qb->createNamedParameter(0),
+                'etag' => $qb->createNamedParameter('abcdefg'),
+                'permissions' => $qb->createNamedParameter(0),
+                'checksum' => $qb->createNamedParameter('abcdefg'),
+            ])->executeStatement();
+
+        $this->mimeTypeDetector = $this->createMock(IMimeTypeDetector::class);
+        $this->mimeTypeDetector->method('detectPath')->willReturn('image/png');
+        $this->mimeTypeLoader = $this->createMock(IMimeTypeLoader::class);
+        $this->mimeTypeLoader->method('getId')->with('image/png')->willReturn(42);
+        $this->mimeTypeLoader->method('getMimetypeById')->with(42)->willReturn('image/png');
+        $this->logger = $this->createMock(LoggerInterface::class);
+    }
+
+    public function tearDown(): void {
+        foreach ($this->previewAppData->getDirectoryListing() as $folder) {
+            $folder->delete();
+        }
+        $this->previewService->deleteAll();
+
+        $qb = $this->db->getQueryBuilder();
+        $qb->delete('filecache')
+            ->where($qb->expr()->eq('fileid', $qb->createNamedParameter(5)))
+            ->executeStatement();
+    }
+
+    #[TestDox('Test the migration from the legacy flat hierarchy to the new database format')]
+    public function testMigrationLegacyPath(): void {
+        $folder = $this->previewAppData->newFolder('5');
+        $folder->newFile('64-64-crop.jpg', 'abcdefg');
+        $folder->newFile('128-128-crop.png', 'abcdefg');
+        $this->assertEquals(1, count($this->previewAppData->getDirectoryListing()));
+        $this->assertEquals(2, count($folder->getDirectoryListing()));
+        $this->assertEquals(0, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
+
+        $job = new MovePreviewJob(
+            Server::get(ITimeFactory::class),
+            $this->appConfig,
+            $this->config,
+            $this->previewMapper,
+            $this->storageFactory,
+            Server::get(IDBConnection::class),
+            Server::get(IRootFolder::class),
+            $this->mimeTypeDetector,
+            $this->mimeTypeLoader,
+            $this->logger,
+            Server::get(IGenerator::class),
+            Server::get(IAppDataFactory::class),
+        );
+        $this->invokePrivate($job, 'run', [[]]);
+        $this->assertEquals(0, count($this->previewAppData->getDirectoryListing()));
+        $this->assertEquals(2, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
+    }
+
+    private static function getInternalFolder(string $name): string {
+        return implode('/', str_split(substr(md5($name), 0, 7))) . '/' . $name;
+    }
+
+    #[TestDox("Test the migration from the 'new' nested hierarchy to the database format")]
+    public function testMigrationPath(): void {
+        $folder = $this->previewAppData->newFolder(self::getInternalFolder((string)5));
+        $folder->newFile('64-64-crop.jpg', 'abcdefg');
+        $folder->newFile('128-128-crop.png', 'abcdefg');
+
+        $folder = $this->previewAppData->getFolder(self::getInternalFolder((string)5));
+        $this->assertEquals(2, count($folder->getDirectoryListing()));
+        $this->assertEquals(0, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
+
+        $job = new MovePreviewJob(
+            Server::get(ITimeFactory::class),
+            $this->appConfig,
+            $this->config,
+            $this->previewMapper,
+            $this->storageFactory,
+            Server::get(IDBConnection::class),
+            Server::get(IRootFolder::class),
+            $this->mimeTypeDetector,
+            $this->mimeTypeLoader,
+            $this->logger,
+            Server::get(IGenerator::class),
+            Server::get(IAppDataFactory::class)
+        );
+        $this->invokePrivate($job, 'run', [[]]);
+        $this->assertEquals(0, count($this->previewAppData->getDirectoryListing()));
+        $this->assertEquals(2, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
+    }
+
+    #[TestDox("Test the migration from the 'new' nested hierarchy to the database format")]
+    public function testMigrationPathWithVersion(): void {
+        $folder = $this->previewAppData->newFolder(self::getInternalFolder((string)5));
+        // No version
+        $folder->newFile('128-128-crop.png', 'abcdefg');
+        $folder->newFile('256-256-max.png', 'abcdefg');
+        $folder->newFile('128-128.png', 'abcdefg');
+
+        // Version 1000
+        $folder->newFile('1000-128-128-crop.png', 'abcdefg');
+        $folder->newFile('1000-256-256-max.png', 'abcdefg');
+        $folder->newFile('1000-128-128.png', 'abcdefg');
+
+        // Version 1001
+        $folder->newFile('1001-128-128-crop.png', 'abcdefg');
+        $folder->newFile('1001-256-256-max.png', 'abcdefg');
+        $folder->newFile('1001-128-128.png', 'abcdefg');
+
+        $folder = $this->previewAppData->getFolder(self::getInternalFolder((string)5));
+        $this->assertEquals(9, count($folder->getDirectoryListing()));
+        $this->assertEquals(0, count(iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5))));
+
+        $job = new MovePreviewJob(
+            Server::get(ITimeFactory::class),
+            $this->appConfig,
+            $this->config,
+            $this->previewMapper,
+            $this->storageFactory,
+            Server::get(IDBConnection::class),
+            Server::get(IRootFolder::class),
+            $this->mimeTypeDetector,
+            $this->mimeTypeLoader,
+            $this->logger,
+            Server::get(IGenerator::class),
+            Server::get(IAppDataFactory::class)
+        );
+        $this->invokePrivate($job, 'run', [[]]);
+        $previews = iterator_to_array($this->previewMapper->getAvailablePreviewsForFile(5));
+        $this->assertEquals(9, count($previews));
+        $this->assertEquals(0, count($this->previewAppData->getDirectoryListing()));
+
+        $nameVersionMapping = [];
+        foreach ($previews as $preview) {
+            $nameVersionMapping[$preview->getName($this->mimeTypeLoader)] = $preview->getVersion();
+        }
+
+        $this->assertEquals([
+            '1000-128-128-crop.png' => 1000,
+            '1000-128-128.png' => 1000,
+            '1000-256-256-max.png' => 1000,
+            '1001-128-128-crop.png' => 1001,
+            '1001-128-128.png' => 1001,
+            '1001-256-256-max.png' => 1001,
+            '128-128-crop.png' => null,
+            '128-128.png' => null,
+            '256-256-max.png' => null,
+        ], $nameVersionMapping);
+    }
 }

tests/lib/Snowflake/GeneratorTest.php

Indentation +46 added lines, -46 removed lines

@@ -21,60 +21,60 @@
  * @package Test
  */
 class GeneratorTest extends TestCase {
-	private Decoder $decoder;
+    private Decoder $decoder;
 
-	public function setUp():void {
-		$this->decoder = new Decoder();
-	}
-	public function testGenerator(): void {
-		$generator = new Generator(new TimeFactory());
-		$snowflakeId = $generator->nextId();
-		$data = $this->decoder->decode($generator->nextId());
+    public function setUp():void {
+        $this->decoder = new Decoder();
+    }
+    public function testGenerator(): void {
+        $generator = new Generator(new TimeFactory());
+        $snowflakeId = $generator->nextId();
+        $data = $this->decoder->decode($generator->nextId());
 
-		$this->assertIsString($snowflakeId);
-		// Check timestamp
-		$this->assertGreaterThan(time() - 30, $data['createdAt']->format('U'));
+        $this->assertIsString($snowflakeId);
+        // Check timestamp
+        $this->assertGreaterThan(time() - 30, $data['createdAt']->format('U'));
 
-		// Check serverId
-		$this->assertGreaterThanOrEqual(0, $data['serverId']);
-		$this->assertLessThanOrEqual(1023, $data['serverId']);
+        // Check serverId
+        $this->assertGreaterThanOrEqual(0, $data['serverId']);
+        $this->assertLessThanOrEqual(1023, $data['serverId']);
 
-		// Check sequenceId
-		$this->assertGreaterThanOrEqual(0, $data['sequenceId']);
-		$this->assertLessThanOrEqual(4095, $data['sequenceId']);
+        // Check sequenceId
+        $this->assertGreaterThanOrEqual(0, $data['sequenceId']);
+        $this->assertLessThanOrEqual(4095, $data['sequenceId']);
 
-		// Check CLI
-		$this->assertTrue($data['isCli']);
-	}
+        // Check CLI
+        $this->assertTrue($data['isCli']);
+    }
 
-	#[DataProvider('provideSnowflakeData')]
-	public function testGeneratorWithFixedTime(string $date, int $expectedSeconds, int $expectedMilliseconds): void {
-		$dt = new \DateTimeImmutable($date);
-		$timeFactory = $this->createMock(ITimeFactory::class);
-		$timeFactory->method('now')->willReturn($dt);
+    #[DataProvider('provideSnowflakeData')]
+    public function testGeneratorWithFixedTime(string $date, int $expectedSeconds, int $expectedMilliseconds): void {
+        $dt = new \DateTimeImmutable($date);
+        $timeFactory = $this->createMock(ITimeFactory::class);
+        $timeFactory->method('now')->willReturn($dt);
 
-		$generator = new Generator($timeFactory);
-		$data = $this->decoder->decode($generator->nextId());
+        $generator = new Generator($timeFactory);
+        $data = $this->decoder->decode($generator->nextId());
 
-		$this->assertEquals($expectedSeconds, ($data['createdAt']->format('U') - IGenerator::TS_OFFSET));
-		$this->assertEquals($expectedMilliseconds, (int)$data['createdAt']->format('v'));
-	}
+        $this->assertEquals($expectedSeconds, ($data['createdAt']->format('U') - IGenerator::TS_OFFSET));
+        $this->assertEquals($expectedMilliseconds, (int)$data['createdAt']->format('v'));
+    }
 
-	public static function provideSnowflakeData(): array {
-		$tests = [
-			['2025-10-01 00:00:00.000000', 0, 0],
-			['2025-10-01 00:00:01.000000', 1, 0],
-			['2025-10-01 00:00:00.001000', 0, 1],
-			['2027-08-06 03:08:30.000975', 58244910, 0],
-			['2030-06-21 12:59:33.100875', 149000373, 100],
-			['2038-01-18 13:33:37.666666', 388157617, 666],
-		];
-		// Timestamp in 32 bits can't go after 2038. Add few cases for 64 bits.
-		if (PHP_INT_SIZE === 8) {
-			$tests[] = ['2039-12-31 23:59:59.999999', 449711999, 999];
-			$tests[] = ['2086-06-21 12:59:33.010875', 1916225973, 10];
-		}
+    public static function provideSnowflakeData(): array {
+        $tests = [
+            ['2025-10-01 00:00:00.000000', 0, 0],
+            ['2025-10-01 00:00:01.000000', 1, 0],
+            ['2025-10-01 00:00:00.001000', 0, 1],
+            ['2027-08-06 03:08:30.000975', 58244910, 0],
+            ['2030-06-21 12:59:33.100875', 149000373, 100],
+            ['2038-01-18 13:33:37.666666', 388157617, 666],
+        ];
+        // Timestamp in 32 bits can't go after 2038. Add few cases for 64 bits.
+        if (PHP_INT_SIZE === 8) {
+            $tests[] = ['2039-12-31 23:59:59.999999', 449711999, 999];
+            $tests[] = ['2086-06-21 12:59:33.010875', 1916225973, 10];
+        }
 
-		return $tests;
-	}
+        return $tests;
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -57,7 +57,7 @@
 		$data = $this->decoder->decode($generator->nextId());
 
 		$this->assertEquals($expectedSeconds, ($data['createdAt']->format('U') - IGenerator::TS_OFFSET));
-		$this->assertEquals($expectedMilliseconds, (int)$data['createdAt']->format('v'));
+		$this->assertEquals($expectedMilliseconds, (int) $data['createdAt']->format('v'));
 	}
 
 	public static function provideSnowflakeData(): array {

tests/lib/Snowflake/DecoderTest.php

Indentation +45 added lines, -45 removed lines

@@ -15,55 +15,55 @@
  * @package Test
  */
 class DecoderTest extends TestCase {
-	private Decoder $decoder;
+    private Decoder $decoder;
 
-	public function setUp():void {
-		$this->decoder = new Decoder();
-	}
+    public function setUp():void {
+        $this->decoder = new Decoder();
+    }
 
-	#[DataProvider('provideSnowflakeIds')]
-	public function testDecode(
-		string $snowflakeId,
-		float $timestamp,
-		int $serverId,
-		int $sequenceId,
-		bool $isCli,
-	): void {
-		$data = $this->decoder->decode($snowflakeId);
+    #[DataProvider('provideSnowflakeIds')]
+    public function testDecode(
+        string $snowflakeId,
+        float $timestamp,
+        int $serverId,
+        int $sequenceId,
+        bool $isCli,
+    ): void {
+        $data = $this->decoder->decode($snowflakeId);
 
-		$this->assertEquals($timestamp, (float)$data['createdAt']->format('U.v'));
-		$this->assertEquals($serverId, $data['serverId']);
-		$this->assertEquals($sequenceId, $data['sequenceId']);
-		$this->assertEquals($isCli, $data['isCli']);
-	}
+        $this->assertEquals($timestamp, (float)$data['createdAt']->format('U.v'));
+        $this->assertEquals($serverId, $data['serverId']);
+        $this->assertEquals($sequenceId, $data['sequenceId']);
+        $this->assertEquals($isCli, $data['isCli']);
+    }
 
-	public static function provideSnowflakeIds(): array {
-		$data = [
-			['4688076898113587', 1760368327.984, 392, 2099, true],
-			// Max milliseconds
-			['4190109696', 1759276800.999, 0, 0, false],
-			// Max serverId
-			['4186112', 1759276800.0, 511, 0, false],
-			// Max sequenceId
-			['4095', 1759276800.0, 0, 4095, false],
-			// Max isCli
-			['4096', 1759276800.0, 0, 0, true],
-			// Min
-			['0', 1759276800, 0, 0, false],
-			// Other
-			['250159983611680096', 1817521710, 392, 1376, true],
-		];
+    public static function provideSnowflakeIds(): array {
+        $data = [
+            ['4688076898113587', 1760368327.984, 392, 2099, true],
+            // Max milliseconds
+            ['4190109696', 1759276800.999, 0, 0, false],
+            // Max serverId
+            ['4186112', 1759276800.0, 511, 0, false],
+            // Max sequenceId
+            ['4095', 1759276800.0, 0, 4095, false],
+            // Max isCli
+            ['4096', 1759276800.0, 0, 0, true],
+            // Min
+            ['0', 1759276800, 0, 0, false],
+            // Other
+            ['250159983611680096', 1817521710, 392, 1376, true],
+        ];
 
-		// 32 bits can't handle large timestamps correctly
-		if (PHP_INT_SIZE === 8) {
-			// Max all (can't happen because ms are up to 999)
-			$data[] = ['999999999999', 3906760448.023, 511, 4095, true];
-			// Max all (real)
-			$data[] = ['9223372036754112511', 3906760447.999, 511, 4095, true];
-			// Max seconds
-			$data[] = ['9223372032559808512', 3906760447, 0, 0, false];
-		}
+        // 32 bits can't handle large timestamps correctly
+        if (PHP_INT_SIZE === 8) {
+            // Max all (can't happen because ms are up to 999)
+            $data[] = ['999999999999', 3906760448.023, 511, 4095, true];
+            // Max all (real)
+            $data[] = ['9223372036754112511', 3906760447.999, 511, 4095, true];
+            // Max seconds
+            $data[] = ['9223372032559808512', 3906760447, 0, 0, false];
+        }
 
-		return $data;
-	}
+        return $data;
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
 	): void {
 		$data = $this->decoder->decode($snowflakeId);
 
-		$this->assertEquals($timestamp, (float)$data['createdAt']->format('U.v'));
+		$this->assertEquals($timestamp, (float) $data['createdAt']->format('U.v'));
 		$this->assertEquals($serverId, $data['serverId']);
 		$this->assertEquals($sequenceId, $data['sequenceId']);
 		$this->assertEquals($isCli, $data['isCli']);

core/Migrations/Version33000Date20251023120529.php

Indentation +53 added lines, -53 removed lines

@@ -21,66 +21,66 @@
  */
 #[AddIndex(table: 'preview_locations', type: IndexType::UNIQUE)]
 class Version33000Date20251023120529 extends SimpleMigrationStep {
-	public function __construct(
-		private readonly IDBConnection $connection,
-	) {
-	}
+    public function __construct(
+        private readonly IDBConnection $connection,
+    ) {
+    }
 
-	/**
-	 * @param Closure(): ISchemaWrapper $schemaClosure The `\Closure` returns a `ISchemaWrapper`
-	 */
-	public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ?ISchemaWrapper {
-		/** @var ISchemaWrapper $schema */
-		$schema = $schemaClosure();
+    /**
+     * @param Closure(): ISchemaWrapper $schemaClosure The `\Closure` returns a `ISchemaWrapper`
+     */
+    public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ?ISchemaWrapper {
+        /** @var ISchemaWrapper $schema */
+        $schema = $schemaClosure();
 
-		if ($schema->hasTable('preview_locations')) {
-			$table = $schema->getTable('preview_locations');
-			$table->addUniqueIndex(['bucket_name', 'object_store_name'], 'unique_bucket_store');
-		}
+        if ($schema->hasTable('preview_locations')) {
+            $table = $schema->getTable('preview_locations');
+            $table->addUniqueIndex(['bucket_name', 'object_store_name'], 'unique_bucket_store');
+        }
 
-		return $schema;
-	}
+        return $schema;
+    }
 
-	public function preSchemaChange(IOutput $output, \Closure $schemaClosure, array $options) {
-		// This shouldn't run on a production instance, only daily
-		$qb = $this->connection->getQueryBuilder();
-		$qb->select('*')
-			->from('preview_locations');
-		$result = $qb->executeQuery();
+    public function preSchemaChange(IOutput $output, \Closure $schemaClosure, array $options) {
+        // This shouldn't run on a production instance, only daily
+        $qb = $this->connection->getQueryBuilder();
+        $qb->select('*')
+            ->from('preview_locations');
+        $result = $qb->executeQuery();
 
-		$set = [];
+        $set = [];
 
-		while ($row = $result->fetch()) {
-			// Iterate over all the rows with duplicated rows
-			$id = $row['id'];
+        while ($row = $result->fetch()) {
+            // Iterate over all the rows with duplicated rows
+            $id = $row['id'];
 
-			if (isset($set[$row['bucket_name'] . '_' . $row['object_store_name']])) {
-				// duplicate
-				$authoritativeId = $set[$row['bucket_name'] . '_' . $row['object_store_name']];
-				$qb = $this->connection->getQueryBuilder();
-				$qb->select('id')
-					->from('preview_locations')
-					->where($qb->expr()->eq('bucket_name', $qb->createNamedParameter($row['bucket_name'])))
-					->andWhere($qb->expr()->eq('object_store_name', $qb->createNamedParameter($row['object_store_name'])))
-					->andWhere($qb->expr()->neq('id', $qb->createNamedParameter($authoritativeId)));
+            if (isset($set[$row['bucket_name'] . '_' . $row['object_store_name']])) {
+                // duplicate
+                $authoritativeId = $set[$row['bucket_name'] . '_' . $row['object_store_name']];
+                $qb = $this->connection->getQueryBuilder();
+                $qb->select('id')
+                    ->from('preview_locations')
+                    ->where($qb->expr()->eq('bucket_name', $qb->createNamedParameter($row['bucket_name'])))
+                    ->andWhere($qb->expr()->eq('object_store_name', $qb->createNamedParameter($row['object_store_name'])))
+                    ->andWhere($qb->expr()->neq('id', $qb->createNamedParameter($authoritativeId)));
 
-				$result = $qb->executeQuery();
-				while ($row = $result->fetch()) {
-					// Update previews entries to the now de-duplicated id
-					$qb = $this->connection->getQueryBuilder();
-					$qb->update('previews')
-						->set('location_id', $qb->createNamedParameter($id))
-						->where($qb->expr()->eq('id', $qb->createNamedParameter($row['id'])));
-					$qb->executeStatement();
+                $result = $qb->executeQuery();
+                while ($row = $result->fetch()) {
+                    // Update previews entries to the now de-duplicated id
+                    $qb = $this->connection->getQueryBuilder();
+                    $qb->update('previews')
+                        ->set('location_id', $qb->createNamedParameter($id))
+                        ->where($qb->expr()->eq('id', $qb->createNamedParameter($row['id'])));
+                    $qb->executeStatement();
 
-					$qb = $this->connection->getQueryBuilder();
-					$qb->delete('preview_locations')
-						->where($qb->expr()->eq('id', $qb->createNamedParameter($row['id'])));
-					$qb->executeStatement();
-				}
-				break;
-			}
-			$set[$row['bucket_name'] . '_' . $row['object_store_name']] = $row['id'];
-		}
-	}
+                    $qb = $this->connection->getQueryBuilder();
+                    $qb->delete('preview_locations')
+                        ->where($qb->expr()->eq('id', $qb->createNamedParameter($row['id'])));
+                    $qb->executeStatement();
+                }
+                break;
+            }
+            $set[$row['bucket_name'] . '_' . $row['object_store_name']] = $row['id'];
+        }
+    }
 }

Spacing +3 added lines, -3 removed lines

@@ -54,9 +54,9 @@ 
 			// Iterate over all the rows with duplicated rows
 			$id = $row['id'];
 
-			if (isset($set[$row['bucket_name'] . '_' . $row['object_store_name']])) {
+			if (isset($set[$row['bucket_name'].'_'.$row['object_store_name']])) {
 				// duplicate
-				$authoritativeId = $set[$row['bucket_name'] . '_' . $row['object_store_name']];
+				$authoritativeId = $set[$row['bucket_name'].'_'.$row['object_store_name']];
 				$qb = $this->connection->getQueryBuilder();
 				$qb->select('id')
 					->from('preview_locations')
@@ -80,7 +80,7 @@ 
 				}
 				break;
 			}
-			$set[$row['bucket_name'] . '_' . $row['object_store_name']] = $row['id'];
+			$set[$row['bucket_name'].'_'.$row['object_store_name']] = $row['id'];
 		}
 	}
 }

core/Migrations/Version33000Date20251023110529.php

Indentation +20 added lines, -20 removed lines

@@ -21,24 +21,24 @@
 #[ModifyColumn(table: 'previews', name: 'id', description: 'Remove auto-increment')]
 #[ModifyColumn(table: 'preview_versions', name: 'id', description: 'Remove auto-increment')]
 class Version33000Date20251023110529 extends SimpleMigrationStep {
-	/**
-	 * @param Closure(): ISchemaWrapper $schemaClosure The `\Closure` returns a `ISchemaWrapper`
-	 */
-	public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ?ISchemaWrapper {
-		$schema = $schemaClosure();
-
-		if ($schema->hasTable('preview_locations')) {
-			$schema->dropAutoincrementColumn('preview_locations', 'id');
-		}
-
-		if ($schema->hasTable('preview_versions')) {
-			$schema->dropAutoincrementColumn('preview_versions', 'id');
-		}
-
-		if ($schema->hasTable('previews')) {
-			$schema->dropAutoincrementColumn('previews', 'id');
-		}
-
-		return $schema;
-	}
+    /**
+     * @param Closure(): ISchemaWrapper $schemaClosure The `\Closure` returns a `ISchemaWrapper`
+     */
+    public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ?ISchemaWrapper {
+        $schema = $schemaClosure();
+
+        if ($schema->hasTable('preview_locations')) {
+            $schema->dropAutoincrementColumn('preview_locations', 'id');
+        }
+
+        if ($schema->hasTable('preview_versions')) {
+            $schema->dropAutoincrementColumn('preview_versions', 'id');
+        }
+
+        if ($schema->hasTable('previews')) {
+            $schema->dropAutoincrementColumn('previews', 'id');
+        }
+
+        return $schema;
+    }
 }

core/register_command.php

Indentation +119 added lines, -119 removed lines

@@ -124,143 +124,143 @@
 $config = Server::get(IConfig::class);
 
 if ($config->getSystemValueBool('installed', false)) {
-	$application->add(Server::get(Disable::class));
-	$application->add(Server::get(Enable::class));
-	$application->add(Server::get(Install::class));
-	$application->add(Server::get(GetPath::class));
-	$application->add(Server::get(ListApps::class));
-	$application->add(Server::get(Remove::class));
-	$application->add(Server::get(Update::class));
+    $application->add(Server::get(Disable::class));
+    $application->add(Server::get(Enable::class));
+    $application->add(Server::get(Install::class));
+    $application->add(Server::get(GetPath::class));
+    $application->add(Server::get(ListApps::class));
+    $application->add(Server::get(Remove::class));
+    $application->add(Server::get(Update::class));
 
-	$application->add(Server::get(Cleanup::class));
-	$application->add(Server::get(Enforce::class));
-	$application->add(Server::get(Command\TwoFactorAuth\Enable::class));
-	$application->add(Server::get(Command\TwoFactorAuth\Disable::class));
-	$application->add(Server::get(State::class));
+    $application->add(Server::get(Cleanup::class));
+    $application->add(Server::get(Enforce::class));
+    $application->add(Server::get(Command\TwoFactorAuth\Enable::class));
+    $application->add(Server::get(Command\TwoFactorAuth\Disable::class));
+    $application->add(Server::get(State::class));
 
-	$application->add(Server::get(Mode::class));
-	$application->add(Server::get(Job::class));
-	$application->add(Server::get(ListCommand::class));
-	$application->add(Server::get(Delete::class));
-	$application->add(Server::get(JobWorker::class));
+    $application->add(Server::get(Mode::class));
+    $application->add(Server::get(Job::class));
+    $application->add(Server::get(ListCommand::class));
+    $application->add(Server::get(Delete::class));
+    $application->add(Server::get(JobWorker::class));
 
-	$application->add(Server::get(Test::class));
+    $application->add(Server::get(Test::class));
 
-	$application->add(Server::get(DeleteConfig::class));
-	$application->add(Server::get(GetConfig::class));
-	$application->add(Server::get(SetConfig::class));
-	$application->add(Server::get(Import::class));
-	$application->add(Server::get(ListConfigs::class));
-	$application->add(Server::get(Preset::class));
-	$application->add(Server::get(Command\Config\System\DeleteConfig::class));
-	$application->add(Server::get(Command\Config\System\GetConfig::class));
-	$application->add(Server::get(Command\Config\System\SetConfig::class));
+    $application->add(Server::get(DeleteConfig::class));
+    $application->add(Server::get(GetConfig::class));
+    $application->add(Server::get(SetConfig::class));
+    $application->add(Server::get(Import::class));
+    $application->add(Server::get(ListConfigs::class));
+    $application->add(Server::get(Preset::class));
+    $application->add(Server::get(Command\Config\System\DeleteConfig::class));
+    $application->add(Server::get(Command\Config\System\GetConfig::class));
+    $application->add(Server::get(Command\Config\System\SetConfig::class));
 
-	$application->add(Server::get(File::class));
-	$application->add(Server::get(Space::class));
-	$application->add(Server::get(Storage::class));
-	$application->add(Server::get(Storages::class));
+    $application->add(Server::get(File::class));
+    $application->add(Server::get(Space::class));
+    $application->add(Server::get(Storage::class));
+    $application->add(Server::get(Storages::class));
 
-	$application->add(Server::get(ConvertType::class));
-	$application->add(Server::get(ConvertMysqlToMB4::class));
-	$application->add(Server::get(ConvertFilecacheBigInt::class));
-	$application->add(Server::get(AddMissingColumns::class));
-	$application->add(Server::get(AddMissingIndices::class));
-	$application->add(Server::get(AddMissingPrimaryKeys::class));
-	$application->add(Server::get(ExpectedSchema::class));
-	$application->add(Server::get(ExportSchema::class));
+    $application->add(Server::get(ConvertType::class));
+    $application->add(Server::get(ConvertMysqlToMB4::class));
+    $application->add(Server::get(ConvertFilecacheBigInt::class));
+    $application->add(Server::get(AddMissingColumns::class));
+    $application->add(Server::get(AddMissingIndices::class));
+    $application->add(Server::get(AddMissingPrimaryKeys::class));
+    $application->add(Server::get(ExpectedSchema::class));
+    $application->add(Server::get(ExportSchema::class));
 
-	$application->add(Server::get(GenerateMetadataCommand::class));
-	$application->add(Server::get(PreviewCommand::class));
-	if ($config->getSystemValueBool('debug', false)) {
-		$application->add(Server::get(StatusCommand::class));
-		$application->add(Server::get(MigrateCommand::class));
-		$application->add(Server::get(GenerateCommand::class));
-		$application->add(Server::get(ExecuteCommand::class));
-	}
+    $application->add(Server::get(GenerateMetadataCommand::class));
+    $application->add(Server::get(PreviewCommand::class));
+    if ($config->getSystemValueBool('debug', false)) {
+        $application->add(Server::get(StatusCommand::class));
+        $application->add(Server::get(MigrateCommand::class));
+        $application->add(Server::get(GenerateCommand::class));
+        $application->add(Server::get(ExecuteCommand::class));
+    }
 
-	$application->add(Server::get(Command\Encryption\Disable::class));
-	$application->add(Server::get(Command\Encryption\Enable::class));
-	$application->add(Server::get(ListModules::class));
-	$application->add(Server::get(SetDefaultModule::class));
-	$application->add(Server::get(Command\Encryption\Status::class));
-	$application->add(Server::get(EncryptAll::class));
-	$application->add(Server::get(DecryptAll::class));
+    $application->add(Server::get(Command\Encryption\Disable::class));
+    $application->add(Server::get(Command\Encryption\Enable::class));
+    $application->add(Server::get(ListModules::class));
+    $application->add(Server::get(SetDefaultModule::class));
+    $application->add(Server::get(Command\Encryption\Status::class));
+    $application->add(Server::get(EncryptAll::class));
+    $application->add(Server::get(DecryptAll::class));
 
-	$application->add(Server::get(Manage::class));
-	$application->add(Server::get(Command\Log\File::class));
+    $application->add(Server::get(Manage::class));
+    $application->add(Server::get(Command\Log\File::class));
 
-	$application->add(Server::get(ChangeKeyStorageRoot::class));
-	$application->add(Server::get(ShowKeyStorageRoot::class));
-	$application->add(Server::get(MigrateKeyStorage::class));
+    $application->add(Server::get(ChangeKeyStorageRoot::class));
+    $application->add(Server::get(ShowKeyStorageRoot::class));
+    $application->add(Server::get(MigrateKeyStorage::class));
 
-	$application->add(Server::get(DataFingerprint::class));
-	$application->add(Server::get(UpdateDB::class));
-	$application->add(Server::get(UpdateJS::class));
-	$application->add(Server::get(Command\Maintenance\Mode::class));
-	$application->add(Server::get(UpdateHtaccess::class));
-	$application->add(Server::get(UpdateTheme::class));
+    $application->add(Server::get(DataFingerprint::class));
+    $application->add(Server::get(UpdateDB::class));
+    $application->add(Server::get(UpdateJS::class));
+    $application->add(Server::get(Command\Maintenance\Mode::class));
+    $application->add(Server::get(UpdateHtaccess::class));
+    $application->add(Server::get(UpdateTheme::class));
 
-	$application->add(Server::get(Upgrade::class));
-	$application->add(Server::get(Repair::class));
-	$application->add(Server::get(RepairShareOwnership::class));
+    $application->add(Server::get(Upgrade::class));
+    $application->add(Server::get(Repair::class));
+    $application->add(Server::get(RepairShareOwnership::class));
 
-	$application->add(Server::get(Command\Preview\Cleanup::class));
-	$application->add(Server::get(Generate::class));
-	$application->add(Server::get(ResetRenderedTexts::class));
+    $application->add(Server::get(Command\Preview\Cleanup::class));
+    $application->add(Server::get(Generate::class));
+    $application->add(Server::get(ResetRenderedTexts::class));
 
-	$application->add(Server::get(Add::class));
-	$application->add(Server::get(Command\User\Delete::class));
-	$application->add(Server::get(Command\User\Disable::class));
-	$application->add(Server::get(Command\User\Enable::class));
-	$application->add(Server::get(LastSeen::class));
-	$application->add(Server::get(Report::class));
-	$application->add(Server::get(ResetPassword::class));
-	$application->add(Server::get(Setting::class));
-	$application->add(Server::get(Profile::class));
-	$application->add(Server::get(Command\User\ListCommand::class));
-	$application->add(Server::get(ClearGeneratedAvatarCacheCommand::class));
-	$application->add(Server::get(Info::class));
-	$application->add(Server::get(SyncAccountDataCommand::class));
-	$application->add(Server::get(Command\User\AuthTokens\Add::class));
-	$application->add(Server::get(Command\User\AuthTokens\ListCommand::class));
-	$application->add(Server::get(Command\User\AuthTokens\Delete::class));
-	$application->add(Server::get(Verify::class));
-	$application->add(Server::get(Welcome::class));
+    $application->add(Server::get(Add::class));
+    $application->add(Server::get(Command\User\Delete::class));
+    $application->add(Server::get(Command\User\Disable::class));
+    $application->add(Server::get(Command\User\Enable::class));
+    $application->add(Server::get(LastSeen::class));
+    $application->add(Server::get(Report::class));
+    $application->add(Server::get(ResetPassword::class));
+    $application->add(Server::get(Setting::class));
+    $application->add(Server::get(Profile::class));
+    $application->add(Server::get(Command\User\ListCommand::class));
+    $application->add(Server::get(ClearGeneratedAvatarCacheCommand::class));
+    $application->add(Server::get(Info::class));
+    $application->add(Server::get(SyncAccountDataCommand::class));
+    $application->add(Server::get(Command\User\AuthTokens\Add::class));
+    $application->add(Server::get(Command\User\AuthTokens\ListCommand::class));
+    $application->add(Server::get(Command\User\AuthTokens\Delete::class));
+    $application->add(Server::get(Verify::class));
+    $application->add(Server::get(Welcome::class));
 
-	$application->add(Server::get(Command\Group\Add::class));
-	$application->add(Server::get(Command\Group\Delete::class));
-	$application->add(Server::get(Command\Group\ListCommand::class));
-	$application->add(Server::get(AddUser::class));
-	$application->add(Server::get(RemoveUser::class));
-	$application->add(Server::get(Command\Group\Info::class));
+    $application->add(Server::get(Command\Group\Add::class));
+    $application->add(Server::get(Command\Group\Delete::class));
+    $application->add(Server::get(Command\Group\ListCommand::class));
+    $application->add(Server::get(AddUser::class));
+    $application->add(Server::get(RemoveUser::class));
+    $application->add(Server::get(Command\Group\Info::class));
 
-	$application->add(Server::get(Command\SystemTag\ListCommand::class));
-	$application->add(Server::get(Command\SystemTag\Delete::class));
-	$application->add(Server::get(Command\SystemTag\Add::class));
-	$application->add(Server::get(Edit::class));
+    $application->add(Server::get(Command\SystemTag\ListCommand::class));
+    $application->add(Server::get(Command\SystemTag\Delete::class));
+    $application->add(Server::get(Command\SystemTag\Add::class));
+    $application->add(Server::get(Edit::class));
 
-	$application->add(Server::get(ListCertificates::class));
-	$application->add(Server::get(ExportCertificates::class));
-	$application->add(Server::get(ImportCertificate::class));
-	$application->add(Server::get(RemoveCertificate::class));
-	$application->add(Server::get(BruteforceAttempts::class));
-	$application->add(Server::get(BruteforceResetAttempts::class));
-	$application->add(Server::get(SetupChecks::class));
-	$application->add(Server::get(SnowflakeDecodeId::class));
-	$application->add(Server::get(Get::class));
+    $application->add(Server::get(ListCertificates::class));
+    $application->add(Server::get(ExportCertificates::class));
+    $application->add(Server::get(ImportCertificate::class));
+    $application->add(Server::get(RemoveCertificate::class));
+    $application->add(Server::get(BruteforceAttempts::class));
+    $application->add(Server::get(BruteforceResetAttempts::class));
+    $application->add(Server::get(SetupChecks::class));
+    $application->add(Server::get(SnowflakeDecodeId::class));
+    $application->add(Server::get(Get::class));
 
-	$application->add(Server::get(GetCommand::class));
-	$application->add(Server::get(EnabledCommand::class));
-	$application->add(Server::get(Command\TaskProcessing\ListCommand::class));
-	$application->add(Server::get(Statistics::class));
-	$application->add(Server::get(Command\TaskProcessing\Cleanup::class));
+    $application->add(Server::get(GetCommand::class));
+    $application->add(Server::get(EnabledCommand::class));
+    $application->add(Server::get(Command\TaskProcessing\ListCommand::class));
+    $application->add(Server::get(Statistics::class));
+    $application->add(Server::get(Command\TaskProcessing\Cleanup::class));
 
-	$application->add(Server::get(RedisCommand::class));
-	$application->add(Server::get(DistributedClear::class));
-	$application->add(Server::get(DistributedDelete::class));
-	$application->add(Server::get(DistributedGet::class));
-	$application->add(Server::get(DistributedSet::class));
+    $application->add(Server::get(RedisCommand::class));
+    $application->add(Server::get(DistributedClear::class));
+    $application->add(Server::get(DistributedDelete::class));
+    $application->add(Server::get(DistributedGet::class));
+    $application->add(Server::get(DistributedSet::class));
 } else {
-	$application->add(Server::get(Command\Maintenance\Install::class));
+    $application->add(Server::get(Command\Maintenance\Install::class));
 }

core/Command/SnowflakeDecodeId.php

Indentation +30 added lines, -30 removed lines

@@ -15,34 +15,34 @@
 use Symfony\Component\Console\Output\OutputInterface;
 
 class SnowflakeDecodeId extends Base {
-	protected function configure(): void {
-		parent::configure();
-
-		$this
-			->setName('decode-snowflake')
-			->setDescription('Decode Snowflake IDs used by Nextcloud')
-			->addArgument('snowflake-id', InputArgument::REQUIRED, 'Nextcloud Snowflake ID to decode');
-	}
-
-	protected function execute(InputInterface $input, OutputInterface $output): int {
-		$snowflakeId = $input->getArgument('snowflake-id');
-		$data = (new Decoder)->decode($snowflakeId);
-
-		$rows = [
-			['Snowflake ID', $snowflakeId],
-			['Seconds', $data['seconds']],
-			['Milliseconds', $data['milliseconds']],
-			['Created from CLI', $data['isCli'] ? 'yes' : 'no'],
-			['Server ID', $data['serverId']],
-			['Sequence ID', $data['sequenceId']],
-			['Creation timestamp', $data['createdAt']->format('U.v')],
-			['Creation date', $data['createdAt']->format('Y-m-d H:i:s.v')],
-		];
-
-		$table = new Table($output);
-		$table->setRows($rows);
-		$table->render();
-
-		return Base::SUCCESS;
-	}
+    protected function configure(): void {
+        parent::configure();
+
+        $this
+            ->setName('decode-snowflake')
+            ->setDescription('Decode Snowflake IDs used by Nextcloud')
+            ->addArgument('snowflake-id', InputArgument::REQUIRED, 'Nextcloud Snowflake ID to decode');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int {
+        $snowflakeId = $input->getArgument('snowflake-id');
+        $data = (new Decoder)->decode($snowflakeId);
+
+        $rows = [
+            ['Snowflake ID', $snowflakeId],
+            ['Seconds', $data['seconds']],
+            ['Milliseconds', $data['milliseconds']],
+            ['Created from CLI', $data['isCli'] ? 'yes' : 'no'],
+            ['Server ID', $data['serverId']],
+            ['Sequence ID', $data['sequenceId']],
+            ['Creation timestamp', $data['createdAt']->format('U.v')],
+            ['Creation date', $data['createdAt']->format('Y-m-d H:i:s.v')],
+        ];
+
+        $table = new Table($output);
+        $table->setRows($rows);
+        $table->render();
+
+        return Base::SUCCESS;
+    }
 }

core/BackgroundJobs/MovePreviewJob.php

Indentation +212 added lines, -212 removed lines

@@ -31,216 +31,216 @@
 use Psr\Log\LoggerInterface;
 
 class MovePreviewJob extends TimedJob {
-	private IAppData $appData;
-	private string $previewRootPath;
-
-	public function __construct(
-		ITimeFactory $time,
-		private readonly IAppConfig $appConfig,
-		private readonly IConfig $config,
-		private readonly PreviewMapper $previewMapper,
-		private readonly StorageFactory $storageFactory,
-		private readonly IDBConnection $connection,
-		private readonly IRootFolder $rootFolder,
-		private readonly IMimeTypeDetector $mimeTypeDetector,
-		private readonly IMimeTypeLoader $mimeTypeLoader,
-		private readonly LoggerInterface $logger,
-		private readonly IGenerator $generator,
-		IAppDataFactory $appDataFactory,
-	) {
-		parent::__construct($time);
-
-		$this->appData = $appDataFactory->get('preview');
-		$this->setTimeSensitivity(self::TIME_INSENSITIVE);
-		$this->setInterval(24 * 60 * 60);
-		$this->previewRootPath = 'appdata_' . $this->config->getSystemValueString('instanceid') . '/preview/';
-	}
-
-	#[Override]
-	protected function run(mixed $argument): void {
-		if ($this->appConfig->getValueBool('core', 'previewMovedDone')) {
-			return;
-		}
-
-		$startTime = time();
-		while (true) {
-			$qb = $this->connection->getQueryBuilder();
-			$qb->select('path')
-				->from('filecache')
-				// Hierarchical preview folder structure
-				->where($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath . '%/%/%/%/%/%/%/%/%')))
-				// Legacy flat preview folder structure
-				->orWhere($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath . '%/%.%')))
-				->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
-				->setMaxResults(100);
-
-			$result = $qb->executeQuery();
-			$foundPreviews = $this->processQueryResult($result);
-
-			if (!$foundPreviews) {
-				break;
-			}
-
-			// Stop if execution time is more than one hour.
-			if (time() - $startTime > 3600) {
-				return;
-			}
-		}
-
-		$this->appConfig->setValueBool('core', 'previewMovedDone', true);
-	}
-
-	private function processQueryResult(IResult $result): bool {
-		$foundPreview = false;
-		$fileIds = [];
-		$flatFileIds = [];
-		while ($row = $result->fetch()) {
-			$pathSplit = explode('/', $row['path']);
-			assert(count($pathSplit) >= 2);
-			$fileId = (int)$pathSplit[count($pathSplit) - 2];
-			if (count($pathSplit) === 11) {
-				// Hierarchical structure
-				if (!in_array($fileId, $fileIds)) {
-					$fileIds[] = $fileId;
-				}
-			} else {
-				// Flat structure
-				if (!in_array($fileId, $flatFileIds)) {
-					$flatFileIds[] = $fileId;
-				}
-			}
-			$foundPreview = true;
-		}
-
-		foreach ($fileIds as $fileId) {
-			$this->processPreviews($fileId, flatPath: false);
-		}
-
-		foreach ($flatFileIds as $fileId) {
-			$this->processPreviews($fileId, flatPath: true);
-		}
-		return $foundPreview;
-	}
-
-	/**
-	 * @param array<string|int, string[]> $previewFolders
-	 */
-	private function processPreviews(int $fileId, bool $flatPath): void {
-		$internalPath = $this->getInternalFolder((string)$fileId, $flatPath);
-		$folder = $this->appData->getFolder($internalPath);
-
-		/**
-		 * @var list<array{file: SimpleFile, preview: Preview}> $previewFiles
-		 */
-		$previewFiles = [];
-
-		foreach ($folder->getDirectoryListing() as $previewFile) {
-			$path = $fileId . '/' . $previewFile->getName();
-			/** @var SimpleFile $previewFile */
-			$preview = Preview::fromPath($path, $this->mimeTypeDetector);
-			$preview->setId($this->generator->nextId());
-			if (!$preview) {
-				$this->logger->error('Unable to import old preview at path.');
-				continue;
-			}
-			$preview->setSize($previewFile->getSize());
-			$preview->setMtime($previewFile->getMtime());
-			$preview->setOldFileId($previewFile->getId());
-			$preview->setEncrypted(false);
-
-			$previewFiles[] = [
-				'file' => $previewFile,
-				'preview' => $preview,
-			];
-		}
-
-		$qb = $this->connection->getQueryBuilder();
-		$qb->select('storage', 'etag', 'mimetype')
-			->from('filecache')
-			->where($qb->expr()->eq('fileid', $qb->createNamedParameter($fileId)))
-			->setMaxResults(1);
-
-		$result = $qb->executeQuery();
-		$result = $result->fetchAll();
-
-		if (count($result) > 0) {
-			foreach ($previewFiles as $previewFile) {
-				/** @var Preview $preview */
-				$preview = $previewFile['preview'];
-				/** @var SimpleFile $file */
-				$file = $previewFile['file'];
-				$preview->setStorageId($result[0]['storage']);
-				$preview->setEtag($result[0]['etag']);
-				$preview->setSourceMimeType($this->mimeTypeLoader->getMimetypeById((int)$result[0]['mimetype']));
-				try {
-					$preview = $this->previewMapper->insert($preview);
-				} catch (Exception) {
-					// We already have this preview in the preview table, skip
-					$qb->delete('filecache')
-						->where($qb->expr()->eq('fileid', $qb->createNamedParameter($file->getId())))
-						->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
-						->executeStatement();
-					continue;
-				}
-
-				try {
-					$this->storageFactory->migratePreview($preview, $file);
-					$qb = $this->connection->getQueryBuilder();
-					$qb->delete('filecache')
-						->where($qb->expr()->eq('fileid', $qb->createNamedParameter($file->getId())))
-						->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
-						->executeStatement();
-					// Do not call $file->delete() as this will also delete the file from the file system
-				} catch (\Exception $e) {
-					$this->previewMapper->delete($preview);
-					throw $e;
-				}
-			}
-		} else {
-			// No matching fileId, delete preview
-			try {
-				$this->connection->beginTransaction();
-				foreach ($previewFiles as $previewFile) {
-					/** @var SimpleFile $file */
-					$file = $previewFile['file'];
-					$file->delete();
-				}
-				$this->connection->commit();
-			} catch (Exception) {
-				$this->connection->rollback();
-			}
-		}
-
-		$this->deleteFolder($internalPath);
-	}
-
-	public static function getInternalFolder(string $name, bool $flatPath): string {
-		if ($flatPath) {
-			return $name;
-		}
-		return implode('/', str_split(substr(md5($name), 0, 7))) . '/' . $name;
-	}
-
-	private function deleteFolder(string $path): void {
-		$current = $path;
-
-		while (true) {
-			$appDataPath = $this->previewRootPath . $current;
-			$qb = $this->connection->getQueryBuilder();
-			$qb->delete('filecache')
-				->where($qb->expr()->eq('path_hash', $qb->createNamedParameter(md5($appDataPath))))
-				->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
-				->executeStatement();
-
-			$current = dirname($current);
-			if ($current === '/' || $current === '.' || $current === '') {
-				break;
-			}
-
-			$folder = $this->appData->getFolder($current);
-			if (count($folder->getDirectoryListing()) !== 0) {
-				break;
-			}
-		}
-	}
+    private IAppData $appData;
+    private string $previewRootPath;
+
+    public function __construct(
+        ITimeFactory $time,
+        private readonly IAppConfig $appConfig,
+        private readonly IConfig $config,
+        private readonly PreviewMapper $previewMapper,
+        private readonly StorageFactory $storageFactory,
+        private readonly IDBConnection $connection,
+        private readonly IRootFolder $rootFolder,
+        private readonly IMimeTypeDetector $mimeTypeDetector,
+        private readonly IMimeTypeLoader $mimeTypeLoader,
+        private readonly LoggerInterface $logger,
+        private readonly IGenerator $generator,
+        IAppDataFactory $appDataFactory,
+    ) {
+        parent::__construct($time);
+
+        $this->appData = $appDataFactory->get('preview');
+        $this->setTimeSensitivity(self::TIME_INSENSITIVE);
+        $this->setInterval(24 * 60 * 60);
+        $this->previewRootPath = 'appdata_' . $this->config->getSystemValueString('instanceid') . '/preview/';
+    }
+
+    #[Override]
+    protected function run(mixed $argument): void {
+        if ($this->appConfig->getValueBool('core', 'previewMovedDone')) {
+            return;
+        }
+
+        $startTime = time();
+        while (true) {
+            $qb = $this->connection->getQueryBuilder();
+            $qb->select('path')
+                ->from('filecache')
+                // Hierarchical preview folder structure
+                ->where($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath . '%/%/%/%/%/%/%/%/%')))
+                // Legacy flat preview folder structure
+                ->orWhere($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath . '%/%.%')))
+                ->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
+                ->setMaxResults(100);
+
+            $result = $qb->executeQuery();
+            $foundPreviews = $this->processQueryResult($result);
+
+            if (!$foundPreviews) {
+                break;
+            }
+
+            // Stop if execution time is more than one hour.
+            if (time() - $startTime > 3600) {
+                return;
+            }
+        }
+
+        $this->appConfig->setValueBool('core', 'previewMovedDone', true);
+    }
+
+    private function processQueryResult(IResult $result): bool {
+        $foundPreview = false;
+        $fileIds = [];
+        $flatFileIds = [];
+        while ($row = $result->fetch()) {
+            $pathSplit = explode('/', $row['path']);
+            assert(count($pathSplit) >= 2);
+            $fileId = (int)$pathSplit[count($pathSplit) - 2];
+            if (count($pathSplit) === 11) {
+                // Hierarchical structure
+                if (!in_array($fileId, $fileIds)) {
+                    $fileIds[] = $fileId;
+                }
+            } else {
+                // Flat structure
+                if (!in_array($fileId, $flatFileIds)) {
+                    $flatFileIds[] = $fileId;
+                }
+            }
+            $foundPreview = true;
+        }
+
+        foreach ($fileIds as $fileId) {
+            $this->processPreviews($fileId, flatPath: false);
+        }
+
+        foreach ($flatFileIds as $fileId) {
+            $this->processPreviews($fileId, flatPath: true);
+        }
+        return $foundPreview;
+    }
+
+    /**
+     * @param array<string|int, string[]> $previewFolders
+     */
+    private function processPreviews(int $fileId, bool $flatPath): void {
+        $internalPath = $this->getInternalFolder((string)$fileId, $flatPath);
+        $folder = $this->appData->getFolder($internalPath);
+
+        /**
+         * @var list<array{file: SimpleFile, preview: Preview}> $previewFiles
+         */
+        $previewFiles = [];
+
+        foreach ($folder->getDirectoryListing() as $previewFile) {
+            $path = $fileId . '/' . $previewFile->getName();
+            /** @var SimpleFile $previewFile */
+            $preview = Preview::fromPath($path, $this->mimeTypeDetector);
+            $preview->setId($this->generator->nextId());
+            if (!$preview) {
+                $this->logger->error('Unable to import old preview at path.');
+                continue;
+            }
+            $preview->setSize($previewFile->getSize());
+            $preview->setMtime($previewFile->getMtime());
+            $preview->setOldFileId($previewFile->getId());
+            $preview->setEncrypted(false);
+
+            $previewFiles[] = [
+                'file' => $previewFile,
+                'preview' => $preview,
+            ];
+        }
+
+        $qb = $this->connection->getQueryBuilder();
+        $qb->select('storage', 'etag', 'mimetype')
+            ->from('filecache')
+            ->where($qb->expr()->eq('fileid', $qb->createNamedParameter($fileId)))
+            ->setMaxResults(1);
+
+        $result = $qb->executeQuery();
+        $result = $result->fetchAll();
+
+        if (count($result) > 0) {
+            foreach ($previewFiles as $previewFile) {
+                /** @var Preview $preview */
+                $preview = $previewFile['preview'];
+                /** @var SimpleFile $file */
+                $file = $previewFile['file'];
+                $preview->setStorageId($result[0]['storage']);
+                $preview->setEtag($result[0]['etag']);
+                $preview->setSourceMimeType($this->mimeTypeLoader->getMimetypeById((int)$result[0]['mimetype']));
+                try {
+                    $preview = $this->previewMapper->insert($preview);
+                } catch (Exception) {
+                    // We already have this preview in the preview table, skip
+                    $qb->delete('filecache')
+                        ->where($qb->expr()->eq('fileid', $qb->createNamedParameter($file->getId())))
+                        ->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
+                        ->executeStatement();
+                    continue;
+                }
+
+                try {
+                    $this->storageFactory->migratePreview($preview, $file);
+                    $qb = $this->connection->getQueryBuilder();
+                    $qb->delete('filecache')
+                        ->where($qb->expr()->eq('fileid', $qb->createNamedParameter($file->getId())))
+                        ->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
+                        ->executeStatement();
+                    // Do not call $file->delete() as this will also delete the file from the file system
+                } catch (\Exception $e) {
+                    $this->previewMapper->delete($preview);
+                    throw $e;
+                }
+            }
+        } else {
+            // No matching fileId, delete preview
+            try {
+                $this->connection->beginTransaction();
+                foreach ($previewFiles as $previewFile) {
+                    /** @var SimpleFile $file */
+                    $file = $previewFile['file'];
+                    $file->delete();
+                }
+                $this->connection->commit();
+            } catch (Exception) {
+                $this->connection->rollback();
+            }
+        }
+
+        $this->deleteFolder($internalPath);
+    }
+
+    public static function getInternalFolder(string $name, bool $flatPath): string {
+        if ($flatPath) {
+            return $name;
+        }
+        return implode('/', str_split(substr(md5($name), 0, 7))) . '/' . $name;
+    }
+
+    private function deleteFolder(string $path): void {
+        $current = $path;
+
+        while (true) {
+            $appDataPath = $this->previewRootPath . $current;
+            $qb = $this->connection->getQueryBuilder();
+            $qb->delete('filecache')
+                ->where($qb->expr()->eq('path_hash', $qb->createNamedParameter(md5($appDataPath))))
+                ->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
+                ->executeStatement();
+
+            $current = dirname($current);
+            if ($current === '/' || $current === '.' || $current === '') {
+                break;
+            }
+
+            $folder = $this->appData->getFolder($current);
+            if (count($folder->getDirectoryListing()) !== 0) {
+                break;
+            }
+        }
+    }
 }

Spacing +9 added lines, -9 removed lines

@@ -53,7 +53,7 @@ 
 		$this->appData = $appDataFactory->get('preview');
 		$this->setTimeSensitivity(self::TIME_INSENSITIVE);
 		$this->setInterval(24 * 60 * 60);
-		$this->previewRootPath = 'appdata_' . $this->config->getSystemValueString('instanceid') . '/preview/';
+		$this->previewRootPath = 'appdata_'.$this->config->getSystemValueString('instanceid').'/preview/';
 	}
 
 	#[Override]
@@ -68,9 +68,9 @@ 
 			$qb->select('path')
 				->from('filecache')
 				// Hierarchical preview folder structure
-				->where($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath . '%/%/%/%/%/%/%/%/%')))
+				->where($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath.'%/%/%/%/%/%/%/%/%')))
 				// Legacy flat preview folder structure
-				->orWhere($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath . '%/%.%')))
+				->orWhere($qb->expr()->like('path', $qb->createNamedParameter($this->previewRootPath.'%/%.%')))
 				->hintShardKey('storage', $this->rootFolder->getMountPoint()->getNumericStorageId())
 				->setMaxResults(100);
 
@@ -97,7 +97,7 @@ 
 		while ($row = $result->fetch()) {
 			$pathSplit = explode('/', $row['path']);
 			assert(count($pathSplit) >= 2);
-			$fileId = (int)$pathSplit[count($pathSplit) - 2];
+			$fileId = (int) $pathSplit[count($pathSplit) - 2];
 			if (count($pathSplit) === 11) {
 				// Hierarchical structure
 				if (!in_array($fileId, $fileIds)) {
@@ -126,7 +126,7 @@ 
 	 * @param array<string|int, string[]> $previewFolders
 	 */
 	private function processPreviews(int $fileId, bool $flatPath): void {
-		$internalPath = $this->getInternalFolder((string)$fileId, $flatPath);
+		$internalPath = $this->getInternalFolder((string) $fileId, $flatPath);
 		$folder = $this->appData->getFolder($internalPath);
 
 		/**
@@ -135,7 +135,7 @@ 
 		$previewFiles = [];
 
 		foreach ($folder->getDirectoryListing() as $previewFile) {
-			$path = $fileId . '/' . $previewFile->getName();
+			$path = $fileId.'/'.$previewFile->getName();
 			/** @var SimpleFile $previewFile */
 			$preview = Preview::fromPath($path, $this->mimeTypeDetector);
 			$preview->setId($this->generator->nextId());
@@ -171,7 +171,7 @@ 
 				$file = $previewFile['file'];
 				$preview->setStorageId($result[0]['storage']);
 				$preview->setEtag($result[0]['etag']);
-				$preview->setSourceMimeType($this->mimeTypeLoader->getMimetypeById((int)$result[0]['mimetype']));
+				$preview->setSourceMimeType($this->mimeTypeLoader->getMimetypeById((int) $result[0]['mimetype']));
 				try {
 					$preview = $this->previewMapper->insert($preview);
 				} catch (Exception) {
@@ -218,14 +218,14 @@ 
 		if ($flatPath) {
 			return $name;
 		}
-		return implode('/', str_split(substr(md5($name), 0, 7))) . '/' . $name;
+		return implode('/', str_split(substr(md5($name), 0, 7))).'/'.$name;
 	}
 
 	private function deleteFolder(string $path): void {
 		$current = $path;
 
 		while (true) {
-			$appDataPath = $this->previewRootPath . $current;
+			$appDataPath = $this->previewRootPath.$current;
 			$qb = $this->connection->getQueryBuilder();
 			$qb->delete('filecache')
 				->where($qb->expr()->eq('path_hash', $qb->createNamedParameter(md5($appDataPath))))