@himorishige/hatago-transport

Transport layer implementations for Hatago MCP Hub.

Features

STDIO Transport: Standard input/output communication
HTTP/SSE Transport: HTTP with Server-Sent Events
WebSocket Transport: Real-time bidirectional communication
Connection Management: Robust connection handling with retry logic

Installation

npm install @himorishige/hatago-transport

Usage

STDIO Transport

import { createStdioTransport } from '@himorishige/hatago-transport';

const transport = await createStdioTransport({
  command: 'node',
  args: ['./mcp-server.js'],
  env: process.env
});

await transport.connect();

HTTP/SSE Transport

import { createHttpTransport } from '@himorishige/hatago-transport';

const transport = createHttpTransport({
  url: 'http://localhost:3000',
  sessionId: 'my-session'
});

await transport.connect();

WebSocket Transport

import { createWebSocketTransport } from '@himorishige/hatago-transport';

const transport = createWebSocketTransport({
  url: 'ws://localhost:3000',
  reconnect: true,
  reconnectInterval: 5000
});

await transport.connect();

API

Transport Interface

All transports implement the common Transport interface:

interface Transport {
  connect(): Promise<void>;
  disconnect(): Promise<void>;
  send(message: any): Promise<void>;
  onMessage(handler: (message: any) => void): void;
  onError(handler: (error: Error) => void): void;
  onClose(handler: () => void): void;
}

License

MIT