Update app.py

app.py

@@ -1,6 +1,6 @@
+import os
 import subprocess
 import asyncio
-import os
 import psutil
 import httpx
 import shutil
@@ -8,25 +8,29 @@ from fastapi import FastAPI, WebSocket, WebSocketDisconnect, UploadFile, File, B
 from fastapi.responses import HTMLResponse, JSONResponse
 
 app = FastAPI()
-ACCESS_PASSWORD = "admin" 
+
+# Environment variable থেকে পাসওয়ার্ড নেওয়া হয়েছে, ডিফল্ট "admin"
+ACCESS_PASSWORD = os.getenv("ACCESS_PASSWORD", "admin")
+
+# সেশন ডিরেক্টরি ট্র্যাকিং
+current_working_dir = os.getcwd()
 
 @app.get("/")
 async def get():
     with open("index.html", "r", encoding="utf-8") as f:
         return HTMLResponse(content=f.read())
 
-# --- ফাইল ম্যানেজার প্রো API ---
+# --- ফাইল ম্যানেজার API ---
 @app.get("/api/files")
 async def list_files(path: str = "."):
     try:
-        # নিরাপদ পাথ হ্যান্ডলিং
-        target_path = os.path.abspath(path)
+        abs_path = os.path.abspath(os.path.join(current_working_dir, path))
         files = []
-        for entry in os.scandir(target_path):
+        for entry in os.scandir(abs_path):
             files.append({
                 "name": entry.name,
                 "is_dir": entry.is_dir(),
-                "path": os.path.relpath(entry.path, os.getcwd()),
+                "path": os.path.relpath(entry.path, current_working_dir),
                 "size": f"{entry.stat().st_size / 1024:.1f} KB" if entry.is_file() else "-"
             })
         return sorted(files, key=lambda x: not x['is_dir'])
@@ -35,31 +39,36 @@ async def list_files(path: str = "."):
 
 @app.get("/api/read")
 async def read_file(path: str):
-    with open(path, "r", encoding="utf-8") as f:
+    target = os.path.join(current_working_dir, path)
+    with open(target, "r", encoding="utf-8") as f:
         return {"content": f.read()}
 
 @app.post("/api/save")
 async def save_file(path: str = Body(...), content: str = Body(...)):
-    with open(path, "w", encoding="utf-8") as f:
+    target = os.path.join(current_working_dir, path)
+    with open(target, "w", encoding="utf-8") as f:
         f.write(content)
     return {"status": "saved"}
 
-@app.post("/api/upload")
-async def upload_file(file: UploadFile = File(...), path: str = "."):
-    file_path = os.path.join(path, file.filename)
-    with open(file_path, "wb") as buffer:
-        shutil.copyfileobj(file.file, buffer)
-    return {"message": "Uploaded"}
+@app.post("/api/create")
+async def create_item(name: str = Body(...), is_dir: bool = Body(...), path: str = Body(...)):
+    target = os.path.join(current_working_dir, path, name)
+    if is_dir: 
+        os.makedirs(target, exist_ok=True)
+    else: 
+        with open(target, "w") as f: f.write("")
+    return {"status": "created"}
 
 @app.delete("/api/delete")
 async def delete_file(path: str):
-    if os.path.isdir(path):
-        shutil.rmtree(path)
+    target = os.path.join(current_working_dir, path)
+    if os.path.isdir(target):
+        shutil.rmtree(target)
     else:
-        os.remove(path)
+        os.remove(target)
     return {"message": "Deleted"}
 
-# --- প্রক্সি ও টার্মিনাল (আগের মতোই) ---
+# --- ওয়েব প্রিভিউ প্রক্সি ---
 @app.get("/proxy")
 async def proxy(url: str = "http://localhost:8080"):
     async with httpx.AsyncClient() as client:
@@ -69,8 +78,10 @@ async def proxy(url: str = "http://localhost:8080"):
         except Exception as e:
             return HTMLResponse(content=f"<div style='color:red;padding:20px;'>Error: {str(e)}</div>")
 
+# --- টার্মিনাল সেশন (WebSocket) ---
 @app.websocket("/ws")
 async def websocket_endpoint(websocket: WebSocket):
+    global current_working_dir
     await websocket.accept()
     try:
         auth = await websocket.receive_text()
@@ -79,12 +90,25 @@ async def websocket_endpoint(websocket: WebSocket):
             await websocket.close()
             return
         await websocket.send_text("AUTH_SUCCESS")
+        
         while True:
             command = await websocket.receive_text()
+            # 'cd' কমান্ড হ্যান্ডলিং
+            if command.startswith("cd "):
+                new_path = command[3:].strip()
+                try:
+                    os.chdir(os.path.expanduser(new_path))
+                    current_working_dir = os.getcwd()
+                    await websocket.send_text(f"Directory: {current_working_dir}")
+                except Exception as e:
+                    await websocket.send_text(str(e))
+                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, cwd=current_working_dir
             )
             stdout, stderr = await process.communicate()
-            output = stdout.decode().strip() or stderr.decode().strip() or "Success."
+            output = stdout.decode().strip() or stderr.decode().strip() or "Command Executed."
             await websocket.send_text(output)
-    except WebSocketDisconnect: pass
+    except WebSocketDisconnect:
+        pass