feat(services): integrate structlog, healthcheck, metrics, and Telegram

Replace logging.basicConfig/getLogger with structlog setup_logging in all
four service entry points. Add HealthCheckServer, ServiceMetrics, and
TelegramNotifier initialization to each service. Update OrderExecutor to
accept a notifier parameter and send order notifications. Add
RedisBroker.ping() for health checks. Update executor tests with
notifier=AsyncMock().

1 files changed, 4 insertions, 0 deletions

diff --git a/shared/src/shared/broker.py b/shared/src/shared/broker.py
index 9a50441..0f87b06 100644
--- a/shared/src/shared/broker.py
+++ b/shared/src/shared/broker.py
@@ -38,6 +38,10 @@ class RedisBroker:
                         messages.append(json.loads(payload))
         return messages
 
+    async def ping(self) -> bool:
+        """Ping the Redis server; return True if reachable."""
+        return await self._redis.ping()
+
     async def close(self) -> None:
         """Close the Redis connection."""
         await self._redis.aclose()