Update src/utils.py

src/utils.py

@@ -7,6 +7,8 @@ from typing import Any, Dict, List, Optional
 from urllib.parse import urlencode
 import aiohttp
 import asyncio
+import functools
+import time
 
 def json_serializer(obj: Any) -> str:
     """
@@ -281,4 +283,107 @@ def retry_on_exception(max_retries: int = 3, delay: float = 1.0, exceptions: tup
     Returns:
         Decorated function
     """
-    def
+    def decorator(func):
+        @functools.wraps(func)
+        def wrapper(*args, **kwargs):
+            for attempt in range(max_retries):
+                try:
+                    return func(*args, **kwargs)
+                except exceptions as e:
+                    if attempt == max_retries - 1:
+                        raise e
+                    time.sleep(delay * (2 ** attempt))  # Exponential backoff
+            return None
+        return wrapper
+    return decorator
+
+def batch_process(items: List, batch_size: int = 10):
+    """
+    Process items in batches.
+    
+    Args:
+        items: List of items to process
+        batch_size: Size of each batch
+        
+    Yields:
+        Batches of items
+    """
+    for i in range(0, len(items), batch_size):
+        yield items[i:i + batch_size]
+
+def safe_get(dictionary: Dict, keys: List[str], default: Any = None) -> Any:
+    """
+    Safely get nested dictionary value.
+    
+    Args:
+        dictionary: Dictionary to search
+        keys: List of keys to traverse
+        default: Default value if key not found
+        
+    Returns:
+        Value or default
+    """
+    current = dictionary
+    for key in keys:
+        if isinstance(current, dict) and key in current:
+            current = current[key]
+        else:
+            return default
+    return current
+
+def format_bytes(size: float) -> str:
+    """
+    Format bytes to human readable string.
+    
+    Args:
+        size: Size in bytes
+        
+    Returns:
+        Formatted string
+    """
+    for unit in ['B', 'KB', 'MB', 'GB', 'TB']:
+        if size < 1024.0:
+            return f"{size:.2f} {unit}"
+        size /= 1024.0
+    return f"{size:.2f} PB"
+
+def generate_conversation_id() -> str:
+    """
+    Generate a unique conversation ID.
+    
+    Returns:
+        Unique conversation ID string
+    """
+    import uuid
+    return f"conv_{uuid.uuid4().hex[:16]}"
+
+def validate_email(email: str) -> bool:
+    """
+    Validate email format.
+    
+    Args:
+        email: Email to validate
+        
+    Returns:
+        True if valid email, False otherwise
+    """
+    import re
+    pattern = r'^[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+\.[a-zA-Z]{2,}$'
+    return re.match(pattern, email) is not None
+
+def get_platform_info() -> Dict[str, Any]:
+    """
+    Get platform information.
+    
+    Returns:
+        Platform information dictionary
+    """
+    import platform
+    return {
+        'system': platform.system(),
+        'release': platform.release(),
+        'version': platform.version(),
+        'machine': platform.machine(),
+        'processor': platform.processor(),
+        'python_version': platform.python_version()
+    }