ClientController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291
  1. <?php
  2. namespace App\Http\Controllers\Client;
  3. use App\Http\Controllers\Controller;
  4. use Illuminate\Http\Request;
  5. use App\Models\Server;
  6. use App\Utils\Helper;
  7. use Symfony\Component\Yaml\Yaml;
  8. use App\Services\UserService;
  9. class ClientController extends Controller
  10. {
  11. public function subscribe(Request $request)
  12. {
  13. $user = $request->user;
  14. $server = [];
  15. // account not expired and is not banned.
  16. $userService = new UserService();
  17. if ($userService->isAvailable($user)) {
  18. $servers = Server::where('show', 1)
  19. ->orderBy('sort', 'ASC')
  20. ->get();
  21. foreach ($servers as $item) {
  22. $groupId = json_decode($item['group_id']);
  23. if (in_array($user->group_id, $groupId)) {
  24. array_push($server, $item);
  25. }
  26. }
  27. }
  28. if (isset($_SERVER['HTTP_USER_AGENT'])) {
  29. if (strpos($_SERVER['HTTP_USER_AGENT'], 'Quantumult%20X') !== false) {
  30. die($this->quantumultX($user, $server));
  31. }
  32. if (strpos($_SERVER['HTTP_USER_AGENT'], 'Quantumult') !== false) {
  33. die($this->quantumult($user, $server));
  34. }
  35. if (strpos(strtolower($_SERVER['HTTP_USER_AGENT']), 'clash') !== false) {
  36. die($this->clash($user, $server));
  37. }
  38. if (strpos($_SERVER['HTTP_USER_AGENT'], 'Surfboard') !== false) {
  39. die($this->surge($user, $server));
  40. }
  41. if (strpos($_SERVER['HTTP_USER_AGENT'], 'Surge') !== false) {
  42. die($this->surge($user, $server));
  43. }
  44. }
  45. die($this->origin($user, $server));
  46. }
  47. private function quantumultX($user, $server)
  48. {
  49. $uri = '';
  50. foreach ($server as $item) {
  51. $uri .= "vmess=" . $item->host . ":" . $item->port . ", method=none, password=" . $user->v2ray_uuid . ", fast-open=false, udp-relay=false, tag=" . $item->name;
  52. if ($item->tls) {
  53. $tlsSettings = json_decode($item->tlsSettings);
  54. $uri .= ', obfs=over-tls';
  55. if (isset($tlsSettings->allowInsecure)) {
  56. // Default: tls-verification=true
  57. $uri .= ', tls-verification=' . ($tlsSettings->allowInsecure ? "false" : "true");
  58. }
  59. if (isset($tlsSettings->serverName)) {
  60. $uri .= ', obfs-host=' . $tlsSettings->serverName;
  61. }
  62. }
  63. if ($item->network == 'ws') {
  64. $uri .= ', obfs=' . ($item->tls ? 'wss' : 'ws');
  65. if ($item->networkSettings) {
  66. $wsSettings = json_decode($item->networkSettings);
  67. if (isset($wsSettings->path)) $uri .= ', obfs-uri=' . $wsSettings->path;
  68. if (isset($wsSettings->headers->Host)) $uri .= ', obfs-host=' . $wsSettings->headers->Host;
  69. }
  70. }
  71. $uri .= "\r\n";
  72. }
  73. return base64_encode($uri);
  74. }
  75. private function quantumult($user, $server)
  76. {
  77. $uri = '';
  78. header('subscription-userinfo: upload=' . $user->u . '; download=' . $user->d . ';total=' . $user->transfer_enable);
  79. foreach ($server as $item) {
  80. $str = '';
  81. $str .= $item->name . '= vmess, ' . $item->host . ', ' . $item->port . ', chacha20-ietf-poly1305, "' . $user->v2ray_uuid . '", over-tls=' . ($item->tls ? "true" : "false") . ', certificate=0, group=' . config('v2board.app_name', 'V2Board');
  82. if ($item->network === 'ws') {
  83. $str .= ', obfs=ws';
  84. if ($item->networkSettings) {
  85. $wsSettings = json_decode($item->networkSettings);
  86. if (isset($wsSettings->path)) $str .= ', obfs-path="' . $wsSettings->path . '"';
  87. if (isset($wsSettings->headers->Host)) $str .= ', obfs-header="Host:' . $wsSettings->headers->Host . '"';
  88. }
  89. }
  90. $uri .= "vmess://" . base64_encode($str) . "\r\n";
  91. }
  92. return base64_encode($uri);
  93. }
  94. private function origin($user, $server)
  95. {
  96. $uri = '';
  97. foreach ($server as $item) {
  98. $uri .= Helper::buildVmessLink($item, $user);
  99. }
  100. return base64_encode($uri);
  101. }
  102. private function surge($user, $server)
  103. {
  104. $proxies = '';
  105. $proxyGroup = '';
  106. foreach ($server as $item) {
  107. // [Proxy]
  108. $proxies .= $item->name . ' = vmess, ' . $item->host . ', ' . $item->port . ', username=' . $user->v2ray_uuid;
  109. if ($item->tls) {
  110. $tlsSettings = json_decode($item->tlsSettings);
  111. $proxies .= ', tls=' . ($item->tls ? "true" : "false");
  112. if (isset($tlsSettings->allowInsecure)) {
  113. $proxies .= ', skip-cert-verify=' . ($tlsSettings->allowInsecure ? "true" : "false");
  114. }
  115. }
  116. if ($item->network == 'ws') {
  117. $proxies .= ', ws=true';
  118. if ($item->networkSettings) {
  119. $wsSettings = json_decode($item->networkSettings);
  120. if (isset($wsSettings->path)) $proxies .= ', ws-path=' . $wsSettings->path;
  121. if (isset($wsSettings->headers->Host)) $proxies .= ', ws-headers=host:' . $wsSettings->headers->Host;
  122. }
  123. }
  124. $proxies .= "\r\n";
  125. // [Proxy Group]
  126. $proxyGroup .= $item->name . ', ';
  127. }
  128. try {
  129. $rules = '';
  130. foreach (glob(base_path() . '/resources/rules/' . '*.surge.conf') as $file) {
  131. $rules = file_get_contents("$file");
  132. }
  133. } catch (\Exception $e) {}
  134. // Subscription link
  135. $subsURL = 'http';
  136. if (isset( $_SERVER['HTTPS'] ) && strtolower( $_SERVER['HTTPS'] ) == 'on') {
  137. $subsURL .= 's';
  138. }
  139. $subsURL .= '://';
  140. if ($_SERVER['SERVER_PORT'] != ('80' || '443')) {
  141. $subsURL .= $_SERVER['SERVER_NAME'] . ':' . $_SERVER['SERVER_PORT'] . $_SERVER['REQUEST_URI'];
  142. } else {
  143. $subsURL .= $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];
  144. }
  145. $rules = str_replace('{subs_link}',$subsURL,$rules);
  146. $rules = str_replace('{proxies}',$proxies,$rules);
  147. $rules = str_replace('{proxy_group}',rtrim($proxyGroup, ', '),$rules);
  148. return $rules;
  149. }
  150. private function clash($user, $server)
  151. {
  152. $proxy = [];
  153. $proxies = [];
  154. $rules = [];
  155. foreach ($server as $item) {
  156. $array = [];
  157. $array['name'] = $item->name;
  158. $array['type'] = 'vmess';
  159. $array['server'] = $item->host;
  160. $array['port'] = $item->port;
  161. $array['uuid'] = $user->v2ray_uuid;
  162. $array['alterId'] = $user->v2ray_alter_id;
  163. $array['cipher'] = 'auto';
  164. if ($item->tls) {
  165. $tlsSettings = json_decode($item->tlsSettings);
  166. $array['tls'] = true;
  167. if (isset($tlsSettings->allowInsecure)) $array['skip-cert-verify'] = ($tlsSettings->allowInsecure ? true : false );
  168. }
  169. if ($item->network == 'ws') {
  170. $array['network'] = $item->network;
  171. if ($item->networkSettings) {
  172. $wsSettings = json_decode($item->networkSettings);
  173. if (isset($wsSettings->path)) $array['ws-path'] = $wsSettings->path;
  174. if (isset($wsSettings->headers->Host)) $array['ws-headers'] = [
  175. 'Host' => $wsSettings->headers->Host
  176. ];
  177. }
  178. }
  179. array_push($proxy, $array);
  180. array_push($proxies, $item->name);
  181. }
  182. $proxyGroup = [
  183. [
  184. 'name' => '🔰 节点选择',
  185. 'type' => 'select',
  186. 'proxies' => array_merge([
  187. '♻️ 自动选择',
  188. '🎯 全球直连'
  189. ], $proxies)
  190. ], [
  191. 'name' => '♻️ 自动选择',
  192. 'type' => 'url-test',
  193. 'url' => 'http://www.gstatic.com/generate_204',
  194. 'interval' => 300,
  195. 'proxies' => $proxies
  196. ], [
  197. 'name' => '🌍 国外媒体',
  198. 'type' => 'select',
  199. 'proxies' => array_merge([
  200. '🔰 节点选择',
  201. '♻️ 自动选择',
  202. '🎯 全球直连'
  203. ], $proxies)
  204. ], [
  205. 'name' => '🌏 国内媒体',
  206. 'type' => 'select',
  207. 'proxies' => array_merge([
  208. '🎯 全球直连',
  209. '🔰 节点选择'
  210. ], $proxies)
  211. ], [
  212. 'name' => 'Ⓜ️ 微软服务',
  213. 'type' => 'select',
  214. 'proxies' => array_merge([
  215. '🎯 全球直连',
  216. '🔰 节点选择'
  217. ], $proxies)
  218. ], [
  219. 'name' => '📲 电报信息',
  220. 'type' => 'select',
  221. 'proxies' => array_merge([
  222. '🔰 节点选择',
  223. '🎯 全球直连'
  224. ], $proxies)
  225. ], [
  226. 'name' => '🍎 苹果服务',
  227. 'type' => 'select',
  228. 'proxies' => array_merge([
  229. '🎯 全球直连',
  230. '🔰 节点选择',
  231. '♻️ 自动选择'
  232. ], $proxies)
  233. ], [
  234. 'name' => '🎯 全球直连',
  235. 'type' => 'select',
  236. 'proxies' => [
  237. 'DIRECT'
  238. ]
  239. ], [
  240. 'name' => '🛑 全球拦截',
  241. 'type' => 'select',
  242. 'proxies' => [
  243. 'REJECT',
  244. 'DIRECT'
  245. ]
  246. ], [
  247. 'name' => '🐟 漏网之鱼',
  248. 'type' => 'select',
  249. 'proxies' => array_merge([
  250. '🔰 节点选择',
  251. '♻️ 自动选择',
  252. '🎯 全球直连'
  253. ], $proxies)
  254. ]
  255. ];
  256. try {
  257. $rules = [];
  258. foreach (glob(base_path() . '/resources/rules/' . '*.clash.yaml') as $file) {
  259. $rules = array_merge($rules, Yaml::parseFile($file)['Rule']);
  260. }
  261. } catch (\Exception $e) {}
  262. $config = [
  263. 'port' => 7890,
  264. 'socks-port' => 7891,
  265. 'allow-lan' => false,
  266. 'mode' => 'Rule',
  267. 'log-level' => 'info',
  268. 'external-controller' => '0.0.0.0:9090',
  269. 'secret' => '',
  270. 'Proxy' => $proxy,
  271. 'Proxy Group' => $proxyGroup,
  272. 'Rule' => $rules
  273. ];
  274. return Yaml::dump($config);
  275. }
  276. }