Merge c8baf937dc into 3a05281a9f

allow admin/staff unbind a user and better subscription domain names

app/Console/Commands/MigrateFromV2b.php

@@ -51,15 +51,16 @@ class MigrateFromV2b extends Command
             ],
             '1.7.3' => [
                 'ALTER TABLE `v2_stat_order` RENAME TO `v2_stat`;',
-                "ALTER TABLE `v2_stat` CHANGE COLUMN order_amount order_total INT COMMENT '订单合计';",
+                "ALTER TABLE `v2_stat` CHANGE COLUMN order_amount paid_total INT COMMENT '订单合计';",
+                "ALTER TABLE `v2_stat` CHANGE COLUMN order_count paid_count INT COMMENT '邀请佣金';",
                 "ALTER TABLE `v2_stat` CHANGE COLUMN commission_amount commission_total INT COMMENT '佣金合计';",
                 "ALTER TABLE `v2_stat`
-                    ADD COLUMN paid_count INT NULL,
-                    ADD COLUMN paid_total INT NULL,
+                    ADD COLUMN order_count INT NULL,
+                    ADD COLUMN order_total INT NULL,
                     ADD COLUMN register_count INT NULL,
                     ADD COLUMN invite_count INT NULL,
                     ADD COLUMN transfer_used_total VARCHAR(32) NULL;
-                ",  
+                ", 
                 "CREATE TABLE `v2_log` (
                     `id` INT AUTO_INCREMENT PRIMARY KEY,
                     `title` TEXT NOT NULL,

app/Plugins/Telegram/Commands/UnBind.php

@@ -12,11 +12,17 @@ class UnBind extends Telegram {
 
     public function handle($message, $match = []) {
         if (!$message->is_private) return;
-        $user = User::where('telegram_id', $message->chat_id)->first();
-        $telegramService = $this->telegramService;
-        if (!$user) {
-            $telegramService->sendMessage($message->chat_id, '没有查询到您的用户信息，请先绑定账号', 'markdown');
-            return;
+        if (!isset($message->args[0])) {
+            $user = User::where('telegram_id', $message->chat_id)->first();
+        } else {
+            $chat = User::where('telegram_id', $message->chat_id)->first();
+            if (!$chat) return;
+            if (!($chat->is_admin || $chat->is_staff)) return;
+            if (strpos($message->args[0], '@') !== true) {
+                $user = User::where('email', $message->args[0])->first();
+            } else {
+                $user = User::where('telegram_id', $message->args[0])->first();
+            }
         }
         $user->telegram_id = NULL;
         if (!$user->save()) {

app/Protocols/Stash.php

@@ -52,10 +52,16 @@ class Stash
                 array_push($proxy, self::buildVmess($user['uuid'], $item));
                 array_push($proxies, $item['name']);
             }
-            // if ($item['type'] === 'vless') {
-            //     array_push($proxy, self::buildVless($user['uuid'], $item));
-            //     array_push($proxies, $item['name']);
-            // }
+            if ($item['type'] === 'vless') {
+                if ($item['flow'] === 'xtls-rprx-vision') {
+                    continue;
+                }
+                if ($item['tls'] === 2) {
+                    continue;
+                }
+                array_push($proxy, self::buildVless($user['uuid'], $item));
+                array_push($proxies, $item['name']);
+            }
             if ($item['type'] === 'hysteria') {
                 array_push($proxy, self::buildHysteria($user['uuid'], $item));
                 array_push($proxies, $item['name']);
@@ -169,56 +175,50 @@ class Stash
         return $array;
     }
 
-    public static function buildVless($uuid, $server)
-    {
+    public static function buildVless($password, $server){
         $array = [];
         $array['name'] = $server['name'];
         $array['type'] = 'vless';
         $array['server'] = $server['host'];
         $array['port'] = $server['port'];
-        $array['uuid'] = $uuid;
-        $array['flow'] = !empty($server['flow']) ? $server['flow']: "";
+        $array['uuid'] = $password;
+        $array['alterId'] = 0;
+        $array['cipher'] = 'auto';
         $array['udp'] = true;
 
-        $fingerprints = ['chrome', 'firefox', 'safari', 'ios', 'edge', 'qq']; //随机客户端指纹
-        $array['client-fingerprint'] = $fingerprints[rand(0,count($fingerprints) - 1)];
+        // XTLS流控算法
+        if($server['flow']) ($array['flow'] = $server['flow']);
 
         if ($server['tls']) {
-            $array['tls'] = true;
             switch($server['tls']){
-                case 1:
+                case 1:  //开启TLS
+                    $array['tls'] = true;
                     if ($server['tls_settings']) {
                         $tlsSettings = $server['tls_settings'];
+                        if (isset($tlsSettings['allowInsecure']) && !empty($tlsSettings['allowInsecure']))
+                            $array['skip-cert-verify'] = ($tlsSettings['allowInsecure'] ? true : false);
                         if (isset($tlsSettings['server_name']) && !empty($tlsSettings['server_name']))
                             $array['servername'] = $tlsSettings['server_name'];
                     }
                     break;
-                case 2:
-                    if (!isset($server['network_settings'])) break;
-                    $networkSettings = $server['network_settings'];
-                    if (isset($networkSettings['reality-opts'])){
-                        $realitySettings = $networkSettings['reality-opts'];
-                        $array['reality-opts'] = [];
-                        $array['reality-opts']['public-key'] = $realitySettings['public-key'];
-                        $array['reality-opts']['short-id'] = $realitySettings['short-id'];
-                    }
+                case 2:  //开启reality
+                    $array['tls'] = true;
+                    $tls_settings = $server['tls_settings'];
+                    if (!empty($tls_settings['allowInsecure'])) $array['skip-cert-verify'] = (bool)$tls_settings['allowInsecure'];
+
+                    if(($tls_settings['public_key'] ?? null)
+                    && ($tls_settings['short_id'] ?? null)
+                    && ($tls_settings['server_name'] ?? null)){
+                        $array['servername'] = $tls_settings['server_name'];
+                        $array['reality-opts'] = [
+                            'public-key' => $tls_settings['public_key'],
+                            'short-id' => $tls_settings['short_id']
+                        ];
+                        $fingerprints = ['chrome', 'firefox', 'safari', 'ios', 'edge', 'qq']; //随机客户端指纹
+                        $array['client-fingerprint'] = $fingerprints[rand(0,count($fingerprints) - 1)];
+                    };
                     break;
             }
-
-        }
-
-        if ($server['network'] === 'tcp') {
-            $tcpSettings = $server['networkSettings'];
-            if (isset($tcpSettings['header']['type']) && $tcpSettings['header']['type'] == 'http') {
-                $array['network'] = $tcpSettings['header']['type'];
-                if (isset($tcpSettings['header']['request']['headers']['Host'])){
-                    $array['http-opts']['headers']['Host'] = $tcpSettings['header']['request']['headers']['Host'];
-                }
-                if (isset($tcpSettings['header']['request']['path'][0])){
-                    $paths = $tcpSettings['header']['request']['path'];
-                    $array['http-opts']['path'] = $paths[array_rand($paths)];
-                };
-            }
         }
 
         if ($server['network'] === 'ws') {
@@ -241,7 +241,9 @@ class Stash
             if ($server['network_settings']) {
                 $grpcSettings = $server['network_settings'];
                 $array['grpc-opts'] = [];
-                if (isset($grpcSettings['serviceName'])) $array['grpc-opts']['grpc-service-name'] = $grpcSettings['serviceName'];
+                if (isset($grpcSettings['serviceName'])) {
+                    $array['grpc-opts']['grpc-service-name'] = $grpcSettings['serviceName'];
+                };
             }
         }
 

app/Utils/Helper.php

@@ -110,11 +110,20 @@ class Helper
 
     public static function getSubscribeUrl(string $token, $subscribeUrl = null)
     {
+        $strs = 'QWERTYUIOPASDFGHJKLZXCVBNM1234567890qwertyuiopasdfghjklzxcvbnm';
+        $randstr = substr(str_shuffle($strs), 0, rand(4,8));
+        
         $path = route('client.subscribe', ['token' => $token], false);
         if(!$subscribeUrl){
             $subscribeUrls = explode(',', admin_setting('subscribe_url'));
             $subscribeUrl = \Arr::random($subscribeUrls);
             $subscribeUrl = self::replaceByPattern($subscribeUrl);
+            if (strpos($subscribeUrl, "*") !== false) {
+                $subscribeUrl = str_replace("*", $randstr, $subscribeUrl);
+            } elseif (strpos($subscribeUrl, '{uuid}') !== false) {
+                $user = User::where('token', $token)->first();
+                $subscribeUrl = str_replace('{uuid}', $user->uuid, $subscribeUrl);
+            }
         }
         return $subscribeUrl ? rtrim($subscribeUrl, '/') . $path : url($path);
     }

update.sh

@@ -11,7 +11,7 @@ if ! command -v git &> /dev/null; then
 fi
 
 git config --global --add safe.directory $(pwd)
-git fetch --all && git reset --hard origin/dev && git pull origin dev
+git fetch --all && git reset --hard origin/legacy && git pull origin legacy
 rm -rf composer.lock composer.phar
 wget https://github.com/composer/composer/releases/latest/download/composer.phar -O composer.phar
 php composer.phar update -vvv