# Production-ready async Telegram bot handler
import asyncio
from typing import Optional
from contextlib import asynccontextmanager

class TelegramBotCore:
    def __init__(self, token: str, db_url: str):
        self.token = token
        self.db = AsyncDatabase(db_url)
        self.queue = asyncio.Queue()
    
    async def handle_message(self, user_id: int, text: str) -> dict:
        """
        Non-blocking message processor with queue handling
        and database operations
        """
        try:
            # Process with timeout
            result = await asyncio.wait_for(
                self._process_payload(user_id, text),
                timeout=5.0
            )
            
            # Store in queue for async processing
            await self.queue.put({
                'user_id': user_id,
                'result': result,
                'timestamp': datetime.now()
            })
            
            return {'status': 'success', 'data': result}
        except asyncio.TimeoutError:
            return {'status': 'error', 'message': 'Processing timeout'}
    
    async def _process_payload(self, user_id: int, text: str) -> Optional[dict]:
        """Heavy computation with DB access"""
        user = await self.db.get_user(user_id)
        
        if not user:
            await self.db.create_user(user_id)
            user = await self.db.get_user(user_id)
        
        # Parallel operations
        tasks = [
            self.db.log_activity(user_id, text),
            self._parse_content(text),
            self._check_spam(user_id, text)
        ]
        
        results = await asyncio.gather(*tasks)
        return {'processed': True, 'data': results}
    
    @asynccontextmanager
    async def get_db_session(self):
        """Context manager for safe DB operations"""
        session = await self.db.create_session()
        try:
            yield session
        finally:
            await session.close()

# Usage
async def main():
    bot = TelegramBotCore(
        token="YOUR_TOKEN",
        db_url="postgresql://user:pass@localhost/dbname"
    )
    
    response = await bot.handle_message(
        user_id=123456789,
        text="Process this content"
    )
    print(response)

if __name__ == "__main__":
    asyncio.run(main())