/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","deleted","label",[100],"permalink","https://www.val.town/x/templates/pylon-support-bot/code/pylon.ts","extension","actionData","errors"]