pub(open) trait Transport {
  fn receive(Self) -> String? raise 
@colmugx/mcp/protocol/types.TransportError
TransportError
  fn send(Self, String) -> Unit raise 
@colmugx/mcp/protocol/types.TransportError
TransportError
  fn send_notification(Self, 
@colmugx/mcp/protocol/types.Notification
Notification) -> Unit raise 
@colmugx/mcp/protocol/types.TransportError
TransportError
  fn close(Self) -> Unit
}

pub(all) enum AnyTransport {
  Stdio(StdioTransport)
  StdioClient(StdioClientTransport)
  Http(HttpTransport)
  HttpClient(HttpClientTransport)
}

pub struct AuthConfig {
  authenticate : (String) -> 
@colmugx/mcp/runtime.Principal
Principal?
  resource_metadata_url : String
  authorization_servers : Array[String]
  required_scopes : String?
  allowed_origins : Array[String]?
}

pub(all) struct AuthenticatedRequest {
  message : String
  reply : 
@moonbitlang/async/aqueue.Queue
Queue[String]
  principal : 
@colmugx/mcp/runtime.Principal
Principal?
  cancellation_token : 
@colmugx/mcp/runtime.CancellationToken
CancellationToken
}

pub(all) enum HeaderSchemaValidation {
  Valid(Array[(Array[String], String)])
  Invalid(String)
}

pub struct HttpClientTransport {
  base_url : String
  auth_token : String?
  closed : Bool
  pending_responses : 
@moonbitlang/async/aqueue.Queue
Queue[String]
  extra_headers : Array[(String, String)]
  tool_header_schemas : Map[String, Array[(Array[String], String)]]
}

pub struct HttpTransport {
  port : Int
  endpoint_path : String
  auth : AuthConfig?
  keepalive_interval_ms : Int
  tool_schema_resolver : 
@moonbitlang/core/ref.Ref
Ref[(String) -> Json?]
  pending_requests : 
@moonbitlang/async/aqueue.Queue
Queue[AuthenticatedRequest]
  pending_reply_queues : Map[String, 
@moonbitlang/async/aqueue.Queue
Queue[String]]
}

pub(all) enum JsonRpcKind {
  Notification
  FinalResponse
  Other
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub struct SseEventReader {
  buf : 
@moonbitlang/core/lexbuf.AsyncLexbuf
AsyncLexbuf
  decode_failed : 
@moonbitlang/core/ref.Ref
Ref[Bool]
}

pub enum SseEventVerdict {
  Message(String)
  Skip
  Eof
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub struct StdioClientTransport {
  cmd : String
  args : Array[String]
  extra_env : Map[String, String]
  closed : Bool
  reader : 
@moonbitlang/async/process.ReadFromProcess
ReadFromProcess?
  raw_writer : 
@moonbitlang/async/process.WriteToProcess
WriteToProcess?
  writer : 
@moonbitlang/async/io.BufferedWriter
BufferedWriter[
@moonbitlang/async/process.WriteToProcess
WriteToProcess]?
  send_mutex : 
@moonbitlang/async.Mutex
Mutex
}

pub struct StdioTransport {
  closed : Bool
  reader : 
@moonbitlang/async/stdio.Input
Input
  writer : 
@moonbitlang/async/io.BufferedWriter
BufferedWriter[
@moonbitlang/async/stdio.Output
Output]
}

fn classify_jsonrpc_message(message : String) -> JsonRpcKind

fn decode_base64(s : String) -> Bytes?

fn decode_base64_sentinel(value : String) -> String?

fn encode_base64(bytes : Bytes) -> String

fn encode_base64_sentinel(value : String) -> String

fn encode_header_value(value : String) -> String

fn extract_argument_value(body : String, path : Array[String]) -> String?

fn header_mismatch_error(detail : String, body~ : String) -> String

fn invalid_params_error(detail : String, body~ : String) -> String

fn is_header_safe(value : String) -> Bool

fn is_notification(body : Json) -> Bool

fn is_valid_header_characters(value : String) -> Bool

fn jsonrpc_error_code(message : String) -> Int?

fn looks_like_sentinel(value : String) -> Bool

fn origin_allowed(origin : String, allowed_origins : Array[String]?) -> Bool

async fn read_sse_event(client : 
@moonbitlang/async/http.Client
Client) -> (String?, String?)

fn request_id_from_body(body : String) -> Json?

fn sse_event_line(json : String) -> String

fn sse_event_verdict(data : String?, id : String?) -> SseEventVerdict

fn unsupported_protocol_version_error(requested : String, body~ : String) -> String

fn validate_jsonrpc_message(message : String) -> Unit raise 
@colmugx/mcp/protocol/types.MCPError
MCPError

fn validate_tool_header_schema(input_schema : Json) -> HeaderSchemaValidation

fn validate_tool_parameter_headers(input_schema : Json, arguments : Json, headers : Array[(String, String)]) -> Result[Unit, String]