import logging
import time

from app.config import settings
from app.service.task.base_task import BaseTask
from app.service.task.task_param import TaskParam
from app.service.task.task_result import TaskResult
from app.util.http_util import logged_client

logger = logging.getLogger(__name__)


class SeedreamImageTask(BaseTask):
    def get_type(self) -> str:
        return "seedream_image"

    def _headers(self) -> dict[str, str]:
        return {
            "Content-Type": "application/json",
            "Authorization": f"Bearer {settings.seed_api_key}",
        }

    def execute(self, param: TaskParam) -> TaskResult:
        url = settings.seedream_image_url
        logger.info("[seedream_image] Calling API: POST %s", url)
        t0 = time.time()

        try:
            with logged_client(timeout=60) as client:
                resp = client.post(url, headers=self._headers(), json=param.inputs)
                elapsed = time.time() - t0
                logger.info("[seedream_image] Response: status=%d, elapsed=%.2fs",
                            resp.status_code, elapsed)
                data = resp.json()

            if "error" in data:
                err = data["error"]
                code = err.get("code", "")
                msg = err.get("message", "")
                logger.error("[seedream_image] API error: code=%s, message=%s", code, msg)
                return TaskResult.failure(f"API error [{code}]: {msg}")

            images: list[str] = []
            for item in data.get("data", []):
                url_val = item.get("url")
                if url_val:
                    images.append(url_val)

            logger.info("[seedream_image] Completed: model=%s, %d images, elapsed=%.2fs",
                         data.get("model"), len(images), time.time() - t0)
            return TaskResult.success({"images": images})
        except Exception as e:
            elapsed = time.time() - t0
            logger.error("[seedream_image] Failed in %.2fs: %s", elapsed, e, exc_info=True)
            return TaskResult.failure(f"Failed to execute task: {e}")