[{"_1":2,"_170":-5,"_171":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","notificationCount",0,"flagDenols","ENV",{"_36":37,"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","2f607f7b74b4e52529fb75176d403d8b5b284eb1","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_148":149,"_167":168,"_169":-5},"handle","salon","name","mandate","path","agents.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":113,"_114":115,"_116":117,"_118":32,"_14":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":129,"_132":133,"_135":136,"_147":20},"id","5dfdba8e-2c6a-11f0-8699-569c3dd06744","createdAt",["D",1746749580352],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","b12b39d0-1fe4-11f0-9001-4fc1852e0e06","pinnedFileId","80211736-2c70-11f0-b8c8-569c3dd06744","pinPreview",true,"screenshotVersion",96,"likeCount","45a0d482-0d4d-4887-9bc4-d08243be47a9","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_130":131},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ3NnI5NzZ4ajBmUUZoTUxYdExrMmZYWnAzdyJ9","org",{"_93":94,"_134":131},"avatar","branch",{"_137":117,"_95":43,"_101":138,"_139":102,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},"version","5dfe05ac-2c6a-11f0-8699-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":150,"_95":98,"_151":152,"_153":-5,"_154":138,"_155":156,"_157":115,"_103":158,"_137":159,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"04c5dcc4-2d16-11f0-99f8-569c3dd06744","fileId","ce1b275c-2c6a-11f0-b231-569c3dd06744","parentId","branchId","branchVersion",56,"latest",["D",1746823304090],12,"fileType","script","content","// agents.ts\nimport { XMLParser } from \"https://esm.sh/fast-xml-parser@4.2.5\"; // For parsing RSS/Atom feeds\nimport { AgentContext, AgentInput, AgentOutput } from \"https://esm.town/v/salon/mandate/interfaces.ts\";\nimport { fetch } from \"https://esm.town/v/std/fetch\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\n\n// Summarizer Agent (unchanged, but shown for completeness)\nexport async function summarizerAgent(\n input: AgentInput<{ textToSummarize: string }>,\n context: AgentContext,\n): Promise> {\n const { mandateId, taskId, payload } = input;\n const { log } = context;\n log(\"INFO\", \"SummarizerAgent\", `Start`);\n\n try {\n if (!payload || typeof payload.textToSummarize !== \"string\") {\n throw new Error(\"Invalid input: \\\"textToSummarize\\\" missing or not a string.\");\n }\n if (payload.textToSummarize.trim() === \"\") {\n log(\"WARN\", \"SummarizerAgent\", \"Input text empty, returning empty summary.\");\n return { mandateId, correlationId: taskId, payload: { summary: \"\" } };\n }\n\n const openai = new OpenAI();\n\n log(\"INFO\", \"SummarizerAgent\", \"Generating summary with OpenAI...\");\n const completion = await openai.chat.completions.create({\n messages: [\n {\n role: \"system\",\n content: \"You are an expert summarization assistant. Provide a concise summary.\",\n },\n { role: \"user\", content: `Please summarize the following text:\\n\\n${payload.textToSummarize}` },\n ],\n temperature: 0.5,\n });\n\n const summary = completion.choices[0]?.message?.content?.trim() ?? \"Could not generate summary.\";\n\n if (summary === \"Could not generate summary.\") {\n log(\"WARN\", \"SummarizerAgent\", \"OpenAI did not return a valid summary content.\");\n }\n\n log(\"SUCCESS\", \"SummarizerAgent\", `Complete`);\n return { mandateId, correlationId: taskId, payload: { summary } };\n } catch (e: any) {\n log(\"ERROR\", \"SummarizerAgent\", `Failed: ${e.message}`, e);\n return { mandateId, correlationId: taskId, payload: { summary: \"\" }, error: e.message };\n }\n}\n\n// Fetch Agent (Now fetches and parses RSS feeds for headlines)\nexport async function fetchAgent(\n input: AgentInput<{ url_from_input?: string; maxHeadlines?: number }>, // Added maxHeadlines\n context: AgentContext,\n): Promise<\n AgentOutput<{\n data: {\n headlines: Array<{ title: string; link: string; summary: string; publishedDate: string }>;\n feedTitle: string;\n sourceUrl: string;\n message?: string;\n };\n rawText?: string;\n contentType?: string | null;\n }>\n> {\n const { mandateId, taskId, payload } = input;\n const { log, config } = context;\n\n const DEFAULT_RSS_URL = \"https://feeds.npr.org/1001/rss.xml\"; // NPR Top Stories as default\n const urlToFetch = payload?.url_from_input ?? config?.rssFeedUrl ?? DEFAULT_RSS_URL;\n const maxHeadlines = Number(payload?.maxHeadlines ?? config?.maxHeadlines ?? 5);\n\n log(\"INFO\", \"FetchAgent\", `Workspaceing headlines from ${urlToFetch}, max: ${maxHeadlines}`);\n\n try {\n const resp = await fetch(urlToFetch);\n const fetchedContentType = resp.headers.get(\"content-type\")?.toLowerCase() || \"\";\n const rawResponseText = await resp.text();\n\n if (!resp.ok) {\n let errorBody = rawResponseText;\n if (errorBody.length > 500) errorBody = errorBody.substring(0, 500) + \"...\";\n throw new Error(`Workspace failed: ${resp.status} ${resp.statusText}. URL: ${urlToFetch}. Body: ${errorBody}`);\n }\n\n let headlines: Array<{ title: string; link: string; summary: string; publishedDate: string }> = [];\n let feedTitle = \"N/A\";\n let parsedSuccessfully = false;\n let parsingMessage: string | undefined = undefined;\n\n // Attempt to parse as RSS/Atom if content type suggests XML, or if it's a known RSS URL pattern/default\n if (\n fetchedContentType.includes(\"xml\") || fetchedContentType.includes(\"rss\") || urlToFetch.endsWith(\".xml\")\n || urlToFetch.endsWith(\".rss\") || urlToFetch === DEFAULT_RSS_URL\n ) {\n try {\n const parser = new XMLParser({\n ignoreAttributes: false, // Keep attributes for links, etc.\n htmlEntities: true, // Decode HTML entities like &\n removeNSPrefix: true, // Remove namespace prefixes for easier access (e.g. dc:creator -> creator)\n });\n const feedJson = parser.parse(rawResponseText);\n\n if (feedJson.rss && feedJson.rss.channel) { // Standard RSS structure\n feedTitle = typeof feedJson.rss.channel.title === \"string\"\n ? feedJson.rss.channel.title\n : JSON.stringify(feedJson.rss.channel.title);\n const items = Array.isArray(feedJson.rss.channel.item)\n ? feedJson.rss.channel.item\n : (feedJson.rss.channel.item ? [feedJson.rss.channel.item] : []);\n\n for (const item of items.slice(0, maxHeadlines)) {\n headlines.push({\n title: (item.title || \"No title\").toString(),\n link: (item.link || (typeof item.link === \"object\" ? item.link[\"@_href\"] : item.link) || \"#\").toString(),\n summary: (item.description || \"\").toString(),\n publishedDate: (item.pubDate || \"\").toString(),\n });\n }\n parsedSuccessfully = headlines.length > 0;\n } else if (feedJson.feed) { // Atom feed structure (heuristic)\n feedTitle = (typeof feedJson.feed.title === \"object\" ? feedJson.feed.title[\"#text\"] : feedJson.feed.title)\n || \"N/A\";\n const entries = Array.isArray(feedJson.feed.entry)\n ? feedJson.feed.entry\n : (feedJson.feed.entry ? [feedJson.feed.entry] : []);\n\n for (const entry of entries.slice(0, maxHeadlines)) {\n let link = \"#\";\n if (Array.isArray(entry.link)) {\n const alternateLink = entry.link.find(l => l[\"@_rel\"] === \"alternate\" || !l[\"@_rel\"]); // prefer alternate or link without rel\n link = alternateLink ? alternateLink[\"@_href\"] : (entry.link[0] ? entry.link[0][\"@_href\"] : \"#\");\n } else if (entry.link && typeof entry.link === \"object\") {\n link = entry.link[\"@_href\"] || \"#\";\n } else if (typeof entry.link === \"string\") {\n link = entry.link;\n }\n\n headlines.push({\n title: ((typeof entry.title === \"object\" ? entry.title[\"#text\"] : entry.title) || \"No title\").toString(),\n link: link.toString(),\n summary: ((entry.summary\n ? (typeof entry.summary === \"object\" ? entry.summary[\"#text\"] : entry.summary)\n : (entry.content ? (typeof entry.content === \"object\" ? entry.content[\"#text\"] : entry.content) : \"\"))\n || \"\").toString(),\n publishedDate: (entry.updated || entry.published || \"\").toString(),\n });\n }\n parsedSuccessfully = headlines.length > 0;\n }\n\n if (parsedSuccessfully) {\n log(\"INFO\", \"FetchAgent\", `Successfully parsed ${headlines.length} headlines from \"${feedTitle}\".`);\n } else {\n parsingMessage = \"RSS/Atom structure not as expected or no items found.\";\n log(\"WARN\", \"FetchAgent\", parsingMessage);\n }\n } catch (parseError: any) {\n parsingMessage = `Failed to parse XML/RSS content. Error: ${parseError.message}`;\n log(\"WARN\", \"FetchAgent\", `${parsingMessage} from URL: ${urlToFetch}`);\n }\n } else {\n parsingMessage =\n `Content type \"${fetchedContentType}\" is not XML/RSS. Not attempting RSS parse. Raw text will be available.`;\n log(\"INFO\", \"FetchAgent\", parsingMessage);\n }\n\n const outputData = {\n headlines,\n feedTitle,\n sourceUrl: urlToFetch,\n ...(parsingMessage && !parsedSuccessfully ? { message: parsingMessage } : {}),\n };\n\n return {\n mandateId,\n correlationId: taskId,\n payload: {\n data: outputData,\n rawText: rawResponseText,\n contentType: fetchedContentType,\n },\n };\n } catch (e: any) {\n log(\"ERROR\", \"FetchAgent\", `Workspace or processing failed: ${e.message}`, e);\n return {\n mandateId,\n correlationId: taskId,\n payload: {\n data: {\n headlines: [],\n feedTitle: \"Error\",\n sourceUrl: urlToFetch,\n message: `Workspace or processing failed: ${e.message}`,\n },\n rawText: undefined,\n contentType: undefined,\n },\n error: e.message,\n };\n }\n}\n\n// Combiner Agent (Adapted to handle new headline structure from FetchAgent)\nexport async function combinerAgent(\n input: AgentInput<{\n summary?: string;\n // Expecting externalData to potentially contain the output of fetchAgent\n externalData?: {\n headlines?: Array<{ title: string; link: string; summary: string; publishedDate: string }>;\n feedTitle?: string;\n sourceUrl?: string;\n message?: string;\n };\n externalDataRawText?: string;\n externalDataContentType?: string | null;\n }>,\n context: AgentContext,\n): Promise> {\n const { mandateId, taskId, payload } = input;\n const { log } = context;\n log(\"INFO\", \"CombinerAgent\", \"Combining results\");\n\n try {\n const summaryText = payload.summary ?? \"N/A\";\n let externalDataDescription = \"External Data: Not Fetched/Available or not in expected format.\";\n\n if (\n payload.externalData?.headlines && Array.isArray(payload.externalData.headlines)\n && payload.externalData.headlines.length > 0\n ) {\n const headlinesArray = payload.externalData.headlines;\n const feedTitle = payload.externalData.feedTitle || \"News Feed\";\n\n externalDataDescription = `Recent Headlines from ${feedTitle} (Source: ${\n payload.externalData.sourceUrl || \"Unknown\"\n }):\\n`;\n headlinesArray.forEach((h, index) => {\n externalDataDescription += `${index + 1}. ${h.title}\\n`;\n if (h.link && h.link !== \"#\") externalDataDescription += ` Link: ${h.link}\\n`;\n if (h.summary) {\n const snippet = h.summary.replace(/<[^>]+>/g, \"\").substring(0, 150); // Strip HTML tags and take a snippet\n externalDataDescription += ` Summary Snippet: ${snippet}${h.summary.length > 150 ? \"...\" : \"\"}\\n`;\n }\n });\n } else if (payload.externalData?.message) { // If fetchAgent had a message (e.g. parsing error but still some info)\n externalDataDescription = `External Data Information: ${payload.externalData.message} (Source: ${\n payload.externalData.sourceUrl || \"Unknown\"\n })`;\n } else if (payload.externalData) {\n let jsonDataString = JSON.stringify(payload.externalData);\n if (jsonDataString.length > 750) {\n jsonDataString = jsonDataString.substring(0, 750) + \"... (JSON truncated)\";\n }\n externalDataDescription = `External Data (JSON): ${jsonDataString}`;\n } else if (payload.externalDataRawText) {\n let rawTextSnippet = payload.externalDataRawText.substring(0, 750);\n if (payload.externalDataRawText.length > 750) {\n rawTextSnippet += \"... (text truncated)\";\n }\n externalDataDescription = `External Data (Content-Type: ${\n payload.externalDataContentType || \"unknown\"\n }): ${rawTextSnippet}`;\n }\n\n const openai = new OpenAI();\n log(\"INFO\", \"CombinerAgent\", \"Combining text with OpenAI...\");\n const completion = await openai.chat.completions.create({\n messages: [\n {\n role: \"system\",\n content:\n \"You are an expert content synthesizer. Combine the provided summary and external data (often news headlines) into a coherent and informative paragraph. Highlight key insights or connections if possible.\",\n },\n {\n role: \"user\",\n content: `Please synthesize the following information:\n\nInternal Summary:\n${summaryText}\n\nInformation from External Source:\n${externalDataDescription}\n`,\n },\n ],\n temperature: 0.7,\n });\n\n const combined = completion.choices[0]?.message?.content?.trim() ?? \"Could not combine information.\";\n\n if (combined === \"Could not combine information.\") {\n log(\"WARN\", \"CombinerAgent\", \"OpenAI did not return valid combined content.\");\n }\n\n log(\"SUCCESS\", \"CombinerAgent\", \"Combined successfully\");\n return { mandateId, correlationId: taskId, payload: { combined } };\n } catch (e: any) {\n log(\"ERROR\", \"CombinerAgent\", `Combining failed: ${e.message}`, e);\n return { mandateId, correlationId: taskId, payload: { combined: \"\" }, error: e.message };\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/salon/mandate/code/agents.ts","extension","actionData","errors"]