Add Telegram bot functionality with command handlers

OneApi/__init__.py

@@ -28,6 +28,135 @@ if not API_ID or not API_HASH or not TOKEN or not MONGO_DB_URI:
 # _-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_-_+_|
 if len(TOKEN) > 50: bot = Client("OneApi", session_string=TOKEN, api_id=API_ID, api_hash=API_HASH, plugins=dict(root="OneApi/pyro"))
 else: bot = Client("OneApi", bot_token=TOKEN, api_id=API_ID, api_hash=API_HASH, plugins=dict(root="OneApi/pyro"))
+
+# Bot command handlers
+@bot.on_message(filters.command("start"))
+async def start_command(client, message):
+    user_id = message.from_user.id
+    user_name = message.from_user.first_name
+    
+    welcome_text = f"""
+🤖 **Welcome to OneApi Cloud Hosting!**
+
+Hi {user_name}! I'm your cloud hosting assistant.
+
+**Available Commands:**
+• `/start` - Show this help message
+• `/info` - Get your account info
+• `/projects` - List your projects
+• `/create <name> <plan>` - Create new project
+• `/connect` - Connect GitHub repository
+
+**Plans Available:**
+• Free - 0 coins
+• Basic - 99 coins  
+• Advance - 199 coins
+• Pro - 269 coins
+
+**Your User ID:** `{user_id}`
+
+Start by creating a project with `/create myapp free`
+    """
+    
+    await message.reply_text(welcome_text)
+
+@bot.on_message(filters.command("info"))
+async def info_command(client, message):
+    user_id = message.from_user.id
+    from .database import user
+    user_db = user()
+    
+    user_info = await user_db.find(user_id)
+    if user_info:
+        info_text = f"""
+📊 **Account Information**
+
+**Name:** {user_info.get('name', 'Not set')}
+**Coins:** {user_info.get('coins', 0)}
+**Projects:** {len(user_info.get('projects', []))}
+**GitHub:** {user_info.get('git', 'Not connected')}
+**User ID:** {user_id}
+        """
+    else:
+        info_text = f"""
+❌ **User Not Found**
+
+You need to register first. Use the API to create your account:
+
+```bash
+curl -X POST https://your-api-url/create_user/ \\
+  -H "Content-Type: application/json" \\
+  -d '{{"user_id": {user_id}, "name": "Your Name"}}'
+```
+
+**Your User ID:** `{user_id}`
+        """
+    
+    await message.reply_text(info_text)
+
+@bot.on_message(filters.command("projects"))
+async def projects_command(client, message):
+    user_id = message.from_user.id
+    from .database import user
+    user_db = user()
+    
+    projects = await user_db.get_projects(user_id)
+    if projects == "not exists":
+        await message.reply_text("❌ User not found. Please register first.")
+        return
+    elif projects == "projects not found":
+        await message.reply_text("📁 No projects found. Create one with `/create myapp free`")
+        return
+    
+    projects_text = "📁 **Your Projects:**\n\n"
+    for i, project in enumerate(projects, 1):
+        projects_text += f"{i}. **{project.get('name')}** (ID: {project.get('project_id')})\n"
+    
+    await message.reply_text(projects_text)
+
+@bot.on_message(filters.command("create"))
+async def create_project_command(client, message):
+    user_id = message.from_user.id
+    from .database import user
+    user_db = user()
+    
+    try:
+        args = message.text.split()[1:]
+        if len(args) < 2:
+            await message.reply_text("❌ Usage: `/create <name> <plan>`\n\nExample: `/create myapp free`")
+            return
+        
+        name = args[0]
+        plan = args[1]
+        
+        result = await user_db.create_project(name, user_id, plan)
+        
+        if result == "ok":
+            await message.reply_text(f"✅ Project '{name}' created successfully with {plan} plan!")
+        elif result == "not exists":
+            await message.reply_text("❌ User not found. Please register first.")
+        elif result == "Name too short":
+            await message.reply_text("❌ Project name must be at least 4 characters long.")
+        elif result == "Name already used":
+            await message.reply_text("❌ A project with this name already exists.")
+        elif result == "Plan not found":
+            await message.reply_text("❌ Invalid plan. Available: free, basic, advance, pro")
+        elif result == "insufficient coins":
+            await message.reply_text("❌ Insufficient coins for this plan.")
+        else:
+            await message.reply_text(f"❌ Error: {result}")
+            
+    except Exception as e:
+        await message.reply_text(f"❌ Error creating project: {str(e)}")
+
+# Start the bot
+async def start_bot():
+    try:
+        await bot.start()
+        logging.info("Telegram bot started successfully!")
+    except Exception as e:
+        logging.error(f"Failed to start bot: {e}")
+
 # ———— R U N ——————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————————
 async def run(command):
   try:

OneApi/__main__.py

@@ -38,5 +38,12 @@ app = cors(app, allow_origin="*")
 async def home():
     return jsonify({'success': 'server online'}), 200
 
+async def main():
+    # Start the bot
+    await start_bot()
+    
+    # Start the web server
+    await app.run_task(host="0.0.0.0", port=int(os.environ.get("PORT", 8080)))
+
 if __name__ == '__main__':
-    app.run(host="0.0.0.0", port=int(os.environ.get("PORT", 8080)))
+    asyncio.run(main())