1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798 |
- // Copyright (C) 2016 The Syncthing Authors.
- //
- // This Source Code Form is subject to the terms of the Mozilla Public
- // License, v. 2.0. If a copy of the MPL was not distributed with this file,
- // You can obtain one at https://mozilla.org/MPL/2.0/.
- package connections
- import (
- "context"
- "crypto/tls"
- "net/url"
- "time"
- "github.com/syncthing/syncthing/lib/config"
- "github.com/syncthing/syncthing/lib/connections/registry"
- "github.com/syncthing/syncthing/lib/dialer"
- "github.com/syncthing/syncthing/lib/protocol"
- "github.com/syncthing/syncthing/lib/relay/client"
- )
- func init() {
- dialers["relay"] = relayDialerFactory{}
- }
- type relayDialer struct {
- commonDialer
- }
- func (d *relayDialer) Dial(ctx context.Context, id protocol.DeviceID, uri *url.URL) (internalConn, error) {
- inv, err := client.GetInvitationFromRelay(ctx, uri, id, d.tlsCfg.Certificates, 10*time.Second)
- if err != nil {
- return internalConn{}, err
- }
- conn, err := client.JoinSession(ctx, inv)
- if err != nil {
- return internalConn{}, err
- }
- err = dialer.SetTCPOptions(conn)
- if err != nil {
- conn.Close()
- return internalConn{}, err
- }
- err = dialer.SetTrafficClass(conn, d.trafficClass)
- if err != nil {
- l.Debugln("Dial (BEP/relay): setting traffic class:", err)
- }
- var tc *tls.Conn
- if inv.ServerSocket {
- tc = tls.Server(conn, d.tlsCfg)
- } else {
- tc = tls.Client(conn, d.tlsCfg)
- }
- err = tlsTimedHandshake(tc)
- if err != nil {
- tc.Close()
- return internalConn{}, err
- }
- return newInternalConn(tc, connTypeRelayClient, false, d.wanPriority), nil
- }
- func (d *relayDialer) Priority(_ string) int {
- return d.wanPriority
- }
- type relayDialerFactory struct{}
- func (relayDialerFactory) New(opts config.OptionsConfiguration, tlsCfg *tls.Config, _ *registry.Registry, _ *lanChecker) genericDialer {
- return &relayDialer{commonDialer{
- trafficClass: opts.TrafficClass,
- reconnectInterval: time.Duration(opts.RelayReconnectIntervalM) * time.Minute,
- tlsCfg: tlsCfg,
- wanPriority: opts.ConnectionPriorityRelay,
- lanPriority: opts.ConnectionPriorityRelay,
- }}
- }
- func (relayDialerFactory) AlwaysWAN() bool {
- return true
- }
- func (relayDialerFactory) Valid(cfg config.Configuration) error {
- if !cfg.Options.RelaysEnabled {
- return errDisabled
- }
- return nil
- }
- func (relayDialerFactory) String() string {
- return "Relay Dialer"
- }
|