Compare commits
2 Commits
master
...
a698c6b225
| Author | SHA1 | Date | |
|---|---|---|---|
|
a698c6b225 | ||
|
|
68c164db97 |
@@ -3,9 +3,6 @@
|
||||
node_modules
|
||||
remotion/node_modules
|
||||
|
||||
# MCP server: herramienta aparte para agentes, no forma parte de la app Next
|
||||
mcp-server
|
||||
|
||||
# Datos persistentes: NO van en la imagen, llegan por volúmenes montados
|
||||
projects
|
||||
data
|
||||
|
||||
3
mcp-server/.gitignore
vendored
3
mcp-server/.gitignore
vendored
@@ -1,3 +0,0 @@
|
||||
node_modules/
|
||||
dist/
|
||||
*.tsbuildinfo
|
||||
@@ -1,75 +0,0 @@
|
||||
# Story Studio MCP Server
|
||||
|
||||
Servidor **MCP** (Model Context Protocol) para controlar [Story Studio](https://story-studio.carlosnarro.com) desde agentes: crear proyectos y conducir todo el pipeline de producción de series animadas IA (idea motriz → personajes → capítulos → guión → escaleta → prompts → fondos → imágenes → vídeos → render).
|
||||
|
||||
Envuelve la **API HTTP** de la app; no accede a la BD directamente.
|
||||
|
||||
## Requisitos
|
||||
|
||||
- Node.js ≥ 18
|
||||
- Una instancia de Story Studio accesible (local en `npm run dev`, o la desplegada).
|
||||
|
||||
## Instalar y compilar
|
||||
|
||||
```bash
|
||||
cd mcp-server
|
||||
npm install
|
||||
npm run build # genera dist/
|
||||
```
|
||||
|
||||
## Configuración
|
||||
|
||||
| Variable | Default | Descripción |
|
||||
|----------|---------|-------------|
|
||||
| `STORY_STUDIO_URL` | `http://localhost:3000` | Base URL de la app. Local: `http://localhost:3000`. Prod: `https://story-studio.carlosnarro.com`. |
|
||||
|
||||
> La app **no tiene autenticación**; el server hereda ese modelo. Apunta `STORY_STUDIO_URL` al entorno que quieras controlar.
|
||||
|
||||
## Uso con Claude Code / clientes MCP
|
||||
|
||||
Transporte **stdio**. Ejemplo de registro (`.mcp.json` o config del cliente):
|
||||
|
||||
```json
|
||||
{
|
||||
"mcpServers": {
|
||||
"story-studio": {
|
||||
"command": "node",
|
||||
"args": ["C:/Users/carlo/Proyectos/story-studio/mcp-server/dist/index.js"],
|
||||
"env": { "STORY_STUDIO_URL": "http://localhost:3000" }
|
||||
}
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
O en desarrollo con recarga: `command: "npx"`, `args: ["tsx", ".../src/index.ts"]`.
|
||||
|
||||
## Herramientas
|
||||
|
||||
Prefijo `story_`. Lectura (`readOnlyHint`) vs generación (efectos, LLM/imagen/vídeo).
|
||||
|
||||
**Proyecto e idea**: `story_list_projects`, `story_get_project`, `story_create_project`,
|
||||
`story_get_idea_motriz`, `story_generate_idea_motriz`, `story_refine_idea_motriz`.
|
||||
|
||||
**Personajes**: `story_get_personajes`, `story_generate_personajes`, `story_add_personaje`,
|
||||
`story_improve_personajes`, y assets de imagen: `story_get_character_assets`,
|
||||
`story_generate_asset_prompts`, `story_generate_base_image`, `story_lock_base_image`,
|
||||
`story_generate_all_variations`.
|
||||
|
||||
**Capítulo y pipeline**: `story_list_capitulos`, `story_create_capitulo`,
|
||||
`story_get_guion` / `story_generate_guion`,
|
||||
`story_get_pre_escaleta` / `story_generate_pre_escaleta`,
|
||||
`story_get_escaleta` / `story_generate_escaleta`,
|
||||
`story_get_prompts` / `story_generate_prompts`,
|
||||
`story_get_fondos` / `story_refresh_fondos` / `story_generate_fondo` / `story_generate_all_fondos`,
|
||||
`story_get_imagenes` / `story_generate_plano_image` / `story_generate_all_images`,
|
||||
`story_get_videos` / `story_generate_plano_video`,
|
||||
`story_render_chapter` / `story_get_render_status`.
|
||||
|
||||
## Orden típico del pipeline
|
||||
|
||||
1. `story_create_project` → `story_generate_idea_motriz` → `story_generate_personajes`
|
||||
2. (opcional) assets de personaje: `story_generate_asset_prompts` → `story_generate_base_image` → `story_lock_base_image` → `story_generate_all_variations`
|
||||
3. `story_create_capitulo` → `story_generate_guion` → `story_generate_pre_escaleta` → `story_generate_escaleta` → `story_generate_prompts`
|
||||
4. `story_refresh_fondos` → `story_generate_all_fondos` → `story_generate_all_images` → `story_generate_plano_video` → `story_render_chapter`
|
||||
|
||||
Las tools de generación pueden tardar (LLM/imagen); el server usa timeouts amplios.
|
||||
1739
mcp-server/package-lock.json
generated
1739
mcp-server/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -1,29 +0,0 @@
|
||||
{
|
||||
"name": "story-studio-mcp-server",
|
||||
"version": "1.0.0",
|
||||
"description": "MCP server para controlar Story Studio (series animadas IA) desde agentes",
|
||||
"type": "module",
|
||||
"main": "dist/index.js",
|
||||
"bin": {
|
||||
"story-studio-mcp-server": "dist/index.js"
|
||||
},
|
||||
"files": ["dist"],
|
||||
"scripts": {
|
||||
"build": "tsc",
|
||||
"start": "node dist/index.js",
|
||||
"dev": "tsx watch src/index.ts",
|
||||
"clean": "rimraf dist"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=18"
|
||||
},
|
||||
"dependencies": {
|
||||
"@modelcontextprotocol/sdk": "^1.12.0",
|
||||
"zod": "^3.23.8"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@types/node": "^22.10.0",
|
||||
"tsx": "^4.19.2",
|
||||
"typescript": "^5.7.2"
|
||||
}
|
||||
}
|
||||
@@ -1,107 +0,0 @@
|
||||
/**
|
||||
* Cliente HTTP para la API de Story Studio.
|
||||
*
|
||||
* La app expone toda su funcionalidad como rutas REST bajo /api. Este cliente centraliza
|
||||
* el fetch, los timeouts (la generación con LLM/imagen puede tardar minutos) y el formateo
|
||||
* de errores accionables para el agente.
|
||||
*/
|
||||
|
||||
export const BASE_URL = (process.env.STORY_STUDIO_URL || 'http://localhost:3000').replace(/\/$/, '');
|
||||
|
||||
// Límite de caracteres de una respuesta de tool para no saturar el contexto del agente.
|
||||
export const CHARACTER_LIMIT = 25000;
|
||||
|
||||
const GET_TIMEOUT_MS = 60_000;
|
||||
const POST_TIMEOUT_MS = 600_000; // generación (LLM / imagen) puede tardar varios minutos
|
||||
|
||||
export class ApiError extends Error {
|
||||
constructor(public status: number, public bodyText: string, message: string) {
|
||||
super(message);
|
||||
this.name = 'ApiError';
|
||||
}
|
||||
}
|
||||
|
||||
function joinUrl(pathname: string): string {
|
||||
return `${BASE_URL}${pathname.startsWith('/') ? '' : '/'}${pathname}`;
|
||||
}
|
||||
|
||||
async function request(method: 'GET' | 'POST', pathname: string, body?: unknown): Promise<unknown> {
|
||||
const controller = new AbortController();
|
||||
const timeout = setTimeout(
|
||||
() => controller.abort(),
|
||||
method === 'POST' ? POST_TIMEOUT_MS : GET_TIMEOUT_MS,
|
||||
);
|
||||
try {
|
||||
const res = await fetch(joinUrl(pathname), {
|
||||
method,
|
||||
headers: body !== undefined ? { 'Content-Type': 'application/json' } : undefined,
|
||||
body: body !== undefined ? JSON.stringify(body) : undefined,
|
||||
signal: controller.signal,
|
||||
});
|
||||
|
||||
const text = await res.text();
|
||||
if (!res.ok) {
|
||||
// La API devuelve { error: "..." } en fallos.
|
||||
let msg = `HTTP ${res.status}`;
|
||||
try {
|
||||
const parsed = JSON.parse(text);
|
||||
if (parsed?.error) msg = parsed.error;
|
||||
} catch { /* body no-JSON */ }
|
||||
throw new ApiError(res.status, text, msg);
|
||||
}
|
||||
|
||||
if (!text) return null;
|
||||
try {
|
||||
return JSON.parse(text);
|
||||
} catch {
|
||||
return text; // respuesta no-JSON (raro)
|
||||
}
|
||||
} catch (err) {
|
||||
if (err instanceof ApiError) throw err;
|
||||
if (err instanceof Error && err.name === 'AbortError') {
|
||||
throw new ApiError(0, '', `La petición a ${pathname} superó el timeout (${method === 'POST' ? '10 min' : '60 s'}).`);
|
||||
}
|
||||
throw new ApiError(0, '', `No se pudo conectar con Story Studio en ${BASE_URL} (${pathname}). ¿Está la app levantada? Detalle: ${err instanceof Error ? err.message : String(err)}`);
|
||||
} finally {
|
||||
clearTimeout(timeout);
|
||||
}
|
||||
}
|
||||
|
||||
export function apiGet(pathname: string): Promise<unknown> {
|
||||
return request('GET', pathname);
|
||||
}
|
||||
|
||||
export function apiPost(pathname: string, body: unknown): Promise<unknown> {
|
||||
return request('POST', pathname, body);
|
||||
}
|
||||
|
||||
/** Codifica un segmento de path (slug, id) de forma segura para la URL. */
|
||||
export function seg(value: string | number): string {
|
||||
return encodeURIComponent(String(value));
|
||||
}
|
||||
|
||||
/**
|
||||
* Formatea el resultado de una tool: texto JSON (truncado si es enorme).
|
||||
* Devuelve la forma { content } que espera el SDK de MCP.
|
||||
*/
|
||||
export function toolResult(data: unknown): { content: { type: 'text'; text: string }[] } {
|
||||
let text = typeof data === 'string' ? data : JSON.stringify(data, null, 2);
|
||||
if (text.length > CHARACTER_LIMIT) {
|
||||
text = text.slice(0, CHARACTER_LIMIT) +
|
||||
`\n\n… [truncado: la respuesta superaba ${CHARACTER_LIMIT} caracteres]`;
|
||||
}
|
||||
return { content: [{ type: 'text', text }] };
|
||||
}
|
||||
|
||||
/** Convierte un error en un resultado de tool accionable (isError). */
|
||||
export function toolError(err: unknown): { content: { type: 'text'; text: string }[]; isError: true } {
|
||||
let text: string;
|
||||
if (err instanceof ApiError) {
|
||||
text = `Error: ${err.message}` + (err.status ? ` (HTTP ${err.status})` : '');
|
||||
} else if (err instanceof Error) {
|
||||
text = `Error: ${err.message}`;
|
||||
} else {
|
||||
text = `Error inesperado: ${String(err)}`;
|
||||
}
|
||||
return { content: [{ type: 'text', text }], isError: true };
|
||||
}
|
||||
@@ -1,489 +0,0 @@
|
||||
#!/usr/bin/env node
|
||||
/**
|
||||
* MCP server para Story Studio — permite a agentes controlar la app de series animadas IA
|
||||
* (crear proyectos, idea motriz, personajes, capítulos, guión, escaleta, prompts, fondos,
|
||||
* imágenes, vídeos y render) a través de su API HTTP.
|
||||
*
|
||||
* Transporte: stdio. Configuración: STORY_STUDIO_URL (default http://localhost:3000).
|
||||
*
|
||||
* NOTA: la app no tiene autenticación; el server hereda ese modelo. Apunta STORY_STUDIO_URL
|
||||
* al entorno correcto (local o https://story-studio.carlosnarro.com).
|
||||
*/
|
||||
|
||||
import { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
|
||||
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';
|
||||
import { z } from 'zod';
|
||||
import { apiGet, apiPost, seg, toolResult, toolError, BASE_URL, ApiError } from './api.js';
|
||||
|
||||
const server = new McpServer({ name: 'story-studio-mcp-server', version: '1.0.0' });
|
||||
|
||||
// Anotaciones reutilizables.
|
||||
const READ = { readOnlyHint: true, destructiveHint: false, idempotentHint: true, openWorldHint: true } as const;
|
||||
// Operaciones con efectos (crean/generan; muchas llaman a LLM/imagen/vídeo → openWorld, no idempotentes).
|
||||
const GEN = { readOnlyHint: false, destructiveHint: false, idempotentHint: false, openWorldHint: true } as const;
|
||||
|
||||
type Args = Record<string, unknown>;
|
||||
|
||||
/** Envuelve el handler con try/catch → resultado de tool uniforme. */
|
||||
function wrap(fn: (args: Args) => Promise<unknown>) {
|
||||
return async (args: Args) => {
|
||||
try {
|
||||
return toolResult(await fn(args));
|
||||
} catch (e) {
|
||||
return toolError(e);
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Proyección compacta de la respuesta de vídeos/sync: un capítulo puede tener 100+ planos y el
|
||||
* objeto completo satura el límite de respuesta (y se trunca a JSON inválido). Devolvemos solo lo
|
||||
* necesario para conducir la generación: por plano su id, si tiene imagen, y las variaciones (estado).
|
||||
*/
|
||||
function compactVideos(data: unknown, onlyPlanoId?: string): unknown {
|
||||
if (!data || typeof data !== 'object') return data;
|
||||
const d = data as Record<string, any>;
|
||||
if (!Array.isArray(d.planos)) return data;
|
||||
const planosSrc = onlyPlanoId ? d.planos.filter((p: any) => p.id === onlyPlanoId) : d.planos;
|
||||
// Proyección MUY lean: un capítulo con 100+ planos y sus videoUrl largos supera el límite de
|
||||
// respuesta. La videoUrl es determinista (/api/projects/{slug}/capitulos/{cap}/videos/{planoId}-{variationId}),
|
||||
// así que se omite aquí; el consumidor puede reconstruirla desde planoId+variationId si la necesita.
|
||||
return {
|
||||
total: d.total,
|
||||
generated: d.generated,
|
||||
pending: d.pending,
|
||||
planos: planosSrc.map((p: any) => ({
|
||||
id: p.id,
|
||||
numeroPlano: p.numeroPlano,
|
||||
imagen: !!p.imagenUrl,
|
||||
variations: (p.videoVariations || []).map((v: any) => {
|
||||
const out: Record<string, unknown> = { id: v.id, status: v.status };
|
||||
if (v.isSelected) out.isSelected = true;
|
||||
if (typeof v.generationTimeSeconds === 'number') out.generationTimeSeconds = v.generationTimeSeconds;
|
||||
if (v.error) out.error = v.error;
|
||||
return out;
|
||||
}),
|
||||
})),
|
||||
};
|
||||
}
|
||||
|
||||
const slugField = z.string().min(1).describe('Slug del proyecto (p.ej. "coco-y-miko"). Obtenlo de story_list_projects.');
|
||||
const numeroField = z.number().int().min(1).describe('Número de capítulo (entero, p.ej. 1).');
|
||||
|
||||
// Helpers de path.
|
||||
const capBase = (slug: string, numero: number) => `/api/projects/${seg(slug)}/capitulos/${numero}`;
|
||||
|
||||
// ============================================================
|
||||
// PROYECTOS
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_list_projects', {
|
||||
title: 'Listar proyectos',
|
||||
description: 'Lista todos los proyectos de Story Studio (id, nombre, slug, estado, paso actual). Empieza por aquí para descubrir qué proyectos existen y su slug.',
|
||||
inputSchema: {},
|
||||
annotations: READ,
|
||||
}, wrap(async () => apiGet('/api/projects')));
|
||||
|
||||
server.registerTool('story_get_project', {
|
||||
title: 'Ver proyecto',
|
||||
description: 'Devuelve los metadatos de un proyecto por su slug.',
|
||||
inputSchema: { slug: slugField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug }) => apiGet(`/api/projects/${seg(slug as string)}`)));
|
||||
|
||||
server.registerTool('story_create_project', {
|
||||
title: 'Crear proyecto',
|
||||
description: 'Crea un proyecto nuevo a partir de un nombre. El slug se deriva del nombre. Falla si ya existe o si el nombre normaliza a vacío.',
|
||||
inputSchema: { name: z.string().min(1).describe('Nombre del proyecto/serie.') },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ name }) => apiPost('/api/projects', { name })));
|
||||
|
||||
// ============================================================
|
||||
// IDEA MOTRIZ
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_idea_motriz', {
|
||||
title: 'Ver idea motriz',
|
||||
description: 'Devuelve la Idea Motriz del proyecto (concepto, narrativa, protagonistas, valores, estructura de guión…) o null si aún no existe.',
|
||||
inputSchema: { slug: slugField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug }) => apiGet(`/api/projects/${seg(slug as string)}/idea-motriz`)));
|
||||
|
||||
server.registerTool('story_generate_idea_motriz', {
|
||||
title: 'Generar idea motriz',
|
||||
description: 'Genera (con GPT-4o) la Idea Motriz a partir de una descripción libre y la guarda. Sobrescribe la existente. Devuelve la Idea Motriz generada.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
input: z.string().min(1).describe('Descripción/brief de la serie a partir del cual generar la idea motriz.'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, input }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/idea-motriz`, { action: 'generate', input })));
|
||||
|
||||
server.registerTool('story_refine_idea_motriz', {
|
||||
title: 'Refinar idea motriz',
|
||||
description: 'Refina la Idea Motriz existente con feedback en lenguaje natural (GPT-4o) y guarda el resultado. Requiere que ya exista una Idea Motriz.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
feedback: z.string().min(1).describe('Instrucciones de cambio/mejora sobre la idea motriz actual.'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, feedback }) => {
|
||||
const s = slug as string;
|
||||
const current = await apiGet(`/api/projects/${seg(s)}/idea-motriz`);
|
||||
if (!current) throw new ApiError(400, '', 'No hay Idea Motriz que refinar. Usa story_generate_idea_motriz primero.');
|
||||
return apiPost(`/api/projects/${seg(s)}/idea-motriz`, { action: 'refine', current, input: feedback });
|
||||
}));
|
||||
|
||||
// ============================================================
|
||||
// PERSONAJES
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_personajes', {
|
||||
title: 'Ver personajes',
|
||||
description: 'Lista los personajes del proyecto (ficha completa: especie, apariencia, personalidad, utilería…).',
|
||||
inputSchema: { slug: slugField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug }) => apiGet(`/api/projects/${seg(slug as string)}/personajes`)));
|
||||
|
||||
server.registerTool('story_generate_personajes', {
|
||||
title: 'Generar personajes',
|
||||
description: 'Genera el elenco de personajes (GPT-4o) a partir de la Idea Motriz del proyecto y los guarda (reemplaza los existentes). Requiere Idea Motriz creada.',
|
||||
inputSchema: { slug: slugField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/personajes`, { action: 'generate' })));
|
||||
|
||||
server.registerTool('story_add_personaje', {
|
||||
title: 'Añadir personaje',
|
||||
description: 'Genera y añade UN personaje nuevo (GPT-4o) a partir de nombre, tipo y una descripción breve, integrándolo con los existentes.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
nombre: z.string().min(1).describe('Nombre del personaje.'),
|
||||
tipo: z.enum(['protagonista', 'aliado', 'antagonista']).describe('Rol del personaje.'),
|
||||
descripcion: z.string().min(1).describe('Descripción breve para guiar la generación.'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, nombre, tipo, descripcion }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/personajes`, {
|
||||
action: 'add', nuevoPersonaje: { nombre, tipo, descripcion },
|
||||
})));
|
||||
|
||||
server.registerTool('story_improve_personajes', {
|
||||
title: 'Mejorar personajes',
|
||||
description: 'Mejora TODO el elenco con feedback en lenguaje natural (GPT-4o) y guarda el resultado.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
feedback: z.string().min(1).describe('Instrucciones de mejora sobre el conjunto de personajes.'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, feedback }) => {
|
||||
const s = slug as string;
|
||||
const personajes = await apiGet(`/api/projects/${seg(s)}/personajes`);
|
||||
return apiPost(`/api/projects/${seg(s)}/personajes`, { action: 'improve', feedback, personajes });
|
||||
}));
|
||||
|
||||
// ============================================================
|
||||
// CHARACTER ASSETS (imágenes de personaje)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_character_assets', {
|
||||
title: 'Ver assets de personaje',
|
||||
description: 'Devuelve los assets de imagen de un personaje (T-poses, emociones): prompts, estado y URLs. baseLocked indica si la imagen base está fijada como referencia.',
|
||||
inputSchema: { slug: slugField, personajeId: z.string().min(1).describe('id del personaje (de story_get_personajes).') },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, personajeId }) =>
|
||||
apiGet(`/api/projects/${seg(slug as string)}/personajes/${seg(personajeId as string)}/assets`)));
|
||||
|
||||
server.registerTool('story_generate_asset_prompts', {
|
||||
title: 'Generar prompts de assets',
|
||||
description: 'Paso 1 del workflow de assets: genera con GPT-4o los prompts de las 9 imágenes (3 T-poses + 6 emociones) del personaje.',
|
||||
inputSchema: { slug: slugField, personajeId: z.string().min(1).describe('id del personaje.') },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, personajeId }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/personajes/${seg(personajeId as string)}/assets`, { action: 'generate-prompts' })));
|
||||
|
||||
server.registerTool('story_generate_base_image', {
|
||||
title: 'Generar imagen base de personaje',
|
||||
description: 'Paso 2: genera la imagen base canónica (T-pose frontal) del personaje con Gemini. Acepta un prompt override opcional.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
personajeId: z.string().min(1).describe('id del personaje.'),
|
||||
prompt: z.string().optional().describe('Prompt override opcional para la imagen base.'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, personajeId, prompt }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/personajes/${seg(personajeId as string)}/assets`,
|
||||
prompt ? { action: 'generate-base-image', prompt } : { action: 'generate-base-image' })));
|
||||
|
||||
server.registerTool('story_lock_base_image', {
|
||||
title: 'Fijar imagen base',
|
||||
description: 'Paso 3: fija la imagen base como referencia canónica (baseLocked=true). Necesario antes de generar variaciones.',
|
||||
inputSchema: { slug: slugField, personajeId: z.string().min(1).describe('id del personaje.') },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, personajeId }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/personajes/${seg(personajeId as string)}/assets`, { action: 'lock-base' })));
|
||||
|
||||
server.registerTool('story_generate_all_variations', {
|
||||
title: 'Generar todas las variaciones de personaje',
|
||||
description: 'Paso 4: genera con Gemini (img2img desde la base) todas las T-poses y emociones pendientes del personaje. Requiere baseLocked. Puede tardar minutos.',
|
||||
inputSchema: { slug: slugField, personajeId: z.string().min(1).describe('id del personaje.') },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, personajeId }) =>
|
||||
apiPost(`/api/projects/${seg(slug as string)}/personajes/${seg(personajeId as string)}/assets`, { action: 'generate-all-variations' })));
|
||||
|
||||
// ============================================================
|
||||
// CAPÍTULOS
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_list_capitulos', {
|
||||
title: 'Listar capítulos',
|
||||
description: 'Lista los capítulos del proyecto (número, título, estado, paso actual).',
|
||||
inputSchema: { slug: slugField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug }) => apiGet(`/api/projects/${seg(slug as string)}/capitulos`)));
|
||||
|
||||
server.registerTool('story_create_capitulo', {
|
||||
title: 'Crear capítulo',
|
||||
description: 'Crea un capítulo. Si pasas virtudSugerida, además genera y guarda su guión conductor (GPT-4o) automáticamente.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
numero: numeroField,
|
||||
titulo: z.string().optional().describe('Título del capítulo (opcional; default "Capítulo N").'),
|
||||
virtudSugerida: z.string().optional().describe('Si se indica, autogenera el guión conductor con esta virtud.'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero, titulo, virtudSugerida }) => {
|
||||
const body: Record<string, unknown> = { numero };
|
||||
if (titulo !== undefined) body.titulo = titulo;
|
||||
if (virtudSugerida !== undefined) body.virtudSugerida = virtudSugerida;
|
||||
return apiPost(`/api/projects/${seg(slug as string)}/capitulos`, body);
|
||||
}));
|
||||
|
||||
// ============================================================
|
||||
// GUIÓN CONDUCTOR
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_guion', {
|
||||
title: 'Ver guión conductor',
|
||||
description: 'Devuelve el guión conductor del capítulo (título, virtud, nudo del mundo, aliado, actos/segmentos, markdown) o null si no existe.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero }) => apiGet(`${capBase(slug as string, numero as number)}/guion`)));
|
||||
|
||||
server.registerTool('story_generate_guion', {
|
||||
title: 'Generar guión conductor',
|
||||
description: 'Genera con GPT-4o el guión conductor del capítulo (a partir de Idea Motriz + personajes) y lo guarda. Requiere Idea Motriz y personajes.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/guion`, { action: 'generate' })));
|
||||
|
||||
// ============================================================
|
||||
// PRE-ESCALETA (esqueleto de planos, computado sin LLM)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_pre_escaleta', {
|
||||
title: 'Ver pre-escaleta',
|
||||
description: 'Devuelve el esqueleto de planos (segmentos y número de planos por segmento) del capítulo, o null.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero }) => apiGet(`${capBase(slug as string, numero as number)}/pre-escaleta`)));
|
||||
|
||||
server.registerTool('story_generate_pre_escaleta', {
|
||||
title: 'Generar pre-escaleta',
|
||||
description: 'Computa la pre-escaleta (planos por segmento, sin LLM) desde los actos del guión conductor y la guarda. Requiere un guión con actos estructurados.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) => {
|
||||
const s = slug as string; const n = numero as number;
|
||||
const guion = await apiGet(`${capBase(s, n)}/guion`);
|
||||
if (!guion || !(guion as any).actos?.length) {
|
||||
throw new ApiError(400, '', 'El guión no tiene actos estructurados. Usa story_generate_guion primero.');
|
||||
}
|
||||
return apiPost(`${capBase(s, n)}/pre-escaleta`, { action: 'generate', guion });
|
||||
}));
|
||||
|
||||
// ============================================================
|
||||
// ESCALETA (desglose de planos con personajes)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_escaleta', {
|
||||
title: 'Ver escaleta',
|
||||
description: 'Devuelve la escaleta del capítulo (planos con acción, sonido, personajes en plano y duración) o null.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero }) => apiGet(`${capBase(slug as string, numero as number)}/escaleta`)));
|
||||
|
||||
server.registerTool('story_generate_escaleta', {
|
||||
title: 'Generar escaleta',
|
||||
description: 'Genera con GPT-4o la escaleta (desglose de planos) desde el guión conductor y la pre-escaleta, y la guarda. Requiere guión y pre-escaleta creados.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) => {
|
||||
const s = slug as string; const n = numero as number;
|
||||
const guion = await apiGet(`${capBase(s, n)}/guion`);
|
||||
if (!guion || !(guion as any).actos?.length) {
|
||||
throw new ApiError(400, '', 'Falta el guión con actos. Usa story_generate_guion y story_generate_pre_escaleta antes.');
|
||||
}
|
||||
return apiPost(`${capBase(s, n)}/escaleta`, { action: 'generate', guion });
|
||||
}));
|
||||
|
||||
// ============================================================
|
||||
// PROMPTS DE IMAGEN (por plano)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_prompts', {
|
||||
title: 'Ver prompts de imagen',
|
||||
description: 'Devuelve el resumen de prompts de imagen por plano del capítulo (markdown + total) o null.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero }) => apiGet(`${capBase(slug as string, numero as number)}/prompts`)));
|
||||
|
||||
server.registerTool('story_generate_prompts', {
|
||||
title: 'Generar prompts de imagen',
|
||||
description: 'Genera con GPT-4o los prompts de imagen de todos los planos (desde la escaleta) y los guarda. Requiere escaleta creada.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/prompts`, { action: 'generate' })));
|
||||
|
||||
// ============================================================
|
||||
// FONDOS (escenarios de referencia)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_fondos', {
|
||||
title: 'Ver fondos',
|
||||
description: 'Lista los fondos de referencia del capítulo (uno por escenario/segmento) con su estado de imagen.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero }) => apiGet(`${capBase(slug as string, numero as number)}/fondos`)));
|
||||
|
||||
server.registerTool('story_refresh_fondos', {
|
||||
title: 'Recalcular fondos',
|
||||
description: 'Re-extrae la lista de fondos desde el guión/escaleta (sin generar imágenes). Útil tras cambiar la escaleta.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/fondos`, { action: 'refresh' })));
|
||||
|
||||
server.registerTool('story_generate_fondo', {
|
||||
title: 'Generar imagen de un fondo',
|
||||
description: 'Genera con Gemini la imagen de UN fondo (escenario vacío, sin personajes) por su id.',
|
||||
inputSchema: { slug: slugField, numero: numeroField, fondoId: z.string().min(1).describe('id del fondo (p.ej. "fondo-I.1").') },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero, fondoId }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/fondos`, { action: 'generate', fondoId })));
|
||||
|
||||
server.registerTool('story_generate_all_fondos', {
|
||||
title: 'Generar todos los fondos',
|
||||
description: 'Genera con Gemini las imágenes de todos los fondos del capítulo. Puede tardar varios minutos.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/fondos`, { action: 'generate-all' })));
|
||||
|
||||
// ============================================================
|
||||
// IMÁGENES DE PLANO
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_imagenes', {
|
||||
title: 'Ver imágenes de plano',
|
||||
description: 'Devuelve los planos del capítulo con su estado de imagen (generado / con prompt) y contadores.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero }) => apiGet(`${capBase(slug as string, numero as number)}/imagenes`)));
|
||||
|
||||
server.registerTool('story_generate_plano_image', {
|
||||
title: 'Generar imagen de un plano',
|
||||
description: 'Genera con Gemini la imagen de UN plano por su id (usando el prompt del plano + referencias de personaje/fondo).',
|
||||
inputSchema: { slug: slugField, numero: numeroField, planoId: z.string().min(1).describe('id del plano (p.ej. "plano-001").') },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero, planoId }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/imagenes`, { action: 'generate', planoId })));
|
||||
|
||||
server.registerTool('story_generate_all_images', {
|
||||
title: 'Generar todas las imágenes de plano',
|
||||
description: 'Genera con Gemini las imágenes de todos los planos del capítulo que tengan prompt. Puede tardar bastante (una llamada por plano).',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) =>
|
||||
apiPost(`${capBase(slug as string, numero as number)}/imagenes`, { action: 'generate-all' })));
|
||||
|
||||
// ============================================================
|
||||
// VÍDEOS (por plano)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_get_videos', {
|
||||
title: 'Ver vídeos de plano',
|
||||
description: 'Devuelve (compacto) los planos del capítulo: id, numeroPlano, si tiene imagen, y sus variaciones de vídeo (id, status queued|processing|ready|error, seleccionada) + contadores generated/pending. En capítulos grandes (100+ planos) pasa `planoId` para traer solo ese plano.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
numero: numeroField,
|
||||
planoId: z.string().optional().describe('Opcional: filtra a un único plano (recomendado en capítulos grandes para no exceder el límite de respuesta).'),
|
||||
},
|
||||
annotations: READ,
|
||||
}, wrap(async ({ slug, numero, planoId }) =>
|
||||
compactVideos(await apiGet(`${capBase(slug as string, numero as number)}/videos`), planoId as string | undefined)));
|
||||
|
||||
server.registerTool('story_generate_plano_video', {
|
||||
title: 'Generar vídeo de un plano',
|
||||
description: 'Genera una variación de vídeo para un plano (image-to-video) a partir de su imagen. Opcionalmente con un prompt de movimiento personalizado. La generación de vídeo puede ser async según el proveedor configurado.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
numero: numeroField,
|
||||
planoId: z.string().min(1).describe('id del plano.'),
|
||||
promptVideo: z.string().optional().describe('Prompt de movimiento opcional (si se omite se compone desde el plano).'),
|
||||
},
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero, planoId, promptVideo }) => {
|
||||
const body: Record<string, unknown> = { action: 'generate', planoId };
|
||||
if (promptVideo !== undefined) body.promptVideo = promptVideo;
|
||||
return apiPost(`${capBase(slug as string, numero as number)}/videos`, body);
|
||||
}));
|
||||
|
||||
server.registerTool('story_sync_video_jobs', {
|
||||
title: 'Sincronizar jobs de vídeo',
|
||||
description: 'Avanza los jobs de vídeo pendientes (queued/processing) del capítulo: consulta el estado en H3, descarga los que estén listos y los marca "ready". Llama a esta tool repetidamente (cada ~45 s) tras story_generate_plano_video hasta que "pending" sea 0. Sincroniza TODO el capítulo server-side; pasa `planoId` para que la respuesta traiga solo ese plano. Devuelve { planos, generated, pending }.',
|
||||
inputSchema: {
|
||||
slug: slugField,
|
||||
numero: numeroField,
|
||||
planoId: z.string().optional().describe('Opcional: filtra la respuesta a un único plano (el sync server-side sigue afectando a todo el capítulo).'),
|
||||
},
|
||||
annotations: { readOnlyHint: false, destructiveHint: false, idempotentHint: true, openWorldHint: true },
|
||||
}, wrap(async ({ slug, numero, planoId }) =>
|
||||
compactVideos(await apiPost(`${capBase(slug as string, numero as number)}/videos`, { action: 'sync-jobs' }), planoId as string | undefined)));
|
||||
|
||||
// ============================================================
|
||||
// RENDER FINAL (Remotion)
|
||||
// ============================================================
|
||||
|
||||
server.registerTool('story_render_chapter', {
|
||||
title: 'Renderizar capítulo (Remotion)',
|
||||
description: 'Lanza el render final del capítulo (Remotion) en background y devuelve un jobId. Consulta el progreso con story_get_render_status.',
|
||||
inputSchema: { slug: slugField, numero: numeroField },
|
||||
annotations: GEN,
|
||||
}, wrap(async ({ slug, numero }) =>
|
||||
apiPost('/api/render', { projectSlug: slug, capituloNumero: numero })));
|
||||
|
||||
server.registerTool('story_get_render_status', {
|
||||
title: 'Estado de un render',
|
||||
description: 'Consulta el progreso/estado de un job de render por su jobId (devuelto por story_render_chapter).',
|
||||
inputSchema: { jobId: z.string().min(1).describe('jobId devuelto por story_render_chapter.') },
|
||||
annotations: READ,
|
||||
}, wrap(async ({ jobId }) => apiGet(`/api/render?jobId=${seg(jobId as string)}`)));
|
||||
|
||||
// ============================================================
|
||||
// Arranque (stdio)
|
||||
// ============================================================
|
||||
|
||||
async function main(): Promise<void> {
|
||||
const transport = new StdioServerTransport();
|
||||
await server.connect(transport);
|
||||
console.error(`[story-studio-mcp] conectado (stdio). API: ${BASE_URL}`);
|
||||
}
|
||||
|
||||
main().catch((err) => {
|
||||
console.error('[story-studio-mcp] error fatal:', err);
|
||||
process.exit(1);
|
||||
});
|
||||
@@ -1,38 +0,0 @@
|
||||
// Test manual del MCP server: lanza el server por stdio, lista tools y llama una de lectura.
|
||||
import { Client } from '@modelcontextprotocol/sdk/client/index.js';
|
||||
import { StdioClientTransport } from '@modelcontextprotocol/sdk/client/stdio.js';
|
||||
|
||||
const url = process.env.STORY_STUDIO_URL || 'https://story-studio.carlosnarro.com';
|
||||
|
||||
const transport = new StdioClientTransport({
|
||||
command: 'node',
|
||||
args: ['dist/index.js'],
|
||||
env: { ...process.env, STORY_STUDIO_URL: url },
|
||||
});
|
||||
|
||||
const client = new Client({ name: 'test-client', version: '1.0.0' });
|
||||
await client.connect(transport);
|
||||
|
||||
const { tools } = await client.listTools();
|
||||
console.log(`\nTOOLS (${tools.length}):`);
|
||||
console.log(tools.map((t) => t.name).join(', '));
|
||||
|
||||
console.log('\n== call story_list_projects ==');
|
||||
const res = await client.callTool({ name: 'story_list_projects', arguments: {} });
|
||||
const text = res.content?.[0]?.text ?? '';
|
||||
console.log('isError:', res.isError === true);
|
||||
console.log(text.slice(0, 600));
|
||||
|
||||
// Prueba una segunda tool de lectura con un slug real si hay proyectos.
|
||||
try {
|
||||
const projs = JSON.parse(text);
|
||||
const slug = Array.isArray(projs) && projs[0]?.slug;
|
||||
if (slug) {
|
||||
console.log(`\n== call story_get_idea_motriz (slug=${slug}) ==`);
|
||||
const r2 = await client.callTool({ name: 'story_get_idea_motriz', arguments: { slug } });
|
||||
console.log('isError:', r2.isError === true, '| len:', (r2.content?.[0]?.text ?? '').length);
|
||||
}
|
||||
} catch { /* ignore */ }
|
||||
|
||||
await client.close();
|
||||
console.log('\nOK');
|
||||
@@ -1,18 +0,0 @@
|
||||
{
|
||||
"compilerOptions": {
|
||||
"target": "ES2022",
|
||||
"module": "Node16",
|
||||
"moduleResolution": "Node16",
|
||||
"lib": ["ES2022"],
|
||||
"outDir": "./dist",
|
||||
"rootDir": "./src",
|
||||
"strict": true,
|
||||
"esModuleInterop": true,
|
||||
"skipLibCheck": true,
|
||||
"forceConsistentCasingInFileNames": true,
|
||||
"declaration": true,
|
||||
"sourceMap": true
|
||||
},
|
||||
"include": ["src/**/*"],
|
||||
"exclude": ["node_modules", "dist"]
|
||||
}
|
||||
@@ -108,10 +108,9 @@ export async function POST(
|
||||
return NextResponse.json({ error: 'No se pudo leer la imagen del plano' }, { status: 500 });
|
||||
}
|
||||
|
||||
// Resolución por plano al máximo legal de H3 (w*h <= 1.032.192 px, múltiplos de 32):
|
||||
// 16:9 (default) = 1344x768 · 9:16 = 768x1344. video-service normaliza igualmente al contrato.
|
||||
// Resolución por plano: 16:9 (default) o 9:16 según body.aspect.
|
||||
const aspect = body.aspect === '9:16' ? '9:16' : '16:9';
|
||||
const [width, height] = aspect === '9:16' ? [768, 1344] : [1344, 768];
|
||||
const [width, height] = aspect === '9:16' ? [480, 832] : [832, 480];
|
||||
|
||||
console.log(`[Videos API] Encolando vídeo H3 para plano ${planoId} (${aspect})`);
|
||||
|
||||
|
||||
@@ -16,8 +16,7 @@
|
||||
* submitVideoJob() lanza error solo si se invoca (no rompe el arranque).
|
||||
*/
|
||||
|
||||
// essia-server entrega la env como H3API_URL; aceptamos también H3API_BASE_URL por compatibilidad.
|
||||
const H3_BASE_URL = (process.env.H3API_URL || process.env.H3API_BASE_URL || 'https://h3api.essia.coop').replace(/\/$/, '');
|
||||
const H3_BASE_URL = (process.env.H3API_BASE_URL || 'https://h3api.essia.coop').replace(/\/$/, '');
|
||||
const H3_API_KEY = process.env.H3API_KEY || '';
|
||||
|
||||
// Modo i2v del MVP: ref2va (imagen->vídeo, validado). fl2va (primer frame exacto, más fiel a
|
||||
@@ -47,33 +46,11 @@ interface H3JobResponse {
|
||||
export interface SubmitVideoOptions {
|
||||
duration?: number; // segundos, 4-15 (default 5)
|
||||
cameraFixed?: boolean; // añade indicación de movimiento mínimo al prompt
|
||||
width?: number; // se ajusta a la rejilla de 32 px de H3 (default 832)
|
||||
height?: number; // ídem (default 480); tope H3: width*height <= 1.032.192 px
|
||||
width?: number; // múltiplo de 32 (default 832 = 16:9)
|
||||
height?: number; // múltiplo de 32 (default 480 = 16:9)
|
||||
mode?: string; // 'ref2va' (default) | 'fl2va' | 't2va'
|
||||
}
|
||||
|
||||
// Contrato de resolución del nodo H3 (verificado 2026-08-17 contra H3ContractError del RH node):
|
||||
// width/height deben ser múltiplos de 32 y width*height <= 1_032_192 px (= 1344x768, su máximo
|
||||
// ~16:9). Fuera de eso el render falla a los pocos segundos ya en el server, así que ajustamos
|
||||
// aquí para que ningún caller pueda encolar un job imposible (p.ej. 1280x720 o 1920x1088).
|
||||
const H3_MAX_PIXELS = 1_032_192;
|
||||
|
||||
function normalizeResolution(width: number, height: number): { width: number; height: number } {
|
||||
const snap = (v: number) => Math.max(32, Math.round(v / 32) * 32);
|
||||
let w = snap(width);
|
||||
let h = snap(height);
|
||||
if (w * h > H3_MAX_PIXELS) {
|
||||
const scale = Math.sqrt(H3_MAX_PIXELS / (w * h));
|
||||
w = snap(w * scale);
|
||||
h = snap(h * scale);
|
||||
while (w * h > H3_MAX_PIXELS) {
|
||||
if (w >= h) w -= 32;
|
||||
else h -= 32;
|
||||
}
|
||||
}
|
||||
return { width: w, height: h };
|
||||
}
|
||||
|
||||
export const H3_COST_USD = COST_PER_VIDEO_USD;
|
||||
|
||||
function ensureConfigured(): void {
|
||||
@@ -111,12 +88,8 @@ export async function submitVideoJob(
|
||||
ensureConfigured();
|
||||
|
||||
const dur = Math.min(15, Math.max(4, options.duration || 5));
|
||||
const requestedW = options.width ?? 832;
|
||||
const requestedH = options.height ?? 480;
|
||||
const { width, height } = normalizeResolution(requestedW, requestedH);
|
||||
if (width !== requestedW || height !== requestedH) {
|
||||
console.log(`[Video Service/H3] Resolución ajustada al contrato H3: ${requestedW}x${requestedH} -> ${width}x${height}`);
|
||||
}
|
||||
const width = options.width ?? 832;
|
||||
const height = options.height ?? 480;
|
||||
const mode = options.mode || DEFAULT_I2V_MODE;
|
||||
const fullPrompt = options.cameraFixed
|
||||
? `${prompt} Minimal camera movement, subtle motion only.`
|
||||
|
||||
Reference in New Issue
Block a user