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

refactor: separate function for connectToRelay

Browse source 
This should make the code easier to glance over,
to understand that relay connection is performed from inside
the datachannel handler.
This commit is contained in:
WofWca 2024-09-05 16:05:44 +04:00 • committed by Shelikhoo
parent 239357509f
commit c5d680342b
No known key found for this signature in database
GPG key ID: 4C9764E9FE80A3DC
1 changed files with 15 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

22
proxy/lib/snowflake.go
View file

@ -348,10 +348,21 @@ func (sf *SnowflakeProxy) datachannelHandler(conn *webRTCConn, remoteAddr net.Ad
relayURL = sf.RelayURL
}
wsConn, err := connectToRelay(relayURL, remoteAddr)
if err != nil {
log.Print(err)
return
}
defer wsConn.Close()
copyLoop(conn, wsConn, sf.shutdown)
log.Printf("datachannelHandler ends")
}
func connectToRelay(relayURL string, remoteAddr net.Addr) (*websocketconn.Conn, error) {
u, err := url.Parse(relayURL)
if err != nil {
log.Printf("invalid relay url: %s", err)
return
return nil, fmt.Errorf("invalid relay url: %s", err)
}
if remoteAddr != nil {
@ -366,15 +377,12 @@ func (sf *SnowflakeProxy) datachannelHandler(conn *webRTCConn, remoteAddr net.Ad
ws, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
if err != nil {
log.Printf("error dialing relay: %s = %s", u.String(), err)
return
return nil, fmt.Errorf("error dialing relay: %s = %s", u.String(), err)
}
wsConn := websocketconn.New(ws)
log.Printf("Connected to relay: %v", relayURL)
defer wsConn.Close()
copyLoop(conn, wsConn, sf.shutdown)
log.Printf("datachannelHandler ends")
return wsConn, nil
}
type dataChannelHandlerWithRelayURL struct {