{displayDescription}
+ )} + {status === "success" ? ( +{message}
+ )} +${post.description}
`; + } + if (post.excerpt) { + emailContent += `${post.excerpt}
`; + } + emailContent += ``; + + // Send emails via AgentMail API + // Note: Using AgentMail SDK when available + let sentCount = 0; + for (const subscriber of subscribers) { + try { + // AgentMail API call would go here + // await agentmailClient.send({ + // to: subscriber.email, + // subject: post.title, + // html: emailContent, + // from: process.env.AGENTMAIL_FROM_EMAIL, + // }); + sentCount++; + } catch (error) { + console.error(`Failed to send to ${subscriber.email}:`, error); + } + } + + // Record that post was sent + await ctx.runMutation(internal.newsletter.recordPostSent, { + postSlug: args.postSlug, + sentCount, + }); + + return { + success: true, + sentCount, + message: `Newsletter sent to ${sentCount} subscribers.`, + }; + }, +}); + +// Internal query to get post by slug (for newsletter) +export const getPostBySlugInternal = internalQuery({ + args: { + slug: v.string(), + }, + returns: v.union( + v.object({ + slug: v.string(), + title: v.string(), + description: v.string(), + excerpt: v.optional(v.string()), + published: v.boolean(), + }), + v.null(), + ), + handler: async (ctx, args) => { + const post = await ctx.db + .query("posts") + .withIndex("by_slug", (q) => q.eq("slug", args.slug)) + .first(); + + if (!post) return null; + + return { + slug: post.slug, + title: post.title, + description: post.description, + excerpt: post.excerpt, + published: post.published, + }; + }, +}); +``` + +**File:** `convex/posts.ts`Add internal query for newsletter: + +```typescript +// Add to existing posts.ts file +export const getPostBySlugInternal = internalQuery({ + args: { slug: v.string() }, + returns: v.union(/* same as above */), + handler: async (ctx, args) => { + // Same implementation as in newsletter.ts + }, +}); +``` + + + +### Step 5: Newsletter Send Script + +**File:** `scripts/send-newsletter.ts`Create script to send newsletters (similar to `sync-posts.ts`): + +```typescript +import { ConvexHttpClient } from "convex/browser"; +import { internal } from "../convex/_generated/api"; +import dotenv from "dotenv"; + +dotenv.config({ path: ".env.local" }); +dotenv.config(); + +const client = new ConvexHttpClient(process.env.VITE_CONVEX_URL!); + +async function sendNewsletterForPost(postSlug: string) { + try { + const result = await client.action(internal.newsletter.sendPostNewsletter, { + postSlug, + }); + + if (result.success) { + console.log(`ā ${result.message}`); + console.log(`š§ Sent to ${result.sentCount} subscribers`); + } else { + console.log(`ā¹ļø ${result.message}`); + } + } catch (error) { + console.error("ā Error sending newsletter:", error); + process.exit(1); + } +} + +// Main execution +const args = process.argv.slice(2); +if (args.length === 0) { + console.error("Usage: npm run newsletter:send --Processing...
} + {status === "success" && ( + <> +{message}
+ + + )} + {status === "error" &&{message}
} + {status === "idle" && ( +Use the unsubscribe link from your email to unsubscribe.
+ )} +