chore: just a test script

Author: ImJustNon

test/PrismaConnector.ts

@@ -0,0 +1,15 @@
+import { PrismaPg } from "@prisma/adapter-pg";
+import { PrismaClient } from "generated/prisma/client";
+import { config } from "src/config/app.config";
+
+export class PrismaConnector {
+	private readonly adapter: PrismaPg;
+	public readonly prisma: PrismaClient;
+
+	constructor() {
+		this.adapter = new PrismaPg({
+			connectionString: config.db.url,
+		});
+		this.prisma = new PrismaClient({ adapter: this.adapter });
+	}
+}

test/mail/MailConnector.ts

@@ -0,0 +1,37 @@
+import { render } from "@react-email/render";
+import * as nodemailer from "nodemailer";
+import { config } from "src/config/app.config";
+import AnnouncementEmail from "src/core/email/templates/AnnouncementEmail";
+
+export abstract class MailConnector {
+	private transporter: nodemailer.Transporter;
+
+	constructor() {
+		this.transporter = nodemailer.createTransport({
+			host: config.email.nodemailer.host,
+			port: config.email.nodemailer.port,
+			secure: config.email.nodemailer.secure,
+			auth: {
+				user: config.email.nodemailer.user,
+				pass: config.email.nodemailer.pass,
+			},
+		});
+	}
+
+	protected async sendMail(to: string, subject: string, html: string) {
+		const info = await this.transporter.sendMail({
+			from: config.email.nodemailer.from,
+			to: to,
+			subject: subject,
+			html: html,
+		});
+
+		console.log(`Email sent to ${to} (MsgID: ${info.messageId})`);
+		return { success: true, messageId: info.messageId };
+	}
+
+	protected handleError(type: string, email: string, error: any) {
+		console.error(`Failed to send ${type} email to ${email}`, error.stack);
+		throw error;
+	}
+}

test/mail/SendMail.ts

@@ -0,0 +1,53 @@
+import fs from "node:fs";
+import path from "node:path";
+import { render } from "@react-email/render";
+import AnnouncementEmail from "src/core/email/templates/AnnouncementEmail";
+import { PrismaConnector } from "test/PrismaConnector";
+import { MailConnector } from "./MailConnector";
+
+class SendMail extends MailConnector {
+	private db: PrismaConnector;
+
+	constructor() {
+		super();
+		this.db = new PrismaConnector();
+	}
+	async sendAnnouncement(email: string, name: string) {
+		try {
+			const html = await render(AnnouncementEmail({ name }));
+			return await this.sendMail(email, "ประกาศผลการคัดเลือก ComCamp 37", html);
+		} catch (error) {
+			this.handleError("announcement", email, error);
+		}
+	}
+
+	async run() {
+		interface EmailList {
+			email: string;
+			name: string;
+		}
+		const loadEmailJson = fs.readFileSync(path.join(__dirname, "./emails.json"), "utf8");
+		const emails: EmailList[] = JSON.parse(loadEmailJson);
+
+		for (const { email, name } of emails) {
+			try {
+				await this.sendAnnouncement(email, name);
+
+				const readlast = fs.readFileSync(path.join(__dirname, "./log/success.json"), "utf8");
+				const toJson: string[] = JSON.parse(readlast);
+				toJson.push(email);
+				fs.writeFileSync(path.join(__dirname, "./log/success.json"), JSON.stringify(toJson, null, 2), "utf8");
+				console.log(`Success : ${name} - ${email}`);
+			} catch (e) {
+				const readlast = fs.readFileSync(path.join(__dirname, "./log/error.json"), "utf8");
+				const toJson: string[] = JSON.parse(readlast);
+				toJson.push(email);
+				fs.writeFileSync(path.join(__dirname, "./log/error.json"), JSON.stringify(toJson, null, 2), "utf8");
+
+				console.log(`Send Email Error: ${name} - ${email}`, e);
+			}
+		}
+	}
+}
+
+new SendMail().run();