_i;-UdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ejjddjZej eeeej$dd ej&d Z dd lmZdd lmZdZddlmZddlmZddlm Z!ddl"m#Z$da%de&d<ddZ'eddZ(ddZ)ere)Z*ndZ*dd dZ+e,dk(re+yy#e$r dZdZdZY\wxYw)!uiRLM Neo-Cortex -- FastAPI Integration Application. This is the top-level FastAPI application that wires together every RLM module into a single runnable server on port 8100. Routers mounted: /api/v1/memory/* — gateway_router (Module 1: write, search, delete, health) /api/v1/feedback/* — feedback_webhook (Module 5: webhook for preference signals) Middleware stack (innermost first): 1. CORS — allows widget origins and localhost dev 2. TenantMiddleware — extracts tenant UUID from JWT or API key Lifecycle: startup — initialises MemoryGateway (opens PG pool, Qdrant, Redis) shutdown — closes all backend connections gracefully Run with:: uvicorn core.rlm.app:app --host 0.0.0.0 --port 8100 Or via the helper shipped in this module:: from core.rlm.app import run run() Story: integration-layer-app ) annotationsN)asynccontextmanager)Any AsyncIteratorDict LOG_LEVELINFOz1%(asctime)s [%(levelname)s] %(name)s: %(message)sz%Y-%m-%dT%H:%M:%S)levelformatdatefmtz core.rlm.app)FastAPI)CORSMiddlewareTF)settings) MemoryGateway) create_router)create_feedback_routerzMemoryGateway | None_gatewaycPttjs tdtS)zReturn the initialised MemoryGateway singleton. Raises: RuntimeError: If called before the application lifespan has started. zhMemoryGateway is not initialised. Ensure the FastAPI lifespan has started before calling get_gateway().)ris_initialized RuntimeError%/mnt/e/genesis-system/core/rlm/app.py get_gatewayrNs, x66 T   OrcKtjd tjt tjtjtjtja tjd{tjddtjdt3 tjd{tjdyy#t$r}tj d|d}~wwxYw7#t$r}tj d|d}~wwxYw7m#t$rYvwxYww) u1Startup → yield → shutdown lifecycle manager.zRLM application starting up...zConfiguration invalid: %sN)pg_dsn qdrant_urlqdrant_api_key redis_urlz&MemoryGateway initialised successfullyz'MemoryGateway initialisation failed: %sz RLM application shutting down...zMemoryGateway closed)loggerinforvalidate ValueErrorcriticalr database_urlrrr r initialize Exceptionclose)appexcs r _lifespanr,`s  KK01$$&&..$$ H !!### <=   KK23 .." " "  *+ 1 3S9  $ A3G  #   sEC:AE5D$ D" D$& EEE E#E: DDDE"D$$ E -EE  E E EEEEc ts tdtjrdnd}tjrdnd}t tjrdndtjrdndd ||tjrd ndt }|j ttjd gd dg ddl m }m }|r)|'|j |tjdntjd|jdtjd!d}|jddd"d}Gdd}t!|} |j#| tjdt%d} |j#| tjd |S#t$r }tjd|Yd}~d}~wwxYw)#zBuild and return the configured FastAPI application. Returns: FastAPI application with all routers, middleware, and lifecycle hooks. Raises: ImportError: If fastapi is not installed. zTfastapi is required to run the RLM server. Install with: pip install fastapi uvicornz/docsNz/redoczRLM Neo-Cortex APIAPIuCLiving Memory Bloodstream — RLM Neo-Cortex memory management API.1.0.0z /openapi.json)title descriptionversiondocs_url redoc_url openapi_urllifespanT)GETPOSTDELETEOPTIONS*) allow_originsallow_credentials allow_methods allow_headersr)TenantMiddleware_MIDDLEWARE_AVAILABLEzTenantMiddleware registeredzxTenantMiddleware could not be registered (starlette not available). Tenant isolation will not be enforced by middleware.z"TenantMiddleware import failed: %sz/health)include_in_schemac KttjsddddStjd{}|jdddd|jd d |jd d |jd d d dS7Ow)zFTop-level health check. Reports gateway readiness and backend status.Nstartingnot_initializedr0)statusgatewayr3rGunknown initializedpgFqdrantredis) postgresqlrLrM)rGrHr3backends)rr health_checkget)backend_healths rhealthzcreate_app..healths  8#:#:$,"  (4466$((9=$,00u=,005A,00%@  7s4BBAB/FcKdddSw)Nzrlm-neo-cortexr0)servicer3rrrrrootzcreate_app..roots+@@sceZdZdZddZy)!create_app.._GatewayProxyz;Thin proxy that delegates all attribute access to _gateway.c@t}| tdt||S)Nz!MemoryGateway not yet initialised)rrgetattr)selfnamegws r __getattr__z-create_app.._GatewayProxy.__getattr__s%Bz"#FGG2t$ $rN)r]strreturnr)__name__ __module__ __qualname____doc__r_rrr _GatewayProxyrYs I %rrf)rHz'Memory router mounted at /api/v1/memory) collectorz+Feedback router mounted at /api/v1/feedback)razDict[str, Any])razDict[str, str]) _FASTAPI_OK ImportErrorrenable_api_docsr r,add_middlewarer cors_origins middlewarerArBr!r"warningrQ_create_memory_routerinclude_router_create_feedback_router) _docs_url _redoc_url applicationrArBr+rSrWrf memory_routerfeedback_routers r create_apprws  8  &554I%554J&.&>&>"E'' R'/'?'?OT K"++:e  BG %5%A  & &'7 8 KK5 6 NNG __Y(2J2J_K L 0__SE_2A3A%%*-/BM}- KK9:.=O/ KK=> E B;SAABs2AF11 G:GGc ddl}|jd|xstj|xstj |tj jy#t$r}td|d}~wwxYw)zStart the RLM server using uvicorn. Args: host: Bind host (defaults to settings.rlm_host). port: Bind port (defaults to settings.rlm_port). reload: Enable hot-reload for development. rNzLuvicorn is required to run the RLM server. Install with: pip install uvicornzcore.rlm.app:app)hostportreload log_level)uvicornrirunrrlm_hostrlm_portr|lower)ryrzr{r}r+s rr~r~sz KK  &X&&  &X&&$$**,   0  sA A7& A22A7__main__)rar)r* 'FastAPI'razAsyncIterator[None])rar)NNF)ryz str | Nonerzz int | Noner{boolraNone)-re __future__rloggingossys contextlibrtypingrrrenvironrQupper _LOG_LEVEL basicConfigr[r getLoggerr!fastapir fastapi.middleware.corsrrhriconfigrrHrgateway_routerrrofeedback_webhookrrqr__annotations__rr,rwr*r~rbrrrrs8# *++ ZZ^^K 0 6 6 8  ':w|| 4 >    > * 6K"BO "& % $',',\zB ,C C: zE}KGNs C'' C54C5