Create server.js

server.js

@@ -0,0 +1,148 @@
+const express = require('express');
+const { spawn } = require('child_process');
+const fs = require('fs');
+const path = require('path');
+const app = express();
+const http = require('http').createServer(app);
+const io = require('socket.io')(http);
+
+// Middleware
+app.use(express.static('public'));
+app.use(express.json());
+
+// User directories base path
+const USERS_DIR = path.join(__dirname, 'users');
+
+// Create users directory if it doesn't exist
+if (!fs.existsSync(USERS_DIR)) {
+  fs.mkdirSync(USERS_DIR, { recursive: true });
+}
+
+// Socket.io connection handler
+io.on('connection', (socket) => {
+  console.log('A user connected');
+
+  // Handle repository cloning
+  socket.on('cloneRepo', ({ userId, repoUrl }) => {
+    const userDir = path.join(USERS_DIR, userId);
+    
+    // Create user directory if it doesn't exist
+    if (!fs.existsSync(userDir)) {
+      fs.mkdirSync(userDir, { recursive: true });
+    }
+
+    // Clone the repository
+    const gitClone = spawn('git', ['clone', repoUrl, '.'], { cwd: userDir });
+
+    gitClone.stdout.on('data', (data) => {
+      socket.emit('output', data.toString());
+    });
+
+    gitClone.stderr.on('data', (data) => {
+      socket.emit('output', data.toString());
+    });
+
+    gitClone.on('close', (code) => {
+      if (code === 0) {
+        socket.emit('output', '✅ Repository cloned successfully!');
+        socket.emit('repoCloned', { success: true });
+      } else {
+        socket.emit('output', '❌ Failed to clone repository');
+        socket.emit('repoCloned', { success: false });
+      }
+    });
+  });
+
+  // Handle npm/yarn install
+  socket.on('installDeps', ({ userId, packageManager }) => {
+    const userDir = path.join(USERS_DIR, userId);
+    const command = packageManager === 'yarn' ? 'yarn' : 'npm';
+    const args = ['install'];
+
+    const installProcess = spawn(command, args, { cwd: userDir });
+
+    installProcess.stdout.on('data', (data) => {
+      socket.emit('output', data.toString());
+    });
+
+    installProcess.stderr.on('data', (data) => {
+      socket.emit('output', data.toString());
+    });
+
+    installProcess.on('close', (code) => {
+      if (code === 0) {
+        socket.emit('output', '✅ Dependencies installed successfully!');
+      } else {
+        socket.emit('output', '❌ Failed to install dependencies');
+      }
+    });
+  });
+
+  // Handle starting the application
+  socket.on('startApp', ({ userId, startCommand }) => {
+    const userDir = path.join(USERS_DIR, userId);
+    const [command, ...args] = startCommand.split(' ');
+
+    const startProcess = spawn(command, args, { cwd: userDir });
+
+    startProcess.stdout.on('data', (data) => {
+      socket.emit('output', data.toString());
+    });
+
+    startProcess.stderr.on('data', (data) => {
+      socket.emit('output', data.toString());
+    });
+
+    startProcess.on('close', (code) => {
+      socket.emit('output', `Process exited with code ${code}`);
+    });
+
+    // Store the process reference so we can kill it later
+    socket.process = startProcess;
+  });
+
+  // Handle stopping the application
+  socket.on('stopApp', () => {
+    if (socket.process) {
+      socket.process.kill();
+      socket.emit('output', '🛑 Application stopped');
+    } else {
+      socket.emit('output', 'No running process to stop');
+    }
+  });
+
+  // Handle file operations
+  socket.on('readFile', ({ userId, filePath }) => {
+    const fullPath = path.join(USERS_DIR, userId, filePath);
+    
+    fs.readFile(fullPath, 'utf8', (err, data) => {
+      if (err) {
+        socket.emit('output', `❌ Error reading file: ${err.message}`);
+      } else {
+        socket.emit('fileContent', { filePath, content: data });
+      }
+    });
+  });
+
+  socket.on('writeFile', ({ userId, filePath, content }) => {
+    const fullPath = path.join(USERS_DIR, userId, filePath);
+    
+    fs.writeFile(fullPath, content, 'utf8', (err) => {
+      if (err) {
+        socket.emit('output', `❌ Error writing file: ${err.message}`);
+      } else {
+        socket.emit('output', `✅ File ${filePath} saved successfully`);
+      }
+    });
+  });
+
+  socket.on('disconnect', () => {
+    console.log('User disconnected');
+    if (socket.process) {
+      socket.process.kill();
+    }
+  });
+});
+
+const PORT = process.env.PORT || 7860;
+http.listen(PORT, () => console.log(`🌐 Server running on port ${PORT}`));