New ${blog.displayName} essay

`,\n `

${latestEssay.title}

`,\n `

${latestEssay.dateText}

`,\n `

${latestEssay.url}

`,\n ].join(\"\");\n\n try {\n await email({\n ...(blog.recipientEmail ? { to: blog.recipientEmail } : {}),\n subject,\n text,\n html,\n });\n } catch (err) {\n if (\n blog.recipientEmail &&\n err instanceof Error &&\n err.message.includes(\"Free tier users cannot use `to`, `cc` and `bcc` fields\")\n ) {\n await email({ subject, text, html });\n } else {\n throw err;\n }\n }\n\n await blob.setJSON(blog.stateKey, { latestEssayId });\n return { status: \"email_sent\", latestEssay };\n}\n\nasync function seedSecondLatestStateOnce(): Promise {\n if (!SEED_SECOND_LATEST_ONCE) return false;\n const marker = await blob.getJSON<{ seededAt: string }>(SEED_MARKER_KEY);\n if (marker) return false;\n\n for (const blog of BLOGS) {\n const response = await fetch(blog.blogUrl);\n if (!response.ok) throw new Error(`Failed to fetch ${blog.blogUrl}: ${response.status}`);\n const pageText = await response.text();\n const essays = blog.parseEssays(pageText);\n if (essays.length < 2) {\n throw new Error(`Need at least 2 parsed essays for ${blog.displayName} to seed second latest.`);\n }\n const latestEssay = essays[0];\n const latestEssayId = `${latestEssay.dateText}::${latestEssay.title}`;\n const secondLatestEssay = essays.find((essay) => {\n const essayId = `${essay.dateText}::${essay.title}`;\n return essayId !== latestEssayId;\n });\n if (!secondLatestEssay) {\n throw new Error(`Could not find a distinct second-latest essay for ${blog.displayName}.`);\n }\n const seededEssayId = `${secondLatestEssay.dateText}::${secondLatestEssay.title}`;\n await blob.setJSON(blog.stateKey, { latestEssayId: seededEssayId });\n }\n\n await blob.setJSON(SEED_MARKER_KEY, { seededAt: new Date().toISOString() });\n return true;\n}\n\nexport default async function (_interval: Interval): Promise {\n const seeded = await seedSecondLatestStateOnce();\n if (seeded) {\n console.log(\"Seeded second-latest blog IDs into blob state. Run again to test notifications.\");\n return;\n }\n\n const checks: Array<[string, Promise]> = BLOGS.map((blog) => [\n blog.key,\n checkBlogForNewEssay(blog),\n ]);\n const results = await Promise.all(\n checks.map(async ([blogKey, task]) => [blogKey, await task] as const),\n );\n const summary = Object.fromEntries(results);\n console.log(summary);\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/val_town1/NewBlogPostNotifierForBlogsWithoutRSSOrEmail/code/main.tsx","extension","actionData","errors"]