Zetrix MCP Server

Instructions

Implementation Reference

• src/index.ts:390-403 (registration)

  MCP tool registration defining the name, description, and input schema for zetrix_ws_subscribe_tx
  { name: "zetrix_ws_subscribe_tx", description: "Subscribe to transaction notifications for specific addresses", inputSchema: { type: "object", properties: { addresses: { type: "array", description: "Array of account addresses to subscribe to", }, }, required: ["addresses"], }, },
• src/index.ts:1092-1108 (handler)

  MCP server request handler for tool calls to zetrix_ws_subscribe_tx, validates args and delegates to ZetrixWebSocketClient
  case "zetrix_ws_subscribe_tx": { if (!args) { throw new Error("Missing arguments"); } const wsClient = getWebSocketClient(); const result = await wsClient.subscribeTransactions( args.addresses as string[] ); return { content: [ { type: "text", text: JSON.stringify(result, null, 2), }, ], }; }
• src/zetrix-websocket.ts:280-306 (handler)

  Core tool logic: sends WebSocket subscription request (CHAIN_SUBSCRIBE_TX) for transaction notifications on specified addresses
  subscribeTransactions(addresses: string[]): Promise<ChainResponse> { return new Promise((resolve, reject) => { if (!this.isRegistered) { reject(new Error("WebSocket not registered. Call registerAndConnect first.")); return; } const request: ChainSubscribeTxRequest = { type: ChainMessageType.CHAIN_SUBSCRIBE_TX, address: addresses, }; const timeout = setTimeout(() => { reject(new Error("Subscription timeout")); }, 10000); const onMessage = (response: ChainResponse) => { if (response.error_code === 0) { clearTimeout(timeout); resolve(response); } }; this.once("message", onMessage); this.sendMessage(request); }); }
• src/zetrix-websocket.ts:66-70 (schema)

  TypeScript interface defining the WebSocket subscription request structure used by the tool handler
  export interface ChainSubscribeTxRequest { type: ChainMessageType.CHAIN_SUBSCRIBE_TX; address: string[]; }