Update main.py

main.py

@@ -1,36 +1,83 @@
 import asyncio
+import sqlite3
 from fastapi import FastAPI
 from aiogram import Bot, Dispatcher, types
 from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton, WebAppInfo
 import uvicorn
+from datetime import datetime
 
-# إعدادات البوت
+# إعدادات البوت والـ Space
 TOKEN = '8628327909:AAETtkAFrUYUMwBhpv3BWsTWH09-fErd8WM'
 BLOCK_ID = '26019'
 bot = Bot(token=TOKEN)
 dp = Dispatcher()
-
 app = FastAPI()
 
-# --- الجزء الخاص بالبوت ---
+# --- إعداد قاعدة البيانات ---
+def init_db():
+    conn = sqlite3.connect('doovoo_users.db')
+    c = conn.cursor()
+    # جدول المستخدمين: ID، الإسم، عدد المشاهدات، وتاريخ أول دخول
+    c.execute('''CREATE TABLE IF NOT EXISTS users 
+                 (user_id TEXT PRIMARY KEY, username TEXT, ad_views INTEGER DEFAULT 0, joined_at TEXT)''')
+    conn.commit()
+    conn.close()
+
+init_db()
+
+# --- وظائف البوت ---
 @dp.message()
 async def start_handler(message: types.Message):
-    url = f"https://render.adsgram.ai/show?blockId={BLOCK_ID}&userId={message.from_user.id}"
+    user_id = str(message.from_user.id)
+    username = message.from_user.username or "Unknown"
+    
+    # تسجيل المستخدم إذا كان جديداً
+    conn = sqlite3.connect('doovoo_users.db')
+    c = conn.cursor()
+    c.execute("INSERT OR IGNORE INTO users (user_id, username, joined_at) VALUES (?, ?, ?)", 
+              (user_id, username, datetime.now().strftime("%Y-%m-%d %H:%M:%S")))
+    conn.commit()
+    conn.close()
+
+    url = f"https://render.adsgram.ai/show?blockId={BLOCK_ID}&userId={user_id}"
     kb = InlineKeyboardMarkup(inline_keyboard=[
         [InlineKeyboardButton(text="💰 Watch Ad & Earn", web_app=WebAppInfo(url=url))]
     ])
-    await message.answer("مرحباً بك في DooVoo! كليكي باش تتفرج وتربح:", reply_markup=kb)
+    await message.answer(f"مرحباً {username}! تفرج واربح النقاط.\nإحصائياتك مسجلة عندنا ✅", reply_markup=kb)
 
-async def run_bot():
-    await dp.start_polling(bot)
-
-# --- الجزء الخاص بالـ Reward API ---
+# --- الـ Reward API (تحديث عدد المشاهدات) ---
 @app.get("/reward")
 async def reward_user(userId: str):
-    print(f"✅ User {userId} rewarded!")
-    return {"status": "success", "user": userId}
+    conn = sqlite3.connect('doovoo_users.db')
+    c = conn.cursor()
+    # زيادة عدد المشاهدات للمستخدم بـ +1
+    c.execute("UPDATE users SET ad_views = ad_views + 1 WHERE user_id = ?", (userId,))
+    conn.commit()
+    conn.close()
+    print(f"🔥 Reward confirmed for: {userId}")
+    return {"status": "success", "new_reward": True}
+
+# --- صفحة الإحصائيات (ليك أنت فقط) ---
+@app.get("/admin/stats")
+async def get_stats():
+    conn = sqlite3.connect('doovoo_users.db')
+    c = conn.cursor()
+    c.execute("SELECT COUNT(*), SUM(ad_views) FROM users")
+    total_users, total_views = c.fetchone()
+    
+    c.execute("SELECT * FROM users ORDER BY ad_views DESC LIMIT 10")
+    top_users = c.fetchall()
+    conn.close()
+    
+    return {
+        "total_active_users": total_users,
+        "total_global_views": total_views or 0,
+        "top_10_players": top_users
+    }
+
+async def run_bot():
+    await dp.start_polling(bot)
 
-# تشغيل البوت عند إقلاع الـ Space
 @app.on_event("startup")
 async def startup_event():
     asyncio.create_task(run_bot())