a )(b@sddgZddlmZddlmZmZddlmZmZm Z m Z ddl m Z ddl mZmZddlmZGd ddejZGd dde Zd S) SecondaryAuthoritySecondaryAuthorityService)service)defertask)clientcommondnsresolve) FileAuthority)failurelog) nativeStringc@sDeZdZdZdZdZddZeddZdd Z d d Z d d Z dS)ra: A service that keeps one or more authorities up to date by doing hourly zone transfers from a master. @ivar primary: IP address of the master. @type primary: L{str} @ivar domains: An authority for each domain mirrored from the master. @type domains: L{list} of L{SecondaryAuthority} N5cs"t|_fdd|D|_dS)a @param primary: The IP address of the server from which to perform zone transfers. @type primary: L{str} @param domains: A sequence of domain names for which to perform zone transfers. @type domains: L{list} of L{bytes} csg|]}t|qS)r.0dprimaryr6lib/python3.9/site-packages/twisted/names/secondary.py +z6SecondaryAuthorityService.__init__..N)rrdomains)selfrrrrr__init__ s z"SecondaryAuthorityService.__init__cs0\}}||g}||_fdd|D|_|S)a Construct a new L{SecondaryAuthorityService} from a tuple giving a server address and a C{str} giving the name of a domain for which this is an authority. @param serverAddress: A two-tuple, the first element of which is a C{str} giving an IP address and the second element of which is a C{int} giving a port number. Together, these define where zone transfers will be attempted from. @param domains: Domain names for which to perform zone transfers. @type domains: sequence of L{bytes} @return: A new instance of L{SecondaryAuthorityService}. csg|]}t|qSr)rfromServerAddressAndDomainr serverAddressrrrAszISecondaryAuthorityService.fromServerAddressAndDomains..)_portr)clsrrrportrrrrfromServerAddressAndDomains-s  z5SecondaryAuthorityService.fromServerAddressAndDomainscCs t|jS)z_ Get a resolver for the transferred domains. @rtype: L{ResolverChain} )r Z ResolverChainrrrrr getAuthorityGsz&SecondaryAuthorityService.getAuthoritycCsVtj|dd|jD|_d}ddlm}|jD]}|||jd|d7}q4dS)NcSsg|]}t|jqSr)rZ LoopingCalltransferrrrrrQrz:SecondaryAuthorityService.startService..rreactori) rService startServicercallstwisted.internetr'Z callLaterstart)rir'crrrr*Os   z&SecondaryAuthorityService.startServicecCs$tj||jD] }|qdSN)rr) stopServicer+stop)rr/rrrr1Zs  z%SecondaryAuthorityService.stopService) __name__ __module__ __qualname____doc__r+rr classmethodr"r$r*r1rrrrrs    c@sreZdZdZdZdZZdZdZddZ e ddZ d d Z dd d Z d dZddZddZddZddZdS)ra An Authority that keeps itself updated by performing zone transfers. @ivar primary: The IP address of the server from which zone transfers will be attempted. @type primary: L{str} @ivar _port: The port number of the server from which zone transfers will be attempted. @type _port: L{int} @ivar domain: The domain for which this is the secondary authority. @type domain: L{bytes} @ivar _reactor: The reactor to use to perform the zone transfers, or L{None} to use the global reactor. FNrcCs&tj|t||_t||_dS)z @param domain: The domain for which this will be the secondary authority. @type domain: L{bytes} or L{str} N)rZ ResolverBaserrrr Z domainStringdomain)rZ primaryIPr8rrrrxs  zSecondaryAuthority.__init__cCs|\}}|||}||_|S)af Construct a new L{SecondaryAuthority} from a tuple giving a server address and a C{bytes} giving the name of a domain for which this is an authority. @param serverAddress: A two-tuple, the first element of which is a C{str} giving an IP address and the second element of which is a C{int} giving a port number. Together, these define where zone transfers will be attempted from. @param domain: A C{bytes} giving the domain to transfer. @type domain: L{bytes} @return: A new instance of L{SecondaryAuthority}. )r)r rr8rr!Z secondaryrrrrs z-SecondaryAuthority.fromServerAddressAndDomaincCs^|jr dSd|_|j}|dur*ddlm}tj|j|jfg|d}| |j  |j  |jS)z Attempt a zone transfer. @returns: A L{Deferred} that fires with L{None} when attempted zone transfer has completed. NTrr&)Zserversr') transferringZ transfering_reactorr,r'rZResolverrrZ lookupZoner8Z addCallback_cbZoneZ addErrback_ebZone)rr'Zresolverrrrr%s   zSecondaryAuthority.transfercCs4|jr |js"ttt|St |||||Sr0) soarecordsrZfailr ZFailurer Z DomainErrorr _lookup)rnamer typeZtimeoutrrrr?s zSecondaryAuthority._lookupcCsf|\}}}i|_}|D]H}|jsD|jtjkrD|jj|jf|_q||jjg |jqdSr0) r>r=rAr ZSOAr@lowerZpayload setdefaultappend)rZzoneZans_rZrecrrrr;s   zSecondaryAuthority._cbZonecCs$td|j|jft|dS)Nz/Updating %s from %s failed during zone transfer)r msgr8rerrrr rrrr<s  zSecondaryAuthority._ebZonecCs||j|jdSr0)r%Z addCallbacks_cbTransferred_ebTransferredr#rrrupdateszSecondaryAuthority.updatecCs d|_dS)NF)r9)rresultrrrrJsz!SecondaryAuthority._cbTransferredcCs*d|_td|j|jft|dS)NFz2Transferring %s from %s failed after zone transfer)Z transferredr rGr8rrHrIrrrrKs z!SecondaryAuthority._ebTransferred)N)r3r4r5r6r9r=r>rr:rr7rr%r?r;r<rLrJrKrrrrr`s    N)__all__Ztwisted.applicationrr,rrZ twisted.namesrrr r Ztwisted.names.authorityr Ztwisted.pythonr r Ztwisted.python.compatrr)rrrrrrs   P