\"${p.trim()}\"

`\n );\n\n // Find notes attached to this highlight\n const highlightNotes = notesData.results?.filter(\n (n: any) => n.parent_id === h.id,\n ) || [];\n\n for (const note of highlightNotes) {\n if (note.content?.trim()) {\n blocks.push(`

${note.content.trim()}

`);\n }\n }\n\n return blocks;\n });\n } else {\n console.error(\"Readwise API error:\", await highlightsRes.text());\n }\n\n // Handle email sources\n const isEmail = payload.category === \"email\" ||\n payload.source_url?.startsWith(\"mailto:\");\n const sourceUrl = isEmail ? null : (payload.source_url || payload.url);\n\n const titleHtml = sourceUrl\n ? `${payload.title || \"Untitled\"}`\n : `${payload.title || \"Untitled\"} (via ${\n payload.author || payload.site_name || \"email\"\n })`;\n\n // Build section\n const highlightsHtml = highlightBlocks.join(\"\\n\\n\");\n const newSection = `\n

${titleHtml}

\n${payload.notes?.trim() ? `

${payload.notes.trim()}

` : \"\"}\n${highlightsHtml}\n`.trim();\n\n // Generate Ghost JWT\n const [id, secret] = GHOST_ADMIN_KEY!.split(\":\");\n const token = jwt.sign({}, Buffer.from(secret, \"hex\"), {\n keyid: id,\n algorithm: \"HS256\",\n expiresIn: \"5m\",\n audience: \"/admin/\",\n });\n\n const headers = {\n \"Content-Type\": \"application/json\",\n Authorization: `Ghost ${token}`,\n };\n\n // Search for existing draft\n const searchRes = await fetch(\n `${GHOST_URL}/ghost/api/admin/posts/?filter=status:draft&limit=all&formats=html`,\n { headers },\n );\n\n if (!searchRes.ok) {\n console.error(\"Ghost search failed:\", await searchRes.text());\n return new Response(\"Ghost search failed\", { status: 500 });\n }\n\n const searchData = await searchRes.json();\n const existingPost = searchData.posts?.find(\n (p: any) => p.title?.toLowerCase() === postTitle.toLowerCase(),\n );\n let ghostRes;\n if (existingPost) {\n // Append to existing draft\n const updatedHtml = existingPost.html + \"\\n\\n\" + newSection;\n ghostRes = await fetch(\n `${GHOST_URL}/ghost/api/admin/posts/${existingPost.id}/?source=html`,\n {\n method: \"PUT\",\n headers,\n body: JSON.stringify({\n posts: [{\n html: updatedHtml,\n updated_at: existingPost.updated_at,\n }],\n }),\n },\n );\n console.log(\"Appended to draft:\", existingPost.id);\n } else {\n // Create new draft\n ghostRes = await fetch(`${GHOST_URL}/ghost/api/admin/posts/?source=html`, {\n method: \"POST\",\n headers,\n body: JSON.stringify({\n posts: [{\n title: postTitle,\n html: newSection,\n status: \"draft\",\n }],\n }),\n });\n console.log(\"Created new draft\");\n }\n\n if (!ghostRes.ok) {\n console.error(\"Ghost error:\", await ghostRes.text());\n return new Response(\"Ghost error\", { status: 500 });\n }\n\n console.log(\n \"Document:\",\n payload.title,\n \"| Highlights:\",\n highlightBlocks.length,\n );\n return new Response(\"OK\", { status: 200 });\n}","deleted","label",[100],"permalink","https://www.val.town/x/hellno/reader-highlights-to-ghost-blog/code/main.ts","extension","actionData","errors"]