FastH3 schema

const ref = await reactor.uploadFile(seedImageFile);
const reply = await reactor.sendCommand("enqueue", {
  prompt: "A waxed yellow coat on a lighthouse stair, lantern swinging. Handheld follow.",
  starting_frame: ref,
});
// reply === { type: "clip_queued", data: { clip: ClipInfo } }

ref = await reactor.upload_file("seed.png")
reply = await reactor.send_command("enqueue", {
    "prompt": "A waxed yellow coat on a lighthouse stair, lantern swinging. Handheld follow.",
    "starting_frame": ref,
})
# reply == {"type": "clip_queued", "data": {"clip": {…ClipInfo…}}}

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

let refusal: ReactorError | undefined;
reactor.on("error", (error) => {
  if (error.operation === "sendCommand") refusal = error;
});

refusal = undefined;
const reply = await reactor.sendCommand("enqueue", { prompt });
if (reply === undefined) {
  // refusal?.code === "queue_full", "prompt_too_long", ...
  showRefusal(refusal?.message ?? "The model refused this command.");
}

from reactor_sdk import ReactorError

try:
    reply = await reactor.send_command("enqueue", {"prompt": prompt})
except ReactorError as error:
    if error.code == "queue_full":
        ...  # wait for a clip_generated, or pop a queued clip
    print(error.message)

reactor.on("message", (msg) => {
  switch (msg.type) {
    case "state_update":
      console.log(`valid: ${msg.data.valid_commands.join(", ")}`);
      break;
    case "queue_update": {
      const { generation, playout, history } = msg.data;
      console.log(
        `generating: ${generation.length}, ready: ${playout.length}, history: ${history.length}`,
      );
      break;
    }
    case "clip_started":
      console.log(`now playing: ${msg.data.clip.prompt.slice(0, 50)}`);
      break;
  }
});

@reactor.on_message
def handle(msg):
    data = msg["data"]
    if msg["type"] == "queue_update":
        print(
            f"generating: {len(data['generation'])}, "
            f"ready: {len(data['playout'])}, "
            f"history: {len(data['history'])}"
        )

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

const reactor = new Reactor({ modelName: "reactor/fast-h3" });

// A refused command reports here, on its own call's error.
reactor.on("error", (error) => {
  if (error.operation === "sendCommand") console.error(error.message);
});

reactor.on("message", (msg) => {
  if (msg.type === "clip_started") {
    console.log(`▶ ${msg.data.clip.prompt.slice(0, 60)}`);
  }
});

reactor.on("statusChanged", async (status) => {
  if (status !== "ready") return;

  await reactor.sendCommand("set_clip_seconds", { seconds: 8 });
  await reactor.sendCommand("set_autoplay", { enabled: true });

  const base = await reactor.sendCommand("enqueue", {
    prompt:
      "Foothills at first light, mist draining off a pine ridge line. Slow aerial glide. Bird calls, a river murmur.",
  });
  if (!base) return; // refused: the error listener above logged why
  const baseId = base.data.clip.clip_id;

  await reactor.sendCommand("enqueue", {
    prompt:
      "Hard cut to a wide shot: the mist thickens into rain over the same foothills, the ridgeline darkening under rolling clouds. Sheets of rain sweep the pines, the flock scatters low, thunder rolls far off.",
    continue_from_clip_id: baseId,
  });
});

const jwt = await getToken();
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_message
    def log(msg):
        if msg["type"] == "clip_started":
            print(f"▶ {msg['data']['clip']['prompt'][:60]}")

    @reactor.on_status(ReactorStatus.READY)
    async def on_ready(status):
        await reactor.send_command("set_clip_seconds", {"seconds": 8})
        await reactor.send_command("set_autoplay", {"enabled": True})

        base = await reactor.send_command("enqueue", {
            "prompt": "Foothills at first light, mist draining off a pine ridge line. Slow aerial glide. Bird calls, a river murmur.",
        })
        base_id = base["data"]["clip"]["clip_id"]

        await reactor.send_command("enqueue", {
            "prompt": "Hard cut to a wide shot: the mist thickens into rain over the same foothills, the ridgeline darkening under rolling clouds. Sheets of rain sweep the pines, the flock scatters low, thunder rolls far off.",
            "continue_from_clip_id": base_id,
        })

    await reactor.connect()
    await asyncio.Event().wait()

asyncio.run(main())