refactor: Process all fs events asynchronously

Signed-off-by: Marcel Klehr <mklehr@gmx.net>

Author: marcelklehr

lib/BackgroundJobs/ProcessAccessUpdatesJob.php

@@ -0,0 +1,64 @@
+<?php
+
+/*
+ * Copyright (c) 2021-2022 The Recognize contributors.
+ * This file is licensed under the Affero General Public License version 3 or later. See the COPYING file.
+ */
+declare(strict_types=1);
+namespace OCA\Recognize\BackgroundJobs;
+
+use OCA\Recognize\Db\FsActionMapper;
+use OCA\Recognize\Service\FsActionService;
+use OCP\AppFramework\Utility\ITimeFactory;
+use OCP\BackgroundJob\IJobList;
+use OCP\BackgroundJob\TimedJob;
+use OCP\DB\Exception;
+use Psr\Log\LoggerInterface;
+
+final class ProcessFsActionsJob extends TimedJob {
+
+	public function __construct(
+		ITimeFactory            $timeFactory,
+		private FsActionService $accessUpdateService,
+		private IJobList        $jobList,
+		private FsActionMapper  $accessUpdateMapper,
+		private LoggerInterface $logger,
+	) {
+		parent::__construct($timeFactory);
+		$this->setInterval(5 * 60);
+		$this->setTimeSensitivity(self::TIME_SENSITIVE);
+	}
+
+	/**
+	 * @param array{storage_id:int, type: string} $argument
+	 * @return void
+	 */
+	protected function run($argument): void {
+		$storageId = $argument['storage_id'] ?? null;
+		$className = $argument['type'];
+
+		if (isset($storageId)) {
+			$this->accessUpdateService->processActionsByClassAndStorageId($className, $storageId);
+			try {
+				$remainingCount = $this->accessUpdateMapper->countByStorageId($className, $storageId);
+			} catch (Exception $e) {
+				$this->logger->error('Failed to count fs actions: ' . $e->getMessage(), ['exception' => $e]);
+				$remainingCount = 1;
+			}
+		} else {
+			$this->accessUpdateService->processActionsByClass($className);
+			try {
+				$remainingCount = $this->accessUpdateMapper->count($className);
+			} catch (Exception $e) {
+				$this->logger->error('Failed to count fs actions: ' . $e->getMessage(), ['exception' => $e]);
+				$remainingCount = 1;
+			}
+		}
+
+
+		if ($remainingCount === 0) {
+			// Remove job from queue
+			$this->jobList->remove(self::class, $argument);
+		}
+	}
+}

lib/BackgroundJobs/ProcessFsActionsJob.php

@@ -10,15 +10,15 @@
 use OCP\AppFramework\Db\Entity;
 
 /**
- * Class AccessUpdate
+ * Class FsAccessUpdate
  *
  * @package OCA\Recognize\Db
  * @method int getStorageId()
  * @method setStorageId(int $storageId)
  * @method int getRootId()
  * @method setRootId(int $rootId)
  */
-final class AccessUpdate extends Entity {
+final class FsAccessUpdate extends Entity {
 	protected ?int $storageId = null;
 	protected ?int $rootId = null;
 
@@ -32,6 +32,8 @@ final class AccessUpdate extends Entity {
 	 */
 	public static array $fields = ['id', 'storageId', 'rootId'];
 
+	public static string $tableName = 'recognize_fs_access_updates';
+
 	public function __construct() {
 		// add types in constructor
 		$this->addType('id', 'integer');