API 文档

import requests
import time

API_KEY = "mp_your_api_key_here"
BASE_URL = "https://www.johngko.com"
headers = {"Authorization": f"Bearer {API_KEY}"}

def upload_file(file_path):
    """上传文件"""
    with open(file_path, "rb") as f:
        response = requests.post(
            f"{BASE_URL}/api/v1/upload",
            headers=headers,
            files={"file": f}
        )
    result = response.json()
    if result["success"]:
        return result["data"]["file_id"]
    raise Exception(f"Upload failed: {result.get('error')}")

def create_task(file_id, function_code, parameters=None):
    """创建处理任务"""
    response = requests.post(
        f"{BASE_URL}/api/v1/tasks",
        headers=headers,
        json={
            "file_id": file_id,
            "function_code": function_code,
            "parameters": parameters or {}
        }
    )
    result = response.json()
    if result["success"]:
        return result["data"]["task_id"]
    raise Exception(f"Create task failed: {result.get('error')}")

def wait_for_task(task_id, timeout=300):
    """等待任务完成"""
    start_time = time.time()
    while time.time() - start_time < timeout:
        response = requests.get(
            f"{BASE_URL}/api/v1/tasks/{task_id}",
            headers=headers
        )
        result = response.json()
        if result["success"]:
            data = result["data"]
            status = data["status"]
            if status == "COMPLETED":
                return data
            elif status == "FAILED":
                raise Exception(f"Task failed: {data.get('error_message')}")
        time.sleep(2)
    raise Exception("Task timeout")

def download_result(task_id, output_path):
    """下载处理结果"""
    response = requests.get(
        f"{BASE_URL}/api/v1/tasks/{task_id}/download",
        headers=headers
    )
    with open(output_path, "wb") as f:
        f.write(response.content)

# 完整流程示例
if __name__ == "__main__":
    # 1. 上传文件
    file_id = upload_file("input.mp4")
    print(f"File uploaded, ID: {file_id}")
    
    # 2. 创建任务
    task_id = create_task(
        file_id,
        "video_compress",
        {"mode": "quality", "quality": "medium"}
    )
    print(f"Task created, ID: {task_id}")
    
    # 3. 等待完成
    result = wait_for_task(task_id)
    print(f"Task completed: {result['output_filename']}")
    
    # 4. 下载结果
    download_result(task_id, "output.mp4")
    print("Download completed!")

const fs = require('fs');
const axios = require('axios');
const FormData = require('form-data');

const API_KEY = 'mp_your_api_key_here';
const BASE_URL = 'https://www.johngko.com';

const headers = { Authorization: `Bearer ${API_KEY}` };

async function uploadFile(filePath) {
  const form = new FormData();
  form.append('file', fs.createReadStream(filePath));
  
  const response = await axios.post(`${BASE_URL}/api/v1/upload`, form, {
    headers: { ...headers, ...form.getHeaders() }
  });
  
  if (response.data.success) {
    return response.data.data.file_id;
  }
  throw new Error(`Upload failed: ${response.data.error}`);
}

async function createTask(fileId, functionCode, parameters = {}) {
  const response = await axios.post(`${BASE_URL}/api/v1/tasks`, {
    file_id: fileId,
    function_code: functionCode,
    parameters
  }, { headers });
  
  if (response.data.success) {
    return response.data.data.task_id;
  }
  throw new Error(`Create task failed: ${response.data.error}`);
}

async function waitForTask(taskId, timeout = 300000) {
  const startTime = Date.now();
  
  while (Date.now() - startTime < timeout) {
    const response = await axios.get(`${BASE_URL}/api/v1/tasks/${taskId}`, { headers });
    
    if (response.data.success) {
      const { status, error_message } = response.data.data;
      
      if (status === 'COMPLETED') {
        return response.data.data;
      }
      if (status === 'FAILED') {
        throw new Error(`Task failed: ${error_message}`);
      }
    }
    
    await new Promise(r => setTimeout(r, 2000));
  }
  
  throw new Error('Task timeout');
}

async function downloadResult(taskId, outputPath) {
  const response = await axios.get(`${BASE_URL}/api/v1/tasks/${taskId}/download`, {
    headers,
    responseType: 'stream'
  });
  
  const writer = fs.createWriteStream(outputPath);
  response.data.pipe(writer);
  
  return new Promise((resolve, reject) => {
    writer.on('finish', resolve);
    writer.on('error', reject);
  });
}

// 完整流程
(async () => {
  const fileId = await uploadFile('input.mp4');
  console.log(`File uploaded, ID: ${fileId}`);
  
  const taskId = await createTask(fileId, 'video_compress', {
    mode: 'quality',
    quality: 'medium'
  });
  console.log(`Task created, ID: ${taskId}`);
  
  const result = await waitForTask(taskId);
  console.log(`Task completed: ${result.output_filename}`);
  
  await downloadResult(taskId, 'output.mp4');
  console.log('Download completed!');
})();