+ from lib389._constants import ReplicaRole, DSRC_HOME, DEFAULT_BENAME

+ from lib389.utils import is_a_dn, copy_with_permissions, ds_supports_new_changelog, ensure_str

+ from lib389.backend import Backends

+ from lib389.replica import Replicas, ReplicationMonitor, BootstrapReplicationManager, Changelog5, ChangelogLDIF, Changelog

+     if not ds_supports_new_changelog():

+         cl = Changelog5(inst)

+         try:

+             cl.create(properties={

+                 'cn': 'changelog5',

+                 'nsslapd-changelogdir': inst.get_changelog_dir()

+             })

+         except ldap.ALREADY_EXISTS:

+             pass

+ # This subcommand is available when 'not ds_supports_new_changelog'

+ # This subcommand is available when 'not ds_supports_new_changelog'

+ # This subcommand is available when 'not ds_supports_new_changelog'

+ # This subcommand is available when 'not ds_supports_new_changelog'

+ # This subcommand is available when 'ds_supports_new_changelog'

+ # that means there is a changelog config entry per backend (aka suffix)

+ def set_per_backend_cl(inst, basedn, log, args):

+     suffix = args.suffix

+     cl = Changelog(inst, suffix)

+     attrs = _args_to_attrs(args)

+     replace_list = []

+     did_something = False

+     for attr, value in attrs.items():

+         if value == "":

+             cl.remove_all(attr)

+             did_something = True

+         else:

+             replace_list.append((attr, value))

+     if len(replace_list) > 0:

+         cl.replace_many(*replace_list)

+     elif not did_something:

+         raise ValueError("There are no changes to set for the replication changelog")

+ 

+     log.info("Successfully updated replication changelog")

+ 

+ # This subcommand is available when 'ds_supports_new_changelog'

+ # that means there is a changelog config entry per backend (aka suffix)

+ def get_per_backend_cl(inst, basedn, log, args):

+     suffix = args.suffix

+     cl = Changelog(inst, suffix)

+     if args and args.json:

+         log.info(cl.get_all_attrs_json())

+     else:

+         log.info(cl.display())

+ 

+     repl_set_per_backend_cl = repl_subcommands.add_parser('set-changelog', help='Set replication changelog attributes.')

+     repl_set_per_backend_cl.set_defaults(func=set_per_backend_cl)

+     repl_set_per_backend_cl.add_argument('--suffix', required=True, help='The suffix that uses the changelog')

+     repl_set_per_backend_cl.add_argument('--max-entries', help="The maximum number of entries to get in the replication changelog")

+     repl_set_per_backend_cl.add_argument('--max-age', help="The maximum age of a replication changelog entry")

+     repl_set_per_backend_cl.add_argument('--trim-interval', help="The interval to check if the replication changelog can be trimmed")

+     repl_get_per_backend_cl = repl_subcommands.add_parser('get-changelog', help='Display replication changelog attributes.')

+     repl_get_per_backend_cl.set_defaults(func=get_per_backend_cl)

+     repl_get_per_backend_cl.add_argument('--suffix', required=True, help='The suffix that uses the changelog')

+                           ensure_list_str, ds_is_older, copy_with_permissions,

+                           ds_supports_new_changelog)

+ class Changelog(DSLdapObject):

+     """Represents the Directory Server changelog of a specific backend. This is used for

+     replication.

+ 

+     :param instance: An instance

+     :type instance: lib389.DirSrv

+     """

+     def __init__(self, instance, suffix=None, dn=None):

+         from lib389.backend import Backends

+         super(Changelog, self).__init__(instance, dn)

+         self._rdn_attribute = 'cn'

+         self._create_objectclasses = [

+             'top',

+             'extensibleobject',

+         ]

+         if not ds_supports_new_changelog():

+             raise ValueError('changelog (integrated to main database) is not supported in that version of the server')

+         if not suffix:

+             raise ValueError('A changelog is specific to a suffix and the suffix value is missing')

+ 

+         # retrieve the backend associated to the provided suffix

+         be_insts = Backends(instance).list()

+         found_suffix = False

+         for be in be_insts:

+             be_suffix = be.get_attr_val_utf8_l('nsslapd-suffix')

+             if suffix == be_suffix:

+                 found_suffix = True

+                 break

+         if not found_suffix:

+             raise ValueError(f'No backend associated with nsslapd-suffix "{suffix}"')

+ 

+         # changelog is a child of the backend

+         self._dn = 'cn=changelog,' + be.dn

+ 

+     def set_max_entries(self, value):

+         """Configure the max entries the changelog can hold.

+ 

+         :param value: the number of entries.

+         :type value: str

+         """

+         self.replace('nsslapd-changelogmaxentries', value)

+ 

+     def set_trim_interval(self, value):

+         """The time between changelog trims in seconds.

+ 

+         :param value: The time in seconds

+         :type value: str

+         """

+         self.replace('nsslapd-changelogtrim-interval', value)

+ 

+     def set_max_age(self, value):

+         """The maximum age of entries in the changelog.

+ 

+         :param value: The age with a time modifier of s, m, h, d, w.

+         :type value: str

+         """

+ 

+         self.replace('nsslapd-changelogmaxage', value)

+