g>!dZddlZddlmZmZmZmZmZmZddl m Z m Z m Z m Z mZmZmZmZej$eZGddZy)z; Defines the RealtimePresence class and its dependencies. N)AnyCallableDictListOptionalUnion) PresenceDiffPresenceEventsPresenceOnJoinCallbackPresenceOnLeaveCallback PresenceOptsRawPresenceDiffRawPresenceStateRealtimePresenceStatec .eZdZddeefdZdefdZdefdZ de gdffdZ de gdffdZ de gdffd Z d efd Zd eeeffd Zd eeeffd Zdedeeefdededef dZdedeeefdededef dZdefdZedeeefdefdZy)AsyncRealtimePresenceNoptsc||_i|_g|_d|_dddddd|_|r |j n t dd }|jj|j|j |jj|j|j |jjd |j y) NcyNargss M/var/www/openai/venv/lib/python3.12/site-packages/realtime/_async/presence.pyz0AsyncRealtimePresence.__init__..sDcyrrrs rrz0AsyncRealtimePresence.__init__..Trcyrrrrrrz0AsyncRealtimePresence.__init__..sdrcyrrrrrrz0AsyncRealtimePresence.__init__.. rrcyrrrrrrz0AsyncRealtimePresence.__init__..!rr)onJoinonLeaveonSync onAuthSuccess onAuthFailurepresence_state presence_diff)statediff)callbackphx_auth) channelr* pending_diffsjoin_refcallereventsr _on_on_state_eventr+_on_diff_event_on_auth_event)selfr.rr2s r__init__zAsyncRealtimePresence.__init__s ,. 46'+ ()"))    KK&6_M  0D0DE t/B/BC d.A.ABrr,c"||jd<y)Nr#r1r7r,s ron_joinzAsyncRealtimePresence.on_join. ( Hrc"||jd<y)Nr$r:r;s ron_leavezAsyncRealtimePresence.on_leave1s!) Irc"||jd<y)Nr%r:r;s ron_synczAsyncRealtimePresence.on_sync4r=rc"||jd<y)Nr&r:r;s ron_auth_successz%AsyncRealtimePresence.on_auth_success7'/ O$rc"||jd<y)Nr'r:r;s ron_auth_failurez%AsyncRealtimePresence.on_auth_failure:rDrpayloadc^|jd}|jd}|jd}|jj|_|j|j||||_|j D]%}|j |j||||_'g|_|yNr#r$r%)r1r.r0 _sync_stater*r/ _sync_diff)r7rGrr#r$r%r+s rr4z%AsyncRealtimePresence._on_state_event=sX&++i(X& -- %%djj'67K &&DT67KDJ'rc |jd}|jd}|jd}|jr|jj|y|j |j ||||_|yrI)r1in_pending_sync_stater/appendrKr*)r7rGrr#r$r%s rr5z$AsyncRealtimePresence._on_diff_eventJskX&++i(X&  % % '    % %g .WfgNDJ Hrc~|jddk(r|jdy|jdy)Nstatusokr&r')getr1)r7rGrs rr6z$AsyncRealtimePresence._on_auth_eventUs5 ;;x D ( (DKK ( * (DKK ( *r current_state new_stater#r$returnc|jDcic]\}}|t|}}}tj|}i} |jD cic] \} } | |vs | | } } } |jD]\}}|j |g} t | dkDr|Dchc]}|j d}}| Dchc]}|j d}}|Dcgc]}|j d|vs|}}| Dcgc]}|j d|vr|}}|r|| |<|s|| |<|| |<|j || | d||Scc}}wcc} } wcc}wcc}wcc}wcc}w)Nr presence_ref)joinsleaves)itemslistr_transform_staterRlenrK)r7rSrTr#r$keyvaluer*transformed_staterXkvrYcurrent_presencespresencenew_presence_refscur_presence_refspjoined_presencesleft_presencess rrJz!AsyncRealtimePresence._sync_state[s5B4G4G4IJ4Ijc5d5k!4IJ1BB9M ""[[]" *TQa7H.HAqD] " ,113JC % #r 2 $%)RW$XRWhX\\.%ARW!$XAR%ARXHLL0AR"% %$$!n(=EV(VAu!$ /".uu^,4EE." $!1E#J!"0F3K"c /42 Uf5vw  CK" %Y%$"s/E E$E&EE""E';E'E,r*r+ctj|jdi}tj|jdi}|jD]\}}|j|g} |||<t | dkDrM|j|D chc]} | jdc} t fd| D} | ||z||<||| ||jD]\}} |j|g} t | dk(r|S| D chc]} | jd} } | D cgc]} | jd| vr| } } | ||<||| | t | dk(s||=|Scc} wcc} wcc} w)NrXrYrrWc3HK|]}|jdvr|yw)rWN)rR).0rdjoined_presence_refss r z3AsyncRealtimePresence._sync_diff..s+%$5||N3;OO$5s")rr\rRrZr]r[)r7r*r+r#r$rXrYr^ new_presencesrcrd cur_presencesripresence_refs_to_removerms @rrKz AsyncRealtimePresence._sync_diffs&66txx7LM&7728NO"'++- C % #r 2 &E#J$%)AF3(AOXHLL0($!%%$5%! +U3Z7c 3)= 9#0"$*<<> C % #r 2 $%*" >L'=K ^,^ $' !2! 1H<</7NN 1 ! +E#J C*N ;$%*#J'$2* C($'!sE>F;Fch|jduxs#|j|jjk7Sr)r0r.)r7s rrMz+AsyncRealtimePresence.in_pending_sync_states)}}$N 9N9N(NNrci}|jD]i\}}t|trOd|vrKg||<|dD]=}|jdd|d<|jdd||j |?e|||<k|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_refNrW phx_ref_prev)rZ isinstancedictpoprN)r*rTr^ presencesrds rr\z&AsyncRealtimePresence._transform_statesL,. #kkmNC)T*w)/C!# # )' 2H/7||It/LH^,LL6cN))(3!3 "+ #,rr)__name__ __module__ __qualname__rrr8r r<r r?rrArCrFrr4rstrrr5r6rrrJrr rKboolrM staticmethodr\rrrrrscCh|&<C.) 6)*!8*)T 2)0T(:00T(:0 '7  d38n +d38n+ * ,* )+@@A* ' * ) *  * X0$0O\120' 0 ) 0  0dOtO1%'<<=1 11rr)__doc__loggingtypingrrrrrrtypesr r r r rrrr getLoggerr{loggerrrrrrsD==      8 $XXr