feat(examples): Add video-resource-server example
Demonstrates serving binary content (video) via MCP resources using the
base64 blob pattern:
1. Server fetches video from CDN
2. Returns as base64 blob via `videos://{id}` resource template
3. Widget fetches resource and plays in `<video>` element
Includes multiple video sizes for testing (1MB to 150MB).
🤖 Generated with [Claude Code](https://claude.com/claude-code)
Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
parent
d925af5257
commit
ba45157d55
1 changed files with 554 additions and 0 deletions
187
examples/video-resource-server/server.ts
Normal file
187
examples/video-resource-server/server.ts
Normal file
|
|
@ -0,0 +1,187 @@
|
|||
/**
|
||||
* Video Resource Server
|
||||
*
|
||||
* Demonstrates serving binary content (video) via MCP resources.
|
||||
* The server fetches videos from CDN and serves them as base64 blobs.
|
||||
*/
|
||||
import {
|
||||
McpServer,
|
||||
ResourceTemplate,
|
||||
} from "@modelcontextprotocol/sdk/server/mcp.js";
|
||||
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
||||
import type {
|
||||
CallToolResult,
|
||||
ReadResourceResult,
|
||||
} from "@modelcontextprotocol/sdk/types.js";
|
||||
import { z } from "zod";
|
||||
import fs from "node:fs/promises";
|
||||
import path from "node:path";
|
||||
import {
|
||||
registerAppTool,
|
||||
registerAppResource,
|
||||
RESOURCE_MIME_TYPE,
|
||||
RESOURCE_URI_META_KEY,
|
||||
} from "@modelcontextprotocol/ext-apps/server";
|
||||
import { startServer } from "../shared/server-utils.js";
|
||||
|
||||
const DIST_DIR = path.join(import.meta.dirname, "dist");
|
||||
const RESOURCE_URI = "ui://video-player/mcp-app.html";
|
||||
|
||||
/**
|
||||
* Video library with different sizes for testing.
|
||||
*/
|
||||
const VIDEO_LIBRARY: Record<string, { url: string; description: string }> = {
|
||||
"bunny-1mb": {
|
||||
url: "https://test-videos.co.uk/vids/bigbuckbunny/mp4/h264/360/Big_Buck_Bunny_360_10s_1MB.mp4",
|
||||
description: "1MB",
|
||||
},
|
||||
"bunny-5mb": {
|
||||
url: "https://test-videos.co.uk/vids/bigbuckbunny/mp4/h264/360/Big_Buck_Bunny_360_10s_5MB.mp4",
|
||||
description: "5MB",
|
||||
},
|
||||
"bunny-10mb": {
|
||||
url: "https://test-videos.co.uk/vids/bigbuckbunny/mp4/h264/720/Big_Buck_Bunny_720_10s_10MB.mp4",
|
||||
description: "10MB",
|
||||
},
|
||||
"bunny-20mb": {
|
||||
url: "https://test-videos.co.uk/vids/bigbuckbunny/mp4/h264/720/Big_Buck_Bunny_720_10s_20MB.mp4",
|
||||
description: "20MB",
|
||||
},
|
||||
"bunny-30mb": {
|
||||
url: "https://test-videos.co.uk/vids/bigbuckbunny/mp4/h264/1080/Big_Buck_Bunny_1080_10s_30MB.mp4",
|
||||
description: "30MB",
|
||||
},
|
||||
"bunny-50mb": {
|
||||
url: "https://sample-videos.com/video321/mp4/720/big_buck_bunny_720p_50mb.mp4",
|
||||
description: "50MB",
|
||||
},
|
||||
"bunny-150mb": {
|
||||
url: "https://cdn.jsdelivr.net/npm/big-buck-bunny-1080p@0.0.6/video.mp4",
|
||||
description: "~150MB (full 1080p)",
|
||||
},
|
||||
};
|
||||
|
||||
function createServer(): McpServer {
|
||||
const server = new McpServer({
|
||||
name: "Video Resource Server",
|
||||
version: "1.0.0",
|
||||
});
|
||||
|
||||
// Register video resource template
|
||||
// This fetches video from CDN and returns as base64 blob
|
||||
server.resource(
|
||||
"video",
|
||||
new ResourceTemplate("videos://{id}", { list: undefined }),
|
||||
{
|
||||
description: "Video served via MCP resource (base64 blob)",
|
||||
mimeType: "video/mp4",
|
||||
},
|
||||
async (uri, { id }): Promise<ReadResourceResult> => {
|
||||
const idStr = Array.isArray(id) ? id[0] : id;
|
||||
const video = VIDEO_LIBRARY[idStr];
|
||||
|
||||
if (!video) {
|
||||
throw new Error(
|
||||
`Video not found: ${idStr}. Available: ${Object.keys(VIDEO_LIBRARY).join(", ")}`,
|
||||
);
|
||||
}
|
||||
|
||||
console.error(`[video-resource] Fetching: ${video.url}`);
|
||||
|
||||
const response = await fetch(video.url);
|
||||
if (!response.ok) {
|
||||
throw new Error(
|
||||
`Failed to fetch video: ${response.status} ${response.statusText}`,
|
||||
);
|
||||
}
|
||||
|
||||
const buffer = await response.arrayBuffer();
|
||||
const base64 = Buffer.from(buffer).toString("base64");
|
||||
|
||||
console.error(
|
||||
`[video-resource] Size: ${buffer.byteLength} bytes -> ${base64.length} base64 chars`,
|
||||
);
|
||||
|
||||
return {
|
||||
contents: [
|
||||
{
|
||||
uri: uri.href,
|
||||
mimeType: "video/mp4",
|
||||
blob: base64,
|
||||
},
|
||||
],
|
||||
};
|
||||
},
|
||||
);
|
||||
|
||||
// Register the video player tool
|
||||
registerAppTool(
|
||||
server,
|
||||
"play_video",
|
||||
{
|
||||
title: "Play Video via Resource",
|
||||
description: `Play a video loaded via MCP resource.
|
||||
Available videos:
|
||||
${Object.entries(VIDEO_LIBRARY)
|
||||
.map(([id, v]) => `- ${id}: ${v.description}`)
|
||||
.join("\n")}`,
|
||||
inputSchema: {
|
||||
videoId: z
|
||||
.enum(Object.keys(VIDEO_LIBRARY) as [string, ...string[]])
|
||||
.describe(
|
||||
`Video ID to play. Available: ${Object.keys(VIDEO_LIBRARY).join(", ")}`,
|
||||
),
|
||||
},
|
||||
_meta: { [RESOURCE_URI_META_KEY]: RESOURCE_URI },
|
||||
},
|
||||
async ({ videoId }): Promise<CallToolResult> => {
|
||||
const video = VIDEO_LIBRARY[videoId];
|
||||
return {
|
||||
content: [
|
||||
{
|
||||
type: "text",
|
||||
text: JSON.stringify({
|
||||
videoUri: `videos://${videoId}`,
|
||||
description: video.description,
|
||||
}),
|
||||
},
|
||||
],
|
||||
};
|
||||
},
|
||||
);
|
||||
|
||||
// Register the MCP App resource (the UI)
|
||||
registerAppResource(
|
||||
server,
|
||||
RESOURCE_URI,
|
||||
RESOURCE_URI,
|
||||
{ mimeType: RESOURCE_MIME_TYPE },
|
||||
async (): Promise<ReadResourceResult> => {
|
||||
const html = await fs.readFile(
|
||||
path.join(DIST_DIR, "mcp-app.html"),
|
||||
"utf-8",
|
||||
);
|
||||
return {
|
||||
contents: [
|
||||
{ uri: RESOURCE_URI, mimeType: RESOURCE_MIME_TYPE, text: html },
|
||||
],
|
||||
};
|
||||
},
|
||||
);
|
||||
|
||||
return server;
|
||||
}
|
||||
|
||||
async function main() {
|
||||
if (process.argv.includes("--stdio")) {
|
||||
await createServer().connect(new StdioServerTransport());
|
||||
} else {
|
||||
const port = parseInt(process.env.PORT ?? "3105", 10);
|
||||
await startServer(createServer, { port, name: "Video Resource Server" });
|
||||
}
|
||||
}
|
||||
|
||||
main().catch((e) => {
|
||||
console.error(e);
|
||||
process.exit(1);
|
||||
});
|
||||
Loading…
Reference in a new issue