o diX.@s.ddlZddlZddlZddlmZddlmZmZddlm Z m Z m Z ddl m Z ddlmZddlmZed Zed ZeeZeGd d d ZeGd ddZde defddZdede fddZdeedeeeffddZdedeeeffddZ Gddde Z!Gddde Z"dS)N) dataclass)AnyOptional) Candidate ConnectionConnectionClosed)AsyncIOEventEmitter)InvalidStateError RTCIceServerz^(?Pstun|stuns)\:(?P[^?:]+)(\:(?P[0-9]+?))?(\?transport=(?P.*))?z^(?Pturn|turns)\:(?P[^?:]+)(\:(?P[0-9]+?))?(\?transport=(?P.*))?c@seZdZUdZeed<eed<eed<eed<eed<eed<eed<d Zeeed <d Z eeed <d Z eeed <d Z eeed <d Z eeed<d S)RTCIceCandidatez The :class:`RTCIceCandidate` interface represents a candidate Interactive Connectivity Establishment (ICE) configuration which may be used to establish an RTCPeerConnection. component foundationipportpriorityprotocoltypeNrelatedAddress relatedPortsdpMid sdpMLineIndextcpType) __name__ __module__ __qualname____doc__int__annotations__strrrrrrrr!r!J/home/ubuntu/.local/lib/python3.10/site-packages/aiortc/rtcicetransport.pyr s r c@sBeZdZUdZdZeeed< dZeeed< dZ e ed<dS)RTCIceParametersz The :class:`RTCIceParameters` dictionary includes the ICE username fragment and password and other ICE-related parameters. NusernameFragmentpasswordFiceLite) rrrrr$rr rr%r&boolr!r!r!r"r#2s r#xreturnc C0t|j|j|j|j|j|j|j|j|j |j d S)N) rrrrrrrrrr) r rrhostrr transportrelated_address related_porttcptyperr(r!r!r"candidate_from_aioiceBr1c Cr*)N) rrr+rrr-r.r,r/r) rrrrrrrrrrrr0r!r!r"candidate_to_aioiceQr2r3serverscCsi}|D]|}t|jtr|j}n|jg}|D]i}t|}|ddkr2d|vr'q|d|df|d<q|ddvrd|vr=q|ddkrJ|d d vrJq|dd krW|d d krWq|jd kr]q|d|df|d<|dd k|d<|d |d<|j|d<|j|d<qq|S)Nschemestun stun_serverr+r)turnturns turn_serverr8r,)udptcpr9r<r%turn_sslturn_transport turn_username turn_password) isinstanceurlslistparse_stun_turn_uricredentialTypeusername credential)r4kwargsserverurisuriparsedr!r!r"connection_kwargs`s8       !rMrKcCs|dr t|}n|drt|}ntd|s td|}|dr1t|d|d<n|ddvrz5RTCIceGatherer.getLocalCandidates..)r_local_candidatesrgr!r!r"getLocalCandidatesz!RTCIceGatherer.getLocalCandidatescCst|jj|jjdS)zd Retrieve the ICE parameters of the ICE gatherer. :rtype: RTCIceParameters )r$r%)r#r_rXrYrgr!r!r"getLocalParameterssz!RTCIceGatherer.getLocalParametersrhcCs||_|ddS)N statechange)raemitrbrhr!r!r" __setStateszRTCIceGatherer.__setState)NNNr)N)rrrrrrCr r r]propertyrhrn classmethodr^r rxr#rzrl __classcell__r!r!rdr"rVs,     rVcseZdZdZdeddffdd ZedefddZedefd d Z edefd d Z d e e ddfddZ dee fddZdeddfddZd ddZd ddZdededdfddZdeddfddZZS)!RTCIceTransporta The :class:`RTCIceTransport` interface allows an application access to information about the Interactive Connectivity Establishment (ICE) transport over which packets are sent and received. :param gatherer: An :class:`RTCIceGatherer`. gathererr)NcsHt||_d|_d|_d|_|j|_d|_|jj|_ |jj |_ dS)Nr[F) r\r]_RTCIceTransport__iceGatherer_RTCIceTransport__monitor_task_RTCIceTransport__start_RTCIceTransport__stater_ _role_setrecv_recvsend_send)rbrrdr!r"r]s  zRTCIceTransport.__init__cCrf)z= The ICE gatherer passed in the constructor. )rrgr!r!r" iceGatherer rizRTCIceTransport.iceGatherercCs|jjrdSdS)zk The current role of the ICE transport. Either `'controlling'` or `'controlled'`. controlling controlled)r_rZrgr!r!r"roleszRTCIceTransport.rolecCrf)z9 The current state of the ICE transport. )rrgr!r!r"rhrizRTCIceTransport.state candidatecsN|jjs%|durd|j_|jdIdHdS|jt|IdHdSdS)z} Add a remote candidate. :param candidate: The new candidate or `None` to signal end of candidates. NT)rr`r_add_remote_candidater3)rbrr!r!r"addRemoteCandidate&sz"RTCIceTransport.addRemoteCandidatecCrp)zn Retrieve the list of candidates associated with the remote :class:`RTCIceTransport`. cSrqr!rrrsr!r!r"ru:rvz7RTCIceTransport.getRemoteCandidates..)r_remote_candidatesrgr!r!r"getRemoteCandidates5ryz#RTCIceTransport.getRemoteCandidatesremoteParameterscs|jdkr td|jdur|jIdHdSt|_t||_| d|j |j _ |j |j _|j|j _z |j IdHWntyR| dYnw| d|jdS)z Initiate connectivity checks. :param remoteParameters: The :class:`RTCIceParameters` associated with the remote :class:`RTCIceTransport`. closedzRTCIceTransport is closedNcheckingfailedrk)rhr rwaitasyncioEvent ensure_future_monitorr_RTCIceTransport__setStater&r_remote_is_liter$remote_usernamer%remote_passwordconnectConnectionErrorset)rbrr!r!r"start<s&         zRTCIceTransport.startcsN|jdkr#|d|jIdH|jdur%|jIdHd|_dSdSdS)zA Irreversibly stop the :class:`RTCIceTransport`. rN)rhrr_closerrgr!r!r"stopYs     zRTCIceTransport.stopcs8 |jIdH}t|tr|jdkr|ddSq)NTrkr)r_ get_eventrArrhr)rbeventr!r!r"rds   zRTCIceTransport._monitormsgargscGs tjd||jg|RdS)NzRTCIceTransport(%s) )loggerdebugr)rbrrr!r!r" __log_debugls zRTCIceTransport.__log_debugrhcCsP||jkr$|d|j|||_|d|dkr&|j|dSdSdS)Nz - %s -> %sr{r)r_RTCIceTransport__log_debugr|rremove_all_listenersr}r!r!r"r~os    zRTCIceTransport.__setStater)rrrrrVr]rrr rrhrr rrCrr#rrrobjectrrrr!r!rdr"rs     r)#rloggingre dataclassesrtypingrraioicerrr pyee.asyncior exceptionsr rtcconfigurationr compilerPrR getLoggerrrr r#r1r3rCdictr rMrDrVrr!r!r!r"s4     -#F