From d7b5a09cb88d92b5a59d56d6dc1cd33f9c93d9b2 Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Tue, 22 Nov 2022 13:23:22 +0100
Subject: [PATCH 1/8] Chec in test_wasmtensorflow.js

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 src/test_wasmtensorflow.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/test_wasmtensorflow.js b/src/test_wasmtensorflow.js
index a78151ff..e9351adf 100644
--- a/src/test_wasmtensorflow.js
+++ b/src/test_wasmtensorflow.js
@@ -1,4 +1,4 @@
-let tf = require('@tensorflow/tfjs')
+const tf = require('@tensorflow/tfjs')
 require('@tensorflow/tfjs-backend-wasm')
 
 tf.setBackend('wasm')

From 89cfdfa3ecc8f64b0a996f78a2ab243f00942a1e Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Tue, 22 Nov 2022 13:38:49 +0100
Subject: [PATCH 2/8] Add bg job mode status in admin settings

see #510

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 appinfo/routes.php                 |  1 +
 lib/Controller/AdminController.php | 10 +++++++++-
 src/components/ViewAdmin.vue       | 26 +++++++++++++++++++-------
 3 files changed, 29 insertions(+), 8 deletions(-)

diff --git a/appinfo/routes.php b/appinfo/routes.php
index be7efa0f..c9cdbcf4 100644
--- a/appinfo/routes.php
+++ b/appinfo/routes.php
@@ -33,6 +33,7 @@
 		['name' => 'admin#nodejs', 'url' => '/admin/nodejs', 'verb' => 'GET'],
 		['name' => 'admin#libtensorflow', 'url' => '/admin/libtensorflow', 'verb' => 'GET'],
 		['name' => 'admin#wasmtensorflow', 'url' => '/admin/wasmtensorflow', 'verb' => 'GET'],
+		['name' => 'admin#cron', 'url' => '/admin/cron', 'verb' => 'GET'],
 		['name' => 'admin#get_setting', 'url' => '/admin/settings/{setting}', 'verb' => 'GET'],
 		['name' => 'admin#set_setting', 'url' => '/admin/settings/{setting}', 'verb' => 'PUT'],
 	],
diff --git a/lib/Controller/AdminController.php b/lib/Controller/AdminController.php
index c4855077..c9d23335 100644
--- a/lib/Controller/AdminController.php
+++ b/lib/Controller/AdminController.php
@@ -13,6 +13,7 @@
 use OCP\AppFramework\Http\JSONResponse;
 use OCP\BackgroundJob\IJobList;
 use OCP\DB\Exception;
+use OCP\IConfig;
 use OCP\IRequest;
 
 class AdminController extends Controller {
@@ -22,8 +23,9 @@ class AdminController extends Controller {
 	private QueueService $queue;
 	private FaceClusterMapper $clusterMapper;
 	private FaceDetectionMapper $detectionMapper;
+	private IConfig $config;
 
-	public function __construct(string $appName, IRequest $request, TagManager $tagManager, IJobList $jobList, SettingsService $settingsService, QueueService $queue, FaceClusterMapper $clusterMapper, FaceDetectionMapper $detectionMapper) {
+	public function __construct(string $appName, IRequest $request, TagManager $tagManager, IJobList $jobList, SettingsService $settingsService, QueueService $queue, FaceClusterMapper $clusterMapper, FaceDetectionMapper $detectionMapper, IConfig $config) {
 		parent::__construct($appName, $request);
 		$this->tagManager = $tagManager;
 		$this->jobList = $jobList;
@@ -31,6 +33,7 @@ public function __construct(string $appName, IRequest $request, TagManager $tagM
 		$this->queue = $queue;
 		$this->clusterMapper = $clusterMapper;
 		$this->detectionMapper = $detectionMapper;
+		$this->config = $config;
 	}
 
 	public function reset(): JSONResponse {
@@ -160,6 +163,11 @@ public function wasmtensorflow(): JSONResponse {
 		return new JSONResponse(['wasmtensorflow' => true]);
 	}
 
+	public function cron(): JSONResponse {
+		$cron = $this->config->getAppValue('core', 'backgroundjobs_mode', '');
+		return new JSONResponse(['cron' => $cron]);
+	}
+
 	public function setSetting(string $setting, $value): JSONResponse {
 		try {
 			$this->settingsService->setSetting($setting, $value);
diff --git a/src/components/ViewAdmin.vue b/src/components/ViewAdmin.vue
index 072f50ca..a60a904f 100644
--- a/src/components/ViewAdmin.vue
+++ b/src/components/ViewAdmin.vue
@@ -18,14 +18,19 @@
 			<NcNoteCard v-if="nodejs === false">
 				{{ t('recognize', 'Could not execute the Node.js binary. You may need to set the path to a working binary manually.') }}
 			</NcNoteCard>
-			<template v-else-if="settings['faces.enabled'] || settings['imagenet.enabled'] || settings['musicnn.enabled'] || settings['movinet.enabled']">
-				<NcNoteCard show-alert type="success">
-					{{ t('recognize', 'The app is installed and will automatically classify files in background processes.') }}
-				</NcNoteCard>
+			<NcNoteCard v-if="cron !== undefined && cron !== 'cron'">
+				{{ t('recognize', 'Background Jobs are not executed via cron. Recognize requires background jobs to be executed via cron.') }}
+			</NcNoteCard>
+			<template v-if="nodejs && (libtensorflow || wasmtensorflow) && cron === 'cron'">
+				<template v-if="settings['faces.enabled'] || settings['imagenet.enabled'] || settings['musicnn.enabled'] || settings['movinet.enabled']">
+					<NcNoteCard show-alert type="success">
+						{{ t('recognize', 'The app is installed and will automatically classify files in background processes.') }}
+					</NcNoteCard>
+				</template>
+				<p v-else>
+					{{ t('recognize', 'None of the tagging options below are currently selected. The app will currently do nothing.') }}
+				</p>
 			</template>
-			<p v-else>
-				{{ t('recognize', 'None of the tagging options below are currently selected. The app will currently do nothing.') }}
-			</p>
 		</NcSettingsSection>
 		<NcSettingsSection :title="t('recognize', 'Image tagging')">
 			<template v-if="settings['faces.enabled']">
@@ -287,6 +292,7 @@ export default {
 			nodejs: undefined,
 			libtensorflow: undefined,
 			wasmtensorflow: undefined,
+			cron: undefined,
 			modelsDownloaded: null,
 		}
 	},
@@ -322,6 +328,7 @@ export default {
 		this.getNodejsStatus()
 		this.getLibtensorflowStatus()
 		this.getWasmtensorflowStatus()
+		this.getCronStatus()
 
 		setInterval(async () => {
 			this.getCount()
@@ -415,6 +422,11 @@ export default {
 			const { wasmtensorflow } = resp.data
 			this.wasmtensorflow = wasmtensorflow
 		},
+		async getCronStatus() {
+			const resp = await axios.get(generateUrl('/apps/recognize/admin/cron'))
+			const { cron } = resp.data
+			this.cron = cron
+		},
 		onChange() {
 			if (this.timeout) {
 				clearTimeout(this.timeout)

From 5ec749841c12ef8f80845fb958296b4b17cedc2e Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Tue, 15 Nov 2022 14:00:37 +0100
Subject: [PATCH 3/8] Factor out ignored directories functionality into
 IgnoreService

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 lib/BackgroundJobs/StorageCrawlJob.php | 46 ++++----------------
 lib/Service/IgnoreService.php          | 58 ++++++++++++++++++++++++++
 2 files changed, 66 insertions(+), 38 deletions(-)
 create mode 100644 lib/Service/IgnoreService.php

diff --git a/lib/BackgroundJobs/StorageCrawlJob.php b/lib/BackgroundJobs/StorageCrawlJob.php
index 0666a585..4ca27865 100644
--- a/lib/BackgroundJobs/StorageCrawlJob.php
+++ b/lib/BackgroundJobs/StorageCrawlJob.php
@@ -16,6 +16,7 @@
 use OCA\Recognize\Classifiers\Video\MovinetClassifier;
 use OCA\Recognize\Constants;
 use OCA\Recognize\Db\QueueFile;
+use OCA\Recognize\Service\IgnoreService;
 use OCA\Recognize\Service\Logger;
 use OCA\Recognize\Service\QueueService;
 use OCA\Recognize\Service\TagManager;
@@ -36,8 +37,9 @@ class StorageCrawlJob extends QueuedJob {
 	private IDBConnection $db;
 	private SystemConfig $systemConfig;
 	private TagManager $tagManager;
+	private IgnoreService $ignoreService;
 
-	public function __construct(ITimeFactory $timeFactory, Logger $logger, IMimeTypeLoader $mimeTypes, QueueService $queue, IJobList $jobList, IDBConnection $db, SystemConfig $systemConfig, TagManager $tagManager) {
+	public function __construct(ITimeFactory $timeFactory, Logger $logger, IMimeTypeLoader $mimeTypes, QueueService $queue, IJobList $jobList, IDBConnection $db, SystemConfig $systemConfig, TagManager $tagManager, IgnoreService $ignoreService) {
 		parent::__construct($timeFactory);
 		$this->logger = $logger;
 		$this->mimeTypes = $mimeTypes;
@@ -46,39 +48,7 @@ public function __construct(ITimeFactory $timeFactory, Logger $logger, IMimeType
 		$this->db = $db;
 		$this->systemConfig = $systemConfig;
 		$this->tagManager = $tagManager;
-	}
-
-	private function getDir(int $fileid, array $directoryTypes, bool $recursive = false): array {
-		/** @var \OCP\DB\QueryBuilder\IQueryBuilder $qb */
-		$qb = new CacheQueryBuilder($this->db, $this->systemConfig, $this->logger);
-		$dir = $qb->selectFileCache()
-			->andWhere($qb->expr()->in('mimetype', $qb->createNamedParameter($directoryTypes, IQueryBuilder::PARAM_INT_ARRAY)))
-			->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($fileid)))
-			->executeQuery()->fetchAll();
-
-		if ($recursive) {
-			foreach ($dir as $item) {
-				$dir = array_merge($dir, $this->getDir($item['fileid'], $directoryTypes, $recursive));
-			}
-		}
-		return $dir;
-	}
-
-	private function getIgnoreFileids(int $storageId, array $ignore_maekers): array {
-		$directoryTypes = array_map(fn ($mimeType) => $this->mimeTypes->getId($mimeType), Constants::DIRECTORY_FORMATS);
-		/** @var \OCP\DB\QueryBuilder\IQueryBuilder $qb */
-		$qb = new CacheQueryBuilder($this->db, $this->systemConfig, $this->logger);
-		$ignoreFiles = $qb->selectFileCache()
-			->andWhere($qb->expr()->in('name', $qb->createNamedParameter($ignore_maekers, IQueryBuilder::PARAM_STR_ARRAY)))
-			->andWhere($qb->expr()->eq('storage', $qb->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
-			->executeQuery()->fetchAll();
-		$ignoreFileids = array_map(fn ($dir) => $dir['parent'], $ignoreFiles);
-		foreach ($ignoreFiles as $ignoreFile) {
-			$ignoreDir = $this->getDir($ignoreFile['parent'], $directoryTypes, true);
-			$fileids = array_map(fn ($dir) => $dir['fileid'], $ignoreDir);
-			$ignoreFileids = array_merge($ignoreFileids, $fileids);
-		}
-		return $ignoreFileids;
+		$this->ignoreService = $ignoreService;
 	}
 
 	protected function run($argument): void {
@@ -114,10 +84,10 @@ protected function run($argument): void {
 		}
 
 		try {
-			$ignoreAllFileids = $this->getIgnoreFileids($storageId, Constants::IGNORE_MARKERS_ALL);
-			$ignoreImageFileids = $this->getIgnoreFileids($storageId, Constants::IGNORE_MARKERS_IMAGE);
-			$ignoreVideoFileids = $this->getIgnoreFileids($storageId, Constants::IGNORE_MARKERS_VIDEO);
-			$ignoreAudioFileids = $this->getIgnoreFileids($storageId, Constants::IGNORE_MARKERS_AUDIO);
+			$ignoreAllFileids = $this->ignoreService->getIgnoredDirectories($storageId, Constants::IGNORE_MARKERS_ALL);
+			$ignoreImageFileids = $this->ignoreService->getIgnoredDirectories($storageId, Constants::IGNORE_MARKERS_IMAGE);
+			$ignoreVideoFileids = $this->ignoreService->getIgnoredDirectories($storageId, Constants::IGNORE_MARKERS_VIDEO);
+			$ignoreAudioFileids = $this->ignoreService->getIgnoredDirectories($storageId, Constants::IGNORE_MARKERS_AUDIO);
 		} catch (Exception $e) {
 			$this->logger->error('Could not fetch ignore files', ['exception' => $e]);
 			return;
diff --git a/lib/Service/IgnoreService.php b/lib/Service/IgnoreService.php
new file mode 100644
index 00000000..0b6ac270
--- /dev/null
+++ b/lib/Service/IgnoreService.php
@@ -0,0 +1,58 @@
+<?php
+
+namespace OCA\Recognize\Service;
+
+use OC\Files\Cache\CacheQueryBuilder;
+use OC\SystemConfig;
+use OCA\Recognize\Constants;
+use OCP\DB\QueryBuilder\IQueryBuilder;
+use OCP\Files\IMimeTypeLoader;
+use OCP\IDBConnection;
+use Psr\Log\LoggerInterface;
+
+class IgnoreService {
+	private IDBConnection $db;
+	private SystemConfig $systemConfig;
+	private LoggerInterface $logger;
+	private IMimeTypeLoader $mimeTypes;
+
+	public function __construct(IDBConnection $db, SystemConfig $systemConfig, LoggerInterface $logger, IMimeTypeLoader $mimeTypes) {
+		$this->db = $db;
+		$this->systemConfig = $systemConfig;
+		$this->logger = $logger;
+		$this->mimeTypes = $mimeTypes;
+	}
+
+	public function getDir(int $fileid, array $directoryTypes, bool $recursive = false): array {
+		/** @var \OCP\DB\QueryBuilder\IQueryBuilder $qb */
+		$qb = new CacheQueryBuilder($this->db, $this->systemConfig, $this->logger);
+		$dir = $qb->selectFileCache()
+			->andWhere($qb->expr()->in('mimetype', $qb->createNamedParameter($directoryTypes, IQueryBuilder::PARAM_INT_ARRAY)))
+			->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($fileid)))
+			->executeQuery()->fetchAll();
+
+		if ($recursive) {
+			foreach ($dir as $item) {
+				$dir = array_merge($dir, $this->getDir($item['fileid'], $directoryTypes, $recursive));
+			}
+		}
+		return $dir;
+	}
+
+	public function getIgnoredDirectories(int $storageId, array $ignoreMarkers): array {
+		$directoryTypes = array_map(fn ($mimeType) => $this->mimeTypes->getId($mimeType), Constants::DIRECTORY_FORMATS);
+		/** @var \OCP\DB\QueryBuilder\IQueryBuilder $qb */
+		$qb = new CacheQueryBuilder($this->db, $this->systemConfig, $this->logger);
+		$ignoreFiles = $qb->selectFileCache()
+			->andWhere($qb->expr()->in('name', $qb->createNamedParameter($ignoreMarkers, IQueryBuilder::PARAM_STR_ARRAY)))
+			->andWhere($qb->expr()->eq('storage', $qb->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
+			->executeQuery()->fetchAll();
+		$ignoreFileids = array_map(fn ($dir) => $dir['parent'], $ignoreFiles);
+		foreach ($ignoreFiles as $ignoreFile) {
+			$ignoreDir = $this->getDir($ignoreFile['parent'], $directoryTypes, true);
+			$fileids = array_map(fn ($dir) => $dir['fileid'], $ignoreDir);
+			$ignoreFileids = array_merge($ignoreFileids, $fileids);
+		}
+		return $ignoreFileids;
+	}
+}

From deb25d8bf164339f5f347da685be37750c253a31 Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Tue, 15 Nov 2022 14:00:48 +0100
Subject: [PATCH 4/8] Use IgnoreService in FileListener

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 lib/Hooks/FileListener.php | 34 +++++++++++++++++++++++++++++++++-
 1 file changed, 33 insertions(+), 1 deletion(-)

diff --git a/lib/Hooks/FileListener.php b/lib/Hooks/FileListener.php
index 39569660..510a7f02 100644
--- a/lib/Hooks/FileListener.php
+++ b/lib/Hooks/FileListener.php
@@ -9,6 +9,7 @@
 use OCA\Recognize\Constants;
 use OCA\Recognize\Db\FaceDetectionMapper;
 use OCA\Recognize\Db\QueueFile;
+use OCA\Recognize\Service\IgnoreService;
 use OCA\Recognize\Service\QueueService;
 use OCP\DB\Exception;
 use OCP\EventDispatcher\Event;
@@ -25,11 +26,13 @@ class FileListener implements IEventListener {
 	private FaceDetectionMapper $faceDetectionMapper;
 	private LoggerInterface $logger;
 	private QueueService $queue;
+	private IgnoreService $ignoreService;
 
-	public function __construct(FaceDetectionMapper $faceDetectionMapper, LoggerInterface $logger, QueueService $queue) {
+	public function __construct(FaceDetectionMapper $faceDetectionMapper, LoggerInterface $logger, QueueService $queue, IgnoreService $ignoreService) {
 		$this->faceDetectionMapper = $faceDetectionMapper;
 		$this->logger = $logger;
 		$this->queue = $queue;
+		$this->ignoreService = $ignoreService;
 	}
 
 	public function handle(Event $event): void {
@@ -80,11 +83,40 @@ public function postDelete(Node $node): void {
 		}
 	}
 
+	/**
+	 * @throws \OCP\Files\InvalidPathException
+	 */
 	public function postInsert(Node $node): void {
 		$queueFile = new QueueFile();
 		$queueFile->setStorageId($node->getMountPoint()->getStorageId());
 		$queueFile->setRootId((string) $node->getMountPoint()->getStorageRootId());
 
+		$ignoreMarkers = [];
+		if (in_array($node->getMimetype(), Constants::IMAGE_FORMATS)) {
+			$ignoreMarkers = array_merge($ignoreMarkers, Constants::IGNORE_MARKERS_IMAGE);
+		}
+		if (in_array($node->getMimetype(), Constants::VIDEO_FORMATS)) {
+			$ignoreMarkers = array_merge($ignoreMarkers, Constants::IGNORE_MARKERS_VIDEO);
+		}
+		if (in_array($node->getMimetype(), Constants::AUDIO_FORMATS)) {
+			$ignoreMarkers = array_merge($ignoreMarkers, Constants::IGNORE_MARKERS_AUDIO);
+		}
+		if (count($ignoreMarkers) === 0) {
+			return;
+		}
+		$ignoreMarkers = array_merge($ignoreMarkers, Constants::IGNORE_MARKERS_ALL);
+		$ignoredDirectories = $this->ignoreService->getIgnoredDirectories($node->getMountPoint()->getNumericStorageId(), $ignoreMarkers);
+
+		try {
+			if (in_array($node->getParent()->getId(), $ignoredDirectories)) {
+				return;
+			}
+		} catch (InvalidPathException $e) {
+			return;
+		} catch (NotFoundException $e) {
+			return;
+		}
+
 		try {
 			$queueFile->setFileId($node->getId());
 		} catch (InvalidPathException|NotFoundException $e) {

From bfdc432189ef1601043ded178fadcdb154485263 Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Tue, 15 Nov 2022 14:01:21 +0100
Subject: [PATCH 5/8] Test FileListener

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 test/ClassifierTest.php | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/test/ClassifierTest.php b/test/ClassifierTest.php
index a2d2842e..fbe4bba9 100644
--- a/test/ClassifierTest.php
+++ b/test/ClassifierTest.php
@@ -108,6 +108,35 @@ public function testSchedulerJob() : void {
 		]);
 	}
 
+	/**
+	 * @dataProvider ignoreImageFilesProvider
+	 * @return void
+	 * @throws \OCP\DB\Exception
+	 * @throws \OCP\Files\InvalidPathException
+	 * @throws \OCP\Files\NotFoundException
+	 * @throws \OCP\Files\NotPermittedException
+	 */
+	public function testFileListener(string $ignoreFileName) : void {
+		$this->config->setAppValue('recognize', 'imagenet.enabled', 'true');
+
+		$this->testFile = $this->userFolder->newFile('/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
+		$this->userFolder->newFolder('/test/ignore/');
+		$this->ignoredFile = $this->userFolder->newFile('/test/ignore/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
+		$this->userFolder->newFile('/test/' . $ignoreFileName, '');
+
+		$storageId = $this->testFile->getMountPoint()->getNumericStorageId();
+		$rootId = $this->testFile->getMountPoint()->getStorageRootId();
+
+		self::assertCount(1, $this->queue->getFromQueue(ImagenetClassifier::MODEL_NAME, $storageId, $rootId, 100), 'one element should have been added to imagenet queue');
+
+		$this->testFile->delete();
+
+		self::assertCount(0, $this->queue->getFromQueue(ImagenetClassifier::MODEL_NAME, $storageId, $rootId, 100), 'entry should have been removed from imagenet queue');
+
+		// disable again
+		$this->config->setAppValue('recognize', 'imagenet.enabled', 'false');
+	}
+
 	/**
 	 * @dataProvider ignoreImageFilesProvider
 	 * @return void

From 867dd08511270d105880b737d26a35e35ad7fec8 Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Tue, 15 Nov 2022 14:34:05 +0100
Subject: [PATCH 6/8] Fix psalm errors

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 lib/Service/IgnoreService.php | 41 +++++++++++++++++++++++++----------
 test/stub.phpstub             | 24 ++++++++++++++++++++
 2 files changed, 53 insertions(+), 12 deletions(-)

diff --git a/lib/Service/IgnoreService.php b/lib/Service/IgnoreService.php
index 0b6ac270..1616ea24 100644
--- a/lib/Service/IgnoreService.php
+++ b/lib/Service/IgnoreService.php
@@ -23,36 +23,53 @@ public function __construct(IDBConnection $db, SystemConfig $systemConfig, Logge
 		$this->mimeTypes = $mimeTypes;
 	}
 
+	/**
+	 * @param int $fileid
+	 * @param array $directoryTypes
+	 * @param bool $recursive
+	 * @return list<array>
+	 */
 	public function getDir(int $fileid, array $directoryTypes, bool $recursive = false): array {
-		/** @var \OCP\DB\QueryBuilder\IQueryBuilder $qb */
 		$qb = new CacheQueryBuilder($this->db, $this->systemConfig, $this->logger);
-		$dir = $qb->selectFileCache()
+		$result = $qb->selectFileCache()
 			->andWhere($qb->expr()->in('mimetype', $qb->createNamedParameter($directoryTypes, IQueryBuilder::PARAM_INT_ARRAY)))
 			->andWhere($qb->expr()->eq('parent', $qb->createNamedParameter($fileid)))
-			->executeQuery()->fetchAll();
+			->executeQuery();
+		/**
+		 * @var list<array> $dir
+		 */
+		$dir = $result->fetchAll();
 
 		if ($recursive) {
 			foreach ($dir as $item) {
-				$dir = array_merge($dir, $this->getDir($item['fileid'], $directoryTypes, $recursive));
+				$dir = array_merge($dir, $this->getDir((int) $item['fileid'], $directoryTypes, $recursive));
 			}
 		}
 		return $dir;
 	}
 
+	/**
+	 * @param int $storageId
+	 * @param array $ignoreMarkers
+	 * @return array
+	 */
 	public function getIgnoredDirectories(int $storageId, array $ignoreMarkers): array {
 		$directoryTypes = array_map(fn ($mimeType) => $this->mimeTypes->getId($mimeType), Constants::DIRECTORY_FORMATS);
-		/** @var \OCP\DB\QueryBuilder\IQueryBuilder $qb */
 		$qb = new CacheQueryBuilder($this->db, $this->systemConfig, $this->logger);
-		$ignoreFiles = $qb->selectFileCache()
+		$result = $qb->selectFileCache()
 			->andWhere($qb->expr()->in('name', $qb->createNamedParameter($ignoreMarkers, IQueryBuilder::PARAM_STR_ARRAY)))
 			->andWhere($qb->expr()->eq('storage', $qb->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
-			->executeQuery()->fetchAll();
-		$ignoreFileids = array_map(fn ($dir) => $dir['parent'], $ignoreFiles);
+			->executeQuery();
+		/**
+		 * @var list<array> $ignoreFiles
+		 */
+		$ignoreFiles = $result->fetchAll();
+		$ignoreFileIds = array_map(fn ($dir): int => (int)$dir['parent'], $ignoreFiles);
 		foreach ($ignoreFiles as $ignoreFile) {
-			$ignoreDir = $this->getDir($ignoreFile['parent'], $directoryTypes, true);
-			$fileids = array_map(fn ($dir) => $dir['fileid'], $ignoreDir);
-			$ignoreFileids = array_merge($ignoreFileids, $fileids);
+			$ignoreDir = $this->getDir((int) $ignoreFile['parent'], $directoryTypes, true);
+			$fileIds = array_map(fn ($dir): int => (int) $dir['fileid'], $ignoreDir);
+			$ignoreFileIds = array_merge($ignoreFileIds, $fileIds);
 		}
-		return $ignoreFileids;
+		return $ignoreFileIds;
 	}
 }
diff --git a/test/stub.phpstub b/test/stub.phpstub
index 940b60ed..c898d516 100644
--- a/test/stub.phpstub
+++ b/test/stub.phpstub
@@ -8,3 +8,27 @@ namespace OC\Hooks {
 		public function listen(string $class, string $value, $closure) {}
 	}
 }
+
+namespace OC {
+    class SystemConfig {
+    	public function getKeys();
+    	public function setValue($key, $value);
+    	public function setValues(array $configs);
+    	public function getValue($key, $default = '');
+    	public function getFilteredValue($key, $default = '');
+    	public function deleteValue($key);
+    }
+}
+
+
+namespace OC\Files\Cache {
+    class CacheQueryBuilder extends \OCP\DB\QueryBuilder\IQueryBuilder {
+        public function __construct(\OCP\IDBCOnnection $db, \OC\SystemConfig $config, \Psr\Log\LoggerInterface $logger);
+        public function selectFileCache(string $alias = null, bool $joinExtendedCache = true):CacheQueryBuilder;
+        public function whereStorageId(int $storageId):CacheQueryBuilder;
+        public function whereFileId(int $fileId):CacheQueryBuilder;
+        public function wherePath(string $path):CacheQueryBuilder;
+        public function whereParent(int $parent):CacheQueryBuilder;
+        public function whereParentInParameter(string $parameter):CacheQueryBuilder;
+    }
+}

From 9fc54f80430eb007b140e1ea012222f20b87f43f Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Wed, 23 Nov 2022 12:58:00 +0100
Subject: [PATCH 7/8] Fix FileListener

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 lib/Hooks/FileListener.php | 2 +-
 test/ClassifierTest.php    | 2 +-
 test/bootstrap.php         | 2 --
 3 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/lib/Hooks/FileListener.php b/lib/Hooks/FileListener.php
index 510a7f02..0ad86ab6 100644
--- a/lib/Hooks/FileListener.php
+++ b/lib/Hooks/FileListener.php
@@ -88,7 +88,7 @@ public function postDelete(Node $node): void {
 	 */
 	public function postInsert(Node $node): void {
 		$queueFile = new QueueFile();
-		$queueFile->setStorageId($node->getMountPoint()->getStorageId());
+		$queueFile->setStorageId((string) $node->getMountPoint()->getNumericStorageId());
 		$queueFile->setRootId((string) $node->getMountPoint()->getStorageRootId());
 
 		$ignoreMarkers = [];
diff --git a/test/ClassifierTest.php b/test/ClassifierTest.php
index fbe4bba9..74ce3f20 100644
--- a/test/ClassifierTest.php
+++ b/test/ClassifierTest.php
@@ -121,8 +121,8 @@ public function testFileListener(string $ignoreFileName) : void {
 
 		$this->testFile = $this->userFolder->newFile('/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
 		$this->userFolder->newFolder('/test/ignore/');
-		$this->ignoredFile = $this->userFolder->newFile('/test/ignore/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
 		$this->userFolder->newFile('/test/' . $ignoreFileName, '');
+		$this->ignoredFile = $this->userFolder->newFile('/test/ignore/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
 
 		$storageId = $this->testFile->getMountPoint()->getNumericStorageId();
 		$rootId = $this->testFile->getMountPoint()->getStorageRootId();
diff --git a/test/bootstrap.php b/test/bootstrap.php
index 856ce7ef..8e42f3e2 100644
--- a/test/bootstrap.php
+++ b/test/bootstrap.php
@@ -9,5 +9,3 @@
 
 // load all enabled apps
 \OC_App::loadApps();
-
-OC_Hook::clear();

From 199bfb4c6acbf012d4b6ef8a78ef9fc4cd2361af Mon Sep 17 00:00:00 2001
From: Marcel Klehr <mklehr@gmx.net>
Date: Wed, 23 Nov 2022 13:45:22 +0100
Subject: [PATCH 8/8] Fix Classifier tests

Signed-off-by: Marcel Klehr <mklehr@gmx.net>
---
 test/ClassifierTest.php | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/test/ClassifierTest.php b/test/ClassifierTest.php
index 74ce3f20..633ee7d2 100644
--- a/test/ClassifierTest.php
+++ b/test/ClassifierTest.php
@@ -76,6 +76,10 @@ public function setUp(): void {
 		$this->queue->clearQueue(LandmarksClassifier::MODEL_NAME);
 		$this->queue->clearQueue(MovinetClassifier::MODEL_NAME);
 		$this->queue->clearQueue(MusicnnClassifier::MODEL_NAME);
+		$this->config->setAppValue('recognize', 'imagenet.enabled', 'false');
+		$this->config->setAppValue('recognize', 'faces.enabled', 'false');
+		$this->config->setAppValue('recognize', 'movinet.enabled', 'false');
+		$this->config->setAppValue('recognize', 'musicnn.enabled', 'false');
 	}
 
 	public function testSchedulerJob() : void {
@@ -118,6 +122,7 @@ public function testSchedulerJob() : void {
 	 */
 	public function testFileListener(string $ignoreFileName) : void {
 		$this->config->setAppValue('recognize', 'imagenet.enabled', 'true');
+		$this->queue->clearQueue(ImagenetClassifier::MODEL_NAME);
 
 		$this->testFile = $this->userFolder->newFile('/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
 		$this->userFolder->newFolder('/test/ignore/');
@@ -132,9 +137,6 @@ public function testFileListener(string $ignoreFileName) : void {
 		$this->testFile->delete();
 
 		self::assertCount(0, $this->queue->getFromQueue(ImagenetClassifier::MODEL_NAME, $storageId, $rootId, 100), 'entry should have been removed from imagenet queue');
-
-		// disable again
-		$this->config->setAppValue('recognize', 'imagenet.enabled', 'false');
 	}
 
 	/**
@@ -152,7 +154,9 @@ public function testImagenetPipeline(string $ignoreFileName) : void {
 		$this->userFolder->newFolder('/test/ignore/');
 		$this->ignoredFile = $this->userFolder->newFile('/test/ignore/alpine.jpg', file_get_contents(__DIR__.'/res/alpine.JPG'));
 		$this->userFolder->newFile('/test/' . $ignoreFileName, '');
+
 		$this->config->setAppValue('recognize', 'imagenet.enabled', 'true');
+
 		/** @var StorageCrawlJob $scheduler */
 		$crawler = \OC::$server->get(StorageCrawlJob::class);
 		/** @var IJobList $this->jobList */