mirror of
https://gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake.git
synced 2025-10-14 05:11:19 -04:00
55 lines
1.2 KiB
Go
55 lines
1.2 KiB
Go
package lib
|
|
|
|
import (
|
|
"io"
|
|
"net"
|
|
)
|
|
|
|
type Connector interface {
|
|
Connect() error
|
|
}
|
|
|
|
type Resetter interface {
|
|
Reset()
|
|
WaitForReset()
|
|
}
|
|
|
|
// Interface for a single remote WebRTC peer.
|
|
// In the Client context, "Snowflake" refers to the remote browser proxy.
|
|
type Snowflake interface {
|
|
io.ReadWriteCloser
|
|
Resetter
|
|
Connector
|
|
}
|
|
|
|
// Interface for catching Snowflakes. (aka the remote dialer)
|
|
type Tongue interface {
|
|
Catch() (Snowflake, error)
|
|
}
|
|
|
|
// Interface for collecting some number of Snowflakes, for passing along
|
|
// ultimately to the SOCKS handler.
|
|
type SnowflakeCollector interface {
|
|
// Add a Snowflake to the collection.
|
|
// Implementation should decide how to connect and maintain the webRTCConn.
|
|
Collect() (Snowflake, error)
|
|
|
|
// Remove and return the most available Snowflake from the collection.
|
|
Pop() Snowflake
|
|
|
|
// Signal when the collector has stopped collecting.
|
|
Melted() <-chan struct{}
|
|
}
|
|
|
|
// Interface to adapt to goptlib's SocksConn struct.
|
|
type SocksConnector interface {
|
|
Grant(*net.TCPAddr) error
|
|
Reject() error
|
|
net.Conn
|
|
}
|
|
|
|
// Interface for the Snowflake's transport. (Typically just webrtc.DataChannel)
|
|
type SnowflakeDataChannel interface {
|
|
io.Closer
|
|
Send([]byte) error
|
|
}
|