api_client.py

import aiohttp
import requests
import logging

# Logger einrichten
logger = logging.getLogger("APIClientLogger")
logger.setLevel(logging.INFO)
import os
os.makedirs("logs", exist_ok=True)
handler = logging.FileHandler(os.path.join("logs", "api_client.log"), encoding="utf-8")
formatter = logging.Formatter('%(asctime)s - %(levelname)s - %(message)s')
handler.setFormatter(formatter)
logger.addHandler(handler)

class APIClient:
    def __init__(self, base_url, token, timeout_seconds=20):
        if not base_url or not token:
            raise ValueError("API base_url und token müssen gesetzt sein.")
        self.base_url = base_url.rstrip("/")
        self.headers = {"Authorization": f"Bearer {token}"}
        self.timeout = aiohttp.ClientTimeout(total=timeout_seconds)

    async def get(self, endpoint):
        """Sendet eine GET-Anfrage asynchron."""
        url = f"{self.base_url}/{endpoint.lstrip('/')}"
        try:
            async with aiohttp.ClientSession(headers=self.headers, timeout=self.timeout) as session:
                async with session.get(url) as response:
                    if response.status == 200:
                        return await response.text()
                    else:
                        logger.error(f"GET-Anfrage fehlgeschlagen: {url}, Status: {response.status}, Response: {await response.text()}")
                        return None
        except Exception as e:
            logger.error(f"Fehler bei GET-Anfrage: {url}, Fehler: {str(e)}")
            return None

    async def post(self, endpoint, data):
        """Sendet eine POST-Anfrage asynchron."""
        url = f"{self.base_url}/{endpoint.lstrip('/')}"
        try:
            async with aiohttp.ClientSession(headers=self.headers, timeout=self.timeout) as session:
                async with session.post(url, json=data) as response:
                    if response.status == 200:
                        return await response.json()
                    else:
                        logger.error(f"POST-Anfrage fehlgeschlagen: {url}, Status: {response.status}, Response: {await response.text()}")
                        return None
        except Exception as e:
            logger.error(f"Fehler bei POST-Anfrage: {url}, Fehler: {str(e)}")
            return None

    def sync_get(self, endpoint):
        """Sendet eine GET-Anfrage synchron."""
        url = f"{self.base_url}/{endpoint.lstrip('/')}"
        try:
            response = requests.get(url, headers=self.headers, timeout=self.timeout.total)
            if response.status_code == 200:
                return response.text
            else:
                logger.error(f"Sync GET-Anfrage fehlgeschlagen: {url}, Status: {response.status_code}, Response: {response.text}")
                return None
        except Exception as e:
            logger.error(f"Fehler bei Sync GET-Anfrage: {url}, Fehler: {str(e)}")
            return None

    def sync_post(self, endpoint, data):
        """Sendet eine POST-Anfrage synchron."""
        url = f"{self.base_url}/{endpoint.lstrip('/')}"
        try:
            response = requests.post(url, json=data, headers=self.headers, timeout=self.timeout.total)
            if response.status_code == 200:
                return response.json()
            else:
                logger.error(f"Sync POST-Anfrage fehlgeschlagen: {url}, Status: {response.status_code}, Response: {response.text}")
                return None
        except Exception as e:
            logger.error(f"Fehler bei Sync POST-Anfrage: {url}, Fehler: {str(e)}")
            return None