o 2c?@s&dZddlZzddlZWn eyddlZYnwddlZddlZddl Zddl Zddl Zddl Zddl ZddlZddlZddlZGdddejjZGdddZGdddeZejjGd d d eZGd d d ejjZejjGd ddeZGdddejjZGdddejjZdS)zDNS Versioned Zones.Nc@seZdZdZdS)UseTransactionz-To alter a versioned zone, use a transaction.N)__name__ __module__ __qualname____doc__rrC/var/www/html/gps/gps/lib/python3.10/site-packages/dns/versioned.pyrsrc@s4eZdZddZddZddZddZd d Zd S) VersioncCs||_||_i|_dSN)zoneidnodes)selfr r rrr__init__s zVersion.__init__cCs6|r||jjstd|jjr||j}|S)Nz*name is not a subdomain of the zone origin) is_absolute is_subdomainr originKeyError relativizernamerrr_validate_name!s  zVersion._validate_namecCs||}|j|Sr )rr getrrrrget_node)s  zVersion.get_nodecCs(||}|dur dS||jj||Sr )r get_rdatasetr rdclassrrrdtypecoversnoderrrr-s zVersion.get_rdatasetcCs |jSr )r itemsrrrrr 3s z Version.itemsN)rrrrrrrr rrrrr s  r cs>eZdZd fdd ZddZddZdd Zd d ZZS) WritableVersionFcsXt|jdkr|jdjd}nd}t|||s"|j|j|j|_t|_ dS)Nr) len _versionsr superrr updatersetchanged)rr replacementr  __class__rrr8s zWritableVersion.__init__cCsp||}|j|}|dus|j|jkr6|j}|j|_|dur)|j|j||j|<|j ||S|Sr ) rr rr r node_factory rdatasetsextendr*add)rrrnew_noderrr _maybe_cowJs     zWritableVersion._maybe_cowcCs0||}||jvr|j|=|j|dSdSr )rr r*r1rrrr delete_nodeYs  zWritableVersion.delete_nodecCs||}||dSr )r3replace_rdataset)rrrdatasetrrrr put_rdataset_s zWritableVersion.put_rdatasetcCs8||}||jj||t|dkr|j|=dSdSNr)r3delete_rdatasetr rr%r rrrrr9cs   zWritableVersion.delete_rdatasetF) rrrrr3r4r7r9 __classcell__rrr,rr"7s r"cseZdZfddZZS)ImmutableVersioncsXt|jd|j|_|jD]}|j|}|r t||j|<qtj |jd|_dSNT) r'rr r r*r r ImmutableNodedns immutableDict)rversionrrr,rrrls  zImmutableVersion.__init__)rrrrr;rrr,rr<jsr<cs"eZdZdgZfddZZS)Noder cstd|_dSr8)r'rr r!r,rrrs  z Node.__init__)rrr __slots__rr;rrr,rrC~srCcsfeZdZdgZfddZejjdffdd Zejjdffdd Z ejjfd d Z d d Z Z S) r>r cs,t|j|_tdd|jD|_dS)NcSsg|]}tj|qSr)r?r6ImmutableRdataset).0rdsrrr sz*ImmutableNode.__init__..)r'rr tupler/)rrr,rrrs  zImmutableNode.__init__Fc|rtdt|||dSNr@F) TypeErrorr' find_rdatasetrrrrcreater,rrrMzImmutableNode.find_rdatasetcrJrK)rLr'rrNr,rrrrPzImmutableNode.get_rdatasetcCtdNr@rL)rrrrrrrr9zImmutableNode.delete_rdatasetcCrQrRrS)rr+rrrr5rTzImmutableNode.replace_rdataset) rrrrDrr? rdatatypeNONErMrr9r5r;rrr,rr>s r>cseZdZgdZeZejjddffdd Z d+ddZ d,d d Z d d Z d dZ ddZddZddZddZddZddZddZddZd,fdd Zd!d"Zejjdffd#d$ Zejjdffd%d& Zejjfd'd(Zd)d*ZZS)-Zone)r&_versions_lock _write_txn_write_waiters _write_event_pruning_policy_readersTNcspt|||t|_t|_|dur|j|_ n||_ d|_ d|_ t|_ t |_|dt||dS)aInitialize a versioned zone object. *origin* is the origin of the zone. It may be a ``dns.name.Name``, a ``str``, or ``None``. If ``None``, then the zone's origin will be set by the first ``$ORIGIN`` line in a zone file. *rdclass*, an ``int``, the zone's rdata class; the default is class IN. *relativize*, a ``bool``, determine's whether domain names are relativized to the zone's origin. The default is ``True``. *pruning policy*, a function taking a `Version` and returning a `bool`, or `None`. Should the version be pruned? If `None`, the default policy, which retains one version is used. N)r'r collectionsdequer& _threadingLock _version_lock_default_pruning_policyr\rYr[rZr)r]_commit_version_unlockedr")rrrrpruning_policyr,rrrs    z Zone.__init__c Cs(|dur |dur td|j{|dur0d}t|jD] }|j|kr&|}nq|dur/tdnE|durp|jr/sz0Zone._prune_versions_unlocked..r#)r%r&r]minr r\rw)r least_keptrrr_prune_versions_unlocked%s  zZone._prune_versions_unlockedcsDdur dkr tddurdd}nfdd}||dS)zYSet a pruning policy that retains up to the specified number of versions Nr$zmax versions must be at least 1cWry)NFr)_rrrpolicy=rzz%Zone.set_max_versions..policycst|jkSr )r%r&)r r max_versionsrrr@s)rfset_pruning_policy)rrrrrrset_max_versions6s   zZone.set_max_versionscCsH|dur|j}|j||_|WddS1swYdS)aSet the pruning policy for the zone. The *policy* function takes a `Version` and returns `True` if the version should be pruned, and `False` otherwise. `None` may also be specified for policy, in which case the default policy is used. Pruning checking proceeds from the least version and the first time the function returns `False`, the checking stops. I.e. the retained versions are always a consecutive sequence. N)rcrbr\r~)rrrrrrDs   "zZone.set_pruning_policycCs@|j|j||WddS1swYdSr )rbr]remover~rrorrr _end_readVs  "zZone._end_readcCs |j|ksJd|_|dSr )rYrxrrrr_end_write_unlocked[s zZone._end_write_unlockedcCs6|j||WddS1swYdSr )rbrrrrr _end_write`s "zZone._end_writecCsF|j|||j|_|jdur||_|dur!||dSdSr )r&rrr~r rrrrorBrrrrrdds  zZone._commit_version_unlockedcCs:|j||||WddS1swYdSr )rbrdrrrr_commit_versionns"zZone._commit_versioncs|rtt|Sr )rr' find_node)rrrOr,rrrrs zZone.find_nodecCtr rrrrrr4wrzzZone.delete_nodec$|rtt|||}tj|Sr )rr'rMr?r6rErrrrrOr6r,rrrMz zZone.find_rdatasetcrr )rr'rr?r6rErr,rrrrzZone.get_rdatasetcCrr rrrrrrrrr9rzzZone.delete_rdatasetcCrr r)rrr+rrrr5rzzZone.replace_rdataset)NNr:)rrrrDrCr.r? rdataclassINrrprvrxrcr~rrrrrrdrrr4rUrVrMrr9r5r;rrr,rrWs8  !/ rWcszeZdZdfdd ZeddZddZdd Zd d Zd d Z ddZ ddZ ddZ ddZ ddZddZZS)rkNcs"|du}t|||||_dSr )r'rrB)rr r+rB read_onlyr,rrrs zTransaction.__init__cCs|jSr )managerr!rrrr szTransaction.zonecCs"|jdusJt|j|j|_dSr )rBr"r r+r!rrrrtszTransaction._setup_versioncCs|j|||Sr )rBrrrrr _get_rdatasetzTransaction._get_rdatasetcCs|jrJ|j||dSr )rrBr7)rrr6rrr _put_rdatasets zTransaction._put_rdatasetcCs|jrJ|j|dSr )rrBr4rrrr _delete_names zTransaction._delete_namecCs|jrJ|j|||dSr )rrBr9rrrr_delete_rdatasets zTransaction._delete_rdatasetcCs|j|duSr )rBrrrrr _name_existsrzTransaction._name_existscCs|jrdSt|jjdkS)NFr)rr%rBr*r!rrr_changedszTransaction._changedcCsX|jr |j|dS|r$t|jjdkr$|j|t|j|jjdS|j |dSr8) rr rr%rBr*rr<rr)rcommitrrr_end_transactionszTransaction._end_transactioncCs|jjdur ||j_dSdSr )rBr)rrrrr _set_origins  zTransaction._set_originccs.|jD]\}}|D]}||fVq qdSr )rBr )rrrr6rrr_iterate_rdatasetss  zTransaction._iterate_rdatasetsr )rrrrpropertyr rtrrrrrrrrrr;rrr,rrks  rk)rr^ threadingr` ImportErrordummy_threading dns.exceptionr? dns.immutabledns.namedns.nodedns.rdataclass dns.rdatatype dns.rdatadns.rdtypes.ANY.SOAdns.transactiondns.zone exception DNSExceptionrr r"r@r<rrCr>r rW transactionrkrrrrs8   3 k