home/models/clash_tools.py

# -*- coding: utf-8 -*-
from concurrent.futures import ThreadPoolExecutor, as_completed
from odoo import fields, models, api
from odoo.exceptions import UserError
from urllib.parse import quote
import httpx
import subprocess


class ClashTools(models.Model):
    _name = 'clash.tools'
    _description = 'Clash Tools'

    name = fields.Char('Name')

    localhost_ip = fields.Char('Localhost IP')

    api_ip = fields.Char('API IP')

    current_node = fields.Char('Current Node')

    total_nodes = fields.Integer('Total Nodes')

    use_type = fields.Selection([
        ('web3', 'WEB3'),
        ('depin', 'Depin'),
    ], string='Use Type', default='')

    current_node_state = fields.Char('Current Node State')

    line_ids = fields.One2many('clash.tools.line', 'clash_tools_id', string='Line')

    clash_no_skip_config_id = fields.Many2one('clash.no_skip.config', string='Clash Skip Config')

    def btn_init_data(self):
        # 一键创建所有局域网中的 clash 连接, 因为懒
        data_dict = {
            'web3_01': '192.168.31.201:58001',
            'web3_02': '192.168.31.201:58002',
            'web3_03': '192.168.31.201:58003',
            'web3_04': '192.168.31.201:58004',
            'web3_05': '192.168.31.201:58005',
            'web3_06': '192.168.31.201:58006',
            'web3_07': '192.168.31.201:58007',
            'web3_08': '192.168.31.201:58008',
            'web3_09': '192.168.31.201:58009',
            'web3_10': '192.168.31.201:58010',
            'depin_01': '192.168.31.201:32001',
            'depin_02': '192.168.31.201:32002',
            'depin_03': '192.168.31.201:32003',
            'depin_04': '192.168.31.201:32004',
            'depin_05': '192.168.31.201:32005',
            'depin_06': '192.168.31.201:32006',
            'depin_07': '192.168.31.201:32007',
            'depin_08': '192.168.31.201:32008',
            'depin_09': '192.168.31.201:32009',
            'depin_10': '192.168.31.201:32010',
            'depin_11': '192.168.31.201:32011',
            'depin_12': '192.168.31.201:32012',
        }
        all_data_name_list = [i.name for i in self.search([])]
        print(all_data_name_list)
        for key, value in data_dict.items():
            if key in all_data_name_list:
                continue
            else:
                use_type = ''
                if 'depin' in key:
                    use_type = 'depin'
                elif 'web3' in key:
                    use_type = 'web3'
                self.create({
                    'name': key,
                    'localhost_ip': value,
                    'use_type': use_type
                })

    def btn_get_all_node(self):
        for rec in self:
            if not rec.localhost_ip:
                continue

            # 先获取所有节点
            url = rec.localhost_ip
            if 'https' in url:
                raise UserError('Local network services do not require HTTPS.')
            if 'http' not in url:
                url = 'http://' + url

            self._set_global_proxy(url, rec)

            proxies_list = self._get_all_node(url, rec)

            if proxies_list:
                rec.total_nodes = len(proxies_list)

            # 清空当前 line
            rec.line_ids.unlink()

            # 循环添加节点到 line
            for proxies in proxies_list:
                if proxies == "DIRECT" or proxies == "REJECT" or proxies == "GLOBAL":
                    continue
                rec.line_ids.create({
                    'name': proxies,
                    'clash_tools_id': rec.id
                })

    def btn_check_all_node(self):
        for rec in self:
            if not rec.localhost_ip:
                continue
            if not rec.line_ids:
                self.btn_get_all_node()

            url = rec.localhost_ip
            if 'https' in url:
                raise UserError('Local network services do not require HTTPS.')
            if 'http' not in url:
                url = 'http://' + url

            line_count = len(rec.line_ids)
            if line_count:
                rec.total_nodes = line_count

            with ThreadPoolExecutor(max_workers=line_count) as executor:
                # 提交任务到线程池
                futures = {executor.submit(self._check_node, quote(line.name, safe=""), url): line for line in rec.line_ids}

                # 处理线程池返回的结果
                for future in as_completed(futures):
                    line = futures[future]
                    try:
                        res = future.result()
                        if res != 9999:
                            line.update({
                                'delay': res.setdefault('delay'),
                                'mean_delay': res.setdefault('meanDelay'),
                                'node_state': 'ok'
                            })
                        else:
                            line.update({
                                'delay': 9999,
                                'mean_delay': 9999,
                                'node_state': 'error'
                            })
                    except Exception as e:
                        print(str(e))
                        line.update({
                            'delay': -1,
                            'mean_delay': -1,
                            'node_state': 'error'
                        })

            result = rec._get_current_node()
            if result:
                rec.current_node = result

    def btn_select_node(self):
        selected_node_list = []
        for rec in self:
            if not rec.localhost_ip:
                continue
            if not rec.line_ids:
                self.btn_get_all_node()

            if not rec.line_ids:
                continue

            url = rec.localhost_ip
            if 'https' in url:
                raise UserError('Local network services do not require HTTPS.')
            if 'http' not in url:
                url = 'http://' + url

            # 拿到 line 中, 延迟最小的节点数据
            line_delay_min = self.line_ids.search([('clash_tools_id', '=', rec.id), ('node_state', '=', 'ok')], order='delay asc')

            for line in line_delay_min:
                if rec.clash_no_skip_config_id:
                    try:
                        no_skip_node_list = rec.clash_no_skip_config_id.no_skip_domains.split(';')
                    except:
                        raise UserError('Please enter the node name to skip, separated by semicolons.')

                    # 查看是否存在不需要跳过的节点, 如果是, 查看有没有使用过这个节点, 如果使用过, 就跳过
                    # 如果没有使用过, 则使用这个节点, 之后将这个节点添加到已使用列表中
                    # 判定节点的时候, 部分节点是英文, 所以需要统一一下大小写
                    selected = False
                    for no_skip_node in no_skip_node_list:
                        if line.name in selected_node_list:
                            break

                        if no_skip_node.strip().lower() in line.name.lower():
                            self._use_select_node(line)
                            selected_node_list.append(line.name)
                            selected = True
                            break

                    if selected:
                        break

                else:
                    # 如果跳过节点的条件为空, 则判断是否使用过这个节点, 没有就使用
                    if line.name in selected_node_list:
                        continue

                    self._use_select_node(line)
                    selected_node_list.append(line.name)
                    break

    def btn_check_current_node(self):
        for rec in self:
            if not rec.localhost_ip or not rec.line_ids or not rec.current_node:
                continue

            url = rec.localhost_ip
            if 'https' in url:
                raise UserError('Local network services do not require HTTPS.')
            if 'http' not in url:
                url = 'http://' + url

            result = self._check_node(quote(rec.current_node, safe=""), url)
            if result != 9999:
                rec.current_node_state = ';'.join([f'{k}:{v}' for k, v in result.items()])
            else:
                rec.current_node_state = 'error'

    def _set_global_proxy(self, url, rec):
        setting_url = url + '/api/configs'

        headers = {
            "Accept": "application/json, text/plain, */*",
            "Accept-Encoding": "gzip, deflate",
            "Accept-Language": "zh-CN,zh;q=0.8",
            "Connection": "keep-alive",
            "Content-Type": "application/json",
            "Host": rec.localhost_ip,
            "Origin": url,
            "Referer": url,
            "Sec-Gpc": "1",
            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36"
        }

        data = {
            "mode": "Global"
        }

        # 发送PATCH请求
        try:
            response = httpx.patch(setting_url, headers=headers, json=data)
            if response.status_code != 204:
                raise UserError(f"{rec.name} Failed to set global proxy. Status code: {response.status_code}")
        except httpx.RequestError as e:
            print("Request failed:", e)

    def _get_all_node(self, url, rec):
        proxies_list_url = url + '/api/proxies'

        headers = {
            "Accept": "application/json, text/plain, */*",
            "Accept-Encoding": "gzip, deflate",
            "Accept-Language": "zh-CN,zh;q=0.8",
            "Connection": "keep-alive",
            "Host": rec.localhost_ip,
            "Referer": url,
            "Sec-Gpc": "1",
            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36"
        }

        response = httpx.get(proxies_list_url, headers=headers)
        proxies_list = response.json()

        if self.clash_no_skip_config_id:
            try:
                skip_node_list = self.clash_no_skip_config_id.no_skip_domains.split(';')
                skip_node_set = {node.lower() for node in skip_node_list}
                result = [proxies for proxies in proxies_list.get('proxies') if any(skip_node in proxies.lower() for skip_node in skip_node_set)]
            except Exception as e:
                raise UserError(f'{self.name} Please enter the node name to skip, separated by semicolons.\nerror: {e}')
        else:
            result = proxies_list.get('proxies', [])

        return result

    def _check_node(self, encode_proxy_name, url):
        command = [
            "curl",
            "-X", "GET",
            f"{url}/api/proxies/{encode_proxy_name}/delay?timeout=5000&url=http:%2F%2Fwww.gstatic.com%2Fgenerate_204"
        ]

        try:
            result = subprocess.run(command, capture_output=True, text=True, check=True)
            if 'Timeout' in result.stdout:
                return 9999
            if 'An error occurred in the delay test' in result.stdout:
                return 9999
            res = eval(result.stdout)
            return res
        except subprocess.CalledProcessError as e:
            return 9999

    def _get_current_node(self):
        url = self.localhost_ip
        if 'https' in url:
            raise UserError('Local network services do not require HTTPS.')
        if 'http' not in url:
            url = 'http://' + url
        headers = {
            "Accept": "application/json, text/plain, */*",
            "Accept-Encoding": "gzip, deflate, br, zstd",
            "Accept-Language": "zh-CN,zh;q=0.8",
            "Connection": "keep-alive",
            "Host": self.localhost_ip,
            "Referer": url,
            "Sec-CH-UA": '"Chromium";v="134", "Not:A-Brand";v="24", "Brave";v="134"',
            "Sec-CH-UA-Mobile": "?0",
            "Sec-CH-UA-Platform": '"macOS"',
            "Sec-Fetch-Dest": "empty",
            "Sec-Fetch-Mode": "cors",
            "Sec-Fetch-Site": "same-origin",
            "Sec-GPC": "1",
            "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/134.0.0.0 Safari/537.36"
        }

        try:
            response = httpx.get(url + '/api/proxies', headers=headers)

            if not response.json() or response.status_code != 200:
                print("JSON data is empty or request failed")
                return ''
            json_data = response.json()
            proxies = json_data.get("proxies")
            proxy_global = proxies.get("GLOBAL")
            now_proxy = proxy_global.get("now")
            return now_proxy
        except httpx.RequestError as e:
            print(f"Request failed: {e}")
            return ''

    def _use_select_node(self, line):
        url = line.clash_tools_id.localhost_ip
        if 'https' in url:
            raise UserError('Local network services do not require HTTPS.')
        if 'http' not in url:
            url = 'http://' + url

        url = url + "/api/proxies/GLOBAL"
        data = {"name": line.name}
        try:
            response = httpx.put(url, json=data)
            if response.status_code == 204:
                print(f"{line.clash_tools_id.localhost_ip} Switched to proxy: {line.name}")
                line.clash_tools_id.update({'current_node': line.clash_tools_id._get_current_node()})
            else:
                print(f"Failed to switch proxy: {response.status_code} - {line.name}")
        except Exception as e:
            print(f"Failed to switch proxy: {e}")


class ClashToolsLine(models.Model):
    _name = 'clash.tools.line'
    _description = 'Clash Tools Line'
    _order = 'delay ASC'

    name = fields.Char('Name')

    delay = fields.Integer('Delay')

    mean_delay = fields.Integer('Mean Delay')

    node_state = fields.Selection([
        ('error', 'Error'),
        ('ok', 'OK'),
    ], string='Node State', default='')

    clash_tools_id = fields.Many2one('clash.tools', string='Clash Tools')

    def btn_use_this_node(self):
        url = self.clash_tools_id.localhost_ip
        if 'https' in url:
            raise UserError('Local network services do not require HTTPS.')
        if 'http' not in url:
            url = 'http://' + url

        url = url + "/api/proxies/GLOBAL"
        data = {"name": self.name}
        try:
            response = httpx.put(url, json=data)
            if response.status_code == 204:
                print(f"{self.clash_tools_id.localhost_ip} Switched to proxy: {self.name}")
                self.clash_tools_id.update({'current_node': self.clash_tools_id._get_current_node()})
            else:
                print(f"Failed to switch proxy: {response.status_code} - {self.name}")
        except Exception as e:
            print(f"Failed to switch proxy: {e}")

    def check_single_node(self):
        url = self.clash_tools_id.localhost_ip
        if 'https' in url:
            raise UserError('Local network services do not require HTTPS.')
        if 'http' not in url:
            url = 'http://' + url

        encode_proxy_name = quote(self.name, safe="")

        command = [
            "curl",
            "-X", "GET",
            f"{url}/api/proxies/{encode_proxy_name}/delay?timeout=5000&url=http:%2F%2Fwww.gstatic.com%2Fgenerate_204"
        ]

        try:
            result = subprocess.run(command, capture_output=True, text=True, check=True)
            if 'Timeout' in result.stdout:
                res = 9999
            if 'An error occurred in the delay test' in result.stdout:
                res = 9999
            res = eval(result.stdout)
        except subprocess.CalledProcessError as e:
            res = 9999

        if res != 9999:
            self.update({
                'delay': res.setdefault('delay'),
                'mean_delay': res.setdefault('meanDelay'),
                'node_state': 'ok'
            })
        else:
            self.update({
                'delay': res,
                'mean_delay': res,
                'node_state': 'error'
            })


class ClashSkipConfig(models.Model):
    _name = 'clash.no_skip.config'
    _description = 'Clash No Skip Config'

    name = fields.Char('Name')
    no_skip_domains = fields.Char('No Skip Domains')

    @api.depends('name', 'no_skip_domains')
    def _compute_display_name(self):
        for record in self:
            record.display_name = f'{record.name} - {record.no_skip_domains}'