[j,tddlZddlmZmZmZmZejeZGddZ e Z dS)N)CallableDictListAnycZeZdZdZdZdedefdZd dedefdZ e ded e fd Z dS) EventBusz>Simple in-memory Pub/Sub Event Bus for decoupled mega-modules.ci|_dSN) subscribers)selfs 9C:\Projects\DSCons\app\core\module_framework\event_bus.py__init__zEventBus.__init__s68 event_typecallbackc||jvr g|j|<|j||td|dS)Nz[EVENT BUS] Subscribed to )r appendloggerinfo)r rrs r subscribezEventBus.subscribe sZ T- - -+-D Z ( $++H555 ===>>>>>rNdatac K||jvrtd|dt|j|d|j|D]} ddl}||r|||n ||G#t$r,}td|d|dYd}~xd}~wwxYwdSdS) Nz[EVENT BUS] Publishing z to z subscribersrz$[EVENT BUS] Error in subscriber for z: T)exc_info) r rrlenasyncioiscoroutinefunction create_task Exceptionerror)r rrrres r publishzEventBus.publishs% ) ) ) KKq*qq#dFVWaFbBcBcqqq r r r ,Z8 j jj"NNN228<<'++HHTNN;;;;  jjjLL!Y !Y!YVW!Y!YdhLiiiiiiiij * ) j jsAB C#"C  Cpayloadcddl}ddlmfd}|||}|d||ft d|ddS) z Publish an event transactionally by writing it to the outbox table. Needs an active psycopg2/psycopg3 cursor (cur). rN)UUIDcPt|rt|Str ) isinstancestr TypeError)objr$s r uuid_convertz-EventBus.publish_outbox..uuid_convert's%#t$$ 3xxOr)defaultz| INSERT INTO erp_outbox_events (event_type, payload, status) VALUES (%s, %s, 'pending') z[EVENT BUS] Event z written to outbox.)jsonuuidr$dumpsexecuterdebug)currr"r,r* payload_jsonr$s @r publish_outboxzEventBus.publish_outboxs        zz'r?s,,,,,,,,,,,,  8 $ $/K/K/K/K/K/K/K/Kb HJJ r