Attachment #10791 for bug #53623

View | Details | Raw Unified | Return to bug 53623 | Differences between
Collapse All | Expand All




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, **kwargs)
		dnsRecords.append(ndr_pack(a_record))

	# IPv6
	for a in object['attributes'].get('aAAARecord', []):
		a_record = AAAARecord(a, **kwargs)
		dnsRecords.append(ndr_pack(a_record))


def __unpack_aRecord(object):
	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:
			r.append(ndrRecord)
	return r


def __pack_soaRecord(object, dnsRecords):



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, **kwargs)
		dnsRecords.append(ndr_pack(a_record))



	for dnsRecord in dnsRecords:
		ndrRecord = ndr_unpack(dnsp.DnssrvRpcRecord, dnsRecord)
		if ndrRecord.wType == dnsp.DNS_TYPE_NS:
			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), **kwargs)
			dnsRecords.append(ndr_pack(mx_record))
			ud.debug(ud.LDAP, ud.INFO, '__pack_mxRecord: %s' % ndr_pack(mx_record))




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, **kwargs))
			dnsRecords.append(ndr_txt_record)
			ud.debug(ud.LDAP, ud.INFO, '__pack_txtRecord: %s' % ndr_txt_record)




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, **kwargs)
		dnsRecords.append(ndr_pack(c_record))





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, **kwargs)
		dnsRecords.append(ndr_pack(s))





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, **kwargs)
		dnsRecords.append(ndr_pack(ptr_record))



		return

	# unpack the host record
	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)

	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')

		newRecord = univention.admin.handlers.dns.host_record.object(None, s4connector.lo, position, dn=None, update_zone=False)
		newRecord.open()
		newRecord['name'] = relativeDomainName
		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()



	relativeDomainName = object['attributes']['relativeDomainName'][0].decode('UTF-8')

	# unpack the record
	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)

		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(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')

		newRecord = univention.admin.handlers.dns.ns_record.object(None, s4connector.lo, position, dn=None, update_zone=False)
		newRecord.open()
		newRecord['zone'] = relativeDomainName
		newRecord['zonettl'] = [min([r.dwTtlSeconds for r in ns_ndrRecord_list])]  # complex UDM syntax
		newRecord[udm_property] = ns
		newRecord.create()



		ud.debug(ud.LDAP, ud.INFO, "ucs_zone_create: ignoring DC=%s object" % (relativeDomainName,))
		return

	ns_ndrRecord_list = __unpack_nsRecord(object)
	ns = [__append_dot(r.data) for r in ns_ndrRecord_list]

	soa = __unpack_soaRecord(object)

	a_ndrRecord_list = __unpack_aRecord(object)

	mx = __unpack_mxRecord(object)


			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

		zone['expire'] = [soa['expire']]  # complex UDM syntax
		zone['ttl'] = [soa['ttl']]  # complex UDM syntax
		if dns_type == 'forward_zone':
			zone['a'] = [r.data for r in a_ndrRecord_list]
			zone['mx'] = mx
		zone.create()


Return to bug 53623