Attachment #9137 for bug #39539

View | Details | Raw Unified | Return to bug 39539
Collapse All | Expand All




	return options, zone_name, command, typ, arguments[3:]


def bind(timeout=None):
	"""Bind to LDAP service."""
	ucr = univention.config_registry.ConfigRegistry()
	ucr.load()

	timeout = timeout or time.time() + 120  # 2 minutes from now
	if time.time() > timeout:
		err = '%s: LDAP server %s unreachable, aborting' % (sys.argv[0], ucr['ldap/master'])
		ud.debug(ud.ADMIN, ud.WARN, err)
   pep8





import sys
import time
import ldap
from optparse import OptionParser
import univention.debug as ud
ud.init('/var/log/univention/directory-manager-cmd.log', ud.FLUSH, ud.FUNCTION)

'''  # FIXME: OptionParser reformats this
	global parser
	parser = OptionParser(usage=usage, description=description)
	parser.add_option(
		'--ignore-missing-zone',
		action='store_true', dest='ignore_missing_zone',
		help='Skip if zone does not exist')
	parser.add_option(
		'--ignore-exists',
		action='store_true', dest='ignore_exists',
		help='Skip if entry already exists')
	parser.add_option(
		'--quiet',
		action='store_true', dest='quiet',
		help='Turn off verbose messages')  # not implemented
	parser.add_option(
		'--reverse',
		action='store_true', dest='reverse',
		help='Modify revers zone instead of forward zone')
	parser.add_option(
		'--overwrite',
		action='store_true', dest='overwrite',
		help='Overwrite exising record')
	parser.add_option(
		'--stoptls',
		action='store_true', dest='stoptls',
		help='Disable TLS')
	parser.add_option(
		'--binddn',
		action='store', dest='binddn',
		help='bind DN')
	parser.add_option(
		'--bindpwd',
		action='store', dest='bindpwd',
		help='bind password')

	options, arguments = parser.parse_args()
	msg = None

	ucr.load()
	timeout = time.time() + 120  # 2 minutes from now
	if time.time() > timeout:
		err = '%s: LDAP server %s unreachable, aborting' % (sys.argv[0], ucr['ldap/master'])
			(sys.argv[0], ucr['ldap/master'])
		ud.debug(ud.ADMIN, ud.WARN, err)
		print >> sys.stderr, err
		sys.exit(1)

	start_tls = 0 if options.stoptls else 2
	else:
		start_tls = 2
	try:
		if options.binddn and options.bindpwd:
			lo = uldap.access(

		ud.debug(ud.ADMIN, ud.WARN, msg)
		print >> sys.stderr, msg
		sys.exit(1)
	except (univention.admin.uexceptions.ldapError, ldap.LDAPError):
		msg = '%s: timeout while trying to contact LDAP server %s' % (sys.argv[0], ucr['ldap/master'])
		msg = '%s: timeout while trying to contact LDAP server %s' % \
			(sys.argv[0], ucr['ldap/master'])
		ud.debug(ud.ADMIN, ud.WARN, msg)
		print >> sys.stderr, msg
		time.sleep(10)
		return bind(timeout)  # recursion


def lookup_zone(zone_name):
	"""Lookup zone and return UDM object."""
	if not options.reverse:
		zones = forward_zone.lookup(co, lo, '(zone=%s)' % (zone_name,), scope='domain', base=position.getDomain(), unique=True)
			scope='domain', base=position.getDomain(), unique=True)
	else:
		zones = reverse_zone.lookup(co, lo, '(subnet=%s)' % (zone_name,), scope='domain', base=position.getDomain(), unique=True)
			scope='domain', base=position.getDomain(), unique=True)
	if not zones:
		if options.ignore_missing_zone:
			sys.exit(0)

	location = [priority, weight, port, host]
	filt = univention.admin.filter.expression('name', name)

	records = srv_record.lookup(co, lo, filt, scope='domain', base=position.getDomain(), superordinate=zone, unique=True)
			base=position.getDomain(), superordinate=zone, unique=True)
	if records:
		record = records[0]
	else:

	location = [priority, weight, port, host]
	filt = univention.admin.filter.expression('name', name)

	records = srv_record.lookup(co, lo, filt, scope='domain', base=position.getDomain(), superordinate=zone, unique=True)
			base=position.getDomain(), superordinate=zone, unique=True)
	if records:
		record = records[0]
	else:

def add_txt_record(name, text):
	"""Add DNS text record."""
	filt = univention.admin.filter.expression('name', name)
	records = txt_record.lookup(co, lo, filt, scope='domain', base=position.getDomain(), superordinate=zone, unique=True)
			base=position.getDomain(), superordinate=zone, unique=True)
	if records:
		record = records[0]
	else:

def add_a_record(name, *adresses):
	"""Add DNS IPv4 address records."""
	filt = univention.admin.filter.expression('name', name)
	records = host_record.lookup(co, lo, filt, scope='domain', base=position.getDomain(), superordinate=zone, unique=True)
			base=position.getDomain(), superordinate=zone, unique=True)
	if records:
		record = records[0]
	else:

def add_cname_record(name, cname):
	"""Add DNS canonical name record."""
	filt = univention.admin.filter.expression('name', name)
	records = alias.lookup(co, lo, filt, scope='domain', base=position.getDomain(), superordinate=zone, unique=True)
			base=position.getDomain(), superordinate=zone, unique=True)
	if records:
		record = records[0]
	else:

		record['name'] = name
		record['zonettl'] = ['80600']

	if record['cname'] and not (record['cname'] == cname or options.overwrite or options.ignore_exists):
			options.overwrite or options.ignore_exists):
		print >> sys.stderr, 'E: Record exists and points to different address'
		sys.exit(1)
	if record['cname'] == cname:

def add_ptr_record(address, ptr):
	"""Add DNS pointer record."""
	filt = univention.admin.filter.expression('address', address)
	records = ptr_record.lookup(co, lo, filt, scope='domain', base=position.getDomain(), superordinate=zone, unique=True)
			base=position.getDomain(), superordinate=zone, unique=True)
	if records:
		record = records[0]
	else:
		record = ptr_record.object(co, lo, position, superordinate=zone)
		record['address'] = address

	if record['ptr_record'] and not (record['ptr_record'] == ptr or ptr in record['ptr_record'] or options.overwrite):
			options.overwrite):
		print >> sys.stderr, 'E: Record exists and points to different address'
		sys.exit(1)
	if record['ptr_record'] == ptr:

			print >> sys.stderr, 'E: Object "%s" exists' % (ex,)
			raise
			sys.exit(1)
	except (ValueError, TypeError, univention.admin.uexceptions.valueInvalidSyntax, univention.admin.uexceptions.valueRequired) as ex:
			univention.admin.uexceptions.valueInvalidSyntax,
			univention.admin.uexceptions.valueRequired) as ex:
		print >> sys.stderr, 'E: failed %s' % (ex,)
		raise
		sys.exit(1)

Return to bug 39539