Fix display bugs in the console.

backend/container/e2b.Dockerfile

@@ -0,0 +1,19 @@
+# e2b template build --name "terminal"
+
+# Use a Debian-based base image
+FROM ubuntu:22.04
+
+# Install dependencies and customize sandbox
+RUN apt update \
+    && apt install -y sudo
+
+# Install xterm
+RUN apt update \
+    && apt install -y xterm
+
+RUN apt update \
+    && apt install -y tmux screen
+
+# Clean up
+RUN apt clean \
+    && rm -rf /var/lib/apt/lists/*

backend/container/e2b.toml

@@ -0,0 +1,14 @@
+# This is a config for E2B sandbox template.
+# You can use 'template_id' (ne8xtb57tq5xw9vwhdyc) or 'template_name (terminal) from this config to spawn a sandbox:
+
+# Python SDK
+# from e2b import Sandbox
+# sandbox = Sandbox(template='terminal')
+
+# JS SDK
+# import { Sandbox } from 'e2b'
+# const sandbox = await Sandbox.create({ template: 'terminal' })
+
+dockerfile = "e2b.Dockerfile"
+template_name = "terminal"
+template_id = "ne8xtb57tq5xw9vwhdyc"

backend/database/src/index.ts

@@ -110,13 +110,8 @@ export default {
 				const body = await request.json()
 				const { type, name, userId, visibility } = initSchema.parse(body)
 
-				const userSandboxes = await db
+				const allSandboxes = await db.select().from(sandbox).all()
-					.select()
+				if (allSandboxes.length >= 8) {
-					.from(sandbox)
-					.where(eq(sandbox.userId, userId))
-					.all()
-
-				if (userSandboxes.length >= 8) {
 					return new Response("You reached the maximum # of sandboxes.", {
 						status: 400,
 					})

backend/server/package-lock.json

@@ -9,11 +9,12 @@
       "version": "1.0.0",
       "license": "ISC",
       "dependencies": {
+        "@e2b/code-interpreter": "^0.0.7",
         "concurrently": "^8.2.2",
         "cors": "^2.8.5",
         "dotenv": "^16.4.5",
-        "e2b": "^0.16.1",
         "express": "^4.19.2",
+        "node-pty": "^1.0.0",
         "rate-limiter-flexible": "^5.0.3",
         "socket.io": "^4.7.5",
         "zod": "^3.22.4"
@@ -50,6 +51,39 @@
         "node": ">=12"
       }
     },
+    "node_modules/@e2b/code-interpreter": {
+      "version": "0.0.7",
+      "resolved": "https://registry.npmjs.org/@e2b/code-interpreter/-/code-interpreter-0.0.7.tgz",
+      "integrity": "sha512-e8nAY4zXU2b9nKthqq/pCPlTVD7f01dtzCtvabWmhlx7Wq+AUln14Q1Wf+uRVJXHkwS9BDv2CupdZpUChsjoCA==",
+      "dependencies": {
+        "e2b": "^0.16.1",
+        "isomorphic-ws": "^5.0.0",
+        "ws": "^8.15.1"
+      },
+      "engines": {
+        "node": ">=18"
+      }
+    },
+    "node_modules/@e2b/code-interpreter/node_modules/ws": {
+      "version": "8.17.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.17.0.tgz",
+      "integrity": "sha512-uJq6108EgZMAl20KagGkzCKfMEjxmKvZHG7Tlq0Z6nOky7YF7aq4mOx6xK8TJ/i1LeK4Qus7INktacctDgY8Ow==",
+      "engines": {
+        "node": ">=10.0.0"
+      },
+      "peerDependencies": {
+        "bufferutil": "^4.0.1",
+        "utf-8-validate": ">=5.0.2"
+      },
+      "peerDependenciesMeta": {
+        "bufferutil": {
+          "optional": true
+        },
+        "utf-8-validate": {
+          "optional": true
+        }
+      }
+    },
     "node_modules/@jridgewell/resolve-uri": {
       "version": "3.1.2",
       "resolved": "https://registry.npmjs.org/@jridgewell/resolve-uri/-/resolve-uri-3.1.2.tgz",
@@ -1247,6 +1281,11 @@
       "resolved": "https://registry.npmjs.org/ms/-/ms-2.0.0.tgz",
       "integrity": "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A=="
     },
+    "node_modules/nan": {
+      "version": "2.19.0",
+      "resolved": "https://registry.npmjs.org/nan/-/nan-2.19.0.tgz",
+      "integrity": "sha512-nO1xXxfh/RWNxfd/XPfbIfFk5vgLsAxUR9y5O0cHMJu/AW9U95JLXqthYHjEp+8gQ5p96K9jUp8nbVOxCdRbtw=="
+    },
     "node_modules/negotiator": {
       "version": "0.6.3",
       "resolved": "https://registry.npmjs.org/negotiator/-/negotiator-0.6.3.tgz",
@@ -1266,6 +1305,15 @@
         "node-gyp-build-test": "build-test.js"
       }
     },
+    "node_modules/node-pty": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/node-pty/-/node-pty-1.0.0.tgz",
+      "integrity": "sha512-wtBMWWS7dFZm/VgqElrTvtfMq4GzJ6+edFI0Y0zyzygUSZMgZdraDUMUhCIvkjhJjme15qWmbyJbtAx4ot4uZA==",
+      "hasInstallScript": true,
+      "dependencies": {
+        "nan": "^2.17.0"
+      }
+    },
     "node_modules/nodemon": {
       "version": "3.1.0",
       "resolved": "https://registry.npmjs.org/nodemon/-/nodemon-3.1.0.tgz",

backend/server/package.json

@@ -11,11 +11,12 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
+    "@e2b/code-interpreter": "^0.0.7",
     "concurrently": "^8.2.2",
     "cors": "^2.8.5",
     "dotenv": "^16.4.5",
-    "e2b": "^0.16.1",
     "express": "^4.19.2",
+    "node-pty": "^1.0.0",
     "rate-limiter-flexible": "^5.0.3",
     "socket.io": "^4.7.5",
     "zod": "^3.22.4"

backend/server/src/fileoperations.ts

@@ -1,177 +0,0 @@
-import * as dotenv from "dotenv";
-import {
-  R2FileBody,
-  R2Files,
-  Sandbox,
-  TFile,
-  TFileData,
-  TFolder,
-} from "./types";
-
-dotenv.config();
-
-export const getSandboxFiles = async (id: string) => {
-  const res = await fetch(
-    `${process.env.STORAGE_WORKER_URL}/api?sandboxId=${id}`,
-    {
-      headers: {
-        Authorization: `${process.env.WORKERS_KEY}`,
-      },
-    }
-  );
-  const data: R2Files = await res.json();
-
-  const paths = data.objects.map((obj) => obj.key);
-  const processedFiles = await processFiles(paths, id);
-  return processedFiles;
-};
-
-export const getFolder = async (folderId: string) => {
-  const res = await fetch(
-    `${process.env.STORAGE_WORKER_URL}/api?folderId=${folderId}`,
-    {
-      headers: {
-        Authorization: `${process.env.WORKERS_KEY}`,
-      },
-    }
-  );
-  const data: R2Files = await res.json();
-
-  return data.objects.map((obj) => obj.key);
-};
-
-const processFiles = async (paths: string[], id: string) => {
-  const root: TFolder = { id: "/", type: "folder", name: "/", children: [] };
-  const fileData: TFileData[] = [];
-
-  paths.forEach((path) => {
-    const allParts = path.split("/");
-    if (allParts[1] !== id) {
-      return;
-    }
-
-    const parts = allParts.slice(2);
-    let current: TFolder = root;
-
-    for (let i = 0; i < parts.length; i++) {
-      const part = parts[i];
-      const isFile = i === parts.length - 1 && part.includes(".");
-      const existing = current.children.find((child) => child.name === part);
-
-      if (existing) {
-        if (!isFile) {
-          current = existing as TFolder;
-        }
-      } else {
-        if (isFile) {
-          const file: TFile = { id: path, type: "file", name: part };
-          current.children.push(file);
-          fileData.push({ id: path, data: "" });
-        } else {
-          const folder: TFolder = {
-            // id: path, // todo: wrong id. for example, folder "src" ID is: projects/a7vgttfqbgy403ratp7du3ln/src/App.css
-            id: `projects/${id}/${parts.slice(0, i + 1).join("/")}`,
-            type: "folder",
-            name: part,
-            children: [],
-          };
-          current.children.push(folder);
-          current = folder;
-        }
-      }
-    }
-  });
-
-  await Promise.all(
-    fileData.map(async (file) => {
-      const data = await fetchFileContent(file.id);
-      file.data = data;
-    })
-  );
-
-  return {
-    files: root.children,
-    fileData,
-  };
-};
-
-const fetchFileContent = async (fileId: string): Promise<string> => {
-  try {
-    const fileRes = await fetch(
-      `${process.env.STORAGE_WORKER_URL}/api?fileId=${fileId}`,
-      {
-        headers: {
-          Authorization: `${process.env.WORKERS_KEY}`,
-        },
-      }
-    );
-    return await fileRes.text();
-  } catch (error) {
-    console.error("ERROR fetching file:", error);
-    return "";
-  }
-};
-
-export const createFile = async (fileId: string) => {
-  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api`, {
-    method: "POST",
-    headers: {
-      "Content-Type": "application/json",
-      Authorization: `${process.env.WORKERS_KEY}`,
-    },
-    body: JSON.stringify({ fileId }),
-  });
-  return res.ok;
-};
-
-export const renameFile = async (
-  fileId: string,
-  newFileId: string,
-  data: string
-) => {
-  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api/rename`, {
-    method: "POST",
-    headers: {
-      "Content-Type": "application/json",
-      Authorization: `${process.env.WORKERS_KEY}`,
-    },
-    body: JSON.stringify({ fileId, newFileId, data }),
-  });
-  return res.ok;
-};
-
-export const saveFile = async (fileId: string, data: string) => {
-  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api/save`, {
-    method: "POST",
-    headers: {
-      "Content-Type": "application/json",
-      Authorization: `${process.env.WORKERS_KEY}`,
-    },
-    body: JSON.stringify({ fileId, data }),
-  });
-  return res.ok;
-};
-
-export const deleteFile = async (fileId: string) => {
-  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api`, {
-    method: "DELETE",
-    headers: {
-      "Content-Type": "application/json",
-      Authorization: `${process.env.WORKERS_KEY}`,
-    },
-    body: JSON.stringify({ fileId }),
-  });
-  return res.ok;
-};
-
-export const getProjectSize = async (id: string) => {
-  const res = await fetch(
-    `${process.env.STORAGE_WORKER_URL}/api/size?sandboxId=${id}`,
-    {
-      headers: {
-        Authorization: `${process.env.WORKERS_KEY}`,
-      },
-    }
-  );
-  return (await res.json()).size;
-};

backend/server/src/index.ts

@@ -1,3 +1,4 @@
+import fs from "fs";
 import os from "os";
 import path from "path";
 import cors from "cors";
@@ -16,9 +17,8 @@ import {
   getSandboxFiles,
   renameFile,
   saveFile,
-} from "./fileoperations";
+} from "./utils";
-import { LockManager } from "./utils";
+import { Sandbox, Process, ProcessMessage } from "e2b";
-import { Sandbox, Terminal, FilesystemManager } from "e2b";
 import {
   MAX_BODY_SIZE,
   createFileRL,
@@ -43,21 +43,14 @@ const io = new Server(httpServer, {
 let inactivityTimeout: NodeJS.Timeout | null = null;
 let isOwnerConnected = false;
 
-const containers: Record<string, Sandbox> = {};
+const terminals: {
-const connections: Record<string, number> = {};
+  [id: string]: Process;
-const terminals: Record<string, Terminal> = {};
+} = {};
+const containers: {
+  [id: string]: Sandbox;
+} = {};
 
-const dirName = "/home/user";
+const dirName = path.join(__dirname, "..");
-
-const moveFile = async (
-  filesystem: FilesystemManager,
-  filePath: string,
-  newFilePath: string
-) => {
-  const fileContents = await filesystem.readBytes(filePath);
-  await filesystem.writeBytes(newFilePath, fileContents);
-  await filesystem.remove(filePath);
-};
 
 io.use(async (socket, next) => {
   const handshakeSchema = z.object({
@@ -110,10 +103,33 @@ io.use(async (socket, next) => {
   next();
 });
 
+class LockManager {
+  private locks: { [key: string]: Promise<any> };
+
+  constructor() {
+    this.locks = {};
+  }
+
+  async acquireLock<T>(key: string, task: () => Promise<T>): Promise<T> {
+    if (!this.locks[key]) {
+      this.locks[key] = new Promise<T>(async (resolve, reject) => {
+        try {
+          const result = await task();
+          resolve(result);
+        } catch (error) {
+          reject(error);
+        } finally {
+          delete this.locks[key];
+        }
+      });
+    }
+    return await this.locks[key];
+  }
+}
+
 const lockManager = new LockManager();
 
 io.on("connection", async (socket) => {
-  try {
   if (inactivityTimeout) clearTimeout(inactivityTimeout);
 
   const data = socket.data as {
@@ -124,7 +140,6 @@ io.on("connection", async (socket) => {
 
   if (data.isOwner) {
     isOwnerConnected = true;
-      connections[data.sandboxId] = (connections[data.sandboxId] ?? 0) + 1;
   } else {
     if (!isOwnerConnected) {
       socket.emit("disableAccess", "The sandbox owner is not connected.");
@@ -133,124 +148,86 @@ io.on("connection", async (socket) => {
   }
 
   await lockManager.acquireLock(data.sandboxId, async () => {
-      try {
     if (!containers[data.sandboxId]) {
-          containers[data.sandboxId] = await Sandbox.create();
+      console.log("Creating container ", data.sandboxId);
-          console.log("Created container ", data.sandboxId);
+      containers[data.sandboxId] = await Sandbox.create({
-          io.emit(
+        template: "terminal",
-            "previewURL",
+      });
-            "https://" + containers[data.sandboxId].getHostname(5173)
+      console.log("Created.");
-          );
-        }
-      } catch (e: any) {
-        console.error(`Error creating container ${data.sandboxId}:`, e);
-        io.emit("error", `Error: container creation. ${e.message ?? e}`);
     }
   });
 
-    // Change the owner of the project directory to user
-    const fixPermissions = async () => {
-      await containers[data.sandboxId].process.startAndWait(
-        `sudo chown -R user "${path.join(dirName, "projects", data.sandboxId)}"`
-      );
-    };
-
   const sandboxFiles = await getSandboxFiles(data.sandboxId);
-    sandboxFiles.fileData.forEach(async (file) => {
+  sandboxFiles.fileData.forEach((file) => {
     const filePath = path.join(dirName, file.id);
-      await containers[data.sandboxId].filesystem.makeDir(
+    fs.mkdirSync(path.dirname(filePath), { recursive: true });
-        path.dirname(filePath)
+    fs.writeFile(filePath, file.data, function (err) {
-      );
+      if (err) throw err;
-      await containers[data.sandboxId].filesystem.write(filePath, file.data);
+    });
   });
-    fixPermissions();
 
   socket.emit("loaded", sandboxFiles.files);
 
   socket.on("getFile", (fileId: string, callback) => {
-      console.log(fileId);
-      try {
     const file = sandboxFiles.fileData.find((f) => f.id === fileId);
     if (!file) return;
 
     callback(file.data);
-      } catch (e: any) {
-        console.error("Error getting file:", e);
-        io.emit("error", `Error: get file. ${e.message ?? e}`);
-      }
   });
 
   socket.on("getFolder", async (folderId: string, callback) => {
-      try {
     const files = await getFolder(folderId);
     callback(files);
-      } catch (e: any) {
-        console.error("Error getting folder:", e);
-        io.emit("error", `Error: get folder. ${e.message ?? e}`);
-      }
   });
 
   // todo: send diffs + debounce for efficiency
   socket.on("saveFile", async (fileId: string, body: string) => {
     try {
+      await saveFileRL.consume(data.userId, 1);
+
       if (Buffer.byteLength(body, "utf-8") > MAX_BODY_SIZE) {
         socket.emit(
-            "error",
+          "rateLimit",
-            "Error: file size too large. Please reduce the file size."
+          "Rate limited: file size too large. Please reduce the file size."
         );
         return;
       }
-        try {
-          await saveFileRL.consume(data.userId, 1);
-          await saveFile(fileId, body);
-        } catch (e) {
-          io.emit("error", "Rate limited: file saving. Please slow down.");
-          return;
-        }
 
       const file = sandboxFiles.fileData.find((f) => f.id === fileId);
       if (!file) return;
       file.data = body;
 
-        await containers[data.sandboxId].filesystem.write(
+      fs.writeFile(path.join(dirName, file.id), body, function (err) {
-          path.join(dirName, file.id),
+        if (err) throw err;
-          body
+      });
-        );
+      await saveFile(fileId, body);
-        fixPermissions();
+    } catch (e) {
-      } catch (e: any) {
+      io.emit("rateLimit", "Rate limited: file saving. Please slow down.");
-        console.error("Error saving file:", e);
-        io.emit("error", `Error: file saving. ${e.message ?? e}`);
     }
   });
 
-    socket.on(
+  socket.on("moveFile", async (fileId: string, folderId: string, callback) => {
-      "moveFile",
-      async (fileId: string, folderId: string, callback) => {
-        try {
     const file = sandboxFiles.fileData.find((f) => f.id === fileId);
     if (!file) return;
 
     const parts = fileId.split("/");
     const newFileId = folderId + "/" + parts.pop();
 
-          await moveFile(
+    fs.rename(
-            containers[data.sandboxId].filesystem,
       path.join(dirName, fileId),
-            path.join(dirName, newFileId)
+      path.join(dirName, newFileId),
+      function (err) {
+        if (err) throw err;
+      }
     );
-          fixPermissions();
 
     file.id = newFileId;
 
     await renameFile(fileId, newFileId, file.data);
     const newFiles = await getSandboxFiles(data.sandboxId);
+
     callback(newFiles.files);
-        } catch (e: any) {
+  });
-          console.error("Error moving file:", e);
-          io.emit("error", `Error: file moving. ${e.message ?? e}`);
-        }
-      }
-    );
 
   socket.on("createFile", async (name: string, callback) => {
     try {
@@ -258,27 +235,19 @@ io.on("connection", async (socket) => {
       // limit is 200mb
       if (size > 200 * 1024 * 1024) {
         io.emit(
-            "error",
+          "rateLimit",
           "Rate limited: project size exceeded. Please delete some files."
         );
         callback({ success: false });
-          return;
       }
 
-        try {
       await createFileRL.consume(data.userId, 1);
-        } catch (e) {
-          io.emit("error", "Rate limited: file creation. Please slow down.");
-          return;
-        }
 
       const id = `projects/${data.sandboxId}/${name}`;
 
-        await containers[data.sandboxId].filesystem.write(
+      fs.writeFile(path.join(dirName, id), "", function (err) {
-          path.join(dirName, id),
+        if (err) throw err;
-          ""
+      });
-        );
-        fixPermissions();
 
       sandboxFiles.files.push({
         id,
@@ -294,42 +263,30 @@ io.on("connection", async (socket) => {
       await createFile(id);
 
       callback({ success: true });
-      } catch (e: any) {
+    } catch (e) {
-        console.error("Error creating file:", e);
+      io.emit("rateLimit", "Rate limited: file creation. Please slow down.");
-        io.emit("error", `Error: file creation. ${e.message ?? e}`);
     }
   });
 
   socket.on("createFolder", async (name: string, callback) => {
-      try {
     try {
       await createFolderRL.consume(data.userId, 1);
-        } catch (e) {
-          io.emit("error", "Rate limited: folder creation. Please slow down.");
-          return;
-        }
 
       const id = `projects/${data.sandboxId}/${name}`;
 
-        await containers[data.sandboxId].filesystem.makeDir(
+      fs.mkdir(path.join(dirName, id), { recursive: true }, function (err) {
-          path.join(dirName, id)
+        if (err) throw err;
-        );
+      });
 
       callback();
-      } catch (e: any) {
+    } catch (e) {
-        console.error("Error creating folder:", e);
+      io.emit("rateLimit", "Rate limited: folder creation. Please slow down.");
-        io.emit("error", `Error: folder creation. ${e.message ?? e}`);
     }
   });
 
   socket.on("renameFile", async (fileId: string, newName: string) => {
-      try {
     try {
       await renameFileRL.consume(data.userId, 1);
-        } catch (e) {
-          io.emit("error", "Rate limited: file renaming. Please slow down.");
-          return;
-        }
 
       const file = sandboxFiles.fileData.find((f) => f.id === fileId);
       if (!file) return;
@@ -339,33 +296,29 @@ io.on("connection", async (socket) => {
       const newFileId =
         parts.slice(0, parts.length - 1).join("/") + "/" + newName;
 
-        await moveFile(
+      fs.rename(
-          containers[data.sandboxId].filesystem,
         path.join(dirName, fileId),
-          path.join(dirName, newFileId)
+        path.join(dirName, newFileId),
+        function (err) {
+          if (err) throw err;
+        }
       );
-        fixPermissions();
       await renameFile(fileId, newFileId, file.data);
-      } catch (e: any) {
+    } catch (e) {
-        console.error("Error renaming folder:", e);
+      io.emit("rateLimit", "Rate limited: file renaming. Please slow down.");
-        io.emit("error", `Error: folder renaming. ${e.message ?? e}`);
+      return;
     }
   });
 
   socket.on("deleteFile", async (fileId: string, callback) => {
-      try {
     try {
       await deleteFileRL.consume(data.userId, 1);
-        } catch (e) {
-          io.emit("error", "Rate limited: file deletion. Please slow down.");
-        }
-
       const file = sandboxFiles.fileData.find((f) => f.id === fileId);
       if (!file) return;
 
-        await containers[data.sandboxId].filesystem.remove(
+      fs.unlink(path.join(dirName, fileId), function (err) {
-          path.join(dirName, fileId)
+        if (err) throw err;
-        );
+      });
       sandboxFiles.fileData = sandboxFiles.fileData.filter(
         (f) => f.id !== fileId
       );
@@ -374,9 +327,8 @@ io.on("connection", async (socket) => {
 
       const newFiles = await getSandboxFiles(data.sandboxId);
       callback(newFiles.files);
-      } catch (e: any) {
+    } catch (e) {
-        console.error("Error deleting file:", e);
+      io.emit("rateLimit", "Rate limited: file deletion. Please slow down.");
-        io.emit("error", `Error: file deletion. ${e.message ?? e}`);
     }
   });
 
@@ -385,14 +337,13 @@ io.on("connection", async (socket) => {
   // });
 
   socket.on("deleteFolder", async (folderId: string, callback) => {
-      try {
     const files = await getFolder(folderId);
 
     await Promise.all(
       files.map(async (file) => {
-            await containers[data.sandboxId].filesystem.remove(
+        fs.unlink(path.join(dirName, file), function (err) {
-              path.join(dirName, file)
+          if (err) throw err;
-            );
+        });
 
         sandboxFiles.fileData = sandboxFiles.fileData.filter(
           (f) => f.id !== file
@@ -405,74 +356,74 @@ io.on("connection", async (socket) => {
     const newFiles = await getSandboxFiles(data.sandboxId);
 
     callback(newFiles.files);
-      } catch (e: any) {
-        console.error("Error deleting folder:", e);
-        io.emit("error", `Error: folder deletion. ${e.message ?? e}`);
-      }
   });
 
+  function toBackslashNotation(input: string) {
+    return input
+      .replace(/\\/g, "\\\\") // Escape backslashes
+      .replace(/\n/g, "\\n") // Escape newlines
+      .replace(/\r/g, "\\r") // Escape carriage returns
+      .replace(/\t/g, "\\t") // Escape tabs
+      .replace(/"/g, '\\"') // Escape double quotes
+      .replace(/'/g, "\\'") // Escape single quotes
+      .replace(/\f/g, "\\f") // Escape form feeds
+      .replace(/\b/g, "\\b") // Escape backspaces
+      .replace(/\v/g, "\\v") // Escape vertical tabs
+      .replace(/\0/g, "\\0") // Escape null characters
+      .replace(/\a/g, "\\a") // Escape alert (bell)
+      .replace(/\e/g, "\\e"); // Escape escape
+  }
+
   socket.on("createTerminal", async (id: string, callback) => {
-      try {
     if (terminals[id] || Object.keys(terminals).length >= 4) {
       return;
     }
 
-        await lockManager.acquireLock(data.sandboxId, async () => {
+    const onData = (data: ProcessMessage) => {
-          try {
+      console.log("process", toBackslashNotation(data.toString()));
-            terminals[id] = await containers[data.sandboxId].terminal.start({
+      io.emit("terminalResponse", {
-              onData: (data: string) => {
+        id,
-                io.emit("terminalResponse", { id, data });
+        data: data.toString() + "\r\n",
-              },
-              size: { cols: 80, rows: 20 },
-              onExit: () => console.log("Terminal exited", id),
       });
-            await terminals[id].sendData(
+    };
-              `cd "${path.join(dirName, "projects", data.sandboxId)}"\r`
+
-            );
+    await lockManager.acquireLock(data.sandboxId, async () => {
-            await terminals[id].sendData("export PS1='user> '\rclear\r");
+      console.log("Creating terminal", id);
+      terminals[id] = await containers[data.sandboxId].process.start({
+        cmd: 'TERM=xterm script -c "screen" /dev/null', // xterm vt100
+        onStdout: onData,
+        onStderr: onData,
+        onExit: (code) => console.log("exit :(", code),
+      });
+      await terminals[id].sendStdin("clear\r\n");
+      await terminals[id].sendStdin("export PS1='user> '\r\n");
+      await terminals[id].sendStdin("clear\r\n");
       console.log("Created terminal", id);
-          } catch (e: any) {
-            console.error(`Error creating terminal ${id}:`, e);
-            io.emit("error", `Error: terminal creation. ${e.message ?? e}`);
-          }
     });
 
     callback();
-      } catch (e: any) {
-        console.error(`Error creating terminal ${id}:`, e);
-        io.emit("error", `Error: terminal creation. ${e.message ?? e}`);
-      }
   });
 
-    socket.on(
+  socket.on("resizeTerminal", (dimensions: { cols: number; rows: number }) => {
-      "resizeTerminal",
+    /*Object.values(terminals).forEach((t) => {
-      (dimensions: { cols: number; rows: number }) => {
+      t.terminal.resize(dimensions.cols, dimensions.rows);
-        try {
+    });*/
-          Object.values(terminals).forEach((t) => {
-            t.resize(dimensions);
   });
-        } catch (e: any) {
-          console.error("Error resizing terminal:", e);
-          io.emit("error", `Error: terminal resizing. ${e.message ?? e}`);
-        }
-      }
-    );
 
   socket.on("terminalData", (id: string, data: string) => {
-      try {
     if (!terminals[id]) {
       return;
     }
 
-        terminals[id].sendData(data);
+    try {
-      } catch (e: any) {
+      console.log(`Writing ${toBackslashNotation(data)} to ${id}`);
-        console.error("Error writing to terminal:", e);
+      terminals[id].sendStdin(data);
-        io.emit("error", `Error: writing to terminal. ${e.message ?? e}`);
+    } catch (e) {
+      console.log("Error writing to terminal", e);
     }
   });
 
   socket.on("closeTerminal", async (id: string, callback) => {
-      try {
     if (!terminals[id]) {
       return;
     }
@@ -481,10 +432,6 @@ io.on("connection", async (socket) => {
     delete terminals[id];
 
     callback();
-      } catch (e: any) {
-        console.error("Error closing terminal:", e);
-        io.emit("error", `Error: closing terminal. ${e.message ?? e}`);
-      }
   });
 
   socket.on(
@@ -496,7 +443,6 @@ io.on("connection", async (socket) => {
       instructions: string,
       callback
     ) => {
-        try {
       const fetchPromise = fetch(
         `${process.env.DATABASE_WORKER_URL}/api/sandbox/generate`,
         {
@@ -530,36 +476,23 @@ io.on("connection", async (socket) => {
       const json = await generateCodeResponse.json();
 
       callback({ response: json.response, success: true });
-        } catch (e: any) {
-          console.error("Error generating code:", e);
-          io.emit("error", `Error: code generation. ${e.message ?? e}`);
-        }
     }
   );
 
   socket.on("disconnect", async () => {
-      try {
     if (data.isOwner) {
-          connections[data.sandboxId]--;
+      Object.entries(terminals).forEach((t) => {
-        }
+        const terminal = t[1];
-
+        terminal.kill();
-        if (data.isOwner && connections[data.sandboxId] <= 0) {
+        delete terminals[t[0]];
-          await Promise.all(
+      });
-            Object.entries(terminals).map(async ([key, terminal]) => {
-              await terminal.kill();
-              delete terminals[key];
-            })
-          );
 
       await lockManager.acquireLock(data.sandboxId, async () => {
-            try {
         if (containers[data.sandboxId]) {
+          console.log("Closing container", data.sandboxId);
           await containers[data.sandboxId].close();
           delete containers[data.sandboxId];
-                console.log("Closed container", data.sandboxId);
+          console.log("Closed");
-              }
-            } catch (error) {
-              console.error("Error closing container ", data.sandboxId, error);
         }
       });
 
@@ -585,15 +518,7 @@ io.on("connection", async (socket) => {
     // } else {
     //   console.log("number of sockets", sockets.length);
     // }
-      } catch (e: any) {
-        console.log("Error disconnecting:", e);
-        io.emit("error", `Error: disconnecting. ${e.message ?? e}`);
-      }
   });
-  } catch (e: any) {
-    console.error("Error connecting:", e);
-    io.emit("error", `Error: connection. ${e.message ?? e}`);
-  }
 });
 
 httpServer.listen(port, () => {

backend/server/src/utils.ts

@@ -1,23 +1,177 @@
-export class LockManager {
+import * as dotenv from "dotenv";
-  private locks: { [key: string]: Promise<any> };
+import {
+  R2FileBody,
+  R2Files,
+  Sandbox,
+  TFile,
+  TFileData,
+  TFolder,
+} from "./types";
 
-  constructor() {
+dotenv.config();
-    this.locks = {};
+
+export const getSandboxFiles = async (id: string) => {
+  const res = await fetch(
+    `${process.env.STORAGE_WORKER_URL}/api?sandboxId=${id}`,
+    {
+      headers: {
+        Authorization: `${process.env.WORKERS_KEY}`,
+      },
+    }
+  );
+  const data: R2Files = await res.json();
+
+  const paths = data.objects.map((obj) => obj.key);
+  const processedFiles = await processFiles(paths, id);
+  return processedFiles;
+};
+
+export const getFolder = async (folderId: string) => {
+  const res = await fetch(
+    `${process.env.STORAGE_WORKER_URL}/api?folderId=${folderId}`,
+    {
+      headers: {
+        Authorization: `${process.env.WORKERS_KEY}`,
+      },
+    }
+  );
+  const data: R2Files = await res.json();
+
+  return data.objects.map((obj) => obj.key);
+};
+
+const processFiles = async (paths: string[], id: string) => {
+  const root: TFolder = { id: "/", type: "folder", name: "/", children: [] };
+  const fileData: TFileData[] = [];
+
+  paths.forEach((path) => {
+    const allParts = path.split("/");
+    if (allParts[1] !== id) {
+      return;
     }
 
-  async acquireLock<T>(key: string, task: () => Promise<T>): Promise<T> {
+    const parts = allParts.slice(2);
-    if (!this.locks[key]) {
+    let current: TFolder = root;
-      this.locks[key] = new Promise<T>(async (resolve, reject) => {
+
-        try {
+    for (let i = 0; i < parts.length; i++) {
-          const result = await task();
+      const part = parts[i];
-          resolve(result);
+      const isFile = i === parts.length - 1 && part.includes(".");
-        } catch (error) {
+      const existing = current.children.find((child) => child.name === part);
-          reject(error);
+
-        } finally {
+      if (existing) {
-          delete this.locks[key];
+        if (!isFile) {
+          current = existing as TFolder;
+        }
+      } else {
+        if (isFile) {
+          const file: TFile = { id: path, type: "file", name: part };
+          current.children.push(file);
+          fileData.push({ id: path, data: "" });
+        } else {
+          const folder: TFolder = {
+            // id: path, // todo: wrong id. for example, folder "src" ID is: projects/a7vgttfqbgy403ratp7du3ln/src/App.css
+            id: `projects/${id}/${parts.slice(0, i + 1).join("/")}`,
+            type: "folder",
+            name: part,
+            children: [],
+          };
+          current.children.push(folder);
+          current = folder;
+        }
+      }
     }
   });
+
+  await Promise.all(
+    fileData.map(async (file) => {
+      const data = await fetchFileContent(file.id);
+      file.data = data;
+    })
+  );
+
+  return {
+    files: root.children,
+    fileData,
+  };
+};
+
+const fetchFileContent = async (fileId: string): Promise<string> => {
+  try {
+    const fileRes = await fetch(
+      `${process.env.STORAGE_WORKER_URL}/api?fileId=${fileId}`,
+      {
+        headers: {
+          Authorization: `${process.env.WORKERS_KEY}`,
+        },
       }
-    return await this.locks[key];
+    );
+    return await fileRes.text();
+  } catch (error) {
+    console.error("ERROR fetching file:", error);
+    return "";
   }
+};
+
+export const createFile = async (fileId: string) => {
+  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `${process.env.WORKERS_KEY}`,
+    },
+    body: JSON.stringify({ fileId }),
+  });
+  return res.ok;
+};
+
+export const renameFile = async (
+  fileId: string,
+  newFileId: string,
+  data: string
+) => {
+  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api/rename`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `${process.env.WORKERS_KEY}`,
+    },
+    body: JSON.stringify({ fileId, newFileId, data }),
+  });
+  return res.ok;
+};
+
+export const saveFile = async (fileId: string, data: string) => {
+  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api/save`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `${process.env.WORKERS_KEY}`,
+    },
+    body: JSON.stringify({ fileId, data }),
+  });
+  return res.ok;
+};
+
+export const deleteFile = async (fileId: string) => {
+  const res = await fetch(`${process.env.STORAGE_WORKER_URL}/api`, {
+    method: "DELETE",
+    headers: {
+      "Content-Type": "application/json",
+      Authorization: `${process.env.WORKERS_KEY}`,
+    },
+    body: JSON.stringify({ fileId }),
+  });
+  return res.ok;
+};
+
+export const getProjectSize = async (id: string) => {
+  const res = await fetch(
+    `${process.env.STORAGE_WORKER_URL}/api/size?sandboxId=${id}`,
+    {
+      headers: {
+        Authorization: `${process.env.WORKERS_KEY}`,
+      },
     }
+  );
+  return (await res.json()).size;
+};

frontend/components/editor/index.tsx

@@ -1,9 +1,9 @@
 "use client"
 
-import { SetStateAction, useCallback, useEffect, useRef, useState } from "react"
+import { useEffect, useRef, useState } from "react"
 import monaco from "monaco-editor"
 import Editor, { BeforeMount, OnMount } from "@monaco-editor/react"
-import { Socket, io } from "socket.io-client"
+import { io } from "socket.io-client"
 import { toast } from "sonner"
 import { useClerk } from "@clerk/nextjs"
 
@@ -23,7 +23,7 @@ import Tab from "../ui/tab"
 import Sidebar from "./sidebar"
 import GenerateInput from "./generate"
 import { Sandbox, User, TFile, TFolder, TTab } from "@/lib/types"
-import { addNew, processFileType, validateName, debounce } from "@/lib/utils"
+import { addNew, processFileType, validateName } from "@/lib/utils"
 import { Cursors } from "./live/cursors"
 import { Terminal } from "@xterm/xterm"
 import DisableAccessModal from "./live/disableModal"
@@ -41,16 +41,12 @@ export default function CodeEditor({
   sandboxData: Sandbox
   reactDefinitionFile: string
 }) {
-  const socketRef = useRef<Socket | null>(null);
+  const socket = io(
-
+    `http://localhost:${process.env.NEXT_PUBLIC_SERVER_PORT}?userId=${userData.id}&sandboxId=${sandboxData.id}`,
-  // Initialize socket connection if it doesn't exist
-  if (!socketRef.current) {
-    socketRef.current = io(
-      `${window.location.protocol}//${window.location.hostname}:${process.env.NEXT_PUBLIC_SERVER_PORT}?userId=${userData.id}&sandboxId=${sandboxData.id}`,
     {
       timeout: 2000,
     }
-    );}
+  )
 
   const [isPreviewCollapsed, setIsPreviewCollapsed] = useState(true)
   const [disableAccess, setDisableAccess] = useState({
@@ -94,9 +90,6 @@ export default function CodeEditor({
     }[]
   >([])
 
-  // Preview state
-  const [previewURL, setPreviewURL] = useState<string>("");
-
   const isOwner = sandboxData.userId === userData.id
   const clerk = useClerk()
 
@@ -105,16 +98,6 @@ export default function CodeEditor({
   const [provider, setProvider] = useState<TypedLiveblocksProvider>()
   const userInfo = useSelf((me) => me.info)
 
-  // Liveblocks providers map to prevent reinitializing providers
-  type ProviderData = {
-    provider: LiveblocksProvider<never, never, never, never>;
-    yDoc: Y.Doc;
-    yText: Y.Text;
-    binding?: MonacoBinding;
-    onSync: (isSynced: boolean) => void;
-  };
-  const providersMap = useRef(new Map<string, ProviderData>());
-
   // Refs for libraries / features
   const editorContainerRef = useRef<HTMLDivElement>(null)
   const monacoRef = useRef<typeof monaco | null>(null)
@@ -307,33 +290,26 @@ export default function CodeEditor({
   }, [decorations.options])
 
   // Save file keybinding logic effect
-  const debouncedSaveData = useCallback(
+  useEffect(() => {
-    debounce((value: string | undefined, activeFileId: string | undefined) => {
+    const down = (e: KeyboardEvent) => {
+      if (e.key === "s" && (e.metaKey || e.ctrlKey)) {
+        e.preventDefault()
+
         setTabs((prev) =>
           prev.map((tab) =>
             tab.id === activeFileId ? { ...tab, saved: true } : tab
           )
-      );
+        )
-      console.log(`Saving file...${activeFileId}`);
-      console.log(`Saving file...${value}`);
-      socketRef.current?.emit("saveFile", activeFileId, value);
-    }, Number(process.env.FILE_SAVE_DEBOUNCE_DELAY)||1000),
-    [socketRef]
-  );
 
-  useEffect(() => {
+        socket.emit("saveFile", activeFileId, editorRef?.getValue())
-    const down = (e: KeyboardEvent) => {
-      if (e.key === "s" && (e.metaKey || e.ctrlKey)) {
-        e.preventDefault();
-        debouncedSaveData(editorRef?.getValue(), activeFileId);
       }
-    };
+    }
-    document.addEventListener("keydown", down);
+    document.addEventListener("keydown", down)
 
     return () => {
-      document.removeEventListener("keydown", down);
+      document.removeEventListener("keydown", down)
-    };
+    }
-  }, [activeFileId, tabs, debouncedSaveData]);
+  }, [tabs, activeFileId])
 
   // Liveblocks live collaboration setup effect
   useEffect(() => {
@@ -342,15 +318,10 @@ export default function CodeEditor({
 
     if (!editorRef || !tab || !model) return
 
-    let providerData: ProviderData;
+    const yDoc = new Y.Doc()
+    const yText = yDoc.getText(tab.id)
+    const yProvider: any = new LiveblocksProvider(room, yDoc)
 
-    // When a file is opened for the first time, create a new provider and store in providersMap.
-    if (!providersMap.current.has(tab.id)) {
-      const yDoc = new Y.Doc();
-      const yText = yDoc.getText(tab.id);
-      const yProvider = new LiveblocksProvider(room, yDoc);
-
-      // Inserts the file content into the editor once when the tab is changed.
     const onSync = (isSynced: boolean) => {
       if (isSynced) {
         const text = yText.toString()
@@ -368,58 +339,29 @@ export default function CodeEditor({
 
     yProvider.on("sync", onSync)
 
-      // Save the provider to the map.
+    setProvider(yProvider)
-      providerData = { provider: yProvider, yDoc, yText, onSync };
-      providersMap.current.set(tab.id, providerData);
-
-    } else {
-      // When a tab is opened that has been open before, reuse the existing provider.
-      providerData = providersMap.current.get(tab.id)!;
-    }
 
     const binding = new MonacoBinding(
-      providerData.yText,
+      yText,
       model,
       new Set([editorRef]),
-      providerData.provider.awareness as unknown as Awareness
+      yProvider.awareness as Awareness
-    );
+    )
-
-    providerData.binding = binding;
-  
-    setProvider(providerData.provider);
 
     return () => {
-      // Cleanup logic
+      yDoc.destroy()
-      if (binding) {
+      yProvider.destroy()
-        binding.destroy();
+      binding.destroy()
+      yProvider.off("sync", onSync)
     }
-      if (providerData.binding) {
+  }, [editorRef, room, activeFileContent])
-        providerData.binding = undefined;
-      }
-    };
-  }, [room, activeFileContent]);
-
-    // Added this effect to clean up when the component unmounts
-    useEffect(() => {
-      return () => {
-        // Clean up all providers when the component unmounts
-        providersMap.current.forEach((data) => {
-          if (data.binding) {
-            data.binding.destroy();
-          }
-          data.provider.disconnect();
-          data.yDoc.destroy();
-        });
-        providersMap.current.clear();
-      };
-    }, []);
 
   // Connection/disconnection effect
   useEffect(() => {
-    socketRef.current?.connect()
+    socket.connect()
 
     return () => {
-      socketRef.current?.disconnect()
+      socket.disconnect()
     }
   }, [])
 
@@ -435,7 +377,7 @@ export default function CodeEditor({
       setFiles(files)
     }
 
-    const onError = (message: string) => {
+    const onRateLimit = (message: string) => {
       toast.error(message)
     }
 
@@ -454,22 +396,20 @@ export default function CodeEditor({
         })
     }
 
-    socketRef.current?.on("connect", onConnect)
+    socket.on("connect", onConnect)
-    socketRef.current?.on("disconnect", onDisconnect)
+    socket.on("disconnect", onDisconnect)
-    socketRef.current?.on("loaded", onLoadedEvent)
+    socket.on("loaded", onLoadedEvent)
-    socketRef.current?.on("error", onError)
+    socket.on("rateLimit", onRateLimit)
-    socketRef.current?.on("terminalResponse", onTerminalResponse)
+    socket.on("terminalResponse", onTerminalResponse)
-    socketRef.current?.on("disableAccess", onDisableAccess)
+    socket.on("disableAccess", onDisableAccess)
-    socketRef.current?.on("previewURL", setPreviewURL)
 
     return () => {
-      socketRef.current?.off("connect", onConnect)
+      socket.off("connect", onConnect)
-      socketRef.current?.off("disconnect", onDisconnect)
+      socket.off("disconnect", onDisconnect)
-      socketRef.current?.off("loaded", onLoadedEvent)
+      socket.off("loaded", onLoadedEvent)
-      socketRef.current?.off("error", onError)
+      socket.off("rateLimit", onRateLimit)
-      socketRef.current?.off("terminalResponse", onTerminalResponse)
+      socket.off("terminalResponse", onTerminalResponse)
-      socketRef.current?.off("disableAccess", onDisableAccess)
+      socket.off("disableAccess", onDisableAccess)
-      socketRef.current?.off("previewURL", setPreviewURL)
     }
     // }, []);
   }, [terminals])
@@ -477,45 +417,32 @@ export default function CodeEditor({
   // Helper functions for tabs:
 
   // Select file and load content
+  const selectFile = (tab: TTab) => {
+    if (tab.id === activeFileId) return
 
-  // Initialize debounced function once
+    setGenerate((prev) => {
-  const fileCache = useRef(new Map());
+      return {
+        ...prev,
+        show: false,
+      }
+    })
+    const exists = tabs.find((t) => t.id === tab.id)
 
-  // Debounced function to get file content
-  const debouncedGetFile = useCallback(
-    debounce((tabId, callback) => {
-      socketRef.current?.emit('getFile', tabId, callback);
-    }, 300), // 300ms debounce delay, adjust as needed
-    []
-  );
-
-  const selectFile = useCallback((tab: TTab) => {
-    if (tab.id === activeFileId) return;
-
-    setGenerate((prev) => ({ ...prev, show: false }));
-
-    const exists = tabs.find((t) => t.id === tab.id);
     setTabs((prev) => {
       if (exists) {
-        setActiveFileId(exists.id);
+        setActiveFileId(exists.id)
-        return prev;
+        return prev
       }
-      return [...prev, tab];
+      return [...prev, tab]
-    });
+    })
 
-    if (fileCache.current.has(tab.id)) {
+    socket.emit("getFile", tab.id, (response: string) => {
-      setActiveFileContent(fileCache.current.get(tab.id));
+      setActiveFileContent(response)
-    } else {
+    })
-      debouncedGetFile(tab.id, (response: SetStateAction<string>) => {
+    setEditorLanguage(processFileType(tab.name))
-        fileCache.current.set(tab.id, response);
+    setActiveFileId(tab.id)
-        setActiveFileContent(response);
-      });
   }
 
-    setEditorLanguage(processFileType(tab.name));
-    setActiveFileId(tab.id);
-  }, [activeFileId, tabs, debouncedGetFile]);
-
   // Close tab and remove from tabs
   const closeTab = (id: string) => {
     const numTabs = tabs.length
@@ -588,7 +515,7 @@ export default function CodeEditor({
       return false
     }
 
-    socketRef.current?.emit("renameFile", id, newName)
+    socket.emit("renameFile", id, newName)
     setTabs((prev) =>
       prev.map((tab) => (tab.id === id ? { ...tab, name: newName } : tab))
     )
@@ -597,7 +524,7 @@ export default function CodeEditor({
   }
 
   const handleDeleteFile = (file: TFile) => {
-    socketRef.current?.emit("deleteFile", file.id, (response: (TFolder | TFile)[]) => {
+    socket.emit("deleteFile", file.id, (response: (TFolder | TFile)[]) => {
       setFiles(response)
     })
     closeTab(file.id)
@@ -607,11 +534,11 @@ export default function CodeEditor({
     setDeletingFolderId(folder.id)
     console.log("deleting folder", folder.id)
 
-    socketRef.current?.emit("getFolder", folder.id, (response: string[]) =>
+    socket.emit("getFolder", folder.id, (response: string[]) =>
       closeTabs(response)
     )
 
-    socketRef.current?.emit("deleteFolder", folder.id, (response: (TFolder | TFile)[]) => {
+    socket.emit("deleteFolder", folder.id, (response: (TFolder | TFile)[]) => {
       setFiles(response)
       setDeletingFolderId("")
     })
@@ -638,7 +565,7 @@ export default function CodeEditor({
         {generate.show && ai ? (
           <GenerateInput
             user={userData}
-            socket={socketRef.current}
+            socket={socket}
             width={generate.width - 90}
             data={{
               fileName: tabs.find((t) => t.id === activeFileId)?.name ?? "",
@@ -698,7 +625,7 @@ export default function CodeEditor({
         handleRename={handleRename}
         handleDeleteFile={handleDeleteFile}
         handleDeleteFolder={handleDeleteFolder}
-        socket={socketRef.current}
+        socket={socket}
         setFiles={setFiles}
         addNew={(name, type) => addNew(name, type, setFiles, sandboxData)}
         deletingFolderId={deletingFolderId}
@@ -818,7 +745,6 @@ export default function CodeEditor({
                   previewPanelRef.current?.expand()
                   setIsPreviewCollapsed(false)
                 }}
-                src={previewURL}
               />
             </ResizablePanel>
             <ResizableHandle />
@@ -831,7 +757,7 @@ export default function CodeEditor({
                 <Terminals
                   terminals={terminals}
                   setTerminals={setTerminals}
-                  socket={socketRef.current}
+                  socket={socket}
                 />
               ) : (
                 <div className="w-full h-full flex items-center justify-center text-lg font-medium text-muted-foreground/50 select-none">
@@ -846,4 +772,3 @@ export default function CodeEditor({
     </>
   )
 }
-

frontend/components/editor/preview/index.tsx

@@ -15,11 +15,9 @@ import { toast } from "sonner"
 export default function PreviewWindow({
   collapsed,
   open,
-  src
 }: {
   collapsed: boolean
   open: () => void
-  src: string
 }) {
   const ref = useRef<HTMLIFrameElement>(null)
   const [iframeKey, setIframeKey] = useState(0)
@@ -47,7 +45,7 @@ export default function PreviewWindow({
 
                 <PreviewButton
                   onClick={() => {
-                    navigator.clipboard.writeText(src)
+                    navigator.clipboard.writeText(`http://localhost:5173`)
                     toast.info("Copied preview link to clipboard")
                   }}
                 >
@@ -75,7 +73,7 @@ export default function PreviewWindow({
             ref={ref}
             width={"100%"}
             height={"100%"}
-            src={src}
+            src={`http://localhost:5173`}
           />
         </div>
       )}

frontend/lib/utils.ts

@@ -61,13 +61,3 @@ export function addNew(
     ])
   }
 }
-
-export function debounce<T extends (...args: any[]) => void>(func: T, wait: number): T {
-  let timeout: NodeJS.Timeout | null = null;
-  return function (...args: Parameters<T>) {
-      if (timeout) {
-          clearTimeout(timeout);
-      }
-      timeout = setTimeout(() => func(...args), wait);
-  } as T;
-}