Simple Notification Service with NextJs

import { SNSClient, PublishCommandInput, PublishCommand } from '@aws-sdk/client-sns';
import { NextRequest, NextResponse } from "next/server";
require('dotenv').config();

interface SendEmailsRequest {
  message: string;
  subject?: string;
}

export  async function POST(req: NextRequest) {
  try {
    if (req.method !== 'POST') {
      return NextResponse.json({ error: 'Method Not Allowed' });
    }

    const emailBody: SendEmailsRequest = await req.json();

    console.log(emailBody);

    const sns = new SNSClient({
        region: process.env.AWS_REGION as string,
        credentials: {
          accessKeyId: process.env.AWS_ACCESS_KEY_ID as string,
          secretAccessKey: process.env.AWS_SECRET_ACCESS_KEY as string,
        }
      });
      

    const results: any[] = [];
    
      try {
        const params: PublishCommandInput = {
          Message: emailBody.message,
          Subject: emailBody.subject,
          TopicArn: process.env.EMAIL_TOPIC_ARN, // Replace with your email topic ARN
          MessageAttributes: {
            // Add any required message attributes for email, e.g., { 'EmailMessage.Destination': { ... } }
          },
          MessageStructure: 'string', // Use 'json' if sending a structured message
        };

        const result = await sns.send( new  PublishCommand(params)); 
        results.push(result);
      } catch (error) {
        console.error(`Error sending email`, error);
        
      }
    

   return NextResponse.json({ success: true, results });
  } catch (error) {
    console.error('General error:', error);
    return NextResponse.json({ error: 'Failed to send emails' });
  }
}