gateway

type Config struct {
	// Enabled indicates if the gateway is enabled.
	Enabled bool `yaml:"enabled"`
	// ReadBufferSize is the WebSocket read buffer size.
	ReadBufferSize int `yaml:"read_buffer_size"`
	// WriteBufferSize is the WebSocket write buffer size.
	WriteBufferSize int `yaml:"write_buffer_size"`
	// MaxMessageSize is the maximum message size in bytes.
	MaxMessageSize int64 `yaml:"max_message_size"`
	// PingInterval is the interval for ping messages.
	PingIntervalSeconds int `yaml:"ping_interval_seconds"`
	// PongTimeout is the timeout for pong responses.
	PongTimeoutSeconds int `yaml:"pong_timeout_seconds"`
	// WriteTimeout is the timeout for write operations.
	WriteTimeoutSeconds int `yaml:"write_timeout_seconds"`
	// RequestTimeout is the timeout for a single gateway request.
	// 0 disables hard request timeout and relies on connection cancellation.
	RequestTimeoutSeconds int `yaml:"request_timeout_seconds"`
	// MaxConnections is the maximum number of connections.
	MaxConnections int `yaml:"max_connections"`
}

type Connection struct {
	ID     string
	UserID string

	// Metadata
	Metadata map[string]interface{}

	// Statistics
	MessagesSent     atomic.Int64
	MessagesReceived atomic.Int64
	ConnectedAt      time.Time
	// contains filtered or unexported fields
}

type ErrorPayload struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

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

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

type Message struct {
	ID        string          `json:"id"`
	Type      MessageType     `json:"type"`
	Method    string          `json:"method,omitempty"`
	Payload   json.RawMessage `json:"payload,omitempty"`
	Error     *ErrorPayload   `json:"error,omitempty"`
	Timestamp int64           `json:"timestamp"`
}

type MessageType string

type RequestHandler func(ctx context.Context, conn *Connection, msg *Message) (*Message, error)