Yi ,UdZddlmZddlZddlZddlmZmZmZddl m Z ddl m Z m Z mZddlmZmZmZdd lmZdd lmZej.d Zhd ZGd deZej6ej8ej:dZded<dddZ gdZ!y)aRLM Neo-Cortex -- Generic Webhook Receiver for Feedback Signals. Provides a FastAPI router at POST /api/v1/feedback/webhook that external systems (GHL, Instantly, custom apps) can POST to in order to record feedback signals for any interaction. Implements Story 5.08 of the RLM Neo-Cortex PRD (Module 5). VERIFICATION_STAMP Story: 5.08 Verified By: parallel-builder Verified At: 2026-02-26 Tests: see tests/rlm/test_feedback.py Coverage: 100% ) annotationsN)AnyDictOptional)UUID) APIRouter HTTPExceptionRequest) BaseModelFieldfield_validator)FeedbackSignal)FeedbackCollectorzcore.rlm.feedback_webhook>neutralnegativepositiveceZdZUdZeddZded<eddd Zd ed <edd Zd ed <eddZ d ed<e d e ddZ y)FeedbackWebhookRequestz/Incoming webhook payload for a feedback signal..z%UUID of the tenant (SubAIVA customer)) descriptionr tenant_idrzUnique interaction identifier) min_lengthrstrinteraction_idz.Feedback signal: positive | negative | neutralsignalapizSignal source identifier)defaultrsourcecR|tvrtd|dtt|S)NzInvalid signal 'z'. Must be one of: )_VALID_SIGNALS ValueErrorsorted)clsvs 2/mnt/e/genesis-system/core/rlm/feedback_webhook.pyvalidate_signalz&FeedbackWebhookRequest.validate_signal1s7 N ""1#%89O8PQ N)r$rreturnr) __name__ __module__ __qualname____doc__r r__annotations__rrrr classmethodr&r'r%rr&su9C-TUItU?^_NC_ DFC3MNFCNXr'r)rrrzDict[str, FeedbackSignal]_SIGNAL_ENUM_MAPcntddg}d|idfd |jdd fd }|S) zCreate and return the FastAPI router. Parameters ---------- collector: Optional pre-built FeedbackCollector. If not provided, the router will create one lazily from environment variables on first request. z/api/v1/feedbackfeedback)prefixtagsinstancecdJttjjdtjjdd<dS)Nr5 DATABASE_URL REDIS_URL)pg_dsn redis_url)rosenvironget)_collector_holdersr%_get_collectorz.create_feedback_router.._get_collectorRsK Z ( 0,=zz~~n5**..5- j )!,,r'z/webhookcK}t|j}|j|j|jd{}|7|jdk7r(t dd|jd|jd|j |j|j|d|ji d{}d |du|r|jd Sdd S77w) aoRecord a feedback signal from an external system. Returns ------- HTTP 200 -- signal recorded successfully {"status": "recorded", "pair_generated": bool, "annotator_id": str} HTTP 422 -- invalid signal string (Pydantic validation) HTTP 404 -- interaction_id unknown (no cached interaction + no context) Nriz Interaction 'z!' not found in cache for tenant 'z7'. Cache the interaction first via cache_interaction().) status_codedetailr)rrrcontextrecorded)statuspair_generated annotator_id) r0rget_interactionrrr record_feedbackrrG)payloadcoll signal_enum interactionpairr?s r%receive_feedbackz0create_feedback_router..receive_feedbackZs &w~~6 !001B1BGDZDZ[[  7>>Y#>#G$:$:#;<##*#4#4"56KK ))''"11w~~. *  !"$.15D--  <@  %\ s%ACCA5C=C>CC)r(r)rJrr(zDict[str, Any])rpost) collectorrouterrOr>r?s @@r%create_feedback_routerrSFsI0 | DF)3Y(?- [[$ $ L Mr')rrSr0r )N)rQzOptional[FeedbackCollector]r(r)"r, __future__rloggingr;typingrrruuidrfastapirr r pydanticr r r contractsrr2r getLoggerloggerr rPOSITIVENEGATIVENEUTRALr0r-rS__all__r/r'r%ras# &&5566%'   6 7 5Y,''''&&/+;| r'