feat: add FroshTools integration

Author: schneider-felix

src/FroshFlowBuilder.php

@@ -2,13 +2,24 @@
 
 namespace Frosh\FlowBuilder;
 
+use Frosh\FlowBuilder\FroshTools\Checker\FlowExecutionErrorChecker;
+use Frosh\Tools\Components\Health\Checker\CheckerInterface;
 use Shopware\Core\Framework\Plugin;
-use Shopware\Core\Framework\Plugin\Context\ActivateContext;
-use Shopware\Core\Framework\Plugin\Context\DeactivateContext;
-use Shopware\Core\Framework\Plugin\Context\InstallContext;
-use Shopware\Core\Framework\Plugin\Context\UninstallContext;
-use Shopware\Core\Framework\Plugin\Context\UpdateContext;
+use Symfony\Component\DependencyInjection\ContainerBuilder;
+use Symfony\Component\DependencyInjection\Definition;
 
 class FroshFlowBuilder extends Plugin
 {
+    public function build(ContainerBuilder $container): void
+    {
+        parent::build($container);
+
+        if (interface_exists(CheckerInterface::class)) {
+            $definition = new Definition(FlowExecutionErrorChecker::class);
+            $definition->setAutowired(true);
+            $definition->setAutoconfigured(true);
+
+            $container->setDefinition(FlowExecutionErrorChecker::class, $definition);
+        }
+    }
 }

src/FroshTools/Checker/FlowExecutionErrorChecker.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Frosh\FlowBuilder\FroshTools\Checker;
+
+use Doctrine\DBAL\Connection;
+use Frosh\FlowBuilder\Subscriber\FlowSubscriber;
+use Frosh\Tools\Components\Health\Checker\CheckerInterface;
+use Frosh\Tools\Components\Health\Checker\HealthChecker\HealthCheckerInterface;
+use Frosh\Tools\Components\Health\HealthCollection;
+use Frosh\Tools\Components\Health\SettingsResult;
+
+class FlowExecutionErrorChecker implements CheckerInterface, HealthCheckerInterface
+{
+
+    public function __construct(
+        private readonly Connection $connection,
+    )
+    {
+    }
+
+    public function collect(HealthCollection $collection): void
+    {
+        $numberOfFailedFlows = $this->connection->fetchOne('SELECT COUNT(*) FROM frosh_flow_state WHERE state = :errorState LIMIT 1;', [
+            'errorState' => FlowSubscriber::FLOW_STATE_ERROR
+        ]);
+
+        if ($numberOfFailedFlows > 0) {
+            $collection->add(
+                SettingsResult::warning(
+                    'flow-execution-failed',
+                    'Some flow executions have failed',
+                    $numberOfFailedFlows,
+                    0
+                )
+            );
+        }
+    }
+}

src/Resources/app/administration/src/snippet/de-DE.json

@@ -1,17 +1,17 @@
 {
-    "frosh-flow-builder": {
-        "history": {
-            "tabTitle": "Verlauf",
-            "cardTitle": "Verlauf",
-            "columns": {
-                "executedAt": "Ausgeführt am",
-                "status": "Status",
-                "triggeredBy": "Ausgelöst von"
-            },
-            "state": {
-                "success": "Erfolgreich",
-                "error": "Fehlgeschlagen"
-            }
-        }
+  "frosh-flow-builder": {
+    "history": {
+      "tabTitle": "Verlauf",
+      "cardTitle": "Verlauf",
+      "columns": {
+        "executedAt": "Ausgeführt am",
+        "status": "Status",
+        "triggeredBy": "Ausgelöst von"
+      },
+      "state": {
+        "success": "Erfolgreich",
+        "error": "Fehlgeschlagen"
+      }
     }
+  }
 }

src/Resources/config/services.xml

@@ -9,6 +9,7 @@
         <prototype
                 namespace="Frosh\FlowBuilder\"
                 resource="../../"
+                exclude="../../FroshTools/"
         />
     </services>
 </container>