diff --git a/server/webhook-ingest/app/config.py b/server/webhook-ingest/app/config.py index 1eaff726..4541ef4c 100644 --- a/server/webhook-ingest/app/config.py +++ b/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): diff --git a/server/webhook-ingest/app/logger.py b/server/webhook-ingest/app/logger.py new file mode 100644 index 00000000..2952fcc7 --- /dev/null +++ b/server/webhook-ingest/app/logger.py @@ -0,0 +1,5 @@ +import logging +import sys + +logger = logging.getLogger('uvicorn.error') +logger.setLevel(logging.DEBUG) \ No newline at end of file diff --git a/server/webhook-ingest/app/nats_client.py b/server/webhook-ingest/app/nats_client.py index 87b14cc9..406c81a9 100644 --- a/server/webhook-ingest/app/nats_client.py +++ b/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}")