mdserver-web/plugins/xui/index.py

# coding:utf-8

import sys
import io
import os
import time
import re

web_dir = os.getcwd() + "/web"
if os.path.exists(web_dir):
    sys.path.append(web_dir)
    os.chdir(web_dir)

import core.mw as mw

app_debug = False
if mw.isAppleSystem():
    app_debug = True


def getPluginName():
    return 'xui'


def getPluginDir():
    return mw.getPluginDir() + '/' + getPluginName()


def getServerDir():
    return mw.getServerDir() + '/' + getPluginName()


def getServiceTpl():
    path = getPluginDir() + "/init.d/" + getPluginName() + ".service.tpl"
    return path


def getConfEnvTpl():
    path = getPluginDir() + "/conf/mt.toml"
    return path


def getConfEnv():
    path = getServerDir() + "/mt.toml"
    return path


def getArgs():
    args = sys.argv[2:]
    tmp = {}
    args_len = len(args)

    if args_len == 1:
        t = args[0].strip('{').strip('}')
        t = t.split(':')
        tmp[t[0]] = t[1]
    elif args_len > 1:
        for i in range(len(args)):
            t = args[i].split(':')
            tmp[t[0]] = t[1]

    return tmp

def status():
    cmd = "ps -ef|grep x-ui |grep -v grep | grep -v python  | awk '{print $2}'"
    data = mw.execShell(cmd)
    if data[0] == '':
        return 'stop'
    return 'start'


def getServiceFile():
    systemDir = mw.systemdCfgDir()
    return systemDir + '/mtproxy.service'


def getMtproxyPort():
    return '8349'


def __release_port(port):
    from collections import namedtuple
    try:
        from utils.firewall import Firewall as MwFirewall
        MwFirewall.instance().addAcceptPort(port, 'mtproxy', 'port')
        return port
    except Exception as e:
        return "Release failed {}".format(e)

def __delete_port(port):
    from collections import namedtuple
    try:
        from utils.firewall import Firewall as MwFirewall
        MwFirewall.instance().delAcceptPortCmd(port, 'tcp')
        return port
    except Exception as e:
        return "Delete failed {}".format(e)

def openPort():
    port = getMtproxyPort()
    for i in [port]:
        __release_port(i)
    return True

def delPort():
    port = getMtproxyPort()
    for i in [port]:
        __delete_port(i)
    return True


def initDreplace():

    envTpl = getConfEnvTpl()
    dstEnv = getConfEnv()
    cmd = getServerDir() + '/mtg/mtg generate-secret `head -c 16 /dev/urandom | xxd -ps`'
    secret = mw.execShell(cmd)
    if not os.path.exists(dstEnv):
        env_content = mw.readFile(envTpl)
        env_content = env_content.replace('{$PORT}', getMtproxyPort())
        env_content = env_content.replace('{$SECRET}', secret[0].strip())
        mw.writeFile(dstEnv, env_content)
        openPort()

    # systemd
    systemDir = mw.systemdCfgDir()
    systemService = systemDir + '/mtproxy.service'
    systemServiceTpl = getServiceTpl()
    if os.path.exists(systemDir) and not os.path.exists(systemService):
        service_path = mw.getServerDir()
        se_content = mw.readFile(systemServiceTpl)
        se_content = se_content.replace('{$SERVER_PATH}', service_path)
        mw.writeFile(systemService, se_content)
        mw.execShell('systemctl daemon-reload')

    return 'ok'


def mtOp(method):
    file = initDreplace()

    if not mw.isAppleSystem():
        mw.execShell('systemctl daemon-reload')
        data = mw.execShell('systemctl ' + method + ' mtproxy')
        if data[1] == '':
            return 'ok'
        return data[1]

    return 'fail'


def start():
    return mtOp('start')


def stop():
    return mtOp('stop')


def restart():
    return mtOp('restart')


def reload():
    return redisOp('reload')


def initdStatus():
    if mw.isAppleSystem():
        return "Apple Computer does not support"

    shell_cmd = 'systemctl status x-ui | grep loaded | grep "enabled;"'
    data = mw.execShell(shell_cmd)
    if data[0] == '':
        return 'fail'
    return 'ok'

def initdInstall():
    if mw.isAppleSystem():
        return "Apple Computer does not support"
    mw.execShell('systemctl enable x-ui')
    return 'ok'


def initdUinstall():
    if mw.isAppleSystem():
        return "Apple Computer does not support"
    mw.execShell('systemctl disable x-ui')
    return 'ok'

def getMtproxyUrl():
    conf = getConfEnv()
    content = mw.readFile(conf)


    rep = r'bind-to\s*=\s*(.*)'
    tmp = re.search(rep, content)
    bind_to = tmp.groups()[0].strip()
    bind_to = bind_to.strip('"')

    rep = r'secret\s*=\s*(.*)'
    tmp = re.search(rep, content)
    secret = tmp.groups()[0].strip()
    secret = secret.strip('"')

    info = bind_to.split(":")

    ip = mw.getLocalIp()

    url = 'tg://proxy?server={0}&port={1}&secret={2}'.format(ip, info[1], secret)
    return mw.returnJson(True, 'ok', url)

def installPreInspection():
    sys = mw.execShell("cat /etc/*-release | grep PRETTY_NAME |awk -F = '{print $2}' | awk -F '\"' '{print $2}'| awk '{print $1}'")

    if sys[1] != '':
        return '不支持该系统'

    sys_id = mw.execShell("cat /etc/*-release | grep VERSION_ID | awk -F = '{print $2}' | awk -F '\"' '{print $2}'")

    sysName = sys[0].strip().lower()
    sysId = sys_id[0].strip()

    if sysName in ('opensuse'):
        return '不支持该系统'

    return 'ok'


if __name__ == "__main__":
    func = sys.argv[1]
    if func == 'status':
        print(status())
    elif func == 'start':
        print(start())
    elif func == 'stop':
        print(stop())
    elif func == 'restart':
        print(restart())
    elif func == 'reload':
        print(reload())
    elif func == 'initd_status':
        print(initdStatus())
    elif func == 'initd_install':
        print(initdInstall())
    elif func == 'initd_uninstall':
        print(initdUinstall())
    elif func == 'install_pre_inspection':
        print(installPreInspection())
    elif func == 'conf':
        print(getServiceFile())
    elif func == 'conf_env':
        print(getConfEnv())
    elif func == 'url':
        print(getMtproxyUrl())
    else:
        print('error')