fixup! fix(dav): move orphan cleaning logic to a chunked background job

Author: st3iny

apps/dav/lib/BackgroundJob/CleanupOrphanedChildrenJob.php

@@ -74,14 +74,15 @@ private function cleanUpOrphans(
 		$result = $selectQb->executeQuery();
 		$rows = $result->fetchAll();
 		$result->closeCursor();
+		if (empty($rows)) {
+			return 0;
+		}
 
 		$orphanItems = array_map(static fn ($row) => $row['id'], $rows);
-		if (!empty($orphanItems)) {
-			$deleteQb = $this->connection->getQueryBuilder();
-			$deleteQb->delete($childTable)
-				->where($deleteQb->expr()->in('id', $deleteQb->createNamedParameter($orphanItems, IQueryBuilder::PARAM_INT_ARRAY)));
-			$deleteQb->executeStatement();
-		}
+		$deleteQb = $this->connection->getQueryBuilder();
+		$deleteQb->delete($childTable)
+			->where($deleteQb->expr()->in('id', $deleteQb->createNamedParameter($orphanItems, IQueryBuilder::PARAM_INT_ARRAY)));
+		$deleteQb->executeStatement();
 
 		return count($orphanItems);
 	}

apps/dav/tests/unit/BackgroundJob/CleanupOrphanedChildrenJobTest.php

@@ -77,40 +77,42 @@ private function getMockQueryBuilder(): IQueryBuilder&MockObject {
 
 	public function testRunWithoutOrphans(): void {
 		$argument = $this->getArgument();
-		$qb = $this->getMockQueryBuilder();
+		$selectQb = $this->getMockQueryBuilder();
 		$result = $this->createMock(IResult::class);
 
 		$this->connection->expects(self::once())
 			->method('getQueryBuilder')
-			->willReturn($qb);
-		$qb->expects(self::once())
+			->willReturn($selectQb);
+		$selectQb->expects(self::once())
 			->method('executeQuery')
 			->willReturn($result);
 		$result->expects(self::once())
 			->method('fetchAll')
 			->willReturn([]);
 		$result->expects(self::once())
 			->method('closeCursor');
-		$qb->expects(self::never())
-			->method('delete');
-		$qb->expects(self::never())
-			->method('executeStatement');
 		$this->jobList->expects(self::never())
 			->method('add');
 
 		self::invokePrivate($this->job, 'run', [$argument]);
 	}
 
 	public function testRunWithPartialBatch(): void {
-		$batch = 0;
 		$argument = $this->getArgument();
-		$qb = $this->getMockQueryBuilder();
+		$selectQb = $this->getMockQueryBuilder();
+		$deleteQb = $this->getMockQueryBuilder();
 		$result = $this->createMock(IResult::class);
 
-		$this->connection->expects(self::once())
+		$qbInvocationCount = self::exactly(2);
+		$this->connection->expects($qbInvocationCount)
 			->method('getQueryBuilder')
-			->willReturn($qb);
-		$qb->expects(self::once())
+			->willReturnCallback(function () use ($qbInvocationCount, $selectQb, $deleteQb) {
+				return match ($qbInvocationCount->getInvocationCount()) {
+					1 => $selectQb,
+					2 => $deleteQb,
+				};
+			});
+		$selectQb->expects(self::once())
 			->method('executeQuery')
 			->willReturn($result);
 		$result->expects(self::once())
@@ -121,10 +123,10 @@ public function testRunWithPartialBatch(): void {
 			]);
 		$result->expects(self::once())
 			->method('closeCursor');
-		$qb->expects(self::once())
+		$deleteQb->expects(self::once())
 			->method('delete')
 			->willReturnSelf();
-		$qb->expects(self::once())
+		$deleteQb->expects(self::once())
 			->method('executeStatement');
 		$this->jobList->expects(self::never())
 			->method('add');
@@ -133,26 +135,32 @@ public function testRunWithPartialBatch(): void {
 	}
 
 	public function testRunWithFullBatch(): void {
-		$batch = 0;
 		$argument = $this->getArgument();
-		$qb = $this->getMockQueryBuilder();
+		$selectQb = $this->getMockQueryBuilder();
+		$deleteQb = $this->getMockQueryBuilder();
 		$result = $this->createMock(IResult::class);
 
-		$this->connection->expects(self::once())
+		$qbInvocationCount = self::exactly(2);
+		$this->connection->expects($qbInvocationCount)
 			->method('getQueryBuilder')
-			->willReturn($qb);
-		$qb->expects(self::once())
+			->willReturnCallback(function () use ($qbInvocationCount, $selectQb, $deleteQb) {
+				return match ($qbInvocationCount->getInvocationCount()) {
+					1 => $selectQb,
+					2 => $deleteQb,
+				};
+			});
+		$selectQb->expects(self::once())
 			->method('executeQuery')
 			->willReturn($result);
 		$result->expects(self::once())
 			->method('fetchAll')
 			->willReturn(array_map(static fn ($i) => ['id' => 42 + $i], range(0, 999)));
 		$result->expects(self::once())
 			->method('closeCursor');
-		$qb->expects(self::once())
+		$deleteQb->expects(self::once())
 			->method('delete')
 			->willReturnSelf();
-		$qb->expects(self::once())
+		$deleteQb->expects(self::once())
 			->method('executeStatement');
 		$this->jobList->expects(self::once())
 			->method('add')