do stuff

server/webhook-ingest/app/config.py

@@ -4,6 +4,7 @@
 
 class Settings(BaseSettings):
     NATS_URL: str = "localhost"
+    NATS_AUTH_TOKEN: str = ""
     WEBHOOK_SECRET: str = ""
 
     class Config:

server/webhook-ingest/app/nats_client.py

@@ -9,6 +9,7 @@ def __init__(self):
     async def connect(self):
         await self.nc.connect(
             servers=settings.NATS_URL,
+            token=settings.NATS_AUTH_TOKEN,
             verbose=True,
             pedantic=True,
             max_reconnect_attempts=-1,

server/webhook-ingest/nats-server.conf

@@ -1,21 +1,15 @@
-# Port for internal connections (unencrypted and no auth)
-listen: "0.0.0.0:5222" 
+listen: "0.0.0.0:4222" 
 
 jetstream {
   store_dir: "/data"
 }
 
-cluster {
-  # Port for external connections (encrypted and auth)
-  listen: "0.0.0.0:4222"
-
-  tls {
-    cert_file: $TLS_CERT_FILE
-    key_file: $TLS_KEY_FILE
-    verify: false
-  }
+tls {
+  cert_file: $TLS_CERT_FILE
+  key_file: $TLS_KEY_FILE
+  verify: false
+}
 
-  authorization {
-    token: $NATS_AUTH_TOKEN
-  }
+authorization {
+  token: $NATS_AUTH_TOKEN
 }