|; iF~UdZddlmZddlmZmZddlmZmZddl m Z m Z m Z m Z mZddlmZddlmZdd lmZdd lmZdd lmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$d d l%m&Z&m'Z'm(Z(m)Z)e!e#heZ*gZ+de,d<gZ-de,d<ej\Z/e0Z1e2Z3dZ4d Z5dZ6dZ7dZ8erddl9m:Z:GddZ;GddZ<GddZ=y)aMulticast DNS Service Discovery for Python, v0.14-wmcbrine Copyright 2003 Paul Scott-Murphy, 2014 William McBrine This module provides a framework for the use of DNS Service Discovery using IP multicast. This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this library; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA ) annotations) TYPE_CHECKINGcast)DNSCache_UniqueRecordsType) DNSAddress DNSPointer DNSQuestion DNSRecordDNSRRSet) DNSIncoming) ServiceInfo)_WrappedTransport) IPVersion) _ADDRESS_RECORD_TYPES _CLASS_IN_DNS_OTHER_TTL _MDNS_PORT _ONE_SECOND_SERVICE_TYPE_ENUMERATION_NAME_TYPE_A _TYPE_AAAA _TYPE_ANY _TYPE_NSEC _TYPE_PTR _TYPE_SRV _TYPE_TXT)QuestionAnswers_AnswerWithAdditionalsType$construct_outgoing_multicast_answers"construct_outgoing_unicast_answerslist[ServiceInfo]_EMPTY_SERVICES_LIST list[str]_EMPTY_TYPES_LIST)Zeroconfc,eZdZdZ ddZy)_AnswerStrategy)questionservices strategy_typetypesc<||_||_||_||_y)zCreate an answer strategy.N)r-r/r0r.)selfr-r/r0r.s S/home/ubuntu/myenv/lib/python3.12/site-packages/zeroconf/_handlers/query_handler.py__init__z_AnswerStrategy.__init__Ns!! *   N) r-r r/_intr0r&r.r$returnNone)__name__ __module__ __qualname__ __slots__r4r5r3r,r,Ks<BI ! ! ! ! $ !  !r5r,cPeZdZdZdZd dZd dZd dZd dZ d dZ ddZ dd Z y )_QueryResponsez7A pair for unicast and multicast DNSOutgoing responses.) _additionals_cache _is_probe_mcast_aggregate_mcast_aggregate_last_second _mcast_now_now _questions_ucastc||_||_||_||_i|_t |_t |_t |_t |_ y)zBuild a query response.N) rBrGrFrAr@setrHrErCrD)r2cache questionsis_probenows r3r4z_QueryResponse.__init__ksL!#  8:&)e *-%03QD%%a((>>6:ooFQ))!,,F F<@'>&j#&juiB]^^ ?FR&jsB+B0B5B:ctrtt|}|jj |}t |duxr|j |jS)a Check to see if a record has been mcasted recently. https://datatracker.ietf.org/doc/html/rfc6762#section-5.4 When receiving a question with the unicast-response bit set, a responder SHOULD usually respond with a unicast packet directed back to the querier. However, if the responder has not multicast that record recently (within one quarter of its TTL), then the responder SHOULD instead multicast the response so as to keep all the peer caches up to date N)rrrrAasync_get_uniquebool is_recentrFr2rT maybe_entrys r3rRz0_QueryResponse._has_mcast_within_one_quarter_ttlsL ,f5Fkk226: Kt+P 0E0Edii0PQQr5ctrtt|}|jj |}t |duxr |j |jz tkS)zCheck if an answer was seen in the last second. Protect the network against excessive packet flooding https://datatracker.ietf.org/doc/html/rfc6762#section-14 N) rrrrArhrirFcreatedrrks r3r[z/_QueryResponse._has_mcast_record_in_last_secondsR ,f5Fkk226: Kt+] KNN;/  0 '>5d7dd5OOG$5$5d=6I4$PQ%5F)4Jv&5-'~~1`3``1KN5 7,,T--@$GH' Qr5ci}|tk(r|j||||S|tk(r|j||||S|tk(r |j ||||j |S|tk(r=|d}|jd}|j|s|jd||<|S|tk(r4|d}|jd} |j| s t|| <|S)zAnswer a question.rN))_ANSWER_STRATEGY_SERVICE_TYPE_ENUMERATIONr_ANSWER_STRATEGY_POINTERr_ANSWER_STRATEGY_ADDRESSrr]_ANSWER_STRATEGY_SERVICErrzr_ANSWER_STRATEGY_TEXTrrJ) r2r-r/r0r.r|r{r dns_servicedns_texts r3_answer_questionzQueryHandler._answer_questions24 E E  < H((H!J$,(5(@(@(B%%%::8SJ[\..&&!! J J22:>55jA  1 1* =+ >.  ""r5c~|j}|j}|j}g}|tk(rL|tk(rC|j j }|r%|jt|t|t|S|ttfvrB|j j|}|r%|jt|tt||tt tfvrB|j j#|}|r%|jt|t$t||t&t(tfvr|j j+|}|h|t&tfvr&|jt|t,t|g|t(tfvr&|jt|t.t|g|S)z(Collect strategies to answer a question.)namelowerr]rrrvasync_get_typesrr,rr%rasync_get_infos_typerr'rrasync_get_infos_serverrrrasync_get_info_namerr) r2r-rquestion_lower_namerrr0r.rs r3rz#QueryHandler._get_answer_strategiesws }}"jjl ,. I "59W"WMM113E!!# A,   Y * *}}99:MNH!!#H.FHY[cd Wj)4 4}};;rp __future__rtypingrrrArr_dnsr r r r r _protocol.incomingr_services.infor _transportr _utils.netrconstrrrrrrrrrrrrrrSr r!r"r#r^r%__annotations__r'Allrintr6strrrrrrr_corer*r,r?rrr=r5r3rs,#&1KK,(*"' J4IJ*,',!9!  ,-) !!"a_a_HYkYkr5