Visko Orbis Stable overview

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

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

// 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, set a prompt and start.
reactor.on("statusChanged", async (status) => {
  if (status !== "ready") return;
  await reactor.sendCommand("set_prompt", {
    prompt:
      "A dramatic coastline of black volcanic cliffs at golden hour, huge dark waves rolling in from a blood-orange sea and exploding into white foam against the rocks. Cinematic slow aerial motion, a single unbroken take.",
  });
  await reactor.sendCommand("start", {});
});

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/visko-orbis-stable",
                      api_key=os.environ["REACTOR_API_KEY"])

    # Once the session is ready, set a prompt and start.
    @reactor.on_status(ReactorStatus.READY)
    async def on_ready(status):
        # Frames arrive as (H, W, 3) uint8 RGB NumPy arrays.
        output = reactor.tracks.with_direction("recvonly").with_kind("video").one()

        @output.on_frame
        def on_frame(frame):
            print(f"Frame: {frame.shape}")

        await reactor.send_command("set_prompt", {
            "prompt": "A dramatic coastline of black volcanic cliffs at golden hour, huge dark waves rolling in from a blood-orange sea. Cinematic slow aerial motion, a single unbroken take.",
        })
        await reactor.send_command("start", {})

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

asyncio.run(main())