a sd_ @sdZddlZddlZddlZddlZddlZddlZddlZddl Zddl Zddl Zddl Zddl ZddlZddlZddlZddlZddlZddlZddlZddlZGdddejjZGdddejjZGdddejjZGd d d ejjZGd d d ejjZGd ddejjZGdddejjZGdddej j!Z"e#$e"j%GdddZ&Gddde&Z'ddZ(ddZ)GdddZ*d.dd Z+Gd!d"d"Z,d/d$d%Z-d0d&d'Z.ej/j0dddddddfd(d)Z1d1d,d-Z2dS)2z DNS MessagesNc@seZdZdZdS) ShortHeaderz2The DNS packet passed to from_wire() is too short.N__name__ __module__ __qualname____doc__rr-/usr/lib/python3/dist-packages/dns/message.pyr+src@seZdZdZdS) TrailingJunkzEThe DNS packet passed to from_wire() has extra junk at the end of it.Nrrrrr r /sr c@seZdZdZdS)UnknownHeaderFieldzVThe header field name was not recognized when converting from text into a message.Nrrrrr r 3sr c@seZdZdZdS)BadEDNSzLAn OPT record occurred somewhere other than the additional data section.Nrrrrr r 8sr c@seZdZdZdS)BadTSIGzWA TSIG record occurred somewhere other than the end of the additional data section.Nrrrrr r =sr c@seZdZdZdS)UnknownTSIGKeyz(A TSIG with an unknown key was received.Nrrrrr rBsrc@seZdZdZdhZddZdS) TruncatedzThe truncated flag is set.messagecCs |jdS)zbAs much of the message as could be processed. Returns a ``dns.message.Message``. r)kwargsselfrrr rKszTruncated.messageN)rrrrZ supp_kwargsrrrrr rFsrc@s,eZdZdZdZdZdZdZeddZ dS) MessageSectionzMessage sectionsrcCsdSNrr)clsrrr _maximumZszMessageSection._maximumN) rrrrQUESTIONANSWER AUTHORITY ADDITIONAL classmethodrrrrr rSsrc@seZdZdZeZdXddZeddZej ddZedd Z e j d d Z ed d Z e j d d Z eddZ e j ddZ ddZ ddZdYddZddZddZddZddZd d!Zejjdd"d"fd#d$Zejjdd"d"fd%d&ZdZd(d)Zed*d+Zdd,dd'd-ejjfd.d/Zed0d1Z ed2d3Z!ed4d5Z"ed6d7Z#ed8d9Z$ed[d;d<Z%d\d=d>Z&ed?d@Z'edAdBZ(e(j dCdBZ(edDdEZ)edFdGZ*d]dHdIZ+dJdKZ,dLdMZ-dNdOZ.dPdQZ/dRdSZ0dTdUZ1dVdWZ2dS)^MessagezA DNS message.NcCsj|durtj|_n||_d|_ggggg|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ i|_dS)NrF)dnsZentropyZ random_16idflagssectionsoptrequest_payloadkeyringtsig request_macxfrorigintsig_ctxindex)rr#rrr __init__fszMessage.__init__cCs |jdS)z The question section.rr%rrrr questionwszMessage.questioncCs||jd<dSNrr0rvrrr r1|scCs |jdS)z The answer section.rr0rrrr answerszMessage.answercCs||jd<dS)Nrr0r3rrr r5scCs |jdS)z The authority section.rr0rrrr authorityszMessage.authoritycCs||jd<dS)Nrr0r3rrr r6scCs |jdS)z The additional data section.rr0rrrr additionalszMessage.additionalcCs||jd<dSrr0r3rrr r7scCsdt|jdS)Nz)reprr#rrrr __repr__szMessage.__repr__cCs|SN)to_textrrrr __str__szMessage.__str__Tc KsPt}|d|j|dtjtj|jtj |j|j }|dtj ||dtj|j|j dkr|d|j |j dkr|dtj |j |d|j |jD]}|d |q|jjD]P\}}|d |d ||D]*} || j||fi||d qq|d d S)zConvert the message to text. The *origin*, *relativize*, and any other keyword arguments are passed to the RRset ``to_wire()`` method. Returns a ``str``. zid %d z opcode %s z rcode %s z flags %s rzedns %s z eflags %s z payload %d z option %s ; N)ioStringIOwriter#r"opcoder< from_flagsr$rcode ednsflagsednsZ edns_to_textpayloadoptions _section_enum __members__itemssection_from_numbergetvalue) rr, relativizekwsZrcr&nameZwhichrrsetrrr r<s.     zMessage.to_textcCst|tsdS|j|jkrdS|j|jkr.dSt|jD]F\}}|j|}|D]}||vrNdSqN|D]}||vrhdSqhq8dS)zTwo messages are equal if they have the same content in the header, question, answer, and authority sections. Returns a ``bool``. FT) isinstancer r#r$ enumerater%)rotherisectionZ other_sectionnrrr __eq__s      zMessage.__eq__cCs || Sr;)r[)rrWrrr __ne__szMessage.__ne__cCs|jtjj@dks:|j|jks:tj|jtj|jkr>dStj|j|jtjjkr\dStj |jrndS|j D]}||j vrtdSqt|j D]}||j vrdSqdS)zIIs *other* a response this message? Returns a ``bool``. rFT) r$r"QRr#rDrErFrGZNOERRORZ is_updater1)rrWrZrrr is_responses*       zMessage.is_responsecCs6t|jD]\}}||ur ||Sq tddS)zReturn the "section number" of the specified section for use in indexing. *section* is one of the section attributes of this message. Raises ``ValueError`` if the section isn't known. Returns an ``int``. zunknown sectionN)rVr%rK ValueError)rrYrXZ our_sectionrrr section_numbers zMessage.section_numbercCs|j|}|j|S)aReturn the section list associated with the specified section number. *number* is a section number `int` or the text form of a section name. Raises ``ValueError`` if the section isn't known. Returns a ``list``. )rKmaker%)rZnumberrYrrr rN s zMessage.section_from_numberFc Cst|tr|} || }n ||} | |||||f} |s|jdur\|j| } | dur| Sn$|D]} | |||||r`| Sq`|sttj |||||} | | |jdur| |j| <| S)aPFind the RRset with the given attributes in the specified section. *section*, an ``int`` section number, or one of the section attributes of this message. This specifies the the section of the message to search. For example:: my_message.find_rrset(my_message.answer, name, rdclass, rdtype) my_message.find_rrset(dns.message.ANSWER, name, rdclass, rdtype) *name*, a ``dns.name.Name``, the name of the RRset. *rdclass*, an ``int``, the class of the RRset. *rdtype*, an ``int``, the type of the RRset. *covers*, an ``int`` or ``None``, the covers value of the RRset. The default is ``None``. *deleting*, an ``int`` or ``None``, the deleting value of the RRset. The default is ``None``. *create*, a ``bool``. If ``True``, create the RRset if it is not found. The created RRset is appended to *section*. *force_unique*, a ``bool``. If ``True`` and *create* is also ``True``, create a new RRset regardless of whether a matching RRset exists already. The default is ``False``. This is useful when creating DDNS Update messages, as order matters for them. Raises ``KeyError`` if the RRset was not found and create was ``False``. Returns a ``dns.rrset.RRset object``. N) rUintrNr`r.getmatchKeyErrorr"rTZRRsetappend) rrYrSrdclassrdtypecoversdeletingcreate force_uniquer`keyrTrrr find_rrsets(&         zMessage.find_rrsetc Cs8z|||||||||} Wnty2d} Yn0| S)a5Get the RRset with the given attributes in the specified section. If the RRset is not found, None is returned. *section*, an ``int`` section number, or one of the section attributes of this message. This specifies the the section of the message to search. For example:: my_message.get_rrset(my_message.answer, name, rdclass, rdtype) my_message.get_rrset(dns.message.ANSWER, name, rdclass, rdtype) *name*, a ``dns.name.Name``, the name of the RRset. *rdclass*, an ``int``, the class of the RRset. *rdtype*, an ``int``, the type of the RRset. *covers*, an ``int`` or ``None``, the covers value of the RRset. The default is ``None``. *deleting*, an ``int`` or ``None``, the deleting value of the RRset. The default is ``None``. *create*, a ``bool``. If ``True``, create the RRset if it is not found. The created RRset is appended to *section*. *force_unique*, a ``bool``. If ``True`` and *create* is also ``True``, create a new RRset regardless of whether a matching RRset exists already. The default is ``False``. This is useful when creating DDNS Update messages, as order matters for them. Returns a ``dns.rrset.RRset object`` or ``None``. N)rnre) rrYrSrgrhrirjrkrlrTrrr get_rrsetWs%  zMessage.get_rrsetrc Ks|dur|jdur|j}|dkr6|jdkr2|j}nd}|dkrDd}n |dkrPd}tj|j|j||}|jD]}||j |j |j ql|j D]}|j tjj|fi|q|jD]}|j tjj|fi|q|jdur| tjj|j|jD]}|j tjj|fi|q||jdurtj||j|jdtt|j||\}} |j|j|| tjj|j||r| |_|S)aReturn a string containing the message in DNS compressed wire format. Additional keyword arguments are passed to the RRset ``to_wire()`` method. *origin*, a ``dns.name.Name`` or ``None``, the origin to be appended to any relative names. If ``None``, and the message has an origin attribute that is not ``None``, then it will be used. *max_size*, an ``int``, the maximum size of the wire format output; default is 0, which means "the message's request payload, if nonzero, or 65535". *multi*, a ``bool``, should be set to ``True`` if this message is part of a multiple message sequence. *tsig_ctx*, a ``hmac.HMAC`` object, the ongoing TSIG context, used when signing zone transfers. Raises ``dns.exception.TooBig`` if *max_size* was exceeded. Returns a ``bytes``. Nrii)r,r'r"ZrendererZRendererr#r$r1Z add_questionrSrhrgr5Z add_rrsetrr6rr&rr7Z write_headerr)ZsignZget_wirer(rbtimer*clearaddr-) rr,Zmax_sizemultir-rQrrTZnew_tsigctxrrr to_wiresL           zMessage.to_wirec Cs8tjjjtjjtjj||||||| }tj|d|Sr2)r"rdtypesANYTSIG rdataclass rdatatyperT from_rdata) keyname algorithmZ time_signedfudgemac original_iderrorrWr)rrr _make_tsigs zMessage._make_tsig,r!c Cst|tjjr||_nRt|tr,tj|}|dur@tt |}||}t|t rbtj|||}||_|durv|j }| ||jj d|d||||_dS)aWhen sending, a TSIG signature using the specified key should be added. *key*, a ``dns.tsig.Key`` is the key to use. If a key is specified, the *keyring* and *algorithm* fields are not used. *keyring*, a ``dict`` or ``dns.tsig.Key``, is either the TSIG keyring or key to use. The format of a keyring dict is a mapping from TSIG key name, as ``dns.name.Name`` to ``dns.tsig.Key`` or a TSIG secret, a ``bytes``. If a ``dict`` *keyring* is specified but a *keyname* is not, the key used will be the first key in the *keyring*. Note that the order of keys in a dictionary is not defined, so applications should supply a keyname when a ``dict`` keyring is used, unless they know the keyring contains only one key. *keyname*, a ``dns.name.Name``, ``str`` or ``None``, the name of thes TSIG key to use; defaults to ``None``. If *keyring* is a ``dict``, the key must be defined in it. If *keyring* is a ``dns.tsig.Key``, this is ignored. *fudge*, an ``int``, the TSIG time fudge. *original_id*, an ``int``, the TSIG original id. If ``None``, the message's id is used. *tsig_error*, an ``int``, the TSIG error code. *other_data*, a ``bytes``, the TSIG other data. *algorithm*, a ``dns.name.Name``, the TSIG algorithm to use. This is only used if *keyring* is a ``dict``, and the key entry is a ``bytes``. Nrr!)rUr"r)Keyr(strrS from_textnextiterbytesr#rr~) rr(r}rr tsig_errorZ other_datar~rmrrr use_tsigs&    zMessage.use_tsigcCs|jr|jjSdSdSr;)r)rSrrrr r}szMessage.keynamecCs|jr|jdjSdSdSr2)r)r~rrrr keyalgorithm s zMessage.keyalgorithmcCs|jr|jdjSdSdSr2)r)rrrrr rs z Message.maccCs|jr|jdjSdSdSr2)r)rrrrr rs zMessage.tsig_errorcCs t|jSr;)boolr)rrrr had_tsigszMessage.had_tsigcCs4tjjj|tjj|pd}tjtjjt ||S)Nr) r"rwrxOPTr{rTr|rSrootrb)r$rIrJr&rrr _make_opt#szMessage._make_optcCs|dus|durd}|dur d}|dur,|}|dkrFd}d}d}g}n |dM}||d>O}|durfg}|dkr|||||_nd|_||_dS)a6Configure EDNS behavior. *edns*, an ``int``, is the EDNS level to use. Specifying ``None``, ``False``, or ``-1`` means "do not use EDNS", and in this case the other parameters are ignored. Specifying ``True`` is equivalent to specifying 0, i.e. "use EDNS0". *ednsflags*, an ``int``, the EDNS flag values. *payload*, an ``int``, is the EDNS sender's payload field, which is the maximum size of UDP datagram the sender can handle. I.e. how big a response to this message can be. *request_payload*, an ``int``, is the EDNS payload size to use when sending this message. If not specified, defaults to the value of *payload*. *options*, a list of ``dns.edns.Option`` objects or ``None``, the EDNS options. NFr@Trl~)rr&r')rrHrGrIr'rJrrr use_edns)s& zMessage.use_ednscCs|jr|jd@d?SdSdS)Nirr@)r&rGrrrr rHWsz Message.ednscCs|jr|jjSdSdSr2)r&ttlrrrr rG^szMessage.ednsflagscCs$|jr||j_n|r |||_dSr;)r&rrr3rrr rGes cCs|jr|jdjSdSdSr2)r&rIrrrr rIls zMessage.payloadcCs|jr|jdjSdSdS)Nrr)r&rJrrrr rJss zMessage.optionscCs6|r|jtjjO_n|jr2|jtjjM_dS)a!Enable or disable 'DNSSEC desired' flag in requests. *wanted*, a ``bool``. If ``True``, then DNSSEC data is desired in the response, EDNS is enabled if required, and then the DO bit is set. If ``False``, the DO bit is cleared if EDNS is enabled. N)rGr"r$ZDOr&)rZwantedrrr want_dnsseczs zMessage.want_dnsseccCstj|j|jS)z7Return the rcode. Returns an ``int``. )r"rFrEr$rGrrrr rFsz Message.rcodecCsLtj|\}}|jdM_|j|O_|jdM_|j|O_dS)zJSet the rcode. *rcode*, an ``int``, is the rcode to set. iiN)r"rFto_flagsr$rG)rrFvalueZevaluerrr set_rcodes zMessage.set_rcodecCstj|jS)z8Return the opcode. Returns an ``int``. )r"rDrEr$rrrr rDszMessage.opcodecCs(|jdM_|jtj|O_dS)zMSet the opcode. *opcode*, an ``int``, is the opcode to set. iN)r$r"rDr)rrDrrr set_opcodeszMessage.set_opcodecCs|Sr;r)rrrrr _get_one_rr_per_rrsetszMessage._get_one_rr_per_rrsetcCs ||ddfS)NFr)rrYrSrgrhrrr _parse_rr_headerszMessage._parse_rr_headercCsl|tjjkr.|tjks(|js(|tjjkr`tn2|tjj kr`|tjks\|tjj ks\||dkr`t ||ddfS)NrF) r"r{rrrr&rSrr ryrxr )rrYcountZpositionrSrgrhrrr _parse_special_rr_headers      z Message._parse_special_rr_header)N)NT)NrFN)rrN)rrrNN)T)3rrrrrrKr/propertyr1setterr5r6r7r:r=r<r[r\r^r`rNr"r{NONErnrorv staticmethodrr)Zdefault_algorithmrr}rrrrrrrHrGrIrJrrFrrDrrrrrrrr r as          $  >  , B  6       .       r c@s eZdZdS) QueryMessageN)rrrrrrr rsrcCs ddl}dSr2)Z dns.update)r"rrr _maybe_import_updatesrcCs2|tjjkrtS|tjjkr*ttjjStSdSr;) r"rDQUERYrZUPDATErupdateZ UpdateMessager )rDrrr _message_factory_from_opcodes   rc@s2eZdZdZd ddZddZdd Zd d ZdS) _WireReaderaWire format reader. parser: the binary parser message: The message object being built initialize_message: Callback to set message parsing options question_only: Are we only reading the question? one_rr_per_rrset: Put each RR into its own RRset? keyring: TSIG keyring ignore_trailing: Ignore trailing junk at end of request? multi: Is this message part of a multi-message sequence? DNS dynamic updates. FNcCs<tj||_d|_||_||_||_||_||_ ||_ dSr;) r"wireZParserparserrinitialize_message question_onlyone_rr_per_rrsetignore_trailingr(rs)rrrrrrr(rsrrr r/sz_WireReader.__init__c Csp|jj|}t|D]V}|j|jj}|jd\}}|j||||\}}}}|jj||||dddqdS)zhRead the next *qcount* records from the wire data and add them to the question section. z!HHTrkrlN) rr%rangerget_namer, get_structrrn) rr`qcountrYrXqnamerhrg_rrr _get_questions    z_WireReader._get_questionc Csr|jj|}|j}t|D]P}|jj}|j}|jjdurN||jj}n|}|j d\} } } } | t j j t j j fvr|j||||| | \} } } }n|j||| | \} } } }|r| dkrt jjd}t j j}nN|j| (t j| | |j|jj}Wdn1s0Y|}|jjr@| t j jkr@d}| t j j krdt j|| ||j_q| t j j kr0|jdurtdt|jtr|j |}t|t!rt j"#|||j$}n|j}|durtd|||j_t j"%|jj&|||t't((|jj)||jj*|j+ |j_*t j|d||j_"q|j,||| | || d|}|dur| dkr`d} |-|| qdS)zRead the next I{count} records from the wire data and add them to the specified section. section: the section of the message to which to add records count: the number of records to read Nz!HHIHrTz"got signed message without keyringzkey '%s' unknowni).rr%rrrZcurrentrr,rPrr"r{rryrr exception FormErrorrZ restrict_tordataZfrom_wire_parserrir+ZSOArTr|r&r(rrUdictrcrr)rr~Zvalidaterrbrpr*r-rsrnrr)rr`rrYrlrXZrr_startZ absolute_namerSrhrgrZrdlenrjemptyrdrirmrTrrr _get_sections       $          z_WireReader._get_sectioncCs|jdkrt|jd\}}}}}}ttj|}||d|_||j_ | |j|j |j |_ | tj||jrdS|tj||tj||tj||js|jdkrt|jr|jjr|jjs|jj|jj|jS)zNRead a wire format DNS message and build a dns.message.Message object. z!HHHHHHr#Nr)rZ remainingrrrr"rDrErr$rrrrrrrrrrrrr rsr-rrr)rr#r$rZancountZaucountZadcountfactoryrrr readHs*    z_WireReader.read)FFFNF)rrrrr/rrrrrrr rs  Krr!Fc sfdd} t|| ||| ||} z | } Wn@tjjyr| jrl| jjtjj@rl| rlt| jdnYn0| jtjj@r| rt| d| S)a4Convert a DNS wire format message into a message object. *keyring*, a ``dns.tsig.Key`` or ``dict``, the key or keyring to use if the message is signed. *request_mac*, a ``bytes``. If the message is a response to a TSIG-signed request, *request_mac* should be set to the MAC of that request. *xfr*, a ``bool``, should be set to ``True`` if this message is part of a zone transfer. *origin*, a ``dns.name.Name`` or ``None``. If the message is part of a zone transfer, *origin* should be the origin name of the zone. If not ``None``, names will be relativized to the origin. *tsig_ctx*, a ``hmac.HMAC`` object, the ongoing TSIG context, used when validating zone transfers. *multi*, a ``bool``, should be set to ``True`` if this message is part of a multiple message sequence. *question_only*, a ``bool``. If ``True``, read only up to the end of the question section. *one_rr_per_rrset*, a ``bool``. If ``True``, put each RR into its own RRset. *ignore_trailing*, a ``bool``. If ``True``, ignore trailing junk at end of the message. *raise_on_truncation*, a ``bool``. If ``True``, raise an exception if the TC bit is set. Raises ``dns.message.ShortHeader`` if the message is less than 12 octets long. Raises ``dns.message.TrailingJunk`` if there were octets in the message past the end of the proper DNS message, and *ignore_trailing* is ``False``. Raises ``dns.message.BadEDNS`` if an OPT record was in the wrong section, or occurred more than once. Raises ``dns.message.BadTSIG`` if a TSIG record was not the last record of the additional data section. Raises ``dns.message.Truncated`` if the TC flag is set and *raise_on_truncation* is ``True``. Returns a ``dns.message.Message``. cs|_|_|_|_dSr;)r*r+r,r-rr,r*r-r+rr rsz%from_wire..initialize_messager) rrr"rrrr$ZTCr)rr(r*r+r,r-rsrrrZraise_on_truncationrreadermrrr from_wirecs9  rc@sBeZdZdZdddZddZd d Zd d Zd dZddZ dS) _TextReaderatText format reader. tok: the tokenizer. message: The message object being built. DNS dynamic updates. last_name: The most recently read name when building a message object. one_rr_per_rrset: Put each RR into its own RRset? origin: The origin for relative names relativize: relativize names? relativize_to: the origin to relativize to. FNTcCshd|_tjj||d|_d|_||_||_||_||_ d|_ d|_ d|_ d|_ d|_tjj|_d|_dS)N idna_codecr@r)rr"Z tokenizer Tokenizertok last_namerr,rP relativize_tor#rHrGrIrFrDrr$)rtextrrr,rPrrrr r/s z_TextReader.__init__cCs|j}|j}|dkr(|j|_nJ|dkrl|j}|sP|j|qh|jtj |jB|_q0n|dkr|j|_ |j |j d>B|_ n|dkr|j dkrd|_ |j}|s|j|q|j tj |jB|_ qn|dkr|j|_ |j dkrrd|_ nb|dkrJ|j}tj ||_|jtj|jB|_n(|d krn|j}tj ||_nt|jd S) z5Process one line from the text format header section.r#r$rHrZeflagsrrIrDrFN)rrcrZget_intr# is_identifierungetr$r"rrHrGZedns_from_textrIZ get_stringrDrrFr get_eol)rrYtokenZwhatrrrr _header_linesH               z_TextReader._header_linecCs|jj|}|jjdd}|s>|j||jj|j|j|_ |j }|j}| s^t j j z,t j|j}|j}| st j j Wn6t j j yt j j Yntyt jj}Yn0t j|j}|j||||\}}}}|jj||||ddd|jdS)z7Process one line from the text format question section.TZ want_leadingrN)rr%rrc is_whitespaceas_namer,rPrrrr"r SyntaxErrorrzrr ExceptionINr{rrnr)rr`rYrrSrgrhrrrr _question_lines6       z_TextReader._question_linec Cs|jj|}|jjdd}|s>|j||jj|j|j|_ |j }|j}| s^t j j z*t|jd}|j}| st j j Wn2t j j yt j j Yntyd}Yn0z,t j|j}|j}| st j j Wn:t j j yt j j Ynty"t jj}Yn0t j|j}|j||||\}}}} |j}| rn|snt j j |s|j|t j|||j|jj|j|j} | } n d} t jj} |j||||| |d|j} | dur| | |dS)zfProcess one line from the text format answer, authority, or additional data sections. TrrN)rr%rrcrrr,rPrrrr"rrrbrrrzrrr{r is_eol_or_eofrrrirrnrrr) rr`rYrrSrrgrhrjrrrirTrrr _rr_linesd                   z_TextReader._rr_linecCs`t|j}||jd}|j|_|jdkr<||j|j|j|jrN| |j|j r\|j |_ |S)Nrr) rrDr#r$rHrrGrIrFrr,)rrrrrr _make_messageVs    z_TextReader._make_messagecCs|j}d}|jdd}|r"q|r|j}|dkrB|j}|jrP|j}n|}zB|j |}|js||_| |j |_ |t jkr|j}n|j}WntyYn0|jq |j|||q |js||_|jS)zNRead a text format DNS message and build a dns.message.Message object.NTZHEADER)rrrcrZ is_commentrupperrrrKrrrrrrrrrr)rZ line_methodr`rurrrr rbs<          z_TextReader.read)FNTN) rrrrr/rrrrrrrrr rs  *: rTcCst||||||}|S)aConvert the text format message into a message object. The reader stops after reading the first blank line in the input to facilitate reading multiple messages from a single file with ``dns.message.from_file()``. *text*, a ``str``, the text format message. *idna_codec*, a ``dns.name.IDNACodec``, specifies the IDNA encoder/decoder. If ``None``, the default IDNA 2003 encoder/decoder is used. *one_rr_per_rrset*, a ``bool``. If ``True``, then each RR is put into its own rrset. The default is ``False``. *origin*, a ``dns.name.Name`` (or ``None``), the origin to use for relative names. *relativize*, a ``bool``. If true, name will be relativized. *relativize_to*, a ``dns.name.Name`` (or ``None``), the origin to use when relativizing names. If not set, the *origin* value will be used. Raises ``dns.message.UnknownHeaderField`` if a header is unknown. Raises ``dns.exception.SyntaxError`` if the text is badly formed. Returns a ``dns.message.Message object`` )rr)rrrr,rPrrrrr rs$ rcCsPt4}t|tr"|t|}t|||WdS1sB0YdS)aRead the next text format message from the specified file. Message blocks are separated by a single blank line. *f*, a ``file`` or ``str``. If *f* is text, it is treated as the pathname of a file to open. *idna_codec*, a ``dns.name.IDNACodec``, specifies the IDNA encoder/decoder. If ``None``, the default IDNA 2003 encoder/decoder is used. *one_rr_per_rrset*, a ``bool``. If ``True``, then each RR is put into its own rrset. The default is ``False``. Raises ``dns.message.UnknownHeaderField`` if a header is unknown. Raises ``dns.exception.SyntaxError`` if the text is badly formed. Returns a ``dns.message.Message object`` N) contextlib ExitStackrUr enter_contextopenr)frrstackrrr from_files  rc Cst|trtjj|| d}tjj|}tjj |}t } | j tj j O_ | j | j|||dddi} |dur|| d<|durd}|dur|| d<|durd}|dur|| d<|durd}|dur|| d <|durd}|| d <| jfi| | || S) aMake a query message. The query name, type, and class may all be specified either as objects of the appropriate type, or as strings. The query will have a randomly chosen query id, and its DNS flags will be set to dns.flags.RD. qname, a ``dns.name.Name`` or ``str``, the query name. *rdtype*, an ``int`` or ``str``, the desired rdata type. *rdclass*, an ``int`` or ``str``, the desired rdata class; the default is class IN. *use_edns*, an ``int``, ``bool`` or ``None``. The EDNS level to use; the default is None (no EDNS). See the description of dns.message.Message.use_edns() for the possible values for use_edns and their meanings. *want_dnssec*, a ``bool``. If ``True``, DNSSEC data is desired. *ednsflags*, an ``int``, the EDNS flag values. *payload*, an ``int``, is the EDNS sender's payload field, which is the maximum size of UDP datagram the sender can handle. I.e. how big a response to this message can be. *request_payload*, an ``int``, is the EDNS payload size to use when sending this message. If not specified, defaults to the value of *payload*. *options*, a list of ``dns.edns.Option`` objects or ``None``, the EDNS options. *idna_codec*, a ``dns.name.IDNACodec``, specifies the IDNA encoder/decoder. If ``None``, the default IDNA 2003 encoder/decoder is used. Returns a ``dns.message.QueryMessage`` rTrNrGrrIr'rJrH)rUrr"rSrr{Z RdataTyperarzZ RdataClassrr$RDrnr1rr) rrhrgrrrGrIr'rJrrrrrr make_querys<-  r rc Cs|jtjj@rtjdt|}||jd}tjj|jtjj@B|_|r`|jtjj O_| |t |j |_ |j dkr|dd||j|jr||j|j|d|d|j|j|_|S)a`Make a message which is a response for the specified query. The message returned is really a response skeleton; it has all of the infrastructure required of a response, but none of the content. The response's question section is a shallow copy of the query's question section, so the query's question RRsets should not be changed. *query*, a ``dns.message.Message``, the query to respond to. *recursion_available*, a ``bool``, should RA be set in the response? *our_payload*, an ``int``, the payload size to advertise in EDNS responses. *fudge*, an ``int``, the TSIG time fudge. *tsig_error*, an ``int``, the TSIG error. Returns a ``dns.message.Message`` object whose specific class is appropriate for the query. For example, if query is a ``dns.update.UpdateMessage``, response will be too. z&specified query message is not a queryrrNr!)r$r"r]rrrrDr#rZRArlistr1rHrrIrrr(r}rrr*)ZqueryZrecursion_availableZ our_payloadrrrZresponserrr make_response#s"     r) Nr!FNNFFFFF)NFNTN)NF)Frrr)3rrrArpZdns.wirer"Zdns.ednsZdns.enumZ dns.exceptionZ dns.flagsZdns.nameZ dns.opcodeZ dns.entropyZ dns.rcodeZ dns.rdataZdns.rdataclassZ dns.rdatatypeZ dns.rrsetZ dns.rendererZdns.tsigZdns.rdtypes.ANY.OPTZdns.rdtypes.ANY.TSIGrrrr Z DNSExceptionr r r rrenumIntEnumrglobalsrrLr rrrrrrrrrzrrrrrrr sr  a  Q\ )  O