apps/frontend/src/server/api/subscribe.post.ts

import MailerLite from '@mailerlite/mailerlite-nodejs';
import { $newsletter } from '@meridian/database';
import { z } from 'zod';
import { getDB } from '../lib/utils';

export default defineEventHandler(async event => {
  const config = useRuntimeConfig(event);

  // Parse the request body to get the email
  const body = await readBody(event);
  const bodyContent = z.object({ email: z.string().email() }).safeParse(body);
  if (bodyContent.success === false) {
    throw createError({ statusCode: 400, statusMessage: 'Invalid email format' });
  }

  try {
    // Insert email into the newsletter table
    await Promise.all([
      getDB(event).insert($newsletter).values({ email: bodyContent.data.email }).onConflictDoNothing(),
      (async () => {
        if (config.mailerlite.api_key === undefined || config.mailerlite.group_id === undefined) {
          console.warn('MailerLite is not configured');
          return; // nothing if mailerlite is not configured
        }
        const mailerlite = new MailerLite({ api_key: config.mailerlite.api_key });
        try {
          await mailerlite.subscribers.createOrUpdate({
            email: bodyContent.data.email,
            groups: [config.mailerlite.group_id],
          });
        } catch (error) {
          console.error('MailerLite error:', error);
          throw createError({ statusCode: 500, statusMessage: 'MailerLite error' });
        }
      })(),
    ]);

    return { success: true, message: 'Successfully subscribed' };
  } catch (error) {
    console.error('Database error:', error);
    throw createError({ statusCode: 500, statusMessage: 'Database error' });
  }
});