feat: emails (openstatusHQ#93)

Author: thibaultleouay

apps/web/src/app/action.ts

@@ -6,7 +6,7 @@ import { Resend } from "resend";
 import { validateEmailNotDisposable, WaitingList } from "@openstatus/emails";
 
 import { EmailTemplate } from "@/components/templates/email-template";
-import { env } from "@/env.mjs";
+import { env } from "@/env";
 
 const redis = Redis.fromEnv();
 
@@ -50,7 +50,7 @@ const wait = (ms: number): Promise<void> => {
 };
 
 // Resend
-export const sendWaitingListEmail = async (email:string) => {
+export const sendWaitingListEmail = async (email: string) => {
   const isValid = await validateEmailNotDisposable(email);
   if (!isValid) {
     await resend.emails.send({

apps/web/src/app/api/checker/cron/10m/route.ts

@@ -1,12 +1,14 @@
 import { NextResponse } from "next/server";
 
-import { cron } from "../_cron";
+import { cron, isAuthorizedDomain } from "../_cron";
 
 export const runtime = "edge";
 export const preferredRegion = ["auto"];
 export const dynamic = "force-dynamic";
 
 export async function GET(req: Request) {
-  await cron({ periodicity: "10m" });
+  if (isAuthorizedDomain(req.url)) {
+    await cron({ periodicity: "10m" });
+  }
   return NextResponse.json({ success: true });
 }

apps/web/src/app/api/checker/cron/1h/route.ts

@@ -0,0 +1,14 @@
+import { NextResponse } from "next/server";
+
+import { cron, isAuthorizedDomain } from "../_cron";
+
+export const runtime = "edge";
+export const preferredRegion = ["auto"];
+export const dynamic = "force-dynamic";
+
+export async function GET(req: Request) {
+  if (isAuthorizedDomain(req.url)) {
+    await cron({ periodicity: "1h" });
+  }
+  return NextResponse.json({ success: true });
+}

apps/web/src/app/api/checker/cron/1m/route.ts

@@ -0,0 +1,14 @@
+import { NextResponse } from "next/server";
+
+import { cron, isAuthorizedDomain } from "../_cron";
+
+export const runtime = "edge";
+export const preferredRegion = ["auto"];
+export const dynamic = "force-dynamic";
+
+export async function GET(req: Request) {
+  if (isAuthorizedDomain(req.url)) {
+    await cron({ periodicity: "1m" });
+  }
+  return NextResponse.json({ success: true });
+}

apps/web/src/app/api/checker/cron/30m/route.ts

@@ -0,0 +1,14 @@
+import { NextResponse } from "next/server";
+
+import { cron, isAuthorizedDomain } from "../_cron";
+
+export const runtime = "edge";
+export const preferredRegion = ["auto"];
+export const dynamic = "force-dynamic";
+
+export async function GET(req: Request) {
+  if (isAuthorizedDomain(req.url)) {
+    await cron({ periodicity: "30m" });
+  }
+  return NextResponse.json({ success: true });
+}

apps/web/src/app/api/checker/cron/5m/route.ts

@@ -0,0 +1,14 @@
+import { NextResponse } from "next/server";
+
+import { cron, isAuthorizedDomain } from "../_cron";
+
+export const runtime = "edge";
+export const preferredRegion = ["auto"];
+export const dynamic = "force-dynamic";
+
+export async function GET(req: Request) {
+  if (isAuthorizedDomain(req.url)) {
+    await cron({ periodicity: "5m" });
+  }
+  return NextResponse.json({ success: true });
+}

apps/web/src/app/api/checker/cron/_cron.ts

@@ -9,7 +9,7 @@ import {
 } from "@openstatus/db/src/schema";
 import { availableRegions } from "@openstatus/tinybird";
 
-import { env } from "@/env.mjs";
+import { env } from "@/env";
 import type { payloadSchema } from "../schema";
 
 const periodicityAvailable = selectMonitorSchema.pick({ periodicity: true });
@@ -18,6 +18,11 @@ const DEFAULT_URL = process.env.VERCEL_URL
   ? `https://${process.env.VERCEL_URL}`
   : "http://localhost:3000";
 
+// We can't secure cron endpoint by vercel thus we should make sure they are called by the generated url
+export const isAuthorizedDomain = (url: string) => {
+  return url.includes(DEFAULT_URL);
+};
+
 export const cron = async ({
   periodicity,
 }: z.infer<typeof periodicityAvailable>) => {

apps/web/src/app/api/checker/regions/_checker.ts

@@ -9,7 +9,7 @@ import {
   Tinybird,
 } from "@openstatus/tinybird";
 
-import { env } from "@/env.mjs";
+import { env } from "@/env";
 import { payloadSchema } from "../schema";
 
 export const monitorSchema = tbIngestPingResponse.pick({

apps/web/src/app/api/ping/route.ts

@@ -1,5 +1,7 @@
 import { NextResponse } from "next/server";
 
+export const dynamic = "force-dynamic";
+
 export async function GET() {
   return NextResponse.json({ ping: "pong" }, { status: 200 });
 }