/gi, \"• \")\n .replace(/<\\/h[1-6]>/gi, \"\\n\\n\")\n .replace(/<[^>]+>/g, \"\")\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/ /g, \" \")\n .replace(/\\n{3,}/g, \"\\n\\n\")\n .trim();\n}\n\n// ─── Fetch full issue context ───────────────────────────────────────────────\n\n/**\n * Fetch an issue by ID.\n *\n * @see https://docs.usepylon.com/pylon-docs/developer/api/api-reference/issues\n */\nasync function getIssue(issueId: string): Promise {\n const res = await fetch(`${PYLON_BASE}/issues/${issueId}`, {\n headers: pylonHeaders(),\n });\n\n if (!res.ok) {\n const text = await res.text();\n throw new Error(`Pylon GET /issues/${issueId} failed (${res.status}): ${text}`);\n }\n\n const json = await res.json();\n return json.data as PylonIssue;\n}\n\n/**\n * Fetch all messages for an issue, paginating if needed.\n * Returns messages in chronological order (oldest first).\n *\n * @see https://docs.usepylon.com/pylon-docs/developer/api/api-reference/messages\n */\nasync function getIssueMessages(issueId: string): Promise {\n const allMessages: PylonMessage[] = [];\n let cursor: string | undefined;\n\n do {\n const params = new URLSearchParams();\n if (cursor) params.set(\"cursor\", cursor);\n const qs = params.toString();\n\n const res = await fetch(\n `${PYLON_BASE}/issues/${issueId}/messages${qs ? `?${qs}` : \"\"}`,\n { headers: pylonHeaders() },\n );\n\n if (!res.ok) {\n const text = await res.text();\n throw new Error(\n `Pylon GET /issues/${issueId}/messages failed (${res.status}): ${text}`,\n );\n }\n\n const json = await res.json();\n const messages = (json.data ?? []) as PylonMessage[];\n allMessages.push(...messages);\n\n cursor = json.pagination?.has_next_page ? json.pagination.cursor : undefined;\n } while (cursor);\n\n // Sort chronologically (oldest first) so the AI sees the conversation in order\n allMessages.sort(\n (a, b) => new Date(a.timestamp).getTime() - new Date(b.timestamp).getTime(),\n );\n\n return allMessages;\n}\n\n/**\n * Pull all the context an AI agent needs to reply to a Pylon issue.\n *\n * Fetches the issue metadata and the full conversation thread in parallel,\n * then filters out internal notes so the AI only sees customer-visible messages.\n *\n * @param issueId The Pylon issue ID (from the webhook payload).\n * @returns Issue metadata + chronologically-ordered conversation messages.\n */\nexport async function getIssueContext(issueId: string): Promise {\n const [issue, allMessages] = await Promise.all([\n getIssue(issueId),\n getIssueMessages(issueId),\n ]);\n\n // Filter out internal notes — the AI should only see the customer-facing thread\n const messages = allMessages.filter((m) => !m.is_private);\n\n return { issue, messages };\n}\n\n/**\n * Build a plain-text prompt from the issue context suitable for an LLM.\n */\nexport function buildPromptFromContext(ctx: IssueContext): string {\n const { issue, messages } = ctx;\n\n const lines: string[] = [\n `## Support Issue #${issue.number}`,\n `**Title:** ${issue.title}`,\n `**Status:** ${issue.state}`,\n `**Source:** ${issue.source}`,\n `**Type:** ${issue.type}`,\n ];\n\n if (issue.requester?.email) {\n lines.push(`**Requester:** ${issue.requester.email}`);\n }\n if (issue.assignee?.email) {\n lines.push(`**Assignee:** ${issue.assignee.email}`);\n }\n if (issue.tags?.length) {\n lines.push(`**Tags:** ${issue.tags.join(\", \")}`);\n }\n if (issue.link) {\n lines.push(`**Issue URL:** ${issue.link}`);\n }\n\n lines.push(\"\", \"---\", \"\", \"## Conversation Thread\", \"\");\n\n for (const msg of messages) {\n const authorLabel = msg.author?.name\n ?? msg.author?.user?.email\n ?? msg.author?.contact?.email\n ?? (msg.author?.contact ? \"Customer\" : \"Agent\");\n const timestamp = new Date(msg.timestamp).toISOString();\n const bodyText = htmlToText(msg.message_html);\n\n lines.push(`### ${authorLabel} (${timestamp})`);\n lines.push(bodyText);\n lines.push(\"\");\n }\n\n return lines.join(\"\\n\");\n}\n\n// ─── Thread & note helpers ──────────────────────────────────────────────────\n\n/** Shape returned by POST /issues/{id}/threads */\nexport interface PylonThread {\n id: string;\n issue_id: string;\n name?: string;\n source?: string;\n thread_id?: string;\n channel_id?: string;\n}\n\n/**\n * Create a new thread (message container) on an issue.\n *\n * @param issueId The Pylon issue ID.\n * @param name Optional human-readable name for the thread.\n * @returns The created thread object (use its `id` as `thread_id` when posting notes).\n *\n * @see https://docs.usepylon.com/pylon-docs/developer/api/api-reference/messages#post-issues-id-threads\n */\nasync function createThread(issueId: string, name?: string): Promise {\n const payload: Record = {};\n if (name) payload.name = name;\n\n const res = await fetch(`${PYLON_BASE}/issues/${issueId}/threads`, {\n method: \"POST\",\n headers: pylonHeaders(),\n body: JSON.stringify(payload),\n });\n\n if (!res.ok) {\n const text = await res.text();\n throw new Error(\n `Pylon POST /issues/${issueId}/threads failed (${res.status}): ${text}`,\n );\n }\n\n const json = await res.json();\n return json.data as PylonThread;\n}\n\n/**\n * Create an internal note inside an existing thread.\n *\n * @param issueId The Pylon issue ID.\n * @param threadId The thread `id` (from createThread or GET /issues/{id}/threads).\n * @param bodyHtml Note body as HTML.\n * @param userId Optional Pylon user ID to post as.\n * @returns The created note `{ id, issue_id }`.\n *\n * @see https://docs.usepylon.com/pylon-docs/developer/api/api-reference/messages#post-issues-id-note\n */\nasync function createNote(opts: {\n issueId: string;\n threadId: string;\n bodyHtml: string;\n userId?: string;\n}): Promise<{ id: string; issue_id: string }> {\n const { issueId, threadId, bodyHtml, userId } = opts;\n\n const payload: Record = {\n thread_id: threadId,\n body_html: bodyHtml,\n };\n if (userId) payload.user_id = userId;\n\n const res = await fetch(`${PYLON_BASE}/issues/${issueId}/note`, {\n method: \"POST\",\n headers: pylonHeaders(),\n body: JSON.stringify(payload),\n });\n\n if (!res.ok) {\n const text = await res.text();\n throw new Error(\n `Pylon POST /issues/${issueId}/note failed (${res.status}): ${text}`,\n );\n }\n\n const json = await res.json();\n return json.data as { id: string; issue_id: string };\n}\n\n// ─── High-level: post an internal note in a new thread ──────────────────────\n\n/**\n * Create a new thread on an issue and post an internal note into it.\n *\n * This is the main entry point for the bot to leave draft replies.\n * The `body` can be plain Markdown — it is converted to HTML automatically.\n *\n * @param opts.issueId The Pylon issue ID.\n * @param opts.body Note body in Markdown (converted to HTML).\n * @param opts.bodyHtml Note body as raw HTML (takes precedence over `body`).\n * @param opts.threadName Optional name for the new thread.\n * @param opts.userId Optional Pylon user ID to post the note as.\n * @returns The created note `{ id, issue_id }`.\n *\n * @see https://docs.usepylon.com/pylon-docs/developer/api/api-reference/messages\n */\nexport async function postThreadNote(opts: {\n issueId: string;\n body?: string;\n bodyHtml?: string;\n threadName?: string;\n userId?: string;\n}): Promise<{ id: string; issue_id: string }> {\n const { issueId, body, bodyHtml, threadName, userId } = opts;\n\n const html = bodyHtml ?? (body ? markdownToHtml(body) : \"\");\n if (!html) {\n throw new Error(\"Either `body` (Markdown) or `bodyHtml` must be provided.\");\n }\n\n // 1. Create a thread container on the issue\n const thread = await createThread(issueId, threadName);\n\n // 2. Post the internal note into the new thread\n return createNote({\n issueId,\n threadId: thread.id,\n bodyHtml: html,\n userId,\n });\n}\n",[],[224],"files",[156,175,185,195,204,214,222],"counts",{"_234":33,"_235":164,"_236":33,"_237":238,"_242":243},"pulls","branches","forks","envVars",{"_239":240,"_241":240},"count",4,"emptyCount","connections",{"_239":33,"_244":33},"unfilledCount","contents",[247,250,253,256,259,262],{"_104":157,"_97":158,"_159":160,"_161":-5,"_162":144,"_163":164,"_165":166,"_106":248,"_101":33,"_168":169,"_170":-5,"_171":22,"_172":-5,"_100":249},["D",1771362877699],[158],{"_104":186,"_97":187,"_159":188,"_161":-5,"_162":144,"_163":143,"_165":166,"_106":251,"_101":190,"_168":191,"_170":192,"_171":22,"_172":-5,"_100":252},["D",1771504968547],[187],{"_104":196,"_97":197,"_159":198,"_161":-5,"_162":144,"_163":164,"_165":166,"_106":254,"_101":33,"_168":200,"_170":201,"_171":22,"_172":-5,"_100":255},["D",1771362877699],[197],{"_104":205,"_97":206,"_159":207,"_161":-5,"_162":144,"_163":208,"_165":166,"_106":257,"_101":210,"_168":180,"_170":211,"_171":22,"_172":-5,"_100":258},["D",1771504942432],[206],{"_104":215,"_97":216,"_159":217,"_161":-5,"_162":144,"_163":164,"_165":166,"_106":260,"_101":33,"_168":191,"_170":219,"_171":22,"_172":-5,"_100":261},["D",1771362877699],[216],{"_104":223,"_97":224,"_159":225,"_161":-5,"_162":144,"_163":164,"_165":166,"_106":263,"_101":33,"_168":180,"_170":227,"_171":22,"_172":-5,"_100":264},["D",1771362877699],[224],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_95":96,"_97":98,"_102":273,"_237":278,"_298":166},{"_104":105,"_97":98,"_106":274,"_108":-5,"_109":22,"_110":111,"_112":113,"_114":74,"_14":115,"_116":-5,"_117":22,"_118":-5,"_119":-5,"_120":33,"_16":121,"_122":-5,"_123":-5,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":275,"_136":276,"_141":277,"_153":22},["D",1771362877699],{"_95":96,"_134":135},{"_95":96,"_138":135,"_14":-5,"_139":140},{"_101":143,"_97":45,"_104":144,"_145":105,"_146":-5,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":98,"_152":96},[279,287,291,294],{"_280":281,"_106":282,"_283":284,"_112":285,"_286":166},"key","KILO_GATEWAY_KEY",["D",1771504962927],"updatedAt",["D",1771505240989],"https://app.kilo.ai/profile","isEmpty",{"_280":288,"_106":289,"_283":-5,"_112":290,"_286":166},"ANTHROPIC_API_KEY",["D",1771362877699],"https://console.anthropic.com/",{"_280":292,"_106":293,"_283":-5,"_112":74,"_286":166},"PYLON_API_KEY",["D",1771362877699],{"_280":295,"_106":296,"_283":-5,"_112":297,"_286":166},"PYLON_WEBHOOK_SECRET",["D",1771362877699],"https://www.val.town/x/stevekrouse/support-bot#2-pylon-webhook-destination","isTeamOrg","actionData","errors"]

Key	Description
KILO_GATEWAY_KEY	https://app.kilo.ai/profile
ANTHROPIC_API_KEY	https://console.anthropic.com/
PYLON_API_KEY
PYLON_WEBHOOK_SECRET	https://www.val.town/x/stevekrouse/support-bot#2-pylon-webhook-destination

templates

pylon-support-bot

Environment variables