db_sync_tool.remote.system

Complexity

Total Complexity

6

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes

0

2 Functions

Rating	Name	Duplication	Size	Complexity
A	run_ssh_command_by_client()	0	11	2
A	run_ssh_command()	0	20	4

#!/usr/bin/env python3
# -*- coding: future_fstrings -*-

"""
System script
"""

import sys
from db_sync_tool.utility import mode, output, helper
from db_sync_tool.remote import client as remote_client


def run_ssh_command_by_client(client, command):
    """
    Running origin ssh command
    :param client: String
    :param command: String
    :return:
    """
    if client == mode.Client.ORIGIN:

Unnecessary "else" after "return"

        return run_ssh_command(command, remote_client.ssh_client_origin, client)
    else:
        return run_ssh_command(command, remote_client.ssh_client_target, client)


def run_ssh_command(command, ssh_client=remote_client.ssh_client_origin, client=None):
    """
    Running ssh command
    :param command: String
    :param ssh_client:
    :param client: String
    :return:
    """
    stdin, stdout, stderr = ssh_client.exec_command(command)

The variable stdin seems to be unused.

    exit_status = stdout.channel.recv_exit_status()

    err = stderr.read().decode()

    if err and exit_status != 0:
        helper.run_script(client=client, script='error')
        sys.exit(output.message(output.Subject.ERROR, err, False))
    elif err:
        output.message(output.Subject.WARNING, err, True)

    return stdout