| """API routes - OpenAI compatible endpoints""" |
| from fastapi import APIRouter, Depends, HTTPException |
| from fastapi.responses import StreamingResponse, JSONResponse |
| from typing import List, Optional |
| import base64 |
| import re |
| import json |
| import time |
| from urllib.parse import urlparse |
| from curl_cffi.requests import AsyncSession |
| from ..core.auth import verify_api_key_header |
| from ..core.models import ChatCompletionRequest |
| from ..services.generation_handler import GenerationHandler, MODEL_CONFIG |
| from ..core.logger import debug_logger |
|
|
| router = APIRouter() |
|
|
| |
| generation_handler: GenerationHandler = None |
|
|
|
|
| def set_generation_handler(handler: GenerationHandler): |
| """Set generation handler instance""" |
| global generation_handler |
| generation_handler = handler |
|
|
|
|
| async def retrieve_image_data(url: str) -> Optional[bytes]: |
| """ |
| 智能获取图片数据: |
| 1. 优先检查是否为本地 /tmp/ 缓存文件,如果是则直接读取磁盘 |
| 2. 如果本地不存在或是外部链接,则进行网络下载 |
| """ |
| |
| try: |
| if "/tmp/" in url and generation_handler and generation_handler.file_cache: |
| path = urlparse(url).path |
| filename = path.split("/tmp/")[-1] |
| local_file_path = generation_handler.file_cache.cache_dir / filename |
|
|
| if local_file_path.exists() and local_file_path.is_file(): |
| data = local_file_path.read_bytes() |
| if data: |
| return data |
| except Exception as e: |
| debug_logger.log_warning(f"[CONTEXT] 本地缓存读取失败: {str(e)}") |
|
|
| |
| try: |
| async with AsyncSession() as session: |
| response = await session.get(url, timeout=30, impersonate="chrome110", verify=False) |
| if response.status_code == 200: |
| return response.content |
| else: |
| debug_logger.log_warning(f"[CONTEXT] 图片下载失败,状态码: {response.status_code}") |
| except Exception as e: |
| debug_logger.log_error(f"[CONTEXT] 图片下载异常: {str(e)}") |
|
|
| return None |
|
|
|
|
| @router.get("/v1/models") |
| async def list_models(api_key: str = Depends(verify_api_key_header)): |
| """List available models""" |
| models = [] |
|
|
| for model_id, config in MODEL_CONFIG.items(): |
| description = f"{config['type'].capitalize()} generation" |
| if config['type'] == 'image': |
| description += f" - {config['model_name']}" |
| else: |
| description += f" - {config['model_key']}" |
|
|
| models.append({ |
| "id": model_id, |
| "object": "model", |
| "owned_by": "flow2api", |
| "description": description |
| }) |
|
|
| return { |
| "object": "list", |
| "data": models |
| } |
|
|
|
|
| @router.post("/v1/chat/completions") |
| async def create_chat_completion( |
| request: ChatCompletionRequest, |
| api_key: str = Depends(verify_api_key_header) |
| ): |
| """Create chat completion (unified endpoint for image and video generation)""" |
| try: |
| |
| if not request.messages: |
| raise HTTPException(status_code=400, detail="Messages cannot be empty") |
|
|
| last_message = request.messages[-1] |
| content = last_message.content |
|
|
| |
| prompt = "" |
| images: List[bytes] = [] |
|
|
| if isinstance(content, str): |
| |
| prompt = content |
| elif isinstance(content, list): |
| |
| for item in content: |
| if item.get("type") == "text": |
| prompt = item.get("text", "") |
| elif item.get("type") == "image_url": |
| |
| image_url = item.get("image_url", {}).get("url", "") |
| if image_url.startswith("data:image"): |
| |
| match = re.search(r"base64,(.+)", image_url) |
| if match: |
| image_base64 = match.group(1) |
| image_bytes = base64.b64decode(image_base64) |
| images.append(image_bytes) |
| elif image_url.startswith("http://") or image_url.startswith("https://"): |
| |
| debug_logger.log_info(f"[IMAGE_URL] 下载远程图片: {image_url}") |
| try: |
| downloaded_bytes = await retrieve_image_data(image_url) |
| if downloaded_bytes and len(downloaded_bytes) > 0: |
| images.append(downloaded_bytes) |
| debug_logger.log_info(f"[IMAGE_URL] ✅ 远程图片下载成功: {len(downloaded_bytes)} 字节") |
| else: |
| debug_logger.log_warning(f"[IMAGE_URL] ⚠️ 远程图片下载失败或为空: {image_url}") |
| except Exception as e: |
| debug_logger.log_error(f"[IMAGE_URL] ❌ 远程图片下载异常: {str(e)}") |
|
|
| |
| if request.image and not images: |
| if request.image.startswith("data:image"): |
| match = re.search(r"base64,(.+)", request.image) |
| if match: |
| image_base64 = match.group(1) |
| image_bytes = base64.b64decode(image_base64) |
| images.append(image_bytes) |
|
|
| |
| model_config = MODEL_CONFIG.get(request.model) |
|
|
| if model_config and model_config["type"] == "image" and len(request.messages) > 1: |
| debug_logger.log_info(f"[CONTEXT] 开始查找历史参考图,消息数量: {len(request.messages)}") |
|
|
| |
| for msg in reversed(request.messages[:-1]): |
| if msg.role == "assistant" and isinstance(msg.content, str): |
| |
| matches = re.findall(r"!\[.*?\]\((.*?)\)", msg.content) |
| if matches: |
| last_image_url = matches[-1] |
|
|
| if last_image_url.startswith("http"): |
| try: |
| downloaded_bytes = await retrieve_image_data(last_image_url) |
| if downloaded_bytes and len(downloaded_bytes) > 0: |
| |
| images.insert(0, downloaded_bytes) |
| debug_logger.log_info(f"[CONTEXT] ✅ 添加历史参考图: {last_image_url}") |
| break |
| else: |
| debug_logger.log_warning(f"[CONTEXT] 图片下载失败或为空,尝试下一个: {last_image_url}") |
| except Exception as e: |
| debug_logger.log_error(f"[CONTEXT] 处理参考图时出错: {str(e)}") |
| |
|
|
| if not prompt: |
| raise HTTPException(status_code=400, detail="Prompt cannot be empty") |
|
|
| |
| if request.stream: |
| |
| async def generate(): |
| async for chunk in generation_handler.handle_generation( |
| model=request.model, |
| prompt=prompt, |
| images=images if images else None, |
| stream=True |
| ): |
| yield chunk |
|
|
| |
| yield "data: [DONE]\n\n" |
|
|
| return StreamingResponse( |
| generate(), |
| media_type="text/event-stream", |
| headers={ |
| "Cache-Control": "no-cache", |
| "Connection": "keep-alive", |
| "X-Accel-Buffering": "no" |
| } |
| ) |
| else: |
| |
| result = None |
| async for chunk in generation_handler.handle_generation( |
| model=request.model, |
| prompt=prompt, |
| images=images if images else None, |
| stream=False |
| ): |
| result = chunk |
|
|
| if result: |
| |
| try: |
| result_json = json.loads(result) |
| return JSONResponse(content=result_json) |
| except json.JSONDecodeError: |
| |
| return JSONResponse(content={"result": result}) |
| else: |
| raise HTTPException(status_code=500, detail="Generation failed: No response from handler") |
|
|
| except HTTPException: |
| raise |
| except Exception as e: |
| raise HTTPException(status_code=500, detail=str(e)) |
|
|