datachannels

type ClientChannel interface {
	// Ready returns a channel that is closed when the data channel is ready.
	Ready() <-chan struct{}
	// Errors returns a channel for receiving errors.
	Errors() <-chan error
	// Closed returns a channel for receiving a notification when the data channel is closed.
	Closed() <-chan struct{}
	// Open opens a new data channel.
	Open(ctx context.Context, proto string) (io.ReadWriteCloser, error)
	// Close closes the peer connection and all data channels.
	Close() error
}

type ClientOptions struct {
	// Client is the webmesh client for performing ICE negotiation.
	Client v1.WebRTCClient
	// NodeID is the node ID to request for connection channels.
	NodeID string
	// Protocol is the protocol to request for connection channels.
	Protocol string
	// Destination is the destination address to request for connection channels.
	Destination string
	// Port is the destination port to request for connection channels.
	// A port of 0 with the udp protocol indicates WireGuard interface traffic.
	Port uint32
}

type ManagedServerChannel interface {
	// Offer returns the offer for the data channel.
	Offer() string
	// AnswerOffer answers the offer from the peer.
	AnswerOffer(offer string) error
	// Candidates returns a channel for receiving ICE candidates.
	Candidates() <-chan string
	// AddCandidate adds an ICE candidate.
	AddCandidate(candidate string) error
	// Closed returns a channel for receiving a notification when the data channel is closed.
	Closed() <-chan struct{}
	// Close closes the data channel.
	Close() error
}

type OfferOptions struct {
	// Proto is the protocol used for the connection.
	// Defaults to "tcp".
	Proto string
	// SrcAddress is the source address and port of the client that
	// initiated the connection.
	SrcAddress string
	// DstAddress is the destination address and port of the connection.
	DstAddress string
	// STUNServers is a list of STUN servers to use for the connection.
	STUNServers []string
}

type PeerConnectionClient struct {
	// PeerConnection is the underlying WebRTC peer connection.
	*webrtc.PeerConnection
	// contains filtered or unexported fields
}

type PeerConnectionServer struct {
	// PeerConnection is the underlying WebRTC peer connection.
	*webrtc.PeerConnection
	// contains filtered or unexported fields
}

type ServerChannel interface {
	// Accept accepts a new connection channel.
	Accept() (proto string, rw io.ReadWriteCloser, err error)
	// Ready returns a channel that is closed when the data channel is ready.
	Ready() <-chan struct{}
	// Errors returns a channel for receiving errors.
	Errors() <-chan error
	// Closed returns a channel for receiving a notification when the data channel is closed.
	Closed() <-chan struct{}
	// Close closes the data channel.
	Close() error
}

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

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