Changeset 1271

Timestamp:

Mar 28, 2023, 4:18:16 PM (20 months ago)

Author:

joergs

Message:

support --dry-run parameter

File:

• dassldapsync/dassldapsync.py (modified) (8 diffs)

dassldapsync/dassldapsync.py

@@ -34 +34 @@
     parser = argparse.ArgumentParser(description='Synchronize the content of two LDAP servers.')
     parser.add_argument('-d', '--debug', action='store_true', help="enable debug output")
+    parser.add_argument('-n', '--dry-run', action='store_true', dest='dryrun', help="dry run")
     parser.add_argument('configfile', default=configfile,
                         help="Configuration file [default: {}]".format(configfile))
@@ -41 +42 @@
 class Options(object):
     def __init__(self):
-        self.delete = True
+        self.create = False
+        self.delete = False
         self.starttls = False
         self.updateonly = False
@@ -198 +200 @@
                 existingDestDn, existingDestEntry = searchresult[0]
                 if existingDestDn.lower() != dn.lower():
-                    self.con.modrdn_s(existingDestDn, dn)
+                    if not self.options.dryrun:
+                        self.con.modrdn_s(existingDestDn, dn)
                     self.notify_renamed(existingDestDn, dn,
                                         existingDestEntry[self.options.renameattr][0],
@@ -262 +265 @@
                 try:
                     self.logger.debug('mod_attrs: ' + str(mod_attrs))
-                    self.con.modify_s(srcDn, mod_attrs)
+                    if not self.options.dryrun:
+                        self.con.modify_s(srcDn, mod_attrs)
                     self.notify_modified(srcDn)
                 except:
@@ -271 +275 @@
 
         except ldap.NO_SUCH_OBJECT:
-            if not self.options.updateonly:
+            if self.options.create:
                 try:
                     entry = ldap.modlist.addModlist(srcAttributes, self.junk_attrs)
-                    self.con.add_s(srcDn, entry)
+                    if not self.options.dryrun:
+                        self.con.add_s(srcDn, entry)
                     self.notify_created(srcDn)
                 except (ldap.OBJECT_CLASS_VIOLATION,
@@ -312 +317 @@
             if self.__is_dn_included(dn):
                 try:
-                    self.con.delete_s(dn)
+                    if not self.options.dryrun:
+                        self.con.delete_s(dn)
                     self.notify_deleted(dn)
                 except:
@@ -330 +336 @@
         update_objects = self.__adapt_source_ldap_objects(searchresult)
         self.__syncLdapDestination(update_objects)
-        if self.options.delete and not self.options.updateonly:
+        if self.options.delete:
             self.__deleteDestLdapObjects(update_objects)
         self.con.unbind()
@@ -609 +615 @@
         pass
 
-    options.updateonly = not config.getboolean("destination", "create", fallback=False)
+    options.dryrun = args.dryrun
+    options.create = config.getboolean("destination", "create", fallback=False)
     options.delete = config.getboolean("destination", "delete", fallback=False)    
     options.starttls = config.getboolean("destination", "starttls", fallback=False)