Assistant API 測試控台

const axios = require('axios');

const API_KEY = '您的_DAVINCI_API_KEY';
const ASSISTANT_ID = 'asst_dvc_FnejbpNgNNXVqnsKUhzBMGfa';
const ASSISTANT_API = 'https://sandbox.davinci.tw/api/assts/v1';
const TARGET_URL = 'https://www.sam-huang.info/files/system_v0.2_draft.docx';

const headers = {
    'Authorization': `Bearer ${API_KEY}`,
    'Content-Type': 'application/json',
    'OpenAI-Beta': 'assistants=v2'
};

const sleep = (ms) => new Promise(resolve => setTimeout(resolve, ms));

async function analyzeDocument() {
    console.log("=== DaVinci Assistant 自動分析腳本 ===");

    // 1. 建立 Thread
    let res = await axios.post(`${ASSISTANT_API}/threads`, {}, { headers });
    const THREAD_ID = res.data.id;
    console.log(`Thread ID: ${THREAD_ID}`);

    // 2. 寫入 Message (直接帶入目標檔案網址)
    await axios.post(`${ASSISTANT_API}/threads/${THREAD_ID}/messages`, {
        role: 'user',
        content: TARGET_URL
    }, { headers });

    // 3. 發起 Run
    res = await axios.post(`${ASSISTANT_API}/threads/${THREAD_ID}/runs`, {
        assistant_id: ASSISTANT_ID,
        additional_instructions: `\nThe current time is: ${new Date().toLocaleString()}`
    }, { headers });
    const RUN_ID = res.data.id;

    // 4. Polling 輪詢與外掛調用
    while (true) {
        await sleep(1500);
        res = await axios.get(`${ASSISTANT_API}/threads/${THREAD_ID}/runs/${RUN_ID}`, { headers });
        let run = res.data;

        if (['queued', 'in_progress', 'cancelling'].includes(run.status)) {
            continue;
        }

        if (run.status === 'requires_action') {
            const toolCalls = run.required_action.submit_tool_outputs.tool_calls;
            const toolOutputs = await Promise.all(toolCalls.map(async (call) => {
                const args = call.function.arguments ? JSON.parse(call.function.arguments) : {};
                const pluginRes = await axios.post(`${ASSISTANT_API}/pluginapi`, args, {
                    params: { tid: THREAD_ID, aid: ASSISTANT_ID, pid: call.function.name },
                    headers: headers,
                    timeout: 30000
                });
                return {
                    tool_call_id: call.id,
                    output: typeof pluginRes.data === 'string' ? pluginRes.data : JSON.stringify(pluginRes.data)
                };
            }));

            await axios.post(`${ASSISTANT_API}/threads/${THREAD_ID}/runs/${RUN_ID}/submit_tool_outputs`, {
                tool_outputs: toolOutputs
            }, { headers });
            continue;
        }

        if (run.status === 'completed') break;
        throw new Error(`任務未預期終止: ${run.status}`);
    }

    // 5. 取得最終對話結果
    res = await axios.get(`${ASSISTANT_API}/threads/${THREAD_ID}/messages`, { headers });
    console.log("分析結果：", res.data.data[0].content[0].text.value);
}

analyzeDocument();