ProxyPanel/app/Services/ProxyService.php

<?php

namespace App\Services;

use App\Models\Node;
use App\Models\User;
use App\Utils\Clients\Formatters\Text;
use App\Utils\Clients\Formatters\URLSchemes;
use Arr;
use Exception;
use Illuminate\Database\Eloquent\Collection;
use ReflectionClass;

/**
 * 订阅代理服务
 * 提供代理配置的生成、管理和格式化功能.
 */
class ProxyService
{
    private static array $servers = [];

    private User $user;

    public function __construct(?User $user = null)
    {
        $this->user = $user ?? auth()->user();
    }

    public function buildClientConfig(?string $target = null, ?int $type = null): string
    { // 构建客户端配置
        $servers = $this->getServers($type);

        // 尝试匹配特定客户端
        $classes = glob(app_path('Utils/Clients').'/*.php');

        foreach ($classes as $file) {
            $className = 'App\\Utils\\Clients\\'.basename($file, '.php');

            if (! class_exists($className)) {
                continue;
            }

            $reflection = new ReflectionClass($className);

            if (! $reflection->hasConstant('AGENT')) {
                continue;
            }

            $agents = $reflection->getConstant('AGENT');
            if (! is_array($agents)) {
                continue;
            }

            foreach ($agents as $agent) {
                if (str_contains($target ?? '', $agent)) {
                    return (new $className)->getConfig($servers, $this->user, $target);
                }
            }
        }

        // 默认返回 URL 方案
        return URLSchemes::build($servers);
    }

    private function getServers(?int $type): array
    {
        if (empty(self::$servers)) {
            $servers = $this->fetchAvailableNodes($type);

            if (empty($servers)) {
                $this->failedProxyReturn(trans('errors.subscribe.none'), $type);
            } else {
                self::$servers = $servers;
            }
        }

        return self::$servers;
    }

    public function fetchAvailableNodes(?int $type = null, bool $withConfigs = true): array|Collection
    { // 获取用户可用的节点列表
        $query = $this->user->nodes()
            ->whereIn('is_display', [2, 3]) // 获取这个账号可用节点
            ->with(['labels', 'country', 'relayNode']); // 预加载关联关系以避免N+1查询

        if ($type === 1 || $type === 4) {
            $query->whereIn('type', [1, 4]);
        } elseif ($type !== null) {
            $query->whereType($type);
        }

        // 根据配置决定是否随机排序，并应用数量限制
        if (sysConfig('rand_subscribe')) {
            $query->inRandomOrder();
        } else {
            $query->orderByDesc('node.sort')->orderBy('node.id');
        }

        // 限制最大订阅数量
        $max = (int) sysConfig('subscribe_max');
        if ($max) {
            $query->limit($max);
        }

        $nodes = $query->get();

        if ($withConfigs) {
            $configs = [];
            foreach ($nodes as $node) {
                $configs[] = $this->generateNodeConfig($node);
            }

            return $configs;
        }

        return $nodes;
    }

    public function generateNodeConfig(Node $node): array
    { // 生成节点的完整配置
        $config = [
            'id' => $node->id,
            'name' => $node->name,
            'country' => $node->country_code,
            'labels' => $node->labels->pluck('name')->toArray(),
            'area' => $node->country->name,
            'host' => $node->host,
            'group' => sysConfig('website_name'),
            'udp' => $node->is_udp,
        ];

        // 如果是中转节点，处理父节点配置
        if ($node->relay_node_id) {
            $parentConfig = $this->generateNodeConfig($node->relayNode);
            $config = array_merge($config, Arr::except($parentConfig, ['id', 'name', 'host', 'group', 'udp']));

            if ($parentConfig['type'] === 'trojan') {
                $config['sni'] = $parentConfig['host'];
            }

            $config['port'] = $node->port;

            return $config;
        }

        // 按节点类型生成特定配置
        return match ($node->type) {
            0 => [ // Shadowsocks
                'type' => 'shadowsocks',
                'port' => $node->port ?: $this->user->port,
                'passwd' => $this->user->passwd,
                ...$node->profile,
            ],
            2 => [ // Vmess
                'type' => 'vmess',
                'port' => $node->port,
                'uuid' => $this->user->vmess_id,
                ...$node->profile,
            ],
            3 => [ // Trojan
                'type' => 'trojan',
                'port' => $node->port,
                'passwd' => $this->user->passwd,
                ...$node->profile,
            ],
            5 => [ // Hysteria2
                'type' => 'hysteria2',
                'port' => $node->port,
                'passwd' => $this->user->port.':'.$this->user->passwd,
                ...$node->profile,
            ],
            default => array_merge(
                [ // 1, 4 => SSR
                    'type' => 'shadowsocksr',
                    ...$node->profile,
                ],
                ($node->profile['passwd'] ?? false) && $node->port
                    ? [ // 单端口使用中转的端口
                        'port' => $node->port,
                        'protocol_param' => $this->user->port.':'.$this->user->passwd,
                    ]
                    : [
                        'port' => $this->user->port,
                        'passwd' => $this->user->passwd,
                    ],
                $node->type === 1
                    ? [
                        'method' => $this->user->method,
                        'protocol' => $this->user->protocol,
                        'obfs' => $this->user->obfs,
                    ]
                    : []
            ),
        } + $config;
    }

    public function failedProxyReturn(string $message, int $type = 0): void
    { // 设置错误代理返回（用于兼容客户端）
        $types = ['shadowsocks', 'shadowsocksr', 'vmess', 'trojan', 'hysteria2'];

        $addition = match ($type) {
            1 => ['method' => 'none', 'passwd' => 'error', 'obfs' => 'origin', 'obfs_param' => '', 'protocol' => 'plain', 'protocol_param' => ''],
            2 => ['uuid' => '0', 'v2_alter_id' => 0, 'method' => 'auto'],
            3 => ['passwd' => 'error'],
            5 => ['passwd' => 'error', 'sni' => 'error', 'insecure' => false],
            default => ['method' => 'none', 'passwd' => 'error'],
        };

        // 确保$type在有效范围内
        $typeIndex = $type > 5 ? 0 : $type;

        self::$servers = [['id' => 0, 'name' => $message, 'type' => $types[$typeIndex], 'host' => sysConfig('website_url'), 'port' => 0, 'udp' => 0, ...$addition]];
    }

    public function getUserProxyConfig(Node $node, bool $isUrlFormat = false): string
    { // 获取用户显示用代理信息
        $server = $this->generateNodeConfig($node);
        $type = $isUrlFormat ? new URLSchemes : new Text;

        return match ($server['type']) {
            'shadowsocks' => $type->buildShadowsocks($server),
            'shadowsocksr' => $type->buildShadowsocksr($server),
            'vmess' => $type->buildVmess($server),
            'trojan' => $type->buildTrojan($server),
            'hysteria2' => $type->buildHysteria2($server),
            default => throw new Exception('Unsupported proxy type: '.$server['type']),
        };
    }

    public function setUser(User $user): void
    { // 设置用户
        $this->user = $user;
    }
}