1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
import { z } from "astro/zod";
import { defineAction } from "astro:actions";
import nodemailer from "nodemailer";
import {
MAX_DAILY_EMAILS,
SMTP_HOST,
SMTP_PASSWORD,
SMTP_PORT,
SMTP_USE_TLS,
SMTP_USER,
} from "astro:env/server";
import { and, db, eq, gte, SendmailToken, SentEmails } from "astro:db";
export default defineAction({
input: z.object({
email: z.string().email(),
message: z.string().nonempty(),
name: z.string().nonempty(),
userId: z.string().nonempty(),
token: z.string().nonempty(),
}),
handler: sendmail,
});
type SendEmailParams = {
email: string;
message: string;
name: string;
token: string;
userId: string;
};
async function sendmail({
name,
email,
message,
token,
userId,
}: SendEmailParams) {
const isTokenCorrect =
(await db.$count(
SendmailToken,
and(
eq(SendmailToken.userId, userId),
eq(SendmailToken.value, token),
gte(SendmailToken.validUntil, Date.now()),
),
)) > 0;
if (!isTokenCorrect) {
return false;
}
await db
.delete(SendmailToken)
.where(
and(eq(SendmailToken.userId, userId), eq(SendmailToken.value, token)),
);
const emailsSentLast24Hours = await db.$count(
SentEmails,
gte(SentEmails.sentAt, Date.now() - 1000 * 60 * 60 * 24),
);
if (emailsSentLast24Hours > MAX_DAILY_EMAILS) {
throw new Error(
`${emailsSentLast24Hours} emails have been sent in the last 24 hours, but the max daily load is ${MAX_DAILY_EMAILS}.`,
);
}
const info = await transporter.sendMail({
from: `"Joe Carstairs" <me@joeac.net>`,
to: `"Joe Carstairs" <me@joeac.net>`,
subject: "joeac.net: a visitor left a message",
text: `${name} <${email}> sent you a message:\n\n\n${message}`,
});
await db
.insert(SentEmails)
.values({ messageId: info.messageId, sentAt: Date.now() });
console.log("Sent an email to Joe. Message ID: ", info.messageId);
}
const transporter = nodemailer.createTransport({
host: SMTP_HOST,
port: SMTP_PORT,
secure: false,
authMethod: "PLAIN",
auth: {
type: "login",
user: SMTP_USER,
pass: SMTP_PASSWORD,
},
});
|
