generate static method
Generates the stdio server Dart code.
tools - List of tool definitions with parameters and metadata
Returns the complete server code as a Dart string.
Implementation
static String generate(List<Map<String, dynamic>> tools) {
// Collect unique imports for custom List inner types
final listInnerImports = _collectListInnerImports(tools);
final listInnerImportStatements = listInnerImports
.map((uri) => "import '$uri';")
.join('\n');
// Collect unique per-tool source imports with aliases
final sourceImports = <String, String>{};
for (final tool in tools) {
final sourceImport = tool['sourceImport'] as String?;
final sourceAlias = tool['sourceAlias'] as String?;
if (sourceImport != null && sourceAlias != null) {
sourceImports[sourceImport] = sourceAlias;
}
}
final sourceImportStatements = sourceImports.entries
.map((e) => "import '${e.key}' as ${e.value};")
.join('\n');
final toolRegistrations = tools
.map((t) {
final name = t['name'] as String;
final schema = SchemaBuilder.buildObjectSchema(
(t['parameters'] as List<Map<String, dynamic>>? ?? []),
);
return '''
registerTool(
Tool(
name: '$name',
description: '${t['description'] ?? 'Tool $name'}',
inputSchema: $schema,
),
_$name,
);''';
})
.join('\n');
final toolHandlers = tools
.map((t) {
final name = t['name'] as String;
final params = t['parameters'] as List<Map<String, dynamic>>? ?? [];
final paramExtractions = params
.map((p) {
final paramName = p['name'] as String;
final paramType = p['type'] as String;
final isOptional = p['isOptional'] == true;
final dartType = _dartType(paramType);
if (isOptional) {
final nullableType = dartType.endsWith('?')
? dartType
: '$dartType?';
return " final $paramName = request.arguments?['$paramName'] as $nullableType;";
}
return " final $paramName = request.arguments!['$paramName'] as $dartType;";
})
.join('\n');
// Generate conversion code for List parameters with custom inner types
final paramConversions = params
.where((p) => _needsListConversion(p['type'] as String))
.map((p) {
final paramName = p['name'] as String;
final paramType = p['type'] as String;
final innerType = _extractListInnerType(paramType);
final isOptional = p['isOptional'] == true;
if (isOptional) {
return ' final ${paramName}Converted = $paramName?.map((e) => $innerType.fromJson(e as Map<String, dynamic>)).toList();';
}
return ' final ${paramName}Converted = $paramName.map((e) => $innerType.fromJson(e as Map<String, dynamic>)).toList();';
})
.join('\n');
final isAsync = t['isAsync'] == true;
final className = t['className'] as String?;
final isStatic = t['isStatic'] == true;
final sourceAlias = t['sourceAlias'] as String? ?? 'lib';
String call;
final methodName = t['methodName'] as String? ?? name;
if (className != null && isStatic) {
call = isAsync
? 'await $sourceAlias.$className.$methodName(${_callArgsWithConversion(params)})'
: '$sourceAlias.$className.$methodName(${_callArgsWithConversion(params)})';
} else if (className != null) {
call = isAsync
? 'await $sourceAlias.$className().$methodName(${_callArgsWithConversion(params)})'
: '$sourceAlias.$className().$methodName(${_callArgsWithConversion(params)})';
} else {
call = isAsync
? 'await $sourceAlias.$methodName(${_callArgsWithConversion(params)})'
: '$sourceAlias.$methodName(${_callArgsWithConversion(params)})';
}
return '''
FutureOr<CallToolResult> _$name(CallToolRequest request) async {
try {
$paramExtractions
$paramConversions
final result = $call;
return CallToolResult(
content: [TextContent(text: _serializeResult(result))],
);
} catch (e) {
return CallToolResult(
content: [TextContent(text: 'An error occurred while processing the request.')],
isError: true,
);
}
}''';
})
.join('\n');
return '''
// Generated MCP stdio server
// DO NOT EDIT - automatically generated by mcp_generator
import 'dart:async';
import 'dart:convert';
import 'dart:io' as io;
import 'package:dart_mcp/server.dart';
import 'package:dart_mcp/stdio.dart';
$listInnerImportStatements
$sourceImportStatements
Future<void> main() async {
final server = MCPServerWithTools(
stdioChannel(input: io.stdin, output: io.stdout),
);
await server.done;
}
base class MCPServerWithTools extends MCPServer with ToolsSupport {
MCPServerWithTools(super.channel)
: super.fromStreamChannel(
implementation: Implementation(
name: 'mcp-server',
version: '1.0.0',
),
instructions: 'Auto-generated MCP server',
) {
$toolRegistrations
}
$toolHandlers
String _serializeResult(dynamic result) {
if (result == null) return 'null';
try {
if (result is List) {
final items = result.map((e) {
if (e == null) return null;
final toJson = e.toJson;
if (toJson != null && toJson is Function) return toJson();
return e.toString();
}).where((e) => e != null).toList();
return jsonEncode(items);
}
final toJson = result.toJson;
if (toJson != null && toJson is Function) return jsonEncode(toJson());
return result.toString();
} catch (_) {
return result.toString();
}
}
}
''';
}