engine

type Error struct {
	// Message is a human-readable description of the error.
	// It provides a clear explanation of what went wrong.
	Message string

	// Description contains the underlying error that caused this transport error.
	// This can be nil if there is no underlying error.
	Description error

	// Type identifies the category of the error (e.g., "TransportError").
	// This helps in error classification and handling.
	Type string

	// Context contains additional context information about the error.
	// This can include request/response data, timing information, etc.
	Context context.Context
	// contains filtered or unexported fields
}

type HandshakeData struct {
	// Sid is the unique session identifier assigned by the server.
	// This ID is used to maintain the connection state and identify the client.
	Sid string `json:"sid,omitempty" msgpack:"sid,omitempty"`

	// Upgrades contains a list of transport types that the server supports
	// for upgrading the current connection. This is used in the transport
	// upgrade process to determine available upgrade options.
	Upgrades []string `json:"upgrades,omitempty" msgpack:"upgrades,omitempty"`

	// PingInterval specifies the interval (in milliseconds) between ping messages
	// sent by the client to keep the connection alive.
	PingInterval int64 `json:"pingInterval,omitempty" msgpack:"pingInterval,omitempty"`

	// PingTimeout specifies the maximum time (in milliseconds) to wait for a pong
	// response before considering the connection dead.
	PingTimeout int64 `json:"pingTimeout,omitempty" msgpack:"pingTimeout,omitempty"`

	// MaxPayload specifies the maximum size (in bytes) of a single packet that
	// can be transmitted over the connection.
	MaxPayload int64 `json:"maxPayload,omitempty" msgpack:"maxPayload,omitempty"`
}

type Log struct {
	*log.Log
}

type Polling interface {
	Transport
}

type PollingBuilder struct{}

type Socket interface {
	SocketWithUpgrade
}

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

type SocketOptionsInterface interface {
	Host() string
	GetRawHost() *string
	SetHost(string)

	Hostname() string
	GetRawHostname() *string
	SetHostname(string)

	Secure() bool
	GetRawSecure() *bool
	SetSecure(bool)

	Port() string
	GetRawPort() *string
	SetPort(string)

	Query() url.Values
	GetRawQuery() url.Values
	SetQuery(url.Values)

	Agent() string
	GetRawAgent() *string
	SetAgent(string)

	Upgrade() bool
	GetRawUpgrade() *bool
	SetUpgrade(bool)

	ForceBase64() bool
	GetRawForceBase64() *bool
	SetForceBase64(bool)

	TimestampParam() string
	GetRawTimestampParam() *string
	SetTimestampParam(string)

	TimestampRequests() bool
	GetRawTimestampRequests() *bool
	SetTimestampRequests(bool)

	Transports() *types.Set[TransportCtor]
	GetRawTransports() *types.Set[TransportCtor]
	SetTransports(*types.Set[TransportCtor])

	TryAllTransports() bool
	GetRawTryAllTransports() *bool
	SetTryAllTransports(bool)

	RememberUpgrade() bool
	GetRawRememberUpgrade() *bool
	SetRememberUpgrade(bool)

	RequestTimeout() time.Duration
	GetRawRequestTimeout() *time.Duration
	SetRequestTimeout(time.Duration)

	TransportOptions() map[string]SocketOptionsInterface
	GetRawTransportOptions() map[string]SocketOptionsInterface
	SetTransportOptions(map[string]SocketOptionsInterface)

	TLSClientConfig() *tls.Config
	GetRawTLSClientConfig() *tls.Config
	SetTLSClientConfig(*tls.Config)

	QUICConfig() *quic.Config
	GetRawQUICConfig() *quic.Config
	SetQUICConfig(*quic.Config)

	ExtraHeaders() http.Header
	GetRawExtraHeaders() http.Header
	SetExtraHeaders(http.Header)

	WithCredentials() bool
	GetRawWithCredentials() *bool
	SetWithCredentials(bool)

	UseNativeTimers() bool
	GetRawUseNativeTimers() *bool
	SetUseNativeTimers(bool)

	AutoUnref() bool
	GetRawAutoUnref() *bool
	SetAutoUnref(bool)

	CloseOnBeforeunload() bool
	GetRawCloseOnBeforeunload() *bool
	SetCloseOnBeforeunload(bool)

	PerMessageDeflate() *types.PerMessageDeflate
	GetRawPerMessageDeflate() *types.PerMessageDeflate
	SetPerMessageDeflate(*types.PerMessageDeflate)

	Path() string
	GetRawPath() *string
	SetPath(string)

	AddTrailingSlash() bool
	GetRawAddTrailingSlash() *bool
	SetAddTrailingSlash(addTrailingSlash bool)

	Protocols() []string
	GetRawProtocols() []string
	SetProtocols([]string)
}

type SocketState string

type SocketWithUpgrade interface {
	SocketWithoutUpgrade
}

type SocketWithoutUpgrade interface {
	// EventEmitter provides event-based communication capabilities
	types.EventEmitter

	// Prototype sets the prototype interface for method rewriting
	Prototype(SocketWithoutUpgrade)

	// Proto returns the prototype interface instance
	Proto() SocketWithoutUpgrade

	// SetPriorWebsocketSuccess updates the WebSocket success state
	// This is used to optimize future connection attempts
	SetPriorWebsocketSuccess(bool)

	// SetUpgrading updates the upgrading state of the socket
	// This indicates whether a transport upgrade is in progress
	SetUpgrading(bool)

	// Id returns the unique identifier for this socket connection
	Id() string

	// Transport returns the current transport being used
	Transport() Transport

	// ReadyState returns the current state of the socket connection
	ReadyState() SocketState

	// WriteBuffer returns the packet buffer for queued writes
	WriteBuffer() *types.Slice[*packet.Packet]

	// Opts returns the socket options configuration
	Opts() SocketOptionsInterface

	// Transports returns the set of available transport types
	Transports() *types.Set[string]

	// Upgrading returns whether a transport upgrade is in progress
	Upgrading() bool

	// CookieJar returns the cookie jar used for HTTP requests
	CookieJar() http.CookieJar

	// PriorWebsocketSuccess returns whether previous WebSocket connections were successful
	PriorWebsocketSuccess() bool

	// Protocol returns the Engine.IO protocol version being used
	Protocol() int

	// Construct initializes the socket with the given URI and options
	Construct(string, SocketOptionsInterface)

	// CreateTransport creates a new transport instance of the specified type
	CreateTransport(string) Transport

	// SetTransport updates the current transport being used
	SetTransport(Transport)

	// OnOpen handles the socket open event
	OnOpen()

	// OnHandshake handles the initial handshake data from the server
	OnHandshake(*HandshakeData)

	// Flush sends all queued packets in the write buffer
	Flush()

	// HasPingExpired checks if the current ping timeout has expired
	HasPingExpired() bool

	// Write queues data to be sent to the server
	// Parameters:
	//   - data: The data to send
	//   - options: Optional packet configuration
	//   - callback: Optional callback to be called after the write completes
	Write(io.Reader, *packet.Options, func()) SocketWithoutUpgrade

	// Send is an alias for Write
	Send(io.Reader, *packet.Options, func()) SocketWithoutUpgrade

	// Close terminates the socket connection
	Close() SocketWithoutUpgrade
}

type Transport interface {
	// EventEmitter provides event-based communication capabilities
	types.EventEmitter

	// Prototype sets the prototype interface for method rewriting
	Prototype(Transport)

	// Proto returns the prototype interface instance
	Proto() Transport

	// SetWritable updates whether the transport can send data
	SetWritable(bool)

	// SetReadyState updates the current state of the transport
	SetReadyState(TransportState)

	// Name returns the identifier for this transport type
	Name() string

	// Query returns the URL query parameters for the transport
	Query() url.Values

	// Writable returns whether the transport can currently send data
	Writable() bool

	// Opts returns the socket options configuration
	Opts() SocketOptionsInterface

	// SupportsBinary returns whether the transport supports binary data
	SupportsBinary() bool

	// ReadyState returns the current state of the transport
	ReadyState() TransportState

	// Socket returns the parent socket instance
	Socket() Socket

	// Construct initializes the transport with the given socket and options
	Construct(Socket, SocketOptionsInterface)

	// OnError handles transport-level errors
	OnError(string, error, context.Context) Transport

	// Open initiates the transport connection
	Open() Transport

	// Close terminates the transport connection
	Close() Transport

	// Send transmits packets through the transport
	Send([]*packet.Packet)

	// OnOpen handles successful connection establishment
	OnOpen()

	// OnData processes incoming raw data
	OnData(types.BufferInterface)

	// OnPacket handles decoded packets
	OnPacket(*packet.Packet)

	// OnClose handles connection termination
	OnClose(error)

	// Pause temporarily suspends the transport
	Pause(func())

	// CreateUri constructs a URL for the transport connection
	CreateUri(string, url.Values) *url.URL

	// DoOpen implements transport-specific connection initialization
	DoOpen()

	// DoClose implements transport-specific connection termination
	DoClose()

	// Write implements transport-specific packet transmission
	Write([]*packet.Packet)
}

type TransportCtor interface {
	// Name returns the identifier for this transport type.
	// This is used to identify the transport in configuration and upgrade processes.
	Name() string

	// New creates a new transport instance with the specified socket and options.
	//
	// Parameters:
	//   - socket: The parent socket instance
	//   - opts: The socket options configuration
	//
	// Returns: A new Transport instance
	New(Socket, SocketOptionsInterface) Transport
}

type TransportState string

type WebSocket interface {
	Transport
}

type WebSocketBuilder struct{}

type WebTransport interface {
	Transport
}

type WebTransportBuilder struct{}