stdio

Overview ¶

This file implements the stdio transport layer for JSON-RPC communication. It provides functionality to read and write JSON-RPC messages over standard input/output streams, similar to the TypeScript implementation in @typescript-sdk/src/shared/stdio.ts.

Key Components:

1. ReadBuffer:

• Buffers continuous stdio stream into discrete JSON-RPC messages
• Thread-safe with mutex protection
• Handles message framing using newline delimiters
• Methods: Append (add data), ReadMessage (read complete message), Clear (reset buffer)

2. StdioTransport:

• Implements the Transport interface using stdio
• Uses bufio.Reader for efficient buffered reading
• Thread-safe with mutex protection
• Supports:
• Asynchronous message reading
• Message sending with newline framing
• Proper cleanup on close
• Event handlers for close, error, and message events

3. Message Handling:

• Deserializes JSON-RPC messages into appropriate types:
• JSONRPCRequest: Messages with ID and method
• JSONRPCNotification: Messages with method but no ID
• JSONRPCError: Error responses with ID
• Generic responses: Success responses with ID
• Serializes messages to JSON with newline termination

Thread Safety:

• All public methods are thread-safe
• Uses sync.Mutex for state protection
• Safe for concurrent reading and writing

Usage:

transport := NewStdioTransport()
transport.SetMessageHandler(func(msg interface{}) {
    // Handle incoming message
})
transport.Start()
defer transport.Close()

// Send a message
transport.Send(map[string]interface{}{
    "jsonrpc": "2.0",
    "method": "test",
    "params": map[string]interface{}{},
})

Error Handling:

• All methods return meaningful errors
• Transport supports error handler for async errors
• Proper cleanup on error conditions

For more details, see the test file stdio_test.go.