Attachment 10791 Details for Bug 53623

[patch] bug53623_incomplete_draft.patch

bug53623_incomplete_draft.patch (text/plain), 8.60 KB, created by Arvid Requate on 2021-08-03 13:52 CEST

(hide)

Description:

Filename:

MIME Type:

Creator: Arvid Requate

Created: 2021-08-03 13:52 CEST

Size: 8.60 KB

patch

obsolete

>diff --git a/services/univention-s4-connector/modules/univention/s4connector/s4/dns.py b/services/univention-s4-connector/modules/univention/s4connector/s4/dns.py
>index 8a6c170c5d..9603b0e8e5 100644
>--- a/services/univention-s4-connector/modules/univention/s4connector/s4/dns.py
>+++ b/services/univention-s4-connector/modules/univention/s4connector/s4/dns.py
>@@ -498,25 +498,30 @@ def __create_s4_dns_node(s4connector, dnsNodeDn, relativeDomainNames, dnsRecords
> def __pack_aRecord(object, dnsRecords):
> 	# add aRecords
> 
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	# IPv4
> 	for a in object['attributes'].get('aRecord', []):
>-		a_record = ARecord(a)
>+		a_record = ARecord(a, **kwargs)
> 		dnsRecords.append(ndr_pack(a_record))
> 
> 	# IPv6
> 	for a in object['attributes'].get('aAAARecord', []):
>-		a_record = AAAARecord(a)
>+		a_record = AAAARecord(a, **kwargs)
> 		dnsRecords.append(ndr_pack(a_record))
> 
> 
> def __unpack_aRecord(object):
>-	a = []
>+	r = []
> 	dnsRecords = object['attributes'].get('dnsRecord', [])
> 	for dnsRecord in dnsRecords:
> 		ndrRecord = ndr_unpack(dnsp.DnssrvRpcRecord, dnsRecord)
> 		if ndrRecord.wType == dnsp.DNS_TYPE_A or ndrRecord.wType == dnsp.DNS_TYPE_AAAA:
>-			a.append(ndrRecord.data)
>-	return a
>+			r.append(ndrRecord)
>+	return r
> 
> 
> def __pack_soaRecord(object, dnsRecords):
>@@ -553,8 +558,13 @@ def __unpack_soaRecord(object):
> 
> 
> def __pack_nsRecord(object, dnsRecords):
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	for nSRecord in object['attributes'].get('nSRecord', []):
>-		a_record = NSRecord(nSRecord)
>+		a_record = NSRecord(nSRecord, **kwargs)
> 		dnsRecords.append(ndr_pack(a_record))
> 
> 
>@@ -564,18 +574,23 @@ def __unpack_nsRecord(object):
> 	for dnsRecord in dnsRecords:
> 		ndrRecord = ndr_unpack(dnsp.DnssrvRpcRecord, dnsRecord)
> 		if ndrRecord.wType == dnsp.DNS_TYPE_NS:
>-			ns.append(__append_dot(ndrRecord.data))
>+			ns.append(ndrRecord)
> 	return ns
> 
> 
> def __pack_mxRecord(object, dnsRecords):
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	for mXRecord in object['attributes'].get('mXRecord', []):
> 		if mXRecord:
> 			ud.debug(ud.LDAP, ud.INFO, '__pack_mxRecord: %s' % mXRecord)
> 			mx = mXRecord.split(b' ')
> 			priority = mx[0]
> 			name = mx[1]
>-			mx_record = MXRecord(name, int(priority))
>+			mx_record = MXRecord(name, int(priority), **kwargs)
> 			dnsRecords.append(ndr_pack(mx_record))
> 			ud.debug(ud.LDAP, ud.INFO, '__pack_mxRecord: %s' % ndr_pack(mx_record))
> 
>@@ -591,11 +606,16 @@ def __unpack_mxRecord(object):
> 
> 
> def __pack_txtRecord(object, dnsRecords):
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	for txtRecord in object['attributes'].get('tXTRecord', []):
> 		if txtRecord:
> 			ud.debug(ud.LDAP, ud.INFO, '__pack_txtRecord: %s' % txtRecord)
> 			token_list = TXT.from_text(rdataclass.IN, rdatatype.TXT, Tokenizer(txtRecord)).strings
>-			ndr_txt_record = ndr_pack(TXTRecord(token_list))
>+			ndr_txt_record = ndr_pack(TXTRecord(token_list, **kwargs))
> 			dnsRecords.append(ndr_txt_record)
> 			ud.debug(ud.LDAP, ud.INFO, '__pack_txtRecord: %s' % ndr_txt_record)
> 
>@@ -612,9 +632,14 @@ def __unpack_txtRecord(object):
> 
> 
> def __pack_cName(object, dnsRecords):
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	for c in object['attributes'].get('cNAMERecord', []):
> 		c = __remove_dot(c)
>-		c_record = CNameRecord(c)
>+		c_record = CNameRecord(c, **kwargs)
> 		dnsRecords.append(ndr_pack(c_record))
> 
> 
>@@ -632,13 +657,18 @@ def __unpack_cName(object):
> 
> 
> def __pack_sRVrecord(object, dnsRecords):
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	for srvRecord in object['attributes'].get('sRVRecord', []):
> 		srv = srvRecord.split(b' ')
> 		priority = int(srv[0])
> 		weight = int(srv[1])
> 		port = int(srv[2])
> 		target = __remove_dot(srv[3])
>-		s = SRVRecord(target, port, priority, weight)
>+		s = SRVRecord(target, port, priority, weight, **kwargs)
> 		dnsRecords.append(ndr_pack(s))
> 
> 
>@@ -653,9 +683,14 @@ def __unpack_sRVrecord(object):
> 
> 
> def __pack_ptrRecord(object, dnsRecords):
>+	kwargs = {}
>+	ttl = object['attributes'].get('dNSTTL', [])
>+	if ttl:
>+		kwargs['ttl'] = int(ttl[0])
>+
> 	for ptr in object['attributes'].get('pTRRecord', []):
> 		ptr = __remove_dot(ptr)
>-		ptr_record = PTRRecord(ptr)
>+		ptr_record = PTRRecord(ptr, **kwargs)
> 		dnsRecords.append(ndr_pack(ptr_record))
> 
> 
>@@ -923,7 +958,7 @@ def ucs_host_record_create(s4connector, object):
> 		return
> 
> 	# unpack the host record
>-	a = __unpack_aRecord(object)
>+	a_ndrRecord_list = __unpack_aRecord(object)
> 
> 	# Does a host record for this zone already exist?
> 	ol_filter = format_escaped('(&(relativeDomainName={0!e})(zoneName={1!e}))', relativeDomainName, zoneName)
>@@ -931,8 +966,10 @@ def ucs_host_record_create(s4connector, object):
> 	if len(searchResult) > 0:
> 		newRecord = univention.admin.handlers.dns.host_record.object(None, s4connector.lo, position=None, dn=searchResult[0][0], update_zone=False)
> 		newRecord.open()
>+		a = [r.data for r in a_ndrRecord_list]
> 		if set(newRecord['a']) != set(a):
> 			newRecord['a'] = a
>+			newRecord['zonettl'] = [min([r.dwTtlSeconds for r in a_ndrRecord_list])]  # complex UDM syntax
> 			newRecord.modify()
> 		else:
> 			ud.debug(ud.LDAP, ud.INFO, 'ucs_host_record_create: do not modify host record')
>@@ -946,7 +983,8 @@ def ucs_host_record_create(s4connector, object):
> 		newRecord = univention.admin.handlers.dns.host_record.object(None, s4connector.lo, position, dn=None, update_zone=False)
> 		newRecord.open()
> 		newRecord['name'] = relativeDomainName
>-		newRecord['a'] = a
>+		newRecord['a'] = [r.data for r in a_ndrRecord_list]
>+		newRecord['zonettl'] = [min([r.dwTtlSeconds for r in a_ndrRecord_list])]  # complex UDM syntax
> 		newRecord.create()
> 
> 
>@@ -1281,7 +1319,8 @@ def ucs_ns_record_create(s4connector, object):
> 	relativeDomainName = object['attributes']['relativeDomainName'][0].decode('UTF-8')
> 
> 	# unpack the record
>-	c = __unpack_nsRecord(object)
>+	ns_ndrRecord_list = __unpack_nsRecord(object)
>+	ns = [__append_dot(r.data) for r in ns_ndrRecord_list]
> 
> 	# Does a host record for this zone already exist?
> 	ol_filter = format_escaped('(&(relativeDomainName={0!e})(zoneName={1!e}))', relativeDomainName, zoneName)
>@@ -1290,8 +1329,9 @@ def ucs_ns_record_create(s4connector, object):
> 		foundRecord = univention.admin.handlers.dns.ns_record.object(None, s4connector.lo, position=None, dn=searchResult[0][0], update_zone=False)
> 		foundRecord.open()
> 
>-		if set(foundRecord[udm_property]) != set(c):
>-			foundRecord[udm_property] = c
>+		if set(foundRecord[udm_property]) != set(ns):
>+			foundRecord[udm_property] = ns
>+			newRecord['zonettl'] = [min([r.dwTtlSeconds for r in ns_ndrRecord_list])]  # complex UDM syntax
> 			foundRecord.modify()
> 		else:
> 			ud.debug(ud.LDAP, ud.INFO, 'ucs_ns_record_create: do not modify ns record')
>@@ -1302,7 +1342,8 @@ def ucs_ns_record_create(s4connector, object):
> 		newRecord = univention.admin.handlers.dns.ns_record.object(None, s4connector.lo, position, dn=None, update_zone=False)
> 		newRecord.open()
> 		newRecord['zone'] = relativeDomainName
>-		newRecord[udm_property] = c
>+		newRecord['zonettl'] = [min([r.dwTtlSeconds for r in ns_ndrRecord_list])]  # complex UDM syntax
>+		newRecord[udm_property] = ns
> 		newRecord.create()
> 
> 
>@@ -1343,11 +1384,12 @@ def ucs_zone_create(s4connector, object, dns_type):
> 		ud.debug(ud.LDAP, ud.INFO, "ucs_zone_create: ignoring DC=%s object" % (relativeDomainName,))
> 		return
> 
>-	ns = __unpack_nsRecord(object)
>+	ns_ndrRecord_list = __unpack_nsRecord(object)
>+	ns = [__append_dot(r.data) for r in ns_ndrRecord_list]
> 
> 	soa = __unpack_soaRecord(object)
> 
>-	a = __unpack_aRecord(object)
>+	a_ndrRecord_list = __unpack_aRecord(object)
> 
> 	mx = __unpack_mxRecord(object)
> 
>@@ -1399,6 +1441,7 @@ def ucs_zone_create(s4connector, object, dns_type):
> 			aRecords = s4connector.configRegistry.get('connector/s4/mapping/dns/forward_zone/%s/static/ipv4' % zoneName.lower())
> 			aAAARecords = s4connector.configRegistry.get('connector/s4/mapping/dns/forward_zone/%s/static/ipv6' % zoneName.lower())
> 			if not aRecords and not aAAARecords:
>+				a = [r.data for r in a_ndrRecord_list]
> 				if set(a) != set(zone['a']):
> 					zone['a'] = a
> 					modify = True
>@@ -1430,7 +1473,7 @@ def ucs_zone_create(s4connector, object, dns_type):
> 		zone['expire'] = [soa['expire']]  # complex UDM syntax
> 		zone['ttl'] = [soa['ttl']]  # complex UDM syntax
> 		if dns_type == 'forward_zone':
>-			zone['a'] = a
>+			zone['a'] = [r.data for r in a_ndrRecord_list]
> 			zone['mx'] = mx
> 		zone.create()
>

Actions: View | Diff

Attachments on bug 53623: 10791 | 10792 | 10794