feat(wfe): add runtime operations

Signed-off-by: Salvatore Martire <4652631+salmart-dev@users.noreply.github.com>

Author: salmart-dev

apps/workflowengine/appinfo/info.xml

@@ -41,6 +41,7 @@
 
 	<commands>
 		<command>OCA\WorkflowEngine\Command\Index</command>
+		<command>OCA\WorkflowEngine\Command\Runtime</command>
 	</commands>
 
 	<settings>

apps/workflowengine/composer/composer/autoload_classmap.php

@@ -21,6 +21,7 @@
     'OCA\\WorkflowEngine\\Check\\TFileCheck' => $baseDir . '/../lib/Check/TFileCheck.php',
     'OCA\\WorkflowEngine\\Check\\UserGroupMembership' => $baseDir . '/../lib/Check/UserGroupMembership.php',
     'OCA\\WorkflowEngine\\Command\\Index' => $baseDir . '/../lib/Command/Index.php',
+    'OCA\\WorkflowEngine\\Command\\Runtime' => $baseDir . '/../lib/Command/Runtime.php',
     'OCA\\WorkflowEngine\\Controller\\AWorkflowOCSController' => $baseDir . '/../lib/Controller/AWorkflowOCSController.php',
     'OCA\\WorkflowEngine\\Controller\\GlobalWorkflowsController' => $baseDir . '/../lib/Controller/GlobalWorkflowsController.php',
     'OCA\\WorkflowEngine\\Controller\\RequestTimeController' => $baseDir . '/../lib/Controller/RequestTimeController.php',

apps/workflowengine/composer/composer/autoload_static.php

@@ -36,6 +36,7 @@ class ComposerStaticInitWorkflowEngine
         'OCA\\WorkflowEngine\\Check\\TFileCheck' => __DIR__ . '/..' . '/../lib/Check/TFileCheck.php',
         'OCA\\WorkflowEngine\\Check\\UserGroupMembership' => __DIR__ . '/..' . '/../lib/Check/UserGroupMembership.php',
         'OCA\\WorkflowEngine\\Command\\Index' => __DIR__ . '/..' . '/../lib/Command/Index.php',
+        'OCA\\WorkflowEngine\\Command\\Runtime' => __DIR__ . '/..' . '/../lib/Command/Runtime.php',
         'OCA\\WorkflowEngine\\Controller\\AWorkflowOCSController' => __DIR__ . '/..' . '/../lib/Controller/AWorkflowOCSController.php',
         'OCA\\WorkflowEngine\\Controller\\GlobalWorkflowsController' => __DIR__ . '/..' . '/../lib/Controller/GlobalWorkflowsController.php',
         'OCA\\WorkflowEngine\\Controller\\RequestTimeController' => __DIR__ . '/..' . '/../lib/Controller/RequestTimeController.php',

apps/workflowengine/lib/AppInfo/Application.php

@@ -40,15 +40,25 @@ public function register(IRegistrationContext $context): void {
 	}
 
 	public function boot(IBootContext $context): void {
+		$context->injectFn(Closure::fromCallable([$this, 'emitRuntimeEvent']));
 		$context->injectFn(Closure::fromCallable([$this, 'registerRuleListeners']));
 	}
 
+	private function emitRuntimeEvent(IEventDispatcher $dispatcher, ContainerInterface $container): void {
+		/** @var Manager $manager */
+		$manager = $container->get(Manager::class);
+		$manager->reloadRuntimeOperations();
+	}
+
 	private function registerRuleListeners(IEventDispatcher $dispatcher,
 		ContainerInterface $container,
 		LoggerInterface $logger): void {
 		/** @var Manager $manager */
 		$manager = $container->get(Manager::class);
-		$configuredEvents = $manager->getAllConfiguredEvents();
+		$configuredEvents = array_merge_recursive(
+			$manager->getAllConfiguredEvents(),
+			$manager->getAllConfiguredRuntimeEvents(),
+		);
 
 		foreach ($configuredEvents as $operationClass => $events) {
 			foreach ($events as $entityClass => $eventNames) {

apps/workflowengine/lib/Command/Runtime.php

@@ -0,0 +1,100 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * SPDX-FileCopyrightText: 2026 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+namespace OCA\WorkflowEngine\Command;
+
+use OC\User\NoUserException;
+use OCA\WorkflowEngine\Helper\ScopeContext;
+use OCA\WorkflowEngine\Manager;
+use OCP\IUserManager;
+use OCP\IUserSession;
+use OCP\WorkflowEngine\IManager;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class Runtime extends Command {
+
+	public function __construct(
+		private Manager $manager,
+		private IUserManager $userManager,
+		private IUserSession $userSession,
+	) {
+		parent::__construct();
+	}
+
+	protected function configure() {
+		$this
+			->setName('workflows:runtime:list')
+			->setDescription('Lists configured runtime workflows')
+			// need to add an optional filtering by app
+			->addArgument(
+				'appId',
+				InputArgument::OPTIONAL,
+				'Filter runtime workflows by appId',
+				null
+			)
+			->addArgument(
+				'scope',
+				InputArgument::OPTIONAL,
+				'Lists workflows for "admin", "user"',
+				'admin'
+			)
+			->addArgument(
+				'userId',
+				InputArgument::OPTIONAL,
+				'User ID used for user scope and session',
+				null
+			);
+	}
+
+	protected function mappedScope(string $scope): int {
+		return match($scope) {
+			'admin' => IManager::SCOPE_ADMIN,
+			'user' => IManager::SCOPE_USER,
+			default => -1,
+		};
+	}
+
+	protected function execute(InputInterface $input, OutputInterface $output): int {
+		$appId = $input->getArgument('appId');
+		$userId = $input->getArgument('userId');
+
+		if ($userId !== null) {
+			$user = $this->userManager->get($userId);
+			if (is_null($user)) {
+				throw new NoUserException("user $userId not found");
+			}
+			$this->userSession->setUser($user);
+			$this->manager->reloadRuntimeOperations();
+		}
+
+		$opsByClass = $this->manager->getAllRuntimeOperations(
+			new ScopeContext(
+				$this->mappedScope($input->getArgument('scope')),
+				$input->getArgument('userId')
+			),
+			$appId,
+		);
+
+		foreach ($opsByClass as &$operations) {
+			foreach ($operations as &$operation) {
+				$checks = $operation['checks'];
+				$appId = $operation['appId'];
+				$decodedChecks = json_decode($checks, true);
+				$operation['checks'] = $this->manager->getRuntimeChecks($decodedChecks, $appId);
+			}
+			unset($operation);
+		}
+		unset($operations);
+
+		$output->writeln(\json_encode($opsByClass, JSON_PRETTY_PRINT));
+		return 0;
+	}
+}