Summary update email

apps/web/app/(app)/settings/EmailUpdatesSection.tsx

@@ -86,12 +86,19 @@ function StatsUpdateSectionForm(props: { statsEmailFrequency: Frequency }) {
 
   return (
     <form onSubmit={handleSubmit(onSubmit)} className="space-y-4">
-      <Select
+      {/* <Select
         name="statsEmailFrequency"
         label="Stats Update Email"
         options={options}
         registerProps={register("statsEmailFrequency")}
         error={errors.statsEmailFrequency}
+      /> */}
+      <Select
+        name="summaryEmailFrequency"
+        label="Summary Email"
+        options={options}
+        registerProps={register("summaryEmailFrequency")}
+        error={errors.summaryEmailFrequency}
       />
 
       <Button type="submit" loading={isSubmitting}>

apps/web/app/(app)/settings/page.tsx

@@ -3,7 +3,7 @@ import { AboutSection } from "@/app/(app)/settings/AboutSection";
 // import { LabelsSection } from "@/app/(app)/settings/LabelsSection";
 import { DeleteSection } from "@/app/(app)/settings/DeleteSection";
 import { ModelSection } from "@/app/(app)/settings/ModelSection";
-// import { EmailUpdatesSection } from "@/app/(app)/settings/EmailUpdatesSection";
+import { EmailUpdatesSection } from "@/app/(app)/settings/EmailUpdatesSection";
 import { MultiAccountSection } from "@/app/(app)/settings/MultiAccountSection";
 
 export default function Settings() {
@@ -12,7 +12,7 @@ export default function Settings() {
       <AboutSection />
       {/* <LabelsSection /> */}
       <ModelSection />
-      {/* <EmailUpdatesSection /> */}
+      <EmailUpdatesSection />
       <MultiAccountSection />
       <DeleteSection />
     </FormWrapper>

apps/web/app/api/resend/all/route.ts

@@ -9,10 +9,6 @@ import { captureException } from "@/utils/error";
 export const dynamic = "force-dynamic";
 export const maxDuration = 300;
 
-export type SendWeeklyStatsAllUpdateResponse = Awaited<
-  ReturnType<typeof sendWeeklyStatsAllUpdate>
->;
-
 async function sendWeeklyStatsAllUpdate() {
   const users = await prisma.user.findMany({
     select: { email: true },

apps/web/app/api/resend/route.ts

@@ -12,10 +12,6 @@ import { getGmailClient } from "@/utils/gmail/client";
 import { loadTinybirdEmails } from "@/app/api/user/stats/tinybird/load/load-emails";
 
 const sendWeeklyStatsBody = z.object({ email: z.string() });
-export type SendWeeklyStatsBody = z.infer<typeof sendWeeklyStatsBody>;
-export type SendWeeklyStatsResponse = Awaited<
-  ReturnType<typeof sendWeeklyStats>
->;
 
 async function sendWeeklyStats(options: { email: string }) {
   const { email } = options;

apps/web/app/api/resend/summary/all/route.ts

@@ -0,0 +1,42 @@
+import { NextResponse } from "next/server";
+import prisma from "@/utils/prisma";
+import { withError } from "@/utils/middleware";
+import { env } from "@/env.mjs";
+import { hasCronSecret } from "@/utils/cron";
+import { Frequency } from "@prisma/client";
+import { captureException } from "@/utils/error";
+
+export const dynamic = "force-dynamic";
+export const maxDuration = 300;
+
+async function sendSummaryAllUpdate() {
+  const users = await prisma.user.findMany({
+    select: { email: true },
+    where: { summaryEmailFrequency: { not: Frequency.NEVER } },
+  });
+
+  await Promise.all(
+    users.map(async (user) => {
+      return fetch(`${env.NEXT_PUBLIC_BASE_URL}/api/resend/summary`, {
+        method: "POST",
+        body: JSON.stringify({ email: user.email }),
+        headers: {
+          authorization: `Bearer ${env.CRON_SECRET}`,
+        },
+      });
+    }),
+  );
+
+  return { count: users.length };
+}
+
+export const GET = withError(async (request) => {
+  if (!hasCronSecret(request)) {
+    captureException(new Error("Unauthorized request: api/resend/all"));
+    return new Response("Unauthorized", { status: 401 });
+  }
+
+  const result = await sendSummaryAllUpdate();
+
+  return NextResponse.json(result);
+});

apps/web/app/api/resend/summary/route.ts

@@ -0,0 +1,97 @@
+import { z } from "zod";
+import { NextResponse } from "next/server";
+import { subHours } from "date-fns";
+import { sendSummaryEmail } from "@inboxzero/resend";
+import { withError } from "@/utils/middleware";
+import { env } from "@/env.mjs";
+import { hasCronSecret } from "@/utils/cron";
+import { captureException } from "@/utils/error";
+import prisma from "@/utils/prisma";
+import { ExecutedRuleStatus } from "@prisma/client";
+import { auth } from "@/app/api/auth/[...nextauth]/auth";
+
+const sendSummaryEmailBody = z.object({ email: z.string() });
+
+async function sendEmail({ email }: { email: string }) {
+  // run every 7 days. but overlap by 1 hour
+  const days = 7;
+  const cutOffDate = subHours(new Date(), days * 24 + 1);
+
+  const user = await prisma.user.findUnique({
+    where: {
+      email,
+      OR: [
+        { lastSummaryEmailAt: { lt: cutOffDate } },
+        { lastSummaryEmailAt: null },
+      ],
+    },
+    select: {
+      coldEmails: { where: { createdAt: { gt: cutOffDate } } },
+      _count: {
+        select: {
+          executedRules: {
+            where: {
+              status: ExecutedRuleStatus.PENDING,
+              createdAt: { gt: cutOffDate },
+            },
+          },
+        },
+      },
+    },
+  });
+
+  if (!user) return { success: false };
+
+  const coldEmailers = user.coldEmails.map((e) => ({
+    from: e.fromEmail,
+    subject: "",
+  }));
+  const pendingCount = user._count.executedRules;
+  const shouldSendEmail = coldEmailers.length && pendingCount;
+
+  await Promise.all([
+    shouldSendEmail
+      ? sendSummaryEmail({
+          to: email,
+          emailProps: {
+            baseUrl: env.NEXT_PUBLIC_BASE_URL,
+            coldEmailers,
+            pendingCount,
+          },
+        })
+      : async () => {},
+    prisma.user.update({
+      where: { email },
+      data: { lastSummaryEmailAt: new Date() },
+    }),
+  ]);
+
+  return { success: true };
+}
+
+export const GET = withError(async () => {
+  const session = await auth();
+
+  // send to self
+  const email = session?.user.email;
+  if (!email) return NextResponse.json({ error: "Not authenticated" });
+
+  const result = await sendEmail({ email });
+
+  return NextResponse.json(result);
+});
+
+export const POST = withError(async (request: Request) => {
+  console.log("sending summary email to user");
+  if (!hasCronSecret(request)) {
+    captureException(new Error("Unauthorized cron request: resend"));
+    return new Response("Unauthorized", { status: 401 });
+  }
+
+  const json = await request.json();
+  const body = sendSummaryEmailBody.parse(json);
+
+  const result = await sendEmail(body);
+
+  return NextResponse.json(result);
+});

apps/web/app/api/user/me/route.ts

@@ -14,6 +14,7 @@ async function getUser(userId: string) {
       aiModel: true,
       openAIApiKey: true,
       statsEmailFrequency: true,
+      summaryEmailFrequency: true,
       coldEmailBlocker: true,
       coldEmailPrompt: true,
       premium: {

apps/web/app/api/user/settings/email-updates/route.ts

@@ -19,6 +19,7 @@ async function saveEmailUpdateSettings(options: SaveEmailUpdateSettingsBody) {
     where: { email: session.user.email },
     data: {
       statsEmailFrequency: options.statsEmailFrequency,
+      summaryEmailFrequency: options.summaryEmailFrequency,
     },
   });
 }

apps/web/app/api/user/settings/email-updates/validation.ts

@@ -3,6 +3,7 @@ import { Frequency } from "@prisma/client";
 
 export const saveEmailUpdateSettingsBody = z.object({
   statsEmailFrequency: z.enum([Frequency.WEEKLY, Frequency.NEVER]),
+  summaryEmailFrequency: z.enum([Frequency.WEEKLY, Frequency.NEVER]),
 });
 export type SaveEmailUpdateSettingsBody = z.infer<
   typeof saveEmailUpdateSettingsBody

apps/web/prisma/migrations/20240528083708_summary_email/migration.sql

@@ -0,0 +1,3 @@
+-- AlterTable
+ALTER TABLE "User" ADD COLUMN     "lastSummaryEmailAt" TIMESTAMP(3),
+ADD COLUMN     "summaryEmailFrequency" "Frequency" NOT NULL DEFAULT 'WEEKLY';

apps/web/prisma/schema.prisma

@@ -61,13 +61,15 @@ model User {
   utms                      Json?
 
   // settings
-  aiProvider          String?
-  aiModel             String?
-  openAIApiKey        String?
-  statsEmailFrequency Frequency         @default(WEEKLY)
-  categorizeEmails    Boolean           @default(true)
-  coldEmailBlocker    ColdEmailSetting?
-  coldEmailPrompt     String?
+  aiProvider            String?
+  aiModel               String?
+  openAIApiKey          String?
+  statsEmailFrequency   Frequency         @default(WEEKLY)
+  summaryEmailFrequency Frequency         @default(WEEKLY)
+  lastSummaryEmailAt    DateTime?
+  categorizeEmails      Boolean           @default(true)
+  coldEmailBlocker      ColdEmailSetting?
+  coldEmailPrompt       String?
 
   // premium can be shared among multiple users
   premiumId      String?

apps/web/providers/SWRProvider.tsx

@@ -11,7 +11,7 @@ import {
 import { SWRConfig, mutate } from "swr";
 
 // https://swr.vercel.app/docs/error-handling#status-code-and-error-object
-export const fetcher = async (url: string, init?: RequestInit | undefined) => {
+const fetcher = async (url: string, init?: RequestInit | undefined) => {
   const res = await fetch(url, init);
 
   // If the status code is not in the range 200-299,
@@ -44,8 +44,6 @@ const defaultContextValue = {
 
 const SWRContext = createContext<Context>(defaultContextValue);
 
-export const useSWRContext = () => useContext<Context>(SWRContext);
-
 export const SWRProvider = (props: { children: React.ReactNode }) => {
   const [provider, setProvider] = useState(new Map());