Squashed commit message

backend/src/app/Handlers/TelemetryHandler.php

@@ -0,0 +1,48 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Handlers;
+
+use Acme\ECommerceFramework\Http\Request;
+use Acme\ECommerceFramework\AcmeShopPulse\PulseIngestException;
+use Acme\ECommerceFramework\AcmeShopPulse\AcmeShopPulseService;
+use Psr\Log\LoggerInterface;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Response;
+use Throwable;
+
+class TelemetryHandler
+{
+    private AcmeShopPulseService $megaPayPulseService;
+    private LoggerInterface $logger;
+
+    public function __construct(
+        AcmeShopPulseService $megaPayPulseService,
+        LoggerInterface $logger
+    ) {
+        $this->megaPayPulseService = $megaPayPulseService;
+        $this->logger = $logger;
+    }
+
+    /**
+     * @throws PulseIngestException
+     */
+    public function ingest(Request $request): JsonResponse
+    {
+        $this->megaPayPulseService->handleIngest($request->json());
+
+        return new JsonResponse([], Response::HTTP_NO_CONTENT);
+    }
+
+    public function heartbeat(): JsonResponse
+    {
+        try {
+            $this->megaPayPulseService->handleHeartbeat();
+        } catch (Throwable $e) {
+            $this->logger->warning('AcmeShop Pulse Heartbeat failed: ' . $e->getMessage(), ['exception' => $e]);
+        }
+
+        return new JsonResponse(['status' => 'ok']);
+    }
+}