MCPX MCP Gateway

import { CatalogMCPServerList } from "@mcpx/shared-model"; import { Logger } from "winston"; import { backendDefaultServers } from "../server/constants-servers.js"; import z from "zod/v4"; import { McpxBoundPayloads } from "@mcpx/webapp-protocol/messages"; type SetCatalogPayload = z.infer<typeof McpxBoundPayloads.setCatalog>; export interface CatalogManagerI { setCatalog(payload: SetCatalogPayload): void; getCatalog(): CatalogMCPServerList; } export class CatalogManager implements CatalogManagerI { private catalog: CatalogMCPServerList; private logger: Logger; constructor(logger: Logger) { this.logger = logger.child({ component: "CatalogManager" }); // initialize the catalog from the default servers this.catalog = backendDefaultServers; } getCatalog(): CatalogMCPServerList { return structuredClone(this.catalog); } setCatalog(payload: SetCatalogPayload): void { // parse and error handel done in the hub this.logger.info("Loading servers catalog from Hub", { serverCount: payload.servers.length, serverNames: payload.servers.map((s) => s.name), }); this.catalog = payload.servers; } }