Update app.py

app.py

@@ -8,6 +8,9 @@ import requests
 from urllib.parse import urlencode
 import aiofiles
 import asyncio
+import subprocess
+import tempfile
+import shutil
 
 app = FastAPI()
 deployments = {}
@@ -48,22 +51,53 @@ class RepoSelectRequest(BaseModel):
     repo_full_name: str
 
 async def simulate_deployment(deploy_id, user_id, repo_full_name):
-    logs = [
-        f"Starting deployment for {repo_full_name}...",
-        "Cloning repository...",
-        "Installing dependencies...",
-        "Setting environment variables...",
-        "Running build...",
-        "Deploying application...",
-        "Finalizing...",
-        "Deployment successful!"
-    ]
     deploy_logs[deploy_id] = []
     deploy_status[deploy_id] = "deploying"
-    for log in logs:
-        deploy_logs[deploy_id].append(log)
-        await asyncio.sleep(2)  # Simulate time between log lines
-    deploy_status[deploy_id] = "success"
+    temp_dir = tempfile.mkdtemp()
+    try:
+        # 1. Clone the repo
+        cmd = ["git", "clone", f"https://github.com/{repo_full_name}.git", temp_dir]
+        proc = await asyncio.create_subprocess_exec(*cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.STDOUT)
+        while True:
+            line = await proc.stdout.readline()
+            if not line:
+                break
+            deploy_logs[deploy_id].append(line.decode().rstrip())
+        await proc.wait()
+        # 2. Install dependencies (if requirements.txt exists)
+        req_path = f"{temp_dir}/requirements.txt"
+        if os.path.exists(req_path):
+            cmd = ["pip", "install", "-r", req_path]
+            proc = await asyncio.create_subprocess_exec(*cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.STDOUT)
+            while True:
+                line = await proc.stdout.readline()
+                if not line:
+                    break
+                deploy_logs[deploy_id].append(line.decode().rstrip())
+            await proc.wait()
+        # 3. Set environment variables from .env (if uploaded)
+        env_content = env_files.get((user_id, repo_full_name))
+        if env_content:
+            env_path = f"{temp_dir}/.env"
+            with open(env_path, "w") as f:
+                f.write(env_content)
+            deploy_logs[deploy_id].append(".env file written.")
+        # 4. (Optional) Run build or start script if present
+        # For demo, just list files
+        cmd = ["ls", "-l", temp_dir]
+        proc = await asyncio.create_subprocess_exec(*cmd, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.STDOUT)
+        while True:
+            line = await proc.stdout.readline()
+            if not line:
+                break
+            deploy_logs[deploy_id].append(line.decode().rstrip())
+        await proc.wait()
+        deploy_status[deploy_id] = "success"
+    except Exception as e:
+        deploy_logs[deploy_id].append(f"Error: {e}")
+        deploy_status[deploy_id] = "failed"
+    finally:
+        shutil.rmtree(temp_dir, ignore_errors=True)
 
 @app.post("/deploy")
 async def deploy(req: DeployRequest, background_tasks: BackgroundTasks):