o uyi@stdZddlZddlmZmZmZmZmZmZddl m Z m Z m Z m Z mZmZmZmZmZeeZGdddZdS)z: Defines the RealtimePresence class and its dependencies. N)AnyCallableDictListOptionalUnion) Presence PresenceDiffPresenceEventsPresenceOnJoinCallbackPresenceOnLeaveCallback PresenceOptsRawPresenceDiffRawPresenceStateRealtimePresenceStatec@seZdZedefddZddZdefddZde fd d Z de gd ffd d Z de fddZdefddZdedefddZdededefddZede defddZd S)AsyncRealtimePresencereturncCs|jdup|jdup|jduSN)on_join_callbackon_leave_callbackon_sync_callbackselfr[/home/ubuntu/maya3_transcribe/venv/lib/python3.10/site-packages/realtime/_async/presence.py_has_callback_attacheds z,AsyncRealtimePresence._has_callback_attachedcCsi|_d|_d|_d|_dSr)staterrrrrrr__init__ s zAsyncRealtimePresence.__init__callbackcC ||_dSr)rrrrrron_join& zAsyncRealtimePresence.on_joincCr r)rr!rrron_leave)r#zAsyncRealtimePresence.on_leaveNcCr r)rr!rrron_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_event6s  z$AsyncRealtimePresence._on_diff_event new_statec 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 Bsz5AsyncRealtimePresence._sync_state..rcSh|]}|dqS presence_refrr/presencerrr Hsz4AsyncRealtimePresence._sync_state..cSr3r4rr6rrrr8Iscg|] }|dvr|qSr4rr/p)cur_presence_refsrr Msz5AsyncRealtimePresence._sync_state..cr9r4rr:)new_presence_refsrrr=Ps  )ritemsgetlenr,) rr.r*r+keyvaluecurrent_presencesjoined_presencesleft_presencesr)r<r>r.rr(=s,     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|]}|dqSr4r@r6rrrr8g z3AsyncRealtimePresence._sync_diff..c3s"|] }|dvr|VqdS)r5NrHr6)joined_presence_refsrr jsz3AsyncRealtimePresence._sync_diff..cSrGr4rHr6rrrr8zrIcsg|] }|dvr|qSr4rHr6)presence_refs_to_removerrr=}s z4AsyncRealtimePresence._sync_diff..)r?rr@rAlistrr)rr*r+rB new_presencesrD cur_presencesrFr)rJrLrr,_s@       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_prevr5phx_ref)r?popupdateappend)rr.rB presencesr7 new_presencerrrr's&  z&AsyncRealtimePresence._transform_state)__name__ __module__ __qualname__propertyboolrrr r"r r$rr%rr)rr-rr(r, staticmethodr'rrrrrs6 " -r)__doc__loggingtypingrrrrrrtypesr r r r r rrrr getLoggerrXloggerrrrrrs  ,