pkg/dartdev/test/commands/mcp_server_test.dart

// Copyright (c) 2025, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:io';

import 'package:dart_mcp/client.dart';
import 'package:dart_mcp/stdio.dart';
import 'package:test/test.dart';

void main() {
  group('dart mcp-server', () {
    for (var withExperiment in const [true, false]) {
      test(
          'can be connected with a client with${withExperiment ? '' : 'out'} the experiment flag',
          () async {
        final client = TestMCPClient();
        addTearDown(client.shutdown);
        final process = await Process.start(Platform.resolvedExecutable, [
          'mcp-server',
          if (withExperiment) '--experimental-mcp-server',
        ]);

        final connection = client.connectServer(
          stdioChannel(input: process.stdout, output: process.stdin),
        );
        connection.done.then((_) => process.kill());

        final initializeResult = await connection.initialize(
          InitializeRequest(
            protocolVersion: ProtocolVersion.latestSupported,
            capabilities: client.capabilities,
            clientInfo: client.implementation,
          ),
        );

        expect(
            initializeResult.protocolVersion, ProtocolVersion.latestSupported);
        connection.notifyInitialized();

        expect(await connection.listTools(ListToolsRequest()), isNotEmpty);
      });
    }
  });
}

base class TestMCPClient extends MCPClient {
  TestMCPClient()
      : super(Implementation(name: 'test client', version: '0.1.0'));
}