fix: files api support and file_id bug remove

Author: zakahan

veadk/models/ark_llm.py

@@ -183,7 +183,7 @@ def _file_data_to_content_param(
             fps = getattr(video_metadata, "fps", 1)
 
     is_file_id = file_uri.startswith("file_id:")
-    value = file_uri[7:] if is_file_id else file_uri
+    value = file_uri[8:] if is_file_id else file_uri
     # video
     if mime_type.startswith("video/"):
         param = {"file_id": value} if is_file_id else {"video_url": value}

veadk/utils/misc.py

@@ -18,7 +18,7 @@
 import sys
 import time
 import types
-from typing import Any, Dict, List, MutableMapping, Tuple
+from typing import Any, Dict, List, MutableMapping, Tuple, Optional
 
 import requests
 from yaml import safe_load
@@ -182,3 +182,34 @@ def get_agent_dir():
         full_path = os.getcwd()
 
     return full_path
+
+
+async def upload_to_files_api(
+    local_path: str,
+    fps: Optional[str] = None,
+    poll_interval: float = 3.0,
+    max_wait_seconds: float = 10 * 60,
+) -> str:
+    from veadk.config import getenv, settings
+    from veadk.consts import DEFAULT_MODEL_AGENT_API_BASE
+    from volcenginesdkarkruntime import AsyncArk
+
+    client = AsyncArk(
+        api_key=getenv("MODEL_AGENT_API_KEY", settings.model.api_key),
+        base_url=getenv("DEFAULT_MODEL_AGENT_API_BASE", DEFAULT_MODEL_AGENT_API_BASE),
+    )
+    file = await client.files.create(
+        file=open(local_path, "rb"),
+        purpose="user_data",
+        preprocess_configs={
+            "video": {
+                "fps": fps,
+            }
+        }
+        if fps
+        else None,
+    )
+    await client.files.wait_for_processing(
+        id=file.id, poll_interval=poll_interval, max_wait_seconds=max_wait_seconds
+    )
+    return file.id