import { Elysia, t } from "elysia"; import { cors } from "@elysiajs/cors"; import { Resend } from "resend"; import { EmailTemplate } from "./email-templates/message"; import winston, { format } from "winston"; const { errors, printf, combine, colorize, timestamp } = format; // logger for server logs export const logger = winston.createLogger({ level: "info", }); logger.add( new winston.transports.Console({ format: combine( errors({ stack: true }), colorize({ all: true }), timestamp(), printf( ({ level, message, timestamp, stack }) => `[${timestamp}]:${level}: ${message}${stack ? `\n\n${stack}` : ""}`, ), ), }), ); const resend = new Resend(Bun.env.RESEND_API_KEY); const serverPort = Bun.env.SERVER_PORT || 3000; // creating Elysia instance new Elysia() .use( cors({ methods: ["POST"], origin: [ Bun.env.NODE_ENV === "production" ? Bun.env.ALLOWED_ORIGIN : "localhost:4321", ], }), ) .post( "/send-email", async (context) => { const { name, email, message } = context.body; try { // the part where we are sending emails const { error } = await resend.emails.send({ from: `${name} <${Bun.env.EMAIL_TO}>`, to: [Bun.env.EMAIL_TO], subject: `New Message Received From ${name}`, react: EmailTemplate({ name, email, message }), }); // error sending email, send back error status and message if (error) { return context.error((error as any).statusCode, error); } logger.info("New email received"); return new Response(JSON.stringify({ message: "Success" }), { headers: { "content-type": "application/json", }, }); } catch (error) { // catch error and log it, respond to user if (error instanceof Error) { logger.error(error.message, error); } return context.error("Internal Server Error", error); } }, { // body must be of three properties: name, email, and message // validation happens as a middleware body: t.Object({ name: t.String({ minLength: 3, error: "Name must be at least 3 characters", }), email: t.String({ format: "email", error: "Invalid email format", }), message: t.String({ minLength: 1, maxLength: 1024, error: "Message should be at least 10 characters and max of 1024 characters", }), }), // any errors that happens during validation will be logged error: ({ path, body, request: { method, headers }, error, code }) => { const errorMessage = `method=${method} path=${path} error=${ error.message } body=${JSON.stringify(body)} userAgent=${headers.get("user-agent")}`; logger.error(errorMessage); return error; }, }, ) // if any errors happen on the server itself, log the errors .onError(({ path, request: { method, headers }, error }) => { const errorMessage = `method=${method} path=${path} userAgent=${headers.get( "user-agent", )}`; logger.error(errorMessage, error); return error; }) .listen(serverPort, () => { logger.info(`Server starting on PORT: ${serverPort}`); });