import subprocess
import yaml
import re


def netstat(port, stat):
    netstat = subprocess.Popen(['netstat', '-plan'], stdout=subprocess.PIPE)
    output = netstat.communicate()[0]
    quantity = re.search(r'(.*) ::(.*):%s(.*) %s (.*)' % (port, stat), output)
    return(quantity)


def __run__(params):
    port = params.get('port', False)
    stat = params.get('stat', False)

    try:
        if port and stat:
            connections = netstat(port, stat)
            return([2, params.get("msg_crit")] if not connections else [0, params.get("msg_ok")])
        else:
            return([2, 'Porta e/ou satus para checagem ausente do YAML'])

    except Exception, err:
        return([2, err])