h0SrSSKJr SSKJrJrJr SSKJr "SS5r "SS\R5r S r "S S 5r SS jrg )z Resolver implementation for querying successive authoritative servers to lookup a record, starting from the root nameservers. @author: Jp Calderone todo:: robustify it documentation )defer)commondnserror)Failurec\rSrSrSrSrSrg)_DummyControllerz A do-nothing DNS controller. This is useful when all messages received will be responses to previously issued queries. Anything else received will be ignored. cgN)selfargss Y/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/names/root.pymessageReceived _DummyController.messageReceiveds r N)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__r rrr r s   rr c@\rSrSrSrS SjrSrSrSrSr S r S r g) Resolver aS L{Resolver} implements recursive lookup starting from a specified list of root servers. @ivar hints: See C{hints} parameter of L{__init__} @ivar _maximumQueries: See C{maximumQueries} parameter of L{__init__} @ivar _reactor: See C{reactor} parameter of L{__init__} @ivar _resolverFactory: See C{resolverFactory} parameter of L{__init__} Nc[RRU5 XlX lX0lUcSSKJn X@lg)a @param hints: A L{list} of L{str} giving the dotted quad representation of IP addresses of root servers at which to begin resolving names. @type hints: L{list} of L{str} @param maximumQueries: An optional L{int} giving the maximum number of queries which will be attempted to resolve a single name. @type maximumQueries: L{int} @param reactor: An optional L{IReactorTime} and L{IReactorUDP} provider to use to bind UDP ports and manage timeouts. @type reactor: L{IReactorTime} and L{IReactorUDP} provider @param resolverFactory: An optional callable which accepts C{reactor} and C{servers} arguments and returns an instance that provides a C{queryUDP} method. Defaults to L{twisted.names.client.Resolver}. @type resolverFactory: callable Nrr) r ResolverBase__init__hints_maximumQueries_reactortwisted.names.clientr_resolverFactory)rr!maximumQueriesreactorresolverFactorys rr Resolver.__init__+s7* $$T* -  " H /rcdURVs/sHo[R4PM sn$s snf)zj Return a list of two-tuples representing the addresses of the root servers, as defined by C{self.hints}. )r!rPORT)rips r_rootsResolver._rootsHs& *.42SXX444s-cURX RS9nURU/U5nU(aURUR5 U$)a Issue one query and return a L{Deferred} which fires with its response. @param query: The query to issue. @type query: L{dns.Query} @param servers: The servers which might have an answer for this query. @type servers: L{list} of L{tuple} of L{str} and L{int} @param timeout: A timeout on how long to wait for the response. @type timeout: L{tuple} of L{int} @param filter: A flag indicating whether to filter the results. If C{True}, the returned L{Deferred} will fire with a three-tuple of lists of L{twisted.names.dns.RRHeader} (like the return value of the I{lookup*} methods of L{IResolver}. IF C{False}, the result will be a L{Message} instance. @type filter: L{bool} @return: A L{Deferred} which fires with the response or a timeout error. @rtype: L{Deferred} )serversr')r%r#queryUDP addCallback filterAnswers)rqueryr0timeoutfilterrds r_queryResolver._queryOsE2  ! !'== ! I JJw (  MM!// *rcUcSnUR[R"XU5UR5X@R5$)z Implement name lookup by recursively discovering the authoritative server for the name and then asking it, starting at one of the servers in C{self.hints}. ) -)_discoverAuthorityrQueryr-r")rnameclstyper5s r_lookupResolver._lookupnsA ?%G&& IId# & w@T@T  rcUS::a[[R"S55$URXUS5nUR UR XUS- 5 U$)a Issue a query to a server and follow a delegation if necessary. @param query: The query to issue. @type query: L{dns.Query} @param servers: The servers which might have an answer for this query. @type servers: L{list} of L{tuple} of L{str} and L{int} @param timeout: A C{tuple} of C{int} giving the timeout to use for this query. @param queriesLeft: A C{int} giving the number of queries which may yet be attempted to answer this query before the attempt will be abandoned. @return: A L{Deferred} which fires with a three-tuple of lists of L{twisted.names.dns.RRHeader} giving the response, or with a L{Failure} if there is a timeout or response error. rz"Query limit reached without resultFr<)rr ResolverErrorr9r2_discoveredAuthority)rr4r0r5 queriesLeftr8s rr@Resolver._discoverAuthority|sT. ! 5../STU U KK 7 d//qQrc^^^^^^UR[R:wa*[TR UR5"U55$0mUR H.nTR UR/5RU5 M0 U4Sjn[5nTRnSn URU5 U mU"UTRTR5n U cUTR:XaOTR[R"[U5TRTR5TR!5TT5n U4Sjn U R#U 5 U $U RTR:Xa#UR UR$UR&4$U R(RU;a[*R,"S5eU R(RnGM90n UR&HSn U R[R.:XdM#U R(R15XRR'MU /n/nUR$Hn U R[R2:XdM#U R(RRnUU ;a&URU U[R445 MoURU5 M U(aTRTUTT5$U(aCTR7UST5n SnU R#U5 U R#UUUU4Sj5 U $[[*R,"S55$) a Interpret the response to a query, checking for error codes and following delegations if necessary. @param response: The L{Message} received in response to issuing C{query}. @type response: L{Message} @param query: The L{dns.Query} which was issued. @type query: L{dns.Query}. @param timeout: The timeout to use if another query is indicated by this response. @type timeout: L{tuple} of L{int} @param queriesLeft: A C{int} giving the number of queries which may yet be attempted to answer this query before the attempt will be abandoned. @return: A L{Failure} indicating a response error, a three-tuple of lists of L{twisted.names.dns.RRHeader} giving the response to C{query} or a L{Deferred} which will fire with one of those. c>SnTRU/5HKnURU:XdMURU:XaUs $UR[R:XdMIUnMM U$r )getrCrDrCNAME)rBrDrCcnamerecordrecordss rfindAnswerOrCName8Resolver._discoveredAuthority..findAnswerOrCNamesVE!++dB/::${{d*%  1 & 0LrNc:>UupnURST5 XU4$Nr)insert)resultsanswers authority additionalpreviouss r cbResolved1Resolver._discoveredAuthority..cbResolveds&9@6Jq(3 'J??rzCycle in CNAME processingrcFUupnUSRR5$rV)payload dottedQuad)rXrYrZr[s r getOneAddress4Resolver._discoveredAuthority..getOneAddresss%18.Jqz))4466rcT>TRTU[R4/TTS- 5$)Nr<)r@rr+)hintrJr4rr5s r/Resolver._discoveredAuthority..s)T44T388,-w arz/Stuck at response without answers or delegation)rCoderOKrexceptionForCoderY setdefaultrBappendsetaddrDrCr@rAstrr-r2rZr[r`rrHAraNSr+ lookupAddress)rresponser4r5rJanswerrSseenrBrQr8r] addressesrrr!trapsnsrbr\rRs` ``` @@rrIResolver._discoveredAuthoritys. >>SVV #400@JK K&&F   v{{B / 6 6v >' uzz HHTNH&tUZZCF~5::%// #d)UZZC # A@ MM*-H * (((*<*Q>QRR>>&&$.--.IJJ~~**EJ %%Bww#%%*,***?*?*A '',,'&$$Bww#&& ZZ__))?LL)B-!:;LL$ % **5%+N N ""58W5A 7 MM- ( MM  H##$UV r)r"r#r%r!) NN) rrrrrr r-r9rEr@rIrr rrrr s&0:5>  ^^TRUUU4Sj5 T$)Nc(>[UT5"T0TD6$r )getattr)r7rkwrBs rrf6makePlaceholder..placeholder..swq$'7'D'Dr)r2)rrdeferredrBs``r placeholder$makePlaceholder..placeholdersDErr )rrBrs`` rmakePlaceholderrs rc&\rSrSrSrSrSrSrg)DeferredResolvericH/UlURUR5 gr )waitingr2gotRealResolver)rresolverDeferreds rr DeferredResolver.__init__s $$T%9%9:rcURnURUlURUlUHnURU5 M gr )r__dict__ __class__callback)rresolverwr8s rr DeferredResolver.gotRealResolvers; LL )) !++A JJx rcURS5(dUS;aGURR[R"55 [ URSU5$[ U5e)Nlookup) getHostByNamer4) startswithrrlrDeferredrAttributeError)rrBs r __getattr__DeferredResolver.__getattr__%sS ??8 $ $0J(J LL   0 1"4<<#3T: :T""r)rrrN)rrrrr rrrr rrrrs;!#rrNc,^[S5Vs/sHn[[S5U-5PM nnUVs/sHo@RSU-5PM nn[R "USS9nU4SjnUR U5 [U5$s snfs snf)a Lookup the root nameserver addresses using the given resolver Return a Resolver which will eventually become a C{root.Resolver} instance that has references to all the root servers that we were able to look up. @param resolver: The resolver instance which will be used to lookup the root nameserver addresses. @type resolver: L{twisted.internet.interfaces.IResolverSimple} @param resolverFactory: An optional callable which returns a resolver instance. It will passed as the C{resolverFactory} argument to L{Resolver.__init__}. @type resolverFactory: callable @return: A L{DeferredResolver} which will be dynamically replaced with L{Resolver} when the root nameservers have been looked up. az%s.root-servers.netT) consumeErrorsc`>[UVs/sHoS(dMUSPM snTS9$s snf)Nrr<)r!r(r)reser(s r buildResolver bootstrap..buildResolverDs1!$-A!41Q4-  -s + +)rangechrordrr DeferredListr2r)rr(idomainsr8Lrs ` r bootstrapr,s(+0)4)Qs3s8a< )G4DKLGq   5 9 :GAL 1D1A MM- A 5Ls !B Br )rtwisted.internetr twisted.namesrrrtwisted.python.failurerr rrrrrr rrrsK #,,*  nv""nb##&r