Streaming video

curl -N https://api.boson.ai/v1/videos/stream \
  -H "Authorization: Bearer $BOSON_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "higgs-avatar",
    "ref_image": "https://docs.boson.ai/public/avatar/sample.jpg",
    "input": "https://docs.boson.ai/public/audio/sample.mp3",
    "size": "640x640"
  }' \
  --output out.mp4

import os

import requests


payload = {
    "model": "higgs-avatar",
    "ref_image": "https://docs.boson.ai/public/avatar/sample.jpg",
    "input": "https://docs.boson.ai/public/audio/sample.mp3",
    "size": "640x640",
}

with open("out.mp4", "wb") as file, requests.post(
    "https://api.boson.ai/v1/videos/stream",
    headers={"Authorization": f"Bearer {os.environ['BOSON_API_KEY']}"},
    json=payload,
    stream=True,
    timeout=300,
) as response:
    response.raise_for_status()
    video_id = response.headers["X-Video-Id"]

    for chunk in response.iter_content(chunk_size=8192):
        if chunk:
            file.write(chunk)

print(f"Saved out.mp4 from video {video_id}")

import { writeFile } from "node:fs/promises";

const response = await fetch("https://api.boson.ai/v1/videos/stream", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.BOSON_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    model: "higgs-avatar",
    ref_image: "https://docs.boson.ai/public/avatar/sample.jpg",
    input: "https://docs.boson.ai/public/audio/sample.mp3",
    size: "640x640",
  }),
});

if (!response.ok || !response.body) {
  throw new Error(await response.text());
}

const chunks: Uint8Array[] = [];
const reader = response.body.getReader();

while (true) {
  const { value, done } = await reader.read();
  if (done) break;
  if (value) chunks.push(value);
}

await writeFile("out.mp4", Buffer.concat(chunks));
console.log(`video id: ${response.headers.get("X-Video-Id")}`);