[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_324":325,"_326":327},"routes/_app.x.$handle.$name",{"_93":92,"_31":43,"_101":83,"_26":95,"_13":14,"_102":-5,"_11":103,"_104":105,"_106":107,"_108":109,"_110":111,"_20":-5,"_112":-5,"_113":-5,"_114":24,"_115":116,"_117":118,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",44,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":20,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","src/utils/http.ts","latestPath","fileId","af709168-7ba9-11f1-8bde-1607ee4eb77e","name","http.ts","fileType","content","import {\n MANAGE_TOKEN,\n PUBLIC_BASE_URL,\n SUBSCRIPTION_TOKEN,\n} from \"../config.ts\";\n\nexport function createTextResponse(\n body: string,\n contentType: string,\n status = 200,\n extraHeaders: HeadersInit = {},\n): Response {\n return new Response(body, {\n status,\n headers: {\n \"content-type\": `${contentType}; charset=utf-8`,\n \"cache-control\": \"no-store\",\n ...extraHeaders,\n },\n });\n}\n\nexport function createJsonResponse(payload: unknown, status = 200): Response {\n return new Response(JSON.stringify(payload, null, 2), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n\nexport function redirect(\n location: string,\n extraHeaders: HeadersInit = {},\n): Response {\n return new Response(null, {\n status: 303,\n headers: {\n location,\n ...extraHeaders,\n },\n });\n}\n\nexport function getBaseUrl(request: Request): string {\n if (PUBLIC_BASE_URL.length > 0) {\n return PUBLIC_BASE_URL.replace(/\\/+$/, \"\");\n }\n\n return new URL(request.url).origin;\n}\n\nexport function appendToken(url: string): string {\n if (!SUBSCRIPTION_TOKEN) {\n return url;\n }\n\n const target = new URL(url);\n target.searchParams.set(\"token\", SUBSCRIPTION_TOKEN);\n return target.toString();\n}\n\nexport function buildAbsoluteUrl(request: Request, pathname: string): string {\n return appendToken(`${getBaseUrl(request)}${pathname}`);\n}\n\nexport function isAuthorized(request: Request): boolean {\n if (!SUBSCRIPTION_TOKEN) {\n return true;\n }\n\n const url = new URL(request.url);\n return url.searchParams.get(\"token\") === SUBSCRIPTION_TOKEN;\n}\n\nfunction getCookieValue(request: Request, name: string): string {\n const cookie = request.headers.get(\"cookie\") ?? \"\";\n const prefix = `${name}=`;\n\n for (const part of cookie.split(\";\")) {\n const trimmed = part.trim();\n if (trimmed.startsWith(prefix)) {\n return decodeURIComponent(trimmed.slice(prefix.length));\n }\n }\n\n return \"\";\n}\n\nfunction getBearerToken(request: Request): string {\n const authorization = request.headers.get(\"authorization\") ?? \"\";\n const match = authorization.match(/^Bearer\\s+(.+)$/i);\n return match?.[1]?.trim() ?? \"\";\n}\n\nfunction isLoopbackRequest(request: Request): boolean {\n const hostname = new URL(request.url).hostname;\n return hostname === \"localhost\" || hostname === \"127.0.0.1\" ||\n hostname === \"::1\";\n}\n\nexport function isManageAuthorized(request: Request): boolean {\n if (!MANAGE_TOKEN) {\n return isLoopbackRequest(request);\n }\n\n const url = new URL(request.url);\n const token = url.searchParams.get(\"manage_token\") ??\n getBearerToken(request) ??\n getCookieValue(request, \"manage_token\");\n\n return token === MANAGE_TOKEN;\n}\n\nexport function createManageAuthHeaders(request: Request): HeadersInit {\n if (!MANAGE_TOKEN) {\n return {};\n }\n\n const url = new URL(request.url);\n if (url.searchParams.get(\"manage_token\") !== MANAGE_TOKEN) {\n return {};\n }\n\n const secure = url.protocol === \"https:\" ? \"; Secure\" : \"\";\n return {\n \"set-cookie\": `manage_token=${\n encodeURIComponent(MANAGE_TOKEN)\n }; HttpOnly; SameSite=Lax; Path=/; Max-Age=2592000${secure}`,\n };\n}\n\nexport function buildContentDisposition(\n filename: string,\n asciiFallback = \"hao-han-network\",\n): string {\n const safeAsciiFallback = asciiFallback\n .replace(/[^\\x20-\\x7E]/g, \"\")\n .replace(/\\s+/g, \"-\")\n .replace(/-+/g, \"-\")\n .replace(/^-|-$/g, \"\") || \"subscription\";\n\n return `inline; filename=\"${safeAsciiFallback}\"; filename*=UTF-8''${\n encodeURIComponent(filename)\n }`;\n}","createdAt",["D",1783610414553],"branchVersion","branchId","a4b542d4-750c-42cb-a4ed-a221886db756","id","4f64cf47-aa7b-4711-8d73-72a0b08eb3fc","iproyal-shadowrocket-subscription",["D",1783608476295],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Shadowrocket subscription","imageUrl","e4cca24b-e9a4-4880-b34b-3295e2d93b2a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f4607-5ed7-720b-a4e0-c166d698923a","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_93":92,"_100":95},"org",{"_93":92,"_94":95,"_96":95,"_18":53,"_97":98,"_99":24},"branch",{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"isOwned",54,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tiga2fa","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_41":42,"_31":43,"_36":320,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":321,"_77":322,"_79":323,"_81":24},"tree",[171,188,189,190],"files",[171,172,173,174,175,176,177,178,179,180,181,182,183,184,185,186,187,188,189,190],"counts",{"_159":59,"_160":161,"_162":59,"_163":164,"_165":166},"contents",[123,124,125,126],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_41":152,"_31":153,"_29":154,"_130":-5,"_39":40,"_38":155,"_132":118,"_36":156,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_26":158},{"_41":145,"_31":146,"_29":147,"_130":-5,"_39":40,"_38":148,"_132":24,"_36":149,"_13":59,"_33":20,"_34":150,"_23":24,"_136":-5,"_26":151},{"_41":138,"_31":139,"_29":140,"_130":-5,"_39":40,"_38":141,"_132":24,"_36":142,"_13":59,"_33":20,"_34":143,"_23":24,"_136":-5,"_26":144},{"_41":127,"_31":128,"_29":129,"_130":-5,"_39":40,"_38":131,"_132":24,"_36":133,"_13":59,"_33":134,"_34":135,"_23":24,"_136":-5,"_26":137},"46be79e4-6f10-4ce0-b11f-106b732bf6f6","valtown.ts","c31fc860-7ba8-11f1-b1b6-1607ee4eb77e","parentId",25,"latest",["D",1783610018343],"http","export default function handler() { return Response.json({ ok: true }); }","label",[128],"613263e3-e4ee-4033-9ce6-eb8bbeca304a","comment-test.ts","8cb3e3b4-7ba9-11f1-a7a2-1607ee4eb77e",36,["D",1783610356537],"// ???? ??`nexport type X = string;",[139],"44ea53fc-8e19-4f73-becb-7997b78cfb1c","comment-proxy-test.ts","8ca30102-7ba9-11f1-be17-1607ee4eb77e",35,["D",1783610356429],"// ProxyProtocol ??????????????`n// ?? TypeScript ???????????,??? socks5 ?? sock5?`nexport type ProxyProtocol = \"socks5\" | \"http\";",[146],"d01fc7c7-bea9-4423-822b-4c3fba7fcb39","src","4706f536-7ba9-11f1-9ae4-1607ee4eb77e",26,["D",1783610239481],"directory",[153],"pulls","branches",1,"forks","envVars",{"_167":169,"_170":59},"connections",{"_167":59,"_168":59},"count","unfilledCount",3,"emptyCount",{"_41":152,"_31":153,"_29":154,"_130":-5,"_39":40,"_38":155,"_132":118,"_36":317,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":318,"_26":319},{"_41":312,"_31":311,"_29":305,"_130":154,"_39":40,"_38":313,"_132":118,"_36":314,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":315,"_26":316},{"_41":302,"_31":303,"_29":304,"_130":305,"_39":40,"_38":306,"_132":118,"_36":307,"_13":59,"_33":20,"_34":308,"_23":24,"_136":-5,"_192":309,"_26":310},{"_41":297,"_31":288,"_29":282,"_130":154,"_39":40,"_38":298,"_132":118,"_36":299,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":300,"_26":301},{"_41":289,"_31":290,"_29":291,"_130":282,"_39":40,"_38":292,"_132":24,"_36":293,"_13":59,"_33":20,"_34":294,"_23":24,"_136":-5,"_192":295,"_26":296},{"_41":279,"_31":280,"_29":281,"_130":282,"_39":40,"_38":283,"_132":118,"_36":284,"_13":59,"_33":20,"_34":285,"_23":24,"_136":-5,"_192":286,"_26":287},{"_41":274,"_31":273,"_29":267,"_130":154,"_39":40,"_38":275,"_132":118,"_36":276,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":277,"_26":278},{"_41":264,"_31":265,"_29":266,"_130":267,"_39":40,"_38":268,"_132":118,"_36":269,"_13":59,"_33":20,"_34":270,"_23":24,"_136":-5,"_192":271,"_26":272},{"_41":259,"_31":250,"_29":244,"_130":154,"_39":40,"_38":260,"_132":118,"_36":261,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":262,"_26":263},{"_41":251,"_31":252,"_29":253,"_130":244,"_39":40,"_38":254,"_132":118,"_36":255,"_13":59,"_33":20,"_34":256,"_23":24,"_136":-5,"_192":257,"_26":258},{"_41":241,"_31":242,"_29":243,"_130":244,"_39":40,"_38":245,"_132":118,"_36":246,"_13":59,"_33":20,"_34":247,"_23":24,"_136":-5,"_192":248,"_26":249},{"_41":234,"_31":235,"_29":236,"_130":154,"_39":40,"_38":237,"_132":118,"_36":238,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":239,"_26":240},{"_41":229,"_31":228,"_29":222,"_130":154,"_39":40,"_38":230,"_132":118,"_36":231,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":232,"_26":233},{"_41":219,"_31":220,"_29":221,"_130":222,"_39":40,"_38":223,"_132":118,"_36":224,"_13":59,"_33":20,"_34":225,"_23":24,"_136":-5,"_192":226,"_26":227},{"_41":214,"_31":213,"_29":209,"_130":154,"_39":40,"_38":215,"_132":118,"_36":216,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":217,"_26":218},{"_41":208,"_31":32,"_29":30,"_130":209,"_39":40,"_38":14,"_132":118,"_36":210,"_13":59,"_33":20,"_34":35,"_23":24,"_136":-5,"_192":211,"_26":212},{"_41":201,"_31":202,"_29":203,"_130":154,"_39":40,"_38":204,"_132":118,"_36":205,"_13":59,"_33":157,"_34":-5,"_23":24,"_136":-5,"_192":206,"_26":207},{"_41":145,"_31":146,"_29":147,"_130":-5,"_39":40,"_38":148,"_132":24,"_36":198,"_13":59,"_33":20,"_34":150,"_23":24,"_136":-5,"_192":199,"_26":200},{"_41":138,"_31":139,"_29":140,"_130":-5,"_39":40,"_38":141,"_132":24,"_36":195,"_13":59,"_33":20,"_34":143,"_23":24,"_136":-5,"_192":196,"_26":197},{"_41":127,"_31":128,"_29":129,"_130":-5,"_39":40,"_38":131,"_132":24,"_36":191,"_13":59,"_33":134,"_34":135,"_23":24,"_136":-5,"_192":193,"_26":194},["D",1783610018343],"children",[],[128],["D",1783610356537],[],[139],["D",1783610356429],[],[146],"adee798d-d23b-4392-b169-6309e9e75d02","views","4a8396ba-7ba9-11f1-a314-1607ee4eb77e",33,["D",1783610245229],[],[153,202],"e5b7b3bb-4756-49f2-b231-41e5169f41c8","49aa52d8-7ba9-11f1-b861-1607ee4eb77e",["D",1783610414553],[],[153,213,32],"utils","316ef761-84a9-4441-a554-9bd27f0c3662",32,["D",1783610244063],[186],[153,213],"6e1fdcf0-8e02-4b27-b835-25ff044abad6","subscription_service.ts","ae399ed4-7ba9-11f1-8e84-1607ee4eb77e","49535a32-7ba9-11f1-b83a-1607ee4eb77e",43,["D",1783610412771],"import { PROFILE_UPDATE_INTERVAL_SECONDS, SERVICE_NAME } from \"../config.ts\";\nimport type {\n BulkImportFormat,\n BulkImportFormInput,\n NewProxyNodeInput,\n ProxyNode,\n ProxyProtocol,\n StaticIpFormInput,\n} from \"../domain/proxy_node.ts\";\n\nfunction toYamlString(value: string): string {\n return JSON.stringify(value);\n}\n\nfunction encodeUriPart(value: string): string {\n return encodeURIComponent(value);\n}\n\nfunction buildProxyUri(\n node: Pick<\n ProxyNode,\n \"protocol\" | \"username\" | \"password\" | \"server\" | \"port\" | \"name\"\n >,\n): string {\n const username = encodeUriPart(node.username);\n const password = encodeUriPart(node.password);\n const name = encodeUriPart(node.name);\n\n return `${node.protocol}://${username}:${password}@${node.server}:${node.port}#${name}`;\n}\n\nexport function buildPlainSubscription(nodes: ProxyNode[]): string {\n return nodes.map((node) => buildProxyUri(node)).join(\"\\n\");\n}\n\nexport function buildBase64Subscription(nodes: ProxyNode[]): string {\n return btoa(buildPlainSubscription(nodes));\n}\n\nexport function buildUniversalSubscription(nodes: ProxyNode[]): string {\n return buildBase64Subscription(nodes);\n}\n\nexport function buildClashSubscription(nodes: ProxyNode[]): string {\n const proxyNames = nodes.map((node) => node.name);\n const lines: string[] = [\n \"mixed-port: 7890\",\n \"allow-lan: false\",\n `mode: ${toYamlString(\"rule\")}`,\n `log-level: ${toYamlString(\"info\")}`,\n \"ipv6: false\",\n \"proxies:\",\n ];\n\n for (const node of nodes) {\n lines.push(` - name: ${toYamlString(node.name)}`);\n lines.push(` type: ${toYamlString(node.protocol)}`);\n lines.push(` server: ${toYamlString(node.server)}`);\n lines.push(` port: ${node.port}`);\n lines.push(` username: ${toYamlString(node.username)}`);\n lines.push(` password: ${toYamlString(node.password)}`);\n\n if (node.protocol === \"socks5\") {\n lines.push(\" udp: false\");\n } else {\n lines.push(\" tls: false\");\n }\n }\n\n lines.push(\"proxy-groups:\");\n lines.push(` - name: ${toYamlString(\"PROXY\")}`);\n lines.push(` type: ${toYamlString(\"select\")}`);\n lines.push(\" proxies:\");\n\n for (const name of proxyNames) {\n lines.push(` - ${toYamlString(name)}`);\n }\n\n lines.push(\"rules:\");\n lines.push(` - ${toYamlString(\"MATCH,PROXY\")}`);\n\n return `${lines.join(\"\\n\")}\\n`;\n}\n\nexport function buildSurgeSubscription(\n managedProfileUrl: string,\n nodes: ProxyNode[],\n): string {\n const proxyNames = nodes.map((node) => node.name);\n const lines: string[] = [\n `#!MANAGED-CONFIG ${managedProfileUrl} interval=${PROFILE_UPDATE_INTERVAL_SECONDS} strict=false`,\n \"\",\n \"[General]\",\n \"loglevel = notify\",\n \"bypass-system = true\",\n \"skip-proxy = 127.0.0.1, localhost, *.local\",\n \"ipv6 = false\",\n \"\",\n \"[Proxy]\",\n ];\n\n for (const node of nodes) {\n lines.push(\n `${node.name} = ${node.protocol}, ${node.server}, ${node.port}, ${node.username}, ${node.password}`,\n );\n }\n\n lines.push(\"\");\n lines.push(\"[Proxy Group]\");\n lines.push(`PROXY = select, ${proxyNames.join(\", \")}`);\n lines.push(\"\");\n lines.push(\"[Rule]\");\n lines.push(\"FINAL,PROXY\");\n\n return `${lines.join(\"\\n\")}\\n`;\n}\n\nexport function buildQuantumultXRemoteResource(universalUrl: string): string {\n return JSON.stringify({\n server_remote: [\n `${universalUrl}, tag=${SERVICE_NAME}`,\n ],\n });\n}\n\nexport function buildNodesFromStaticIpForm(\n input: StaticIpFormInput,\n): NewProxyNodeInput[] {\n const baseLabel = input.label.trim() || input.server.trim();\n const nodes: NewProxyNodeInput[] = [];\n\n if (input.createSocks5) {\n nodes.push({\n name: `${baseLabel}-SOCKS5`,\n protocol: \"socks5\",\n server: input.server.trim(),\n port: input.socks5Port,\n username: input.username.trim(),\n password: input.password.trim(),\n enabled: true,\n });\n }\n\n if (input.createHttp) {\n nodes.push({\n name: `${baseLabel}-HTTP`,\n protocol: \"http\",\n server: input.server.trim(),\n port: input.httpPort,\n username: input.username.trim(),\n password: input.password.trim(),\n enabled: true,\n });\n }\n\n return nodes;\n}\n\nexport function parseStaticIpForm(formData: FormData): StaticIpFormInput {\n const label = String(formData.get(\"label\") ?? \"\");\n const server = String(formData.get(\"server\") ?? \"\").trim();\n const username = String(formData.get(\"username\") ?? \"\").trim();\n const password = String(formData.get(\"password\") ?? \"\").trim();\n const socks5Port = Number(formData.get(\"socks5Port\") ?? \"12324\");\n const httpPort = Number(formData.get(\"httpPort\") ?? \"12323\");\n const createSocks5 = formData.get(\"createSocks5\") === \"on\";\n const createHttp = formData.get(\"createHttp\") === \"on\";\n\n if (!server || !username || !password) {\n throw new Error(\"????? IP????????\");\n }\n\n if (!createSocks5 && !createHttp) {\n throw new Error(\"??????????\");\n }\n\n if (!Number.isInteger(socks5Port) || socks5Port <= 0) {\n throw new Error(\"SOCKS5 ??????\");\n }\n\n if (!Number.isInteger(httpPort) || httpPort <= 0) {\n throw new Error(\"HTTP ??????\");\n }\n\n return {\n label,\n server,\n username,\n password,\n socks5Port,\n httpPort,\n createSocks5,\n createHttp,\n };\n}\n\nexport function parseBulkImportForm(formData: FormData): BulkImportFormInput {\n const protocol = String(formData.get(\"protocol\") ?? \"\").trim();\n const format = String(formData.get(\"format\") ?? \"\").trim();\n const labelPrefix = String(formData.get(\"labelPrefix\") ?? \"\").trim();\n const rawText = String(formData.get(\"rawText\") ?? \"\");\n\n if (!isProxyProtocol(protocol)) {\n throw new Error(\"?????,??????\");\n }\n\n if (!isBulkImportFormat(format)) {\n throw new Error(\"????????\");\n }\n\n if (!rawText.trim()) {\n throw new Error(\"?????? IP ???\");\n }\n\n return {\n protocol,\n format,\n labelPrefix,\n rawText,\n };\n}\n\nexport function buildNodesFromBulkImport(\n input: BulkImportFormInput,\n): NewProxyNodeInput[] {\n const lines = input.rawText\n .split(/\\r?\\n/)\n .map((line) => line.trim())\n .filter(Boolean);\n\n if (lines.length === 0) {\n throw new Error(\"?????? IP ???\");\n }\n\n return lines.map((line, index) => parseBulkImportLine(line, index, input));\n}\n\nfunction parseBulkImportLine(\n line: string,\n index: number,\n input: BulkImportFormInput,\n): NewProxyNodeInput {\n switch (input.format) {\n case \"host_port_user_pass\":\n return parseHostPortUserPassLine(line, index, input);\n }\n}\n\nfunction parseHostPortUserPassLine(\n line: string,\n index: number,\n input: BulkImportFormInput,\n): NewProxyNodeInput {\n const parts = line.split(\":\");\n\n if (parts.length !== 4) {\n throw new Error(\n `? ${index + 1} ??????,?? HOST:PORT:USER:PASS?`,\n );\n }\n\n const [serverRaw, portRaw, usernameRaw, passwordRaw] = parts;\n const server = serverRaw.trim();\n const username = usernameRaw.trim();\n const password = passwordRaw.trim();\n const port = Number(portRaw.trim());\n\n if (!server || !username || !password) {\n throw new Error(`? ${index + 1} ??? IP????????`);\n }\n\n if (!Number.isInteger(port) || port <= 0) {\n throw new Error(`? ${index + 1} ???????`);\n }\n\n const prefix = input.labelPrefix.trim();\n const protocolLabel = input.protocol.toUpperCase();\n const name = prefix\n ? `${prefix}-${protocolLabel}-${server}`\n : `${protocolLabel}-${server}`;\n\n return {\n name,\n protocol: input.protocol,\n server,\n port,\n username,\n password,\n enabled: true,\n };\n}\n\nfunction isProxyProtocol(value: string): value is ProxyProtocol {\n return value === \"socks5\" || value === \"http\";\n}\n\nfunction isBulkImportFormat(value: string): value is BulkImportFormat {\n return value === \"host_port_user_pass\";\n}\n\nexport function buildQuickImportLinks({\n clashUrl,\n surgeUrl,\n universalUrl,\n base64Url,\n}: {\n clashUrl: string;\n surgeUrl: string;\n universalUrl: string;\n base64Url: string;\n}) {\n return {\n clashUrl,\n surgeUrl,\n universalUrl,\n base64Url,\n clashSchemeUrl: `clash://install-config?url=${\n encodeURIComponent(clashUrl)\n }`,\n surgeSchemeUrl: `surge:///install-config?url=${\n encodeURIComponent(surgeUrl)\n }`,\n surfboardSchemeUrl: `surfboard:///install-config?url=${\n encodeURIComponent(surgeUrl)\n }`,\n shadowrocketSchemeUrl: `shadowrocket://add/${\n encodeURIComponent(base64Url)\n }`,\n quantumultXSchemeUrl:\n `https://quantumult.app/x/open-app/add-resource?remote-resource=${\n encodeURIComponent(buildQuantumultXRemoteResource(universalUrl))\n }`,\n };\n}\n\nexport function sortNodesByDisplayOrder(nodes: ProxyNode[]): ProxyNode[] {\n return [...nodes].sort((a, b) =>\n a.createdAt.getTime() - b.createdAt.getTime()\n );\n}",[],[153,228,220],"services","8ff390db-6ee2-4456-88c0-bcb1f383faa3",31,["D",1783610243498],[184],[153,228],"eb83a8d1-e6ca-4349-9250-f5522de1c02e","routes","4b1b7a2a-7ba9-11f1-b83a-1607ee4eb77e",34,["D",1783610246487],[],[153,235],"a57e51f6-3377-44e1-9397-d7fc998464d9","proxy_node_repository.ts","acdd63fe-7ba9-11f1-a92c-1607ee4eb77e","4848ce42-7ba9-11f1-855f-1607ee4eb77e",40,["D",1783610410493],"import type { NewProxyNodeInput, ProxyNode } from \"../domain/proxy_node.ts\";\n\nexport interface AddManyNodesResult {\n insertedCount: number;\n skippedCount: number;\n}\n\nexport interface ProxyNodeRepository {\n init(): Promise;\n listAll(): Promise;\n listEnabled(): Promise;\n addMany(nodes: NewProxyNodeInput[]): Promise;\n deleteById(id: number): Promise;\n}",[],[153,250,242],"repositories","7bf5b753-453b-401e-b7a8-133abb1a79fb","postgres_proxy_node_repository.ts","adda57da-7ba9-11f1-b34a-1607ee4eb77e",42,["D",1783610412155],"import type { Sql } from \"postgres\";\n\nimport { DEFAULT_PROXY_NODES } from \"../data/default_nodes.ts\";\nimport type { NewProxyNodeInput, ProxyNode } from \"../domain/proxy_node.ts\";\nimport { ensureSchema } from \"../db/schema.ts\";\nimport type {\n AddManyNodesResult,\n ProxyNodeRepository,\n} from \"./proxy_node_repository.ts\";\n\ninterface ProxyNodeRow {\n id: number;\n name: string;\n protocol: \"socks5\" | \"http\";\n server: string;\n port: number;\n username: string;\n password: string;\n enabled: boolean;\n created_at: string | Date;\n}\n\nexport class PostgresProxyNodeRepository implements ProxyNodeRepository {\n constructor(private readonly sql: Sql) {}\n\n async init(): Promise {\n await ensureSchema(this.sql);\n\n const [{ count }] = await this.sql<{ count: string }[]>`\n select count(*)::text as count from proxy_nodes\n `;\n\n if (Number(count) === 0) {\n await this.addMany(DEFAULT_PROXY_NODES);\n }\n }\n\n async listAll(): Promise {\n const rows = await this.sql`\n select\n id,\n name,\n protocol,\n server,\n port,\n username,\n password,\n enabled,\n created_at\n from proxy_nodes\n order by created_at asc, id asc\n `;\n\n return rows.map(mapRowToProxyNode);\n }\n\n async listEnabled(): Promise {\n const rows = await this.sql`\n select\n id,\n name,\n protocol,\n server,\n port,\n username,\n password,\n enabled,\n created_at\n from proxy_nodes\n where enabled = true\n order by created_at asc, id asc\n `;\n\n return rows.map(mapRowToProxyNode);\n }\n\n async addMany(nodes: NewProxyNodeInput[]): Promise {\n if (nodes.length === 0) {\n return {\n insertedCount: 0,\n skippedCount: 0,\n };\n }\n\n const insertedCount = await this.sql.begin(async (sql) => {\n let count = 0;\n\n for (const node of nodes) {\n const insertedRows = await sql<{ id: number }[]>`\n insert into proxy_nodes (\n name,\n protocol,\n server,\n port,\n username,\n password,\n enabled\n )\n values (\n ${node.name},\n ${node.protocol},\n ${node.server},\n ${node.port},\n ${node.username},\n ${node.password},\n ${node.enabled ?? true}\n )\n on conflict (protocol, server, port, username, password) do nothing\n returning id\n `;\n\n count += insertedRows.length;\n }\n\n return count;\n });\n\n return {\n insertedCount,\n skippedCount: nodes.length - insertedCount,\n };\n }\n\n async deleteById(id: number): Promise {\n await this.sql`delete from proxy_nodes where id = ${id}`;\n }\n}\n\nfunction mapRowToProxyNode(row: ProxyNodeRow): ProxyNode {\n return {\n id: row.id,\n name: row.name,\n protocol: row.protocol,\n server: row.server,\n port: row.port,\n username: row.username,\n password: row.password,\n enabled: row.enabled,\n createdAt: new Date(row.created_at),\n };\n}",[],[153,250,252],"612b0149-ef0c-4a48-ab24-c83865ec78d9",28,["D",1783610241741],[180,181],[153,250],"6c770103-6f8f-4685-b3c1-18b5a5546fbb","proxy_node.ts","96d2d63e-7ba9-11f1-a325-1607ee4eb77e","47df361c-7ba9-11f1-8d2c-1607ee4eb77e",37,["D",1783610373490],"export type ProxyProtocol = \"socks5\" | \"http\";\n\nexport type BulkImportFormat = \"host_port_user_pass\";\n\nexport interface ProxyNode {\n id: number;\n name: string;\n protocol: ProxyProtocol;\n server: string;\n port: number;\n username: string;\n password: string;\n enabled: boolean;\n createdAt: Date;\n}\n\nexport interface NewProxyNodeInput {\n name: string;\n protocol: ProxyProtocol;\n server: string;\n port: number;\n username: string;\n password: string;\n enabled?: boolean;\n}\n\nexport interface StaticIpFormInput {\n label: string;\n server: string;\n username: string;\n password: string;\n socks5Port: number;\n httpPort: number;\n createSocks5: boolean;\n createHttp: boolean;\n}\n\nexport interface BulkImportFormInput {\n protocol: ProxyProtocol;\n format: BulkImportFormat;\n labelPrefix: string;\n rawText: string;\n}",[],[153,273,265],"domain","e89bdf4c-61b3-45e0-b6ad-6a76383db575",27,["D",1783610241050],[178],[153,273],"c062a91f-2110-4252-a2a7-21153c445115","schema.ts","ac862f80-7ba9-11f1-ba86-1607ee4eb77e","48a29bde-7ba9-11f1-b258-1607ee4eb77e",39,["D",1783610409924],"import type { Sql } from \"postgres\";\n\nexport async function ensureSchema(sql: Sql): Promise {\n await sql`\n create table if not exists proxy_nodes (\n id bigserial primary key,\n name text not null,\n protocol text not null check (protocol in ('socks5', 'http')),\n server text not null,\n port integer not null,\n username text not null,\n password text not null,\n enabled boolean not null default true,\n created_at timestamptz not null default now()\n )\n `;\n\n await sql`\n create unique index if not exists proxy_nodes_unique_identity\n on proxy_nodes (protocol, server, port, username, password)\n `;\n}",[],[153,288,280],"db","0245e158-ac6d-49a6-8e01-a851b2bf934f","client.ts","ad74f2a0-7ba9-11f1-ac8a-1607ee4eb77e",41,["D",1783610411490],"import postgres, { type Sql } from \"npm:postgres@^3.4.9\";\n\nimport { DATABASE_URL } from \"../config.ts\";\n\nexport function createSql(): Sql {\n if (!DATABASE_URL) {\n throw new Error(\"DATABASE_URL is required.\");\n }\n\n return postgres(DATABASE_URL, {\n prepare: false,\n max: 5,\n idle_timeout: 10,\n });\n}",[],[153,288,290],"6abdb3f4-6b21-4b38-bf84-5c3cd86da97d",29,["D",1783610242335],[175,176],[153,288],"09c42410-862c-4a7e-b89f-97e80cf24e2a","default_nodes.ts","abd89302-7ba9-11f1-9ad4-1607ee4eb77e","48f992b8-7ba9-11f1-9f11-1607ee4eb77e",38,["D",1783610408788],"import type { NewProxyNodeInput } from \"../domain/proxy_node.ts\";\n\nexport const DEFAULT_PROXY_NODES: NewProxyNodeInput[] = [];",[],[153,311,303],"data","eccada17-c447-447e-b3fd-e689650b2e0e",30,["D",1783610242906],[173],[153,311],["D",1783610239481],[172,174,177,179,182,183,185,187],[153],["D",1783608476295],{"_93":92,"_100":95},{"_93":92,"_94":95,"_96":95,"_18":53,"_97":98,"_99":24},{"_13":82,"_31":83,"_41":40,"_84":42,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":43,"_91":92},"ctx",{"_75":-5,"_120":357,"_358":359,"_360":361,"_362":24,"_363":24,"_364":24,"_365":118,"_366":-5,"_367":-7,"_368":-7,"_369":59,"_370":24,"_371":24,"_372":-5,"_373":24,"_374":24,"_375":24,"_376":-5},"ENV",{"_328":329,"_330":331,"_332":83,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348,"_349":350,"_351":352,"_353":354,"_355":356},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v44