@deepracticex/mcp-client - npm Package Compare versions

+23

dist/transport/WebSocketTransport.d.ts

		/**
		* 简化的 WebSocket Transport Implementation
		*
		* 通过 WebSocket 与 MCP 服务器进行双向通信
		*/
		import { EventEmitter } from 'events';
		import type { WebSocketTransportConfig, JsonRpcRequest, JsonRpcResponse } from '../types/index.js';
		export declare class WebSocketTransport extends EventEmitter {
		private config;
		private ws;
		private connected;
		private pendingRequests;
		constructor(config: WebSocketTransportConfig);
		connect(): Promise<void>;
		sendRequest(request: JsonRpcRequest): Promise<JsonRpcResponse>;
		close(): Promise<void>;
		isConnected(): boolean;
		private createWebSocketConnection;
		private setupWebSocketHandlers;
		private handleMessage;
		private cleanup;
		}
		//# sourceMappingURL=WebSocketTransport.d.ts.map

+1

dist/transport/WebSocketTransport.d.ts.map

{"version":3,"file":"WebSocketTransport.d.ts","sourceRoot":"","sources":["../../src/transport/WebSocketTransport.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAGH,OAAO,EAAE,YAAY,EAAE,MAAM,QAAQ,CAAC;AACtC,OAAO,KAAK,EAAE,wBAAwB,EAAE,cAAc,EAAE,eAAe,EAAE,MAAM,mBAAmB,CAAC;AAEnG,qBAAa,kBAAmB,SAAQ,YAAY;IAStC,OAAO,CAAC,MAAM;IAR1B,OAAO,CAAC,EAAE,CAA0B;IACpC,OAAO,CAAC,SAAS,CAAS;IAC1B,OAAO,CAAC,eAAe,CAIlB;gBAEe,MAAM,EAAE,wBAAwB;IAI9C,OAAO,IAAI,OAAO,CAAC,IAAI,CAAC;IAaxB,WAAW,CAAC,OAAO,EAAE,cAAc,GAAG,OAAO,CAAC,eAAe,CAAC;IA0B9D,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IA4C5B,WAAW,IAAI,OAAO;YAIR,yBAAyB;IAsBvC,OAAO,CAAC,sBAAsB;IAiC9B,OAAO,CAAC,aAAa;IA2BrB,OAAO,CAAC,OAAO;CAchB"}

+179

dist/transport/WebSocketTransport.js

		/**
		* 简化的 WebSocket Transport Implementation
		*
		* 通过 WebSocket 与 MCP 服务器进行双向通信
		*/
		import WebSocket from 'ws';
		import { EventEmitter } from 'events';
		export class WebSocketTransport extends EventEmitter {
		constructor(config) {
		super();
		this.config = config;
		this.ws = null;
		this.connected = false;
		this.pendingRequests = new Map();
		}
		async connect() {
		if (this.isConnected()) {
		return;
		}
		try {
		await this.createWebSocketConnection();
		this.connected = true;
		}
		catch (error) {
		throw new Error(`Failed to connect to WebSocket server: ${error}`);
		}
		}
		async sendRequest(request) {
		if (!this.isConnected()) {
		throw new Error('Not connected');
		}
		return new Promise((resolve, reject) => {
		// 设置请求超时
		const timeout = setTimeout(() => {
		this.pendingRequests.delete(request.id);
		reject(new Error(`Request timeout: ${request.method}`));
		}, 30000);
		this.pendingRequests.set(request.id, { resolve, reject, timeout });
		// 发送请求
		const message = JSON.stringify(request);
		this.ws.send(message, (error) => {
		if (error) {
		this.pendingRequests.delete(request.id);
		clearTimeout(timeout);
		reject(new Error(`Failed to send request: ${error.message}`));
		}
		});
		});
		}
		async close() {
		if (!this.ws) {
		return;
		}
		try {
		// 清理所有待处理的请求
		Array.from(this.pendingRequests.entries()).forEach(([id, { reject, timeout }]) => {
		clearTimeout(timeout);
		reject(new Error('Connection closed'));
		});
		this.pendingRequests.clear();
		// 关闭 WebSocket
		await new Promise((resolve) => {
		if (!this.ws) {
		resolve();
		return;
		}
		const timeout = setTimeout(() => {
		this.cleanup();
		resolve();
		}, 5000);
		this.ws.once('close', () => {
		clearTimeout(timeout);
		resolve();
		});
		if (this.ws.readyState === WebSocket.OPEN) {
		this.ws.close(1000, 'Client closing connection');
		}
		else {
		resolve();
		}
		});
		this.cleanup();
		this.emit('close');
		}
		catch (error) {
		// 忽略关闭错误
		}
		}
		isConnected() {
		return this.connected && this.ws !== null && this.ws.readyState === WebSocket.OPEN;
		}
		async createWebSocketConnection() {
		return new Promise((resolve, reject) => {
		try {
		this.ws = new WebSocket(this.config.url, {
		headers: this.config.headers
		});
		this.ws.once('open', () => {
		this.setupWebSocketHandlers();
		resolve();
		});
		this.ws.once('error', (error) => {
		reject(error);
		});
		}
		catch (error) {
		reject(error);
		}
		});
		}
		setupWebSocketHandlers() {
		if (!this.ws)
		return;
		// 消息处理
		this.ws.on('message', (data) => {
		try {
		const message = data.toString('utf-8');
		this.handleMessage(message);
		}
		catch (error) {
		console.error('Failed to process WebSocket message:', error);
		}
		});
		// 错误处理
		this.ws.on('error', (error) => {
		console.error('WebSocket error:', error);
		this.cleanup();
		this.emit('error', error);
		});
		// 关闭处理
		this.ws.on('close', (code, reason) => {
		console.log(`WebSocket closed with code ${code}, reason ${reason}`);
		this.cleanup();
		this.emit('close');
		});
		// Ping/Pong 处理（保持连接活跃）
		this.ws.on('ping', (data) => {
		this.ws?.pong(data);
		});
		}
		handleMessage(message) {
		try {
		const parsed = JSON.parse(message);
		if (parsed.id !== undefined) {
		// 这是一个响应
		const pending = this.pendingRequests.get(parsed.id);
		if (pending) {
		clearTimeout(pending.timeout);
		this.pendingRequests.delete(parsed.id);
		if (parsed.error) {
		pending.reject(new Error(parsed.error.message));
		}
		else {
		pending.resolve(parsed);
		}
		}
		}
		else {
		// 这是一个通知，暂时忽略
		console.log('Received notification:', parsed);
		}
		}
		catch (error) {
		console.error('Failed to parse message:', error, 'Message:', message);
		}
		}
		cleanup() {
		if (this.ws) {
		this.ws.removeAllListeners();
		// 强制关闭连接
		if (this.ws.readyState === WebSocket.OPEN \|\| this.ws.readyState === WebSocket.CONNECTING) {
		this.ws.terminate();
		}
		this.ws = null;
		}
		this.connected = false;
		}
		}
		//# sourceMappingURL=WebSocketTransport.js.map

+1

dist/transport/WebSocketTransport.js.map

+1

-1

package.json

		{
		"name": "@deepracticex/mcp-client",
		"version": "1.0.2",
		"version": "1.0.3",
		"description": "MCP (Model Context Protocol) client for DeeChat - Simplified domain-rich model implementation for managing MCP server connections, tools, resources, and prompts",
		@@ -5,0 +5,0 @@ "main": "dist/index.js",

@deepracticex/mcp-client - npm Package Compare versions

Improved metrics