[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_191":192,"_193":194},"routes/_app.x.$handle.$name",{"_16":17,"_20":21,"_83":65,"_84":85,"_63":-7,"_86":-5,"_13":87,"_88":89,"_11":90,"_91":92,"_93":94,"_95":-5,"_96":-5,"_97":-5,"_98":26,"_99":100,"_101":26,"_102":-5,"_103":-5,"_104":105},"routes/_app.x.$handle.$name.search.$(branch)",{"_11":12,"_13":14,"_15":-5,"_16":17},"files",[],"project",{"_18":19,"_20":21,"_22":23,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":57,"_58":59,"_60":61,"_62":26},"query","handle","KqEmL35T8y1YDcjzi9gRZ2SOe4P73","id","9ea7caf8-5b3e-11f1-8910-ee650bb23af1","name","baohuangtian-crons","createdAt",["D",1780045993309],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","Bao Huang Tian scheduled cron entrypoints","imageUrl","userId","1b06fec8-ebc5-4a87-9c5e-c5d4ab16c0e6","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e1a35-373c-751f-ac7a-32ad31701ae9","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_16":17,"_82":78},"org",{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},"branch",{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"isOwned","version",5,"main","9ea8acb6-5b3e-11f1-8910-ee650bb23af1","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","迪迦","avatar","https://lh3.googleusercontent.com/a/ACg8ocLqxrq95dl6q1ky9ObFN7sAiEcqwhjvlRIB1o8-snquCPIuoH06=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_18":19,"_20":21,"_22":187,"_24":-5,"_25":26,"_27":28,"_29":28,"_30":31,"_32":-5,"_33":34,"_35":-5,"_36":26,"_37":-5,"_38":-5,"_39":40,"_41":42,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":48,"_49":48,"_50":51,"_52":51,"_53":51,"_54":48,"_55":48,"_56":188,"_58":189,"_60":190,"_62":26},"tree",[166,167,168,169,170],[166,167,168,169,170],"counts",{"_156":40,"_157":152,"_158":40,"_159":160,"_161":162},"contents",[106,107,108,109,110],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_18":149,"_20":150,"_113":151,"_115":-5,"_116":66,"_117":152,"_118":119,"_22":153,"_63":40,"_121":122,"_123":154,"_125":26,"_126":-5,"_84":155},{"_18":142,"_20":143,"_113":144,"_115":-5,"_116":66,"_117":145,"_118":119,"_22":146,"_63":40,"_121":122,"_123":147,"_125":26,"_126":-5,"_84":148},{"_18":135,"_20":136,"_113":137,"_115":-5,"_116":66,"_117":138,"_118":119,"_22":139,"_63":40,"_121":122,"_123":140,"_125":26,"_126":-5,"_84":141},{"_18":128,"_20":129,"_113":130,"_115":-5,"_116":66,"_117":131,"_118":119,"_22":132,"_63":40,"_121":122,"_123":133,"_125":26,"_126":-5,"_84":134},{"_18":111,"_20":112,"_113":114,"_115":-5,"_116":66,"_117":64,"_118":119,"_22":120,"_63":40,"_121":122,"_123":124,"_125":26,"_126":-5,"_84":127},"1abf0e44-5b3f-11f1-9925-ee650bb23af1","merchant_settlement_release.cron.ts","fileId","1abf0ee4-5b3f-11f1-9925-ee650bb23af1","parentId","branchId","branchVersion","latest",true,["D",1780046201491],"fileType","interval","content","/**\n * Val Town Cron 触发器：\n * - 在 Val Town 中将该文件设置为 Cron（interval）；\n * - 每次触发时请求后端任务接口，让后端释放到期冻结结算。\n *\n * 需要在 Val Town Env Variables 中配置：\n * - MERCHANT_SETTLEMENT_RELEASE_ENDPOINT 例如 https://your-domain.com/internal/jobs/merchant-settlement-release\n * - MERCHANT_SETTLEMENT_RELEASE_CRON_TOKEN 与后端 MERCHANT_SETTLEMENT_RELEASE_JOB_TOKEN 保持一致\n * - MERCHANT_SETTLEMENT_RELEASE_REQUEST_TIMEOUT_MS（可选，默认 15000）\n */\ntype ValTownInterval = unknown;\n\nexport default async function (_interval: ValTownInterval): Promise {\n const endpoint = Deno.env.get(\"MERCHANT_SETTLEMENT_RELEASE_ENDPOINT\")\n ?.trim();\n const token = Deno.env.get(\"MERCHANT_SETTLEMENT_RELEASE_CRON_TOKEN\")?.trim();\n const timeoutMs = Number(\n Deno.env.get(\"MERCHANT_SETTLEMENT_RELEASE_REQUEST_TIMEOUT_MS\")?.trim() ??\n \"15000\",\n );\n\n if (!endpoint) {\n throw new Error(\"missing MERCHANT_SETTLEMENT_RELEASE_ENDPOINT\");\n }\n if (!token) {\n throw new Error(\"missing MERCHANT_SETTLEMENT_RELEASE_CRON_TOKEN\");\n }\n\n const controller = new AbortController();\n const timeoutHandle = setTimeout(() => controller.abort(), timeoutMs);\n try {\n const response = await fetch(endpoint, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n trigger: \"valtown_cron\",\n sentAtIso: new Date().toISOString(),\n }),\n signal: controller.signal,\n });\n\n if (!response.ok) {\n const responseText = await response.text();\n throw new Error(\n `merchant settlement release trigger failed: ${response.status} ${response.statusText} ${responseText}`,\n );\n }\n } finally {\n clearTimeout(timeoutHandle);\n }\n}\n","deleted","label",[112],"1a817d2c-5b3f-11f1-9466-ee650bb23af1","group_payment_refund_reconcile.cron.ts","1a817dcc-5b3f-11f1-9466-ee650bb23af1",4,["D",1780046201087],"/**\n * Val Town Cron：触发后端退款对账任务。\n *\n * 需要在 Val Town Env Variables 配置：\n * - PAYMENT_REFUND_RECONCILE_ENDPOINT\n * 例：https://your-domain.com/internal/jobs/group-payment-refund-reconcile\n * - PAYMENT_REFUND_RECONCILE_CRON_TOKEN\n * 与后端 RuntimeConfig.GROUP_PAYMENT_REFUND_RECONCILE_JOB_TOKEN 保持一致\n * - PAYMENT_REFUND_RECONCILE_REQUEST_TIMEOUT_MS（可选，默认 15000）\n */\ntype ValTownInterval = unknown;\n\nconst DEFAULT_REQUEST_TIMEOUT_MS = 15_000;\n\nfunction readRequiredEnv(name: string): string {\n // Deno.env.get 读取 Val Town 环境变量；trim 去掉复制粘贴带来的空格。\n const value = Deno.env.get(name)?.trim();\n // endpoint/token 都必须真实存在，缺失时让本次 cron 明确失败。\n if (!value) {\n throw new Error(`missing ${name}`);\n }\n // 返回清理后的值，后续请求只使用这一份。\n return value;\n}\n\nfunction readRequestTimeoutMs(): number {\n // 超时时间可选，不配置时使用项目约定的 15 秒。\n const rawValue = Deno.env\n .get(\"PAYMENT_REFUND_RECONCILE_REQUEST_TIMEOUT_MS\")\n ?.trim();\n // 空值直接走默认，避免每个环境都要额外配置。\n if (!rawValue) {\n return DEFAULT_REQUEST_TIMEOUT_MS;\n }\n // Number 把字符串数字转为 number，例如 \"15000\" -> 15000。\n const parsedValue = Number(rawValue);\n // 超时必须为正数，配置错误时宁可失败，也不要静默使用坏参数。\n if (!Number.isFinite(parsedValue) || parsedValue <= 0) {\n throw new Error(\n \"PAYMENT_REFUND_RECONCILE_REQUEST_TIMEOUT_MS must be a positive number\",\n );\n }\n // setTimeout 需要整数毫秒。\n return Math.floor(parsedValue);\n}\n\nfunction isRecord(value: unknown): value is Record {\n // typeof object 包含 null，所以这里显式排除 null 和数组。\n return typeof value === \"object\" && value !== null && !Array.isArray(value);\n}\n\nfunction parseJsonResponse(responseText: string): unknown | null {\n // 空响应没有可解析内容，统一返回 null。\n if (responseText.trim().length === 0) {\n return null;\n }\n try {\n // 后端正常返回 JSON，解析后可提取任务统计字段。\n return JSON.parse(responseText);\n } catch {\n // 异常页或纯文本错误不影响主请求判断。\n return null;\n }\n}\n\nfunction truncateLogText(value: string, maxLength = 1000): string {\n // Val Town 日志只保留前 maxLength 个字符，避免错误响应刷屏。\n return value.length > maxLength ? `${value.slice(0, maxLength)}...` : value;\n}\n\nfunction normalizeErrorMessage(error: unknown): string {\n // Error 优先取 message；其他类型转成字符串，保证日志字段稳定。\n return error instanceof Error ? error.message : String(error);\n}\n\nfunction buildEndpointLogLabel(endpoint: string): string {\n try {\n // 日志只记录协议、域名、路径，不记录 query，避免误写敏感参数。\n const url = new URL(endpoint);\n // Authorization token 只放请求头，绝不进入日志。\n return `${url.protocol}//${url.host}${url.pathname}`;\n } catch {\n // URL 本身非法时，后续 fetch 也会失败；日志里用固定标签即可。\n return \"invalid-url\";\n }\n}\n\nfunction buildReconcileSummary(payload: unknown): Record {\n // 后端约定返回 { ok: true, result: {...} }。\n if (!isRecord(payload)) {\n return { responseKind: \"non_json\" };\n }\n // result 缺失时保留 ok，便于定位后端是否返回了异常结构。\n if (!isRecord(payload.result)) {\n return { ok: payload.ok ?? null, responseKind: \"json_without_result\" };\n }\n\n // startedAtMs/finishedAtMs 是后端任务耗时，不等于本次 HTTP 总耗时。\n const backendDurationMs = typeof payload.result.startedAtMs === \"number\" &&\n typeof payload.result.finishedAtMs === \"number\"\n ? Math.max(0, payload.result.finishedAtMs - payload.result.startedAtMs)\n : null;\n\n // 只记录聚合统计，不记录订单、退款单完整明细和任何密钥。\n return {\n ok: payload.ok ?? null,\n backendDurationMs,\n scannedCount: payload.result.scannedCount ?? null,\n succeededCount: payload.result.succeededCount ?? null,\n failedCount: payload.result.failedCount ?? null,\n stillPendingCount: payload.result.stillPendingCount ?? null,\n queryFailedCount: payload.result.queryFailedCount ?? null,\n alreadyFinishedCount: payload.result.alreadyFinishedCount ?? null,\n skippedAsBusy: payload.result.skippedAsBusy ?? null,\n errorSampleCount: Array.isArray(payload.result.errorSamples)\n ? payload.result.errorSamples.length\n : null,\n };\n}\n\nfunction buildFailureResponseSummary(\n payload: unknown,\n responseText: string,\n): Record {\n // JSON 错误响应优先提取 ok/error，避免写入完整响应体。\n if (isRecord(payload)) {\n return {\n ok: payload.ok ?? null,\n error: typeof payload.error === \"string\"\n ? truncateLogText(payload.error)\n : null,\n };\n }\n // 非 JSON 响应只截断记录文本。\n return {\n responseKind: \"non_json\",\n responseText: truncateLogText(responseText),\n };\n}\n\nexport default async function (_interval: ValTownInterval): Promise {\n // endpoint 是后端内部任务接口地址。\n const endpoint = readRequiredEnv(\"PAYMENT_REFUND_RECONCILE_ENDPOINT\");\n // token 只放 Authorization 请求头，不写进任何日志。\n const token = readRequiredEnv(\"PAYMENT_REFUND_RECONCILE_CRON_TOKEN\");\n // timeoutMs 控制本次 fetch 最长等待时间。\n const timeoutMs = readRequestTimeoutMs();\n // runStartedAtMs 用来计算 Val Town 侧观察到的 HTTP 总耗时。\n const runStartedAtMs = Date.now();\n // sentAtIso 发给后端，也用于跨系统对齐同一次触发。\n const sentAtIso = new Date(runStartedAtMs).toISOString();\n // endpointLabel 是脱敏后的接口标签。\n const endpointLabel = buildEndpointLogLabel(endpoint);\n // AbortController 到点后主动中断 fetch。\n const controller = new AbortController();\n // setTimeout 到点调用 abort，让 fetch 抛出 AbortError。\n const timeoutHandle = setTimeout(() => controller.abort(), timeoutMs);\n // 避免 HTTP 失败时 catch 块重复打印同一条错误。\n let failureLogged = false;\n\n console.info(\"payment refund reconcile cron started\", {\n endpoint: endpointLabel,\n sentAtIso,\n timeoutMs,\n });\n\n try {\n // Val Town 只负责 POST 触发；真正查支付商和改库都在后端完成。\n const response = await fetch(endpoint, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n trigger: \"valtown_cron\",\n sentAtIso,\n }),\n signal: controller.signal,\n });\n\n // 响应流只能读取一次，所以先统一读成文本。\n const responseText = await response.text();\n // 尝试解析 JSON，失败时返回 null。\n const responsePayload = parseJsonResponse(responseText);\n // requestDurationMs 是 Val Town 侧看到的完整请求耗时。\n const requestDurationMs = Date.now() - runStartedAtMs;\n\n if (!response.ok) {\n console.error(\"payment refund reconcile cron http failed\", {\n endpoint: endpointLabel,\n status: response.status,\n statusText: response.statusText,\n requestDurationMs,\n response: buildFailureResponseSummary(responsePayload, responseText),\n });\n failureLogged = true;\n throw new Error(\n `payment refund reconcile trigger failed: ${response.status} ${response.statusText} ${\n truncateLogText(responseText)\n }`,\n );\n }\n\n if (isRecord(responsePayload) && responsePayload.ok === false) {\n console.error(\"payment refund reconcile cron backend failed\", {\n endpoint: endpointLabel,\n status: response.status,\n requestDurationMs,\n response: buildFailureResponseSummary(responsePayload, responseText),\n });\n failureLogged = true;\n throw new Error(\n `payment refund reconcile backend returned ok=false: ${\n truncateLogText(String(responsePayload.error ?? \"unknown error\"))\n }`,\n );\n }\n\n console.info(\"payment refund reconcile cron completed\", {\n endpoint: endpointLabel,\n status: response.status,\n requestDurationMs,\n ...buildReconcileSummary(responsePayload),\n });\n } catch (error) {\n if (!failureLogged) {\n console.error(\"payment refund reconcile cron failed\", {\n endpoint: endpointLabel,\n requestDurationMs: Date.now() - runStartedAtMs,\n error: truncateLogText(normalizeErrorMessage(error)),\n });\n }\n // 重新抛出，让 Val Town 把本次运行标记为失败。\n throw error;\n } finally {\n // 成功失败都清理 timeout，避免函数结束后仍残留定时器。\n clearTimeout(timeoutHandle);\n }\n}\n",[129],"1a4821b2-5b3f-11f1-9be3-ee650bb23af1","group_payment_refund_auto_approve.cron.ts","1a482252-5b3f-11f1-9be3-ee650bb23af1",3,["D",1780046200712],"/**\n * Val Town Cron：触发后端退款申请自动处理任务。\n *\n * 需要在 Val Town Env Variables 配置：\n * - PAYMENT_REFUND_AUTO_APPROVE_ENDPOINT\n * 例：https://your-domain.com/internal/jobs/group-payment-refund-auto-approve\n * - PAYMENT_REFUND_AUTO_APPROVE_CRON_TOKEN\n * 与后端 RuntimeConfig.GROUP_PAYMENT_REFUND_AUTO_APPROVE_JOB_TOKEN 保持一致\n * - PAYMENT_REFUND_AUTO_APPROVE_REQUEST_TIMEOUT_MS（可选，默认 15000）\n */\ntype ValTownInterval = unknown;\n\nconst DEFAULT_REQUEST_TIMEOUT_MS = 15_000;\n\nfunction readRequiredEnv(name: string): string {\n const value = Deno.env.get(name)?.trim();\n if (!value) {\n throw new Error(`missing ${name}`);\n }\n return value;\n}\n\nfunction readRequestTimeoutMs(): number {\n const rawValue = Deno.env\n .get(\"PAYMENT_REFUND_AUTO_APPROVE_REQUEST_TIMEOUT_MS\")\n ?.trim();\n if (!rawValue) {\n return DEFAULT_REQUEST_TIMEOUT_MS;\n }\n\n const parsedValue = Number(rawValue);\n if (!Number.isFinite(parsedValue) || parsedValue <= 0) {\n throw new Error(\n \"PAYMENT_REFUND_AUTO_APPROVE_REQUEST_TIMEOUT_MS must be a positive number\",\n );\n }\n return Math.floor(parsedValue);\n}\n\nfunction isRecord(value: unknown): value is Record {\n return typeof value === \"object\" && value !== null && !Array.isArray(value);\n}\n\nfunction parseJsonResponse(responseText: string): unknown | null {\n if (responseText.trim().length === 0) {\n return null;\n }\n try {\n return JSON.parse(responseText);\n } catch {\n return null;\n }\n}\n\nfunction truncateLogText(value: string, maxLength = 1000): string {\n return value.length > maxLength ? `${value.slice(0, maxLength)}...` : value;\n}\n\nfunction normalizeErrorMessage(error: unknown): string {\n return error instanceof Error ? error.message : String(error);\n}\n\nfunction buildEndpointLogLabel(endpoint: string): string {\n try {\n const url = new URL(endpoint);\n return `${url.protocol}//${url.host}${url.pathname}`;\n } catch {\n return \"invalid-url\";\n }\n}\n\nfunction buildAutoApproveSummary(payload: unknown): Record {\n if (!isRecord(payload)) {\n return { responseKind: \"non_json\" };\n }\n if (!isRecord(payload.result)) {\n return { ok: payload.ok ?? null, responseKind: \"json_without_result\" };\n }\n\n const backendDurationMs = typeof payload.result.startedAtMs === \"number\" &&\n typeof payload.result.finishedAtMs === \"number\"\n ? Math.max(0, payload.result.finishedAtMs - payload.result.startedAtMs)\n : null;\n\n return {\n ok: payload.ok ?? null,\n backendDurationMs,\n scannedCount: payload.result.scannedCount ?? null,\n approvedCount: payload.result.approvedCount ?? null,\n refundSucceededCount: payload.result.refundSucceededCount ?? null,\n refundPendingCount: payload.result.refundPendingCount ?? null,\n refundFailedCount: payload.result.refundFailedCount ?? null,\n failedCount: payload.result.failedCount ?? null,\n skippedAsBusy: payload.result.skippedAsBusy ?? null,\n errorSampleCount: Array.isArray(payload.result.errorSamples)\n ? payload.result.errorSamples.length\n : null,\n };\n}\n\nfunction buildFailureResponseSummary(\n payload: unknown,\n responseText: string,\n): Record {\n if (isRecord(payload)) {\n return {\n ok: payload.ok ?? null,\n error: typeof payload.error === \"string\"\n ? truncateLogText(payload.error)\n : null,\n };\n }\n return {\n responseKind: \"non_json\",\n responseText: truncateLogText(responseText),\n };\n}\n\nexport default async function (_interval: ValTownInterval): Promise {\n const endpoint = readRequiredEnv(\"PAYMENT_REFUND_AUTO_APPROVE_ENDPOINT\");\n const token = readRequiredEnv(\"PAYMENT_REFUND_AUTO_APPROVE_CRON_TOKEN\");\n const timeoutMs = readRequestTimeoutMs();\n const runStartedAtMs = Date.now();\n const sentAtIso = new Date(runStartedAtMs).toISOString();\n const endpointLabel = buildEndpointLogLabel(endpoint);\n const controller = new AbortController();\n const timeoutHandle = setTimeout(() => controller.abort(), timeoutMs);\n let failureLogged = false;\n\n console.info(\"payment refund auto approve cron started\", {\n endpoint: endpointLabel,\n sentAtIso,\n timeoutMs,\n });\n\n try {\n const response = await fetch(endpoint, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n trigger: \"valtown_cron\",\n sentAtIso,\n }),\n signal: controller.signal,\n });\n\n const responseText = await response.text();\n const responsePayload = parseJsonResponse(responseText);\n const requestDurationMs = Date.now() - runStartedAtMs;\n\n if (!response.ok) {\n console.error(\"payment refund auto approve cron http failed\", {\n endpoint: endpointLabel,\n status: response.status,\n statusText: response.statusText,\n requestDurationMs,\n response: buildFailureResponseSummary(responsePayload, responseText),\n });\n failureLogged = true;\n throw new Error(\n `payment refund auto approve trigger failed: ${response.status} ${response.statusText} ${\n truncateLogText(responseText)\n }`,\n );\n }\n\n console.info(\"payment refund auto approve cron completed\", {\n endpoint: endpointLabel,\n requestDurationMs,\n result: buildAutoApproveSummary(responsePayload),\n });\n } catch (error) {\n if (!failureLogged) {\n console.error(\"payment refund auto approve cron failed\", {\n endpoint: endpointLabel,\n requestDurationMs: Date.now() - runStartedAtMs,\n error: normalizeErrorMessage(error),\n });\n }\n throw error;\n } finally {\n clearTimeout(timeoutHandle);\n }\n}\n",[136],"1a078814-5b3f-11f1-8eaa-ee650bb23af1","group_payment_confirmation_sweep.cron.ts","1a0788e6-5b3f-11f1-8eaa-ee650bb23af1",2,["D",1780046200285],"/**\n * Val Town Cron 触发器：\n * - 在 Val Town 中将该文件设置为 Cron；\n * - 每次触发时请求你的后端任务接口；\n * - 后端负责扫描 PENDING 订单、查询支付商、确认 PAID、商家入账。\n *\n * 需要在 Val Town Env Variables 中配置：\n * - PAYMENT_CONFIRMATION_SWEEP_ENDPOINT\n * 例如 https://your-domain.com/internal/jobs/group-payment-confirmation-sweep\n * - PAYMENT_CONFIRMATION_SWEEP_CRON_TOKEN\n * 与后端 GROUP_PAYMENT_CONFIRMATION_SWEEP_JOB_TOKEN 保持一致\n * - PAYMENT_CONFIRMATION_SWEEP_REQUEST_TIMEOUT_MS（可选，默认 15000）\n */\ntype ValTownInterval = unknown;\n\nconst DEFAULT_REQUEST_TIMEOUT_MS = 15_000;\n\nfunction readRequiredEnv(name: string): string {\n // Val Town 的环境变量通过 Deno.env.get 读取；trim 用来去掉复制粘贴时多出的空格。\n const value = Deno.env.get(name)?.trim();\n // 空字符串等同于未配置，因为 endpoint/token 都必须有真实内容。\n if (!value) {\n // 直接抛错能让 Val Town 把本次 cron 标记为失败，方便尽早发现配置问题。\n throw new Error(`missing ${name}`);\n }\n // 返回清理后的字符串，后续请求只使用这一份值。\n return value;\n}\n\nfunction readRequestTimeoutMs(): number {\n // 超时时间是可选配置；不填时使用项目约定的 15 秒。\n const rawValue = Deno.env\n .get(\"PAYMENT_CONFIRMATION_SWEEP_REQUEST_TIMEOUT_MS\")\n ?.trim();\n // 未配置时返回默认值，避免每个 Val Town 环境都必须额外填这个变量。\n if (!rawValue) {\n return DEFAULT_REQUEST_TIMEOUT_MS;\n }\n\n // Number 会把字符串数字转成 number，例如 \"15000\" -> 15000。\n const parsedValue = Number(rawValue);\n // 超时时间必须是正数；配置错误时直接失败，比静默使用坏配置更容易排查。\n if (!Number.isFinite(parsedValue) || parsedValue <= 0) {\n throw new Error(\n \"PAYMENT_CONFIRMATION_SWEEP_REQUEST_TIMEOUT_MS must be a positive number\",\n );\n }\n // Math.floor 去掉小数部分，保证传给 setTimeout 的是整数毫秒。\n return Math.floor(parsedValue);\n}\n\nfunction isRecord(value: unknown): value is Record {\n // typeof object 会包含 null，所以要额外排除 null。\n return typeof value === \"object\" && value !== null && !Array.isArray(value);\n}\n\nfunction parseJsonResponse(responseText: string): unknown | null {\n // 空响应体没有可解析内容，统一返回 null。\n if (responseText.trim().length === 0) {\n return null;\n }\n\n try {\n // JSON.parse 把后端返回的 JSON 字符串转成对象，便于提取任务统计字段。\n return JSON.parse(responseText);\n } catch {\n // 后端异常时可能返回纯文本或 HTML；这里不让日志解析影响原请求结果。\n return null;\n }\n}\n\nfunction truncateLogText(value: string, maxLength = 1000): string {\n // 日志只保留前 maxLength 个字符，避免异常响应体过大刷屏。\n return value.length > maxLength ? `${value.slice(0, maxLength)}...` : value;\n}\n\nfunction normalizeErrorMessage(error: unknown): string {\n // Error 对象优先取 message；其他类型转成字符串，保证日志字段稳定。\n return error instanceof Error ? error.message : String(error);\n}\n\nfunction buildEndpointLogLabel(endpoint: string): string {\n try {\n // URL 解析后只记录协议、域名和路径，不记录 query，避免误把敏感参数写入日志。\n const url = new URL(endpoint);\n // 这个标签用于排查打到了哪个后端接口，不包含 Authorization token。\n return `${url.protocol}//${url.host}${url.pathname}`;\n } catch {\n // endpoint 若不是合法 URL，fetch 稍后也会失败；日志里只标记为 invalid-url。\n return \"invalid-url\";\n }\n}\n\nfunction buildSweepSummary(payload: unknown): Record {\n // 后端约定返回 { ok: true, result: {...} }；不是对象时只标记响应类型。\n if (!isRecord(payload)) {\n return { responseKind: \"non_json\" };\n }\n\n // result 才是扫描任务的统计主体；缺失时保留 ok 字段辅助定位异常返回。\n if (!isRecord(payload.result)) {\n return {\n ok: payload.ok ?? null,\n responseKind: \"json_without_result\",\n };\n }\n\n // result 中的 startedAtMs/finishedAtMs 是后端任务自身耗时，不等于本次 HTTP 总耗时。\n const backendDurationMs = typeof payload.result.startedAtMs === \"number\" &&\n typeof payload.result.finishedAtMs === \"number\"\n ? Math.max(0, payload.result.finishedAtMs - payload.result.startedAtMs)\n : null;\n\n // 只记录聚合统计，不记录 token、数据库连接、支付商密钥或完整订单数据。\n return {\n ok: payload.ok ?? null,\n backendDurationMs,\n scannedCount: payload.result.scannedCount ?? null,\n confirmedCount: payload.result.confirmedCount ?? null,\n alreadyConfirmedCount: payload.result.alreadyConfirmedCount ?? null,\n waitingCount: payload.result.waitingCount ?? null,\n failedCount: payload.result.failedCount ?? null,\n skippedAsBusy: payload.result.skippedAsBusy ?? null,\n errorSampleCount: Array.isArray(payload.result.errorSamples)\n ? payload.result.errorSamples.length\n : null,\n };\n}\n\nfunction buildFailureResponseSummary(\n payload: unknown,\n responseText: string,\n): Record {\n // JSON 错误响应优先提取 ok/error，避免把完整响应体直接写入日志。\n if (isRecord(payload)) {\n return {\n ok: payload.ok ?? null,\n error: typeof payload.error === \"string\"\n ? truncateLogText(payload.error)\n : null,\n };\n }\n\n // 非 JSON 响应只截断记录文本，防止日志过长。\n return {\n responseKind: \"non_json\",\n responseText: truncateLogText(responseText),\n };\n}\n\nexport default async function (_interval: ValTownInterval): Promise {\n // endpoint 是后端内部任务接口地址，例如 /internal/jobs/group-payment-confirmation-sweep。\n const endpoint = readRequiredEnv(\"PAYMENT_CONFIRMATION_SWEEP_ENDPOINT\");\n // token 只放进 Authorization 请求头，不写入任何日志。\n const token = readRequiredEnv(\"PAYMENT_CONFIRMATION_SWEEP_CRON_TOKEN\");\n // timeoutMs 控制本次 fetch 最长等待多久，避免 cron 长时间挂起。\n const timeoutMs = readRequestTimeoutMs();\n // runStartedAtMs 用来计算 Val Town 端观察到的 HTTP 总耗时。\n const runStartedAtMs = Date.now();\n // sentAtIso 会发给后端，也会写入日志，方便跨系统对齐同一次触发。\n const sentAtIso = new Date(runStartedAtMs).toISOString();\n // endpointLabel 是脱敏后的接口标签，不包含 query 和 token。\n const endpointLabel = buildEndpointLogLabel(endpoint);\n // AbortController 用来在 timeoutMs 到达时主动中断 fetch。\n const controller = new AbortController();\n // setTimeout 到点后调用 abort，让 fetch 抛出 AbortError。\n const timeoutHandle = setTimeout(() => controller.abort(), timeoutMs);\n // 这个标记避免 HTTP 失败时 catch 块重复打印同一条错误日志。\n let failureLogged = false;\n\n console.info(\"payment confirmation sweep cron started\", {\n endpoint: endpointLabel,\n sentAtIso,\n timeoutMs,\n });\n\n try {\n // fetch 负责向后端发起 POST；真正扫描订单和入账仍由后端完成。\n const response = await fetch(endpoint, {\n method: \"POST\",\n headers: {\n // Bearer token 与后端 GROUP_PAYMENT_CONFIRMATION_SWEEP_JOB_TOKEN 对齐。\n Authorization: `Bearer ${token}`,\n // JSON body 明确声明 Content-Type，便于后端按 JSON 请求理解。\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n trigger: \"valtown_cron\",\n sentAtIso,\n }),\n signal: controller.signal,\n });\n\n // 无论成功失败都先读取响应体；响应流只能读一次，所以后面复用 responseText。\n const responseText = await response.text();\n // 尝试把响应体解析成 JSON，解析失败则返回 null。\n const responsePayload = parseJsonResponse(responseText);\n // requestDurationMs 是 Val Town 端看到的完整请求耗时。\n const requestDurationMs = Date.now() - runStartedAtMs;\n\n if (!response.ok) {\n // HTTP 非 2xx 表示后端拒绝或执行失败，需要让本次 cron 明确失败。\n console.error(\"payment confirmation sweep cron http failed\", {\n endpoint: endpointLabel,\n status: response.status,\n statusText: response.statusText,\n requestDurationMs,\n response: buildFailureResponseSummary(responsePayload, responseText),\n });\n // 标记已记录失败，catch 中就不再重复打印。\n failureLogged = true;\n throw new Error(\n `payment confirmation sweep trigger failed: ${response.status} ${response.statusText} ${\n truncateLogText(responseText)\n }`,\n );\n }\n\n if (isRecord(responsePayload) && responsePayload.ok === false) {\n // HTTP 2xx 但业务 ok=false 也按失败处理，避免定时任务误判成功。\n console.error(\"payment confirmation sweep cron backend failed\", {\n endpoint: endpointLabel,\n status: response.status,\n requestDurationMs,\n response: buildFailureResponseSummary(responsePayload, responseText),\n });\n // 标记已记录失败，catch 中就不再重复打印。\n failureLogged = true;\n throw new Error(\n `payment confirmation sweep backend returned ok=false: ${\n truncateLogText(String(responsePayload.error ?? \"unknown error\"))\n }`,\n );\n }\n\n // 成功日志只记录聚合指标，方便在 Val Town Runs 里快速判断任务效果。\n console.info(\"payment confirmation sweep cron completed\", {\n endpoint: endpointLabel,\n status: response.status,\n requestDurationMs,\n ...buildSweepSummary(responsePayload),\n });\n } catch (error) {\n if (!failureLogged) {\n // 网络错误、超时、URL 配置错误等会走这里。\n console.error(\"payment confirmation sweep cron failed\", {\n endpoint: endpointLabel,\n requestDurationMs: Date.now() - runStartedAtMs,\n error: truncateLogText(normalizeErrorMessage(error)),\n });\n }\n // 重新抛出错误，让 Val Town 把本次运行标记为失败。\n throw error;\n } finally {\n // 不管成功失败，都清理 timeout，避免函数结束后还有定时器残留。\n clearTimeout(timeoutHandle);\n }\n}\n",[143],"19c0c3a2-5b3f-11f1-9466-ee650bb23af1","group_auto_kick.cron.ts","19c0c460-5b3f-11f1-9466-ee650bb23af1",1,["D",1780046199823],"/**\n * Val Town Cron 触发器：\n * - 在 Val Town 中将该文件设置为 Cron（interval）；\n * - 每次触发时请求你的后端任务接口，让后端执行一轮自动踢人扫描。\n *\n * 需要在 Val Town Env Variables 中配置：\n * - AUTO_KICK_ENDPOINT 例如 https://your-domain.com/internal/jobs/group-auto-kick\n * - AUTO_KICK_CRON_TOKEN 与后端 GROUP_AUTO_KICK_JOB_TOKEN 保持一致\n * - AUTO_KICK_REQUEST_TIMEOUT_MS（可选，默认 15000）\n */\ntype ValTownInterval = unknown;\n\nexport default async function (_interval: ValTownInterval): Promise {\n const endpoint = Deno.env.get(\"AUTO_KICK_ENDPOINT\")?.trim();\n const token = Deno.env.get(\"AUTO_KICK_CRON_TOKEN\")?.trim();\n const timeoutMs = Number(\n Deno.env.get(\"AUTO_KICK_REQUEST_TIMEOUT_MS\")?.trim() ?? \"15000\",\n );\n\n if (!endpoint) {\n throw new Error(\"missing AUTO_KICK_ENDPOINT\");\n }\n if (!token) {\n throw new Error(\"missing AUTO_KICK_CRON_TOKEN\");\n }\n\n const controller = new AbortController();\n const timeoutHandle = setTimeout(() => controller.abort(), timeoutMs);\n try {\n const response = await fetch(endpoint, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n trigger: \"valtown_cron\",\n sentAtIso: new Date().toISOString(),\n }),\n signal: controller.signal,\n });\n\n if (!response.ok) {\n const responseText = await response.text();\n throw new Error(\n `auto-kick trigger failed: ${response.status} ${response.statusText} ${responseText}`,\n );\n }\n } finally {\n clearTimeout(timeoutHandle);\n }\n}\n",[150],"pulls","branches","forks","envVars",{"_163":40,"_165":40},"connections",{"_163":40,"_164":40},"count","unfilledCount","emptyCount",{"_18":149,"_20":150,"_113":151,"_115":-5,"_116":66,"_117":152,"_118":119,"_22":184,"_63":40,"_121":122,"_123":154,"_125":26,"_126":-5,"_172":185,"_84":186},{"_18":142,"_20":143,"_113":144,"_115":-5,"_116":66,"_117":145,"_118":119,"_22":181,"_63":40,"_121":122,"_123":147,"_125":26,"_126":-5,"_172":182,"_84":183},{"_18":135,"_20":136,"_113":137,"_115":-5,"_116":66,"_117":138,"_118":119,"_22":178,"_63":40,"_121":122,"_123":140,"_125":26,"_126":-5,"_172":179,"_84":180},{"_18":128,"_20":129,"_113":130,"_115":-5,"_116":66,"_117":131,"_118":119,"_22":175,"_63":40,"_121":122,"_123":133,"_125":26,"_126":-5,"_172":176,"_84":177},{"_18":111,"_20":112,"_113":114,"_115":-5,"_116":66,"_117":64,"_118":119,"_22":171,"_63":40,"_121":122,"_123":124,"_125":26,"_126":-5,"_172":173,"_84":174},["D",1780046201491],"children",[],[112],["D",1780046201087],[],[129],["D",1780046200712],[],[136],["D",1780046200285],[],[143],["D",1780046199823],[],[150],["D",1780045993309],{"_16":17,"_82":78},{"_16":17,"_75":76,"_77":78,"_33":34,"_79":80,"_81":26},{"_63":64,"_20":65,"_18":66,"_67":19,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":21,"_74":17},"ctx",{"_56":-5,"_103":224,"_225":226,"_227":228,"_229":26,"_230":26,"_231":26,"_232":119,"_233":-5,"_234":-7,"_235":-7,"_236":40,"_237":26,"_238":26,"_239":-5,"_240":26,"_241":26,"_242":26,"_243":-5},"ENV",{"_195":196,"_197":198,"_199":65,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223},"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"]

Search