yji ddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZejeZGd d eeZGd d eZGd deZGddeZeezZdeddfdZdS)N)Enum)Literal) BaseModel) tracked_db) QueueItem)create_webhook_payload)construct_work_unit_keyceZdZdZdZdS)WebhookEventTypez queue.emptyz test.eventN)__name__ __module__ __qualname__ QUEUE_EMPTYTEST;/DATA/AppData/hermes/projects/honcho/src/webhooks/events.pyr r sK DDDrr ceZdZUdZeed<dS)BaseWebhookEventz"Base class for all webhook events. workspace_idN)r r r__doc__str__annotations__rrrrrs$,,rrceZdZUdZejZeejed<e ed<dZ e dzed<dZ e dzed<dZ e dzed<dS)QueueEmptyEventz-Webhook event for when a queue becomes empty.type queue_typeN session_idobserverobserved) r r rrr rrrrrrrr rrrrrsy772B2ND'". /NNNOOO!Jd !!!HcDjHcDjrrcBeZdZUdZejZeejed<dS) TestEventzWebhook event for testing.rN) r r rrr rrrrrrrr"r"$s4$$+;+@D'"' (@@@@@rr"eventreturnc LK t|jj|ddh}t d4d{V}t t |jddi|dd|jd }||| d{Vt d |j|jdddd{VdS#1d{VswxYwYdS#t$r$t d |jYdSwxYw) zf Add a webhook event to our DB queue. Args: event: The webhook event to publish. jsonr)modeexclude) event_typedatapublish_webhook_eventN task_typewebhook) work_unit_keypayloadrr,workspace_name message_idz/Published webhook event '%s' for workspace '%s'z"Failed to publish webhook event %s)rrvalue model_dumprrr raddcommitloggerdebug Exception exception)r#r/db queue_items rr+r+.s" )z'!!vx!@@    566       ""5&#Y  #$1   J FF:   ))++        LLA "   !                              ,     0 J       s7AC5 BC"C5" C,,C5/C,0C55*D#"D#)loggingenumrtypingrpydanticrsrc.dependenciesr src.modelsrsrc.utils.queue_payloadrsrc.utils.work_unitr getLoggerr r6rr rrr" WebhookEventr+rrrrFs'''''' ::::::777777  8 $ $sD y      &   AAAAA AAA* ) |) ) ) ) ) ) ) r