Migrating from Replicate to Naive

import Replicate from "replicate";

// One account-wide token. It is unrelated to where this agent's card, inbox,
// phone, and KYC live — and whether the agent "may render" is a token you hold,
// not a governed, execution-time decision.
const replicate = new Replicate(); // reads REPLICATE_API_TOKEN

// `run` blocks until the prediction finishes, then returns the output file(s).
const [image] = await replicate.run("black-forest-labs/flux-schnell", {
  input: {
    prompt: "A minimalist logo for a tech startup, flat design, indigo",
  },
});

// `image` is a FileOutput → an HTTPS URL (removed from Replicate after ~1h).
const url = image.url();

// The same NAIVE_API_KEY reaches cards, email, phone, vault, and KYC.
import { Naive } from "@usenaive-sdk/server";
const naive = new Naive({ apiKey: process.env.NAIVE_API_KEY! });

// 1. Submit via the images sub-client — same FLUX schnell model
const { job_id } = await naive.images.generate({
  model: "fal-ai/flux/schnell",
  input: { prompt: "A minimalist logo for a tech startup, flat design, indigo" },
}); // 202 { job_id, status: "queued", estimated_credits }

// 2. Poll the unified jobs system (covers image AND video jobs; or images.status(job_id))
let job = await naive.jobs.get(job_id);
while (job.status === "queued" || job.status === "processing") {
  await new Promise((r) => setTimeout(r, 2000));
  job = await naive.jobs.get(job_id);
}
const url = job.result.images[0].url; // fal.media URL

// Whether this agent may generate at all is its Account Kit's `images` primitive,
// checked at execution time; the render spends credits against the SAME budget
// ceiling as its cards, email, and phone — and it is logged against the acting agent.

const replicate = new Replicate();

// Submit an async prediction; Replicate will POST your webhook on completion.
const prediction = await replicate.predictions.create({
  model: "minimax/video-01",
  input: { prompt: "A golden retriever running on a beach at sunset, cinematic" },
  webhook: "https://example.com/replicate-webhook",
  webhook_events_filter: ["completed"],
});

// ...or poll it yourself.
let p = await replicate.predictions.get(prediction.id);
while (p.status === "starting" || p.status === "processing") {
  await new Promise((r) => setTimeout(r, 3000));
  p = await replicate.predictions.get(prediction.id);
}
const videoUrl = p.output; // HTTPS URL

// Submit via the video sub-client — Kling text-to-video
const { job_id } = await naive.video.generate({
  model: "fal-ai/kling-video/v3/pro/text-to-video",
  input: {
    prompt: "A golden retriever running on a beach at sunset, cinematic",
    duration: "5",
    aspect_ratio: "16:9",
  },
}); // 202 { job_id, estimated_credits }

// Same jobs poller as images (or naive.video.status(job_id))
let job = await naive.jobs.get(job_id);
while (job.status === "queued" || job.status === "processing") {
  await new Promise((r) => setTimeout(r, 15000)); // video takes 30–120s
  job = await naive.jobs.get(job_id);
}
const videoUrl = job.result.video.url; // also auto-added to the Media library

// The r8_ token renders; it knows nothing about this agent's money or identity.
const replicate = new Replicate();
await replicate.run("black-forest-labs/flux-schnell", {
  input: { prompt: "launch banner for Acme" },
});

// The card, inbox, phone, and KYC for this customer's agent live elsewhere —
// separate accounts, separate billing, separate audit — and "may this agent
// render?" is a token you hold, not a governed decision.

// One tenant user per customer; the same handle reaches every primitive.
const acme = await naive.users.create({
  external_id: dbCustomer.id,
  email: dbCustomer.email,
});
const client = naive.forUser(acme.id);

// Generate over the per-user scope — gated + metered like the rest.
await client.images.generate({
  model: "fal-ai/flux/schnell",
  input: { prompt: "launch banner for Acme" },
});

// The SAME identity owns this customer's card, inbox, phone, and KYC — one
// account, one budget, one audit trail, every capability governed by its
// Account Kit.
await client.cards.create({ spending_limit_cents: 25_000 });
await client.email.createInbox({ local_part: "ops" });