o }jh@stdZddlZddlmZmZmZmZmZmZddl m Z m Z m Z m Z mZmZmZmZmZeeZGdddZdS)z: Defines the RealtimePresence class and its dependencies. N)AnyCallableDictListOptionalUnion) Presence PresenceDiffPresenceEventsPresenceOnJoinCallbackPresenceOnLeaveCallback PresenceOptsRawPresenceDiffRawPresenceStateRealtimePresenceStatec@seZdZddZdefddZdefddZdegdffd d Z d e fd d Z d e fddZ dedefddZdededefddZede defddZdS)AsyncRealtimePresencecCsi|_d|_d|_d|_dSN)stateon_join_callbackon_leave_callbackon_sync_callback)selfrN/var/www/html/bot/env/lib/python3.10/site-packages/realtime/_async/presence.py__init__s zAsyncRealtimePresence.__init__callbackcC ||_dSr)rrrrrron_join zAsyncRealtimePresence.on_joincCrr)rrrrron_leave!r zAsyncRealtimePresence.on_leaveNcCrr)rrrrron_sync$r zAsyncRealtimePresence.on_syncpayloadcCs,t|}|||_|jr|dSdSr)r_transform_state _sync_staterr)rr#rrrr_on_state_event's   z%AsyncRealtimePresence._on_state_eventcCs@t|d}t|d}||||_|jr|dSdS)Njoinsleaves)rr$ _sync_diffrr)rr#r'r(rrr_on_diff_event.s  z$AsyncRealtimePresence._on_diff_event new_statereturnc si}fdd|jD}D]B\}}|j|g}t|dkrPdd|Ddd|Dfdd|D}fd d|D}|rI|||<|rO|||<q|||<q|||S) Ncsi|] \}}|vr||qSrr).0kv)r+rr :sz5AsyncRealtimePresence._sync_state..rcSh|]}|dqS presence_refrr-presencerrr @sz4AsyncRealtimePresence._sync_state..cSr1r2rr4rrrr6Ascg|] }|dvr|qSr2rr-p)cur_presence_refsrr Esz5AsyncRealtimePresence._sync_state..cr7r2rr8)new_presence_refsrrr;Hs  )ritemsgetlenr)) rr+r'r(keyvaluecurrent_presencesjoined_presencesleft_presencesr)r:r<r+rr%5s,     z!AsyncRealtimePresence._sync_stater'r(cs|D]<\}}|j|g}||j|<t|dkr6dd|Dtfdd|D}||j||j|<|jr@||||q|D]>\}}|j|g}t|dkrZ|jSdd|Dfdd|D}||j|<|jry||||t|dkr|j|=qE|jS) NrcSh|]}|dqSr2r>r4rrrr6_ z3AsyncRealtimePresence._sync_diff..c3s"|] }|dvr|VqdS)r3NrFr4)joined_presence_refsrr bsz3AsyncRealtimePresence._sync_diff..cSrEr2rFr4rrrr6rrGcsg|] }|dvr|qSr2rFr4)presence_refs_to_removerrr;us z4AsyncRealtimePresence._sync_diff..)r=rr>r?listrr)rr'r(r@ new_presencesrB cur_presencesrDr)rHrJrr)Ws@       z AsyncRealtimePresence._sync_diffrcCsdi}|D])\}}g||<|dD]}d|vr|d=d|di}|||||qq|S)aX Transform the raw presence state into a standardized RealtimePresenceState format. This method processes the input state, which can be either a RawPresenceState or an already transformed RealtimePresenceState. It handles the conversion of the Phoenix channel's presence format to our internal representation. Args: state (Union[RawPresenceState, RealtimePresenceState[T]]): The presence state to transform. Returns: RealtimePresenceState[T]: The transformed presence state. Example: Input (RawPresenceState): { "user1": { "metas": [ {"phx_ref": "ABC123", "user_id": "user1", "status": "online"}, {"phx_ref": "DEF456", "phx_ref_prev": "ABC123", "user_id": "user1", "status": "away"} ] }, "user2": [{"user_id": "user2", "status": "offline"}] } Output (RealtimePresenceState): { "user1": [ {"presence_ref": "ABC123", "user_id": "user1", "status": "online"}, {"presence_ref": "DEF456", "user_id": "user1", "status": "away"} ], "user2": [{"user_id": "user2", "status": "offline"}] } metas phx_ref_prevr3phx_ref)r=popupdateappend)rr+r@ presencesr5 new_presencerrrr$s&  z&AsyncRealtimePresence._transform_state)__name__ __module__ __qualname__rr rr r!rr"rr&rr*rr%r) staticmethodr$rrrrrs2 " -r)__doc__loggingtypingrrrrrrtypesr r r r r rrrr getLoggerrVloggerrrrrrs  ,