Update app.py

app.py

@@ -2,33 +2,26 @@ import subprocess
 import asyncio
 import os
 import psutil
-import shutil
-from fastapi import FastAPI, WebSocket, WebSocketDisconnect
+import httpx
+from fastapi import FastAPI, WebSocket, WebSocketDisconnect, UploadFile, File
 from fastapi.responses import HTMLResponse, JSONResponse
+from fastapi.staticfiles import StaticFiles
+from typing import List
 
 app = FastAPI()
-ACCESS_PASSWORD = "admin" # আপনার পাসওয়ার্ড
+ACCESS_PASSWORD = "admin" # আপনার পাসওয়ার্ড পরিবর্তন করুন
 
 @app.get("/")
 async def get():
     with open("index.html", "r", encoding="utf-8") as f:
         return HTMLResponse(content=f.read())
 
-@app.get("/api/metrics")
-async def get_metrics():
-    return {
-        "cpu": psutil.cpu_percent(),
-        "ram": psutil.virtual_memory().percent,
-        "disk": psutil.disk_usage('/').percent,
-        "uptime": shutil.disk_usage("/").total // (1024**3) # Storage limit approx
-    }
-
+# --- ফাইল ম্যানেজার API ---
 @app.get("/api/files")
 async def list_files(path: str = "."):
     try:
-        abs_path = os.path.abspath(path)
         files = []
-        for entry in os.scandir(abs_path):
+        for entry in os.scandir(path):
             files.append({
                 "name": entry.name,
                 "is_dir": entry.is_dir(),
@@ -39,32 +32,48 @@ async def list_files(path: str = "."):
     except Exception as e:
         return JSONResponse(status_code=500, content={"error": str(e)})
 
+@app.post("/api/upload")
+async def upload_file(file: UploadFile = File(...)):
+    with open(file.filename, "wb") as buffer:
+        shutil.copyfileobj(file.file, buffer)
+    return {"message": "Uploaded"}
+
+@app.delete("/api/delete")
+async def delete_file(path: str):
+    if os.path.isdir(path):
+        os.rmdir(path)
+    else:
+        os.remove(path)
+    return {"message": "Deleted"}
+
+# --- ওয়েব প্রিভিউ প্রক্সি ---
+@app.get("/proxy")
+async def proxy(url: str = "http://localhost:8080"):
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.get(url, timeout=5.0)
+            return HTMLResponse(content=response.text)
+        except Exception as e:
+            return HTMLResponse(content=f"<div style='color:red;padding:20px;'>Error: {str(e)}<br>নিশ্চিত করুন যে আপনার লোকাল সার্ভারটি ৮০৮০ পোর্টে রানিং আছে।</div>")
+
+# --- ওয়েব সকেট টার্মিনাল ---
 @app.websocket("/ws")
 async def websocket_endpoint(websocket: WebSocket):
     await websocket.accept()
     try:
         auth = await websocket.receive_text()
         if auth != ACCESS_PASSWORD:
-            await websocket.send_text("[-] AUTH_FAILED")
+            await websocket.send_text("AUTH_FAILED")
             await websocket.close()
             return
-        
-        await websocket.send_text("[+] AUTH_SUCCESS")
-        
+        await websocket.send_text("AUTH_SUCCESS")
         while True:
             command = await websocket.receive_text()
-            # ক্লিয়ার কমান্ড হ্যান্ডলিং
-            if command.strip() == "clear":
-                await websocket.send_text("\033[H\033[2J")
-                continue
-
             process = await asyncio.create_subprocess_shell(
-                command,
-                stdout=asyncio.subprocess.PIPE,
-                stderr=asyncio.subprocess.PIPE
+                command, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.PIPE
             )
             stdout, stderr = await process.communicate()
-            output = stdout.decode().strip() or stderr.decode().strip() or "Done."
+            output = stdout.decode().strip() or stderr.decode().strip() or "Executed."
             await websocket.send_text(output)
     except WebSocketDisconnect:
         pass