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)}`);
  }
}