#!/usr/bin/env node
import "dotenv/config";
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
import {
CallToolRequestSchema,
ErrorCode,
ListToolsRequestSchema,
McpError,
} from "@modelcontextprotocol/sdk/types.js";
// Plex shared module
import {
PlexClient,
PlexTools,
createPlexToolRegistry,
PLEX_CORE_TOOL_SCHEMAS,
DEFAULT_PLEX_URL,
} from "./plex/index.js";
// Trakt integration
import { TraktMCPFunctions } from "./trakt/mcp-functions.js";
import { TRAKT_TOOL_SCHEMAS } from "./trakt/tool-schemas.js";
import { createTraktToolRegistry } from "./trakt/tool-registry.js";
class PlexTraktMCPServer {
private server: Server;
constructor() {
this.server = new Server(
{ name: "plex-trakt-server", version: "1.0.0" },
{ capabilities: { tools: {} } }
);
const plexToken = process.env.PLEX_TOKEN;
if (!plexToken) {
throw new Error("PLEX_TOKEN environment variable is required");
}
const plexClient = new PlexClient({
baseUrl: process.env.PLEX_URL || DEFAULT_PLEX_URL,
token: plexToken,
});
const plexTools = new PlexTools(plexClient);
const plexRegistry = createPlexToolRegistry(plexTools);
const traktFunctions = new TraktMCPFunctions(plexClient);
const traktRegistry = createTraktToolRegistry(traktFunctions);
this.server.setRequestHandler(ListToolsRequestSchema, async () => ({
tools: [...PLEX_CORE_TOOL_SCHEMAS, ...TRAKT_TOOL_SCHEMAS],
}));
this.server.setRequestHandler(CallToolRequestSchema, async (request) => {
const { name, arguments: args } = request.params;
const a = (args ?? {}) as Record<string, unknown>;
try {
if (plexRegistry.has(name)) {
return await plexRegistry.handle(name, a);
}
return await traktRegistry.handle(name, a);
} catch (error) {
if (error instanceof McpError) throw error;
const msg = error instanceof Error ? error.message : String(error);
throw new McpError(ErrorCode.InternalError, `Error executing ${name}: ${msg}`);
}
});
}
async run() {
const transport = new StdioServerTransport();
await this.server.connect(transport);
console.error("Plex-Trakt MCP server running on stdio");
}
}
async function main() {
const server = new PlexTraktMCPServer();
await server.run();
}
main().catch((error) => {
console.error("Server error:", error);
process.exit(1);
});
