Implement Admin Newsletter backend

- Added API endpoint to send newsletters
- Integrated email service to dispatch newsletters
- Updated frontend to include newsletter form and submission handling

Author: Lauren Pothuru

backend/scripts/email/emailService.ts

@@ -1,3 +1,4 @@
+/* eslint-disable import/prefer-default-export */
 import { Resend } from 'resend';
 import * as dotenv from 'dotenv';
 import fetch, { Headers, Response, Request } from 'node-fetch';
@@ -6,8 +7,8 @@ import React from 'react';
 import { ApartmentWithId } from '@common/types/db-types';
 import GenerateNewsletter from './templates/GenerateNewsletter';
 import { getUserBatches, USERS } from './helpers/firebase_users_loader';
+import { NewsletterRequest } from './templates/Types';
 
-// Initialize fetch globals if needed
 if (!global.fetch) {
   global.fetch = fetch as unknown as typeof global.fetch;
   global.Headers = Headers as unknown as typeof global.Headers;
@@ -25,50 +26,31 @@ type EmailCampaignOptions = {
   recentAreaPropertyIDs?: string[];
   lovedPropertyIDs?: string[];
   reviewedPropertyIDs?: string[];
+  newsletterData?: NewsletterRequest;
 };
 
-/**
- * sendEmailCampaign
- * Sends a marketing email campaign to batches of users featuring apartment properties.
- *
- * @param options - Configuration options for the email campaign
- * @param options.subject - Email subject line (default: 'Check Out These New Apartments!')
- * @param options.toEmail - Primary recipient email address (default: '[email protected]')
- * @param options.nearbyPropertyIDs - List of property IDs to feature as nearby available properties
- * @param options.budgetPropertyIDs - List of property IDs to feature as budget-friendly properties
- * @param options.recentAreaPropertyIDs - List of property IDs to feature as recent area properties
- * @param options.lovedPropertyIDs - List of property IDs to feature as top loved properties
- * @param options.reviewedPropertyIDs - List of property IDs to feature as most reviewed properties
- * @returns Promise that resolves when all email batches have been sent
- */
 const sendEmailCampaign = async (options: EmailCampaignOptions = {}): Promise<void> => {
-  const { subject = 'Check Out These New Apartments!', toEmail = '[email protected]' } =
-    options;
+  const {
+    subject = 'Check Out These New Apartments!',
+    toEmail = '[email protected]',
+    newsletterData,
+  } = options;
 
-  // Load environment variables
   dotenv.config({ path: path.resolve(process.cwd(), '.env.dev') });
 
-  const fromEmail = 'updates.cuapts.org';
+  const fromEmail = 'updates@cuapts.org';
   const fromName = 'CU Apts';
 
   const apiKey = process.env.RESEND_API_KEY;
   if (!apiKey) {
-    console.error('Missing RESEND_API_KEY in environment variables');
-    return;
+    throw new Error('Missing RESEND_API_KEY in environment variables');
   }
 
-  /**
-   * getPropertiesByIds
-   * Fetches apartment data for a given list of property IDs.
-   *
-   * @param ids - List of apartment IDs to fetch from backend API
-   * @returns List of ApartmentWithId objects
-   *
-   */
   const getPropertiesByIds = async (ids: string[]): Promise<ApartmentWithId[]> => {
+    if (!ids || ids.length === 0) return [];
+
     try {
       const idParam = ids.join(',');
-
       const response = await fetch(`${API_BASE_URL}/api/apts/${idParam}`);
 
       if (!response.ok) {
@@ -83,7 +65,7 @@ const sendEmailCampaign = async (options: EmailCampaignOptions = {}): Promise<vo
     }
   };
 
-  // Loads chosen properties
+  // Load properties
   const nearbyProperties = options.nearbyPropertyIDs
     ? await getPropertiesByIds(options.nearbyPropertyIDs)
     : [];
@@ -100,63 +82,50 @@ const sendEmailCampaign = async (options: EmailCampaignOptions = {}): Promise<vo
     ? await getPropertiesByIds(options.reviewedPropertyIDs)
     : [];
 
-  console.log(`Fetched ${nearbyProperties.length} nearby properties (recently released spotlight)`);
-  console.log(`Fetched ${budgetProperties.length} budget properties (recently released spotlight)`);
-  console.log(`Fetched ${recentAreaProperties.length} recent area properties (area spotlight)`);
-  console.log(`Fetched ${lovedProperties.length} loved properties (loved spotlight)`);
-  console.log(`Fetched ${reviewedProperties.length} reviewed properties (loved spotlight)`);
+  console.log(`Fetched ${nearbyProperties.length} nearby properties`);
+  console.log(`Fetched ${budgetProperties.length} budget properties`);
+  console.log(`Fetched ${recentAreaProperties.length} recent area properties`);
+  console.log(`Fetched ${lovedProperties.length} loved properties`);
+  console.log(`Fetched ${reviewedProperties.length} reviewed properties`);
 
   const resend = new Resend(apiKey);
 
-  /**
-   * BATCH PROCESSING AND EMAIL SENDING
-   * Processes users in batches and sends emails concurrently:
-   * - Creates batches of 50 users and maps over batches to send emails in parallel
-   * - Uses BCC to hide recipient emails from each other
-   *
-   * To use, uncomment line 191, comment out line 192, and run the file as normal.
-   */
-  // eslint-disable-next-line @typescript-eslint/no-unused-vars
   const sendBatchEmail = async () => {
     try {
-      console.log(`Total users available in database: ${USERS.length}`);
+      console.log(`Total users available: ${USERS.length}`);
       const validEmails = USERS.filter((user) => user.email && user.email.includes('@'));
       console.log(`Valid email addresses: ${validEmails.length}`);
 
       if (validEmails.length === 0) {
-        console.error('No valid email addresses found!');
-        return;
+        throw new Error('No valid email addresses found!');
       }
 
       const userBatches = await getUserBatches(50);
-      console.log(
-        `Preparing to send emails to ${userBatches.length} batches of users (${50} per batch)`
-      );
+      console.log(`Sending to ${userBatches.length} batches of users`);
 
       const emailPromises = userBatches.map(async (batch, i) => {
         const bccEmails = batch.map((user) => user.email);
-        console.log(
-          `Preparing batch ${i + 1}/${userBatches.length} with ${bccEmails.length} recipients`
-        );
 
         const { data, error } = await resend.emails.send({
           from: `${fromName} <${fromEmail}>`,
           to: toEmail,
-          // bcc: bccEmails,
+          bcc: bccEmails,
           subject,
           react: React.createElement(GenerateNewsletter, {
             nearbyProperties,
             budgetProperties,
             recentAreaProperties,
             lovedProperties,
             reviewedProperties,
+            newsletterData,
           }),
         });
 
         if (error) {
           console.error(`Error sending batch ${i + 1}:`, error);
+          throw error;
         } else {
-          console.log(`Batch ${i + 1} sent successfully! ID:`, data?.id || 'no ID returned');
+          console.log(`Batch ${i + 1} sent successfully! ID:`, data?.id);
         }
       });
 
@@ -168,65 +137,46 @@ const sendEmailCampaign = async (options: EmailCampaignOptions = {}): Promise<vo
     }
   };
 
-  /**
-   * SINGLE TEST EMAIL SENDING
-   * Sends an email to one person (useful for testing email templates).
-   *   To use, uncomment line 192, comment out line 191, edit info below,
-   *   and run the file as normal.
-   */
   const sendSingleTestEmail = async () => {
     try {
       const { data, error } = await resend.emails.send({
-        from: '[email protected]',
-        to: '[email protected]',
+        from: `${fromName} <${fromEmail}>`,
+        to: toEmail,
         subject,
         react: React.createElement(GenerateNewsletter, {
           nearbyProperties,
           budgetProperties,
           recentAreaProperties,
           lovedProperties,
           reviewedProperties,
+          newsletterData,
         }),
       });
+
       if (error) {
         console.error('Error sending email:', error);
+        throw error;
       } else {
-        console.log('Email sent successfully! ID:', data ? data.id : ' no ID returned.');
+        console.log('Email sent successfully! ID:', data?.id);
       }
     } catch (err) {
       console.error('Exception when sending email:', err);
+      throw err;
     }
   };
 
-  // sendBatchEmail();
-  sendSingleTestEmail();
-};
-
-/**
- * Entry point function that executes the email campaign with default settings.
- * Handles logging and error handling for the campaign process.
- *
- * @returns Promise that resolves when the campaign completes
- */
-async function main() {
-  try {
-    console.log('Starting email campaign...');
-
-    // Customize  email subject
-    await sendEmailCampaign({
-      subject: 'New Apartment Listings Available!',
-      recentAreaPropertyIDs: ['12', '2', '24'],
-      budgetPropertyIDs: ['23', '24', '24'],
-      nearbyPropertyIDs: ['14', '23', '24'],
-      reviewedPropertyIDs: ['1', '2', '3'],
-      lovedPropertyIDs: ['4', '5', '6'],
-    });
-
-    console.log('Campaign completed successfully!');
-  } catch (error) {
-    console.error('Failed to send campaign:', error);
+  // Determine which sending method to use based on sendToAll flag
+  // If newsletterData exists and sendToAll is true, send to all users
+  // Otherwise, send a single test email
+  const shouldSendToAll = newsletterData?.sendToAll === true;
+
+  if (shouldSendToAll) {
+    console.log('Sending to all subscribers...');
+    await sendBatchEmail();
+  } else {
+    console.log(`Sending test email to: ${toEmail}`);
+    await sendSingleTestEmail();
   }
-}
+};
 
-// Execute main function directly
-main().catch(console.error);
+export { sendEmailCampaign };