Bump Resend version + fixed scripts

apps/web/app/api/cron/usage/utils.ts

@@ -114,28 +114,30 @@ export const updateUsage = async () => {
               },
             },
           }),
-          getStats({
-            domain: project.domains.map((domain) => domain.slug).join(","),
-            endpoint: "top_links",
-            interval: "30d",
-          }).then((data) =>
-            data
-              .slice(0, 5)
-              .map(
-                ({
-                  domain,
-                  key,
-                  clicks,
-                }: {
-                  domain: string;
-                  key: string;
-                  clicks: number;
-                }) => ({
-                  link: linkConstructor({ domain, key, pretty: true }),
-                  clicks,
-                }),
-              ),
-          ),
+          project.usage > 0
+            ? getStats({
+                domain: project.domains.map((domain) => domain.slug).join(","),
+                endpoint: "top_links",
+                interval: "30d",
+              }).then((data) =>
+                data
+                  .slice(0, 5)
+                  .map(
+                    ({
+                      domain,
+                      key,
+                      clicks,
+                    }: {
+                      domain: string;
+                      key: string;
+                      clicks: number;
+                    }) => ({
+                      link: linkConstructor({ domain, key, pretty: true }),
+                      clicks,
+                    }),
+                  ),
+              )
+            : [],
         ]);
 
         const emails = project.users.map((user) => user.user.email) as string[];

apps/web/package.json

@@ -75,7 +75,7 @@
     "rehype-pretty-code": "^0.9.5",
     "rehype-slug": "^5.1.0",
     "remark-gfm": "^3.0.1",
-    "resend": "^0.17.1",
+    "resend": "1.1.0",
     "shiki": "^0.14.1",
     "sonner": "^0.5.0",
     "stripe": "^12.12.0",

apps/web/scripts/get-top-links-for-project.ts

@@ -1,27 +1,7 @@
 import "dotenv-flow/config";
 import prisma from "@/lib/prisma";
 import { getStats } from "@/lib/stats";
-
-function linkConstructor({
-  key,
-  domain = "dub.sh",
-  localhost,
-  pretty,
-  noDomain,
-}: {
-  key: string;
-  domain?: string;
-  localhost?: boolean;
-  pretty?: boolean;
-  noDomain?: boolean;
-}) {
-  const link = `${
-    localhost ? "http://home.localhost:8888" : `https://${domain}`
-  }${key !== "_root" ? `/${key}` : ""}`;
-
-  if (noDomain) return `/${key}`;
-  return pretty ? link.replace(/^https?:\/\//, "") : link;
-}
+import { linkConstructor } from "./utils";
 
 async function main() {
   const project = await prisma.project.findUnique({

apps/web/scripts/run.ts

@@ -8,7 +8,9 @@ if (!command) {
   process.exit(1);
 }
 
-const scriptPath = `./scripts/${command}.ts`;
+const scriptPath = `./scripts/${command}.${
+  command === "send-emails" ? "tsx" : "ts"
+}`;
 
 exec(
   `tsx ${scriptPath}`,

apps/web/scripts/send-emails.tsx

@@ -0,0 +1,42 @@
+import "dotenv-flow/config";
+import prisma from "@/lib/prisma";
+
+async function main() {
+  const users = await prisma.user.findMany({
+    where: {
+      projects: {
+        some: {
+          project: {
+            slug: "steven",
+          },
+        },
+      },
+    },
+    select: {
+      name: true,
+      email: true,
+    },
+  });
+
+  const response = await fetch("https://api.resend.com/emails/batch", {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `Bearer ${process.env.RESEND_API_KEY}`,
+    },
+    body: JSON.stringify(
+      users.map(({ name, email }) => {
+        return {
+          from: "Steven from Dub <[email protected]>",
+          to: email,
+          subject: "Hello from Dub",
+          text: `Hi ${name},\n\nThis is a test email from Dub.\n\nBest,\nSteven`,
+        };
+      }),
+    ),
+  }).then((res) => res.json());
+
+  console.log(response);
+}
+
+main();

apps/web/scripts/utils.ts

@@ -0,0 +1,31 @@
+import { Redis } from "@upstash/redis";
+import { Resend } from "resend";
+
+// Initiate Redis instance by connecting to REST URL
+export const redis = new Redis({
+  url: process.env.UPSTASH_REDIS_REST_URL || "",
+  token: process.env.UPSTASH_REDIS_REST_TOKEN || "",
+});
+
+export const resend = new Resend(process.env.RESEND_API_KEY);
+
+export function linkConstructor({
+  key,
+  domain = "dub.sh",
+  localhost,
+  pretty,
+  noDomain,
+}: {
+  key: string;
+  domain?: string;
+  localhost?: boolean;
+  pretty?: boolean;
+  noDomain?: boolean;
+}) {
+  const link = `${
+    localhost ? "http://home.localhost:8888" : `https://${domain}`
+  }${key !== "_root" ? `/${key}` : ""}`;
+
+  if (noDomain) return `/${key}`;
+  return pretty ? link.replace(/^https?:\/\//, "") : link;
+}

apps/web/ui/stats/feedback/action.ts

@@ -1,22 +1,24 @@
 "use server";
 
+import { nanoid } from "@dub/utils";
+import { resend } from "emails";
+import FeedbackEmail from "emails/feedback-email";
+
 export async function submitFeedback(data: FormData) {
   const email = data.get("email") as string;
   const feedback = data.get("feedback") as string;
 
-  return await fetch("https://api.resend.com/emails", {
-    method: "POST",
+  return await resend?.emails.send({
+    from: "[email protected]",
+    to: ["[email protected]"],
+    ...(email && { reply_to: email }),
+    subject: "🎉 New Feedback Received!",
+    react: FeedbackEmail({
+      email,
+      feedback,
+    }),
     headers: {
-      "Content-Type": "application/json",
-      Authorization: "Bearer " + process.env.RESEND_API_KEY,
+      "X-Entity-Ref-ID": nanoid(),
     },
-    body: JSON.stringify({
-      from: "[email protected]",
-      to: "[email protected]",
-      reply_to: email,
-      ...(email && { reply_to: email }),
-      subject: "🎉 New Feedback Received!",
-      text: feedback,
-    }),
   });
 }