tfddgZddlmZddlmZmZddlmZmZm Z m Z ddl m Z ddl mZmZddlmZGd dejZGd de Zd S) SecondaryAuthoritySecondaryAuthorityService)service)defertask)clientcommondnsresolve) FileAuthority)failurelog) nativeStringcHeZdZdZdZdZdZedZdZ dZ dZ 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} N5cVt|_fd|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} c0g|]}t|S)r).0dprimarys V/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/names/secondary.py z6SecondaryAuthorityService.__init__..+s$HHH1*7A66HHHN)rrdomains)selfrrs ` r__init__z"SecondaryAuthorityService.__init__ s3$G,, HHHHHHH rc^\}}||g}||_fd|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}. cFg|]}t|Sr)rfromServerAddressAndDomain)rr serverAddresss rrzISecondaryAuthorityService.fromServerAddressAndDomains..As9     9 9- K K   r)_portr)clsr!rrportrs ` rfromServerAddressAndDomainsz5SecondaryAuthorityService.fromServerAddressAndDomains-sW"& #gr""        rc4tj|jS)z_ Get a resolver for the transferred domains. @rtype: L{ResolverChain} )r ResolverChainrrs r getAuthorityz&SecondaryAuthorityService.getAuthorityGs $T\222rctj|d|jD|_d}ddlm}|jD]#}|||jd|dz }$dS)Nc@g|]}tj|jSr)r LoopingCalltransfer)rrs rrz:SecondaryAuthorityService.startService..Qs%IIIqd&qz22IIIrrreactori) rService startServicercallstwisted.internetr/ callLaterstart)rir/cs rr2z&SecondaryAuthorityService.startServiceOs$$T***IIDLIII ,,,,,,  A   a' 2 2 2 FAA  rctj||jD]}|dSN)rr1 stopServicer3stop)rr8s rr;z%SecondaryAuthorityService.stopServiceZsB##D)))  A FFHHHH  r) __name__ __module__ __qualname____doc__r3r"r classmethodr%r)r2r;rrrrrs   E E I I I[2333   rcneZdZdZdZdxZZdZdZdZ e dZ dZ ddZ d Zd Zd Zd Zd ZdS)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. FNrctj|t||_t j||_dS)z @param domain: The domain for which this will be the secondary authority. @type domain: L{bytes} or L{str} N)r ResolverBaserrrr domainStringdomain)r primaryIPrFs rrzSecondaryAuthority.__init__xs@ $$T***#I.. &v.. rc6|\}}|||}||_|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#r!rFrr$ secondarys rr z-SecondaryAuthority.fromServerAddressAndDomains+"& C((  rc|jrdSd|_|j}|ddlm}t j|j|jfg|}| |j  |j  |jS)z Attempt a zone transfer. @returns: A L{Deferred} that fires with L{None} when attempted zone transfer has completed. NTrr.)serversr/) transferring transfering_reactorr4r/rResolverrr" lookupZonerF addCallback_cbZone addErrback_ebZone)rr/resolvers rr-zSecondaryAuthority.transfers    F- ? 0 0 0 0 0 0?lDJ/0'       , , [ & & Z % % rc|jr|js8tjt jt j|Stj |||||Sr:) soarecordsrfailr Failurer DomainErrorr _lookup)rnamer#typetimeouts rr\zSecondaryAuthority._lookupsVx Ft| F:gocod.C.CDDEE E$T4dGDDDrcP|\}}}ix|_}|D]}|js@|jtjkr+|jj|jf|_I||jjg |jdSr:) rXrWr^r SOAr]lowerpayload setdefaultappend)rzoneans_rrecs rrRzSecondaryAuthority._cbZones Q q L LC8 LCG 3 3HM//113;? SX]0022B77>>s{KKKK  L Lrcxtjd|jd|jdtj|dS)Nz Updating  from z failed during zone transfer)rmsgrFrerrrr s rrTzSecondaryAuthority._ebZonesF {{{DLLL *    rcj||j|jdSr:)r- addCallbacks_cbTransferred_ebTransferredr(s rupdatezSecondaryAuthority.updates, $$T%8$:MNNNNNrcd|_dS)NF)rL)rresults rrrz!SecondaryAuthority._cbTransferreds!rcd|_tjd|jd|jdtj|dS)NFz Transferring rlz failed after zone transfer) transferredrrmrFrrnros rrsz!SecondaryAuthority._ebTransferredsN  {{{DLLL *    rr:)r=r>r?r@rLrWrXr"rNrrAr r-r\rRrTrtrrrsrrrrr`s$LC' EH / / /[*   4EEEELLLOOO"""rN)__all__twisted.applicationrr4rr twisted.namesrr r r twisted.names.authorityr twisted.pythonr rtwisted.python.compatrr1rrrrrrs !< =''''''((((((((666666666666111111''''''''......MMMMMMMM`xxxxxxxxxxr