Videoagent Video Studio

{
  "name": "videoagent-video-studio",
  "version": "1.0.0",
  "lockfileVersion": 3,
  "requires": true,
  "packages": {
    "": {
      "name": "videoagent-video-studio",
      "version": "1.0.0",
      "engines": {
        "node": ">=18"
      }
    }
  }
}


{
  "name": "videoagent-video-studio",
  "version": "1.0.0",
  "description": "OpenClaw skill for text-to-video and image-to-video — zero API keys via hosted proxy.",
  "type": "module",
  "engines": {
    "node": ">=18"
  }
}


/**
 * videoagent-video-studio proxy — POST /api/generate
 * Body: { mode, prompt, imageUrl?, duration?, aspectRatio?, model? }
 * model: minimax | kling | veo | hunyuan | pixverse | grok | seedance
 */

const { fal } = require("@fal-ai/client");
const { getModel, listModels, resolveModel, FAL } = require("../models.js");

const FAL_KEY           = process.env.FAL_KEY || "";
const VALID_TOKENS      = (process.env.VALID_TOKENS || "").split(",").filter(Boolean);
const FREE_LIMIT_PER_IP = Math.max(0, parseInt(process.env.FREE_LIMIT_PER_IP || "100", 10));

const {
  getIssuedToken,
  getTokenUsage,
  incrementTokenUsage,
  trackGeneration,
  trackError,
  trackRateLimit,
} = require("../usage-store.js");

fal.config({ credentials: FAL_KEY });

function getClientIp(req) {
  const xff = req.headers["x-forwarded-for"];
  return (typeof xff === "string" ? xff.split(",")[0] : xff?.[0])?.trim()
    || req.headers["x-real-ip"]
    || req.socket?.remoteAddress
    || "unknown";
}

function json(res, status, data) {
  res.setHeader("Content-Type", "application/json");
  res.status(status).json(data);
}

function err(res, status, message, details = null) {
  json(res, status, { success: false, error: message, ...(details && { details }) });
}

function getBearerToken(req) {
  const h = req.headers.authorization;
  return h && h.startsWith("Bearer ") ? h.slice(7).trim() : null;
}

function clampDuration(d, max = 10) {
  const n = parseInt(d, 10);
  if (Number.isNaN(n) || n < 1) return 5;
  return Math.min(n, max);
}

async function runFal(modelId, mode, body) {
  const m = getModel(modelId);
  if (!m || m.provider !== FAL) throw new Error(`Unknown FAL model: ${modelId}`);
  const endpoint = mode === "image-to-video" ? m.i2v : m.t2v;
  if (!endpoint) throw new Error(`Model ${modelId} does not support ${mode}`);

  const normalized = {
    prompt:      body.prompt,
    imageUrl:    body.imageUrl || body.image_url,
    duration:    clampDuration(body.duration),
    aspectRatio: body.aspectRatio || "16:9",
  };
  const input  = m.falInput(normalized, mode);
  const result = await fal.subscribe(endpoint, { input, logs: false });

  const url = result?.data?.video?.url || result?.data?.url;
  if (!url) throw new Error("No video URL in response");

  return { success: true, mode, model: modelId, videoUrl: url,
           duration: normalized.duration, aspectRatio: normalized.aspectRatio };
}

function pickDefaultModel(mode) {
  const list = listModels();
  const m = list.find(m => m.provider === FAL && (mode === "text-to-video" ? m.t2v : m.i2v));
  return m ? m.id : "minimax";
}

module.exports = async function handler(req, res) {
  if (req.method === "OPTIONS") return res.status(204).end();

  // ── GET: health + model list ────────────────────────────────────────────────
  if (req.method === "GET") {
    return json(res, 200, {
      service: "videoagent-video-studio-proxy",
      version: "2.1.0",
      status: "ok",
      modes: ["text-to-video", "image-to-video"],
      models: listModels(),
      free_limit_per_token: FREE_LIMIT_PER_IP,
      free_limit_reset: "daily",
      max_tokens_per_ip_per_day: VALID_TOKENS.length === 0
        ? parseInt(process.env.MAX_TOKENS_PER_IP_PER_DAY || "3", 10) : null,
    });
  }

  if (req.method !== "POST") return err(res, 405, "Method not allowed");

  // ── Auth ────────────────────────────────────────────────────────────────────
  const bearerToken = getBearerToken(req);

  if (VALID_TOKENS.length > 0) {
    if (!bearerTo