=SrSSKJr SSKJr SSKJr SSKrSSKJr SSK J r SSK J r SS K J r SS K Jr SS KJr SS KJr SS KJr SSKJr SSKr\R."5 "SS\R05r"SS\5r"SS\5r"SS\5r"SS\5rSrSrS)SjrSr S*Sjr!S+Sjr"S+Sjr#Sr$S,S jr%S+S!jr&S+S"jr'S+S#jr(S$r)S+S%jr*S+S&jr+S'r,S-S(jr-g).z)Helper methods for importing record-sets.)absolute_import)division)unicode_literalsN)encoding) rdatatype)zone) record_types) svcb_stub)apis) exceptions)yamlc\rSrSrSrSrg)Error(z%Base exception for all import errors.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r-lib/googlecloudsdk/api_lib/dns/import_util.pyrr(s-rrc\rSrSrSrSrg)RecordsFileNotFound,z)The specified records file was not found.rNrrrrrr,s1rrc\rSrSrSrSrg)RecordsFileIsADirectory0z*The specified records file is a directory.rNrrrrrr0s2rrc\rSrSrSrSrg)UnableToReadRecordsFile4z;Unable to read record sets from the specified records file.rNrrrrr"r"4sCrr"c\rSrSrSrSrg)ConflictingRecordsFound8zCConflicts found between records being imported and current records.rNrrrrr%r%8sKrr%c SRSSURRU5URURUR UR UR455$)a\Returns the translation of the given SOA rdata. Args: rdata: Rdata, The data to be translated. origin: Name, The origin domain name. Returns: str, The translation of the given SOA rdata which includes all the required SOA fields. Note that the primary NS name is left in a substitutable form because it is always provided by Cloud DNS.  c3N# UHn[R"U5v M g7fN)six text_type).0xs r "_SOATranslation..Is$!1cmmA!s#%{0})joinrname derelativizeserialrefreshretryexpireminimumrdataorigins r_SOATranslationr=<s\   ++ " "6 * ,, -- ++ ,, --! rc[R"U5nURS5(aURS5(aU$SR U5$)aReturns the given text within quotes. Args: text: str, The text to be escaped. Returns: str, The given text within quotes. For further details on why this is necessary, please look at the TXT section at: https://cloud.google.com/dns/what-is-cloud-dns#supported_record_types. "z"{0}")rDecode startswithendswithformat)texts r QuotedTextrEUsC  $ __SdmmC00 K >>$ rc"URUSS9$)zReturns the given rdata as text (formatted by its .to_text() method). Args: rdata: Rdata, The data to be translated. origin: Name, The origin domain name. Returns: str, The textual presentation form of the given rdata. F)r< relativize)to_textr:s r_NullTranslationrIhs f 77rcBU[R:Xa[$[$)zReturns the rdata translation function for a record type. Args: rr_type: The record type Returns: The record type's translation function. )rSOAr=rI)rr_types rGetRdataTranslationrMus   rcHU(agX:XaU[R:Xagg)aReturns whether the given record should be filtered out. Args: name: string, The name of the resord set we are considering rdtype: RDataType or string, type of Record we are considering approving. origin: Name, The origin domain of the zone we are considering replace_origin_ns: Bool, Whether origin NS records should be imported Returns: True if the given record should be filtered out, false otherwise. FT)rNS)namerdtyper<replace_origin_nss r_FilterOutRecordrSs   ~&ILL0  rcUR[R;ag[R"SU5nUR 5nUR UlURU5R5Ul URUl [R"UR5Ul /nUH-nUR[UR5"Xr55 M/ XelU$)aReturns the Cloud DNS ResourceRecordSet for the given zone file record. Args: name: Name, Domain name of the zone record. rdset: Rdataset, The zone record object. origin: Name, The origin domain of the zone file. api_version: [str], the api version to use for creating the records. Returns: The ResourceRecordSet equivalent for the given zone record, or None for unsupported record types. Ndns)rQr SUPPORTED_TYPES core_apisGetMessagesModuleResourceRecordSetkindr4rHrPttlrtypeappendrMrrdatas)rPrdsetr< api_versionmessages record_setrdatasr;s r_RecordSetFromZoneRecordrds \\555   ( ( <())+*OO*/%%f-557*/99*.%%ell3*/ &e MM%ell3EBC rc[R"XSS9n0nUR5H=upV[XVURUS9nU(dM#XtUR UR 4'M? U$)a!Returns record-sets for the given domain imported from the given zone file. Args: zone_file: file, The zone file with records for the given domain. domain: str, The domain for which record-sets should be obtained. api_version: [str], the api version to use for creating the records. Returns: A (name, type) keyed dict of ResourceRecordSets that were obtained from the zone file. Note that only records of supported types are retrieved. Also, the primary NS field for SOA records is discarded since that is provided by Cloud DNS. F) check_originr`)r from_fileiterate_rdatasetsrdr<rPr\) zone_filedomainr` zone_contents record_setsrPr_rbs rRecordSetsFromZoneFilernsh..G-+"446kd) ])){DJz8B:??JOO45 7 rcXU[R;ag[R"U5$)aConverts string_type to an RdataType enum value if it is a standard type. Only standard record types can be converted to a RdataType, all other types will cause an exception. This method allow getting the standard enum type if available without throwing an exception if an extended type is provided. Args: string_type: [str] The record type as a string. Returns: The record type as an RdataType enum or None if the type is not a standard DNS type. N)r CLOUD_DNS_EXTENDED_TYPESr from_text) string_types r_ToStandardEnumTypeSaferss&L999    [ ))rc0n[R"SU5n[R"U5nUGH#n[ US5nU[ R ;a U(aUS[ R;aMFUR5nURUl USUl USUl USUl SU;a USUl O/SU;a)[R"UR US5UlU[$R&La1[(R*"SSURS S S 9URS 'XURUR4'GM& U$) a"Returns record-sets read from the given yaml file. Args: yaml_file: file, A yaml file with records. include_extended_records: [bool], If extended record should be included (otherwise they are silently skipped). api_version: [str], the api version to use for creating the records. Returns: A (name, type) keyed dict of ResourceRecordSets that were obtained from the yaml file. Note that only records of supported types are retrieved. Also, the primary NS field for SOA records is discarded since that is provided by Cloud DNS. rUr\rPr[r^ routingPolicyz\S+r1r)count)rWrXr load_allrsr rVrprYrZrPr[r\r^ api_encodingPyValueToMessageRRSetRoutingPolicyrurrKresub) yaml_fileinclude_extended_recordsr`rmrayaml_record_setsyaml_record_set rdata_typerbs rRecordSetsFromYamlFilersC"+  ( ( <(]]9-)o()@AJ555 $|'L'LL++-J ooJO%f-JO$U+JN%f-JOO#*95j O +!-!>!>  % % / *"j Y]]" ffVUJ4F4Fq4I+,.j7A*//235*8 rc[R"SU5nUR5nURUlURUlUR UlUR Ul[UR5UlU$)zReturns a copy of the given record-set. Args: record_set: ResourceRecordSet, Record-set to be copied. api_version: [str], the api version to use for creating the records. Returns: Returns a copy of the given record-set. rU) rWrXrYrZrPr\r[listr^)rbr`racopys r_RecordSetCopyrsg ( ( <(  # # %$oo$)oo$)oo$) ^^$(j(()$, +rc[XS9nURSRURSR5S5URS'X0:Xa [ X25$U$)aiReturns the replacement SOA record with restored primary NS name. Args: current_record: ResourceRecordSet, Current record-set. record_to_be_imported: ResourceRecordSet, Record-set to be imported. api_version: [str], the api version to use for creating the records. Returns: ResourceRecordSet, the replacement SOA record with restored primary NS name. rgr)rr^rCsplitNextSOARecordSetcurrent_recordrecord_to_be_importedr` replacements r_SOAReplacementr)sj4N+&..q188Q%%'*,+a" K 55 rc$[XS9nX0:XagU$)aReturns a record-set containing rrdata to be imported. Args: current_record: ResourceRecordSet, Current record-set. record_to_be_imported: ResourceRecordSet, Record-set to be imported. api_version: [str], the api version to use for creating the records. Returns: ResourceRecordSet, a record-set containing rrdata to be imported. None, if rrdata to be imported is identical to current rrdata. rgN)rrs r_RDataReplacementr?s4N+"  rcBU[R:Xa[$[$)aGets the RData replacement function for this type. Args: rdtype: RDataType, the type for which to fetch a replacement function. Returns: A function for replacing rdata of a record-set with rdata from another record-set with the same name and type. )rrKrr)rQs r_GetRDataReplacementrRs y}}  rc[XS9nURSR5n[[ US5S-S-5US'SR U5URS'U$)aReturns a new SOA record set with an incremented serial number. Args: soa_record_set: ResourceRecordSet, Current SOA record-set. api_version: [str], the api version to use for creating the records. Returns: A a new SOA record-set with an incremented serial number. rgrrvlr()rr^rstrintr2)soa_record_setr`next_soa_record_set rdata_partss rrrasi'~O&&q)//1+KN+a/G<=+a.#&88K#8a rcJ[UR5[UR5s=:H=(a S:HOs =(ab [URSR5[ R L=(a) [URSU5URS:H$)aReturns True if the change only contains an SOA increment, False otherwise. Args: change: Change, the change to be checked api_version: [str], the api version to use for creating the records. Returns: True if the change only contains an SOA increment, False otherwise. rvr)len additions deletionsrsr\rrKr)changer`s rIsOnlySOAIncrementrss f 3v'7'7#8 = =A = ? !&"2"21"5":": ;y}} L ? 6++A.& (+1+;+;A+> ?@rcNSRURUR5$)Nz{0} {1})rCrPr\)records r _NameAndTypers   &++v{{ 33rc 6[R"SU5nUR5n/Ul/Ul[ UR 55n[ UR 55n URU 5n U(dFU (a?[SR[U 5V s/sHn [X 5PM sn 55eU Hn X n Xn [U S5n[U RUUU5(aM8[U5"XUS9nU(dMQURR!U 5 URR!U5 M U R#U5H n URR!X5 M" UR#U 5Hn X n [U S5nU[$R&LaAURR!U 5 URR![)X55 MiU(dMr[U RUUU5(aMURR!U 5 M [+Xu5(agURR-[S9 URR-[S9 U$s sn f)aReturns a change for importing the given record-sets. Args: current: dict, (name, type) keyed dict of current record-sets. to_be_imported: dict, (name, type) keyed dict of record-sets to be imported. replace_all: bool, Whether the record-sets to be imported should replace the current record-sets. origin: string, the name of the apex zone ex. "foo.com" replace_origin_ns: bool, Whether origin NS records should be imported. api_version: [str], the api version to use for creating the records. Raises: ConflictingRecordsFound: If conflicting records are found. Returns: A Change that describes the actions required to import the given record-sets. rUz4The following records (name type) already exist: {0}rvrgN)key)rWrXChangerrsetkeys intersectionr%rCsortedrrsrSrPrr] differencerrKrrsort)currentto_be_imported replace_allr<rRr`rar current_keyskeys_to_be_importedintersecting_keysrrrrQrs r ComputeChangersS0 ( ( <( ?? &&&W\\^$,N//12"//0CD * !>EE39:K3L M3LC\', '3L M O PPc\N*/ $SV ,F N//""- / /)0 [Jk / ,! + +L 9c N/0: $ $%8 9c\N $SV ,F  n- .~KL -n.A.A.4.4.?AA n-:,, L)L) -K Ns$J r*)F)v1)Fr)FNFr).r __future__rrrr|apitools.base.pyrryrUrrgooglecloudsdk.api_lib.dnsr r googlecloudsdk.api_lib.utilr rWgooglecloudsdk.corer r googlecloudsdk.core.utilr+registerrrrr"r%r=rErIrMrSrdrnrsrrrrrrrrrrrrrs 0&' 5309*$-  .J  .2%23e3DeDLeL2 & 8 *<0*(5:'+1h(,& $ @ 4 $$)" Ir