https.js

import{connect as t}from"cloudflare:sockets";

const n="495c7195-85b8-498a-bf20-2ea9ce9175b5",r=65536,s=262144,a=8192,c=16384,o=32768,h=8192,l={"Content-Type":"application/octet-stream","grpc-status":"0","X-Accel-Buffering":"no","Cache-Control":"no-store"},u=new Map,y=new Map,f=new Map,w=new Array(20),A0=Uint8Array,A1=setTimeout,A2=clearTimeout,A3=WebSocket,A4=()=>{},A5=WebSocketPair;

let p,d,g,b,m=0;
const k=/^(25[0-5]|2[0-4]\d|[01]?\d\d?)\.(25[0-5]|2[0-4]\d|[01]?\d\d?)\.(25[0-5]|2[0-4]\d|[01]?\d\d?)\.(25[0-5]|2[0-4]\d|[01]?\d\d?)$/,A=/^\[?([a-fA-F0-9:]+)\]?$/,L=new A0(0),U=new TextDecoder,v=new TextEncoder,S=new A0(20),C=v.encode("ss-subkey"),x=t=>15&(t>64?t+9:t),T=new A0(16);for(let t=0,e=0;t<16;t++){let r=n.charCodeAt(e++);45===r&&(r=n.charCodeAt(e++));let s=n.charCodeAt(e++);45===s&&(s=n.charCodeAt(e++)),T[t]=x(r)<<4|x(s)}
const AI=["chatgpt.com","openai.com","openai.azure.com","oaistatic.com","oaiusercontent.com","chat.com","claude.ai","claude.com","anthropic.com","grok.com","x.ai","perplexity.ai","poe.com","character.ai","pi.ai","you.com","phind.com","blackbox.ai","civitai.com"],isAI=h=>{if(!h)return 0;h=(""+h).toLowerCase().replace(/\.$/,"");if(h.includes(":")||/^\d+\.\d+\.\d+\.\d+$/.test(h))return 0;for(const d of AI)if(h===d||h.endsWith("."+d))return 1;return 0},isIP=h=>k.test(h)||A.test(h),sni=t=>{if(!t||t.length<44||22!==t[0]||1!==t[5])return"";let e=44+t[43];e+=2+(t[e]<<8|t[e+1]),e+=1+t[e];if(e+2>t.length)return"";const n=e+2+(t[e]<<8|t[e+1]);e+=2;for(;e+4<=n&&e+4<=t.length;){const r=t[e]<<8|t[e+1],o=t[e+2]<<8|t[e+3];if(e+=4,0===r){const n=e+5,r=t[e+3]<<8|t[e+4];return 0===t[e+2]&&n+r<=t.length?U.decode(t.subarray(n,n+r)):""}e+=o}return""};
const M=(t,e,n,r=0)=>{for(let s=0;s<n;s++)if(t[s+r]!==e[s])return 0;return 1},E=t=>M(t,T,16,1),H=(...t)=>{const e=new A0(t.reduce((t,e)=>t+e.length,0));let n=0;for(const r of t)e.set(r,n),n+=r.length;return e},_=t=>v.encode(t),P=(t,e)=>t[e]<<8|t[e+1];
function R(t){try{t?.close?.()?.catch(A4)}catch{}}
const D=t=>{try{t?.releaseLock()}catch{}},W=t=>t instanceof A0?t:ArrayBuffer.isView(t)?new A0(t.buffer,t.byteOffset,t.byteLength):new A0(t),$=(t,e,n)=>{t[e]=n>>8&255,t[e+1]=255&n},O=(t,e)=>1===t?`${e[0]}.${e[1]}.${e[2]}.${e[3]}`:3===t?U.decode(e):`[${Array.from({length:8},(t,n)=>(e[2*n]<<8|e[2*n+1]).toString(16)).join(":")}]`;
function I(t){if(!t)return null;if((t=t.trim()).startsWith("https://"))try{const e=/!ip(?:$|&)/i.test(t),n=new URL(t.replace(/!ip(?:$|&)/i,""));return{type:"https",host:n.hostname,port:parseInt(n.port)||443,username:n.username?decodeURIComponent(n.username):"",password:n.password?decodeURIComponent(n.password):"",isc:e||k.test(n.hostname)||A.test(n.hostname)}}catch{return null}const e=t.match(/^\[([^\]]+)\](?::(\d+))?$/);if(e){const t=parseInt(e[2],10);return{type:"direct",host:e[1],port:!isNaN(t)&&t>0?t:443}}const n=t.lastIndexOf(":");if(n>0){const e=t.substring(0,n),r=parseInt(t.substring(n+1),10);if(!isNaN(r)&&r>0&&r<=65535)return{type:"direct",host:e,port:r}}return{type:"direct",host:t,port:443}}
const K=async t=>{const e=(await async function(t,e){const n=t+"_"+e,r=Date.now(),s=u.get(n);if(s){if(r-s.time<18e4)return s.data;u.delete(n)}const i=y.get(n);if(i)return i;const a=(async()=>{try{const r=await fetch(`https://cloudflare-dns.com/dns-query?name=${encodeURIComponent(t)}&type=${e}`,{headers:{Accept:"application/dns-json"}});if(!r.ok)return[];const s=(await r.json()).Answer||[];return s.length&&(u.size>=400&&u.delete(u.keys().next().value),u.set(n,{data:s,time:Date.now()})),s}catch{return[]}})();y.set(n,a);try{return await a}finally{y.delete(n)}}(t,"TXT")).filter(t=>16===t.type).map(t=>t.data);return e.length?e.map(t=>t.replace(/"/g,"")).join(",").replace(/[\r\n\s]+/g,",").split(",").map(t=>t.trim()).filter(Boolean):[]},B=()=>b??=(()=>{const t=new TextEncoder,e=new A0(0),n=new Map(Object.entries({TLS_AES_128_GCM_SHA256:{id:4865,keyLen:16,ivLen:12,hash:"SHA-256",tls13:!0},TLS_AES_256_GCM_SHA384:{id:4866,keyLen:32,ivLen:12,hash:"SHA-384",tls13:!0},TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256:{id:49199,keyLen:16,ivLen:4,hash:"SHA-256",kex:"ECDHE"},TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384:{id:49200,keyLen:32,ivLen:4,hash:"SHA-384",kex:"ECDHE"},TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256:{id:49195,keyLen:16,ivLen:4,hash:"SHA-256",kex:"ECDHE"},TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384:{id:49196,keyLen:32,ivLen:4,hash:"SHA-384",kex:"ECDHE"}}).map(([,t])=>[t.id,t])),r=new Map([[29,"X25519"],[23,"P-256"]]),s=[2052,2053,2054,1025,1281,1537,1027,1283,1539],i=(...t)=>{const e=t=>{const n=[];for(const r of t)r instanceof A0?n.push(...r):Array.isArray(r)?n.push(...e(r)):"number"==typeof r&&n.push(r);return n};return new A0(e(t))},a=t=>[t>>8&255,255&t],c=(t,e)=>t[e]<<8|t[e+1],o=(t,e)=>t[e]<<16|t[e+1]<<8|t[e+2],h=(...t)=>{const e=t.filter(t=>t&&t.length>0),n=e.reduce((t,e)=>t+e.length,0),r=new A0(n);let s=0;for(const t of e)r.set(t,s),s+=t.length;return r},l=t=>crypto.getRandomValues(new A0(t)),u=(t,e)=>{if(!t||!e||t.length!==e.length)return!1;let n=0;for(let r=0;r<t.length;r++)n|=t[r]^e[r];return 0===n},y=t=>"SHA-512"===t?64:"SHA-384"===t?48:32;async function f(t,e,n){const r=await crypto.subtle.importKey("raw",e,{name:"HMAC",hash:t},!1,["sign"]);return new A0(await crypto.subtle.sign("HMAC",r,n))}async function w(t,e){return new A0(await crypto.subtle.digest(t,e))}async function p(e,n,r,s,i="SHA-256"){const a=h(t.encode(n),r);let c=new A0(0),o=a;for(;c.length<s;){o=await f(i,e,o);const t=await f(i,e,h(o,a));c=h(c,t)}return c.slice(0,s)}async function d(t,e,n){return e&&e.length||(e=new A0(y(t))),f(t,e,n)}async function g(e,n,r,s,c){const o=t.encode("tls13 "+r);return async function(t,e,n,r){const s=y(t),i=Math.ceil(r/s);let a=new A0(0),c=new A0(0);for(let r=1;r<=i;r++)c=await f(t,e,h(c,n,[r])),a=h(a,c);return a.slice(0,r)}(e,n,i(a(c),o.length,o,s.length,s),c)}async function b(t="P-256"){if("X25519"===t){const t=await crypto.subtle.generateKey({name:"X25519"},!0,["deriveBits"]);return{kp:t,pk:new A0(await crypto.subtle.exportKey("raw",t.publicKey))}}const e=await crypto.subtle.generateKey({name:"ECDH",namedCurve:t},!0,["deriveBits"]);return{kp:e,pk:new A0(await crypto.subtle.exportKey("raw",e.publicKey))}}async function m(t,e,n="P-256"){if("X25519"===n){const n=await crypto.subtle.importKey("raw",e,{name:"X25519"},!1,[]);return new A0(await crypto.subtle.deriveBits({name:"X25519",public:n},t,256))}const r=await crypto.subtle.importKey("raw",e,{name:"ECDH",namedCurve:n},!1,[]),s="P-384"===n?384:"P-521"===n?528:256;return new A0(await crypto.subtle.deriveBits({name:"ECDH",public:r},t,s))}async function k(t,e,n,r){const s=await crypto.subtle.importKey("raw",t,{name:"AES-GCM"},!1,["encrypt"]);return new A0(await crypto.subtle.encrypt({name:"AES-GCM",iv:e,additionalData:r,tagLength:128},s,n))}async function A(t,e,n,r){const s=await crypto.subtle.importKey("raw",t,{name:"AES-GCM"},!1,["decrypt"]);return new A0(await crypto.subtle.decrypt({name:"AES-GCM",iv:e,additionalData:r,tagLength:128},s,n))}function L(t,e,n=771){return i(t,a(n),a(e.length),e)}function U(t,e){return i(t,[(n=e.length)>>16&255,n>>8&255,255&n],e);var n}class v{constructor(){this.b=new A0(0)}feed(t){this.b=h(this.b,t)}next(){if(this.b.length<5)return null;const t=this.b[0],e=c(this.b,1),n=c(this.b,3);if(this.b.length<5+n)return null;const r=this.b.slice(5,5+n);return this.b=this.b.slice(5+n),{type:t,version:e,length:n,fragment:r}}}class S{constructor(){this.b=new A0(0)}feed(t){this.b=h(this.b,t)}next(){if(this.b.length<4)return null;const t=this.b[0],e=o(this.b,1);if(this.b.length<4+e)return null;const n=this.b.slice(4,4+e),r=this.b.slice(0,4+e);return this.b=this.b.slice(4+e),{type:t,length:e,body:n,raw:r}}}function C(t){let e=0;const n=c(t,e);e+=2;const r=t.slice(e,e+32);e+=32;const s=t[e++],i=t.slice(e,e+s);e+=s;const a=c(t,e);e+=2;const o=t[e++];let h=n,l=null;if(e<t.length){const n=c(t,e);e+=2;const r=e+n;for(;e+4<=r;){const n=c(t,e);e+=2;const r=c(t,e);e+=2;const s=t.slice(e,e+r);if(e+=r,43===n&&r>=2)h=c(s,0);else if(51===n&&r>=4){const t=c(s,0),e=c(s,2);l={group:t,key:s.slice(4,4+e)}}}}const y=new A0([207,33,173,116,229,154,97,17,190,29,140,2,30,101,184,145,194,162,17,22,122,187,140,94,7,158,9,226,200,168,51,156]);return{version:n,sr:r,sid:i,cs:a,comp:o,sv:h,ks:l,isHRR:u(r,y),isTls13:772===h}}function x(t,e=0){let n=0;if(e){const e=t[n++];n+=e}if(n+3>t.length)return null;const r=o(t,n);if(n+=3,!r||n+3>t.length)return null;const s=o(t,n);return n+=3,s?t.slice(n,n+s):null}const T=t=>t&&1===t[0]&&112===t[1];const M=t=>{const e=new A0(8);return new DataView(e.buffer).setBigUint64(0,t,!1),e},E=(t,e)=>{const n=t.slice(),r=M(e);for(let t=0;t<8;t++)n[n.length-8+t]^=r[t];return n},H=(t,n,r,s)=>Promise.all([g(t,n,"key",e,r),g(t,n,"iv",e,s)]);return{TlsClient:class{constructor(t,e={}){if(this.sk=t,this.sn=e.serverName||"",this.s13=!1!==e.tls13,this.s12=!1!==e.tls12,!this.s13&&!this.s12)throw 0;this.to=e.timeout??3e4,this.cr=l(32),this.sr=null,this.hk=[],this.hc=!1,this.cs=null,this.cc=null,this.is13=!1,this.ms=null,this.hs=null,this.cwk=null,this.swk=null,this.cwi=null,this.swi=null,this.chk=null,this.shk=null,this.chi=null,this.shi=null,this.cak=null,this.sak=null,this.cai=null,this.sai=null,this.csn=0n,this.ssn=0n,this.rp=new v,this.hp=new S,this.kps=new Map,this.ekp=null,this.sc=!1}rh(t){this.hk.push(t)}ts(){return 1===this.hk.length?this.hk[0]:h(...this.hk)}gfc(t){return n.get(t)||null}async rc(t){if(!this.to)return t.read();let e;const n=t.read(),r=await Promise.race([n,new Promise(t=>e=A1(t,this.to,0))]).finally(()=>A2(e));if(r)return r;try{await t.cancel("err")}catch{}try{await n}catch{}throw 0}async pr(t,e){for(;;){let n;for(;n=this.rp.next();)if(await e(n))return;const{value:r,done:s}=await this.rc(t);if(s)throw 0;this.rp.feed(r)}}async ph(t,e,n){for(let t;t=this.hp.next();)if(await e(t))return;return this.pr(t,async t=>{if(21===t.type){if(T(t.fragment))return;throw 0}if(22===t.type){this.hp.feed(t.fragment);for(let t;t=this.hp.next();)if(await e(t))return 1}},n)}async ac(t){if(!t?.length)throw 0;this.sc=!0}async handshake(){const[e,n]=await Promise.all([b("P-256"),b("X25519")]);this.kps=new Map([[23,e],[29,n]]),this.ekp=e.kp;const r=this.sk.readable.getReader(),c=this.sk.writable.getWriter();try{const o=function(e,n,r,{tls13:c=!0,tls12:o=!0}={}){n=(t=>{if("["===(t=String(t??"").trim())[0]&&"]"===t[t.length-1]&&(t=t.slice(1,-1)),!t||t.includes(":"))return"";const e=t.split(".");if(4!==e.length)return t;for(const n of e){if(""===n||n.length>3)return t;let e=0;for(let r=0;r<n.length;r++){const s=n.charCodeAt(r)-48;if(s<0||s>9)return t;e=10*e+s}if(e>255)return t}return""})(n);const l=[];c&&l.push(4865,4866),o&&l.push(49199,49200,49195,49196);const u=i(...l.flatMap(a)),y=[i(255,1,0,1,0)];if(n){const e=t.encode(n),r=i(0,a(e.length),e);y.push(i(a(0),a(r.length+2),a(r.length),r))}y.push(i(a(11),0,2,1,0)),y.push(i(a(10),0,6,0,4,0,29,0,23));const f=i(...s.flatMap(a));if(y.push(i(a(13),a(f.length+2),a(f.length),f)),c&&r){let t;if(y.push(o?i(a(43),0,5,4,3,4,3,3):i(a(43),0,3,2,3,4)),y.push(i(a(45),0,2,1,1)),r?.x25519&&r?.p256)t=h(i(0,29,a(r.x25519.length),r.x25519),i(0,23,a(r.p256.length),r.p256));else if(r?.x25519)t=i(0,29,a(r.x25519.length),r.x25519);else if(r?.p256)t=i(0,23,a(r.p256.length),r.p256);else{if(!(r instanceof A0))throw 0;t=i(0,23,a(r.length),r)}y.push(i(a(51),a(t.length+2),a(t.length),t))}const w=h(...y);return U(1,i(a(771),e,0,a(u.length),u,1,0,a(w.length),w))}(this.cr,this.sn,{x25519:n.pk,p256:e.pk},{tls13:this.s13,tls12:this.s12});this.rh(o),await c.write(L(22,o,769));const l=await this.rsh(r);if(l.isHRR)throw 0;if(l.ks?.group&&this.kps.has(l.ks.group)){const t=this.kps.get(l.ks.group);this.ekp=t.kp}l.isTls13?await this.h13(r,c,l):await this.h12(r,c),this.hc=!0}finally{r.releaseLock(),c.releaseLock()}}async rsh(t){for(;;){const{value:e,done:n}=await this.rc(t);if(n)throw 0;let r;for(this.rp.feed(e);r=this.rp.next();){if(21===r.type){if(T(r.fragment))continue;throw 0}if(22!==r.type)continue;let t;for(this.hp.feed(r.fragment);t=this.hp.next();){if(2!==t.type)continue;this.rh(t.raw);const e=C(t.body);if(this.sr=e.sr,this.cs=e.cs,this.cc=this.gfc(e.cs),this.is13=e.isTls13,!this.cc)throw 0;return e}}}}async h12(t,e){let n=null;if(await this.ph(t,async t=>{switch(t.type){case 11:{this.rh(t.raw);const e=x(t.body);if(!e)throw 0;await this.ac(e);break}case 12:this.rh(t.raw),n=function(t){let e=0;e++;const n=c(t,e);e+=2;const r=t[e++];return{nc:n,spk:t.slice(e,e+r)}}(t.body);break;case 14:return this.rh(t.raw),1;case 13:throw 0;default:this.rh(t.raw)}},"err"),!this.sc||!n)throw 0;const a=r.get(n.nc);if(!a)throw 0;const l=this.kps.get(n.nc);if(!l)throw 0;const y=await m(l.kp.privateKey,n.spk,a),f=U(16,i(l.pk.length,l.pk));this.rh(f);const d=this.cc.hash;this.ms=await p(y,"master secret",h(this.cr,this.sr),48,d);const g=this.cc.keyLen,b=this.cc.ivLen,k=await p(this.ms,"key expansion",h(this.sr,this.cr),2*g+2*b,d);this.cwk=k.slice(0,g),this.swk=k.slice(g,2*g),this.cwi=k.slice(2*g,2*g+b),this.swi=k.slice(2*g+b,2*g+2*b),await e.write(L(22,f)),await e.write(L(20,i(1)));const A=U(20,await p(this.ms,"client finished",await w(d,this.ts()),12,d));this.rh(A),await e.write(L(22,await this.e12(A,22)));let v=!1;await this.pr(t,async t=>{if(21===t.type){if(T(t.fragment))return;throw 0}if(20===t.type)return void(v=!0);if(22!==t.type||!v)return;const e=await this.d12(t.fragment,22);if(20!==e[0])return;const n=o(e,1),r=e.slice(4,4+n),s=await p(this.ms,"server finished",await w(d,this.ts()),12,d);if(!u(r,s))throw 0;return 1},"err")}async h13(t,n,s){const i=r.get(s.ks?.group);if(!i||!s.ks?.key?.length)throw 0;const a=this.cc.hash,c=y(a),o=this.cc.keyLen,l=this.cc.ivLen,p=await m(this.ekp.privateKey,s.ks.key,i),b=await d(a,null,new A0(c)),k=await g(a,b,"derived",await w(a,e),c);this.hs=await d(a,k,p);const A=await w(a,this.ts()),v=await g(a,this.hs,"c hs traffic",A,c),S=await g(a,this.hs,"s hs traffic",A,c);[this.chk,this.chi]=await H(a,v,o,l),[this.shk,this.shi]=await H(a,S,o,l);const C=await g(a,S,"finished",e,c);let M=!1;const E=async t=>{switch(t.type){case 8:case 15:default:this.rh(t.raw);break;case 11:{const e=x(t.body,1);if(!e)throw 0;await this.ac(e),this.rh(t.raw);break}case 13:throw 0;case 20:{const e=await f(a,C,await w(a,this.ts()));if(!u(e,t.body))throw 0;this.rh(t.raw),M=!0;break}}};await this.pr(t,async t=>{if(20===t.type||22===t.type)return;if(21===t.type){if(T(t.fragment))return;throw 0}if(23!==t.type)return;const e=await this.d13h(t.fragment),n=e[e.length-1],r=e.slice(0,-1);if(22===n){this.hp.feed(r);for(let t;t=this.hp.next();)if(await E(t),M)return 1}},"err");const _=await w(a,this.ts()),P=await g(a,this.hs,"derived",await w(a,e),c),R=await d(a,P,new A0(c)),D=await g(a,R,"c ap traffic",_,c),W=await g(a,R,"s ap traffic",_,c);[this.cak,this.cai]=await H(a,D,o,l),[this.sak,this.sai]=await H(a,W,o,l);const $=await g(a,v,"finished",e,c),O=U(20,await f(a,$,await w(a,this.ts())));this.rh(O),await n.write(L(23,await this.e13h(h(O,[22])))),this.csn=0n,this.ssn=0n}async e12(t,e){const n=this.csn++,r=M(n),s=h(r,[e],a(771),a(t.length)),i=l(8);return h(i,await k(this.cwk,h(this.cwi,i),t,s))}async d12(t,e){const n=this.ssn++,r=M(n),s=t.slice(0,8),i=t.slice(8);return A(this.swk,h(this.swi,s),i,h(r,[e],a(771),a(i.length-16)))}async e13h(t){const e=E(this.chi,this.csn++),n=i(23,3,3,a(t.length+16));return k(this.chk,e,t,n)}async d13h(t){const e=E(this.shi,this.ssn++),n=i(23,3,3,a(t.length));return A(this.shk,e,t,n)}async e13(t){const e=h(t,[23]),n=E(this.cai,this.csn++),r=i(23,3,3,a(e.length+16));return k(this.cak,n,e,r)}async d13(t){const e=E(this.sai,this.ssn++),n=i(23,3,3,a(t.length)),r=await A(this.sak,e,t,n);return{data:r.slice(0,-1),type:r[r.length-1]}}async write(t){if(!this.hc)throw 0;const e=this.sk.writable.getWriter();try{this.is13?await e.write(L(23,await this.e13(t))):await e.write(L(23,await this.e12(t,23)))}finally{e.releaseLock()}}async read(){for(;;){let t;for(;t=this.rp.next();){if(21===t.type){if(0===t.fragment[1])return null;throw 0}if(23!==t.type)continue;if(!this.is13)return this.d12(t.fragment,23);const{data:e,type:n}=await this.d13(t.fragment);if(23===n)return e;if(22!==n)continue;let r;for(this.hp.feed(e);r=this.hp.next();)if(4!==r.type&&24===r.type)throw 0}const e=this.sk.readable.getReader();try{const{value:t,done:n}=await this.rc(e);if(n)return null;this.rp.feed(t)}finally{e.releaseLock()}}}close(){this.sk.close()}}}})().TlsClient,G=(t,e,n)=>new ReadableStream({start:e=>t?.length&&e.enqueue(t),pull:e,cancel:n}),N=(t,e,n)=>({readable:G(e,async e=>{try{const n=await t.read();n?e.enqueue(n):e.close()}catch(t){e.error(t)}},()=>t.close()),writable:new WritableStream({write:e=>t.write(e),close(){t.close()},abort(){t.close()}}),close:n}),X=t=>{if(t.byteLength<24||!E(t))return null;let e=19+t[17];if(e+3>t.byteLength)return null;let n=t[e+2];const r=t[e]<<8|t[e+1];1!==n&&(n+=1);const s=((t,e,n)=>{const r=3===n?t[e++]:1===n?4:4===n?16:null;return null===r||e+r>t.length?null:{b:t.subarray(e,e+r),o:e+r}})(t,e+3,n);return s?{t:n,b:s.b,p:r,u:2===t[18+t[17]],v:t[0],o:s.o}:null},j=(t,e)=>{if(1===e){const n=X(t);return n?{type:e,host:O(n.t,n.b),port:n.p,payload:t.subarray(n.o),responsePrefix:new A0([n.v,0]),udpDns:n.u}:null}if(3===e){if(t.length<1)return null;const n=t[0];let r,s,i;if(1===n&&t.length>=7)r=O(1,t.subarray(1,5)),s=P(t,5),i=7;else if(3===n&&t.length>=4+t[1])r=O(3,t.subarray(2,2+t[1])),s=P(t,2+t[1]),i=4+t[1];else{if(!(4===n&&t.length>=19))return null;r=O(4,t.subarray(1,17)),s=P(t,17),i=19}return{type:e,host:r,port:s,payload:t.subarray(i),responsePrefix:L,udpDns:!1}}return null},z=t=>{const e=t.byteLength;if(M(t,T,Math.min(Math.max(0,e-1),16),1)){if(e<17)return{more:1};if(E(t)){const n=j(t,1);return n?{type:1,session:n}:e<c?{more:1}:{error:1}}}return e<17?{more:1}:{error:1}},V=async(e,n)=>{"["==(e=String(e).trim())[0]&&"]"==e[e.length-1]&&(e=e.slice(1,-1));const r=t({hostname:e,port:n},{allowHalfOpen:!0});try{return await r.opened,r}catch(t){throw R(r),t}},q=async(t,e,n,r)=>{const s=await crypto.subtle.importKey("raw",e.length?e:S,{name:"HMAC",hash:"SHA-1"},!1,["sign"]),i=new A0(await crypto.subtle.sign("HMAC",s,t)),a=await crypto.subtle.importKey("raw",i,{name:"HMAC",hash:"SHA-1"},!1,["sign"]),c=new A0(20*Math.ceil(r/20));let o=L;for(let t=0;t<Math.ceil(r/20);t++)o=new A0(await crypto.subtle.sign("HMAC",a,H(o,n,new A0([t+1])))),c.set(o,20*t);return c.slice(0,r)},Q=async()=>g??=new A0(await crypto.subtle.digest("MD5",_(n)));
class F{constructor(t){this.key=t,this.nonce=new A0(12),this.ck=null}async init(){this.ck=await crypto.subtle.importKey("raw",this.key,{name:"AES-GCM"},!1,["encrypt","decrypt"])}inc(){for(let t=0;t<this.nonce.length&&(this.nonce[t]++,!this.nonce[t]);t++);}ivs(){const t=this.nonce.slice();return this.inc(),t}async encIv(t,e){return new A0(await crypto.subtle.encrypt({name:"AES-GCM",iv:e,tagLength:128},this.ck,t))}async dec(t){try{const e=new A0(await crypto.subtle.decrypt({name:"AES-GCM",iv:this.nonce,tagLength:128},this.ck,t));return this.inc(),e}catch{return null}}}
class J{constructor(){this.dec=null,this.enc=null,this.buf=L,this.o=0,this.e=0,this.plen=-1,this.need=0}async decData(t,e){const n=t?.byteLength||0;if(n){if(this.buf.length){if(this.buf.length-this.e<n)if(this.o>0&&this.buf.length-this.e+this.o>=n)this.buf.copyWithin(0,this.o,this.e),this.e-=this.o,this.o=0;else{const t=new A0(this.e-this.o+n);t.set(this.buf.subarray(this.o,this.e)),this.buf=t,this.e-=this.o,this.o=0}}else this.buf=new A0(n),this.o=0,this.e=0;this.buf.set(t.length===n?t:t.subarray(0,n),this.e),this.e+=n}if(this.e-this.o>262144)return"buf";if(!this.dec){if(this.e-this.o<16)return;const t=this.buf.subarray(this.o,this.o+16);this.o+=16,this.dec=new F(await q(await Q(),t,C,16)),await this.dec.init()}for(;;){if(this.plen<0){if(this.e-this.o<18)break;const t=await this.dec.dec(this.buf.subarray(this.o,this.o+18));if(!t)return"len";this.plen=P(t,0),this.need=this.plen+16,this.o+=18}if(this.e-this.o<this.need)break;const t=await this.dec.dec(this.buf.subarray(this.o,this.o+this.need));if(!t)return"pay";e(t),this.o+=this.need,this.plen=-1}}async encData(t){let e=L;if(!this.enc){const t=crypto.getRandomValues(new A0(16));this.enc=new F(await q(await Q(),t,C,16)),await this.enc.init(),e=t}if(!t||0===t.length)return e;const n=new A0(e.length+t.length+34*Math.ceil(t.length/16383));e.length&&n.set(e),t=W(t);let r=e.length;for(let e=0;e<t.length;e+=262128){const s=[];for(let n=e;n<Math.min(e+262128,t.length);n+=16383){const e=t.subarray(n,Math.min(n+16383,t.length)),r=new A0(2);$(r,0,e.length);const i=this.enc.ivs(),a=this.enc.ivs();s.push(Promise.all([this.enc.encIv(r,i),this.enc.encIv(e,a)]))}for(const[e,i]of await Promise.all(s))n.set(e,r),r+=18,n.set(i,r),r+=i.length}return n}}
const Y=async(t,e,n,a)=>{let c,o=!0;try{c=e.getReader({mode:"byob"})}catch{c=e.getReader(),o=!1}const h=s,l=r;let u=new A0(h),y=new ArrayBuffer(l),f=0,w=0,p=!0,v;const d=()=>{if(w&&(A2(w),w=0),!f)return;const t=f;return f=0,v=n(u.subarray(0,t))},g=async()=>{for(;t.readyState===A3.OPEN&&t.bufferedAmount>262144&&(await(globalThis.scheduler?.wait?.(t.bufferedAmount>524288?8:2)??new Promise(t=>A1(t,2))),!(t.bufferedAmount<=65536)););};try{for(;t.readyState===A3.OPEN;){if(v)await v;if(t.bufferedAmount>262144)await g();const j=Math.min(l,h-f),e=await(o?c.read(new A0(y,0,j)):c.read());if(e.done)break;const r=e.value,s=r?.byteLength||0;s&&(o?(y=r.buffer,u.set(r,f),f+=s):f+s>h?(d(),s>=h?v=n(r):(u.set(r,0),f=s)):(u.set(r,f),f+=s));const a=p&&f<l;p=!1,f+l>h||a?d():w||=A1(d,0)}}catch{}finally{try{d()}catch{}D(c),a()}},Z=(t,e)=>{const n=new A0(32768);let r=0,s=0,i=!1,p=Promise.resolve();const f=()=>{i||(c.stop(),e())},w=n=>{try{p=t.write(n).catch(f)}catch{f()}return p},a=()=>{s&&(A2(s),s=0);if(r&&!i){const t=n.slice(0,r);r=0,w(t)}return p},c=t=>{if(i||!t?.byteLength)return p;const e=t.byteLength;if(e>=32768)return a(),w(t);r+e>32768&&a(),n.set(t,r),r+=e;if(32768===r)return a();s||=A1(a,0);return p};c.flush=a,c.stop=()=>{i=!0,r=0,A2(s),s=0};return c};
async function tt(n,r,s,i){if("1"!==i)try{return await V(n,r)}catch{}let a=(("function"==typeof s?s():s)||"").trim();return"https"===(c=await(async()=>{if(a.toLowerCase().endsWith("!txt")){const t=a.slice(0,-4).trim();try{if(p!==t||!d){const e=await K(t);e.length&&(d=e,p=t)}if(d?.length){const t=I(d[Math.floor(Math.random()*d.length)]);if(t)return t}}catch{}return{type:"direct",host:t,port:443}}return I(a)||{type:"direct",host:a,port:443}})()).type?async function(e,n,r){let s,i=null;try{s=t({hostname:e.host,port:e.port},e.isc?{allowHalfOpen:!0}:{secureTransport:"on",allowHalfOpen:!0}),await s.opened;let a=`CONNECT ${n}:${r} HTTP/1.1\r\nHost: ${n}:${r}\r\n`;if(e.username&&(a+=`Proxy-Authorization: Basic ${btoa(`${e.username}:${e.password||""}`)}\r\n`),a+="User-Agent: Mozilla/5.0\r\nConnection: keep-alive\r\n\r\n",e.isc)i=new(B())(s,{serverName:e.host}),await i.handshake(),await i.write(_(a));else{const t=s.writable.getWriter();await t.write(_(a)),t.releaseLock()}let c=e.isc?null:s.readable.getReader(),o=L;for(;;){let t,n;if(e.isc)t=await i.read(),n=!t;else{const e=await c.read();t=e.value,n=e.done}if(n||!t||(o=H(o,t),o.length>=12&&50!==o[9]))throw 0;let r=-1;for(let t=0;t<=o.length-4;t++)if(13===o[t]&&10===o[t+1]&&13===o[t+2]&&10===o[t+3]){r=t+4;break}if(-1!==r){c?.releaseLock();let t=o.subarray(r);if(e.isc)return N(i,t,()=>i.close());if(t.length>0){let{readable:e,writable:n}=new TransformStream,r=n.getWriter();return r.write(t),r.releaseLock(),s.readable.pipeTo(n).catch(A4),{readable:e,writable:s.writable,close:()=>R(s)}}return s}if(o.length>8192)throw 0}}catch(t){throw i?.close(),R(s),t}}(c,n,r):V(c.host,c.port);var c}
const et=async t=>{const e=W(t);let n;try{n=await V("1.1.1.1",53);const t=n.writable.getWriter(),r=n.readable.getReader();let s=L;const i=async t=>{for(;s.byteLength<t;){const{done:t,value:e}=await r.read();if(t)throw 0;const n=W(e);s=s.byteLength?H(s,n):n}const e=s.subarray(0,t);return s=s.byteLength>t?s.subarray(t):new A0(0),e},a=e.byteLength>=2&&P(e,0)===e.byteLength-2;await t.write(a?e:H(new A0([e.byteLength>>8,255&e.byteLength]),e));const c=await i(2),o=await i(P(c,0));return a?H(c,o):o}catch{return null}finally{R(n)}};
async function nt(t,e){try{const n=await et(t);n?.byteLength&&e.readyState===A3.OPEN&&e.send(n)}catch{}}
const rt=async(t,e)=>{const n=await et(t);if(!n)throw 0;await e.write(n)},st=async(t,e)=>{if(t.byob){const n=new ArrayBuffer(e),r=await t.reader.read(new A0(n));return{done:r.done,value:r.value?W(r.value):L}}const n=await t.reader.read();return{done:n.done,value:n.value?W(n.value):L}};
async function it(t,e,n){const r=new A5,[s,i]=Object.values(r);i.binaryType="arraybuffer",i.accept({allowHalfOpen:!0});let o={socket:null,writer:null,bw:null},h=!1,l=!1,u=!1,y=0,f=null,w=null,p=0,d=[],g=Promise.resolve(),b=Promise.resolve(),zz0=0,zz1=0,zz2=0,zz3=0,zz4=0,m=A1(()=>{y||k()},15e3);const k=t=>{if(t="number"==typeof t?t:1e3,!l){l=!0,d=[],m&&(A2(m),m=0);o.bw?.stop(),R(o.writer),D(o.writer),R(o.socket);try{i.close(t,"")}catch{}}},A=t=>{if(!f)return void(i.readyState===A3.OPEN&&i.send(t));const e=t.slice();return b=b.then(async()=>{if(!l)try{const t=await f.encData(e);i.readyState===A3.OPEN&&i.send(t)}catch{}}).catch(A4)},L=()=>{b.then(()=>{try{i.close(1e3,"")}catch{}})};async function U(){if(!u&&!l){u=!0,zz1=0;try{for(;!l;){if(h){let t=d.shift();if(!t)break;if(t.byteLength<65536&&d.length){const e=[t];let n=t.byteLength;for(;d.length&&n+d[0].byteLength<=65536;){const t=d.shift();e.push(t),n+=t.byteLength}e.length>1&&(t=H(...e))}await nt(t,i);continue}if(!o.socket){const t=d.shift();if(!t)break;const r=j(t,y);if(!r)throw 0;if(r.responsePrefix.byteLength&&(zz3||(i.send(r.responsePrefix),zz3=1)),r.udpDns){if(53!==r.port)throw 0;h=!0,await nt(r.payload,i);continue}let zs=isIP(r.host)&&r.payload.byteLength?sni(r.payload):"",sq=null;if(!r.payload.byteLength&&isIP(r.host)&&"1"!==n){if(!zz0)zz0=Date.now();if(d.length)zs=sni(d[0]);else{if(!zz4){try{sq=await V(r.host,r.port)}catch{zz4=1}}if(!sq&&Date.now()-zz0<200){zz1=1,d.unshift(t),zz2||(zz2=A1(()=>{zz2=0,zz1=0,U()},200));return}}}zz2&&(A2(zz2),zz2=0);const s=sq||await tt(r.host,r.port,()=>e(r.host,zs),zz4?(zz4=0,"1"):n);if(!s)throw 0;if(l)return R(s);o.socket=s,o.writer=s.writable.getWriter(),o.bw=Z(o.writer,()=>k(1011)),Y(i,s.readable,A,L),r.payload.byteLength&&await o.bw(r.payload);continue}const t=d.shift();if(!t)break;await o.bw(t)}}catch{k(1011)}finally{u=!1,!l&&d.length&&!zz1&&U()}}}const v=t=>{if(l)return;let e=W(t);if(e.byteLength){if(!y){w=w?.byteLength?H(w,e):e;const t=(t=>{const e=t.byteLength;return e<2||M(t,T,Math.min(e-1,16),1)?X(t)?1:e<c?0:3:3})(w);if(!t)return;e=w,w=null,y=t,m&&(A2(m),m=0)}1===y||2===y?(d.push(e),U()):(f??=new J,++p>256?k(1011):g=g.then(async()=>{try{if(!l){const t=[];if(await f.decData(e,e=>e.byteLength&&t.push(e)))return void k(1011);for(const e of t)d.push(e);U()}}catch{k(1011)}finally{p--}}).catch(A4))}},S=(()=>{const e=[t.headers.get("sec-websocket-protocol")],n=t.headers.get("Referer");n&&e.push(n.slice((t.headers.get("host")||"").length));for(const t of e)try{if(!t||t.length>4*Math.ceil(a/3))continue;const e="function"==typeof A0.fromBase64?A0.fromBase64(t,{alphabet:"base64url"}):A0.from(atob(t.replace(/-/g,"+").replace(/_/g,"/")+"====".slice(0,(4-t.length%4)%4)),t=>t.charCodeAt(0));if(e.byteLength&&e.byteLength<=a)return e}catch{}return null})();return S&&v(S),i.addEventListener("message",t=>v(t.data)),i.addEventListener("close",k),i.addEventListener("error",k),new Response(null,{status:101,webSocket:s,headers:{"Sec-WebSocket-Extensions":""}})}
async function at(t,e,n){if(!t.body)return new Response(null,{status:400});const s={highWaterMark:1048576},i="function"==typeof IdentityTransformStream?new IdentityTransformStream(s):new TransformStream({},s,s),a=(t=>{try{return{reader:t.getReader({mode:"byob"}),byob:!0}}catch{return{reader:t.getReader(),byob:!1}}})(t.body),u=a.reader,y=i.writable.getWriter();let f=null,w=!1,p=!1,d=!1,g=null,b=null,bw=null,wq=0,m=A1(()=>{try{u.cancel().catch(A4)}catch{}},15e3);const k=()=>{w||(w=!0,D(u))},A=t=>{if(!d){d=!0,m&&(A2(m),m=0);try{g?.abort(t)}catch{}try{b?.abort(t)}catch{}try{bw?.stop()}catch{}if(!w)u.cancel(t).catch(A4);k();if(R(f),!p){p=!0;try{y.abort(t).catch(A4)}catch{}D(y)}}};return(async()=>{let s=new A0(0),l=null,zs="",zq=null,zw=0;for(;!l;){const t=z(s);if(t.session){l=t.session,m&&(A2(m),m=0);break}if(t.error||s.byteLength>=c)throw 0;const e=c-s.byteLength,n=Math.min(0===s.byteLength?o:h,e);if(n<=0)throw 0;const{done:r,value:i}=await st(a,n);if(r)throw 0;i.byteLength&&(s=s.byteLength?H(s,i):new A0(i))}if(l.responsePrefix.byteLength&&y.write(l.responsePrefix).catch(A),l.udpDns){if(53!==l.port)throw 0;const t=((t,e)=>{let n=L,r=Promise.resolve(),s=!1;return{write:i=>(r=r.then(()=>(async e=>{if(s||!e?.byteLength)return;const r=W(e);n=n.byteLength?H(n,r):r;let i=0;for(;n.byteLength-i>=2;){const e=i+2+(n[i]<<8|n[i+1]);if(n.byteLength<e)break;await rt(n.slice(i,e),t),i=e}n=i<n.byteLength?n.slice(i):L})(i)),r.catch(e),r),async finish(){if(await r,s=!0,n.byteLength)throw 0}}})(y,A);for(l.payload.byteLength&&await t.write(l.payload);;){const{done:e,value:n}=await st(a,r);if(e)break;n.byteLength&&await t.write(n)}if(await t.finish(),k(),!p){p=!0;try{await y.close()}finally{D(y)}}return void(d=!0)}if("1"!==n&&isIP(l.host)&&!(zs=sni(l.payload))&&(!l.payload.byteLength||22===l.payload[0])){try{l.payload.byteLength||(f=await V(l.host,l.port))}catch{wq=1}if(!f){const zr=st(a,o);let zt;const zg=await Promise.race([zr,new Promise(e=>zt=A1(()=>e(null),200))]);A2(zt),zg?(zg.done||(l.payload=l.payload.byteLength?H(l.payload,zg.value):zg.value),zs=sni(l.payload)):(zq=zr,zw=1)}}if(!f&&(f=await tt(l.host,l.port,()=>e(l.host,zs),wq?"1":n),!f))throw 0;if(d)return R(f);p||(p=!0,D(y)),g=new AbortController,b=new AbortController;f.readable.pipeTo(i.writable,{signal:b.signal}).catch(A);const wr=f.writable.getWriter();bw=Z(wr,()=>A(0)),l.payload.byteLength&&(bw(l.payload),bw.flush()),zw&&(zq=await zq),zq&&zq.byteLength&&(bw(zq),bw.flush()),k(),t.body.pipeTo(new WritableStream({write:t=>bw(t),close:()=>bw.flush().then(()=>wr.close())}),{signal:g.signal}).catch(t=>{d||A(t)})})().catch(A),new Response(i.readable,{status:200,headers:l})}
export default{async fetch(t){try{const n="websocket"===(t.headers.get("Upgrade")||"").toLowerCase(),r=(t.headers.get("content-type")||"").split(";",1)[0].trim().toLowerCase(),s="POST"===t.method&&(r.startsWith("application/grpc")||"application/octet-stream"===r);if(!n&&!s)return new Response(null,{status:204});const i=new URL(t.url),a=t.headers.get("global")||/(?:[?&]|%3F)global=([^&/]*)/i.exec(i.pathname+i.search)?.[1],c=(q,zz)=>{const n=function(t){let e=t.pathname+(t.search||"");const n=f.get(e);if(n)return n;let r=e;r.startsWith("/")&&(r=r.slice(1));try{r=decodeURIComponent(r)}catch{}const s=r.indexOf("?"),i=s<0?r:r.slice(0,s),a=s<0?"":r.slice(s+1).split("/")[0],c=i.indexOf("=");let o;if(c<=0)o={proxy:null,embeddedQuery:a};else{const t=i.slice(c+1).trim(),e=t.match(/^(https:\/\/[^/?#]+(?:\/[^?#]*)?)/i);o={proxy:t?e?e[1]:t.indexOf("/")>=0?t.slice(0,t.indexOf("/")).trim():t:null,embeddedQuery:a}}return w[m]&&f.delete(w[m]),w[m]=e,f.set(e,o),m=(m+1)%20,o}(i),r=new URLSearchParams(n.embeddedQuery),s=(i.searchParams.get("auto")||r.get("auto"))?.split("/")[0],k=(t.cf?.colo||"").toLowerCase(),c=n.proxy,h=`${k}.proxy.zjcloud.us.ci`;return"1"===a||"0"===s||isAI(q)||isAI(zz)?c||h:h};return n?await it(t,c,a):await at(t,c,a)}catch{return new Response(null,{status:500})}}};