/usr/lib/python3/dist-packages/twisted/names/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/names/__pycache__/authority.cpython-310.pyc (14736B)
o
¯b+A ã @ sœ d Z ddlZddlZddlmZ ddlmZmZmZ ddl m
Z
ddl m Z m
Z
ddlmZ dd d
„ZG d d „ d ejƒZG d
d„ deƒZG dd„ deƒZdS )z
Authoritative resolvers.
é N)Údefer)ÚcommonÚdnsÚerror)Úfailure)ÚexecfileÚ nativeString)ÚFilePathú/tmp/twisted-names.serialc C s t d¡}t d¡}z)tj | ¡s-t| dƒ}| |d ¡ W d ƒ n1 s(w Y W t |¡ nt |¡ w t| ƒ}| ¡ ¡ \}}W d ƒ n1 sQw Y ||kr`t
|ƒd pad}t| dƒ}| d||f ¡ W d ƒ n1 s{w Y |d |f }|S )
aÛ
Return a monotonically increasing (across program runs) integer.
State is stored in the given file. If it does not exist, it is
created with rw-/---/--- permissions.
This manipulates process-global state by calling C{os.umask()}, so it isn't
thread-safe.
@param filename: Path to a file that is used to store the state across
program runs.
@type filename: L{str}
@return: a monotonically increasing number
@rtype: L{str}
z%Y%m%dé Úwz 0Né r z%s %dz%02d) ÚtimeÚstrftimeÚosÚumaskÚpathÚexistsÚopenÚwriteÚreadlineÚsplitÚint)ÚfilenameÚserialÚoÚfÚ
serialFileÚ
lastSerialÚzoneID© r ú9/usr/lib/python3/dist-packages/twisted/names/authority.pyÚ getSerial s$
ÿ€
ÿ ÿr" c @ sp e Zd ZdZejejejfZej ej
fZ dZ dZ
dd„ Zdd„ Zdd„ Zd d
„ Zdd d „Zddd„Zdd„ ZdS )Ú
FileAuthoritya
An Authority that is loaded from a file.
This is an abstract class that implements record search logic. To create
a functional resolver, subclass it and override the L{loadFile} method.
@ivar _ADDITIONAL_PROCESSING_TYPES: Record types for which additional
processing will be done.
@ivar _ADDRESS_TYPES: Record types which are useful for inclusion in the
additional section generated during additional processing.
@ivar soa: A 2-tuple containing the SOA domain name as a L{bytes} and a
L{dns.Record_SOA}.
@ivar records: A mapping of domains (as lowercased L{bytes}) to records.
@type records: L{dict} with L{bytes} keys
Nc C s t j | ¡ | |¡ i | _d S ©N)r Ú ResolverBaseÚ__init__ÚloadFileÚ_cache©Úselfr r r r! r& V s
zFileAuthority.__init__c C s
|| _ d S r$ )Ú__dict__)r* Ústater r r! Ú __setstate__[ s
zFileAuthority.__setstate__c C s dS )ab
Load DNS records from a file.
This method populates the I{soa} and I{records} attributes. It must be
overridden in a subclass. It is called once from the initializer.
@param filename: The I{filename} parameter that was passed to the
initilizer.
@returns: L{None} -- the return value is ignored
Nr r) r r r! r' ^ s zFileAuthority.loadFilec
c sp || D ]0}|j | jv r5|jjj}| j | ¡ d¡D ]}|j| jv r4t j
||jt j |j p.||ddV qqdS )aW
Find locally known information that could be useful to the consumer of
the response and construct appropriate records to include in the
I{additional} section of that response.
Essentially, implement RFC 1034 section 4.3.2 step 6.
@param answer: A L{list} of the records which will be included in the
I{answer} section of the response.
@param authority: A L{list} of the records which will be included in
the I{authority} section of the response.
@param ttl: The default TTL for records for which this is not otherwise
specified.
@return: A generator of L{dns.RRHeader} instances for inclusion in the
I{additional} section. These instances represent extra information
about the records in C{answer} and C{authority}.
r T©ÚauthN)
ÚtypeÚ _ADDITIONAL_PROCESSING_TYPESÚpayloadÚnameÚrecordsÚgetÚlowerÚTYPEÚ_ADDRESS_TYPESr ÚRRHeaderÚINÚttl)r* ÚanswerÚ authorityr; Úrecordr3 Úrecr r r! Ú_additionalRecordsk s €
ÿ€ûz FileAuthority._additionalRecordsc C s´ g }g }g }g }t | jd j| jd jƒ} | j | ¡ ¡}
|
r»|
D ]_} | jdur,| j} n| } | jt j
krP| ¡ | jd ¡ krP| t j || jt j
| | dd¡ n| j|ksZ|t jkrj| t j || jt j
| | dd¡ | jt jkr€| t j || jt j
| | dd¡ q!|s…|}| ||| ¡}
|r”| |
¡ n| |
¡ |s³|s³| t j | jd t jt j
| | jd dd¡ t |||f¡S t || jd ¡rÏt t t |¡¡¡S t t t |¡¡¡S )a
Determine a response to a particular DNS query.
@param name: The name which is being queried and for which to lookup a
response.
@type name: L{bytes}
@param cls: The class which is being queried. Only I{IN} is
implemented here and this value is presently disregarded.
@type cls: L{int}
@param type: The type of records being queried. See the types defined
in L{twisted.names.dns}.
@type type: L{int}
@param timeout: All processing is done locally and a result is
available immediately, so the timeout value is ignored.
@return: A L{Deferred} that fires with a L{tuple} of three sets of
response records (to comprise the I{answer}, I{authority}, and
I{additional} sections of a DNS response) or with a L{Failure} if
there is a problem processing the query.
r
Nr Fr. T) ÚmaxÚsoaÚminimumÚexpirer4 r5 r6 r; r7 r ÚNSÚappendr9 r: Ú ALL_RECORDSÚCNAMEr@ ÚextendÚSOAr ÚsucceedÚ_isSubdomainOfÚfailr ÚFailureÚAuthoritativeDomainErrorr Ú DomainError)r* r3 Úclsr0 ÚtimeoutÚcnamesÚresultsr= Ú
additionalÚ default_ttlÚdomain_recordsr> r; ÚadditionalInformationr r r! Ú_lookup‰ sT
"ÿÿ ÿ€ÿ
ÿÿzFileAuthority._lookupé
c
C s t |¡}| jd ¡ | ¡ krt| jd j| jd jƒ}| jd jd ur,| jd j}n|}t j| jd t j t j
|| jd ddg}| j ¡ D ]*\}}|D ]#}|jd urX|j} n|} |j
t j krp| t j||j
t j
| |dd¡ qMqG| |d ¡ t |ddf¡S t t t |¡¡¡S )Nr r
Tr. r )r Ú domainStringrB r6 rA rC rD r; r9 rJ r: r4 Úitemsr7 rF r rK rM r rN rP )
r* r3 rR rV Úsoa_ttlrT ÚkÚrr? r; r r r! Ú
lookupZoneâ s0
ÿÿ
ÿ€ú zFileAuthority.lookupZonec C sb g g g }}}|D ]!}|d r+| |d d ¡ | |d d ¡ | |d d ¡ q
|||fS )Nr r
é )rI )r* rT Úansr/ ÚaddÚresr r r! Ú
_cbAllRecordsþ s €
zFileAuthority._cbAllRecordsr$ )rZ )Ú__name__Ú
__module__Ú __qualname__Ú__doc__r rH ÚMXrE r1 ÚAÚAAAAr8 rB r4 r& r- r' r@ rY r` re r r r r! r# ; s
Y r# c @ s( e Zd ZdZdd„ Zdd„ Zdd„ ZdS ) ÚPySourceAuthorityzC
A FileAuthority that is built up from Python source code.
c C s| | ¡ i }}t|||ƒ d|vrtd| ƒ‚i | _|d D ] }t|d tjƒr+|| _| j |d ¡ g ¡
|d ¡ q d S )NÚzonezNo zone defined in r
r ) ÚsetupConfigNamespacer Ú
ValueErrorr4 Ú
isinstancer Ú
Record_SOArB Ú
setdefaultr6 rF )r* r ÚgÚlÚrrr r r! r'
s "ýzPySourceAuthority.loadFilec s ‡ fdd„}|S )Nc s t | ¡ˆ |i |¤ŽfS r$ )r r[ )r3 ÚargÚkw©r0 r r! ÚwrapRecordFunc s z4PySourceAuthority.wrapRecord.
.wrapRecordFuncr )r* r0 rz r ry r! Ú
wrapRecord s z PySourceAuthority.wrapRecordc C sN i }t j ¡ }dd„ |D ƒD ]}tt |ƒ}| |¡}|||tdƒd … < q|S )Nc S s g | ] }| d ¡r|‘qS )ÚRecord_)Ú
startswith)Ú.0Úxr r r! Ú
" s z:PySourceAuthority.setupConfigNamespace..r| )r r+ ÚkeysÚgetattrr{ Úlen)r* r_ r\ r> r0 r r r r! ro s
z&PySourceAuthority.setupConfigNamespaceN)rf rg rh ri r' r{ ro r r r r! rm s
rm c @ sH e Zd ZdZdd„ Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Z dd„ Z
dS )Ú
BindAuthorityz™
An Authority that loads U{BIND zone files
}.
Supports only C{$ORIGIN} and C{$TTL} directives.
c C sJ t |ƒ}t| ¡ d ƒ| _| ¡ d¡}| |¡}| |¡}| |¡ dS )z}
Load records from C{filename}.
@param filename: file to read from
@type filename: L{bytes}
ó .TN) r r ÚbasenameÚoriginÚ
getContentÚ
splitlinesÚ
stripCommentsÚcollapseContinuationsÚ
parseLines)r* r ÚfpÚlinesr r r! r' 1 s
zBindAuthority.loadFilec C s dd„ dd„ |D ƒD ƒS )z«
Strip comments from C{lines}.
@param lines: lines to work on
@type lines: iterable of L{bytes}
@return: C{lines} sans comments.
c s s4 | ]}| d ¡dkr
|p|d| d ¡… V qdS )ó ;éÿÿÿÿN)Úfind)r~ Úar r r! Ú K s
€ "ÿ
ÿz.BindAuthority.stripComments..c S s g | ]}| ¡ ‘qS r )Ústrip)r~ Úbr r r! r€ M s z/BindAuthority.stripComments..r )r* rŽ r r r! rŠ B s þzBindAuthority.stripCommentsc
C s° g }d}|D ]G}|dkr(| d¡dkr| |¡ q| |d| d¡… ¡ d}q| d¡dkrC|d d|d| d¡… 7 < d}q|d d| 7 < qtddd „ |D ƒƒS )
zÄ
Transform multiline statements into single lines.
@param lines: lines to work on
@type lines: iterable of L{bytes}
@return: iterable of continuous lines
r ó (r Nr
ó )ó c s s | ]}| ¡ V qd S r$ )r )r~ Úliner r r! r“ h s € z6BindAuthority.collapseContinuations..)r‘ rF Úfilter)r* rŽ ru r, r™ r r r! r‹ P s "z#BindAuthority.collapseContinuationsc C sŒ d}| j }i | _|D ]6}|d dkrt |d ¡}q
|d dkr%|d }q
|d dkr/tdƒ‚|d dkr9td ƒ‚| |||¡ q
|| _ d
S ) zs
Parse C{lines}.
@param lines: lines to work on
@type lines: iterable of L{bytes}
i0* r s $TTLr
s $ORIGINs $INCLUDEz"$INCLUDE directive not implementeds $GENERATEz#$GENERATE directive not implementedN)r‡ r4 r Ústr2timeÚNotImplementedErrorÚparseRecordLine)r* rŽ r; r‡ r™ r r r! rŒ j s
zBindAuthority.parseLinesc C sd | d¡s|d |dd… }n|dd… }t| d|› dƒ}|r*|||||ƒ dS td|›dƒ‚)a
Add a record to our authority. Expand domain with origin if necessary.
@param owner: origin?
@type owner: L{bytes}
@param ttl: time to live for the record
@type ttl: L{int}
@param domain: the domain for which the record is to be added
@type domain: L{bytes}
@param type: record type
@type type: L{str}
@param cls: record class
@type cls: L{str}
@param rdata: record data
@type rdata: L{list} of L{bytes}
r… Nr Úclass_z
Record class ú not supported)Úendswithr‚ rœ )r* Úownerr; r0 ÚdomainrQ Úrdatar r r r! Ú addRecord… s
zBindAuthority.addRecordc C sn t tdt|ƒ› dƒ}|r-||Ž }||_| j | ¡ g ¡ |¡ |dkr+||f| _dS dS t dt|ƒ›dƒ‚)a>
Simulate a class IN and recurse into the actual class.
@param ttl: time to live for the record
@type ttl: L{int}
@param type: record type
@type type: str
@param domain: the domain
@type domain: bytes
@param rdata:
@type rdata: bytes
r| NrJ z Record type rŸ )
r‚ r r r; r4 rs r6 rF rB rœ )r* r; r0 r¢ r£ r> r_ r r r! Úclass_IN¥ s ÿÿzBindAuthority.class_INc C sv dd„ t j ¡ D ƒ}dd„ t j ¡ D ƒ}||B }d}|}|d dkr+|dd… }|}n|d ¡ sA|d |vrA|d }|dd… }|d ¡ sM|d |v rR|} |}n
|d } |dd… }|d |v r|d }|dd… }|d ¡ r~t|d ƒ}|dd… }n"|d ¡ r¡t|d ƒ}|dd… }|d |v r¡|d }|dd… }|d }
|dd… } | ||t|
ƒ| t|ƒ| ¡ dS ) aƒ
Parse a C{line} from a zone file respecting C{origin} and C{ttl}.
Add resulting records to authority.
@param origin: starting point for the zone
@type origin: L{bytes}
@param ttl: time to live for the record
@type ttl: L{int}
@param line: zone file line to parse; split by word
@type line: L{list} of L{bytes}
c S ó h | ]}| d ¡’qS ©Úascii©Úencode)r~ Úqcr r r! Ú Ñ ó z0BindAuthority.parseRecordLine..c S r¦ r§ r© )r~ Úqtr r r! r¬ Ò r s INr ó @r
N)r Ú
QUERY_CLASSESÚvaluesÚ QUERY_TYPESÚisdigitr r¤ r ) r* r‡ r; r™ Ú queryClassesÚ
queryTypesÚmarkersrQ r¡ r¢ r0 r£ r r r! r  s@ € z BindAuthority.parseRecordLineN) rf rg rh ri r' rŠ r‹ rŒ r¤ r¥ r r r r r! r„ ) s r„ )r
)ri r r Útwisted.internetr Ú
twisted.namesr r r Útwisted.pythonr Útwisted.python.compatr r Útwisted.python.filepathr r" r% r# rm r„ r r r r! Ú s
' N!