Update main.py

main.py

@@ -10,11 +10,8 @@ B_T = os.getenv("BOT_TOKEN")
 S_K = os.getenv("PANEL_SECRET")
 A_T = os.getenv("ADMIN_TELE_ID")
 
-if C_V != K_I:
-    sys.exit(1)
-
-if not all([B_T, S_K, A_T]):
-    sys.exit(1)
+if C_V != K_I: sys.exit(1)
+if not all([B_T, S_K, A_T]): sys.exit(1)
 
 app = FastAPI()
 sio = socketio.AsyncServer(async_mode='asgi', cors_allowed_origins="*")
@@ -24,43 +21,31 @@ A_I = int(A_T)
 
 @bot.message_handler(commands=['start'])
 def _s(m):
-    msg = (
-        "⚡ **AQSO CORE v11** ⚡\n\n"
-        "🛠️ **MENU UTAMA:**\n"
-        "├ `/daftar [user] [pass]`\n"
-        "├ `/hapus [user]`\n"
-        "├ `/list` (Admin Only)\n"
-        "└ `/status` (Check System)\n\n"
-        "🚀 **PANEL:** `READY`"
-    )
-    bot.reply_to(m, msg, parse_mode="Markdown")
+    l = "⚡ **AQSO CORE** ⚡\n\n├ `/daftar [user] [pass]`\n├ `/hapus [user]`\n└ `/list`"
+    bot.reply_to(m, l, parse_mode="Markdown")
 
 @bot.message_handler(commands=['daftar'])
 def _r(m):
     try:
         a = m.text.split()
         if len(a) < 3: return
-        u, p = a[1], a[2]
-        if database.add_user(u, p):
-            bot.reply_to(m, f"✅ {u.upper()} AUTHORIZED.")
-        else:
-            bot.reply_to(m, "❌ ERROR.")
+        if database.add_user(a[1], a[2]): bot.reply_to(m, "✅ OK.")
+        else: bot.reply_to(m, "❌ ERROR.")
     except: pass
 
 @bot.message_handler(commands=['hapus'])
 def _d(m):
     if m.from_user.id != A_I: return
     try:
-        u = m.text.split()[1]
-        database.del_user(u)
-        bot.reply_to(m, "🗑️ DELETED.")
+        database.del_user(m.text.split()[1])
+        bot.reply_to(m, "🗑️ OK.")
     except: pass
 
 @bot.message_handler(commands=['list'])
 def _l(m):
     if m.from_user.id != A_I: return
     u = database.list_users()
-    bot.reply_to(m, "👥 **DB USERS:**\n" + "\n".join(u) if u else "NULL", parse_mode="Markdown")
+    bot.reply_to(m, "👥 **USERS:**\n" + "\n".join(u) if u else "EMPTY")
 
 def _bt():
     try:
@@ -69,7 +54,7 @@ def _bt():
     except: pass
 
 @app.on_event("startup")
-async def _st():
+async def _os():
     if not os.path.exists(W_R): os.makedirs(W_R, exist_ok=True)
     await database.init_db()
     threading.Thread(target=_bt, daemon=True).start()
@@ -84,7 +69,7 @@ def _au(r):
     return None
 
 @app.get("/")
-def _idx(): return HTMLResponse(ui_templates.PANEL_UI)
+def _id(): return HTMLResponse(ui_templates.PANEL_UI)
 
 @app.post("/login_api")
 async def _lg(u: str = Form(...), p: str = Form(...)):
@@ -124,8 +109,7 @@ async def _ul(r: Request, f: UploadFile = File(...)):
     if not u: return
     w = _gw(u)
     d = os.path.join(w, os.path.basename(f.filename))
-    with open(d, "wb") as o:
-        shutil.copyfileobj(f.file, o)
+    with open(d, "wb") as o: shutil.copyfileobj(f.file, o)
     if d.endswith(".zip"):
         try:
             with zipfile.ZipFile(d, 'r') as z: z.extractall(w)
@@ -136,8 +120,7 @@ async def _mv(r: Request, d: dict):
     u = _au(r)
     if not u: return
     w = _gw(u)
-    s = os.path.join(w, d['src'])
-    t = os.path.join(w, d['dst'])
+    s, t = os.path.join(w, d['src']), os.path.join(w, d['dst'])
     if os.path.exists(s): shutil.move(s, t)
 
 @app.delete("/api/delete/{n}")
@@ -164,7 +147,7 @@ async def _cn(sid, env):
         os.chdir(w)
         os.execvpe("bash", ["bash"], {**os.environ, "HOME": w, "TERM": "xterm-256color"})
     _fm[sid] = fd
-    async def _ss():
+    async def _st():
         while sid in _fm:
             await asyncio.sleep(3)
             await sio.emit('stats', {'cpu': psutil.cpu_percent(), 'ram': psutil.virtual_memory().percent}, room=sid)
@@ -173,7 +156,7 @@ async def _cn(sid, env):
             await asyncio.sleep(0.01)
             if _fm[sid] and select.select([_fm[sid]], [], [], 0)[0]:
                 await sio.emit('o', os.read(_fm[sid], 2048).decode(errors='ignore'), room=sid)
-    sio.start_background_task(_ss)
+    sio.start_background_task(_st)
     sio.start_background_task(_rp)
 
 @sio.on('i')