.

app.py

@@ -2,11 +2,11 @@ import asyncio
 import gradio as gr
 from fastapi import FastAPI
 
-from app.config import settings
-from app.listener import RabbitListenerBase
-from app.rabbit_repo import RabbitRepo
-from app.service import LLMService
-from app.runners.base import ILLMRunner
+from config import settings
+from listener import RabbitListenerBase
+from rabbit_repo import RabbitRepo
+from service import LLMService
+from runners.base import ILLMRunner
 
 # --- Runner factory (stub) ---
 class EchoRunner(ILLMRunner):
@@ -72,17 +72,17 @@ with gr.Blocks() as demo:
 app = FastAPI()
 app = gr.mount_gradio_app(app, demo, path="/")
 
-@app.get("/health")
+@get("/health")
 async def health():
     return {"status":"ok"}
 
-@app.on_event("startup")
+@on_event("startup")
 async def on_start():
     await publisher.connect()
     await service.init()
     await listener.start(DECLS)
 
-@app.on_event("shutdown")
+@on_event("shutdown")
 async def on_stop():
     # aio-pika RobustConnection closes on GC; optionally add explicit closes if you add references
     pass

config.py

@@ -1,22 +1,55 @@
-from pydantic import BaseSettings, AnyUrl
-from typing import Optional, Dict
+# app/config.py
+import os
+from functools import lru_cache
+
+# v2-first import, fallback to v1
+try:
+    from pydantic_settings import BaseSettings, SettingsConfigDict  # pydantic v2
+    from pydantic import AnyUrl, Field
+    IS_V2 = True
+except Exception:
+    from pydantic import BaseSettings, AnyUrl  # pydantic v1
+    from pydantic import Field
+    IS_V2 = False
 
 class Settings(BaseSettings):
-    # AMQP
-    AMQP_URL: AnyUrl  # e.g. amqps://user:pass@host:5671/%2F?heartbeat=30
+    # Read from env: set this in your Space Secrets as AMQP_URL
+    AMQP_URL: AnyUrl = Field(..., description="amqps://user:pass@host:5671/%2F?heartbeat=30")
+
     RABBIT_INSTANCE_NAME: str = "prod"
-    RABBIT_EXCHANGE_TYPE: str = "topic"  # match your .NET Type
-    RABBIT_ROUTING_KEY: str = ""         # match your .NET RoutingKeys ("" ok)
+    RABBIT_EXCHANGE_TYPE: str = "topic"
+    RABBIT_ROUTING_KEY: str = ""
     RABBIT_PREFETCH: int = 1
 
-    # Service identity
-    SERVICE_ID: str = "monitor"          # "monitor"|"nmap"|...
+    SERVICE_ID: str = "gradllm"
     USE_TLS: bool = True
 
-    # Optional exchange type overrides by prefix, like .NET ExchangeTypes
-    EXCHANGE_TYPES: Dict[str, str] = {}
+    # Optional: prefix->type map, e.g. {"llmStartSession": "topic"}
+    EXCHANGE_TYPES: dict[str, str] = {}
+
+    if IS_V2:
+        # pydantic v2
+        model_config = SettingsConfigDict(
+            case_sensitive=True,
+            env_file=".env",        # for local dev; ignored on HF unless you commit it
+            env_file_encoding="utf-8",
+        )
+    else:
+        # pydantic v1
+        class Config:
+            case_sensitive = True
+            env_file = ".env"
+            env_file_encoding = "utf-8"
 
-    class Config:
-        case_sensitive = True
+@lru_cache
+def get_settings() -> Settings:
+    try:
+        return Settings()
+    except Exception as e:
+        # Friendlier message when AMQP_URL is missing/invalid
+        raise RuntimeError(
+            "AMQP_URL is not set or invalid. In your Hugging Face Space, add a Secret "
+            "named AMQP_URL (e.g. amqps://user:pass@host:5671/%2F?heartbeat=30)."
+        ) from e
 
-settings = Settings()  # env-driven
+settings = get_settings()

requirements.txt

@@ -0,0 +1,6 @@
+gradio==5.42.0
+fastapi==0.116.1
+uvicorn==0.35.0
+aio-pika==9.5.7
+pydantic==2.11.1
+pydantic-settings==2.10.1