[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_173":174,"_175":176},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_108":90,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":25,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",38,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","fe5ab508-417d-11f1-8714-42b51c65c3df","name","fileType","interval","content","// Val Town：ikuuu 全自动签到（2Captcha + Cookie优先）\n// 设计目标：单次运行不超时、失败可自愈、打码次数最少\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst env = (k: string) => Deno.env.get(k) || \"\";\nconst num = (k: string, d: number) => {\n const v = parseFloat(env(k));\n return Number.isFinite(v) ? v : d;\n};\nconst bool = (k: string, d = false) => {\n const v = env(k);\n return v === \"\" ? d : /^(1|true|yes|on)$/i.test(v);\n};\n\nconst BASE = (env(\"IKUUU_BASE_URL\") || \"https://ikuuu.org\").replace(/\\/$/, \"\");\nconst CAPTCHA_ID = env(\"IKUUU_CAPTCHA_ID\") ||\n \"cc96d05ba8b60f9112f76e18526fcb73\";\nconst SOLVER_ENDPOINT = (env(\"SOLVER_ENDPOINT\") || \"https://api.2captcha.com\")\n .replace(/\\/$/, \"\");\nconst SOLVER_KEY = env(\"TWOCAPTCHA_KEY\");\nconst TG_TOKEN = env(\"TELEGRAM_TOKEN\");\nconst TG_CHAT = env(\"TELEGRAM_CHAT_ID\");\n\nconst BUDGET_MS = num(\"BUDGET_SEC\", 52) * 1000; // 总时间预算，须小于 Val Town 运行上限\nconst RESERVE_MS = 4000; // 预留给汇总与 Telegram 推送\nconst HTTP_TIMEOUT = num(\"HTTP_TIMEOUT_SEC\", 12) * 1000;\nconst CONCURRENCY = Math.max(1, num(\"CONCURRENCY\", 4));\nconst JITTER_MAX_SEC = num(\"JITTER_MAX_SEC\", 5);\nconst LOGIN_RETRIES = Math.max(0, num(\"LOGIN_RETRIES\", 1)); // 验证码被拒时的额外登录次数\nconst CRED_PAUSE_AFTER = Math.max(2, num(\"CRED_PAUSE_AFTER\", 3)); // 凭据连错几次后停止打码\nconst FAIL_STREAK_ALERT = Math.max(1, num(\"FAIL_STREAK_ALERT\", 2));\nconst BALANCE_ALERT = num(\"BALANCE_ALERT\", 1);\nconst TZ_OFFSET = num(\"TZ_OFFSET\", 8);\nconst ALWAYS_REPORT = bool(\"ALWAYS_REPORT\");\nconst FETCH_INFO = bool(\"FETCH_INFO\", ALWAYS_REPORT); // 抓流量/到期需额外一次请求\nconst FORCE = bool(\"FORCE\"); // 忽略“今日已签”缓存\nconst RESET_STATE = bool(\"RESET_STATE\"); // 清空失败计数与凭据暂停\nconst UA =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/151.0.0.0 Safari/537.36 Edg/151.0.0.0\";\n\nclass CookieExpired extends Error {}\nclass CaptchaRejected extends Error {}\nclass BadCredential extends Error {}\nclass CredentialPaused extends BadCredential {} // 熔断生效，本次未真正尝试登录\nclass LoginFlowChanged extends BadCredential {} // 站点登录接口已变更，重试与再次打码都不会成功\nclass OutOfBudget extends Error {}\n\nconst START = Date.now();\nconst left = () => BUDGET_MS - (Date.now() - START);\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst secs = (t: number) => ((Date.now() - t) / 1000).toFixed(1) + \"s\";\nconst today = () =>\n new Date(Date.now() + TZ_OFFSET * 3600_000).toISOString().slice(0, 10);\nfunction needBudget(ms: number) {\n if (left() - RESERVE_MS < ms) {\n throw new OutOfBudget(\n `时间预算不足（剩余 ${(left() / 1000).toFixed(1)}s）`,\n );\n }\n}\n\nlet solvesUsed = 0;\nlet maxSolves = Infinity;\nconst pendingReports: Promise[] = [];\n\nasync function fx(\n url: string,\n opts: RequestInit = {},\n ms = HTTP_TIMEOUT,\n): Promise {\n needBudget(1000);\n const cap = Math.max(1000, Math.min(ms, left() - RESERVE_MS));\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), cap);\n try {\n return await fetch(url, { ...opts, signal: ctrl.signal });\n } catch (e) {\n if (ctrl.signal.aborted) {\n throw new Error(\n `请求超时 ${(cap / 1000).toFixed(0)}s: ${new URL(url).pathname}`,\n );\n }\n throw e;\n } finally {\n clearTimeout(t);\n }\n}\n\n// 仅重试网络/服务端抖动，语义明确的错误直接抛出，避免浪费预算与打码额度\nasync function retry(\n fn: () => Promise,\n tries = 2,\n gap = 1200,\n): Promise {\n let last: unknown;\n for (let i = 0; i < tries; i++) {\n try {\n return await fn();\n } catch (e) {\n if (\n e instanceof CookieExpired || e instanceof BadCredential ||\n e instanceof OutOfBudget\n ) throw e;\n last = e;\n if (i < tries - 1) {\n needBudget(gap + 2000);\n await sleep(gap);\n }\n }\n }\n throw last;\n}\n\nasync function solverPost(path: string, body: unknown): Promise {\n const res = await fx(`${SOLVER_ENDPOINT}${path}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ clientKey: SOLVER_KEY, ...(body as object) }),\n }, 15000);\n const text = await res.text();\n try {\n return JSON.parse(text);\n } catch {\n throw new Error(\n `打码接口非 JSON 响应(HTTP ${res.status}): ${text.slice(0, 80)}`,\n );\n }\n}\n\nfunction accounts() {\n return env(\"IKUUU_ACCOUNTS\")\n .split(/\\|\\||\\n/).map((l) => l.trim()).filter((l) =>\n l && !l.startsWith(\"#\")\n )\n .map((l) => {\n const i = l.indexOf(\":\");\n return { email: l.slice(0, i).trim(), pwd: l.slice(i + 1).trim() };\n })\n .filter((a) => a.email && a.pwd);\n}\n\n// ---- 状态存储：整批读、整批写，避免每账号多次往返 ----\ntype State = {\n cookie: string;\n streak: number;\n credFail: number;\n lastSigned: string;\n lastStatus: string;\n lastError: string;\n};\nconst BLANK: State = {\n cookie: \"\",\n streak: 0,\n credFail: 0,\n lastSigned: \"\",\n lastStatus: \"\",\n lastError: \"\",\n};\n\nasync function loadState(): Promise> {\n const ddl = [\n `CREATE TABLE IF NOT EXISTS ikuuu_cookies (email TEXT PRIMARY KEY, cookie TEXT, updated_at DATETIME DEFAULT CURRENT_TIMESTAMP)`,\n `CREATE TABLE IF NOT EXISTS ikuuu_state (email TEXT PRIMARY KEY, fail_streak INTEGER DEFAULT 0, last_status TEXT, last_signed TEXT, cred_fail INTEGER DEFAULT 0, last_error TEXT, updated_at DATETIME DEFAULT CURRENT_TIMESTAMP)`,\n ];\n try {\n await sqlite.batch(ddl);\n } catch {\n for (const s of ddl) await sqlite.execute(s);\n }\n for (\n const col of [\n `last_signed TEXT`,\n `cred_fail INTEGER DEFAULT 0`,\n `last_error TEXT`,\n ]\n ) {\n try {\n await sqlite.execute(`ALTER TABLE ikuuu_state ADD COLUMN ${col}`);\n } catch { /* 老库补列，已存在则忽略 */ }\n }\n\n const map = new Map();\n const touch = (email: string) => {\n if (!map.has(email)) map.set(email, { ...BLANK });\n return map.get(email)!;\n };\n const [ck, st] = await Promise.all([\n sqlite.execute(`SELECT email, cookie FROM ikuuu_cookies`),\n sqlite.execute(\n `SELECT email, fail_streak, last_status, last_signed, cred_fail, last_error FROM ikuuu_state`,\n ),\n ]);\n for (const r of ck.rows) touch(String(r[0])).cookie = String(r[1] ?? \"\");\n for (const r of st.rows) {\n const s = touch(String(r[0]));\n s.streak = Number(r[1] ?? 0);\n s.lastStatus = String(r[2] ?? \"\");\n s.lastSigned = String(r[3] ?? \"\");\n s.credFail = Number(r[4] ?? 0);\n s.lastError = String(r[5] ?? \"\");\n }\n return map;\n}\n\nasync function saveAll(stmts: { sql: string; args: unknown[] }[]) {\n if (!stmts.length) return;\n try {\n await sqlite.batch(stmts);\n } catch {\n for (const s of stmts) await sqlite.execute(s).catch(() => {});\n }\n}\n\n// ---- 2Captcha ----\nasync function solveCaptcha(\n email: string,\n): Promise<{ taskId: string; solution: any }> {\n if (solvesUsed >= maxSolves) {\n throw new Error(`打码已达本次上限 ${maxSolves} 次，跳过登录以控制成本`);\n }\n needBudget(15000); // 时间不够就别开单，省一次钱\n solvesUsed++;\n const t0 = Date.now();\n const create = await solverPost(\"/createTask\", {\n task: {\n type: \"GeeTestTaskProxyless\",\n websiteURL: `${BASE}/auth/login`,\n version: 4,\n initParameters: { captcha_id: CAPTCHA_ID },\n },\n });\n if (create.errorId) {\n throw new Error(\n `createTask: ${create.errorCode} ${create.errorDescription || \"\"}`,\n );\n }\n\n await sleep(6000);\n for (;;) {\n const res = await solverPost(\"/getTaskResult\", { taskId: create.taskId });\n if (res.status === \"ready\") {\n console.log(`[${email}] 打码完成 ${secs(t0)}`);\n return { taskId: create.taskId, solution: res.solution };\n }\n if (res.errorId) {\n throw new CaptchaRejected(\n `求解失败: ${res.errorCode} ${res.errorDescription || \"\"}`,\n );\n }\n needBudget(3000);\n await sleep(2000);\n }\n}\nfunction reportBad(taskId: string) {\n pendingReports.push(\n solverPost(\"/reportIncorrect\", { taskId }).catch(() => {}),\n );\n}\nasync function getBalance(): Promise {\n if (!SOLVER_KEY) return null;\n try {\n const r = await solverPost(\"/getBalance\", {});\n return typeof r.balance === \"number\" ? r.balance : null;\n } catch {\n return null;\n }\n}\n\n// ---- ikuuu ----\nconst JSON_HEADERS = {\n \"User-Agent\": UA,\n Accept: \"application/json, text/javascript, */*; q=0.01\",\n \"X-Requested-With\": \"XMLHttpRequest\",\n};\n\nfunction cookieMap(header: string): Record {\n const out: Record = {};\n for (const part of header.split(\";\")) {\n const p = part.trim();\n const eq = p.indexOf(\"=\");\n if (eq > 0) out[p.slice(0, eq)] = p.slice(eq + 1);\n }\n return out;\n}\nfunction setCookiePairs(res: Response): string[] {\n return (res.headers.getSetCookie?.() ?? [res.headers.get(\"set-cookie\") ?? \"\"])\n .filter(Boolean);\n}\nfunction mergeCookie(existing: string, setCookies: string[]): string {\n const map = cookieMap(existing);\n for (const sc of setCookies) {\n const first = sc.split(\";\")[0];\n const eq = first.indexOf(\"=\");\n if (eq > 0) map[first.slice(0, eq).trim()] = first.slice(eq + 1).trim();\n }\n return Object.entries(map).map(([k, v]) => `${k}=${v}`).join(\"; \");\n}\nfunction plainMsg(msg: string): string {\n return msg.replace(/<[^>]+>/g, \" \").replace(/\\s+/g, \" \").trim();\n}\n\nasync function beginLoginSession(): Promise<{ cookie: string; pageLoadedAt: string }> {\n const pageLoadedAt = String(Date.now());\n const page = await fx(`${BASE}/auth/login`, {\n headers: {\n \"User-Agent\": UA,\n Accept:\n \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\n },\n redirect: \"follow\",\n });\n const cookie = mergeCookie(\"\", setCookiePairs(page));\n await page.text(); // 读完 body，避免悬挂连接\n if (!/PHPSESSID=/i.test(cookie)) {\n console.warn(\n `GET /auth/login 未拿到 PHPSESSID（仅 ${cookie || \"空 Cookie\"}），登录可能仍会 invalid_phase`,\n );\n }\n return { cookie, pageLoadedAt };\n}\n\nasync function login(acc: { email: string; pwd: string }): Promise {\n const { cookie: session, pageLoadedAt } = await beginLoginSession();\n const { taskId, solution: c } = await solveCaptcha(acc.email);\n const host = new URL(BASE).hostname;\n const form = new URLSearchParams({\n host,\n phase: \"password\",\n email: acc.email,\n passwd: acc.pwd,\n remember_me: \"on\",\n pageLoadedAt,\n \"captcha_result[lot_number]\": String(c.lot_number),\n \"captcha_result[captcha_output]\": String(c.captcha_output),\n \"captcha_result[pass_token]\": String(c.pass_token),\n \"captcha_result[gen_time]\": String(c.gen_time),\n });\n const res = await fx(`${BASE}/auth/login`, {\n method: \"POST\",\n headers: {\n ...JSON_HEADERS,\n Origin: BASE,\n Referer: `${BASE}/auth/login`,\n \"Content-Type\": \"application/x-www-form-urlencoded; charset=UTF-8\",\n ...(session ? { Cookie: session } : {}),\n },\n body: form.toString(),\n redirect: \"manual\",\n });\n const cookie = mergeCookie(session, setCookiePairs(res));\n const text = await res.text();\n let lj: { ret?: number; msg?: string; result?: string; phase?: string };\n try {\n lj = JSON.parse(text);\n } catch {\n throw new Error(\n `登录响应非 JSON(HTTP ${res.status}): ${text.slice(0, 100)}`,\n );\n }\n\n const ok = lj.ret === 1 ||\n lj.result === \"ok\" || lj.result === \"success\" ||\n lj.result === \"logged_in\" || lj.result === \"authenticated\" ||\n lj.phase === \"authenticated\";\n if (!ok) {\n const msg = plainMsg(String(lj.msg ?? \"\"));\n const result = String(lj.result ?? \"\");\n console.error(\n `[${acc.email}] 登录被拒(HTTP ${res.status}) result=${result || \"-\"} phase=${\n lj.phase ?? \"-\"\n } 原文: ${msg || text.slice(0, 200)}`,\n );\n if (result === \"invalid_phase\" || /登录流程无效/.test(msg)) {\n reportBad(taskId);\n throw new LoginFlowChanged(\n `登录会话未建立(invalid_phase)：GET 登录页后 Cookie=${\n session || \"空\"\n }；${msg}`,\n );\n }\n if (\n result === \"user_not_found\" || result === \"wrong_password\" ||\n /邮箱不存在|密码错误|密码不正确|邮箱或密码|账户不存在|帐户不存在|用户不存在|尚未注册|未注册|已封禁|已禁用|账号被封/\n .test(msg)\n ) {\n throw new BadCredential(`凭据/账号异常(${result || \"msg\"}): ${msg}`);\n }\n if (\n /totp|2fa|otp|email_code|verify/i.test(result) ||\n /二步验证|邮箱验证码/.test(msg)\n ) {\n throw new LoginFlowChanged(`登录需要额外验证(${result}): ${msg}`);\n }\n if (/验证|captcha|geetest|刷新页面/i.test(msg) || /captcha/i.test(result)) {\n reportBad(taskId);\n throw new CaptchaRejected(`验证码被拒: ${msg || result}`);\n }\n throw new Error(`登录失败(${result || `HTTP ${res.status}`}): ${msg}`);\n }\n if (!cookie) throw new Error(\"登录成功但未返回 Cookie\");\n console.log(\n `[${acc.email}] 登录成功 Cookie键: ${\n Object.keys(cookieMap(cookie)).join(\",\") || \"无\"\n }`,\n );\n return cookie;\n}\n\nasync function loginWithRetry(\n acc: { email: string; pwd: string },\n): Promise {\n for (let i = 0;; i++) {\n try {\n return await login(acc);\n } catch (e) {\n const canRetry = e instanceof CaptchaRejected && i < LOGIN_RETRIES &&\n solvesUsed < maxSolves && left() - RESERVE_MS > 20000;\n if (!canRetry) throw e;\n console.log(\n `[${acc.email}] 验证码被拒，重试登录 ${i + 1}/${LOGIN_RETRIES}`,\n );\n }\n }\n}\n\nasync function doCheckin(\n cookie: string,\n): Promise<{ signed: boolean; msg: string }> {\n const res = await fx(`${BASE}/user/checkin`, {\n method: \"POST\",\n headers: {\n ...JSON_HEADERS,\n Cookie: cookie,\n Referer: `${BASE}/user`,\n \"Content-Type\": \"application/json\",\n },\n redirect: \"manual\",\n });\n if ([301, 302, 401, 403].includes(res.status)) throw new CookieExpired();\n const text = await res.text();\n // 5xx/429 属服务端抖动，交给 retry 重试，绝不能误判为 Cookie 失效去触发付费登录\n if (res.status >= 500 || res.status === 429) {\n throw new Error(`签到 HTTP ${res.status}`);\n }\n let data: { ret?: number; msg?: string };\n try {\n data = JSON.parse(text);\n } catch {\n if (/auth\\/login|登录|sign\\s*in/i.test(text)) throw new CookieExpired();\n throw new Error(`签到响应异常(HTTP ${res.status}): ${text.slice(0, 80)}`);\n }\n // Cookie 有效即已鉴权：ret===1 为当日新签到，其余（“今日已签到”等）同样视为成功\n return { signed: data.ret === 1, msg: data.msg || \"\" };\n}\n\n// 最佳努力：抓剩余流量/到期（ikuuu 为 SPA，取不到则安静跳过）\nasync function userInfo(cookie: string): Promise {\n try {\n const res = await fx(`${BASE}/user`, {\n headers: { ...JSON_HEADERS, Cookie: cookie },\n redirect: \"manual\",\n }, 8000);\n if (res.status !== 200) return \"\";\n const html = await res.text();\n const rem = html.match(\n /(?:剩余流量|未使用流量|剩余|remain[a-z]*flow)[^0-9]{0,12}([\\d.]+\\s?[KMGT]B)/i,\n );\n const exp = html.match(/(20\\d{2}-\\d{2}-\\d{2})/);\n const parts: string[] = [];\n if (rem) parts.push(`剩余 ${rem[1]}`);\n if (exp) parts.push(`到期 ${exp[1]}`);\n return parts.join(\", \");\n } catch {\n return \"\";\n }\n}\n\ntype Outcome = {\n signed: boolean;\n msg: string;\n info: string;\n cookie?: string;\n cached?: boolean;\n};\n\nasync function runAccount(\n acc: { email: string; pwd: string },\n st: State,\n): Promise {\n // 当天已确认签到过：整条链路零请求零成本，重复运行也安全\n if (!FORCE && st.lastSigned === today()) {\n return {\n signed: false,\n msg: \"今日已签到（本地记录）\",\n info: \"\",\n cached: true,\n };\n }\n\n const t0 = Date.now();\n if (JITTER_MAX_SEC > 0) {\n await sleep(\n Math.random() *\n Math.min(\n JITTER_MAX_SEC * 1000,\n Math.max(0, (left() - RESERVE_MS) * 0.15),\n ),\n );\n }\n\n let cookie = st.cookie;\n let fresh: string | undefined;\n let r: { signed: boolean; msg: string } | null = null;\n\n if (cookie) {\n try {\n r = await retry(() => doCheckin(cookie));\n console.log(`[${acc.email}] 缓存 Cookie 签到 ${secs(t0)}`);\n } catch (e) {\n if (!(e instanceof CookieExpired)) throw e;\n console.log(`[${acc.email}] Cookie 失效，转登录`);\n }\n }\n\n if (!r) {\n // 熔断只看“连续凭据错误”这一专用计数，且带上原始报错，避免掩盖真实原因\n if (st.credFail >= CRED_PAUSE_AFTER) {\n throw new CredentialPaused(\n `凭据连续错误 ${st.credFail} 次已暂停打码（原始报错：${\n st.lastError || \"未记录\"\n }）；确认密码无误后用 RESET_STATE=1 运行一次恢复`,\n );\n }\n fresh = await loginWithRetry(acc);\n cookie = fresh;\n r = await retry(() => doCheckin(cookie));\n console.log(`[${acc.email}] 登录+签到 ${secs(t0)}`);\n }\n\n const info = FETCH_INFO ? await userInfo(cookie) : \"\";\n return { ...r, info, cookie: fresh };\n}\n\nasync function pool(\n items: T[],\n limit: number,\n fn: (t: T, i: number) => Promise,\n) {\n const out: PromiseSettledResult[] = new Array(items.length);\n let next = 0;\n await Promise.all(\n Array.from({ length: Math.min(limit, items.length) }, async () => {\n for (;;) {\n const i = next++;\n if (i >= items.length) return;\n try {\n out[i] = { status: \"fulfilled\", value: await fn(items[i], i) };\n } catch (reason) {\n out[i] = { status: \"rejected\", reason } as PromiseSettledResult;\n }\n }\n }),\n );\n return out;\n}\n\nasync function tg(text: string) {\n if (!TG_TOKEN || !TG_CHAT) return;\n try {\n await fetch(`https://api.telegram.org/bot${TG_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: TG_CHAT, text, parse_mode: \"HTML\" }),\n signal: AbortSignal.timeout(8000),\n });\n } catch { /* 通知失败不影响主流程 */ }\n}\n\nexport default async function () {\n try {\n const accs = accounts();\n if (!accs.length) throw new Error(\"IKUUU_ACCOUNTS 未配置或格式有误\");\n if (!SOLVER_KEY) {\n console.warn(\"未配置 TWOCAPTCHA_KEY，Cookie 失效后将无法自动登录\");\n }\n\n const balanceP = getBalance(); // 与签到并行，不占用串行时间\n const state = await loadState();\n if (RESET_STATE) {\n await sqlite.execute(\n `UPDATE ikuuu_state SET fail_streak = 0, cred_fail = 0, last_status = '', last_error = ''`,\n );\n for (const s of state.values()) {\n s.streak = 0;\n s.credFail = 0;\n s.lastStatus = \"\";\n s.lastError = \"\";\n }\n console.log(\"已重置失败计数与凭据熔断\");\n }\n maxSolves = num(\"MAX_SOLVES\", accs.length * (1 + LOGIN_RETRIES));\n console.log(\n `${accs.length} 个账号开始（并发 ${CONCURRENCY}，打码上限 ${maxSolves}，预算 ${\n BUDGET_MS / 1000\n }s）`,\n );\n\n const settled = await pool(\n accs,\n CONCURRENCY,\n (a) => runAccount(a, state.get(a.email) ?? BLANK),\n );\n\n const day = today();\n const writes: { sql: string; args: unknown[] }[] = [];\n const lines: string[] = [];\n const alerts: string[] = [];\n let okCount = 0;\n\n for (let i = 0; i < accs.length; i++) {\n const email = accs[i].email;\n const prev = state.get(email) ?? BLANK;\n const s = settled[i];\n\n if (s.status === \"fulfilled\") {\n okCount++;\n const v = s.value;\n if (v.cookie) {\n writes.push({\n sql:\n `INSERT OR REPLACE INTO ikuuu_cookies (email, cookie, updated_at) VALUES (?, ?, CURRENT_TIMESTAMP)`,\n args: [email, v.cookie],\n });\n }\n writes.push({\n sql:\n `INSERT OR REPLACE INTO ikuuu_state (email, fail_streak, last_status, last_signed, cred_fail, last_error, updated_at) VALUES (?, 0, ?, ?, 0, '', CURRENT_TIMESTAMP)`,\n args: [email, v.signed ? \"signed\" : \"already\", day],\n });\n const tag = v.cached\n ? \"⏭️ 今日已签(缓存)\"\n : v.signed\n ? \"✅ 签到成功\"\n : \"ℹ️ 今日已签到\";\n lines.push(`• ${email}：${tag}${v.info ? `（${v.info}）` : \"\"}`);\n console.log(\n `[${email}] ${tag} ${v.msg}${v.info ? \" | \" + v.info : \"\"}`,\n );\n } else {\n const err = s.reason as Error;\n const paused = err instanceof CredentialPaused;\n const permanent = err instanceof BadCredential;\n const streak = prev.streak + 1;\n // 凭据计数只由真正的凭据错误推进；熔断本次并未登录，不加计数也不覆盖原始报错\n const credFail = paused\n ? prev.credFail\n : permanent\n ? prev.credFail + 1\n : prev.credFail;\n writes.push({\n sql:\n `INSERT OR REPLACE INTO ikuuu_state (email, fail_streak, last_status, last_signed, cred_fail, last_error, updated_at) VALUES (?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP)`,\n args: [\n email,\n streak,\n permanent ? \"bad_credential\" : \"fail\",\n prev.lastSigned,\n credFail,\n paused ? prev.lastError : err.message.slice(0, 300),\n ],\n });\n lines.push(`• ${email}：❌ ${err.message}（连续 ${streak} 次）`);\n console.error(`[${email}] ❌ ${err.message}（连续 ${streak} 次）`);\n if (permanent || streak >= FAIL_STREAK_ALERT) {\n alerts.push(`• ${email}：${err.message}（连续 ${streak} 次）`);\n }\n }\n }\n\n await saveAll(writes);\n const bal = await balanceP;\n const lowBal = bal !== null && bal < BALANCE_ALERT;\n console.log(\n `总耗时 ${\n secs(START)\n }，成功 ${okCount}/${accs.length}，打码 ${solvesUsed} 次，余额 ${\n bal ?? \"未知\"\n }`,\n );\n\n const sections: string[] = [];\n if (alerts.length) {\n sections.push(`🚨 Ikuuu 签到需处理\\n${alerts.join(\"\\n\")}`);\n }\n if (lowBal) {\n sections.push(\n `💰 2Captcha 余额不足：$${bal}（低于 $${BALANCE_ALERT}），请尽快充值，否则 Cookie 失效后无法自动登录。`,\n );\n }\n if (ALWAYS_REPORT) {\n sections.unshift(\n `📋 Ikuuu 签到回执 ${okCount}/${accs.length}\\n${\n lines.join(\"\\n\")\n }\\n余额 $${bal ?? \"未知\"} · 打码 ${solvesUsed} 次 · 耗时 ${\n secs(START)\n }`,\n );\n }\n if (sections.length) await tg(sections.join(\"\\n\\n\"));\n\n await Promise.allSettled(pendingReports);\n return {\n total: accs.length,\n succeeded: okCount,\n failed: accs.length - okCount,\n alerts: alerts.length,\n solves: solvesUsed,\n balance: bal,\n elapsed: secs(START),\n };\n } catch (e) {\n const m = `🛑 Ikuuu 签到任务整体异常\\n${(e as Error).message}`;\n console.error(m);\n await tg(m);\n throw e;\n }\n}","// Val Town：ikuuu 全自动签到（2Captcha + Cookie优先）\n// 设计目标：单次运行不超时、失败可自愈、打码次数最少\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst ENV: Record =\n typeof Deno.env.toObject === \"function\" ? Deno.env.toObject() : {};\nconst env = (k: string) => {\n if (Object.keys(ENV).length) return ENV[k] ?? \"\";\n return Deno.env.get(k) || \"\";\n};\nconst num = (k: string, d: number) => {\n const v = parseFloat(env(k));\n return Number.isFinite(v) ? v : d;\n};\nconst bool = (k: string, d = false) => {\n const v = env(k);\n return v === \"\" ? d : /^(1|true|yes|on)$/i.test(v);\n};\n\nconst BASE = (env(\"IKUUU_BASE_URL\") || \"https://ikuuu.org\").replace(/\\/$/, \"\");\nconst CAPTCHA_ID = env(\"IKUUU_CAPTCHA_ID\") ||\n \"cc96d05ba8b60f9112f76e18526fcb73\";\nconst SOLVER_ENDPOINT = (env(\"SOLVER_ENDPOINT\") || \"https://api.2captcha.com\")\n .replace(/\\/$/, \"\");\nconst SOLVER_KEY = env(\"TWOCAPTCHA_KEY\");\nconst TG_TOKEN = env(\"TELEGRAM_TOKEN\");\nconst TG_CHAT = env(\"TELEGRAM_CHAT_ID\");\n\nconst BUDGET_MS = num(\"BUDGET_SEC\", 52) * 1000; // 总时间预算，须小于 Val Town 运行上限\nconst RESERVE_MS = 4000; // 预留给汇总与 Telegram 推送\nconst HTTP_TIMEOUT = num(\"HTTP_TIMEOUT_SEC\", 12) * 1000;\nconst CONCURRENCY = Math.max(1, num(\"CONCURRENCY\", 4));\nconst JITTER_MAX_SEC = num(\"JITTER_MAX_SEC\", 5);\nconst LOGIN_RETRIES = Math.max(0, num(\"LOGIN_RETRIES\", 1)); // 验证码被拒时的额外登录次数\nconst CRED_PAUSE_AFTER = Math.max(2, num(\"CRED_PAUSE_AFTER\", 3)); // 凭据连错几次后停止打码\nconst FAIL_STREAK_ALERT = Math.max(1, num(\"FAIL_STREAK_ALERT\", 2));\nconst BALANCE_ALERT = num(\"BALANCE_ALERT\", 1);\nconst TZ_OFFSET = num(\"TZ_OFFSET\", 8);\nconst ALWAYS_REPORT = bool(\"ALWAYS_REPORT\");\nconst FETCH_INFO = bool(\"FETCH_INFO\", ALWAYS_REPORT); // 抓流量/到期需额外一次请求\nconst FORCE = bool(\"FORCE\"); // 忽略“今日已签”缓存\nconst RESET_STATE = bool(\"RESET_STATE\"); // 清空失败计数与凭据暂停\nconst UA =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/151.0.0.0 Safari/537.36 Edg/151.0.0.0\";\n\nclass CookieExpired extends Error {}\nclass CaptchaRejected extends Error {}\nclass BadCredential extends Error {}\nclass CredentialPaused extends BadCredential {} // 熔断生效，本次未真正尝试登录\nclass LoginFlowChanged extends BadCredential {} // 站点登录接口已变更，重试与再次打码都不会成功\nclass OutOfBudget extends Error {}\n\nconst START = Date.now();\nconst left = () => BUDGET_MS - (Date.now() - START);\nconst sleep = (ms: number) => new Promise((r) => setTimeout(r, ms));\nconst secs = (t: number) => ((Date.now() - t) / 1000).toFixed(1) + \"s\";\nconst today = () =>\n new Date(Date.now() + TZ_OFFSET * 3600_000).toISOString().slice(0, 10);\nfunction needBudget(ms: number) {\n if (left() - RESERVE_MS < ms) {\n throw new OutOfBudget(\n `时间预算不足（剩余 ${(left() / 1000).toFixed(1)}s）`,\n );\n }\n}\n\nlet solvesUsed = 0;\nlet maxSolves = Infinity;\nconst pendingReports: Promise[] = [];\n\nasync function fx(\n url: string,\n opts: RequestInit = {},\n ms = HTTP_TIMEOUT,\n): Promise {\n needBudget(1000);\n const cap = Math.max(1000, Math.min(ms, left() - RESERVE_MS));\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), cap);\n try {\n return await fetch(url, { ...opts, signal: ctrl.signal });\n } catch (e) {\n if (ctrl.signal.aborted) {\n throw new Error(\n `请求超时 ${(cap / 1000).toFixed(0)}s: ${new URL(url).pathname}`,\n );\n }\n throw e;\n } finally {\n clearTimeout(t);\n }\n}\n\n// 仅重试网络/服务端抖动，语义明确的错误直接抛出，避免浪费预算与打码额度\nasync function retry(\n fn: () => Promise,\n tries = 2,\n gap = 1200,\n): Promise {\n let last: unknown;\n for (let i = 0; i < tries; i++) {\n try {\n return await fn();\n } catch (e) {\n if (\n e instanceof CookieExpired || e instanceof BadCredential ||\n e instanceof OutOfBudget\n ) throw e;\n last = e;\n if (i < tries - 1) {\n needBudget(gap + 2000);\n await sleep(gap);\n }\n }\n }\n throw last;\n}\n\nasync function solverPost(path: string, body: unknown): Promise {\n const res = await fx(`${SOLVER_ENDPOINT}${path}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ clientKey: SOLVER_KEY, ...(body as object) }),\n }, 15000);\n const text = await res.text();\n try {\n return JSON.parse(text);\n } catch {\n throw new Error(\n `打码接口非 JSON 响应(HTTP ${res.status}): ${text.slice(0, 80)}`,\n );\n }\n}\n\nfunction accounts() {\n return env(\"IKUUU_ACCOUNTS\")\n .split(/\\|\\||\\n/).map((l) => l.trim()).filter((l) =>\n l && !l.startsWith(\"#\")\n )\n .map((l) => {\n const i = l.indexOf(\":\");\n return { email: l.slice(0, i).trim(), pwd: l.slice(i + 1).trim() };\n })\n .filter((a) => a.email && a.pwd);\n}\n\n// ---- 状态存储：整批读、整批写，避免每账号多次往返 ----\ntype State = {\n cookie: string;\n streak: number;\n credFail: number;\n lastSigned: string;\n lastStatus: string;\n lastError: string;\n};\nconst BLANK: State = {\n cookie: \"\",\n streak: 0,\n credFail: 0,\n lastSigned: \"\",\n lastStatus: \"\",\n lastError: \"\",\n};\n\nasync function loadState(): Promise> {\n const ddl = [\n `CREATE TABLE IF NOT EXISTS ikuuu_cookies (email TEXT PRIMARY KEY, cookie TEXT, updated_at DATETIME DEFAULT CURRENT_TIMESTAMP)`,\n `CREATE TABLE IF NOT EXISTS ikuuu_state (email TEXT PRIMARY KEY, fail_streak INTEGER DEFAULT 0, last_status TEXT, last_signed TEXT, cred_fail INTEGER DEFAULT 0, last_error TEXT, updated_at DATETIME DEFAULT CURRENT_TIMESTAMP)`,\n ];\n try {\n await sqlite.batch(ddl);\n } catch {\n for (const s of ddl) await sqlite.execute(s);\n }\n for (\n const col of [\n `last_signed TEXT`,\n `cred_fail INTEGER DEFAULT 0`,\n `last_error TEXT`,\n ]\n ) {\n try {\n await sqlite.execute(`ALTER TABLE ikuuu_state ADD COLUMN ${col}`);\n } catch { /* 老库补列，已存在则忽略 */ }\n }\n\n const map = new Map();\n const touch = (email: string) => {\n if (!map.has(email)) map.set(email, { ...BLANK });\n return map.get(email)!;\n };\n const [ck, st] = await Promise.all([\n sqlite.execute(`SELECT email, cookie FROM ikuuu_cookies`),\n sqlite.execute(\n `SELECT email, fail_streak, last_status, last_signed, cred_fail, last_error FROM ikuuu_state`,\n ),\n ]);\n for (const r of ck.rows) touch(String(r[0])).cookie = String(r[1] ?? \"\");\n for (const r of st.rows) {\n const s = touch(String(r[0]));\n s.streak = Number(r[1] ?? 0);\n s.lastStatus = String(r[2] ?? \"\");\n s.lastSigned = String(r[3] ?? \"\");\n s.credFail = Number(r[4] ?? 0);\n s.lastError = String(r[5] ?? \"\");\n }\n return map;\n}\n\nasync function saveAll(stmts: { sql: string; args: unknown[] }[]) {\n if (!stmts.length) return;\n try {\n await sqlite.batch(stmts);\n } catch {\n for (const s of stmts) await sqlite.execute(s).catch(() => {});\n }\n}\n\n// ---- 2Captcha ----\nasync function solveCaptcha(\n email: string,\n): Promise<{ taskId: string; solution: any }> {\n if (solvesUsed >= maxSolves) {\n throw new Error(`打码已达本次上限 ${maxSolves} 次，跳过登录以控制成本`);\n }\n needBudget(15000); // 时间不够就别开单，省一次钱\n solvesUsed++;\n const t0 = Date.now();\n const create = await solverPost(\"/createTask\", {\n task: {\n type: \"GeeTestTaskProxyless\",\n websiteURL: `${BASE}/auth/login`,\n version: 4,\n initParameters: { captcha_id: CAPTCHA_ID },\n },\n });\n if (create.errorId) {\n throw new Error(\n `createTask: ${create.errorCode} ${create.errorDescription || \"\"}`,\n );\n }\n\n await sleep(6000);\n for (;;) {\n const res = await solverPost(\"/getTaskResult\", { taskId: create.taskId });\n if (res.status === \"ready\") {\n console.log(`[${email}] 打码完成 ${secs(t0)}`);\n return { taskId: create.taskId, solution: res.solution };\n }\n if (res.errorId) {\n throw new CaptchaRejected(\n `求解失败: ${res.errorCode} ${res.errorDescription || \"\"}`,\n );\n }\n needBudget(3000);\n await sleep(2000);\n }\n}\nfunction reportBad(taskId: string) {\n pendingReports.push(\n solverPost(\"/reportIncorrect\", { taskId }).catch(() => {}),\n );\n}\nasync function getBalance(): Promise {\n if (!SOLVER_KEY) return null;\n try {\n const r = await solverPost(\"/getBalance\", {});\n return typeof r.balance === \"number\" ? r.balance : null;\n } catch {\n return null;\n }\n}\n\n// ---- ikuuu ----\nconst JSON_HEADERS = {\n \"User-Agent\": UA,\n Accept: \"application/json, text/javascript, */*; q=0.01\",\n \"X-Requested-With\": \"XMLHttpRequest\",\n};\n\nfunction cookieMap(header: string): Record {\n const out: Record = {};\n for (const part of header.split(\";\")) {\n const p = part.trim();\n const eq = p.indexOf(\"=\");\n if (eq > 0) out[p.slice(0, eq)] = p.slice(eq + 1);\n }\n return out;\n}\nfunction setCookiePairs(res: Response): string[] {\n return (res.headers.getSetCookie?.() ?? [res.headers.get(\"set-cookie\") ?? \"\"])\n .filter(Boolean);\n}\nfunction mergeCookie(existing: string, setCookies: string[]): string {\n const map = cookieMap(existing);\n for (const sc of setCookies) {\n const first = sc.split(\";\")[0];\n const eq = first.indexOf(\"=\");\n if (eq > 0) map[first.slice(0, eq).trim()] = first.slice(eq + 1).trim();\n }\n return Object.entries(map).map(([k, v]) => `${k}=${v}`).join(\"; \");\n}\nfunction plainMsg(msg: string): string {\n return msg.replace(/<[^>]+>/g, \" \").replace(/\\s+/g, \" \").trim();\n}\n\nasync function beginLoginSession(): Promise<{ cookie: string; pageLoadedAt: string }> {\n const pageLoadedAt = String(Date.now());\n const page = await fx(`${BASE}/auth/login`, {\n headers: {\n \"User-Agent\": UA,\n Accept:\n \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\n },\n redirect: \"follow\",\n });\n const cookie = mergeCookie(\"\", setCookiePairs(page));\n await page.text(); // 读完 body，避免悬挂连接\n if (!/PHPSESSID=/i.test(cookie)) {\n console.warn(\n `GET /auth/login 未拿到 PHPSESSID（仅 ${cookie || \"空 Cookie\"}），登录可能仍会 invalid_phase`,\n );\n }\n return { cookie, pageLoadedAt };\n}\n\nasync function login(acc: { email: string; pwd: string }): Promise {\n const { cookie: session, pageLoadedAt } = await beginLoginSession();\n const { taskId, solution: c } = await solveCaptcha(acc.email);\n const host = new URL(BASE).hostname;\n const form = new URLSearchParams({\n host,\n phase: \"password\",\n email: acc.email,\n passwd: acc.pwd,\n remember_me: \"on\",\n pageLoadedAt,\n \"captcha_result[lot_number]\": String(c.lot_number),\n \"captcha_result[captcha_output]\": String(c.captcha_output),\n \"captcha_result[pass_token]\": String(c.pass_token),\n \"captcha_result[gen_time]\": String(c.gen_time),\n });\n const res = await fx(`${BASE}/auth/login`, {\n method: \"POST\",\n headers: {\n ...JSON_HEADERS,\n Origin: BASE,\n Referer: `${BASE}/auth/login`,\n \"Content-Type\": \"application/x-www-form-urlencoded; charset=UTF-8\",\n ...(session ? { Cookie: session } : {}),\n },\n body: form.toString(),\n redirect: \"manual\",\n });\n const cookie = mergeCookie(session, setCookiePairs(res));\n const text = await res.text();\n let lj: { ret?: number; msg?: string; result?: string; phase?: string };\n try {\n lj = JSON.parse(text);\n } catch {\n throw new Error(\n `登录响应非 JSON(HTTP ${res.status}): ${text.slice(0, 100)}`,\n );\n }\n\n const ok = lj.ret === 1 ||\n lj.result === \"ok\" || lj.result === \"success\" ||\n lj.result === \"logged_in\" || lj.result === \"authenticated\" ||\n lj.phase === \"authenticated\";\n if (!ok) {\n const msg = plainMsg(String(lj.msg ?? \"\"));\n const result = String(lj.result ?? \"\");\n console.error(\n `[${acc.email}] 登录被拒(HTTP ${res.status}) result=${result || \"-\"} phase=${\n lj.phase ?? \"-\"\n } 原文: ${msg || text.slice(0, 200)}`,\n );\n if (result === \"invalid_phase\" || /登录流程无效/.test(msg)) {\n reportBad(taskId);\n throw new LoginFlowChanged(\n `登录会话未建立(invalid_phase)：GET 登录页后 Cookie=${\n session || \"空\"\n }；${msg}`,\n );\n }\n if (\n result === \"user_not_found\" || result === \"wrong_password\" ||\n /邮箱不存在|密码错误|密码不正确|邮箱或密码|账户不存在|帐户不存在|用户不存在|尚未注册|未注册|已封禁|已禁用|账号被封/\n .test(msg)\n ) {\n throw new BadCredential(`凭据/账号异常(${result || \"msg\"}): ${msg}`);\n }\n if (\n /totp|2fa|otp|email_code|verify/i.test(result) ||\n /二步验证|邮箱验证码/.test(msg)\n ) {\n throw new LoginFlowChanged(`登录需要额外验证(${result}): ${msg}`);\n }\n if (/验证|captcha|geetest|刷新页面/i.test(msg) || /captcha/i.test(result)) {\n reportBad(taskId);\n throw new CaptchaRejected(`验证码被拒: ${msg || result}`);\n }\n throw new Error(`登录失败(${result || `HTTP ${res.status}`}): ${msg}`);\n }\n if (!cookie) throw new Error(\"登录成功但未返回 Cookie\");\n console.log(\n `[${acc.email}] 登录成功 Cookie键: ${\n Object.keys(cookieMap(cookie)).join(\",\") || \"无\"\n }`,\n );\n return cookie;\n}\n\nasync function loginWithRetry(\n acc: { email: string; pwd: string },\n): Promise {\n for (let i = 0;; i++) {\n try {\n return await login(acc);\n } catch (e) {\n const canRetry = e instanceof CaptchaRejected && i < LOGIN_RETRIES &&\n solvesUsed < maxSolves && left() - RESERVE_MS > 20000;\n if (!canRetry) throw e;\n console.log(\n `[${acc.email}] 验证码被拒，重试登录 ${i + 1}/${LOGIN_RETRIES}`,\n );\n }\n }\n}\n\nasync function doCheckin(\n cookie: string,\n): Promise<{ signed: boolean; msg: string }> {\n const res = await fx(`${BASE}/user/checkin`, {\n method: \"POST\",\n headers: {\n ...JSON_HEADERS,\n Cookie: cookie,\n Referer: `${BASE}/user`,\n \"Content-Type\": \"application/json\",\n },\n redirect: \"manual\",\n });\n if ([301, 302, 401, 403].includes(res.status)) throw new CookieExpired();\n const text = await res.text();\n // 5xx/429 属服务端抖动，交给 retry 重试，绝不能误判为 Cookie 失效去触发付费登录\n if (res.status >= 500 || res.status === 429) {\n throw new Error(`签到 HTTP ${res.status}`);\n }\n let data: { ret?: number; msg?: string };\n try {\n data = JSON.parse(text);\n } catch {\n if (/auth\\/login|登录|sign\\s*in/i.test(text)) throw new CookieExpired();\n throw new Error(`签到响应异常(HTTP ${res.status}): ${text.slice(0, 80)}`);\n }\n // Cookie 有效即已鉴权：ret===1 为当日新签到，其余（“今日已签到”等）同样视为成功\n return { signed: data.ret === 1, msg: data.msg || \"\" };\n}\n\n// 最佳努力：抓剩余流量/到期（ikuuu 为 SPA，取不到则安静跳过）\nasync function userInfo(cookie: string): Promise {\n try {\n const res = await fx(`${BASE}/user`, {\n headers: { ...JSON_HEADERS, Cookie: cookie },\n redirect: \"manual\",\n }, 8000);\n if (res.status !== 200) return \"\";\n const html = await res.text();\n const rem = html.match(\n /(?:剩余流量|未使用流量|剩余|remain[a-z]*flow)[^0-9]{0,12}([\\d.]+\\s?[KMGT]B)/i,\n );\n const exp = html.match(/(20\\d{2}-\\d{2}-\\d{2})/);\n const parts: string[] = [];\n if (rem) parts.push(`剩余 ${rem[1]}`);\n if (exp) parts.push(`到期 ${exp[1]}`);\n return parts.join(\", \");\n } catch {\n return \"\";\n }\n}\n\ntype Outcome = {\n signed: boolean;\n msg: string;\n info: string;\n cookie?: string;\n cached?: boolean;\n};\n\nasync function runAccount(\n acc: { email: string; pwd: string },\n st: State,\n): Promise {\n // 当天已确认签到过：整条链路零请求零成本，重复运行也安全\n if (!FORCE && st.lastSigned === today()) {\n return {\n signed: false,\n msg: \"今日已签到（本地记录）\",\n info: \"\",\n cached: true,\n };\n }\n\n const t0 = Date.now();\n if (JITTER_MAX_SEC > 0) {\n await sleep(\n Math.random() *\n Math.min(\n JITTER_MAX_SEC * 1000,\n Math.max(0, (left() - RESERVE_MS) * 0.15),\n ),\n );\n }\n\n let cookie = st.cookie;\n let fresh: string | undefined;\n let r: { signed: boolean; msg: string } | null = null;\n\n if (cookie) {\n try {\n r = await retry(() => doCheckin(cookie));\n console.log(`[${acc.email}] 缓存 Cookie 签到 ${secs(t0)}`);\n } catch (e) {\n if (!(e instanceof CookieExpired)) throw e;\n console.log(`[${acc.email}] Cookie 失效，转登录`);\n }\n }\n\n if (!r) {\n // 熔断只看“连续凭据错误”这一专用计数，且带上原始报错，避免掩盖真实原因\n if (st.credFail >= CRED_PAUSE_AFTER) {\n throw new CredentialPaused(\n `凭据连续错误 ${st.credFail} 次已暂停打码（原始报错：${\n st.lastError || \"未记录\"\n }）；确认密码无误后用 RESET_STATE=1 运行一次恢复`,\n );\n }\n fresh = await loginWithRetry(acc);\n cookie = fresh;\n r = await retry(() => doCheckin(cookie));\n console.log(`[${acc.email}] 登录+签到 ${secs(t0)}`);\n }\n\n const info = FETCH_INFO ? await userInfo(cookie) : \"\";\n return { ...r, info, cookie: fresh };\n}\n\nasync function pool(\n items: T[],\n limit: number,\n fn: (t: T, i: number) => Promise,\n) {\n const out: PromiseSettledResult[] = new Array(items.length);\n let next = 0;\n await Promise.all(\n Array.from({ length: Math.min(limit, items.length) }, async () => {\n for (;;) {\n const i = next++;\n if (i >= items.length) return;\n try {\n out[i] = { status: \"fulfilled\", value: await fn(items[i], i) };\n } catch (reason) {\n out[i] = { status: \"rejected\", reason } as PromiseSettledResult;\n }\n }\n }),\n );\n return out;\n}\n\nasync function tg(text: string) {\n if (!TG_TOKEN || !TG_CHAT) return;\n try {\n await fetch(`https://api.telegram.org/bot${TG_TOKEN}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: TG_CHAT, text, parse_mode: \"HTML\" }),\n signal: AbortSignal.timeout(8000),\n });\n } catch { /* 通知失败不影响主流程 */ }\n}\n\nexport default async function () {\n try {\n const accs = accounts();\n if (!accs.length) throw new Error(\"IKUUU_ACCOUNTS 未配置或格式有误\");\n if (!SOLVER_KEY) {\n console.warn(\"未配置 TWOCAPTCHA_KEY，Cookie 失效后将无法自动登录\");\n }\n\n const balanceP = getBalance(); // 与签到并行，不占用串行时间\n const state = await loadState();\n if (RESET_STATE) {\n await sqlite.execute(\n `UPDATE ikuuu_state SET fail_streak = 0, cred_fail = 0, last_status = '', last_error = ''`,\n );\n for (const s of state.values()) {\n s.streak = 0;\n s.credFail = 0;\n s.lastStatus = \"\";\n s.lastError = \"\";\n }\n console.log(\"已重置失败计数与凭据熔断\");\n }\n maxSolves = num(\"MAX_SOLVES\", accs.length * (1 + LOGIN_RETRIES));\n console.log(\n `${accs.length} 个账号开始（并发 ${CONCURRENCY}，打码上限 ${maxSolves}，预算 ${\n BUDGET_MS / 1000\n }s）`,\n );\n\n const settled = await pool(\n accs,\n CONCURRENCY,\n (a) => runAccount(a, state.get(a.email) ?? BLANK),\n );\n\n const day = today();\n const writes: { sql: string; args: unknown[] }[] = [];\n const lines: string[] = [];\n const alerts: string[] = [];\n let okCount = 0;\n\n for (let i = 0; i < accs.length; i++) {\n const email = accs[i].email;\n const prev = state.get(email) ?? BLANK;\n const s = settled[i];\n\n if (s.status === \"fulfilled\") {\n okCount++;\n const v = s.value;\n if (v.cookie) {\n writes.push({\n sql:\n `INSERT OR REPLACE INTO ikuuu_cookies (email, cookie, updated_at) VALUES (?, ?, CURRENT_TIMESTAMP)`,\n args: [email, v.cookie],\n });\n }\n writes.push({\n sql:\n `INSERT OR REPLACE INTO ikuuu_state (email, fail_streak, last_status, last_signed, cred_fail, last_error, updated_at) VALUES (?, 0, ?, ?, 0, '', CURRENT_TIMESTAMP)`,\n args: [email, v.signed ? \"signed\" : \"already\", day],\n });\n const tag = v.cached\n ? \"⏭️ 今日已签(缓存)\"\n : v.signed\n ? \"✅ 签到成功\"\n : \"ℹ️ 今日已签到\";\n lines.push(`• ${email}：${tag}${v.info ? `（${v.info}）` : \"\"}`);\n console.log(\n `[${email}] ${tag} ${v.msg}${v.info ? \" | \" + v.info : \"\"}`,\n );\n } else {\n const err = s.reason as Error;\n const paused = err instanceof CredentialPaused;\n const permanent = err instanceof BadCredential;\n const streak = prev.streak + 1;\n // 凭据计数只由真正的凭据错误推进；熔断本次并未登录，不加计数也不覆盖原始报错\n const credFail = paused\n ? prev.credFail\n : permanent\n ? prev.credFail + 1\n : prev.credFail;\n writes.push({\n sql:\n `INSERT OR REPLACE INTO ikuuu_state (email, fail_streak, last_status, last_signed, cred_fail, last_error, updated_at) VALUES (?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP)`,\n args: [\n email,\n streak,\n permanent ? \"bad_credential\" : \"fail\",\n prev.lastSigned,\n credFail,\n paused ? prev.lastError : err.message.slice(0, 300),\n ],\n });\n lines.push(`• ${email}：❌ ${err.message}（连续 ${streak} 次）`);\n console.error(`[${email}] ❌ ${err.message}（连续 ${streak} 次）`);\n if (permanent || streak >= FAIL_STREAK_ALERT) {\n alerts.push(`• ${email}：${err.message}（连续 ${streak} 次）`);\n }\n }\n }\n\n await saveAll(writes);\n const bal = await balanceP;\n const lowBal = bal !== null && bal < BALANCE_ALERT;\n console.log(\n `总耗时 ${\n secs(START)\n }，成功 ${okCount}/${accs.length}，打码 ${solvesUsed} 次，余额 ${\n bal ?? \"未知\"\n }`,\n );\n\n const sections: string[] = [];\n if (alerts.length) {\n sections.push(`🚨 Ikuuu 签到需处理\\n${alerts.join(\"\\n\")}`);\n }\n if (lowBal) {\n sections.push(\n `💰 2Captcha 余额不足：$${bal}（低于 $${BALANCE_ALERT}），请尽快充值，否则 Cookie 失效后无法自动登录。`,\n );\n }\n if (ALWAYS_REPORT) {\n sections.unshift(\n `📋 Ikuuu 签到回执 ${okCount}/${accs.length}\\n${\n lines.join(\"\\n\")\n }\\n余额 $${bal ?? \"未知\"} · 打码 ${solvesUsed} 次 · 耗时 ${\n secs(START)\n }`,\n );\n }\n if (sections.length) await tg(sections.join(\"\\n\\n\"));\n\n await Promise.allSettled(pendingReports);\n return {\n total: accs.length,\n succeeded: okCount,\n failed: accs.length - okCount,\n alerts: alerts.length,\n solves: solvesUsed,\n balance: bal,\n elapsed: secs(START),\n };\n } catch (e) {\n const m = `🛑 Ikuuu 签到任务整体异常\\n${(e as Error).message}`;\n console.error(m);\n await tg(m);\n throw e;\n }\n}","createdAt",["D",1786635396384],"branchVersion","branchId","fe5770dc-417d-11f1-8714-42b51c65c3df","id","fe56a01c-417d-11f1-8714-42b51c65c3df","ikuuu-checkin",["D",1777214481899],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Daily auto check-in for ikuuu.org","imageUrl","96c2793d-57c8-41d2-a49a-d1ee82f9dd24","pinnedFileId","c260aefc-ac64-11f1-acc6-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","93515af8-c7b7-459c-9bf2-3bb3df310a75","tursoName","fe56a01c417d11f1871442b51c65c3df","tursoHostname","fe56a01c417d11f1871442b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789501263826],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":103},"org",{"_100":99,"_101":-5,"_102":103,"_18":55,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",65,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","yuxiaoy","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJObXd1QWdCZmVtaUh0bGU5TkswOG1sM0xheiIsImluaXRpYWxzIjoiRlkifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":168,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":169,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":170,"_84":171,"_86":172,"_88":25},"tree",[159,160],"files",[159,160],"counts",{"_147":63,"_148":149,"_150":63,"_151":152,"_153":154},"contents",[130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":143,"_13":144,"_33":20,"_35":145,"_24":25,"_137":-5,"_27":146},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":135,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":138},"d330df3f-2576-4768-a0ea-6f34871804ce","parentId","latest",["D",1786635396384],30,"label",[28],"411168f7-367f-4424-96b5-fb03fa8acafb","README.md","5dad93ac-8ef6-11f1-8b69-1607ee4eb77e",25,["D",1785771732899],2,"# ikuuu 全自动签到（Val Town 版）\n\n部署在 [Val Town](https://www.val.town) 上的 ikuuu\n每日自动签到：**邮箱+密码全自动登录**（GeeTest V4 交由 2Captcha\n求解），支持多账号、Cookie 复用、Telegram 通知。无需服务器，无需手动更新\nCookie。\n\n主脚本：[`valtown-checkin.ts`](./valtown-checkin.ts)\n\n## 为什么需要它\n\nikuuu 从 2026-04 起在登录页启用了 **GeeTest V4 验证码**，传统的\"邮箱+密码直接\nPOST 登录\"会返回：\n\n> 系统无法接受您的验证结果，请刷新页面后重试。\n\n本项目实测过纯算法求解器（GeekedTest 思路）与多家免费打码平台，在当前 GeeTest V4\n的 \"ai\" 类型题目上均已失效，因此改用 **2Captcha** 求解。配合下面的 Cookie\n复用策略，实际打码次数被压到极低，长期成本可忽略。\n\n## 工作原理\n\n```\nVal Town Cron\n └─ 读取 SQLite 中的账号状态（Cookie / 签到日期 / 失败计数）\n ├─ 今天已签到？ → 直接跳过，零请求零成本\n ├─ 有缓存 Cookie？ → 直接 POST /user/checkin\n └─ Cookie 失效？ → 2Captcha 求解 GeeTest V4 → POST /auth/login → 签到\n └─ 汇总结果，异常时推送 Telegram\n```\n\n关键点：**只有 Cookie 失效时才会打码**。ikuuu\n的会话通常能维持很久，所以绝大多数天数是零成本运行。\n\n## 部署步骤\n\n### 1. 创建 Val\n\n在 Val Town 新建一个 **Cron Val**，把 `valtown-checkin.ts` 的内容整体粘贴进去。\n\n建议 cron 设为每天一次，例如 `30 0 * * *`（UTC，对应北京时间 08:30）。\n\n### 2. 配置环境变量\n\n在 Val Town 的 **Settings → Environment Variables** 中添加。\n\n**必填：**\n\n| 变量 | 说明 |\n| ---------------- | ------------------------------------------------ |\n| `IKUUU_ACCOUNTS` | 账号列表，格式 `邮箱:密码`，多账号用 `\\|\\|` 分隔 |\n| `TWOCAPTCHA_KEY` | 2Captcha 的 API Key |\n\n多账号示例（Val Town 环境变量是单行，用 `||` 连接）：\n\n```\nalice@example.com:pwd1||bob@example.com:pwd2\n```\n\n> 按**第一个冒号**分隔邮箱和密码，所以密码含冒号没问题；但密码里不能出现 `||`。\n\n**可选：**\n\n| 变量 | 默认 | 说明 |\n| ------------------- | -------------------- | ----------------------------------------------------- |\n| `IKUUU_BASE_URL` | `https://ikuuu.org` | ikuuu 常换域名，失效时改这里 |\n| `IKUUU_CAPTCHA_ID` | 已内置 | GeeTest 验证码 ID，站点更新导致失效时才需覆盖 |\n| `TELEGRAM_TOKEN` | — | Telegram Bot Token（@BotFather 获取） |\n| `TELEGRAM_CHAT_ID` | — | 接收通知的 Chat ID（@userinfobot 获取） |\n| `ALWAYS_REPORT` | 关 | 设 `1` 则每次都推送回执，否则仅异常时推送 |\n| `FETCH_INFO` | 跟随 `ALWAYS_REPORT` | 设 `1` 则额外抓取剩余流量与到期日（每账号多一次请求） |\n| `BALANCE_ALERT` | `1` | 2Captcha 余额低于此值（美元）时告警 |\n| `FAIL_STREAK_ALERT` | `2` | 连续失败几次才升级为强提醒 |\n| `LOGIN_RETRIES` | `1` | 验证码被拒时的额外登录尝试次数 |\n| `CRED_PAUSE_AFTER` | `3` | 连续几次**凭据错误**后暂停打码（熔断） |\n| `MAX_SOLVES` | 账号数 ×(1+重试数) | 单次运行的打码硬上限 |\n| `CONCURRENCY` | `4` | 多账号并发数 |\n| `BUDGET_SEC` | `52` | 总时间预算，必须小于 Val Town 的运行上限 |\n| `HTTP_TIMEOUT_SEC` | `12` | 单个 HTTP 请求超时 |\n| `JITTER_MAX_SEC` | `5` | 每账号随机延迟上限，用于错峰 |\n| `TZ_OFFSET` | `8` | 判定\"今天\"所用的时区偏移 |\n| `FORCE` | 关 | 设 `1` 忽略\"今日已签\"缓存，强制执行 |\n| `RESET_STATE` | 关 | 设 `1` 清空失败计数与凭据熔断，跑完记得改回 |\n\n### 3. 手动跑一次验证\n\n在 Val Town 点 Run，看日志是否输出 `✅ 签到成功`。首次运行会打码登录并把 Cookie\n写入 SQLite，之后就走缓存了。\n\n## 设计要点\n\n**Cookie 优先，成本最低。** 签到本身不需要验证码，只有登录才需要。脚本把 Cookie\n持久化在 Val Town 的 SQLite 里，只在确认失效时才触发付费打码。\n\n**当天已签则完全跳过。** 成功签到会记录日期（按 `TZ_OFFSET`\n判定），同一天内重复运行不产生任何请求，手动重跑和 cron 重复触发都是安全的。\n\n**失败分类，避免误烧钱。** 5xx / 429 判定为服务端抖动并重试，不会误认成 Cookie\n失效而去登录；只有 301/302/401/403\n或响应内容像登录页才算失效。登录失败会区分\"验证码被拒\"（上报退款并重试）与\"凭据错误\"（不重试，直接告警）。\n\n**全局时间预算。** 每个网络请求前检查剩余时间，并始终预留 4 秒发送通知，避免被\nVal Town 静默掐断而收不到任何告警。\n\n**凭据熔断。**\n连续多次确凿的凭据错误后停止打码，避免密码改了却每天白烧钱。恢复方式：确认密码无误后加\n`RESET_STATE=1` 跑一次。\n\n## 常见问题\n\n**登录失败怎么排查？** 日志里会有一行\n`登录被拒(HTTP xxx) 原文: ...`，那是服务端的真实回复，据此判断是域名变更、验证码配置变化还是账号问题。\n\n**ikuuu 换域名了？** 改 `IKUUU_BASE_URL` 即可。\n\n**成本大概多少？** GeeTest V4 在 2Captcha 约 $0.003/次。由于只在 Cookie\n失效时打码，实际一年下来通常不到 $1。\n\n**为什么不用 2Captcha 的 Browser API（云浏览器）？** 那是托管 Chrome 服务，需要\nPuppeteer/Playwright 通过 CDP 驱动。真实浏览器完成一次登录通常要几十秒，会超出\nVal Town 免费版 60 秒的运行上限——这正是本项目最初放弃 Puppeteer 方案的原因。当前\nHTTP 直连方案更快也更省。\n\n**安全吗？** 账号密码只存在 Val Town 环境变量中，不写入代码；日志不打印 Cookie\n与密码。\n\n## 目录结构\n\n```\n.\n├── valtown-checkin.ts # 主脚本，粘贴到 Val Town 即可运行\n└── README.md\n```\n\n> 早期还有一套基于 GitHub Actions + 纯算法 GeeTest 求解器的实现（`checkin.py` /\n> `geeked/`），实测求解器已被 ikuuu 的风控拦截（成功率 0/10），已从仓库移除。",[140],"pulls","branches",1,"forks","envVars",{"_155":157,"_158":63},"connections",{"_155":63,"_156":63},"count","unfilledCount",5,"emptyCount",{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":165,"_13":144,"_33":20,"_35":145,"_24":25,"_137":-5,"_162":166,"_27":167},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":25,"_38":161,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_162":163,"_27":164},["D",1786635396384],"children",[],[28],["D",1785771732899],[],[140],["D",1777214481899],["D",1789501263826],{"_100":99,"_107":103},{"_100":99,"_101":-5,"_102":103,"_18":55,"_104":105,"_106":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_127":206,"_207":208,"_209":210,"_211":25,"_212":25,"_213":25,"_214":59,"_215":-5,"_216":-7,"_217":-7,"_218":63,"_219":25,"_220":25,"_221":-5,"_222":25,"_223":25,"_224":25,"_225":-5},"ENV",{"_177":178,"_179":180,"_181":90,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205},"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 · v38