o zsg>!@spdZddlZddlmZmZmZmZmZmZddl m Z m Z m Z m Z mZmZmZmZeeZGdddZdS)z; Defines the RealtimePresence class and its dependencies. N)AnyCallableDictListOptionalUnion) PresenceDiffPresenceEventsPresenceOnJoinCallbackPresenceOnLeaveCallback PresenceOptsRawPresenceDiffRawPresenceStateRealtimePresenceStatec @s0eZdZd&deefddZdefddZdefdd Z de gdffd d Z de gdffd d Z de gdffddZ defddZdeeeffddZdeeeffddZdedeeefdededef ddZdedeeefdededef d d!Zdefd"d#Zedeeefdefd$d%ZdS)'AsyncRealtimePresenceNoptscCs||_i|_g|_d|_ddddddddddd|_|r$|jntdd d }|jj|j|jd |jj|j |j d |jjd |j d dS) NcWdSNargsrrT/var/www/html/minecraft/env/lib/python3.10/site-packages/realtime/_async/presence.pyz0AsyncRealtimePresence.__init__..cWrrrrrrrrrcSrrrrrrrrrcSrrrrrrrr rcSrrrrrrrr!r)onJoinonLeaveonSync onAuthSuccess onAuthFailurepresence_state presence_diff)statediff)callbackphx_auth) channelr" pending_diffsjoin_refcallereventsr _on_on_state_eventr#_on_diff_event_on_auth_event)selfr&rr*rrr__init__s"  zAsyncRealtimePresence.__init__r$cC||jd<dS)Nrr)r/r$rrron_join.zAsyncRealtimePresence.on_joincCr1)Nrr2r3rrron_leave1r5zAsyncRealtimePresence.on_leavecCr1)Nrr2r3rrron_sync4r5zAsyncRealtimePresence.on_synccCr1)Nrr2r3rrron_auth_success7r5z%AsyncRealtimePresence.on_auth_successcCr1)Nrr2r3rrron_auth_failure:r5z%AsyncRealtimePresence.on_auth_failurepayloadcGsl|jd}|jd}|jd}|jj|_||j||||_|jD] }||j||||_q!g|_|dSNrrr)r)r&r( _sync_stater"r' _sync_diff)r/r:rrrrr#rrrr,=s      z%AsyncRealtimePresence._on_state_eventcGsT|jd}|jd}|jd}|r|j|dS||j||||_|dSr;)r)in_pending_sync_stater'appendr=r")r/r:rrrrrrrr-Js    z$AsyncRealtimePresence._on_diff_eventcGs.|ddkr|jddS|jddS)Nstatusokrr)getr))r/r:rrrrr.Usz$AsyncRealtimePresence._on_auth_event current_state new_staterrreturnc sdd|D}t|i}fdd|D}D]A\}} ||g} t| dkr\dd| Ddd| Dfdd | D} fd d | D} | rU| ||<| r[| ||<q| ||<q||||d ||S) NcSsi|] \}}|t|qSr)list).0keyvaluerrr bsz5AsyncRealtimePresence._sync_state..csi|] \}}|vr||qSrr)rGkv)transformed_staterrrJfrcSh|]}|dqS presence_refrBrGpresencerrr nsz4AsyncRealtimePresence._sync_state..cSrOrPrRrSrrrrUo cg|] }|dvr|qSrPrRrGp)cur_presence_refsrr srNz5AsyncRealtimePresence._sync_state..crWrPrRrX)new_presence_refsrrr[v )joinsleaves)itemsr_transform_staterBlenr=) r/rCrDrrr"r^r_rHrIcurrent_presencesjoined_presencesleft_presencesr)rZr\rMrr<[s8       z!AsyncRealtimePresence._sync_stater"r#c st|di}t|di}|D]7\}}||g} |||<t| dkrGdd||Dtfdd| D} | ||||<||| |q|D]6\}} ||g} t| dkre|Sdd| Dfd d | D} | ||<||| | t| dkr||=qR|S) Nr^r_rcSrOrPrRrSrrrrUrVz3AsyncRealtimePresence._sync_diff..c3s"|] }|dvr|VqdS)rQNrRrS)joined_presence_refsrr sz3AsyncRealtimePresence._sync_diff..cSrOrPrRrSrrrrUrVcrWrPrRrS)presence_refs_to_removerrr[r]z4AsyncRealtimePresence._sync_diff..)rrarBr`rbrF) r/r"r#rrr^r_rH new_presencesrc cur_presencesrer)rfrhrr=s>        z AsyncRealtimePresence._sync_diffcCs|jdup |j|jjkSr)r(r&)r/rrrr>sz+AsyncRealtimePresence.in_pending_sync_statecCsvi}|D]2\}}t|tr4d|vr4g||<|dD]}|dd|d<|dd|||qq|||<q|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"}] } metasphx_refNrQ phx_ref_prev)r` isinstancedictpopr?)r"rDrH presencesrTrrrras&   z&AsyncRealtimePresence._transform_stater)__name__ __module__ __qualname__rr r0r r4r r6rr7r8r9rr,rstrrr-r.rrr<rr r=boolr> staticmethodrarrrrrsN    ,  2 r)__doc__loggingtypingrrrrrrtypesr r r r r rrr getLoggerrrloggerrrrrrs  (