[{"_1":2,"_189":-5,"_190":-5},"loaderData",{"_3":4,"_96":97},"root",{"_5":6,"_37":38,"_69":70},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20,"_36":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","isHigherTownieTier","ENV",{"_39":40,"_41":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","efeea19332d9bfe7de1049656877be9cb817c45f","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_71":72},"__internal_clerk_state",{"_73":74,"_75":48,"_76":77,"_78":77,"_79":20,"_80":77,"_81":77,"_82":77,"_83":77,"_84":85,"_94":20,"_95":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_86":20,"_19":20,"_87":77,"_88":89,"_90":77,"_91":48,"_92":20,"_93":77},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_98":99,"_100":101,"_102":103,"_104":105,"_162":163,"_186":187,"_188":-5},"handle","catalloc","name","catnip","path","discord/helpers/cron.ts","project",{"_106":107,"_100":101,"_108":109,"_110":-5,"_111":20,"_112":113,"_114":115,"_116":-5,"_12":117,"_118":-5,"_119":20,"_120":-5,"_121":-5,"_122":33,"_14":123,"_124":125,"_126":127,"_128":129,"_130":-5,"_131":132,"_133":132,"_134":135,"_136":135,"_137":135,"_138":132,"_139":132,"_23":140,"_143":144,"_148":149,"_161":20},"id","4db147e2-1d6c-11f1-9a9a-42dde27851f2","createdAt",["D",1773248642232],"deletedAt","legacyEnvVars","privacy","public","description","Open source Discord bot template built for Val Town","imageUrl","d06b6c80-f3a1-11ef-89a3-8735e07158f4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","e03963fb-ecc4-48fb-bc25-0173a8b9a8c8","tursoName","4db147e21d6c11f19a9a42dde27851f2","tursoHostname","4db147e21d6c11f19a9a42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1776211266606],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_98":99,"_141":142},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/0478d851-5bca-4d5e-6593-fb952af01c00/square512","org",{"_98":99,"_145":142,"_12":117,"_146":147},"avatar","tier","pro","branch",{"_150":151,"_100":46,"_106":152,"_153":107,"_154":-5,"_155":-5,"_156":-5,"_157":-5,"_158":-5,"_159":101,"_160":99},"version",358,"4db1f610-1d6c-11f1-9a9a-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_106":164,"_100":165,"_166":167,"_168":169,"_170":152,"_171":172,"_173":174,"_108":175,"_150":176,"_177":178,"_179":180,"_181":20,"_182":-5,"_102":183},"c45ab28e-1fc4-11f1-98b7-42dde27851f2","cron.ts","fileId","9ca84440-1d6c-11f1-87f5-42dde27851f2","parentId","9475eb06-1d6c-11f1-ac6f-42dde27851f2","branchId","branchVersion",351,"latest",true,["D",1773506539341],3,"fileType","script","content","/**\n * discord/helpers/cron.ts\n *\n * Shared cron job lifecycle and delivery-with-retry helpers.\n * Reduces boilerplate in reminders, scheduled-messages, giveaways, polls, tickets cron files.\n */\n\nimport { kv } from \"../persistence/kv.ts\";\nimport { createLogger, finalizeAllLoggers, type DiscordLogger } from \"../webhook/logger.ts\";\nimport { isPathMuted, MUTED_PATHS_KEY } from \"../persistence/log-config.ts\";\n\nexport interface CronOpts {\n name: string;\n /** Path for mute checking, e.g. \"cron:reminders\". If omitted, muting is not checked. */\n mutePath?: string;\n prefix: string;\n maxDue?: number;\n concurrency?: number;\n process: (entry: { key: string; value: unknown }, logger: DiscordLogger) => Promise;\n}\n\n/**\n * Standard cron lifecycle: create logger, list due items, process with concurrency limit, finalize.\n */\nexport async function runCron(opts: CronOpts): Promise {\n const logger = createLogger(opts.name);\n const start = Date.now();\n try {\n const maxDueLimit = opts.maxDue ?? 100;\n let entries: Array<{ key: string; value: unknown }>;\n\n if (opts.mutePath) {\n // Single query: fetch muted-paths config + due items together\n const { config, due } = await kv.listDueWithConfig(\n MUTED_PATHS_KEY,\n Date.now(),\n opts.prefix,\n maxDueLimit,\n );\n try {\n logger.muted = isPathMuted(opts.mutePath, config ?? []);\n } catch { /* proceed unmuted */ }\n entries = due;\n } else {\n entries = await kv.listDue(Date.now(), opts.prefix, maxDueLimit);\n }\n\n const concurrency = opts.concurrency ?? 5;\n for (let i = 0; i < entries.length; i += concurrency) {\n const batch = entries.slice(i, i + concurrency);\n const results = await Promise.allSettled(\n batch.map((entry) => opts.process(entry, logger)),\n );\n for (const r of results) {\n if (r.status === \"rejected\") {\n logger.error(\"Item processing failed:\", r.reason);\n }\n }\n }\n\n if (entries.length > 0) {\n logger.info(`Run complete: ${entries.length} item(s) processed in ${Date.now() - start}ms`);\n if (entries.length >= maxDueLimit) {\n logger.warn(`Processed ${maxDueLimit} items (max) — more may be pending for next run`);\n }\n }\n } catch (err) {\n logger.error(\"Cron run failed:\", err);\n } finally {\n await finalizeAllLoggers();\n }\n}\n\nexport interface DeliverWithRetryOpts {\n entry: { key: string; value: unknown };\n deliver: (value: any) => Promise<{ ok: boolean; status?: number; error?: string }>;\n validate?: (value: any) => boolean;\n logger: DiscordLogger;\n entityLabel: string;\n maxRetries?: number;\n backoffBaseMs?: number;\n permanentFailureCodes?: number[];\n}\n\n/**\n * Claim-delete + delivery + backoff retry pattern for cron jobs.\n * Used by reminders and scheduled-messages cron.\n */\nexport async function deliverWithRetry(opts: DeliverWithRetryOpts): Promise {\n const {\n entry, deliver, validate, logger, entityLabel,\n maxRetries = 5,\n backoffBaseMs = 60_000,\n permanentFailureCodes = [403, 404],\n } = opts;\n\n const value = entry.value as Record;\n\n if (validate && !validate(value)) {\n logger.warn(`Deleting malformed ${entityLabel}: ${entry.key}`);\n await kv.claimDelete(entry.key).catch(() => {});\n return;\n }\n\n let claimed: boolean;\n try {\n claimed = await kv.claimDelete(entry.key);\n } catch (err) {\n logger.error(`Failed to claim ${entityLabel} ${entry.key}: ${err instanceof Error ? err.message : String(err)}`);\n return;\n }\n if (!claimed) return;\n\n try {\n const result = await deliver(value);\n if (result.ok) {\n // Delivered successfully — already deleted by claimDelete\n } else if (result.status && permanentFailureCodes.includes(result.status)) {\n logger.warn(`${capitalize(entityLabel)} ${entry.key} dropped: channel inaccessible (${result.status})`);\n } else {\n await reinsertWithBackoff(entry, value, logger, entityLabel, maxRetries, backoffBaseMs);\n }\n } catch (err) {\n logger.error(`Failed to deliver ${entityLabel} ${entry.key}:`, err);\n await reinsertWithBackoff(entry, value, logger, entityLabel, maxRetries, backoffBaseMs);\n }\n}\n\nasync function reinsertWithBackoff(\n entry: { key: string },\n value: Record,\n logger: DiscordLogger,\n entityLabel: string,\n maxRetries: number,\n backoffBaseMs: number,\n): Promise {\n const retryCount = ((value.retryCount as number) ?? 0) + 1;\n if (retryCount < maxRetries) {\n await kv.set(entry.key, { ...value, retryCount }, Date.now() + backoffBaseMs * Math.pow(2, retryCount - 1));\n } else {\n logger.warn(`${capitalize(entityLabel)} ${entry.key} dropped after ${maxRetries} retries`);\n }\n}\n\nfunction capitalize(s: string): string {\n return s.charAt(0).toUpperCase() + s.slice(1);\n}\n","deleted","label",[184,185,165],"discord","helpers","permalink","https://www.val.town/x/catalloc/catnip/code/discord/helpers/cron.ts","extension","actionData","errors"]