fix 503 workspace lock

dist/lib/docker/manager.js

@@ -43,6 +43,8 @@ exports.pendingProvisioning = new Map();
 function isNativeWorkspaceRunning(id) {
     if (exports.nativeProcesses.has(id))
         return true;
+    if (exports.pendingProvisioning.has(id))
+        return true;
     // Prefix fallback for reconnected sessions
     return Array.from(exports.nativeProcesses.keys()).some(k => id.startsWith(k));
 }
@@ -174,7 +176,14 @@ async function performProvisioning(config) {
             fs_1.default.writeFileSync(path_1.default.join(workspacePath, '.codeverse-id'), config.id);
             log(`Allocated isolated filesystem segment: ${config.id.slice(0, 8)}`);
         }
-        // 2. IDX Engine: Sync Environment
+        // 2. Register in active pool (EARLY REGISTRATION: satisfy proxy health checks)
+        const port = findAvailablePort();
+        exports.nativeProcesses.set(config.id, {
+            pid: -1, // PID not yet available
+            port,
+            process: { kill: () => true, pid: -1 }
+        });
+        // 3. IDX Engine: Sync Environment
         const idxConfig = idx_engine_1.IdxEngine.getIdxConfig(workspacePath);
         log(`Declarative config detected (Packages: ${idxConfig.packages.length}). Initializing synchronization...`);
         await idx_engine_1.IdxEngine.syncNixEnvironment(workspacePath, idxConfig, (msg) => log(msg));
@@ -186,8 +195,6 @@ async function performProvisioning(config) {
             }
             fs_1.default.writeFileSync(flagPath, new Date().toISOString());
         }
-        // 4. Identify Target Port
-        const port = findAvailablePort();
         // 5. Spawn code-server
         const shellCommand = process.platform === 'win32' ? 'npx' : 'code-server';
         const args = process.platform === 'win32' ? ['code-server'] : [];
@@ -223,8 +230,9 @@ async function performProvisioning(config) {
         });
         child.on('close', (code, signal) => {
             log(`[IDE:EXIT] IDE process died with code ${code} (Signal: ${signal})`);
+            exports.nativeProcesses.delete(config.id);
         });
-        // 6. Register in active pool
+        // 6. Update Registry with real Process
         exports.nativeProcesses.set(config.id, { pid: child.pid, port, process: child });
         // 7. Handshake Loop
         let attempts = 0;

dist/lib/idx/idx-engine.js

@@ -150,7 +150,8 @@ class IdxEngine {
                     ...process.env,
                     HOME: workspacePath,
                     NIX_CONFIG: 'experimental-features = nix-command flakes'
-                }
+                },
+                timeout: 300000 // 5-minute safety timeout
             });
             child.stdout.on('data', (data) => log(data.toString().trim()));
             child.stderr.on('data', (data) => log(`[INFO] ${data.toString().trim()}`));

dist/server.js

@@ -205,8 +205,8 @@ const server = (0, http_1.createServer)((req, res) => {
     const workspaceHostMatch = host.match(/^workspace-([a-zA-Z0-9-]+)\./);
     const id = workspaceHostMatch ? workspaceHostMatch[1] : ((pathname === null || pathname === void 0 ? void 0 : pathname.startsWith("/workspace/")) ? pathname.split("/")[2] : null);
     if (id) {
-        const isReady = (0, manager_1.isNativeWorkspaceRunning)(id);
-        if (isReady) {
+        const isRunning = (0, manager_1.isNativeWorkspaceRunning)(id);
+        if (isRunning) {
             const port = (0, manager_1.getNativeWorkspacePort)(id) || 8080;
             req.headers['x-codeverse-id'] = id;
             req.headers['x-codeverse-type'] = 'workspace';
@@ -219,26 +219,30 @@ const server = (0, http_1.createServer)((req, res) => {
             return proxy.web(req, res, { target: `http://127.0.0.1:${port}`, changeOrigin: true });
         }
         else if (!(pathname === null || pathname === void 0 ? void 0 : pathname.startsWith("/api/"))) {
-            // 🚑 WORKSPACE BOOTING FALLBACK: Prevent Next.js 404 while workspace is initializing
+            // 🚑 WORKSPACE OFFLINE OR BOOTING: Detect if it's truly gone or just waking up
             res.writeHead(503, { 'Content-Type': 'text/html', 'Retry-After': '5' });
             return res.end(`
                 <html>
                     <head>
-                        <title>CodeVerse | Booting Workspace</title>
+                        <title>CodeVerse | Workspace Status</title>
                         <style>
                             body { background: #09090b; color: #71717a; font-family: sans-serif; display: flex; align-items: center; justify-content: center; height: 100vh; margin: 0; }
-                            .container { text-align: center; border: 1px solid #27272a; padding: 2rem; border-radius: 1rem; background: #111113; }
-                            .spinner { width: 40px; height: 40px; border: 3px solid #3f3f46; border-top-color: #3b82f6; border-radius: 50%; animation: spin 1s linear infinite; margin: 0 auto 1.5rem; }
-                            h1 { color: #f4f4f5; font-size: 1.25rem; }
+                            .container { text-align: center; border: 1px solid #27272a; padding: 2.5rem; border-radius: 1rem; background: #111113; max-width: 450px; }
+                            .spinner { width: 30px; height: 30px; border: 2px solid #3f3f46; border-top-color: #3b82f6; border-radius: 50%; animation: spin 1s linear infinite; margin: 0 auto 1.5rem; }
+                            h1 { color: #f4f4f5; font-size: 1.25rem; margin: 0 0 1rem; }
+                            p { font-size: 0.9rem; margin-bottom: 2rem; line-height: 1.6; }
+                            .btn { background: #3b82f6; color: white; padding: 0.75rem 1.5rem; border-radius: 0.5rem; text-decoration: none; font-weight: bold; display: inline-block; transition: background 0.2s; }
+                            .btn:hover { background: #2563eb; }
                             @keyframes spin { to { transform: rotate(360deg); } }
                         </style>
-                        <script>setTimeout(() => window.location.reload(), 3000);</script>
+                        <script>setTimeout(() => window.location.reload(), 5000);</script>
                     </head>
                     <body>
                         <div class="container">
                             <div class="spinner"></div>
-                            <h1>Workspace is Booting</h1>
-                            <p>Preparing your agentic session...</p>
+                            <h1>Provisioning Environment</h1>
+                            <p>We're restoring your workspace from cold storage. This usually takes 30-60 seconds depending on the Nix profile complexity.</p>
+                            <a href="/" class="btn">Return to Dashboard</a>
                         </div>
                     </body>
                 </html>
@@ -250,7 +254,7 @@ const server = (0, http_1.createServer)((req, res) => {
 });
 // Setup Sockets
 const io = new socket_io_1.Server(server, { path: "/api/socketio" });
-const yjsWss = new ws_1.WebSocketServer({ noServer: true });
+const shoket = new ws_1.WebSocketServer({ noServer: true });
 // Start Listening Immediately
 server.listen(PORT, HOST, () => {
     console.log('----------------------------------------------------');
@@ -287,13 +291,13 @@ server.listen(PORT, HOST, () => {
 server.on("upgrade", (req, socket, head) => {
     const { pathname } = new URL(req.url || "/", `http://${req.headers.host}`);
     if (pathname === "/api/collab") {
-        yjsWss.handleUpgrade(req, socket, head, (ws) => {
-            yjsWss.emit("connection", ws, req);
+        shoket.handleUpgrade(req, socket, head, (ws) => {
+            shoket.emit("connection", ws, req);
         });
     }
 });
-yjsWss.on("connection", (conn, request) => {
-    const { doc, awareness } = getOrCreateDoc(new URL(request.url || "/", "http://l").searchParams.get('doc') || "default");
+shoket.on("connection", (conn, request) => {
+    const { doc } = getOrCreateDoc(new URL(request.url || "/", "http://l").searchParams.get('doc') || "default");
     conn.binaryType = "arraybuffer";
     const encoder = encoding.createEncoder();
     encoding.writeVarUint(encoder, 0);

lib/docker/manager.ts

@@ -39,6 +39,7 @@ export const pendingProvisioning = new Map<string, Promise<WorkspaceOperationRes
  */
 export function isNativeWorkspaceRunning(id: string): boolean {
     if (nativeProcesses.has(id)) return true;
+    if (pendingProvisioning.has(id)) return true;
     // Prefix fallback for reconnected sessions
     return Array.from(nativeProcesses.keys()).some(k => id.startsWith(k));
 }
@@ -204,7 +205,15 @@ async function performProvisioning(config: WorkspaceConfig): Promise<WorkspaceOp
         log(`Allocated isolated filesystem segment: ${config.id.slice(0, 8)}`);
     }
 
-    // 2. IDX Engine: Sync Environment
+    // 2. Register in active pool (EARLY REGISTRATION: satisfy proxy health checks)
+    const port = findAvailablePort();
+    nativeProcesses.set(config.id, { 
+        pid: -1, // PID not yet available
+        port, 
+        process: { kill: () => true, pid: -1 } as unknown as WorkspaceProcess 
+    });
+
+    // 3. IDX Engine: Sync Environment
     const idxConfig = IdxEngine.getIdxConfig(workspacePath);
     log(`Declarative config detected (Packages: ${idxConfig.packages.length}). Initializing synchronization...`);
     
@@ -219,9 +228,6 @@ async function performProvisioning(config: WorkspaceConfig): Promise<WorkspaceOp
         fs.writeFileSync(flagPath, new Date().toISOString());
     }
 
-        // 4. Identify Target Port
-        const port = findAvailablePort();
-
         // 5. Spawn code-server
         const shellCommand = process.platform === 'win32' ? 'npx' : 'code-server';
         const args = process.platform === 'win32' ? ['code-server'] : [];
@@ -261,9 +267,10 @@ async function performProvisioning(config: WorkspaceConfig): Promise<WorkspaceOp
 
         child.on('close', (code, signal) => {
             log(`[IDE:EXIT] IDE process died with code ${code} (Signal: ${signal})`);
+            nativeProcesses.delete(config.id);
         });
 
-        // 6. Register in active pool
+        // 6. Update Registry with real Process
         nativeProcesses.set(config.id, { pid: child.pid!, port, process: child });
 
         // 7. Handshake Loop

lib/idx/idx-engine.ts

@@ -164,7 +164,8 @@ export class IdxEngine {
                 ...process.env, 
                 HOME: workspacePath,
                 NIX_CONFIG: 'experimental-features = nix-command flakes'
-            }
+            },
+            timeout: 300000 // 5-minute safety timeout
         });
 
         child.stdout.on('data', (data) => log(data.toString().trim()));

server.ts

@@ -185,8 +185,9 @@ const server = createServer((req: IncomingMessage, res: ServerResponse) => {
     const id = workspaceHostMatch ? workspaceHostMatch[1] : (pathname?.startsWith("/workspace/") ? pathname.split("/")[2] : null);
 
     if (id) {
-        const isReady = isNativeWorkspaceRunning(id);
-        if (isReady) {
+        const isRunning = isNativeWorkspaceRunning(id);
+        
+        if (isRunning) {
             const port = getNativeWorkspacePort(id) || 8080;
             req.headers['x-codeverse-id'] = id;
             req.headers['x-codeverse-type'] = 'workspace';
@@ -197,26 +198,30 @@ const server = createServer((req: IncomingMessage, res: ServerResponse) => {
             }
             return proxy.web(req, res, { target: `http://127.0.0.1:${port}`, changeOrigin: true });
         } else if (!pathname?.startsWith("/api/")) {
-            // 🚑 WORKSPACE BOOTING FALLBACK: Prevent Next.js 404 while workspace is initializing
+            // 🚑 WORKSPACE OFFLINE OR BOOTING: Detect if it's truly gone or just waking up
             res.writeHead(503, { 'Content-Type': 'text/html', 'Retry-After': '5' });
             return res.end(`
                 <html>
                     <head>
-                        <title>CodeVerse | Booting Workspace</title>
+                        <title>CodeVerse | Workspace Status</title>
                         <style>
                             body { background: #09090b; color: #71717a; font-family: sans-serif; display: flex; align-items: center; justify-content: center; height: 100vh; margin: 0; }
-                            .container { text-align: center; border: 1px solid #27272a; padding: 2rem; border-radius: 1rem; background: #111113; }
-                            .spinner { width: 40px; height: 40px; border: 3px solid #3f3f46; border-top-color: #3b82f6; border-radius: 50%; animation: spin 1s linear infinite; margin: 0 auto 1.5rem; }
-                            h1 { color: #f4f4f5; font-size: 1.25rem; }
+                            .container { text-align: center; border: 1px solid #27272a; padding: 2.5rem; border-radius: 1rem; background: #111113; max-width: 450px; }
+                            .spinner { width: 30px; height: 30px; border: 2px solid #3f3f46; border-top-color: #3b82f6; border-radius: 50%; animation: spin 1s linear infinite; margin: 0 auto 1.5rem; }
+                            h1 { color: #f4f4f5; font-size: 1.25rem; margin: 0 0 1rem; }
+                            p { font-size: 0.9rem; margin-bottom: 2rem; line-height: 1.6; }
+                            .btn { background: #3b82f6; color: white; padding: 0.75rem 1.5rem; border-radius: 0.5rem; text-decoration: none; font-weight: bold; display: inline-block; transition: background 0.2s; }
+                            .btn:hover { background: #2563eb; }
                             @keyframes spin { to { transform: rotate(360deg); } }
                         </style>
-                        <script>setTimeout(() => window.location.reload(), 3000);</script>
+                        <script>setTimeout(() => window.location.reload(), 5000);</script>
                     </head>
                     <body>
                         <div class="container">
                             <div class="spinner"></div>
-                            <h1>Workspace is Booting</h1>
-                            <p>Preparing your agentic session...</p>
+                            <h1>Provisioning Environment</h1>
+                            <p>We're restoring your workspace from cold storage. This usually takes 30-60 seconds depending on the Nix profile complexity.</p>
+                            <a href="/" class="btn">Return to Dashboard</a>
                         </div>
                     </body>
                 </html>
@@ -230,7 +235,7 @@ const server = createServer((req: IncomingMessage, res: ServerResponse) => {
 
 // Setup Sockets
 const io = new Server(server, { path: "/api/socketio" });
-const yjsWss = new WebSocketServer({ noServer: true });
+const shoket = new WebSocketServer({ noServer: true });
 
 // Start Listening Immediately
 server.listen(PORT, HOST, () => {
@@ -273,14 +278,14 @@ server.listen(PORT, HOST, () => {
 server.on("upgrade", (req, socket, head) => {
     const { pathname } = new URL(req.url || "/", `http://${req.headers.host}`);
     if (pathname === "/api/collab") {
-        yjsWss.handleUpgrade(req, socket, head, (ws) => {
-            yjsWss.emit("connection", ws, req);
+        shoket.handleUpgrade(req, socket, head, (ws) => {
+            shoket.emit("connection", ws, req);
         });
     }
 });
 
-yjsWss.on("connection", (conn: WebSocket, request: IncomingMessage) => {
-    const { doc, awareness } = getOrCreateDoc(new URL(request.url || "/", "http://l").searchParams.get('doc') || "default");
+shoket.on("connection", (conn: WebSocket, request: IncomingMessage) => {
+    const { doc } = getOrCreateDoc(new URL(request.url || "/", "http://l").searchParams.get('doc') || "default");
     conn.binaryType = "arraybuffer";
     const encoder = encoding.createEncoder();
     encoding.writeVarUint(encoder, 0);