create method

TransportConfig create(ServerConfig server)

Implementation

TransportConfig create(ServerConfig server) {
  final cfg = server.transportConfig;

  switch (server.transportType) {
    case TransportType.stdio:
      final command = cfg['command'];
      if (command is! String) {
        throw ArgumentError(
          'stdio transport requires "command" string field',
        );
      }
      return TransportConfig.stdio(
        command: command,
        arguments:
            (cfg['arguments'] as List<dynamic>?)?.cast<String>() ??
                const <String>[],
        workingDirectory: cfg['workingDirectory'] as String?,
      );

    case TransportType.sse:
      final serverUrl = cfg['serverUrl'];
      if (serverUrl is! String) {
        throw ArgumentError(
          'sse transport requires "serverUrl" string field',
        );
      }
      final heartbeatSeconds = cfg['heartbeatInterval'] as int?;
      return TransportConfig.sse(
        serverUrl: serverUrl,
        bearerToken: cfg['bearerToken'] as String?,
        enableCompression:
            cfg['enableCompression'] as bool? ?? false,
        heartbeatInterval: heartbeatSeconds != null
            ? Duration(seconds: heartbeatSeconds)
            : null,
      );

    case TransportType.streamableHttp:
      final baseUrl = cfg['baseUrl'];
      if (baseUrl is! String) {
        throw ArgumentError(
          'streamableHttp transport requires "baseUrl" string field',
        );
      }
      final timeoutSeconds = cfg['timeout'] as int?;
      return TransportConfig.streamableHttp(
        baseUrl: baseUrl,
        useHttp2: cfg['useHttp2'] as bool? ?? true,
        timeout: timeoutSeconds != null
            ? Duration(seconds: timeoutSeconds)
            : null,
        terminateOnClose: false,
      );
  }
}