home.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
# File  : index.py
# Author: DaShenHan&道长-----先苦后甜，任凭晚风拂柳颜------
# Date  : 2022/9/6
import json
import ujson
import os
import re

from flask import Blueprint, abort, render_template, render_template_string, url_for, redirect, make_response, \
    send_from_directory, request
from controllers.service import storage_service, rules_service, parse_service
from controllers.classes import getClasses, getClassInfo

from utils.files import getPics, custom_merge, getAlist, get_live_url, get_multi_rules, getCustonDict
from js.rules import getRules, getPys
from utils.encode import parseText, base64Encode, base64Decode
from base.R import R
from utils.system import getHost, is_linux
from utils.cfg import cfg
from utils import parser
from utils.ua import time, get_interval
from utils.log import logger
from utils.update import getLocalVer, getHotSuggest
from js.rules import getJxs
import random
from utils.web import getParmas, verfy_token
from utils.common_api import js_render
import functools

home = Blueprint("home", __name__, static_folder='/static')


@home.route('/')
def forbidden():  # put application's code here
    abort(403)


@home.route('/favicon.ico')  # 设置icon
def favicon():
    # return home.send_static_file('img/favicon.svg')
    return redirect('/static/img/favicon.svg')
    # 对于当前文件所在路径,比如这里是static下的favicon.ico
    # return send_from_directory(os.path.join(app.root_path, 'static'),  'img/favicon.svg', mimetype='image/vnd.microsoft.icon')


@home.route('/index')
def index():
    sup_port = cfg.get('SUP_PORT', 9001)
    lsg = storage_service()
    pid_url = lsg.getItem('PID_URL')
    manager0 = ':'.join(getHost(0).split(':')[0:2])
    manager1 = ':'.join(getHost(1).split(':')[0:2])
    manager2 = pid_url or ':'.join(getHost(2).split(':')[0:2]).replace('https', 'http')
    if sup_port:
        manager0 += f':{sup_port}'
        manager1 += f':{sup_port}'
        if not pid_url:
            manager2 += f':{sup_port}'
    # print(manager2)
    ver = getLocalVer()
    return render_template('index.html', ver=ver, getHost=getHost, manager0=manager0, manager1=manager1,
                           manager2=manager2, is_linux=is_linux())


@home.route('/rules/clear')
def rules_to_clear():
    if not verfy_token():
        # return render_template('login.html')
        return R.error('请登录后再试')
    return render_template('rules_to_clear.html', rules=getRules(), classes=getClasses())


@home.route('/rules/view')
def rules_to_view():
    if not verfy_token():
        # return render_template('login.html')
        return R.error('请登录后再试')
    return render_template('rules_to_view.html', rules=getRules(), classes=getClasses())


@home.route('/pics')
def random_pics():
    id = getParmas('id')
    # print(f'id:{id}')
    base_path = os.path.dirname(os.path.abspath(os.path.dirname(__file__)))  # 上级目录
    path = 'images'
    img_path = os.path.join(base_path, f'{path}')
    pics = getPics(img_path)
    # print(pics)
    new_conf = cfg
    lsg = storage_service()
    store_conf_dict = lsg.getStoreConfDict()
    new_conf.update(store_conf_dict)
    if not new_conf.WALL_PAPER or (id and len(pics) > 0):
        if id and f'{img_path}/{id}.jpg' in pics:
            pic = f'{img_path}/{id}.jpg'
        else:
            pic = random.choice(pics)
        file = open(pic, "rb").read()
        response = make_response(file)
        response.headers['Content-Type'] = 'image/jpeg'
        return response
    else:
        return redirect(new_conf.WALL_PAPER)


@home.route('/clear')
def clear_rule():
    rule = getParmas('rule')
    if not rule:
        return R.failed('规则字段必填')
    cache_path = os.path.abspath(f'cache/{rule}.js')
    if not os.path.exists(cache_path):
        return R.failed('服务端没有此规则的缓存文件!' + cache_path)
    os.remove(cache_path)
    return R.success('成功删除文件:' + cache_path)


@home.route("/plugin/<name>", methods=['GET'])
def plugin(name):
    # name=道长影视模板.js
    if not name or not name.split('.')[-1] in ['js', 'txt', 'py', 'json']:
        return R.failed(f'非法猥亵,未指定文件名。必须包含js|txt|json|py')
    try:
        return parser.toJs(name)
    except Exception as e:
        return R.failed(f'非法猥亵\n{e}')


@home.route('/files/<name>')
def get_files(name):
    base_path = 'base/files'
    os.makedirs(base_path, exist_ok=True)
    file_path = os.path.join(base_path, f'{name}')
    if not os.path.exists(file_path):
        return R.failed(f'{file_path}文件不存在')

    with open(file_path, mode='rb') as f:
        file_byte = f.read()
    response = make_response(file_byte)
    filename = name
    response.headers['Content-Type'] = 'application/octet-stream'
    response.headers['Content-Disposition'] = f'attachment;filename="{filename}"'
    return response


@home.route('/txt/<path:filename>')
def custom_static_txt(filename):
    # 自定义静态目录 {{ url_for('custom_static',filename='help.txt')}}
    # print(filename)
    return send_from_directory('txt', filename)


@home.route('/libs/<path:filename>')
def custom_static_libs(filename):
    # 自定义静态目录 {{ url_for('custom_static',filename='help.txt')}}
    # print(filename)
    return send_from_directory('libs', filename)


# @home.route('/js/<path:filename>')
# def custom_static_js(filename):
#     # 自定义静态目录 {{ url_for('custom_static',filename='help.txt')}}
#     # print(filename)
#     return send_from_directory('js', filename)

@home.route('/js/<path:name>', methods=['GET'])
def custom_static_js(name):
    # 自定义静态目录 {{ url_for('custom_static',filename='help.txt')}}
    # print(name)
    return js_render(name)


@home.route('/raw/js/<path:filename>')
def custom_raw_js(filename):
    return send_from_directory('js', filename)


# @home.route('/txt/<name>')
# def get_txt_files(name):
#     base_path = 'txt'
#     os.makedirs(base_path,exist_ok=True)
#     file_path = os.path.join(base_path, f'{name}')
#     if not os.path.exists(file_path):
#         return R.failed(f'{file_path}文件不存在')
#
#     with open(file_path, mode='r',encoding='utf-8') as f:
#         file_byte = f.read()
#     response = make_response(file_byte)
#     response.headers['Content-Type'] = 'text/plain; charset=utf-8'
#     return response


@home.route('/lives')
def get_lives():
    # ?path=base/live.txt
    path = getParmas('path')
    live_path = path or 'base/直播.txt'
    if not re.search('(txt|json|conf)$', live_path, re.M | re.S) or not re.search('^(txt|base)', live_path,
                                                                                  re.M | re.S):
        abort(403)
    if not os.path.exists(live_path):
        # with open(live_path,mode='w+',encoding='utf-8') as f:
        #     f.write('')
        return ''

    with open(live_path, encoding='utf-8') as f:
        live_text = f.read()
    if len(live_text) > 100 and live_text.find('http') < 0:
        try:
            live_text = base64Decode(live_text)
            logger.info(f'{path} base64解码完毕')
        except Exception as e:
            logger.info(f'{path} base64解码失败:{e}')
    response = make_response(live_text)
    response.headers['Content-Type'] = 'text/plain; charset=utf-8'
    return response


@home.route('/liveslib')
def get_liveslib():
    lsg = storage_service()
    SPIDER_JAR = lsg.getItem('SPIDER_JAR', 'custom_spider.jar')
    live_path = f'libs/jar/{SPIDER_JAR}'
    logger.info(f'SPIDER_JAR：{SPIDER_JAR}>>当前系统挂载的指定jar文件位置:{live_path}')
    if not os.path.exists(live_path):
        with open(live_path, mode='w+', encoding='utf-8') as f:
            f.write('')

    with open(live_path, mode='rb') as f:
        live_text = f.read()
    response = make_response(live_text)
    filename = 'custom_spider.jar'
    response.headers['Content-Type'] = 'application/octet-stream'
    response.headers['Content-Disposition'] = f'attachment;filename="{filename}"'
    return response


@home.route('/hotsugg')
def get_hot_search():
    s_from = getParmas('from')
    size = getParmas('size')
    data = getHotSuggest(s_from, size)
    return R.success('获取成功', data)


def merged_hide(merged_config):
    t1 = time()
    store_rule = rules_service()
    hide_rules = store_rule.getHideRules()
    hide_rule_names = list(map(lambda x: x['name'], hide_rules))
    # print(hide_rule_names)
    all_cnt = len(merged_config['sites'])

    def filter_show(x):
        name = x['api'].split('rule=')[1].split('&')[0] if 'rule=' in x['api'] else x['key'].replace('dr_', '')
        # print(name)
        if not str(x['key']).startswith('dr_') and name == 'drpy':
            name = x['key']
        return name not in hide_rule_names

    merged_config['sites'] = list(filter(filter_show, merged_config['sites']))
    logger.info(
        f'数据库筛选隐藏规则耗时{get_interval(t1)}毫秒,共计{all_cnt}条规则,隐藏后可渲染{len(merged_config["sites"])}条规则')


@home.route('/config/<int:mode>')
def config_render(mode):
    # print(dict(app.config))
    tt = time()
    UA = request.headers['User-Agent']
    ver = getParmas('ver')
    m = getParmas('mode')
    sp = getParmas('sp')  # 优选
    logger.info(f'ver:{ver},UA:{UA}')
    if ver not in ['1', '2']:
        ISTVB = 'okhttp/3' in UA
    elif ver == '1':
        ISTVB = False
    elif ver == '2':
        ISTVB = True
    # print(ISTVB)
    if mode == 1:
        jyw_ip = getHost(mode)
        logger.info(jyw_ip)
    new_conf = cfg
    lsg = storage_service()
    store_conf_dict = lsg.getStoreConfDict()
    new_conf.update(store_conf_dict)
    # print(new_conf)
    # print(type(new_conf),new_conf)
    host = getHost(mode)
    # ali_token = lsg.getItem('ALI_TOKEN')
    ali_token = new_conf.ALI_TOKEN
    xr_mode = new_conf.XR_MODE
    js_proxy = new_conf.JS_PROXY
    js0_password = new_conf.JS0_PASSWORD
    js_mode = int(new_conf.JS_MODE or 0)
    if m:
        try:
            js_mode = int(m)
        except:
            pass
    print(f'{type(js_mode)} jsmode:{js_mode}')
    # print(ali_token)
    customConfig = getCustonDict(host, ali_token, js0_password)
    # print(customConfig)
    jxs = getJxs(host=host)
    use_py = lsg.getItem('USE_PY')
    pys = getPys() if use_py else []
    # print(pys)
    alists = getAlist()
    alists_str = json.dumps(alists, ensure_ascii=False)
    live_url = get_live_url(new_conf, mode)
    rules = getRules('js', js_mode)
    rules = get_multi_rules(rules)
    # html = render_template('config.txt',rules=getRules('js'),host=host,mode=mode,jxs=jxs,base64Encode=base64Encode,config=new_conf)
    if new_conf.EXT_FUNC and new_conf.EXT_FUNC.strip():
        try:
            new_conf.EXT_FUNC = json.loads(new_conf.EXT_FUNC)
            logger.info(f'扩展规则加载成功,共计:{len(new_conf.EXT_FUNC)}')
        except Exception as e:
            logger.info(f'加载扩展规则发生错误:{e}')
            new_conf.EXT_FUNC = []
    else:
        new_conf.EXT_FUNC = []

    html = render_template('config.txt', js0_password=js0_password, UA=UA, xr_mode=xr_mode, ISTVB=ISTVB, pys=pys,
                           rules=rules, host=host, mode=mode, js_mode=js_mode, jxs=jxs, alists=alists,
                           alists_str=alists_str, live_url=live_url, config=new_conf)
    merged_config = custom_merge(parseText(html), customConfig)
    # print(merged_config['sites'])
    merged_hide(merged_config)
    # response = make_response(html)
    # print(len(merged_config['sites']))
    # print(merged_config['sites'])
    merged_config['sites'] = sort_sites_by_order(merged_config['sites'], js_mode)
    # print(merged_config['sites'])
    if sp:  # 执行动态优选源
        special_rule(merged_config, lsg)

    # print(merged_config['parses'])
    parses = sort_parses_by_order(merged_config['parses'], host)
    # print(parses)
    merged_config['parses'] = parses
    config_text = json.dumps(merged_config, ensure_ascii=False, indent=1)

    # 依赖代理逻辑修改,改为admin/view去动态代理
    # if js_proxy:
    #     # print('js_proxy:',js_proxy)
    #     if '=>' in js_proxy:
    #         oldsrc = js_proxy.split('=>')[0]
    #         newsrc = js_proxy.split('=>')[1]
    #         print(f'js1源代理已启用,全局替换{oldsrc}为{newsrc}')
    #         config_text = config_text.replace(oldsrc,newsrc)

    response = make_response(config_text)
    # response = make_response(str(merged_config))
    response.headers['Content-Type'] = 'application/json; charset=utf-8'
    logger.info(f'自动生成动态配置共计耗时:{get_interval(tt)}毫秒')
    return response


def special_rule(merged_config, lsg):
    # print(merged_config['sites'])
    special = lsg.getItem('SPECIAL').strip()
    # print('SPECIAL：',special)
    special_dict = {}
    for sp in special.split('&'):
        special_dict[sp.split(':')[0]] = sp.split(':')[1] if ':' in sp else ''

    special_keys = list(special_dict.keys())
    special_ft = list(filter(lambda x: x.get('key').replace('dr_', '') in special_keys, merged_config['sites']))
    for spf in special_ft:
        spf['name'] = special_dict[spf['key'].replace('dr_', '')] or spf['name']

    special_st = sorted(special_ft, key=lambda x: special_keys.index(x.get('key').replace('dr_', '')))
    merged_config['sites'] = special_st
    merged_config['dr_count'] = len(special_st)


def comp(x, y):
    if x['order'] > y['order']:
        return 1
    elif x['order'] < y['order']:
        return - 1
    else:
        if x['write_date'] < y['write_date']:
            return 1
        elif x['write_date'] > y['write_date']:
            return -1
        else:
            return 0


def sort_sites_by_order(sites, js_mode=0):
    rules = rules_service()
    rule_list = rules.query_all()
    # print(rule_list)
    rule_names = list(map(lambda x: x['name'], rule_list))
    # print(rule_names)
    # print(sites)
    for i in range(len(sites)):
        # sites[i]['id'] = i+1
        site_name = sites[i]['api'].split('rule=')[1].split('&')[0] if 'rule=' in sites[i]['api'] else sites[i]['key']
        if js_mode and str(site_name).startswith('dr'):
            site_name = site_name.replace('dr_', '')
        if not str(sites[i]['key']).startswith('dr_') and site_name == 'drpy':
            site_name = sites[i]['key']
            # print(sites[i])
        # print(site_name)
        if site_name in rule_names:
            site_rule = rule_list[rule_names.index(site_name)]
            sites[i]['state'] = 1 if site_rule['state'] is None else site_rule['state']
            sites[i]['order'] = 0 if site_rule['order'] is None else site_rule['order']
            sites[i]['write_date'] = 0 if site_rule['write_date'] is None else site_rule['write_date'].timestamp()
        else:
            sites[i]['state'] = 1
            sites[i]['order'] = 0
            sites[i]['write_date'] = 0
        # sites[i]['site_name'] = site_name
    # print(sites)
    # sites.sort(key=lambda x: x['order'], reverse=False)
    sites.sort(key=functools.cmp_to_key(comp), reverse=False)
    # print(sites)
    for site in sites:
        del site['state']
        del site['order']
        del site['write_date']
    return sites


def sort_parses_by_order(parses, host):
    t1 = time()
    parse = parse_service()
    parse_list = parse.query_all()
    parse_url_list = list(map(lambda x: x['url'], parse_list))
    new_parses = []
    new_parses_url = []
    for i in range(len(parses)):
        # parses[i]['id'] = i + 1
        # 去重
        if parses[i]['url'] in new_parses_url:
            # print(f"重复的解析:{parses[i]['name']},{parses[i]['url']}")
            continue
        if str(parses[i]['url']).startswith(host):
            parses[i]['url'] = parses[i]['url'].replace(host, '')
        if parses[i]['url'] in parse_url_list:
            parse_rule = parse_list[parse_url_list.index(parses[i]['url'])]
            parses[i]['state'] = 1 if parse_rule['state'] is None else parse_rule['state']
            parses[i]['order'] = 0 if parse_rule['order'] is None else parse_rule['order']
            parses[i]['write_date'] = 0 if parse_rule['write_date'] is None else parse_rule['write_date'].timestamp()
        else:
            parses[i]['state'] = 1
            parses[i]['order'] = 0
            parses[i]['write_date'] = 0

        # 外层自动补header
        if not parses[i].get('header'):
            parses[i]['header'] = {'User-Agent': 'Mozilla/5.0'}
        if str(parses[i]['url']).startswith('/'):
            parses[i]['url'] = host + parses[i]['url']
        new_parses.append(parses[i])
        new_parses_url.append(parses[i]['url'])
    new_parses.sort(key=functools.cmp_to_key(comp), reverse=False)
    # print(sites)
    for par in new_parses:
        del par['state']
        del par['order']
        del par['write_date']
    # print(new_parses)
    logger.info(f'{len(new_parses)}/{len(parses)}条解析解析排序耗时:{get_interval(t1)}毫秒')
    return new_parses


@home.route('/configs')
def config_gen():
    if not verfy_token():
        return R.failed('请登录后再试')
    # 生成文件
    os.makedirs('txt', exist_ok=True)
    new_conf = cfg
    lsg = storage_service()
    store_conf_dict = lsg.getStoreConfDict()
    new_conf.update(store_conf_dict)
    if new_conf.EXT_FUNC and new_conf.EXT_FUNC.strip():
        try:
            new_conf.EXT_FUNC = json.loads(new_conf.EXT_FUNC)
            logger.info(f'扩展规则加载成功,共计:{len(new_conf.EXT_FUNC)}')
        except Exception as e:
            logger.info(f'加载扩展规则发生错误:{e}')
            new_conf.EXT_FUNC = []
    else:
        new_conf.EXT_FUNC = []
    try:
        use_py = lsg.getItem('USE_PY')
        js_mode = int(new_conf.JS_MODE or 0)
        js0_password = new_conf.JS0_PASSWORD
        pys = getPys() if use_py else False
        alists = getAlist()
        alists_str = json.dumps(alists, ensure_ascii=False)
        rules = getRules('js', js_mode)
        rules = get_multi_rules(rules)
        host0 = getHost(0)
        jxs = getJxs(host=host0)
        set_local = render_template('config.txt', js0_password=js0_password, pys=pys, rules=rules, alists=alists,
                                    alists_str=alists_str, live_url=get_live_url(new_conf, 0), mode=0, js_mode=js_mode,
                                    host=host0, jxs=jxs, config=new_conf)
        # print(set_local)
        host1 = getHost(1)
        jxs = getJxs(host=host1)
        set_area = render_template('config.txt', js0_password=js0_password, pys=pys, rules=rules, alists=alists,
                                   alists_str=alists_str, live_url=get_live_url(new_conf, 1), mode=1, js_mode=js_mode,
                                   host=host1, jxs=jxs, config=new_conf)
        host2 = getHost(2) or host1
        # print('远程地址:'+host2)
        jxs = getJxs(host=host2)
        set_online = render_template('config.txt', js0_password=js0_password, pys=pys, rules=rules, alists=alists,
                                     alists_str=alists_str, live_url=get_live_url(new_conf, 2), mode=1, js_mode=js_mode,
                                     host=host2, jxs=jxs, config=new_conf)
        ali_token = new_conf.ALI_TOKEN
        # parses = []
        with open('txt/pycms0.json', 'w+', encoding='utf-8') as f:
            customConfig = getCustonDict(host0, ali_token, js0_password)
            set_dict = custom_merge(parseText(set_local), customConfig)
            merged_hide(set_dict)
            set_dict['sites'] = sort_sites_by_order(set_dict['sites'], js_mode)
            # if not parses:
            #     print('生成静态配置时初始化排序parses')
            #     parses = sort_parses_by_order(set_dict['parses'])
            # set_dict['parses'] = parses
            set_dict['parses'] = sort_parses_by_order(set_dict['parses'], host0)
            # set_dict = json.loads(set_local)
            f.write(json.dumps(set_dict, ensure_ascii=False, indent=4))
        with open('txt/pycms1.json', 'w+', encoding='utf-8') as f:
            customConfig = getCustonDict(host1, ali_token, js0_password)
            set_dict = custom_merge(parseText(set_area), customConfig)
            merged_hide(set_dict)
            set_dict['sites'] = sort_sites_by_order(set_dict['sites'], js_mode)
            set_dict['parses'] = sort_parses_by_order(set_dict['parses'], host1)
            # set_dict = json.loads(set_area)
            f.write(json.dumps(set_dict, ensure_ascii=False, indent=4))

        with open('txt/pycms2.json', 'w+', encoding='utf-8') as f:
            customConfig = getCustonDict(host2, ali_token, js0_password)
            set_dict = custom_merge(parseText(set_online), customConfig)
            merged_hide(set_dict)
            set_dict['sites'] = sort_sites_by_order(set_dict['sites'], js_mode)
            set_dict['parses'] = sort_parses_by_order(set_dict['parses'], host2)
            # set_dict = json.loads(set_online)
            f.write(json.dumps(set_dict, ensure_ascii=False, indent=4))
        files = [os.path.abspath(rf'txt\pycms{i}.json') for i in range(3)]
        # print(files)
        return R.success('猫配置生成完毕，文件位置在:\n' + '\n'.join(files))
    except Exception as e:
        return R.failed(f'配置文件生成错误:\n{e}')


@home.route("/info", methods=['get'])
def info_all():
    if not verfy_token():
        # return render_template('login.html')
        return R.error('请登录后再试')
    data = storage_service.query_all()
    return R.ok(data=data)