FastH3 overview

import { Reactor } from "@reactor-team/js-sdk";

const video = document.querySelector("video")!;
const reactor = new Reactor({ modelName: "reactor/fast-h3" });

// Render frames as soon as they arrive.
reactor.on("trackReceived", (name, track, stream) => {
  if (name !== "main_video") return;
  video.srcObject = stream;
  void video.play();
});

// Once the session is ready, enqueue a clip and play it when built.
reactor.on("statusChanged", async (status) => {
  if (status !== "ready") return;
  await reactor.sendCommand("enqueue", {
    prompt:
      "Aerial pullback over a rain-slicked night market, neon signs buzzing, steam rising off food carts. Slow continuous drone move, wide shot. Rain patter, vendor calls, sizzling woks.",
  });
});

reactor.on("message", async (msg) => {
  if (msg.type !== "clip_generated") return;
  // Autoplay starts each built clip on its own; manual `play` on a *second*
  // clip_generated would race and be refused ("another clip is playing").
  // Uncomment the line below instead if autoplay is off on this client.
  // await reactor.sendCommand("play", { clip_id: msg.data.clip.clip_id });
});

const jwt = await getToken(); // token minted on your server
await reactor.connect(jwt);

import asyncio
import os
from reactor_sdk import Reactor, ReactorStatus

async def main():
    reactor = Reactor(model_name="reactor/fast-h3",
                      api_key=os.environ["REACTOR_API_KEY"])

    @reactor.on_status(ReactorStatus.READY)
    async def on_ready(status):
        await reactor.send_command("enqueue", {
            "prompt": "Aerial pullback over a rain-slicked night market, neon signs buzzing, steam rising off food carts. Slow continuous drone move, wide shot. Rain patter, vendor calls, sizzling woks.",
        })

    @reactor.on_message
    def on_message(msg):
        if msg["type"] == "clip_generated":
            asyncio.ensure_future(
                reactor.send_command("play", {"clip_id": msg["data"]["clip"]["clip_id"]})
            )

    await reactor.connect()
    await asyncio.Event().wait()  # run until interrupted

asyncio.run(main())