Issue #7 completed

ai-backend/config/settings.py

@@ -8,8 +8,8 @@
 from typing import Any
 
 from dotenv import load_dotenv
-from pydantic import Field, validator
-from pydantic_settings import BaseSettings
+from pydantic import Field, field_validator
+from pydantic_settings import BaseSettings, SettingsConfigDict
 
 # Load environment variables from .env file
 load_dotenv()
@@ -21,12 +21,12 @@ class Settings(BaseSettings):
     """Application settings loaded from environment variables with validation."""
 
     # Required settings
-    openai_api_key: str = Field(..., min_length=20, description="OpenAI API key")
-    supabase_url: str = Field(..., description="Supabase project URL")
-    supabase_service_role_key: str = Field(
+    OPENAI_API_KEY: str = Field(..., min_length=20, description="OpenAI API key")
+    SUPABASE_URL: str = Field(..., description="Supabase project URL")
+    SUPABASE_SERVICE_ROLE_KEY: str = Field(
         ..., min_length=20, description="Supabase service role key"
     )
-    rapidapi_key: str = Field(
+    RAPIDAPI_KEY: str = Field(
         ..., min_length=10, description="RapidAPI key for API-Football"
     )
 
@@ -56,39 +56,44 @@ class Settings(BaseSettings):
         description="API-Football base URL",
     )
 
-    @validator("openai_api_key")
-    def validate_openai_key(cls, v: str) -> str:  # noqa: N805
+    @field_validator("OPENAI_API_KEY")
+    @classmethod
+    def validate_openai_key(cls, v: str) -> str:
         if not v or v == "your-openai-api-key" or v == "sk-...":
             raise ValueError("Valid OpenAI API key is required")
         if not v.startswith("sk-"):
             raise ValueError('OpenAI API key must start with "sk-"')
         return v
 
-    @validator("supabase_url")
-    def validate_supabase_url(cls, v: str) -> str:  # noqa: N805
+    @field_validator("SUPABASE_URL")
+    @classmethod
+    def validate_supabase_url(cls, v: str) -> str:
         if not v.startswith("https://"):
             raise ValueError("Supabase URL must be a valid HTTPS URL")
         if not v.endswith(".supabase.co"):
             raise ValueError("Supabase URL must end with .supabase.co")
         return v
 
-    @validator("environment")
-    def validate_environment(cls, v: str) -> str:  # noqa: N805
+    @field_validator("environment")
+    @classmethod
+    def validate_environment(cls, v: str) -> str:
         allowed = ["development", "staging", "production"]
         if v not in allowed:
             raise ValueError(f"Environment must be one of: {allowed}")
         return v
 
-    @validator("log_level")
-    def validate_log_level(cls, v: str) -> str:  # noqa: N805
+    @field_validator("log_level")
+    @classmethod
+    def validate_log_level(cls, v: str) -> str:
         allowed = ["DEBUG", "INFO", "WARNING", "ERROR", "CRITICAL"]
         v_upper = v.upper()
         if v_upper not in allowed:
             raise ValueError(f"Log level must be one of: {allowed}")
         return v_upper
 
-    @validator("log_format")
-    def validate_log_format(cls, v: str) -> str:  # noqa: N805
+    @field_validator("log_format")
+    @classmethod
+    def validate_log_format(cls, v: str) -> str:
         allowed = ["json", "text"]
         if v not in allowed:
             raise ValueError(f"Log format must be one of: {allowed}")
@@ -110,13 +115,9 @@ def to_dict(self) -> dict[str, Any]:
             "api_football_base_url": self.api_football_base_url,
         }
 
-    class Config:
-        """Pydantic configuration for Settings model."""
-
-        env_file = ".env"
-        case_sensitive = True
-        # Allow extra fields for forward compatibility
-        extra = "ignore"
+    model_config = SettingsConfigDict(
+        env_file=".env", case_sensitive=True, extra="ignore"
+    )
 
 
 # Global settings instance

ai-backend/test_environment.py

@@ -0,0 +1,66 @@
+"""
+Test script to verify all dependencies are properly installed
+"""
+
+import sys
+
+print(f"Python version: {sys.version}")
+
+# Test core dependencies
+try:
+    import openai
+
+    print("✅ OpenAI package imported successfully")
+except ImportError as e:
+    print(f"❌ OpenAI import failed: {e}")
+
+try:
+    from agents.researcher import ResearchAgent
+
+    print("✅ OpenAI Agents package imported successfully")
+except ImportError as e:
+    print(f"❌ OpenAI Agents import failed: {e}")
+
+try:
+    import fastapi
+
+    print("✅ FastAPI package imported successfully")
+except ImportError as e:
+    print(f"❌ FastAPI import failed: {e}")
+
+try:
+    from pydantic import BaseModel
+
+    print("✅ Pydantic package imported successfully")
+except ImportError as e:
+    print(f"❌ Pydantic import failed: {e}")
+
+try:
+    from supabase import create_client
+
+    print("✅ Supabase package imported successfully")
+except ImportError as e:
+    print(f"❌ Supabase import failed: {e}")
+
+try:
+    import aiohttp
+
+    print("✅ Aiohttp package imported successfully")
+except ImportError as e:
+    print(f"❌ Aiohttp import failed: {e}")
+
+try:
+    from dotenv import load_dotenv
+
+    print("✅ Python-dotenv package imported successfully")
+except ImportError as e:
+    print(f"❌ Python-dotenv import failed: {e}")
+
+try:
+    import structlog
+
+    print("✅ Structlog package imported successfully")
+except ImportError as e:
+    print(f"❌ Structlog import failed: {e}")
+
+print("\n🎉 Environment test completed!")

ai-backend/test_openai.py

@@ -0,0 +1,38 @@
+"""
+Test OpenAI API connection
+"""
+import os
+from dotenv import load_dotenv
+import openai
+
+# Load environment variables
+load_dotenv()
+
+# Set up OpenAI client
+client = openai.OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
+
+def test_openai_connection():
+    """Test basic OpenAI API connection"""
+    if not os.getenv("OPENAI_API_KEY") or os.getenv("OPENAI_API_KEY") == "your_openai_api_key_here":
+        print("⚠️  OpenAI API key not set. Skipping connection test.")
+        return
+
+    try:
+        # Test with a simple completion
+        response = client.chat.completions.create(
+            model="gpt-4.1-nano",
+            messages=[
+                {"role": "user", "content": "Say 'Hello from Sport Scribe AI!'"}
+            ],
+            max_tokens=50
+        )
+
+        print("✅ OpenAI API connection successful!")
+        print(f"Response: {response.choices[0].message.content}")
+
+    except Exception as e:
+        print(f"❌ OpenAI API connection failed: {e}")
+
+if __name__ == "__main__":
+    test_openai_connection()
+

ai-backend/tests/test_environment.py

@@ -0,0 +1,48 @@
+"""Test script to verify all dependencies are properly installed."""
+
+import sys
+
+print(f"Python version: {sys.version}")
+
+# Test core dependencies
+try:
+    print("✅ OpenAI package imported successfully")
+except ImportError as e:
+    print(f"❌ OpenAI import failed: {e}")
+
+try:
+    print("✅ OpenAI Agents package imported successfully")
+except ImportError as e:
+    print(f"❌ OpenAI Agents import failed: {e}")
+
+try:
+    print("✅ FastAPI package imported successfully")
+except ImportError as e:
+    print(f"❌ FastAPI import failed: {e}")
+
+try:
+    print("✅ Pydantic package imported successfully")
+except ImportError as e:
+    print(f"❌ Pydantic import failed: {e}")
+
+try:
+    print("✅ Supabase package imported successfully")
+except ImportError as e:
+    print(f"❌ Supabase import failed: {e}")
+
+try:
+    print("✅ Aiohttp package imported successfully")
+except ImportError as e:
+    print(f"❌ Aiohttp import failed: {e}")
+
+try:
+    print("✅ Python-dotenv package imported successfully")
+except ImportError as e:
+    print(f"❌ Python-dotenv import failed: {e}")
+
+try:
+    print("✅ Structlog package imported successfully")
+except ImportError as e:
+    print(f"❌ Structlog import failed: {e}")
+
+print("\n🎉 Environment test completed!")

ai-backend/tests/test_openai.py

@@ -0,0 +1,37 @@
+"""Test OpenAI API connection."""
+
+import os
+
+import openai
+from dotenv import load_dotenv
+
+# Load environment variables
+load_dotenv()
+
+# Set up OpenAI client
+client = openai.OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
+
+
+def test_openai_connection() -> None:
+    """Test basic OpenAI API connection."""
+    if not os.getenv("OPENAI_API_KEY") or os.getenv("OPENAI_API_KEY") == "your_openai_api_key_here":
+        print("⚠️  OpenAI API key not set. Skipping connection test.")
+        return
+
+    try:
+        # Test with a simple completion
+        response = client.chat.completions.create(
+            model="gpt-4.1-nano",
+            messages=[{"role": "user", "content": "Say 'Hello from Sport Scribe AI!'"}],
+            max_tokens=50,
+        )
+
+        print("✅ OpenAI API connection successful!")
+        print(f"Response: {response.choices[0].message.content}")
+
+    except Exception as e:
+        print(f"❌ OpenAI API connection failed: {e}")
+
+
+if __name__ == "__main__":
+    test_openai_connection()

ai-backend/tests/test_quality_tools.py

@@ -0,0 +1,66 @@
+"""Sample code to test quality tools."""
+
+import asyncio
+
+
+class FootballDataProcessor:
+    """Process football data for AI analysis."""
+
+    def __init__(self, league: str) -> None:
+        """Initialize processor with league."""
+        self.league = league
+        self.processed_games: list[dict[str, str]] = []
+
+    def process_game_data(
+        self, home_team: str, away_team: str, score: str | None = None
+    ) -> dict[str, str]:
+        """Process individual game data.
+
+        Args:
+            home_team: Name of home team
+            away_team: Name of away team
+            score: Optional match score
+
+        Returns:
+            Processed game data dictionary
+        """
+        game_data = {
+            "home_team": home_team.strip(),
+            "away_team": away_team.strip(),
+            "league": self.league,
+        }
+
+        if score:
+            game_data["score"] = score.strip()
+
+        return game_data
+
+    async def fetch_recent_games(self, limit: int = 10) -> list[dict[str, str]]:
+        """Fetch recent games asynchronously.
+
+        Args:
+            limit: Maximum number of games to fetch
+
+        Returns:
+            list of recent games
+        """
+        # Simulate async API call
+        await asyncio.sleep(0.1)
+
+        return [
+            self.process_game_data("Arsenal", "Chelsea", "2-1"),
+            self.process_game_data("Liverpool", "Manchester City", "1-3"),
+        ][:limit]
+
+
+def main() -> None:
+    """Main function to test the processor."""
+    processor = FootballDataProcessor("Premier League")
+
+    # Test synchronous processing
+    game = processor.process_game_data("Arsenal", "Chelsea", "2-1")
+    print(f"Processed game: {game}")
+
+
+if __name__ == "__main__":
+    main()