Skip to content
This repository was archived by the owner on Aug 30, 2024. It is now read-only.

Commit d6fb8f4

Browse files
committed
Use TURNS by default
1 parent f889e54 commit d6fb8f4

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

internal/cmd/tunnel.go

+1-2
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,8 @@ type client struct {
110110

111111
func (c *client) start() error {
112112
url := fmt.Sprintf("%s%s%s%s%s", c.brokerAddr.String(), "/api/private/envagent/", c.id, "/connect?session_token=", c.token)
113-
tcpProxy := fmt.Sprintf("turn:%s:5349?transport=tcp", c.brokerAddr.Host)
113+
tcpProxy := fmt.Sprintf("turns:%s:5349?transport=tcp", c.brokerAddr.Host)
114114
c.logger.Info(c.ctx, "connecting to broker", slog.F("url", url), slog.F("tcp-proxy", tcpProxy))
115-
116115
conn, resp, err := websocket.Dial(c.ctx, url, nil)
117116
if err != nil && resp == nil {
118117
return fmt.Errorf("dial: %w", err)

internal/x/xwebrtc/conn.go

+6-1
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,17 @@
11
package xwebrtc
22

3-
import "github.com/pion/webrtc/v3"
3+
import (
4+
"time"
5+
6+
"github.com/pion/webrtc/v3"
7+
)
48

59
// NewPeerConnection creates a new peer connection.
610
// It uses the Google stun server by default.
711
func NewPeerConnection(servers []webrtc.ICEServer) (*webrtc.PeerConnection, error) {
812
se := webrtc.SettingEngine{}
913
se.DetachDataChannels()
14+
se.SetICETimeouts(time.Second*5, time.Second*5, time.Second*2)
1015
api := webrtc.NewAPI(webrtc.WithSettingEngine(se))
1116

1217
return api.NewPeerConnection(webrtc.Configuration{

0 commit comments

Comments
 (0)