transport

type Config struct {
	// RecvBufferSize is the size of the receive channel buffer.
	// Default: 100
	RecvBufferSize int

	// SendBufferSize is the size of the internal send buffer.
	// Default: 100
	SendBufferSize int
}

type Error struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type GoalCompleteParams struct {
	SessionID string `json:"session_id"`
	Goal      string `json:"goal"`
	Output    string `json:"output"`
}

type GoalStartedParams struct {
	SessionID string `json:"session_id"`
	Goal      string `json:"goal"`
}

type Handler interface {
	Handle(ctx context.Context, method string, params json.RawMessage) (interface{}, error)
}

type HandlerFunc func(ctx context.Context, method string, params json.RawMessage) (interface{}, error)

type InboundMessage struct {
	// Request is set if this is a JSON-RPC request (has ID).
	Request *Request

	// Notification is set if this is a notification (no ID).
	Notification *Notification

	// Raw contains the original bytes for passthrough scenarios.
	Raw json.RawMessage
}

type Notification struct {
	JSONRPC string      `json:"jsonrpc"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params,omitempty"`
}

type OutboundMessage struct {
	// Response is set when replying to a request.
	Response *Response

	// Notification is set when sending an unsolicited notification.
	Notification *Notification
}

type Request struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      interface{}     `json:"id,omitempty"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params,omitempty"`
}

type Response struct {
	JSONRPC string      `json:"jsonrpc"`
	ID      interface{} `json:"id,omitempty"`
	Result  interface{} `json:"result,omitempty"`
	Error   *Error      `json:"error,omitempty"`
}

type RunParams struct {
	File   string            `json:"file"`
	Inputs map[string]string `json:"inputs,omitempty"`
}

type RunResult struct {
	SessionID  string            `json:"session_id"`
	Status     string            `json:"status"`
	Outputs    map[string]string `json:"outputs,omitempty"`
	Iterations map[string]int    `json:"iterations,omitempty"`
	Error      string            `json:"error,omitempty"`
}

type SSEClient struct {
	// contains filtered or unexported fields
}

type SSEConfig struct {
	Config // Embed base config

	// FlushInterval for SSE writes.
	FlushInterval time.Duration

	// HeartbeatInterval sends SSE comments as keepalive (0 = disabled).
	HeartbeatInterval time.Duration
}

type SSETransport struct {
	// contains filtered or unexported fields
}

type Server struct {

	// NotifyFunc is called to send notifications
	NotifyFunc func(method string, params interface{})
	// contains filtered or unexported fields
}

type StdioTransport struct {
	// contains filtered or unexported fields
}

type ToolCallParams struct {
	SessionID string                 `json:"session_id"`
	Goal      string                 `json:"goal"`
	Tool      string                 `json:"tool"`
	Args      map[string]interface{} `json:"args"`
	Result    interface{}            `json:"result,omitempty"`
	Error     string                 `json:"error,omitempty"`
}

type Transport interface {
	// Recv returns channel for incoming messages.
	// Channel is closed when transport shuts down.
	Recv() <-chan *InboundMessage

	// Send queues a message for delivery.
	// Returns ErrClosed if transport is closed.
	Send(msg *OutboundMessage) error

	// Run starts the transport, blocks until ctx cancelled or error.
	// Returns nil on graceful shutdown, error otherwise.
	Run(ctx context.Context) error

	// Close initiates graceful shutdown.
	// Drains pending sends before returning.
	Close() error
}

type WebSocketConfig struct {
	Config // Embed base config

	// WriteTimeout for write operations.
	WriteTimeout time.Duration

	// ReadTimeout for read operations (0 = no timeout).
	ReadTimeout time.Duration

	// MaxMessageSize limits incoming message size.
	MaxMessageSize int64

	// PingInterval for keepalive pings (0 = disabled).
	PingInterval time.Duration
}

type WebSocketTransport struct {
	// contains filtered or unexported fields
}