MCP Dart Client

import 'dart:io';

import 'package:mcp_dart/mcp_dart.dart';

Future<List<Tool>> listAllTools(McpClient client) async {
  final tools = <Tool>[];
  final seen = <String>{};
  String? cursor;
  do {
    final page = await client.listTools(
      params: cursor == null ? null : ListToolsRequest(cursor: cursor),
    );
    tools.addAll(page.tools);
    cursor = page.nextCursor;
    if (cursor != null && !seen.add(cursor)) {
      throw StateError('tools/list repeated cursor "$cursor"');
    }
  } while (cursor != null);
  return tools;
}

Future<void> main() async {
  final client = McpClient(
    const Implementation(name: 'notes-client', version: '1.0.0'),
  );
  try {
    await client.connect(
      StdioClientTransport(
        const StdioServerParameters(
          command: 'dart',
          args: ['run', 'bin/server.dart'],
        ),
      ),
    );
    print('connected to ${client.getServerVersion()?.name} '
        'using MCP ${client.getProtocolVersion()}');

    for (final tool in await listAllTools(client)) {
      print('${tool.name}: ${tool.description ?? ''}');
    }

    final result = await client.callTool(
      const CallToolRequest(
        name: 'add_note',
        arguments: {'id': 'todo', 'text': 'Ship the release'},
      ),
      options: const RequestOptions(timeout: Duration(seconds: 30)),
    );
    for (final content in result.content) {
      if (content is TextContent) {
        (result.isError ? stderr : stdout).writeln(content.text);
      }
    }

    if (client.getServerCapabilities()?.resources != null) {
      final read = await client.readResource(
        const ReadResourceRequest(uri: 'notes://index'),
      );
      for (final contents in read.contents) {
        if (contents is TextResourceContents) {
          print(contents.text);
        }
      }
    }
  } on McpError catch (error) {
    stderr.writeln('MCP error ${error.code}: ${error.message}');
  } finally {
    await client.close();
  }
}

import 'package:mcp_dart/mcp_dart.dart';

Future<void> main() async {
  final client = McpClient(
    const Implementation(name: 'remote-client', version: '1.0.0'),
  );
  try {
    await client.connect(
      StreamableHttpClientTransport(Uri.parse('https://mcp.example.com/mcp')),
    );

    if (client.getServerCapabilities()?.prompts != null) {
      final prompt = await client.getPrompt(
        const GetPromptRequest(
          name: 'summarize_note',
          arguments: {'id': 'todo'},
        ),
      );
      for (final message in prompt.messages) {
        final content = message.content;
        if (content is TextContent) {
          print('${message.role.name}: ${content.text}');
        }
      }
    }

    final controller = BasicAbortController();
    final pending = client.callTool(
      const CallToolRequest(name: 'export_rows', arguments: {'rows': 5000}),
      options: RequestOptions(
        signal: controller.signal,
        onprogress: (progress) {
          print('${progress.progress}/${progress.total} ${progress.message}');
          if (progress.progress >= 1000) {
            controller.abort('User cancelled');
          }
        },
      ),
    );
    try {
      await pending;
    } on AbortError {
      print('export cancelled');
    }
  } finally {
    await client.close();
  }
}