@pulze-io/renderflow

Official TypeScript/JavaScript client for the RenderFlow API.

Installation

npm install @pulze-io/renderflow

Quick Start

import { RenderFlow } from "@pulze-io/renderflow";

const rf = new RenderFlow({
    apiKey: process.env.RENDERFLOW_API_KEY
});

const jobs = await rf.jobs.list();
console.log(`Found ${jobs.length} jobs`);

Submitting a Job

const job = await rf.jobs.create({
    name: "Exterior Shot",
    file: "C:/projects/scene.max",
    type: "3dsmax.render",
    host: { id: "3dsmax", name: "3ds Max", version: "2026" },
    engine: { id: "vray", name: "V-Ray", version: "7.20.04" },
    frame: "1-100",
    resolution: "1920x1080",
    priority: 75,
    status: "pending"
});

await rf.jobs.start(job.id);

Managing Jobs

// Get a specific job
const job = await rf.jobs.get("job_id");

// Update job settings
await rf.jobs.update("job_id", {
    priority: 100,
    limit: 5,
    max_batch_size: 10
});

// Control jobs
await rf.jobs.stop("job_id");
await rf.jobs.reset("job_id");
await rf.jobs.archive("job_id");
await rf.jobs.delete("job_id");

Tasks

// List tasks for a job (paginated)
const tasks = await rf.tasks.list("job_id", 1, 50);

// Get a specific task
const task = await rf.tasks.get("task_id");

// Get task logs
const logs = await rf.tasks.logs("task_id", 0, 500);

// Get task thumbnail
const thumbnail = await rf.tasks.thumbnail("task_id");

Nodes

// List all nodes
const nodes = await rf.nodes.list();

// Get node details
const node = await rf.nodes.get("node_id");

// Update node status
await rf.nodes.updateStatus("node_id", "suspended");

// Assign to a pool
await rf.nodes.updatePool("node_id", "pool_id");

// Get node utilization
const util = await rf.nodes.utilization("node_id");

// Get benchmark rankings
const benchmarks = await rf.nodes.benchmarks("vray");

Pools

const pools = await rf.pools.list();
const pool = await rf.pools.get("pool_id");

Users

const users = await rf.users.list();
const user = await rf.users.get("user_id");

Errors

const errors = await rf.errors.list();
const jobErrors = await rf.errors.byJob("job_id");
const nodeErrors = await rf.errors.byNode("node_id");

Real-time Events

Subscribe to live updates using Server-Sent Events:

// Listen to all job changes
const listener = rf.jobs.on((event) => {
    console.log(event.type);      // "insert" | "update" | "delete" | "replace"
    console.log(event.document);  // full job document
    console.log(event.updated);   // changed fields (on update)
    console.log(event.time);      // event timestamp
});

// Listen to task events for a specific job
const taskListener = rf.tasks.on("job_id", (event) => {
    console.log(`Task ${event.document._id}: ${event.document.status}`);
});

// Listen to node events
const nodeListener = rf.nodes.on((event) => {
    console.log(`Node ${event.document.name}: ${event.document.status}`);
});

// Error handling
const listener = rf.jobs.on(
    (event) => console.log(event),
    (error) => console.error("Connection error:", error)
);

// Stop listening
listener.close();

Service Info

const info = await rf.info.get();
console.log(`RenderFlow ${info.version} (${info.node_type})`);