add logging

server/webhook-ingest/app/config.py

@@ -1,5 +1,5 @@
-from fastapi import logger
 from pydantic_settings import BaseSettings
+from app.logger import logger
 
 
 class Settings(BaseSettings):

server/webhook-ingest/app/logger.py

@@ -0,0 +1,5 @@
+import logging
+import sys
+
+logger = logging.getLogger('uvicorn.error')
+logger.setLevel(logging.DEBUG)

server/webhook-ingest/app/nats_client.py

@@ -1,6 +1,6 @@
-from fastapi import logger
 from nats.aio.client import Client as NATS
 from app.config import settings
+from app.logger import logger
 
 
 class NATSClient:
@@ -10,7 +10,15 @@ def __init__(self, nats_url: str, nats_auth_token: str):
         self.nats_auth_token = nats_auth_token
 
     async def connect(self):
-        await self.nc.connect(servers=self.nats_url, token=self.nats_auth_token)
+        await self.nc.connect(
+            servers=[self.nats_url], 
+            token=self.nats_auth_token, 
+            verbose=True, 
+            pedantic=True,
+            max_reconnect_attempts=-1,
+            allow_reconnect=True,
+            reconnect_time_wait=2,
+        )
         self.js = self.nc.jetstream()
         logger.info(f"Connected to NATS at {self.nats_url}")