archives/snowflake
2
0
Fork 0
mirror of https://gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake.git synced 2025-10-13 20:11:19 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Refactor creation of webRTCConn in proxy

Browse source
This commit is contained in:
Cecylia Bocovich 2022-10-18 14:55:50 -04:00
parent 90d1a56719
commit 6007d5e08e
No known key found for this signature in database
GPG key ID: 009DE379FD9B7B90
2 changed files with 7 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
proxy/lib/snowflake.go
View file

@ -384,8 +384,7 @@ func (sf *SnowflakeProxy) makePeerConnectionFromOffer(sdp *webrtc.SessionDescrip
close(dataChan) close(dataChan)
pr, pw := io.Pipe() pr, pw := io.Pipe()
conn := &webRTCConn{pc: pc, dc: dc, pr: pr, eventLogger: sf.EventDispatcher} conn := newWebRTCConn(pc, dc, pr, sf.EventDispatcher)
conn.bytesLogger = newBytesSyncLogger()
dc.OnOpen(func() { dc.OnOpen(func() {
log.Println("OnOpen channel") log.Println("OnOpen channel")

6
proxy/lib/webrtcconn.go
View file

@ -34,6 +34,12 @@ type webRTCConn struct {
eventLogger event.SnowflakeEventReceiver eventLogger event.SnowflakeEventReceiver
} }
func newWebRTCConn(pc *webrtc.PeerConnection, dc *webrtc.DataChannel, pr *io.PipeReader, eventLogger event.SnowflakeEventReceiver) (*webRTCConn) {
conn := &webRTCConn{pc: pc, dc: dc, pr: pr, eventLogger: eventLogger}
conn.bytesLogger = newBytesSyncLogger()
return conn
}
func (c *webRTCConn) Read(b []byte) (int, error) { func (c *webRTCConn) Read(b []byte) (int, error) {
return c.pr.Read(b) return c.pr.Read(b)
} }