[{"_1":2,"_183":-5,"_184":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":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","isTeamOrgMember","ENV",{"_38":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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","7721b06a805a6662fde743a1ec849364175efb5b","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":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",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_157":158,"_180":181,"_182":-5},"handle","colel","name","rust-nyc-talk-submissions","path","backend/autothread/logic.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":112,"_113":114,"_12":115,"_116":117,"_118":119,"_120":119,"_121":-5,"_122":33,"_14":123,"_124":-5,"_125":-5,"_126":127,"_128":127,"_129":130,"_131":130,"_132":130,"_133":127,"_134":127,"_23":135,"_138":139,"_143":144,"_156":20},"id","240b2d8a-4b86-11f0-94fc-76b3cceeab13","createdAt",["D",1750169995086],"deletedAt","legacyEnvVars","privacy","public","description","https://github.com/colelawrence/rust-nyc-talk-submissions","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/40c3f457-a412-4e39-8a41-e53f83b5a100/square512","c821e8f7-4cc4-4c23-96f1-319b8f33d4b7","pinnedFileId","1a35e418-5107-11f0-8713-f69ea79377d9","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","6b193d60-e165-45a9-869c-c3f886455f3e","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_136":137},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ6RVZCOExVNXBIT3FrVDh5a0VZQTNRRG5ycCJ9","org",{"_95":96,"_140":137,"_12":115,"_141":142},"avatar","tier","pro","branch",{"_145":146,"_97":45,"_103":147,"_148":104,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":98,"_155":96},"version",176,"240b9f7c-4b86-11f0-94fc-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":159,"_97":160,"_161":162,"_163":164,"_165":147,"_166":167,"_168":119,"_105":169,"_145":170,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"7f49c760-02dd-11f1-8d16-42dde27851f2","logic.ts","fileId","6e6475d2-fd3b-11f0-ba65-42dde27851f2","parentId","6e3fdb3c-fd3b-11f0-94eb-42dde27851f2","branchId","branchVersion",123,"latest",["D",1770328577165],1,"fileType","script","content","/**\n * Autothread Logic\n *\n * Core processing logic for the autothread system.\n * Extracted from autothread.cron.ts to be callable from both cron and debug endpoints.\n */\n\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport type { DiscordChannel, DiscordMessage, DiscordService } from \"../discord.ts\";\nimport { isThreadAlreadyExistsError } from \"../errors.ts\";\nimport type { AutothreadStore } from \"./store.ts\";\nimport type {\n AutothreadConfig,\n RunContext,\n RunEvent,\n PlannedAction,\n AIThreadResult,\n GateEvaluation,\n} from \"./types.ts\";\n\n// Constants\nconst COOLDOWN_WINDOW_MS = 10 * 60 * 1000; // 10 minutes\nconst MAX_THREADS_PER_CHANNEL_PER_WINDOW = 3;\nconst MAX_THREAD_NAME_LENGTH = 97; // Discord allows 100; leave room for \"...\"\nconst MIN_MESSAGE_LENGTH = 10;\n\n// Regex patterns for content filtering\nconst COMMAND_PREFIXES = /^[!/.]/;\nconst EMOJI_ONLY = /^[\\p{Emoji}\\s]+$/u;\nconst LINK_ONLY = /^(?\\s*)+$/;\nconst MENTION_ONLY = /^(<@!?\\d+>|<@&\\d+>|<#\\d+>|\\s)+$/;\n\n// Helper functions\nexport function sanitizeContent(content: string): string {\n return content.replace(/\\s+/g, \" \").trim();\n}\n\nexport function hasAutothreadTag(topic: string | null | undefined): boolean {\n if (!topic) return false;\n return /\\[autothread(?::[^\\]]+)?\\]/i.test(topic);\n}\n\nexport function hasQuietMode(topic: string | null | undefined): boolean {\n if (!topic) return false;\n return topic.toLowerCase().includes(\"[autothread:quiet]\");\n}\n\nexport function generateThreadName(msg: DiscordMessage): string {\n const sanitized = sanitizeContent(msg.content);\n\n if (sanitized.length >= MIN_MESSAGE_LENGTH) {\n if (sanitized.length > MAX_THREAD_NAME_LENGTH) {\n return sanitized.slice(0, MAX_THREAD_NAME_LENGTH - 3) + \"...\";\n }\n return sanitized;\n }\n\n const timestamp = new Date(msg.timestamp);\n const hours = timestamp.getUTCHours().toString().padStart(2, \"0\");\n const minutes = timestamp.getUTCMinutes().toString().padStart(2, \"0\");\n return `Discussion from ${msg.author.username} @ ${hours}:${minutes}`;\n}\n\n// Gate evaluation\nexport function evaluateMessageGates(msg: DiscordMessage): GateEvaluation {\n const gates: GateEvaluation[\"gates\"] = [];\n\n // Gate 1: Bot check\n const isBot = msg.author.bot === true;\n gates.push({\n name: \"not_bot\",\n passed: !isBot,\n reason: isBot ? \"Author is a bot\" : undefined,\n });\n\n // Gate 2: Already has thread\n const hasThread = !!msg.thread;\n gates.push({\n name: \"no_existing_thread\",\n passed: !hasThread,\n reason: hasThread ? \"Message already has a thread\" : undefined,\n });\n\n const sanitized = sanitizeContent(msg.content);\n\n // Gate 3: Minimum length\n const tooShort = sanitized.length < MIN_MESSAGE_LENGTH;\n gates.push({\n name: \"min_length\",\n passed: !tooShort,\n reason: tooShort\n ? `Content too short (${sanitized.length} < ${MIN_MESSAGE_LENGTH})`\n : undefined,\n });\n\n // Gate 4: Command prefix\n const isCommand = COMMAND_PREFIXES.test(sanitized);\n gates.push({\n name: \"not_command\",\n passed: !isCommand,\n reason: isCommand ? \"Starts with command prefix (!, /, .)\" : undefined,\n });\n\n // Gate 5: Emoji only\n const isEmojiOnly = EMOJI_ONLY.test(sanitized);\n gates.push({\n name: \"not_emoji_only\",\n passed: !isEmojiOnly,\n reason: isEmojiOnly ? \"Contains only emoji\" : undefined,\n });\n\n // Gate 6: Link only\n const isLinkOnly = LINK_ONLY.test(sanitized);\n gates.push({\n name: \"not_link_only\",\n passed: !isLinkOnly,\n reason: isLinkOnly ? \"Contains only links\" : undefined,\n });\n\n // Gate 7: Mention only\n const isMentionOnly = MENTION_ONLY.test(sanitized);\n gates.push({\n name: \"not_mention_only\",\n passed: !isMentionOnly,\n reason: isMentionOnly ? \"Contains only mentions\" : undefined,\n });\n\n return {\n messageId: msg.id,\n passed: gates.every((g) => g.passed),\n gates,\n };\n}\n\nexport function isValidMessageForThread(msg: DiscordMessage): boolean {\n return evaluateMessageGates(msg).passed;\n}\n\n// AI naming\nexport async function generateAIThreadName(\n targetMsg: DiscordMessage,\n contextMessages: DiscordMessage[],\n): Promise {\n try {\n const openai = new OpenAI();\n\n const MAX_CONTEXT_CHARS = 3500;\n let contextStr = \"\";\n\n for (const msg of contextMessages) {\n const line = `[${msg.author.username}]: ${sanitizeContent(msg.content)}\\n`;\n if (contextStr.length + line.length > MAX_CONTEXT_CHARS) break;\n contextStr += line;\n }\n\n const targetLine = `>>> [${targetMsg.author.username}]: ${sanitizeContent(targetMsg.content)}`;\n\n const prompt = `You are helping create a Discord thread. Based on the conversation context and the target message (marked with >>>), generate:\n1. A concise thread name (max 100 chars, no quotes, no newlines)\n2. A brief summary (2-4 bullet points) to post as the first message\n\nContext:\n${contextStr}\nTarget message to create thread from:\n${targetLine}\n\nReturn ONLY valid JSON, no markdown, no code fences:\n{\"thread_name\": \"...\", \"summary\": \"• Point 1\\\\n• Point 2\\\\n• Point 3\"}`;\n\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [{ role: \"user\", content: prompt }],\n max_tokens: 200,\n temperature: 0.7,\n });\n\n const responseText = completion.choices[0]?.message?.content?.trim();\n if (!responseText) {\n console.warn(`⚠️ [Autothread:AI] Empty response from OpenAI`);\n return null;\n }\n\n let jsonStr = responseText;\n const fenceMatch = jsonStr.match(/```(?:json)?\\s*([\\s\\S]*?)\\s*```/);\n if (fenceMatch) {\n jsonStr = fenceMatch[1];\n }\n const braceMatch = jsonStr.match(/\\{[\\s\\S]*\\}/);\n if (braceMatch) {\n jsonStr = braceMatch[0];\n }\n\n const parsed = JSON.parse(jsonStr);\n\n const threadName = sanitizeContent(String(parsed.thread_name || \"\")).slice(\n 0,\n 100,\n );\n if (!threadName) {\n console.warn(`⚠️ [Autothread:AI] Empty thread_name after sanitization`);\n return null;\n }\n\n let summary: string | null = null;\n if (parsed.summary) {\n const rawSummary = String(parsed.summary).trim();\n if (rawSummary.length > 0) {\n summary =\n rawSummary.length > 2000 ? rawSummary.slice(0, 1997) + \"...\" : rawSummary;\n }\n }\n\n console.log(`🤖 [Autothread:AI] Generated name: \"${threadName}\"`);\n return { threadName, summary };\n } catch (err) {\n console.error(\n `❌ [Autothread:AI] Failed to generate AI name:`,\n err instanceof Error ? err.message : err,\n );\n return null;\n }\n}\n\nexport function gatherContextMessages(\n allMessages: DiscordMessage[],\n targetMsgId: string,\n maxBefore = 4,\n): DiscordMessage[] {\n const targetIndex = allMessages.findIndex((m) => m.id === targetMsgId);\n if (targetIndex === -1) return [];\n const startIndex = Math.max(0, targetIndex - maxBefore);\n return allMessages.slice(startIndex, targetIndex);\n}\n\n// Event helper\nfunction createEvent(\n level: RunEvent[\"level\"],\n event: string,\n channelId?: string,\n messageId?: string,\n details?: Record,\n): RunEvent {\n return {\n timestamp: new Date().toISOString(),\n level,\n event,\n channelId,\n messageId,\n details,\n };\n}\n\n// Main processing function\nexport async function processChannel(\n channel: DiscordChannel,\n discord: DiscordService,\n store: AutothreadStore,\n config: AutothreadConfig,\n ctx: RunContext,\n): Promise<{ threadsCreated: number; actions: PlannedAction[] }> {\n const actions: PlannedAction[] = [];\n const lastMessageId = await store.getLastMessageId(channel.id);\n\n // Fetch messages using backward pagination\n const allMessages: DiscordMessage[] = [];\n let before: string | undefined = undefined;\n const MAX_PAGES = 3;\n\n for (let page = 0; page < MAX_PAGES; page++) {\n const batch = await discord.getMessages(channel.id, { before, limit: 100 });\n if (batch.length === 0) break;\n\n allMessages.push(...batch);\n const oldestInBatch = batch[batch.length - 1]!.id;\n\n if (lastMessageId && BigInt(oldestInBatch) <= BigInt(lastMessageId)) {\n break;\n }\n before = oldestInBatch;\n }\n\n // Sort oldest-first\n allMessages.sort((a, b) => (BigInt(a.id) < BigInt(b.id) ? -1 : 1));\n\n // Filter to new messages\n const newMessages = lastMessageId\n ? allMessages.filter((m) => BigInt(m.id) > BigInt(lastMessageId))\n : allMessages;\n\n ctx.events.push(\n createEvent(\"debug\", \"channel_scanned\", channel.id, undefined, {\n totalMessages: allMessages.length,\n newMessages: newMessages.length,\n lastMessageId,\n }),\n );\n\n if (newMessages.length === 0) {\n if (config.mode !== \"plan\") {\n await store.updateChannelState(channel.id, channel.name, channel.topic ?? null);\n }\n return { threadsCreated: 0, actions };\n }\n\n // Check cooldown\n const isQuietMode = hasQuietMode(channel.topic);\n const onCooldown = await store.isChannelOnCooldown(\n channel.id,\n COOLDOWN_WINDOW_MS,\n MAX_THREADS_PER_CHANNEL_PER_WINDOW,\n );\n\n if (onCooldown) {\n ctx.events.push(\n createEvent(\"info\", \"channel_on_cooldown\", channel.id),\n );\n actions.push({\n type: \"cooldown\",\n channelId: channel.id,\n channelName: channel.name,\n reason: `Cooldown: ${MAX_THREADS_PER_CHANNEL_PER_WINDOW} threads in ${COOLDOWN_WINDOW_MS / 60000} min`,\n });\n if (config.mode !== \"plan\") {\n await store.updateChannelState(channel.id, channel.name, channel.topic ?? null);\n }\n return { threadsCreated: 0, actions };\n }\n\n let threadsCreated = 0;\n let safelyProcessedUpTo = lastMessageId;\n\n for (const msg of newMessages) {\n if (ctx.threadsCreatedThisRun + threadsCreated >= config.maxThreadsPerRun) {\n ctx.events.push(createEvent(\"warn\", \"thread_cap_reached\"));\n break;\n }\n\n const gateEval = evaluateMessageGates(msg);\n if (!gateEval.passed) {\n const failedGate = gateEval.gates.find((g) => !g.passed);\n actions.push({\n type: \"skip\",\n channelId: channel.id,\n channelName: channel.name,\n messageId: msg.id,\n reason: failedGate?.reason ?? \"Failed gate evaluation\",\n });\n\n if (config.mode !== \"plan\") {\n await store.tryClaimMessage(channel.id, msg.id, \"skipped\");\n safelyProcessedUpTo = msg.id;\n }\n continue;\n }\n\n // In plan mode, just record what would happen\n if (config.mode === \"plan\") {\n const contextMsgs = config.enableAI\n ? gatherContextMessages(allMessages, msg.id, 4)\n : [];\n let threadName = generateThreadName(msg);\n let wouldPostSummary = false;\n\n if (config.enableAI) {\n const aiResult = await generateAIThreadName(msg, contextMsgs);\n if (aiResult) {\n threadName = aiResult.threadName;\n wouldPostSummary = !!aiResult.summary && !isQuietMode;\n }\n }\n\n actions.push({\n type: \"create_thread\",\n channelId: channel.id,\n channelName: channel.name,\n messageId: msg.id,\n threadName,\n wouldPostSummary,\n });\n\n ctx.events.push(\n createEvent(\"info\", \"would_create_thread\", channel.id, msg.id, {\n threadName,\n wouldPostSummary,\n }),\n );\n\n threadsCreated++;\n continue;\n }\n\n // Try to claim message\n const claimStatus = config.mode === \"dry_run\" ? \"dry_run\" : \"processing\";\n const claimed = await store.tryClaimMessage(channel.id, msg.id, claimStatus);\n\n if (!claimed) {\n safelyProcessedUpTo = msg.id;\n continue;\n }\n\n // Generate thread name\n const contextMsgs = config.enableAI\n ? gatherContextMessages(allMessages, msg.id, 4)\n : [];\n let threadName = generateThreadName(msg);\n let summary: string | null = null;\n\n if (config.enableAI) {\n const aiResult = await generateAIThreadName(msg, contextMsgs);\n if (aiResult) {\n threadName = aiResult.threadName;\n summary = aiResult.summary;\n }\n }\n\n // Dry-run: log but don't create thread\n if (config.mode === \"dry_run\") {\n ctx.events.push(\n createEvent(\"info\", \"dry_run_thread\", channel.id, msg.id, {\n threadName,\n hasSummary: !!summary,\n }),\n );\n actions.push({\n type: \"create_thread\",\n channelId: channel.id,\n channelName: channel.name,\n messageId: msg.id,\n threadName,\n wouldPostSummary: !!summary && !isQuietMode,\n });\n threadsCreated++;\n safelyProcessedUpTo = msg.id;\n continue;\n }\n\n // Live mode: actually create thread\n try {\n const thread = await discord.startThreadFromMessage(\n channel.id,\n msg.id,\n threadName,\n );\n\n if (summary && !isQuietMode) {\n try {\n await discord.sendMessage(thread.id, summary);\n } catch (summaryErr) {\n console.warn(\n `⚠️ [Autothread] Failed to post summary:`,\n summaryErr instanceof Error ? summaryErr.message : summaryErr,\n );\n }\n }\n\n await store.updateMessageStatus(channel.id, msg.id, \"created\", thread.id);\n await store.recordThreadCreated(channel.id);\n\n ctx.events.push(\n createEvent(\"info\", \"thread_created\", channel.id, msg.id, {\n threadId: thread.id,\n threadName,\n }),\n );\n\n actions.push({\n type: \"create_thread\",\n channelId: channel.id,\n channelName: channel.name,\n messageId: msg.id,\n threadName,\n });\n\n threadsCreated++;\n safelyProcessedUpTo = msg.id;\n } catch (err) {\n const errorMsg = err instanceof Error ? err.message : String(err);\n\n // Discord 160004: thread already exists for this message — treat as success\n if (isThreadAlreadyExistsError(err)) {\n console.log(\n `ℹ️ [Autothread] Thread already exists for message ${msg.id} in #${channel.name}, marking as created`,\n );\n await store.updateMessageStatus(channel.id, msg.id, \"created\", undefined);\n ctx.events.push(\n createEvent(\"info\", \"thread_already_exists\", channel.id, msg.id),\n );\n safelyProcessedUpTo = msg.id;\n continue;\n }\n\n ctx.errorsThisRun++;\n ctx.lastError = errorMsg;\n\n await store.updateMessageStatus(channel.id, msg.id, \"error\", undefined, errorMsg);\n\n ctx.events.push(\n createEvent(\"error\", \"thread_creation_failed\", channel.id, msg.id, {\n error: errorMsg,\n }),\n );\n\n actions.push({\n type: \"error\",\n channelId: channel.id,\n channelName: channel.name,\n messageId: msg.id,\n reason: errorMsg,\n });\n\n safelyProcessedUpTo = msg.id;\n }\n }\n\n // Update cursor\n if (config.mode !== \"plan\" && safelyProcessedUpTo) {\n await store.updateChannelState(\n channel.id,\n channel.name,\n channel.topic ?? null,\n safelyProcessedUpTo,\n );\n }\n\n return { threadsCreated, actions };\n}\n\n// Poll and process all channels\nexport async function pollAndProcessMessages(\n discord: DiscordService,\n store: AutothreadStore,\n config: AutothreadConfig,\n ctx: RunContext,\n): Promise {\n const allChannels = await discord.listGuildChannels();\n const textChannels = allChannels.filter((ch) => ch.type === 0);\n\n let autothreadChannels = textChannels.filter(\n (ch) => hasAutothreadTag(ch.topic),\n );\n\n if (autothreadChannels.length === 0) {\n console.log(\n `ℹ️ [Autothread] No channels with [autothread] tag found. Checked ${textChannels.length} text channels. ` +\n `Add \"[autothread]\" to a channel's topic to enable. Sample topics: ${textChannels.slice(0, 5).map((ch) => `#${ch.name}: \"${ch.topic ?? \"(empty)\"}\"`).join(\", \")}`,\n );\n ctx.events.push(\n createEvent(\"info\", \"no_autothread_channels\", undefined, undefined, {\n textChannelCount: textChannels.length,\n sampleChannels: textChannels.slice(0, 5).map((c) => ({\n id: c.id,\n name: c.name,\n topic: c.topic ?? null,\n })),\n }),\n );\n return [];\n }\n\n if (config.channelAllowlist) {\n const beforeAllowlist = autothreadChannels.length;\n autothreadChannels = autothreadChannels.filter((ch) =>\n config.channelAllowlist!.includes(ch.id),\n );\n if (autothreadChannels.length === 0 && beforeAllowlist > 0) {\n console.warn(\n `⚠️ [Autothread] ${beforeAllowlist} channels have [autothread] tag but none match the allowlist: ${config.channelAllowlist.join(\",\")}`,\n );\n }\n }\n\n autothreadChannels = autothreadChannels.slice(0, config.maxChannelsPerRun);\n\n ctx.events.push(\n createEvent(\"info\", \"poll_started\", undefined, undefined, {\n channelCount: autothreadChannels.length,\n channels: autothreadChannels.map((c) => ({ id: c.id, name: c.name, topic: c.topic })),\n }),\n );\n\n console.log(\n `🔍 [Autothread] Found ${autothreadChannels.length} autothread channel(s): ${autothreadChannels.map((c) => `#${c.name}`).join(\", \")}`,\n );\n\n if (autothreadChannels.length === 0) {\n return [];\n }\n\n const allActions: PlannedAction[] = [];\n\n for (const channel of autothreadChannels) {\n if (ctx.threadsCreatedThisRun >= config.maxThreadsPerRun) {\n break;\n }\n\n try {\n const { threadsCreated, actions } = await processChannel(\n channel,\n discord,\n store,\n config,\n ctx,\n );\n ctx.threadsCreatedThisRun += threadsCreated;\n allActions.push(...actions);\n } catch (err) {\n const errorMsg = err instanceof Error ? err.message : String(err);\n ctx.errorsThisRun++;\n ctx.lastError = errorMsg;\n ctx.events.push(\n createEvent(\"error\", \"channel_processing_failed\", channel.id, undefined, {\n error: errorMsg,\n }),\n );\n }\n }\n\n return allActions;\n}\n","deleted","label",[178,179,160],"backend","autothread","permalink","https://www.val.town/x/colel/rust-nyc-talk-submissions/code/backend/autothread/logic.ts","extension","actionData","errors"]