apis/openai_api.py

import openai
from .base_api import BaseAPI
import asyncio

class OpenAIAPI(BaseAPI):
    """OpenAI API implementation"""
    
    def __init__(self, api_key: str, model_name: str, **kwargs):
        super().__init__(api_key, model_name, **kwargs)
        self.client = openai.AsyncOpenAI(api_key=api_key)
        
    async def generate_response(self, prompt: str, **kwargs) -> str:
        """Generate response using OpenAI API"""
        try:
            response = await self.client.chat.completions.create(
                model=self.model_name,
                messages=[{"role": "user", "content": prompt}],
                temperature=kwargs.get('temperature', 0.0),
                max_tokens=kwargs.get('max_tokens', 2048),
                timeout=self.timeout
            )
            return response.choices[0].message.content
        except Exception as e:
            raise Exception(f"OpenAI API error: {str(e)}")
            
    def get_model_info(self) -> dict:
        """Get model information"""
        return {
            "provider": "OpenAI",
            "model": self.model_name,
            "api_version": "v1"
        }