U ¹êW[¢“ã6@s’dZddlZddlZddlZddlmZmZddlmZddl m Z ddl m Z m Z mZddlmZddlmZdd lmZmZmZd Zd d d dddddddœ ZiZe ¡D]\ZZeee<q¬[[dddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;dd?d@dAdBdCdDdEdFdGdHd'dIœ5ZdJdKdLdMœZdNdO„ZdPdQ„Z e!ƒZ"GdRdS„dSe!ƒZ#dTdU„Z$GdVdW„dWƒZ%d|dXdY„Z&dZd[„Z'd}d\d]„Z(Gd^d_„d_e)ƒZ*Gd`da„dae*ƒZ+Gdbdc„dcƒZ,Gddde„dee,ƒZ-Gdfdg„dge,ƒZ.Gdhdi„diej/ƒZ0Gdjdk„dke j1ƒZ2Gdldm„dmeƒZ3Gdndo„doƒZ4Gdpdq„dqeƒZ5Gdrds„dseƒZ6Gdtdu„due2ƒZ7Gdvdw„dweƒZ8Gdxdy„dye7ƒZ9ee5e6ƒGdzd{„d{ƒƒZ:dS)~zP Session Initialization Protocol. Documented in RFC 2543. [Superseded by 3261] éN)Ú implementerÚ Interface)Ú OrderedDict)Úcred)ÚprotocolÚdeferÚreactor)Úbasic)Úlog)Ú_PY3Ú iteritemsÚunicodeiÄÚiÚmÚeÚlÚcÚfÚsÚtÚv) úcall-idÚcontactzcontent-encodingúcontent-lengthz content-typeÚfromZsubjectÚtoÚviaZTryingZRingingzCall Is Being ForwardedZQueuedzSession ProgressZOKzMultiple ChoiceszMoved PermanentlyzMoved Temporarilyz See Otherz Use ProxyzAlternative Servicez Bad RequestZ UnauthorizedzPayment RequiredZ Forbiddenz Not FoundzMethod Not AllowedzNot AcceptablezProxy Authentication RequiredzRequest TimeoutZConflictZGonezLength RequiredzRequest Entity Too LargezRequest-URI Too LargezUnsupported Media TypezUnsupported URI Schemez Bad ExtensionzExtension RequiredzInterval Too BriefzTemporarily UnavailablezCall/Transaction Does Not Existz Loop Detectedz Too Many HopszAddress IncompleteZ Ambiguousz Busy HerezRequest TerminatedzNot Acceptable HerezRequest PendingZUndecipherablezInternal Server ErrorzNot Implementedz Bad GatewayzService UnavailablezServer Time-outzSIP Version not supportedzMessage Too LargezBusy EverywhereZDeclinezDoes not exist anywhere)5édé´éµé¶é·éÈi,i-i.i/i1i|éé‘i’i“é”i•i–i—i˜i™iši›iižiŸi i¤i¥i§iàiáiâiãiäiåiæiçièiëiíéôéõiöi÷iøiùiiXi[i\i^ZCSeqzCall-IDzWWW-Authenticate)Úcseqrúwww-authenticatecCsd dd„| d¡Dƒ¡S)zK Capitalize a string, making sure to treat '-' as a word separator ú-cSsg|] }| ¡‘qS©)Ú capitalize)Ú.0Úxr+r+ú7/usr/lib/python3/dist-packages/twisted/protocols/sip.pyÚ tsz"dashCapitalize..)ÚjoinÚsplit©rr+r+r/ÚdashCapitalizepsr4cCs0|d|dkrdkr,nn |dd…S|S)Nréÿÿÿÿú"ér+r3r+r+r/Úunqxs  r8c@sLeZdZdZeddddeddfdd„Zdd„Zd d „Ze eeƒZ d d „Z dS) ÚViaa‡ A L{Via} is a SIP Via header, representing a segment of the path taken by the request. See RFC 3261, sections 8.1.1.7, 18.2.2, and 20.42. @ivar transport: Network protocol used for this leg. (Probably either "TCP" or "UDP".) @type transport: C{str} @ivar branch: Unique identifier for this request. @type branch: C{str} @ivar host: Hostname or IP for this leg. @type host: C{str} @ivar port: Port used for this leg. @type port C{int}, or None. @ivar rportRequested: Whether to request RFC 3581 client processing or not. @type rportRequested: C{bool} @ivar rportValue: Servers wishing to honor requests for RFC 3581 processing should set this parameter to the source port the request was received from. @type rportValue: C{int}, or None. @ivar ttl: Time-to-live for requests on multicast paths. @type ttl: C{int}, or None. @ivar maddr: The destination multicast address, if any. @type maddr: C{str}, or None. @ivar hidden: Obsolete in SIP 2.0. @type hidden: C{bool} @ivar otherParams: Any other parameters in the header. @type otherParams: C{dict} ZUDPNFc Ks˜||_||_||_||_||_||_|dkrJtjdtddd|_ d|_ n8|dkr`d|_ d|_ n"|t krvd|_ d|_ n ||_ d|_ ||_ | |_ | |_dS)a( Set parameters of this Via header. All arguments correspond to attributes of the same name. To maintain compatibility with old SIP code, the 'rport' argument is used to determine the values of C{rportRequested} and C{rportValue}. If None, C{rportRequested} is set to True. (The deprecated method for doing this is to pass True.) If an integer, C{rportValue} is set to the given value. Any arguments not explicitly named here are collected into the C{otherParams} dict. Tz+rport=True is deprecated since Twisted 9.0.é)Ú stacklevelNF)Ú transportÚhostÚportÚttlÚhiddenÚreceivedÚwarningsÚwarnÚDeprecationWarningÚ rportValueÚrportRequestedÚ_absentÚbranchÚmaddrÚ otherParams) Úselfr=r>r<r?r@rAÚrportrHrIÚkwr+r+r/Ú__init__¢s2ýz Via.__init__cCs&|jdkrdS|jdk r|jSdSdS)zG Returns the rport value expected by the old SIP code. TN)rFrE©rKr+r+r/Ú _getrportÎs   z Via._getrportcCs||_d|_dS)z L{Base._fixupNAT} sets C{rport} directly, so this method sets C{rportValue} based on that. @param newRPort: The new rport value. @type newRPort: C{int} FN)rErF)rKZnewRPortr+r+r/Ú _setrportÚsz Via._setrportcCs¾d|j|j|jf}|jr"|d7}dD]&}t||ƒ}|dk r&|d||f7}q&|jr^|d7}n|jdk rx|d|jf7}t|j   ¡ƒ}|D].\}}|dkr¨|d|7}qŠ|d||f7}qŠ|S) zI Serialize this header for use in a request or response. zSIP/2.0/%s %s:%sz;hidden)r?rHrIrANú;%s=%sz;rportz ;rport=%sú;) r<r=r>r@ÚgetattrrFrErLÚsortedrJÚitems)rKrÚnÚvalueÚetcÚkrr+r+r/ÚtoStringçs"    z Via.toString) Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚPORTrGrNrPrQÚpropertyrLr[r+r+r+r/r9s þ ,  r9cCsL| d¡}|d|dd…}}| dd¡\}}| ¡}i}| d¡\}}} |dks\|dkrjtd |fƒ‚| |d <d |krž| d ¡\} } t| ƒ|d <| |d <n||d <|D]–} |  ¡ dd¡} t| ƒdkrÚ| dd} } n| \} } | dkrôd|d<qª|  dd¡}t|ƒdkr|dd}}n|\}}|dkr8t|ƒ}|||<qªtf|ŽS)za Parse a Via header. @return: The parsed version of this header. @rtype: L{Via} rSrr7Nú ú/ZSIPz2.0zwrong protocol or version: %rr<ú:r>r=Úr@Tú=)rLr?)r2ÚstripÚ ValueErrorÚintÚlenr9)rXÚpartsZsentÚparamsZ protocolinfoZbyÚresultZpnameZpversionr<r=r>ÚpZcommentÚnamer+r+r/ÚparseViaHeaders<       rpc @s2eZdZdZd dd„Zdd„Zdd„Zd d „ZdS) ÚURLz A SIP URL. Nc Csl||_||_||_||_||_||_||_| |_||_| |_ | dkrLg|_ n| |_ | dkrbi|_ n| |_ dS©N) Úusernamer=Úpasswordr>r<ÚusertypeÚmethodÚtagr?rIÚotherÚheaders) rKr=rsrtr>r<rurvr?rIrwrxryr+r+r/rN2s z URL.__init__cCsúg}|j}|dƒ|jdkrF||jƒ|jdkr>|d|jƒ|dƒ||jƒ|jdkrh|d|jƒ|jdkr€|d|jƒdD]&}t||ƒ}|dkr„|d||fƒq„|jD]}|d|ƒq²|jrð|d ƒ|d   d d „|j  ¡Dƒ¡ƒd   |¡S)Núsip:z:%sú@z:%dz;user=%s©r<r?rIrvrwrRz;%sú?ú&cSs*g|]"\}}dt |¡pt|ƒ|f‘qS)z%s=%s)Ú specialCasesÚgetr4)r-Úhrr+r+r/r0^sz URL.toString..re) Úappendrsrtr=r>rurTrxryr1rV)rKrÚwrWrr+r+r/r[Is.        z URL.toStringcCs| ¡Srr)r[rOr+r+r/Ú__str__bsz URL.__str__cCsd|j|j|j|j|jfS)Nz)rsrtr=r>r<rOr+r+r/Ú__repr__fsz URL.__repr__) NNNNNNNNNNN)r\r]r^r_rNr[r„r…r+r+r+r/rq-sþ rqcCsi}| d¡s"td|dd…ƒ‚|dd… d¡}|d|dd…}}| dd¡}t|ƒd krª|\}} | d d¡} t| ƒdkr| d|d <q²| d|d <| d|d <n|d} |  d d¡} t| ƒdkrØ| d|d <n| d|d <t| dƒ|d<|dkr||d <|dkr||d<|D]æ} | |dkr|d| kr|i|d<} |  dd¡\} }| d¡D]}| d¡\}}|| |<q^|  dd¡}t|ƒdkr¬| dg¡ | ¡q|\}}|dkrÈ||d<n8|dkrî|dkrät|ƒ}|||<n| dg¡ | ¡qtf|ŽS)zV Return string into URL object. URIs are of form 'sip:user@example.com'. rzzunsupported scheme: NérSrr7r{r:rdrsrtr=r>r5r}ryr~rfrxÚuserrur|r?)Ú startswithrhr2rjriÚ setdefaultr‚rq)Úurlr=r>ÚdrkZ userdomainrlZudpartsZuserpassZhostportZuppartsZhppartsrnrryÚheaderrZrZnvrorXr+r+r/ÚparseURLksV                   rcCsd|_d|_d|_i|_dS)z* Clean a URL from a Request line. N)r<rIr?ry)rŠr+r+r/ÚcleanRequestURL£srŽc Csê| ¡}| d¡r&dt|||difSi}| dd¡\}}| ¡}| d¡rX|dd…}| d¡rn|dd…}| d d¡\}}t|||d}| ¡}|rÄ| d ¡D] }|s¬q¢| d ¡\} } | || <q¢|ràd|_i|_d|_d|_|||fS) z Return (name, uri, params) for From/To/Contact header. @param clean: remove unnecessary info, usually for From and To headers. rzre©r=r>úrSrf) rgrˆrr2Úendswithr?ryr<rI) Zaddressr=r>ÚcleanrlrorŠZ paramstringrrZrr+r+r/Ú parseAddress®s2      r”c@seZdZddd„ZdS)ÚSIPErrorNcCs4|dkrt|}t |d||f¡||_||_dS)NzSIP error (%d): %s)Ú statusCodesÚ ExceptionrNÚcodeÚphrase)rKr˜r™r+r+r/rNÓs zSIPError.__init__)N©r\r]r^rNr+r+r+r/r•Òsr•c@seZdZdZdS)ÚRegistrationErrorz( Registration was not possible. N©r\r]r^r_r+r+r+r/r›Üsr›c@sDeZdZdZdZdd„Zdd„Zdd„Zd d „Zd d „Z d d„Z dS)ÚMessagez A SIP message. NcCstƒ|_d|_d|_dS)Nrer)rryÚbodyÚfinishedrOr+r+r/rNêszMessage.__init__cCs>| ¡}t ||¡}|dkr&t|ƒ|_|j |g¡ |¡dS)Nr)ÚlowerÚ longHeadersr€riÚlengthryr‰r‚)rKrorXr+r+r/Ú addHeaderðs   zMessage.addHeadercCs|j|7_dSrr)rž©rKÚdatar+r+r/ÚbodyDataReceivedøszMessage.bodyDataReceivedcCs,|jdkr"|jt|jƒkr"tdƒ‚d|_dS)Nzwrong body lengthr7)r¢rjržrhrŸrOr+r+r/ÚcreationFinishedüszMessage.creationFinishedcCs^d| ¡}|j ¡D]0\}}|D]"}|dt |¡p:t|ƒ|f7}q"q|d7}||j7}|S)Nz%s z%s: %s z )Ú_getHeaderLineryrVrr€r4rž)rKrrWZvsrr+r+r/r[s " zMessage.toStringcCst‚dSrr©ÚNotImplementedErrorrOr+r+r/r¨ szMessage._getHeaderLine) r\r]r^r_r¢rNr£r¦r§r[r¨r+r+r+r/rãs rc@s*eZdZdZd dd„Zdd„Zdd„Zd S) ÚRequestz A Request for a URI úSIP/2.0cCs:t |¡||_t|tƒr"||_nt|ƒ|_t|jƒdSrr)rrNrvÚ isinstancerqÚurirrŽ)rKrvr®Úversionr+r+r/rNs    zRequest.__init__cCsdt|ƒ|j|j ¡fS)Nz)Úidrvr®r[rOr+r+r/r… szRequest.__repr__cCsd|j|j ¡fS)Nz %s %s SIP/2.0)rvr®r[rOr+r+r/r¨$szRequest._getHeaderLineN)r¬©r\r]r^r_rNr…r¨r+r+r+r/r«s r«c@s*eZdZdZd dd„Zdd„Zdd „ZdS) ÚResponsez% A Response to a URI Request Nr¬cCs*t |¡||_|dkr t|}||_dSrr)rrNr˜r–r™)rKr˜r™r¯r+r+r/rN.s  zResponse.__init__cCsdt|ƒ|jfS)Nz)r°r˜rOr+r+r/r…6szResponse.__repr__cCsd|j|jfS)Nz SIP/2.0 %s %s)r˜r™rOr+r+r/r¨:szResponse._getHeaderLine)Nr¬r±r+r+r+r/r²)s r²c@sxeZdZdZdZdZdZdZdZdd„Z dd d „Z d d „Z d d„Z dd„Z dd„Zdd„Zdd„Zddd„Zdd„ZdS)ÚMessagesParserz A SIP messages parser. Expects dataReceived, dataDone repeatedly, in that order. Shouldn't be connected to actual transport. r¬r7Ú firstlinercCs||_| ¡dSrr)ÚmessageReceivedÚreset)rKZmessageReceivedCallbackr+r+r/rNNszMessagesParser.__init__recCs,d|_d|_d|_d|_d|_| |¡dS)Nr´r)Ústater¢Ú bodyReceivedÚmessagerŒZ setLineMode©rKZ remainingDatar+r+r/r¶Ss zMessagesParser.resetcCsd|_| ¡dS)NÚinvalid)r·Ú setRawModerOr+r+r/ÚinvalidMessage\szMessagesParser.invalidMessagecCsb| ¡|jdkrdS|jdkr,| ¡dS|jdkr@| ¡n|j|jkrV| ¡ntdƒ‚dS)zI Clear out any buffered data that may be hanging around. r´Nržzthis should never happen)ZclearLineBufferr·r¶r¢Ú messageDoner¸Ú RuntimeErrorrOr+r+r/ÚdataDoneas      zMessagesParser.dataDonecCsHz&t|tƒr| d¡}tj ||¡Wnt ¡| ¡YnXdS)Núutf-8) r­r Úencoder Ú LineReceiverÚ dataReceivedr Úerrr½r¤r+r+r/rÄvs  zMessagesParser.dataReceivedcCst‚dS)z2 Expected to create self.message. Nr©©rKÚliner+r+r/ÚhandleFirstLine€szMessagesParser.handleFirstLinecCs | ¡dSrr)r½rÆr+r+r/ÚlineLengthExceeded‡sz!MessagesParser.lineLengthExceededcCs4trt|tƒr| d¡}|jdkrþ| d¡s8| d¡rF|dd…}q$|sNdSz| dd¡\}}}Wntk r‚| ¡YdSX|dkrÌ|j rÌz t |ƒ}Wntk r¼| ¡YdSXt ||ƒ|_ n(|dkrè|j rèt||ƒ|_ n | ¡dSd |_dS|jd kst‚|rî| d¡s,| d ¡rJ|j\}}||| ¡f|_n¢|jrf|j j|jŽd|_z| d d¡\}}Wn tk rš| ¡YdSX|| ¡f|_| ¡d kr0zt | ¡ƒ|_Wn tk rê| ¡YdSXnBd |_|jr|j j|jŽd|_|jdkr(| ¡dS| ¡dS)NrÁr´Ú ú r7rbr:r¬ryú rdrržr)r r­ÚbytesÚdecoder·rˆr2rhr½ÚacceptResponsesrir²r¹ÚacceptRequestsr«ÚAssertionErrorrŒÚlstripr£r r¢r¾r¼)rKrÇÚaÚbrr˜rorXr+r+r/Ú lineReceived‹sj      zMessagesParser.lineReceivedcCs2|jdkst‚|j ¡| |j¡| |¡dS)Nrž)r·rÑr¹r§rµr¶rºr+r+r/r¾Ïs  zMessagesParser.messageDonecCsÄ|jdkst‚tr&t|tƒr&| d¡}|jdkr4dS|jdkrL|j |¡ntt |ƒ}|j|j }||kr’|j |d|…¡|  ||d…¡dS|j |7_ |j |¡|j |jkrÀ|  ¡dS)N)ržr»rÁr») r·rÑr r­rÍrÎr¢r¹r¦rjr¸r¾)rKr¥ZdataLenZ expectedLenr+r+r/ÚrawDataReceivedÖs"      zMessagesParser.rawDataReceivedN)re)re)r\r]r^r_r¯rÏrÐr·ÚdebugrNr¶r½rÀrÄrÈrÉrÕr¾rÖr+r+r+r/r³?s   D r³c@s`eZdZdZeZdZdd„Zdd„Zdd„Zd d „Z d d „Z d d„Z dd„Z dd„Z dd„ZdS)ÚBasez1 Base class for SIP clients and servers. FcCsg|_t|jƒ|_dSrr)Úmessagesr³Ú addMessageÚparserrOr+r+r/rNõsz Base.__init__cCs|j |¡dSrr)rÙr‚)rKÚmsgr+r+r/rÚúszBase.addMessagecCs€|j |¡|j ¡|jD]P}| ||¡|jrHt d| ¡|f¡t |t ƒr`|  ||¡q|  ||¡qg|jdd…<dS)NzReceived %r from %r) rÛrÄrÀrÙÚ _fixupNATr×r rÜr[r­r«Úhandle_requestÚhandle_response)rKr¥Úaddrrr+r+r/ÚdatagramReceivedþs     zBase.datagramReceivedcCsz|\}}t|jddƒ}|j|krN||_|j|kr:||_| ¡|jdd<n(|jdkrv||_||_| ¡|jdd<dS)NrrT)rpryr=rAr>rLr[)rKr¹Ú sourcePeerÚsrcHostÚsrcPortZ senderViar+r+r/rÝ s   zBase._fixupNATcCsLt|jddƒ}|jp|j}|jp.|jp.|j}t||d}| ||¡dS©zX Deliver response. Destination is based on topmost Via header. rrrN© rpryrAr=rLr>r`rqÚ sendMessage©rKZresponseMessageZdestViar=r>ZdestAddrr+r+r/ÚdeliverResponses   zBase.deliverResponsecCs2t|ƒ}dD] }|j |g¡dd…|j|<q |S©z9 Create a response to a request message. )rrrrr(N©r²ryr€©rKr˜ZrequestÚresponseror+r+r/ÚresponseFromRequest)szBase.responseFromRequestcCsj|jdkrtdƒ‚|jr.t d| ¡|f¡| ¡}t|tƒrJ| d¡}|j  ||j |j p`|j f¡dS)z£ Send a message. @param destURL: C{URL}. This should be a *physical* URL, not a logical one. @param message: The message to send. )ZudpNzonly UDP currently supportedzSending %r to %rrÁN) r<r¿r×r rÜr[r­r rÂÚwriter=r>r`)rKZdestURLr¹r¥r+r+r/rç4s   zBase.sendMessagecCst‚dS)zƒ Override to define behavior for requests received @type message: C{Message} @type addr: C{tuple} Nr©©rKr¹ràr+r+r/rÞEszBase.handle_requestcCst‚dS)z… Override to define behavior for responses received. @type message: C{Message} @type addr: C{tuple} Nr©rðr+r+r/rßOszBase.handle_responseN)r\r]r^r_r`r×rNrÚrárÝrérîrçrÞrßr+r+r+r/rØís  rØc@seZdZdZdS)ÚIContactz( A user of a registrar or proxy Nrœr+r+r+r/rñZsrñc@seZdZdd„ZdS)Ú RegistrationcCs||_||_dSrr)ÚsecondsToExpiryÚ contactURL)rKrórôr+r+r/rNbszRegistration.__init__Nršr+r+r+r/ròasròc@s(eZdZdZdd„Zdd„Zdd„ZdS) Ú IRegistryz? Allows registration of logical->physical URL mapping. cCsdS)z’ Register the physical address of a logical URL. @return: Deferred of C{Registration} or failure with RegistrationError. Nr+©Ú domainURLÚ logicalURLÚ physicalURLr+r+r/ÚregisterAddressmszIRegistry.registerAddresscCsdS)z” Unregister the physical address of a logical URL. @return: Deferred of C{Registration} or failure with RegistrationError. Nr+rör+r+r/ÚunregisterAddressuszIRegistry.unregisterAddresscCsdS)zˆ Get registration info for logical URL. @return: Deferred of C{Registration} object or failure of LookupError. Nr+©rør+r+r/ÚgetRegistrationInfo}szIRegistry.getRegistrationInfoN)r\r]r^r_rúrûrýr+r+r+r/rõhsrõc@seZdZdZdd„ZdS)ÚILocatorz< Allow looking up physical address for logical URL. cCsdS)z½ Return physical URL of server for logical URL of user. @param logicalURL: a logical C{URL}. @return: Deferred which becomes URL or fails with LookupError. Nr+rür+r+r/Ú getAddress‹szILocator.getAddressN)r\r]r^r_rÿr+r+r+r/rþ†srþc@sfeZdZdZeZdZdefdd„Zdd„Zdd„Zd d „Z d d „Z d d„Z dd„Z dd„Z dd„ZdS)ÚProxyz SIP proxy. NcCs"|p t ¡|_||_t |¡dS)z˜ Create new instance. @param host: our hostname/IP as set in Via headers. @param port: our port as set in Via headers. N)ÚsocketZgetfqdnr=r>rØrN)rKr=r>r+r+r/rNžszProxy.__init__cCst|j|jdS)z< Return value of Via header for this proxy. r)r9r=r>rOr+r+r/ÚgetViaªsz Proxy.getViac sªtˆdˆjdƒ}|dkr ˆj}z|ˆ|ƒ}WnZtk rd}zˆ ˆ |jˆ¡¡W5d}~XYnBt ¡ˆ ˆ dˆ¡¡YnX|dk r¦|  ‡‡fdd„¡dS)Nzhandle_%s_requestr&csˆ ˆ |jˆ¡¡Srr)rérîr˜)r©r¹rKr+r/ÚÀsz&Proxy.handle_request..) rTrvÚhandle_request_defaultr•rérîr˜r rÅÚ addErrback)rKr¹ràrr‹rr+rr/rÞ±s$zProxy.handle_requestc sš|\}}‡fdd„}ˆ ¡}| ¡|jdkr._mungContactHeaderrzDropping looped message.Nrrr7©r“) rr[ryr rÜÚinsertr”ÚlocatorrÿÚ addCallbackrçrÚ_cantForwardRequest) rKr¹rârãrärZ viaHeaderror®Ztagsr‹r+rOr/rÅs    zProxy.handle_request_defaultcCs,| t¡|jdd=| | d|¡¡dS)Nrrr%)ÚtrapÚ LookupErrorryrérî©rKÚerrorr¹r+r+r/r ãs  zProxy._cantForwardRequestcCsLt|jddƒ}|jp|j}|jp.|jp.|j}t||d}| ||¡dSrårærèr+r+r/réés   zProxy.deliverResponsecCs2t|ƒ}dD] }|j |g¡dd…|j|<q |Srêrërìr+r+r/rîøszProxy.responseFromRequestcCslt|jddƒ}|j|jf|j|jfkr8t d¡dS|jdd=|jds^| ||¡dS| |¡dS)z+ Default response handler. rrz&Dropping incorrectly addressed messageN)rpryr=r>r rÜÚ gotResponseré)rKr¹ràrr+r+r/rßs    zProxy.handle_responsecCsdS)zJ Called with responses that are addressed at this server. Nr+rðr+r+r/rszProxy.gotResponse)r\r]r^r_r`r rNrrÞrr rérîrßrr+r+r+r/r•s  rc@seZdZdd„Zdd„ZdS)Ú IAuthorizercCsdS)zÇ Generate a challenge the client may respond to. @type peer: C{tuple} @param peer: The client's address @rtype: C{str} @return: The challenge string Nr+)Zpeerr+r+r/Ú getChallengeszIAuthorizer.getChallengecCsdS)zf Create a credentials object from the given response. @type response: C{str} Nr+)rír+r+r/rÎ*szIAuthorizer.decodeN)r\r]r^rrÎr+r+r+r/rs rc@s„eZdZdZdZdZiZdd„Zdd„Zdd„Z d d „Z d d „Z d d„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd„Zdd„ZdS)Ú RegisterProxyzk A proxy that allows registration for a specific domain. Unregistered users won't be handled. NcOstj|f|ž|Ži|_dSrr)rrNZliveChallenges)rKÚargsrMr+r+r/rN@szRegisterProxy.__init__cCs |\}}dSrrr+©rKr¹Z host_portr=r>r+r+r/Úhandle_ACK_requestEsz RegisterProxy.handle_ACK_requestcCsL|\}}|jdkr"| |||¡n&d|jkr:| |||¡S| |||¡SdS)z` Handle a registration request. Currently registration is not proxied. NÚ authorization)ÚportalÚregisterryÚ unauthorizedÚloginrr+r+r/Úhandle_REGISTER_requestOs   z%RegisterProxy.handle_REGISTER_requestc Cs€| d|¡}t|jƒD]Z\}}| ||f¡}|dkrHd| ¡|jf}nd| ¡||jf}|j dg¡ |¡q|  |¡dS)Nr$z %s realm="%s"z%s %s,realm="%s"r)) rîr Ú authorizersrÚtitler=ryr‰r‚ré) rKr¹r=r>rZschemeZauthZchalrXr+r+r/ras zRegisterProxy.unauthorizedc CsÜ|jdd dd¡}|j |d ¡¡}|rÆz| |d¡}Wn:tk rV‚YqØt ¡|  |  d|¡¡YqØX|j d|j 7_ |j  |dt¡ |j|||¡ |j|||¡ tj¡n|  |  d|¡¡dS)Nrrr7r&r{r')ryr2rr€r rÎr•r rÅrérîrsr=rrrñr Ú_cbLoginrÚ_ebLogin)rKr¹r=r>rkrÓrr+r+r/rms2ÿþýzRegisterProxy.logincCs|\}}}| |||¡dSrr)r)rKZi_a_lr¹r=r>rrÓrr+r+r/r ƒs zRegisterProxy._cbLogincCs | tjj¡| |||¡dSrr)r rrZUnauthorizedLoginr)rKZfailurer¹r=r>r+r+r/r!‰szRegisterProxy._ebLoginc Csºt|jdddd\}}}d}d|jkr8|jdd}|j ddg¡ddkr`| |||¡nV|dk rt|||d \}}}|j |j||¡} n |j |¡} | j|j |j |f|fd dS) z- Allow all users to register rrr7rNrÚexpiresÚ0r)Z callbackArgsZ errbackArgs) r”ryr€Ú unregisterÚregistryrúr®rýZ addCallbacksÚ _cbRegisterÚ _ebRegister) rKr¹r=r>roÚtoURLrlrrôr‹r+r+r/rŽs   þzRegisterProxy.registercCsT| d|¡}|jdkr:| d|j ¡¡| dd|j¡| dd¡| |¡dS)Nr"rr"z%drr#)rîrôr£r[róré)rKÚ registrationr¹rír+r+r/r&§s    zRegisterProxy._cbRegistercCs| tt¡dSrr)r r›rrr+r+r/r'°szRegisterProxy._ebRegisterc Cszt|jddƒ}Wn&tk r<| | d|¡¡YnPX|dkrŒ|dkrTd}nt|ƒ\}}}|j |j||¡}|  |j |¡  |j |¡dS)Nr"rr#Ú*) riryrhrérîr”r%rûr®r Ú _cbUnregisterrÚ _ebUnregister) rKr¹r(rr"rôrorlr‹r+r+r/r$¶sÿzRegisterProxy.unregistercCs@| d|¡}|j dg¡ |j ¡¡| dd¡| |¡dS)Nr"rr"r#)rîryr‰r‚rôr[r£ré)rKr)r¹rÜr+r+r/r+Çs  zRegisterProxy._cbUnregistercCsdSrrr+)rKr)r¹r+r+r/r,ÎszRegisterProxy._ebUnregister)r\r]r^r_rr%rrNrrrrr r!rr&r'r$r+r,r+r+r+r/r3s"   rc@s@eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dS)ÚInMemoryRegistryz6 A simplistic registry for a specific domain. cCs||_i|_dSrr)ÚdomainÚusers)rKr.r+r+r/rNØszInMemoryRegistry.__init__cCsR|j|jkrt tdƒ¡S|j|jkr@|j|j\}}t |¡St tdƒ¡SdS©Nzunknown domainú no such user)r=r.rÚfailrrsr/Úsucceed©rKZuserURIÚdcrŠr+r+r/rÿÝs    zInMemoryRegistry.getAddresscCsh|j|jkrt tdƒ¡S|j|jkrV|j|j\}}t tt |  ¡t   ¡ƒ|ƒ¡St tdƒ¡SdSr0) r=r.rr2rrsr/r3ròriÚgetTimeÚtimer4r+r+r/rýçs    z$InMemoryRegistry.getRegistrationInfocCsVz|j|\}}Wn"tk r4t tdƒ¡YSX| ¡|j|=t td|ƒ¡S)Nr1r)r/ÚKeyErrorrr2rZcancelr3rò)rKrsr5rŠr+r+r/Ú_expireRegistrationñsz$InMemoryRegistry._expireRegistrationcCsÌ|j|jkr$t d¡t tdƒ¡S|j|jkrHt d¡t tdƒ¡S|j|jkrp|j|j\}}|  d¡nt   d|j |j¡}t d|  ¡|  ¡f¡||f|j|j<t tt| ¡t ¡ƒ|ƒ¡S)Nz(Registration for domain we don't handle.r%izRegistered %s at %s)r=r.r rÜrr2r›rsr/r¶rZ callLaterr9r[r3ròrir6r7)rKr÷rørùr5Úoldr+r+r/rúüs      z InMemoryRegistry.registerAddresscCs | |j¡Srr)r9rs)rKr÷rørùr+r+r/rû sz"InMemoryRegistry.unregisterAddressN) r\r]r^r_rNrÿrýr9rúrûr+r+r+r/r-Ós   r-)NN)NNr);r_rr7rBZzope.interfacerrÚ collectionsrZtwistedrZtwisted.internetrrrZtwisted.protocolsr Ztwisted.pythonr Ztwisted.python.compatr r r r`Z shortHeadersr¡rVrZrr–rr4r8ÚobjectrGr9rprqrrŽr”r—r•r›rr«r²rÃr³ZDatagramProtocolrØrñròrõrþrrrr-r+r+r+r/Úsà    ø  Æ>ý,> 8 $ ./m !