TNT-Flo/sandbox-web-ide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: restructure error handling

Browse Source
This commit is contained in:
James Murdza 2024-10-25 06:40:47 -06:00
parent a6f457ef59
commit 2eb2388e12
1 changed files with 39 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
backend/server/src/index.ts
View File

@ -107,50 +107,52 @@ io.on("connection", async (socket) => {
} }
} }
const sandboxManager = sandboxManagers[data.sandboxId] ?? new SandboxManager(
data.sandboxId,
data.userId,
{ aiWorker, dokkuClient, gitClient, socket }
)
try { try {
const sandboxManager = sandboxManagers[data.sandboxId] ?? new SandboxManager(
data.sandboxId,
data.userId,
{ aiWorker, dokkuClient, gitClient, socket }
)
sandboxManager.initializeContainer() sandboxManager.initializeContainer()
Object.entries(sandboxManager.handlers()).forEach(([event, handler]) => {
socket.on(event, async (options: any, callback?: (response: any) => void) => {
try {
const response = await handler(options)
callback?.(response);
} catch (e: any) {
console.error(`Error processing event "${event}":`, e);
socket.emit("error", `Error: ${event}. ${e.message ?? e}`);
}
});
});
socket.on("disconnect", async () => {
try {
if (data.isOwner) {
connections[data.sandboxId]--
}
await sandboxManager.disconnect()
if (data.isOwner && connections[data.sandboxId] <= 0) {
socket.broadcast.emit(
"disableAccess",
"The sandbox owner has disconnected."
)
}
} catch (e: any) {
console.log("Error disconnecting:", e)
socket.emit("error", `Error: disconnecting. ${e.message ?? e}`)
}
})
} catch (e: any) { } catch (e: any) {
console.error(`Error initializing sandbox ${data.sandboxId}:`, e); console.error(`Error initializing sandbox ${data.sandboxId}:`, e);
socket.emit("error", `Error: initialize sandbox ${data.sandboxId}. ${e.message ?? e}`); socket.emit("error", `Error: initialize sandbox ${data.sandboxId}. ${e.message ?? e}`);
} }
Object.entries(sandboxManager.handlers()).forEach(([event, handler]) => {
socket.on(event, async (options: any, callback?: (response: any) => void) => {
try {
const response = await handler(options)
callback?.(response);
} catch (e: any) {
console.error(`Error processing event "${event}":`, e);
socket.emit("error", `Error: ${event}. ${e.message ?? e}`);
}
});
});
socket.on("disconnect", async () => {
try {
if (data.isOwner) {
connections[data.sandboxId]--
}
await sandboxManager.disconnect()
if (data.isOwner && connections[data.sandboxId] <= 0) {
socket.broadcast.emit(
"disableAccess",
"The sandbox owner has disconnected."
)
}
} catch (e: any) {
console.log("Error disconnecting:", e)
socket.emit("error", `Error: disconnecting. ${e.message ?? e}`)
}
})
} catch (e: any) { } catch (e: any) {
console.error("Error connecting:", e) console.error("Error connecting:", e)
socket.emit("error", `Error: connection. ${e.message ?? e}`) socket.emit("error", `Error: connection. ${e.message ?? e}`)