1 files changed, 80 insertions, 0 deletions
diff --git a/src/lib/resend.ts b/src/lib/resend.ts
new file mode 100644
index 0000000..5ab7032
--- /dev/null
+++ b/src/lib/resend.ts
@@ -0,0 +1,80 @@
+import { baseUrl } from '@/lib/constants';
+import { Resend, type UpdateContactOptions } from 'resend';
+import NewsletterWelcomeEmail from '../../emails/newsletter-welcome';
+import type { getPosts } from './source';
+
+const resend = new Resend(process.env.RESEND_API_KEY as string);
+
+export async function updateContact({
+  email,
+  audienceId,
+  ...props
+}: {
+  email: string;
+  audienceId: string;
+} & Omit<UpdateContactOptions, 'email' | 'audienceId'>) {
+  const { data, error } = await resend.contacts.update({
+    email,
+    audienceId,
+    ...props,
+  });
+
+  if (!data || error) {
+    if (error?.name === 'not_found') {
+      return null;
+    }
+    throw new Error(`Failed to update contact: ${error?.message}`);
+  }
+
+  return data;
+}
+
+export async function getContact({
+  email,
+  audienceId,
+}: {
+  email: string;
+  audienceId: string;
+}) {
+  const { data: contacts, error } = await resend.contacts.list({ audienceId });
+
+  if (error || !contacts) {
+    throw new Error(
+      `Failed to list contacts: ${error?.message || 'Unknown error'}`,
+    );
+  }
+
+  const contact = contacts.data.find((contact) => contact.email === email);
+  return contact || null;
+}
+
+export async function sendWelcomeEmail({
+  posts,
+  firstName,
+  to,
+}: {
+  posts: ReturnType<typeof getPosts>;
+  firstName: string;
+  to: string;
+}) {
+  const EMAIL_FROM = process.env.EMAIL_FROM as string;
+  if (!EMAIL_FROM) throw new Error('Missing EMAIL_FROM environment variable');
+  if (!firstName || !to) throw new Error('Missing required email fields');
+
+  const formattedPosts = posts.map((post) => ({
+    ...post.data,
+    image: `${baseUrl}${post.data.image}`,
+    url: `${baseUrl}${post.url}`,
+  }));
+
+  const { data: res, error } = await resend.emails.send({
+    from: EMAIL_FROM,
+    to,
+    subject: 'Welcome to my newsletter!',
+    react: NewsletterWelcomeEmail({ firstName, posts: formattedPosts }),
+  });
+
+  if (error) {
+    throw new Error(`Failed to send welcome email: ${JSON.stringify(error)}`);
+  }
+}