Ë
    °È„jO  ã                   óÎ   — d dl mZ d dl mZ d dl mZ d dlmZ d dlmZ d dlmZ d dlm	Z	 d dlm
Z
 d d	lmZ d d
lmZ d dlmZ ddlmZ ddlmZ ddlmZ ddlmZ  G d„ de«      Zy)é    )ÚList)ÚOptional)ÚUnion)ÚFrame)ÚMediaDescription)Ú
MediaState)ÚNetworkInfo)ÚSegmentPartRequest)ÚStreamDevice)Ú
StreamMode)Ú
StreamTypeé   )ÚHandlersHolder)Ú
CallConfig)ÚGroupCallConfig)ÚUpdatec            	       óŠ  ‡ — e Zd ZdZdZˆ fd„Zd„ Zd„ Zdee	e
f   fd„Zd„ Zd(dee	e
f   fd	„Zdee	e
f   fd
„Zdee	e
f   defd„Zde	fd„Zde	defd„Zde	fd„Zde	dedefd„Zde	defd„Zde	fd„Zde	defd„Zde	dededee   fd„Z de	de!fd„Z"de#fd„Z$de	d e%d!ee&e'f   d"e(e
   fd#„Z)e*d$e	fd%„«       Z+de	fd&„Z,d)d'„Z-ˆ xZ.S )*ÚScaffoldz1.2.20z1.24.0c                 ób  •— t         ‰| �  «        d | _        d | _        d | _        d | _        d | _        d | _        d | _        d | _	        d | _
        t        «       | _        t        «       | _        t        «       | _        t        «       | _        t        «       | _        t        «       | _        d | _        y ©N)ÚsuperÚ__init__Ú_appÚ_is_runningÚ_my_idÚ_env_checkerÚ_cache_user_peerÚ_cache_local_peerÚ	_handlersÚ_bindingÚloopÚsetÚ_need_unmuteÚdictÚ_p2p_configsÚ_call_sourcesÚ_wait_connectÚ_presentationsÚ_pending_connectionsÚ
_chat_lock)ÚselfÚ	__class__s    €úI/var/www/html/GAP/venv/lib/python3.12/site-packages/pytgcalls/scaffold.pyr   zScaffold.__init__   s”   ø€ Ü‰ÑÔØˆŒ	ØˆÔØˆŒØ ˆÔØ $ˆÔØ!%ˆÔØˆŒàˆŒØˆŒ	Ü›EˆÔÜ ›FˆÔÜ!›VˆÔÜ!›VˆÔÜ!›eˆÔÜ$(£FˆÔ!Øˆ�ó    c                  ó   — y r   © ©r+   s    r-   Ú_handle_mtprotozScaffold._handle_mtproto,   ó   € Ør.   c              ƒ   ó   K  — y ­wr   r0   r1   s    r-   Ú_init_mtprotozScaffold._init_mtproto/   ó	   è ø€ Øùó   ‚Úchat_idc              ƒ   ó   K  — y ­wr   r0   ©r+   r8   s     r-   Úresolve_chat_idzScaffold.resolve_chat_id2   r6   r7   c              ƒ   ó   K  — y ­wr   r0   r1   s    r-   ÚstartzScaffold.start5   r6   r7   c              ƒ   ó   K  — y ­wr   r0   )r+   r8   ÚstreamÚconfigs       r-   ÚplayzScaffold.play8   r6   r7   c              ƒ   ó   K  — y ­wr   r0   r:   s     r-   Ú_update_sourceszScaffold._update_sources;   r6   r7   Újoinc              ƒ   ó   K  — y ­wr   r0   )r+   r8   rD   s      r-   Ú_join_presentationzScaffold._join_presentation>   r6   r7   c              ƒ   ó   K  — y ­wr   r0   r:   s     r-   Ú_clear_callzScaffold._clear_callA   r6   r7   Ústatec              ƒ   ó   K  — y ­wr   r0   )r+   r8   rI   s      r-   Ú_update_statuszScaffold._update_statusD   r6   r7   c              ƒ   ó   K  — y ­wr   r0   r:   s     r-   Ú_switch_connectionzScaffold._switch_connectionG   r6   r7   Ústream_typeÚdevicec              ƒ   ó   K  — y ­wr   r0   )r+   r8   rN   rO   s       r-   Ú_handle_stream_endedzScaffold._handle_stream_endedJ   s   è ø€ ð 	ùr7   Údatac              ƒ   ó   K  — y ­wr   r0   )r+   r8   rR   s      r-   Ú_emit_sig_datazScaffold._emit_sig_dataR   r6   r7   c              ƒ   ó   K  — y ­wr   r0   r:   s     r-   Ú_request_broadcast_timestampz%Scaffold._request_broadcast_timestampU   s   è ø€ ð 	ùr7   Úpart_requestc              ƒ   ó   K  — y ­wr   r0   )r+   r8   rW   s      r-   Ú_request_broadcast_partz Scaffold._request_broadcast_part[   ó   è ø€ ð
 	ùr7   ÚmodeÚframesc              ƒ   ó   K  — y ­wr   r0   )r+   r8   r[   rO   r\   s        r-   Ú_handle_stream_framezScaffold._handle_stream_frameb   ó   è ø€ ð 	ùr7   Ú	net_statec              ƒ   ó   K  — y ­wr   r0   )r+   r8   r`   s      r-   Ú_handle_connection_changedz#Scaffold._handle_connection_changedk   rZ   r7   Úupdatec              ƒ   ó   K  — y ­wr   r0   )r+   rc   s     r-   Ú_handle_mtproto_updatesz Scaffold._handle_mtproto_updatesr   r6   r7   Úmedia_descriptionr@   Úpayloadc              ƒ   ó   K  — y ­wr   r0   )r+   r8   rf   r@   rg   s        r-   Ú_connect_callzScaffold._connect_callu   r_   r7   Úrc                  ó   — y r   r0   )rj   s    r-   Ú_log_retrieszScaffold._log_retries~   s   € àr.   c                  ó   — y r   r0   r:   s     r-   Ú_clear_cachezScaffold._clear_cache‚   r3   r.   c                  ó   — y r   r0   )r+   Úfilterss     r-   Ú	on_updatezScaffold.on_update…   r3   r.   )NNr   )/Ú__name__Ú
__module__Ú__qualname__Ú_REQUIRED_PYROGRAM_VERSIONÚ_REQUIRED_TELETHON_VERSIONr   r2   r5   r   ÚintÚstrr;   r=   rA   rC   ÚboolrF   rH   r   rK   rM   r   r   rQ   ÚbytesrT   rV   r
   rY   r   r   ÚRawFramer^   r	   rb   r   re   r   r   r   r   ri   Ústaticmethodrl   rn   rq   Ú__classcell__)r,   s   @r-   r   r      s´  ø„ Ø!)ÐØ!)Ðôò(òð¨U°3¸°8©_ó òñ %¨¨S¨¡/ó ð¨U°3¸°8©_ó ð°°c¸3°h±ð Àtó ð¨ó ð¨Cð ¸
ó ð°ó ðàðð  ðð ó	ð¨Cð °uó ðàóðàðð )óðàðð ðð ð	ð
 �X‘óðàðð óð°Fó ðàðð ,ðð �j /Ð1Ñ2ð	ð
 ˜#‘óð ð˜ò ó ðð Có ÷r.   r   N)Útypingr   r   r   Úntgcallsr   r{   r   r   r	   r
   r   r   r   Úhandlersr   Útypesr   r   r   r   r0   r.   r-   ú<module>r‚      s@   ðÝ Ý Ý å &Ý %Ý Ý  Ý 'Ý !Ý Ý å $Ý Ý "Ý ôrˆ~õ rr.   