$j|!dZddlZddlZddlZddlZddlZddlmZmZddlm Z m Z ddl m Z ddlmZmZmZe r dd lmZdd lmZejeZgd ZeedzZd eezdzd efdZGddZdS)z3Webhook manager for delivering event notifications.N)datetimetimezone) TYPE_CHECKINGAny)fq_table_explicit) WebhookConfig WebhookEventWebhookHttpConfig)DatabaseBackend)TenantExtension)i,ii iPFvaluereturnc|tSt|trtj|Stj|S)zMParse http_config column value (JSONB returned as text or dict) into a model.)r isinstancestrmodel_validate_jsonmodel_validate)rs f/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/hindsight_api/webhooks/manager.py_parse_http_configrsG } """%< 4U;;;  +E 2 22c eZdZdZ ddddeeddfdZd ed ed efd Z dd e dedzd dfdZ dd e de dedzd dfdZ dS)WebhookManagera# Manages webhook registration and event firing. Supports both global webhooks (configured via env vars) and per-bank webhooks stored in the database. Deliveries are queued as async_operations tasks (operation_type='webhook_delivery') and picked up by the worker poller. Nbackendr global_webhookstenant_extensionzTenantExtension | Nonec0||_||_||_dSN)_backend_global_webhooks_tenant_extension)selfrrrs r__init__zWebhookManager.__init__,s!   /!1rsecret payload_bytesrcdtj||tjzS)z,Compute HMAC-SHA256 signature for a payload.zsha256=)hmacnewencodehashlibsha256 hexdigest)r$r&r's r _sign_payloadzWebhookManager._sign_payload6s148FMMOO]GNSS]]____reventschemac<Ktd|}td|}tjtj}|} |j4d{V}|jj |||j d{V}d|D} |j | z} d} | D]} | j s |j j| jvrt!j} | jr| jnd}t'jdt+| |j | j| j|j j||| jd }|jj||| |j ||d{V| dz } dddd{Vn#1d{VswxYwYt6d |j d |j d | d dS#t:$r0}t6d |j d |Yd}~dSd}~wwxYw)a Queue webhook deliveries for an event as async_operations tasks. Loads per-bank and global webhooks, inserts pending webhook_delivery tasks for any webhook whose event_types list matches the fired event type. The worker poller picks these up and calls MemoryEngine._handle_webhook_delivery(). Args: event: The event to deliver. schema: Database schema (for multi-tenant). None = default schema. webhooksasync_operationsNcg|]s}tt|d|d|d|d|drt|dng|dt|dtSidbank_idurlr& event_typesenabled http_config)r7r8r9r&r:r;r<r rlistr.0rows r z-WebhookManager.fire_event..Ss   "s4y>> #IJ"8}@CM@R$ZD]);$<$<$+I+I+K+K   $ $L-+HH!$ $ qLGG?!/6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !6 !p LLv vvu}vvX_vvv w w w w w ] ] ] LL[[[XY[[ \ \ \ \ \ \ \ \ \ ]s=G!5DF G! F**G!-F*.1G!! H+%HHrac Ktd|}td|}tjtj}|} |jj|||j d{V}d|D} |j | z} d} | D]} | j s |j j | jvrtj} | jr| jnd}t%jdt)| |j | j| j|j j ||| jd }|jj||| |j ||d{V| dz } t4d |j d |j d | d dS#t8$r,}t4d |j d |dd}~wwxYw)a5 Queue webhook deliveries within an existing database connection/transaction. Identical to fire_event() but uses the provided connection instead of acquiring one from the pool. Use this to atomically insert delivery tasks in the same transaction as the primary operation (transactional outbox pattern). Args: event: The event to deliver. conn: Existing database connection (may be inside an active transaction). schema: Database schema (for multi-tenant). None = default schema. r3r4Ncg|]s}tt|d|d|d|d|drt|dng|dt|dtSr6r=r?s rrBz7WebhookManager.fire_event_with_conn..s   3t9~~ NE x=Failed to queue webhook deliveries (in-transaction) for event z]. CRITICAL: The enclosing database transaction is now aborted and will roll back all changes.)rMrrNrrOrPr!rRrSr8r"r;r0rr:rTrUr7rVrWrr9r&r<rXrYrZr[r\r])r$r0rar1r^r_rNr`rbrcrdrerfrFrIrgrhs rfire_event_with_connz#WebhookManager.fire_event_with_connsv"*f55 0&99 l8<((++-- A *DD D      K 0;>LG'  ;$G,???#z|| +2:?WZZ4 #z 2(+L(9(9#(=&{").&+k&7#.&0'.':'E'E'G'G     m'DD M  1  LL~u{~~em~~w~~~         LLnQVQ\nn`annn      sEF G''GGr )__name__ __module__ __qualname____doc__r>r r%rbytesr/r rirrlrrrr#s6: 22"2m,23 2222`C``#````M]M]lM]C$JM]RVM]M]M]M]^SS SCSQTW[Q[SgkSSSSSSrr) rpr,r)rVloggingrTrrtypingrr engine.schemarrMmodelsr r r hindsight_api.engine.db.baser hindsight_api.extensions.tenantr getLoggerrmrZ RETRY_DELAYSlen MAX_ATTEMPTSrdictrrrrrrr~s`99  ''''''''%%%%%%%%::::::BBBBBBBBBB@<<<<<<??????  8 $ $+** s<  1$ 3cDj4/34E3333yyyyyyyyyyr