improve base64 decoding in sandbox

Author: pomdtr

internal/worker/sandbox.ts

@@ -1,3 +1,5 @@
+import { Buffer } from "node:buffer";
+
 function cleanStack(str?: string) {
     if (!str) return undefined;
     return str
@@ -6,19 +8,19 @@ function cleanStack(str?: string) {
             (line) =>
                 !line.includes(import.meta.url) &&
                 !line.includes("deno_http/00_serve.ts") &&
-                !line.includes("core/01_core.js")
+                !line.includes("core/01_core.js"),
         )
         .join("\n");
 }
 
 function serializeError(e: Error) {
     return { name: e.name, message: e.message, stack: cleanStack(e.stack) };
-};
+}
 
 function respondWithError(error: Error) {
     return Response.json(
         { error: serializeError(error) },
-        { status: 500, headers: { 'Content-Type': 'application/json' } },
+        { status: 500, headers: { "Content-Type": "application/json" } },
     );
 }
 
@@ -42,25 +44,37 @@ if (payload.command === "fetch") {
             try {
                 const mod = await import(payload.entrypoint);
                 if (!mod.default) {
-                    return new Response("The app does not provide a default export.", { status: 500 });
+                    return new Response(
+                        "The app does not provide a default export.",
+                        { status: 500 },
+                    );
                 }
 
                 if (typeof mod.default !== "object") {
-                    return new Response("The app default export must be an object.", { status: 500 });
+                    return new Response(
+                        "The app default export must be an object.",
+                        { status: 500 },
+                    );
                 }
                 if (
                     !("fetch" in mod.default) ||
                     typeof mod.default.fetch !== "function"
                 ) {
-                    return new Response("The app default export does not have a fetch method.", { status: 500 });
+                    return new Response(
+                        "The app default export does not have a fetch method.",
+                        { status: 500 },
+                    );
                 }
 
                 const handler = mod.default.fetch;
                 // Websocket requests are stateful and should be handled differently
                 if (req.headers.get("upgrade") === "websocket") {
                     const resp = await handler(req);
                     if (!(resp instanceof Response)) {
-                        return new Response("Fetch handler must return a Response object.", { status: 500 });
+                        return new Response(
+                            "Fetch handler must return a Response object.",
+                            { status: 500 },
+                        );
                     }
 
                     return resp;
@@ -69,13 +83,20 @@ if (payload.command === "fetch") {
                 const url = new URL(req.url);
                 const proto = req.headers.get("x-forwarded-proto");
                 const host = req.headers.get("x-forwarded-host");
-                const resp = await handler(new Request(`${proto}://${host}${url.pathname}${url.search}`, {
-                    method: req.method,
-                    headers: req.headers,
-                    body: req.body,
-                }));
+                const resp = await handler(
+                    new Request(
+                        `${proto}://${host}${url.pathname}${url.search}`,
+                        {
+                            method: req.method,
+                            headers: req.headers,
+                            body: req.body,
+                        },
+                    ),
+                );
                 if (!(resp instanceof Response)) {
-                    throw new Error("Fetch handler must return a Response object.");
+                    throw new Error(
+                        "Fetch handler must return a Response object.",
+                    );
                 }
 
                 return resp;
@@ -100,7 +121,9 @@ if (payload.command === "fetch") {
     }
 
     if (!(typeof handler.cron === "function")) {
-        console.error("The mod default export cron property must be a function.");
+        console.error(
+            "The mod default export cron property must be a function.",
+        );
         Deno.exit(1);
     }
 
@@ -116,12 +139,14 @@ if (payload.command === "fetch") {
 
     const handler = mod.default;
     if (!("email" in handler)) {
-        console.error("The mod default export does not have an email function.");
+        console.error(
+            "The mod default export does not have an email function.",
+        );
         Deno.exit(1);
     }
 
-    const data = btoa(payload.msg)
-    const blob = new Blob([data]);
+    const buf = Buffer.from(payload.email, "base64")
+    const blob = new Blob([buf]);
     await handler.email(blob.stream());
 } else {
     console.error("Unknown command: ", payload.command);