把 Harness 的识图能力
接入你的应用

import { readFile } from 'node:fs/promises'

const BASE_URL = process.env.IMAGE_AGENT_URL
const API_KEY = process.env.VISION_ONLY_API_KEY
const imageBase64 = (await readFile('./product.jpg')).toString('base64')

async function request(path, options = {}) {
  const response = await fetch(`${BASE_URL}${path}`, {
    ...options,
    headers: {
      Authorization: `Bearer ${API_KEY}`,
      'Content-Type': 'application/json',
      ...options.headers,
    },
  })
  const body = await response.json()
  if (!response.ok) throw new Error(body.error?.code || 'api_error')
  return body
}

const session = await request('/v1/sessions', {
  method: 'POST',
  body: JSON.stringify({
    capability: 'vision',
    client_reference: 'order-1001',
  }),
})

const accepted = await request(`/v1/sessions/${session.id}/messages`, {
  method: 'POST',
  body: JSON.stringify({
    mode: 'queue',
    text: '提取图片中的商品名称、价格和文案',
    images: [{
      media_type: 'image/jpeg',
      name: 'product.jpg',
      data: imageBase64,
    }],
  }),
})

let cursor = 0
while (true) {
  const run = await request(
    `/v1/sessions/${session.id}/runs/${accepted.run_id}` +
    `?after=${cursor}&limit=50`
  )
  cursor = run.next_cursor

  for (const event of run.events) console.log(event.message)

  if (run.status === 'completed') {
    console.log(run.result.text)
    break
  }
  if (run.status === 'waiting_input') {
    console.log('需要回答：', run.input_required)
    break
  }
  if (['failed', 'cancelled'].includes(run.status)) {
    throw new Error(run.error?.code || run.status)
  }
  await new Promise(resolve => setTimeout(resolve, 1000))
}