Merge pull request #155 from nextcloud/feat/fs-event-stats

fix: Add Fs events to stats

Author: marcelklehr

lib/Command/Statistics.php

@@ -9,6 +9,7 @@
 
 namespace OCA\ContextChat\Command;
 
+use OCA\ContextChat\Db\FsEventMapper;
 use OCA\ContextChat\Db\QueueContentItemMapper;
 use OCA\ContextChat\Service\ActionScheduler;
 use OCA\ContextChat\Service\LangRopeService;
@@ -29,6 +30,7 @@ public function __construct(
 		private StorageService $storageService,
 		private LangRopeService $langRopeService,
 		private QueueContentItemMapper $contentQueue,
+		private FsEventMapper $fsEventMapper,
 	) {
 		parent::__construct();
 	}
@@ -69,6 +71,9 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 
 		$actionsCount = $this->actionService->count();
 		$output->writeln('Actions in queue: ' . $actionsCount);
+
+		$fsEventsCount = $this->fsEventMapper->count();
+		$output->writeln('File system events in queue: ' . $fsEventsCount);
 		return 0;
 	}
 }

lib/Settings/AdminSettings.php

@@ -6,6 +6,7 @@
  */
 namespace OCA\ContextChat\Settings;
 
+use OCA\ContextChat\Db\FsEventMapper;
 use OCA\ContextChat\Db\QueueContentItemMapper;
 use OCA\ContextChat\Logger;
 use OCA\ContextChat\Service\ActionScheduler;
@@ -30,6 +31,7 @@ public function __construct(
 		private LangRopeService $langRopeService,
 		private QueueContentItemMapper $contentQueue,
 		private Logger $logger,
+		private FsEventMapper $fsEventMapper,
 	) {
 	}
 
@@ -60,6 +62,12 @@ public function getForm(): TemplateResponse {
 			$this->logger->error($e->getMessage(), ['exception' => $e]);
 			$stats['queued_actions_count'] = 0;
 		}
+		try {
+			$stats['queued_fs_events_count'] = $this->fsEventMapper->count();
+		} catch (Exception $e) {
+			$this->logger->error($e->getMessage(), ['exception' => $e]);
+			$stats['queued_fs_events_count'] = 0;
+		}
 		try {
 			$stats['vectordb_document_counts'] = $this->langRopeService->getIndexedDocumentsCounts();
 			$stats['backend_available'] = true;

src/components/ViewAdmin.vue

@@ -46,6 +46,7 @@ SPDX-License-Identifier: AGPL-3.0-or-later
 			<p>&nbsp;</p>
 			<p>{{ t('context_chat', 'Eligible files for indexing: {count}', {count: stats.eligible_files_count}) }}</p>
 			<p>{{ t('context_chat', 'Queued content update actions: {count}', {count: stats.queued_actions_count}) }}</p>
+			<p>{{ t('context_chat', 'Queued File System events: {count}', {count: stats.queued_fs_events_count}) }}</p>
 		</NcSettingsSection>
 		<NcSettingsSection :name="t('context_chat', 'Context Chat Logs')">
 			<div class="horizontal-flex">