1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
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)}`);
}
}
|
