perf(workflowengine): Cache query that is performed on every request

Signed-off-by: Julius Härtl <jus@bitgrid.net>

apps/workflowengine/lib/Manager.php

@@ -49,6 +49,7 @@
 use OCP\DB\QueryBuilder\IQueryBuilder;
 use OCP\EventDispatcher\IEventDispatcher;
 use OCP\Files\Storage\IStorage;
+use OCP\ICacheFactory;
 use OCP\IConfig;
 use OCP\IDBConnection;
 use OCP\IL10N;
@@ -120,6 +121,7 @@ class Manager implements IManager {
 
 	/** @var IConfig */
 	private $config;
+	private ICacheFactory $cacheFactory;
 
 	public function __construct(
 		IDBConnection $connection,
@@ -129,7 +131,8 @@ public function __construct(
 		ILogger $logger,
 		IUserSession $session,
 		IEventDispatcher $dispatcher,
-		IConfig $config
+		IConfig $config,
+		ICacheFactory $cacheFactory,
 	) {
 		$this->connection = $connection;
 		$this->container = $container;
@@ -140,6 +143,7 @@ public function __construct(
 		$this->session = $session;
 		$this->dispatcher = $dispatcher;
 		$this->config = $config;
+		$this->cacheFactory = $cacheFactory;
 	}
 
 	public function getRuleMatcher(): IRuleMatcher {
@@ -153,6 +157,12 @@ public function getRuleMatcher(): IRuleMatcher {
 	}
 
 	public function getAllConfiguredEvents() {
+		$cache = $this->cacheFactory->createDistributed('flow');
+		$cached = $cache->get('events');
+		if ($cached !== null) {
+			return $cached;
+		}
+
 		$query = $this->connection->getQueryBuilder();
 
 		$query->select('class', 'entity')
@@ -176,6 +186,8 @@ public function getAllConfiguredEvents() {
 		}
 		$result->closeCursor();
 
+		$cache->set('events', $operations, 3600);
+
 		return $operations;
 	}
 
@@ -289,6 +301,8 @@ protected function insertOperation(
 			]);
 		$query->execute();
 
+		$this->cacheFactory->createDistributed('flow')->remove('events');
+
 		return $query->getLastInsertId();
 	}
 
@@ -407,6 +421,7 @@ public function updateOperation(
 			throw $e;
 		}
 		unset($this->operations[$scopeContext->getHash()]);
+		$this->cacheFactory->createDistributed('flow')->remove('events');
 
 		return $this->getOperation($id);
 	}
@@ -444,6 +459,8 @@ public function deleteOperation($id, ScopeContext $scopeContext) {
 			unset($this->operations[$scopeContext->getHash()]);
 		}
 
+		$this->cacheFactory->createDistributed('flow')->remove('events');
+
 		return $result;
 	}
 

apps/workflowengine/tests/ManagerTest.php

@@ -32,6 +32,7 @@
 use OCA\WorkflowEngine\Manager;
 use OCP\EventDispatcher\IEventDispatcher;
 use OCP\Files\IRootFolder;
+use OCP\ICacheFactory;
 use OCP\IConfig;
 use OCP\IDBConnection;
 use OCP\IL10N;
@@ -76,6 +77,8 @@ class ManagerTest extends TestCase {
 	protected $dispatcher;
 	/** @var MockObject|IConfig */
 	protected $config;
+	/** @var MockObject|ICacheFactory  */
+	protected $cacheFactory;
 
 	protected function setUp(): void {
 		parent::setUp();
@@ -94,6 +97,7 @@ protected function setUp(): void {
 		$this->session = $this->createMock(IUserSession::class);
 		$this->dispatcher = $this->createMock(IEventDispatcher::class);
 		$this->config = $this->createMock(IConfig::class);
+		$this->cacheFactory = $this->createMock(ICacheFactory::class);
 
 		$this->manager = new Manager(
 			\OC::$server->getDatabaseConnection(),
@@ -103,7 +107,8 @@ protected function setUp(): void {
 			$this->logger,
 			$this->session,
 			$this->dispatcher,
-			$this->config
+			$this->config,
+			$this->cacheFactory
 		);
 		$this->clearTables();
 	}