[{"_1":2,"_188":-5,"_189":-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,"_185":186,"_187":-5},"handle","catalloc","name","catnip","path","services/livestreams.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},"230e11e4-1e3b-11f1-9c08-42dde27851f2","livestreams.cron.ts","fileId","9508cc6e-1d6c-11f1-95a1-42dde27851f2","parentId","940748e0-1d6c-11f1-9109-42dde27851f2","branchId","branchVersion",348,"latest",true,["D",1773337475861],1,"fileType","interval","content","/**\n * services/livestreams.cron.ts\n *\n * Cron job that polls streaming platforms and posts Discord embeds\n * when tracked streamers go live. Schedule in Val Town to run every 2-5 minutes.\n *\n * Algorithm:\n * 1. Load all stream trackers from KV\n * 2. Group by platform, check each (Twitch batched, YouTube/Kick parallel)\n * 3. Compare against stored live state — post notification on new live, clear on offline\n */\n\nimport { kv } from \"../discord/persistence/kv.ts\";\nimport {\n type StreamTracker,\n streamLiveKey,\n} from \"../discord/interactions/commands/livestream.ts\";\nimport {\n type Platform,\n type StreamStatus,\n checkTwitchStreams,\n checkYouTubeStream,\n checkKickStream,\n} from \"../discord/services/stream-platforms.ts\";\nimport { discordBotFetch } from \"../discord/discord-api.ts\";\nimport { createLogger, finalizeAllLoggers } from \"../discord/webhook/logger.ts\";\nimport { logConfig, isPathMuted } from \"../discord/persistence/log-config.ts\";\nimport { CONFIG } from \"../discord/constants.ts\";\n\nconst logger = createLogger(\"LivestreamCron\");\n\nconst MAX_TRACKERS_PER_RUN = 200;\nconst CONCURRENCY = 5;\n\ninterface StreamLiveState {\n title: string;\n url: string;\n notifiedAt: string;\n}\n\nconst PLATFORM_COLORS: Record = {\n twitch: 0x9146ff,\n youtube: 0xff0000,\n kick: 0x53fc18,\n};\n\nconst PLATFORM_LABELS: Record = {\n twitch: \"Twitch\",\n youtube: \"YouTube\",\n kick: \"Kick\",\n};\n\n/** Run up to `limit` async tasks at a time. */\nasync function parallelMap(\n items: T[],\n fn: (item: T) => Promise,\n limit: number,\n): Promise[]> {\n const results: PromiseSettledResult[] = [];\n let index = 0;\n\n async function worker() {\n while (index < items.length) {\n const i = index++;\n try {\n const value = await fn(items[i]);\n results[i] = { status: \"fulfilled\", value };\n } catch (reason) {\n results[i] = { status: \"rejected\", reason };\n }\n }\n }\n\n const workers = Array.from({ length: Math.min(limit, items.length) }, () => worker());\n await Promise.all(workers);\n return results;\n}\n\nconst COOLDOWN_MS = 5 * 60 * 1000; // 5-minute renotification cooldown\n\nasync function processTracker(\n tracker: StreamTracker,\n status: StreamStatus,\n): Promise<\"notified\" | \"cleared\" | \"noop\"> {\n const liveKey = streamLiveKey(tracker.guildId, tracker.platform, tracker.username);\n const cooldownKey = `stream_cooldown:${tracker.guildId}:${tracker.platform}:${tracker.username.toLowerCase()}`;\n\n if (status.isLive) {\n // Attempt atomic claim: only write if no live state exists yet\n let wonClaim = false;\n const liveState: StreamLiveState = {\n title: status.title || \"\",\n url: status.streamUrl,\n notifiedAt: new Date().toISOString(),\n };\n try {\n await kv.update(liveKey, (current) => {\n if (current) return current; // already live — no-op\n wonClaim = true;\n return liveState;\n });\n } catch {\n // CAS exhaustion — another cron instance is racing; skip this cycle\n return \"noop\";\n }\n\n if (!wonClaim) return \"noop\"; // already had live state\n\n // Check renotification cooldown\n const cooldown = await kv.get<{ clearedAt: number }>(cooldownKey);\n if (cooldown && Date.now() - cooldown.clearedAt < COOLDOWN_MS) {\n return \"noop\"; // within cooldown window — skip notification\n }\n\n // Post notification\n const embed = {\n author: {\n name: `${tracker.displayName} is now live!`,\n url: status.streamUrl,\n },\n title: status.title || \"Live Stream\",\n url: status.streamUrl,\n color: PLATFORM_COLORS[tracker.platform],\n footer: { text: PLATFORM_LABELS[tracker.platform] },\n timestamp: new Date().toISOString(),\n ...(status.thumbnailUrl ? { image: { url: status.thumbnailUrl } } : {}),\n };\n\n const result = await discordBotFetch(\"POST\", `channels/${tracker.channelId}/messages`, {\n embeds: [embed],\n });\n\n if (!result.ok) {\n logger.error(`Failed to notify ${tracker.displayName} (${tracker.platform}) in guild ${tracker.guildId}: ${result.error}`);\n // Clean up the live state we just wrote since notification failed\n try {\n await kv.delete(liveKey);\n } catch (deleteErr) {\n logger.error(`Failed to clean up live state ${liveKey}:`, deleteErr);\n }\n return \"noop\";\n }\n\n return \"notified\";\n } else {\n // Offline — clear live state if it existed\n const claimed = await kv.claimDelete(liveKey);\n if (claimed) {\n // Set cooldown so rapid online/offline cycles don't spam\n await kv.set(cooldownKey, { clearedAt: Date.now() }, Date.now() + COOLDOWN_MS);\n return \"cleared\";\n }\n return \"noop\";\n }\n}\n\nexport default async function () {\n // Check if this cron path is muted\n try {\n const mutedPaths = await logConfig.getMutedPaths();\n logger.muted = isPathMuted(\"cron:livestreams\", mutedPaths);\n } catch { /* proceed unmuted */ }\n\n try {\n const entries = await kv.list(\"stream:\", MAX_TRACKERS_PER_RUN);\n if (entries.length === 0) return;\n\n // Group trackers by platform\n const byPlatform: Record = {\n twitch: [],\n youtube: [],\n kick: [],\n };\n\n for (const entry of entries) {\n const tracker = entry.value as StreamTracker;\n if (!tracker?.platform || !tracker?.username || !tracker?.channelId) continue;\n if (byPlatform[tracker.platform]) {\n byPlatform[tracker.platform].push(tracker);\n }\n }\n\n let notified = 0;\n let cleared = 0;\n let errors = 0;\n\n // --- Twitch (batched) ---\n if (byPlatform.twitch.length > 0 && CONFIG.twitchClientId && CONFIG.twitchClientSecret) {\n try {\n const usernames = byPlatform.twitch.map((t) => t.username);\n const statuses = await checkTwitchStreams(usernames);\n\n const results = await parallelMap(\n byPlatform.twitch,\n async (tracker) => {\n const status = statuses.get(tracker.username.toLowerCase());\n if (!status) return \"noop\" as const;\n return await processTracker(tracker, status);\n },\n CONCURRENCY,\n );\n for (const r of results) {\n if (r.status === \"fulfilled\") {\n if (r.value === \"notified\") notified++;\n else if (r.value === \"cleared\") cleared++;\n } else {\n errors++;\n logger.error(\"Twitch check failed:\", r.reason);\n }\n }\n } catch (err) {\n errors++;\n logger.error(\"Twitch batch check failed:\", err);\n }\n }\n\n // --- YouTube (per-channel, parallel) ---\n if (byPlatform.youtube.length > 0 && CONFIG.youtubeApiKey) {\n const results = await parallelMap(\n byPlatform.youtube,\n async (tracker) => {\n const status = await checkYouTubeStream(tracker.username);\n return await processTracker(tracker, status);\n },\n CONCURRENCY,\n );\n for (const r of results) {\n if (r.status === \"fulfilled\") {\n if (r.value === \"notified\") notified++;\n else if (r.value === \"cleared\") cleared++;\n } else {\n errors++;\n logger.error(\"YouTube check failed:\", r.reason);\n }\n }\n }\n\n // --- Kick (per-user, parallel) ---\n if (byPlatform.kick.length > 0) {\n const results = await parallelMap(\n byPlatform.kick,\n async (tracker) => {\n const status = await checkKickStream(tracker.username);\n return await processTracker(tracker, status);\n },\n CONCURRENCY,\n );\n for (const r of results) {\n if (r.status === \"fulfilled\") {\n if (r.value === \"notified\") notified++;\n else if (r.value === \"cleared\") cleared++;\n } else {\n errors++;\n logger.error(\"Kick check failed:\", r.reason);\n }\n }\n }\n\n const total = byPlatform.twitch.length + byPlatform.youtube.length + byPlatform.kick.length;\n logger.info(\n `Run complete: ${total} tracker(s) — ${notified} notified, ${cleared} cleared, ${errors} error(s)`,\n );\n } finally {\n await finalizeAllLoggers();\n }\n}\n","deleted","label",[184,165],"services","permalink","https://www.val.town/x/catalloc/catnip/code/services/livestreams.cron.ts","extension","actionData","errors"]