feat(jobs): allow workers to keep track of executed jobs

Signed-off-by: Benjamin Gaussorgues <benjamin.gaussorgues@nextcloud.com>

Author: Altahrim

core/Command/Background/JobWorker.php

@@ -1,15 +1,18 @@
 <?php
 
 declare(strict_types=1);
+
 /**
  * SPDX-FileCopyrightText: 2021 Nextcloud GmbH and Nextcloud contributors
  * SPDX-License-Identifier: AGPL-3.0-or-later
  */
 
 namespace OC\Core\Command\Background;
 
+use OC\BackgroundJob\JobClassesRegistry;
 use OC\Core\Command\InterruptedException;
 use OCP\BackgroundJob\IJobList;
+use OCP\BackgroundJob\IJobRuns;
 use OCP\Files\ISetupManager;
 use OCP\ITempManager;
 use Psr\Log\LoggerInterface;
@@ -19,15 +22,17 @@
 use Symfony\Component\Console\Output\OutputInterface;
 
 class JobWorker extends JobBase {
-
 	public function __construct(
 		protected IJobList $jobList,
 		protected LoggerInterface $logger,
 		private ITempManager $tempManager,
 		private ISetupManager $setupManager,
+		private readonly IJobRuns $jobRuns,
+		private readonly JobClassesRegistry $jobClassesRegistry,
 	) {
 		parent::__construct($jobList, $logger);
 	}
+
 	#[\Override]
 	protected function configure(): void {
 		parent::configure();
@@ -124,13 +129,25 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 				continue;
 			}
 
+			$jobClassName = get_class($job);
 			$output->writeln('Running job ' . get_class($job) . ' with ID ' . $job->getId());
 
 			if ($output->isVerbose()) {
 				$this->printJobInfo($job->getId(), $job, $output);
 			}
 
+			memory_reset_peak_usage();
+			$jobClassId = $this->jobClassesRegistry->getId($jobClassName);
+			$jobRunId = $this->jobRuns->started($jobClassId);
+			$startTime = microtime(true);
 			$job->start($this->jobList);
+			$timeSpent = microtime(true) - $startTime;
+			$jobMemoryPeak = memory_get_peak_usage();
+			// TODO Job failure will never be catched here because exceptions are catched within $job->start method
+			// The error will only be visible in server logs.
+			// It should be a temporary state until a proper job runner is implemented.
+			$this->jobRuns->finished($jobRunId, (int)($timeSpent * 1000), (int)($jobMemoryPeak / 1024));
+
 			$output->writeln('Job ' . $job->getId() . ' has finished', OutputInterface::VERBOSITY_VERBOSE);
 
 			// clean up after unclean jobs