From 8b0ba11c3dfb577d1696f4b71a6f4e9f8d42349f Mon Sep 17 00:00:00 2001

From: Pierre Rogier <progier@redhat.com>

Date: Mon, 30 Nov 2020 12:42:17 +0100

Subject: [PATCH] Add dsconf replication monitor test case (gitHub issue 4449)

 in  1.4.3 branch

---

 .../tests/suites/clu/repl_monitor_test.py     | 234 ++++++++++++++++++

 1 file changed, 234 insertions(+)

 create mode 100644 dirsrvtests/tests/suites/clu/repl_monitor_test.py

diff --git a/dirsrvtests/tests/suites/clu/repl_monitor_test.py b/dirsrvtests/tests/suites/clu/repl_monitor_test.py

new file mode 100644

index 000000000..b03d170c8

--- /dev/null

+++ b/dirsrvtests/tests/suites/clu/repl_monitor_test.py

@@ -0,0 +1,234 @@

+# --- BEGIN COPYRIGHT BLOCK ---

+# Copyright (C) 2020 Red Hat, Inc.

+# All rights reserved.

+#

+# License: GPL (version 3 or any later version).

+# See LICENSE for details.

+# --- END COPYRIGHT BLOCK ---

+#

+import time

+import subprocess

+import pytest

+

+from lib389.cli_conf.replication import get_repl_monitor_info

+from lib389.tasks import *

+from lib389.utils import *

+from lib389.topologies import topology_m2

+from lib389.cli_base import FakeArgs

+from lib389.cli_base.dsrc import dsrc_arg_concat

+from lib389.cli_base import connect_instance

+

+pytestmark = pytest.mark.tier0

+

+LOG_FILE = '/tmp/monitor.log'

+logging.getLogger(__name__).setLevel(logging.DEBUG)

+log = logging.getLogger(__name__)

+

+

+@pytest.fixture(scope="function")

+def set_log_file(request):

+    fh = logging.FileHandler(LOG_FILE)

+    fh.setLevel(logging.DEBUG)

+    log.addHandler(fh)

+

+    def fin():

+        log.info('Delete files')

+        os.remove(LOG_FILE)

+

+        config = os.path.expanduser(DSRC_HOME)

+        if os.path.exists(config):

+            os.remove(config)

+

+    request.addfinalizer(fin)

+

+

+def check_value_in_log_and_reset(content_list, second_list=None, single_value=None, error_list=None):

+    with open(LOG_FILE, 'r+') as f:

+        file_content = f.read()

+

+        for item in content_list:

+            log.info('Check that "{}" is present'.format(item))

+            assert item in file_content

+

+        if second_list is not None:

+            log.info('Check for "{}"'.format(second_list))

+            for item in second_list:

+                assert item in file_content

+

+        if single_value is not None:

+            log.info('Check for "{}"'.format(single_value))

+            assert single_value in file_content

+

+        if error_list is not None:

+            log.info('Check that "{}" is not present'.format(error_list))

+            for item in error_list:

+                assert item not in file_content

+

+        log.info('Reset log file')

+        f.truncate(0)

+

+

+@pytest.mark.ds50545

+@pytest.mark.bz1739718

+@pytest.mark.skipif(ds_is_older("1.4.0"), reason="Not implemented")

+def test_dsconf_replication_monitor(topology_m2, set_log_file):

+    """Test replication monitor that was ported from legacy tools

+

+    :id: ce48020d-7c30-41b7-8f68-144c9cd757f6

+    :setup: 2 MM topology

+    :steps:

+         1. Create DS instance

+         2. Run replication monitor with connections option

+         3. Run replication monitor with aliases option

+         4. Run replication monitor with --json option

+         5. Run replication monitor with .dsrc file created

+         6. Run replication monitor with connections option as if using dsconf CLI

+    :expectedresults:

+         1. Success

+         2. Success

+         3. Success

+         4. Success

+         5. Success

+         6. Success

+    """

+

+    m1 = topology_m2.ms["master1"]

+    m2 = topology_m2.ms["master2"]

+

+    alias_content = ['Supplier: M1 (' + m1.host + ':' + str(m1.port) + ')',

+                     'Supplier: M2 (' + m2.host + ':' + str(m2.port) + ')']

+

+    connection_content = 'Supplier: '+ m1.host + ':' + str(m1.port)

+    content_list = ['Replica Root: dc=example,dc=com',

+                    'Replica ID: 1',

+                    'Replica Status: Available',

+                    'Max CSN',

+                    'Status For Agreement: "002" ('+ m2.host + ':' + str(m2.port) + ')',

+                    'Replica Enabled: on',

+                    'Update In Progress: FALSE',

+                    'Last Update Start:',

+                    'Last Update End:',

+                    'Number Of Changes Sent:',

+                    'Number Of Changes Skipped: None',

+                    'Last Update Status: Error (0) Replica acquired successfully: Incremental update succeeded',

+                    'Last Init Start:',

+                    'Last Init End:',

+                    'Last Init Status:',

+                    'Reap Active: 0',

+                    'Replication Status: In Synchronization',

+                    'Replication Lag Time:',

+                    'Supplier: ',

+                     m2.host + ':' + str(m2.port),

+                    'Replica Root: dc=example,dc=com',

+                    'Replica ID: 2',

+                    'Status For Agreement: "001" (' + m1.host + ':' + str(m1.port)+')']

+

+    error_list = ['consumer (Unavailable)',

+                  'Failed to retrieve database RUV entry from consumer']

+

+    json_list = ['type',

+                 'list',

+                 'items',

+                 'name',

+                 m1.host + ':' + str(m1.port),

+                 'data',

+                 '"replica_id": "1"',

+                 '"replica_root": "dc=example,dc=com"',

+                 '"replica_status": "Available"',

+                 'maxcsn',

+                 'agmts_status',

+                 'agmt-name',

+                 '002',

+                 'replica',

+                 m2.host + ':' + str(m2.port),

+                 'replica-enabled',

+                 'update-in-progress',

+                 'last-update-start',

+                 'last-update-end',

+                 'number-changes-sent',

+                 'number-changes-skipped',

+                 'last-update-status',

+                 'Error (0) Replica acquired successfully: Incremental update succeeded',

+                 'last-init-start',

+                 'last-init-end',

+                 'last-init-status',

+                 'reap-active',

+                 'replication-status',

+                 'In Synchronization',

+                 'replication-lag-time',

+                 '"replica_id": "2"',

+                 '001',

+                 m1.host + ':' + str(m1.port)]

+

+    dsrc_content = '[repl-monitor-connections]\n' \

+                   'connection1 = ' + m1.host + ':' + str(m1.port) + ':' + DN_DM + ':' + PW_DM + '\n' \

+                   'connection2 = ' + m2.host + ':' + str(m2.port) + ':' + DN_DM + ':' + PW_DM + '\n' \

+                   '\n' \

+                   '[repl-monitor-aliases]\n' \

+                   'M1 = ' + m1.host + ':' + str(m1.port) + '\n' \

+                   'M2 = ' + m2.host + ':' + str(m2.port)

+

+    connections = [m1.host + ':' + str(m1.port) + ':' + DN_DM + ':' + PW_DM,

+                   m2.host + ':' + str(m2.port) + ':' + DN_DM + ':' + PW_DM]

+

+    aliases = ['M1=' + m1.host + ':' + str(m1.port),

+               'M2=' + m2.host + ':' + str(m2.port)]

+

+    args = FakeArgs()

+    args.connections = connections

+    args.aliases = None

+    args.json = False

+

+    log.info('Run replication monitor with connections option')

+    get_repl_monitor_info(m1, DEFAULT_SUFFIX, log, args)

+    check_value_in_log_and_reset(content_list, connection_content, error_list=error_list)

+

+    log.info('Run replication monitor with aliases option')

+    args.aliases = aliases

+    get_repl_monitor_info(m1, DEFAULT_SUFFIX, log, args)

+    check_value_in_log_and_reset(content_list, alias_content)

+

+    log.info('Run replication monitor with --json option')

+    args.aliases = None

+    args.json = True

+    get_repl_monitor_info(m1, DEFAULT_SUFFIX, log, args)

+    check_value_in_log_and_reset(json_list)

+

+    with open(os.path.expanduser(DSRC_HOME), 'w+') as f:

+        f.write(dsrc_content)

+

+    args.connections = None

+    args.aliases = None

+    args.json = False

+

+    log.info('Run replication monitor when .dsrc file is present with content')

+    get_repl_monitor_info(m1, DEFAULT_SUFFIX, log, args)

+    check_value_in_log_and_reset(content_list, alias_content)

+    os.remove(os.path.expanduser(DSRC_HOME))

+

+    log.info('Run replication monitor with connections option as if using dsconf CLI')

+    # Perform same test than steps 2 test but without using directly the topology instance.

+    # but with an instance similar to those than dsconf cli generates:

+    # step 2 args

+    args.connections = connections

+    args.aliases = None

+    args.json = False

+    # args needed to generate an instance with dsrc_arg_concat

+    args.instance = 'master1'

+    args.basedn = None

+    args.binddn = None

+    args.bindpw = None

+    args.pwdfile = None

+    args.prompt = False

+    args.starttls = False

+    dsrc_inst = dsrc_arg_concat(args, None)

+    inst = connect_instance(dsrc_inst, True, args)

+    get_repl_monitor_info(inst, DEFAULT_SUFFIX, log, args)

+    check_value_in_log_and_reset(content_list, connection_content, error_list=error_list)

+

+

+if __name__ == '__main__':

+    # Run isolated

+    # -s for DEBUG mode

+    CURRENT_FILE = os.path.realpath(__file__)

+    pytest.main("-s %s" % CURRENT_FILE)

-- 

2.26.2