refactor: remove mcp-hub marketplace

Author: ycjcl868

packages/agent-infra/mcp-hub/README.md

@@ -417,13 +417,12 @@ The [ravitemer/mcphub.nvim](https://github.com/ravitemer/mcphub.nvim) plugin pro
 - Execute MCP tools directly from Neovim
 - Access MCP resources within your editing workflow
 - Real-time status updates in Neovim
-- Auto install mcp servers with marketplace addition
 
 ## REST API
 
 ### MCP Hub Search API
 
-The MCP Hub provides a powerful search API to find and filter MCP servers, both connected (currently running) and available (from the marketplace).
+The MCP Hub provides a powerful search API to find and filter MCP servers that are currently running and connected to the hub.
 
 #### Endpoint
 
@@ -451,20 +450,10 @@ Response Format
       "category": "development",
       "tags": ["filesystem", "file-management"],
       "status": "connected",
-      "source": "connected",
       "capabilities": {
         "tools": [...],
         "resources": [...]
       }
-    },
-    {
-      "name": "GitHub",
-      "description": "GitHub API integration",
-      "category": "development",
-      "tags": ["github", "api"],
-      "status": "available",
-      "source": "marketplace",
-      "stars": 1000
     }
   ],
   "query": {
@@ -481,12 +470,10 @@ Response Format
 #### Server Status
 
 - **connected**: Server is currently running and connected to the hub
-- **available**: Server is available in the marketplace but not currently connected
 
 #### Server Source
 
 - **connected**: Server is from your local configuration and currently running
-- **marketplace**: Server is from the MCP marketplace registry
 
 #### Examples
 
@@ -518,9 +505,8 @@ curl "http://localhost:3000/mcp?search=code&category=development&tags=editor&sor
 #### Notes
 
 1. The search is case-insensitive
-2. Connected servers take precedence over marketplace servers in deduplication
-3. If marketplace is unavailable, only connected servers will be returned
-4. The endpoint distinguishes between search requests (with query params) and MCP protocol requests (without query params)
+2. Connected servers take precedence over duplicate entries
+3. The endpoint distinguishes between search requests (with query params) and MCP protocol requests (without query params)
 
 ### Health and Status
 
@@ -739,80 +725,6 @@ Response:
 }
 ```
 
-### Marketplace Integration
-
-#### List Available Servers
-
-```bash
-GET /api/marketplace
-```
-
-Query Parameters:
-
-- `search`: Filter by name, description, or tags
-- `category`: Filter by category
-- `tags`: Filter by comma-separated tags
-- `sort`: Sort by "newest", "stars", or "name"
-
-Response:
-
-```json
-{
-  "servers": [
-    {
-      "id": "example-server",
-      "name": "Example Server",
-      "description": "Description here",
-      "author": "example-author",
-      "url": "https://github.com/user/repo",
-      "category": "search",
-      "tags": ["search", "ai"],
-      "stars": 100,
-      "featured": true,
-      "verified": true,
-      "lastCommit": 1751257963,
-      "updatedAt": 1751265038
-    }
-  ],
-  "timestamp": "2024-02-20T05:55:00.000Z"
-}
-```
-
-#### Get Server Details
-
-```bash
-POST /api/marketplace/details
-Content-Type: application/json
-
-{
-  "mcpId": "example-server"
-}
-```
-
-Response:
-
-```json
-{
-  "server": {
-    "id": "example-server",
-    "name": "Example Server",
-    "description": "Description here",
-    "author": "example-author",
-    "url": "https://github.com/user/repo",
-    "category": "search",
-    "tags": ["search", "ai"],
-    "installations": [],
-    "stars": 100,
-    "featured": true,
-    "verified": true,
-    "lastCommit": 1751257963,
-    "updatedAt": 1751265038
-  },
-  "readmeContent": "# Server Documentation...",
-  "timestamp": "2024-02-20T05:55:00.000Z"
-}
-```
-
 ### MCP Server Operations
 
 #### Execute Tool
@@ -1348,27 +1260,13 @@ All client requests follow a standardized flow:
 
 - Node.js >= 18.0.0
 
-## MCP Registry
-
-MCP Hub now uses the [MCP Registry](https://github.com/ravitemer/mcp-registry) system for marketplace functionality. This provides:
-
-- **Decentralized Server Discovery**: Registry hosted on GitHub Pages for better reliability
-- **Direct GitHub Integration**: README documentation fetched directly from repositories
-- **Enhanced Metadata**: Comprehensive server information including stars, categories, and installation instructions
-- **Better Caching**: Improved cache system with 1-hour TTL for frequent updates
-- **Fallback Support**: Automatic fallback to curl when fetch fails (useful for proxy/VPN environments)
-
-The registry is updated regularly with new servers and improvements to existing entries.
-
 ## Todo
 
-- [x] Implement custom marketplace rather than depending on mcp-marketplace
 - [ ] TUI like mcphub.nvim
 - [ ] Web UI for managing servers
 
 ### 🙏 Credits
 
 Thanks to:
 
-- [ravitemer/mcp-registry](https://github.com/ravitemer/mcp-registry) - For providing the MCP server marketplace endpoints that power MCP Hub's marketplace integration
 - [ravitemer/mcp-hub](https://github.com/ravitemer/mcp-hub) - A centralized manager for Model Context Protocol (MCP) servers with dynamic server management and monitoring

packages/agent-infra/mcp-hub/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@agent-infra/mcp-hub",
-  "version": "1.0.6",
+  "version": "1.1.0",
   "description": "A manager server for MCP servers that handles process management and tool routing",
   "author": "Ravitemer",
   "license": "MIT",

packages/agent-infra/mcp-hub/src/MCPConnection.ts

@@ -96,25 +96,6 @@ export interface DevConfig {
 // Transport types
 export type TransportType = 'stdio' | 'sse' | 'http';
 
-// Interface for marketplace item
-export interface MarketplaceItem {
-  mcpId: string;
-  name?: string;
-  description?: string;
-}
-
-// Interface for marketplace cache
-export interface MarketplaceCache {
-  catalog?: {
-    items?: MarketplaceItem[];
-  };
-}
-
-// Interface for marketplace
-export interface Marketplace {
-  cache?: MarketplaceCache;
-}
-
 // Interface for server info
 export interface ServerInfo {
   name: string;
@@ -226,12 +207,7 @@ export class MCPConnection extends EventEmitter {
   // Dev watcher for file changes (stdio servers only)
   private devWatcher: DevWatcher | null;
 
-  constructor(
-    name: string,
-    config: ServerConfig,
-    marketplace?: Marketplace,
-    hubServerUrl?: string,
-  ) {
+  constructor(name: string, config: ServerConfig, hubServerUrl?: string) {
     super();
     this.name = name; // Keep as mcpId
 
@@ -243,26 +219,10 @@ export class MCPConnection extends EventEmitter {
     // Dev watcher for file changes (stdio servers only)
     this.devWatcher = null;
 
-    // Set display name from marketplace
-    this.displayName = name; // Default to mcpId
-    let serverDescription = '';
-    if (marketplace?.cache?.catalog?.items) {
-      const item = marketplace.cache.catalog.items.find(
-        (item) => item.mcpId === name,
-      );
-      if (item?.name) {
-        this.displayName = item.name;
-        serverDescription = item.description || '';
-        logger.debug(`Using marketplace name for server '${name}'`, {
-          name,
-          displayName: item.name,
-        });
-      }
-    }
+    // Default display name and description from config
+    this.displayName = config.name || name;
     this.config = config;
-    this.description = config.description
-      ? config.description
-      : serverDescription;
+    this.description = config.description || '';
     this.client = null;
     this.transport = null;
     this.transportType = config.type; // Store the transport type from config
@@ -902,7 +862,7 @@ export class MCPConnection extends EventEmitter {
   getServerInfo(): ServerInfo {
     return {
       name: this.name, // Original mcpId
-      displayName: this.displayName, // Friendly name from marketplace
+      displayName: this.displayName,
       description: this.description,
       transportType: this.transportType, // Include transport type in server info
       status: this.status,

packages/agent-infra/mcp-hub/src/MCPHub.ts

@@ -20,7 +20,6 @@ import EventEmitter from 'events';
 interface MCPHubOptions {
   port?: number;
   watch?: boolean;
-  marketplace?: any;
 }
 
 interface ServerStartResult {
@@ -50,11 +49,10 @@ export class MCPHub extends EventEmitter {
   public hubServerUrl: string;
   public configManager: ConfigManager;
   public shouldWatchConfig: boolean;
-  public marketplace?: any;
 
   constructor(
     configPathOrObject: string | string[] | object,
-    { port, watch = false, marketplace }: MCPHubOptions = {},
+    { port, watch = false }: MCPHubOptions = {},
   ) {
     super();
     this.connections = new Map();
@@ -65,7 +63,6 @@ export class MCPHub extends EventEmitter {
       watch &&
       (typeof configPathOrObject === 'string' ||
         Array.isArray(configPathOrObject));
-    this.marketplace = marketplace;
   }
 
   async initialize(isRestarting?: boolean): Promise<void> {
@@ -123,7 +120,6 @@ export class MCPHub extends EventEmitter {
           const connection = new MCPConnection(
             name,
             serverConfig,
-            this.marketplace,
             this.hubServerUrl,
           );
           [
@@ -302,12 +298,7 @@ export class MCPHub extends EventEmitter {
   async connectServer(name: string, config: any): Promise<any> {
     let connection = this.getConnection(name);
     if (!connection) {
-      connection = new MCPConnection(
-        name,
-        config,
-        this.marketplace,
-        this.hubServerUrl,
-      );
+      connection = new MCPConnection(name, config, this.hubServerUrl);
       this.connections.set(name, connection);
     }
     await connection.connect(config);
@@ -569,33 +560,6 @@ export class MCPHub extends EventEmitter {
       });
     }
 
-    // Get marketplace servers if marketplace is available
-    if (this.marketplace) {
-      try {
-        const marketplaceServers = await this.marketplace.getCatalog(options);
-
-        // Filter out servers that are already connected (unless filtering by category/tags)
-        const connectedNames = new Set(
-          connectedServers.map((s) => s.name.toLowerCase()),
-        );
-        const uniqueMarketplace = marketplaceServers.filter(
-          (server: any) => !connectedNames.has(server.name.toLowerCase()),
-        );
-
-        // Add marketplace servers with 'available' status
-        uniqueMarketplace.forEach((server: any) => {
-          results.push({
-            ...server,
-            source: 'marketplace',
-            status: 'available',
-          });
-        });
-      } catch (error: any) {
-        logger.debug(`Failed to search marketplace: ${error.message}`);
-        // Continue with just connected servers if marketplace fails
-      }
-    }
-
     // Apply sorting if requested
     if (options.sort) {
       switch (options.sort) {