summaryrefslogtreecommitdiff
path: root/website/src/actions/sendmail.ts
blob: 3b2d242db7e1c6efb1c9e88cab8637e90fe514c8 (plain)
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
import { z } from "astro/zod";
import { actions, defineAction } from "astro:actions";
import nodemailer from "nodemailer";
import { MAX_DAILY_EMAILS, SENDMAIL_BIN } from "astro:env/server";
import { and, db, eq, gte, lte, SendmailToken, SentEmails } from "astro:db";
import { isToken } from "typescript";

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({
  sendmail: true,
  path: SENDMAIL_BIN,
});