api: maybe resend receive support proxy

Author: RiskyMH

apps/api/src/routes/v0/receive-email/resend/route.ts

@@ -0,0 +1,65 @@
+import { POST as postReceiveEmail } from "../route";
+
+
+export async function POST(request: Bun.BunRequest) {
+    const event = await request.json() as {
+        type: 'email.received';
+        data: {
+            email_id: string;
+        };
+    };
+    const emailthingKey = request.params.emailthing_key;
+    const resendKey = request.params.resend_key;
+    const categoryId = request.params.category_id;
+
+    if (event.type === 'email.received') {
+        const res = await fetch(`https://api.resend.com/emails/receiving/${event.data.email_id}`, {
+            method: "GET",
+            headers: {
+                "Content-Type": "application/json",
+                Authorization: `Bearer ${resendKey}`,
+                "user-agent": "EmailThing (https://emailthing.app)",
+            },
+        });
+
+        if (!res.ok) {
+            const errorData = await res.json();
+            return new Response(`Failed to fetch email data: ${res.status} - ${errorData.message}`, { status: 500 });
+        }
+
+        const emailData = await res.json() as {
+            from: string;
+            to: string[];
+            raw: {
+                download_url: string;
+            };
+        };
+
+        const rawReq = await fetch(emailData.raw.download_url)
+
+        if (!rawReq.ok) {
+            return new Response(`Failed to download raw email: ${rawReq.status} - ${await rawReq.text()}`, { status: 500 });
+        }
+
+        const rawEmail = await rawReq.text();
+
+        const newRequest = new Request(`https://api.emailthing.app/v0/receive-email`, {
+            method: "POST",
+            headers: {
+                "Content-Type": "application/json",
+                Authorization: `Bearer ${emailthingKey}`,
+                ...request.headers,
+            },
+            body: JSON.stringify({
+                raw: rawEmail,
+                from: emailData.from,
+                to: emailData.to[0],
+                categoryId,
+            }),
+        });
+
+        return await postReceiveEmail(newRequest);
+    }
+
+    return new Response("Unknown event type")
+}

apps/api/src/routes/v0/receive-email/route.ts

@@ -199,7 +199,7 @@ export async function POST(request: Request) {
     }
 
     for (const attachment of email.attachments) {
-        const name = attachment.filename || attachment.mimeType || createId();
+        const name = attachment.filename || attachment.contentId || attachment.mimeType || createId();
 
         const attContent = typeof attachment.content === "string" ? Buffer.from(attachment.content) : attachment.content;
         const attId = createId();