Osmosis MCP Server

import { JsonRpcId, JsonRpcRequest, JsonRpcResponse, JsonRpcSuccessResponse } from "@cosmjs/json-rpc"; import { Stream } from "xstream"; import { RpcStreamingClient, SubscriptionEvent } from "./rpcclient"; export declare class WebsocketClient implements RpcStreamingClient { private readonly url; private readonly socket; /** Same events as in socket.events but in the format we need */ private readonly jsonRpcResponseStream; private readonly subscriptionStreams; constructor(baseUrl: string, onError?: (err: any) => void); execute(request: JsonRpcRequest): Promise<JsonRpcSuccessResponse>; listen(request: JsonRpcRequest): Stream<SubscriptionEvent>; /** * Resolves as soon as websocket is connected. execute() queues requests automatically, * so this should be required for testing purposes only. */ connected(): Promise<void>; disconnect(): void; protected responseForRequestId(id: JsonRpcId): Promise<JsonRpcResponse>; }