import subprocess
from datetime import datetime

def __run__(params):
    try:
        process = subprocess.Popen(["/storage/cluster_deploy/create-deploy.sh", "show-version"], stdout=subprocess.PIPE)
        out, err = process.communicate()
        versions = set([version.split("=")[1].lstrip() for version in out.splitlines()])

        if len(versions) == 1:
            return([0, 'OK - All installed instances are version {0}'.format(list(versions)[0])])
        else:
            if datetime.now().hour >= int(params.get("max_limit", 18)):
                return([2, 'O DR, nao esta sincronizado'])
            else:
                return([1, 'Existe alteracoes a serem replicadas'])

    except Exception, err:
        return([2, 'Error: {0}'.format(err)])