diff --git a/tests/test_postgresql.py b/tests/test_postgresql.py index 7d9fc330288a73baf2a4b611ecf8b635c41ff686..19ef292b86ace67905830eae61ff143fd008e2ab 100755 --- a/tests/test_postgresql.py +++ b/tests/test_postgresql.py @@ -89,7 +89,7 @@ def get_nodes(conf: dict) -> dict: name = elements[1] address = elements[2].split(":") host = address[0] - port = address[1] + port = int(address[1]) rephacheck = elements[7] # update dictionary @@ -146,8 +146,8 @@ def check_primary(nodes: dict) -> tuple: """ for node in nodes.keys(): - host = nodes[node]["address"] - port = nodes[node]["rephacheck"] + host = nodes[node]["host"] + port = int(nodes[node]["rephacheck"]) if get_node_state(host, port) == "primary": return True, node @@ -164,8 +164,8 @@ def check_standby(nodes: dict) -> tuple: """ for node in nodes.keys(): - host = nodes[node]["address"] - port = nodes[node]["rephacheck"] + host = nodes[node]["host"] + port = int(nodes[node]["rephacheck"]) if get_node_state(host, port) == "standby": return True, node @@ -182,8 +182,8 @@ def check_witness(nodes: dict) -> tuple: """ for node in nodes.keys(): - host = nodes[node]["address"] - port = nodes[node]["rephacheck"] + host = nodes[node]["host"] + port = int(nodes[node]["rephacheck"]) if get_node_state(host, port) == "witness": return True, node @@ -200,8 +200,8 @@ def check_fenced(nodes: dict) -> tuple: """ for node in nodes.keys(): - host = nodes[node]["address"] - port = nodes[node]["rephacheck"] + host = nodes[node]["host"] + port = int(nodes[node]["rephacheck"]) if get_node_state(host, port) == "fenced": return True, node @@ -390,7 +390,7 @@ def check_ha(db_conn: dict, errors: int = 0, warnings: int = 0) -> tuple: # check remotes for node in nodes: - node_host = nodes[node]["address"] + node_host = nodes[node]["host"] node_port = nodes[node]["port"] if not check_listen(node_host, node_port): print("{}Cannot bind {}:{}{}".format(RED, node_host, node_port, DEF)) @@ -497,9 +497,9 @@ def main(): conf = es_utils.load_conf() # get database configuration - db_host = conf.get("DB_HOST", "127.0.0.1") - db_port = int(conf.get("DB_PORT", 5432)) - db_user = conf.get("DB_USER", "postgres") + db_host = conf.get("DB_HOST") if conf.get("DB_HOST") else "127.0.0.1" + db_port = int(conf.get("DB_PORT")) if conf.get("DB_PORT") else 5432 + db_user = conf.get("DB_USER") if conf.get("DB_USER") else "postgres" db_pass = conf.get("DB_PG_ROOT_PWD") db_conf = {"host": db_host, "port": db_port, "user": db_user, "pass": db_pass}