import commands
import re

def __run__(params):
    try:
        thresolds = params.get('node1')
        status, output = commands.getstatusoutput("sudo rabbitmqctl cluster_status")

        if status == 0:
            for line in output.split('\n'):
                if 'running_nodes' in line:
                    nodes = re.search('\[(.*?)\]', line)

                    if nodes:
                        if len(nodes.group().split(',')) == 1:
                                return [1, 'OK: Apenas o no {0} esta ativo!'.format(thresolds)]
                        if len(nodes.group().split(',')) == 2:
                                return [0, 'OK: cluster esta ativo!']
                        else:
                            return [2, 'Critical']
                    else:
                        return [2, 'Critical: Algo de errado acontece']
        else:
            return [2, 'O comando rabbitmqctl cluster status, reportou erros verifique o no {0}'.format(thresolds)]

    except Exception, err:
        return [2, err]