2024-09-16 16:11:10 +02:00
|
|
|
package client
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
|
|
|
|
auth "github.com/netbirdio/netbird/relay/auth/hmac"
|
|
|
|
)
|
|
|
|
|
|
|
|
const (
|
|
|
|
connectionTimeout = 30 * time.Second
|
|
|
|
maxConcurrentServers = 7
|
|
|
|
)
|
|
|
|
|
|
|
|
type connResult struct {
|
|
|
|
RelayClient *Client
|
|
|
|
Url string
|
|
|
|
Err error
|
|
|
|
}
|
|
|
|
|
|
|
|
type ServerPicker struct {
|
|
|
|
TokenStore *auth.TokenStore
|
|
|
|
PeerID string
|
|
|
|
}
|
|
|
|
|
|
|
|
func (sp *ServerPicker) PickServer(parentCtx context.Context, urls []string) (*Client, error) {
|
|
|
|
ctx, cancel := context.WithTimeout(parentCtx, connectionTimeout)
|
|
|
|
defer cancel()
|
|
|
|
|
|
|
|
totalServers := len(urls)
|
|
|
|
|
|
|
|
connResultChan := make(chan connResult, totalServers)
|
|
|
|
successChan := make(chan connResult, 1)
|
|
|
|
concurrentLimiter := make(chan struct{}, maxConcurrentServers)
|
2024-09-19 13:49:28 +02:00
|
|
|
|
2024-09-16 16:11:10 +02:00
|
|
|
for _, url := range urls {
|
2024-09-19 13:49:28 +02:00
|
|
|
// todo check if we have a successful connection so we do not need to connect to other servers
|
2024-09-16 16:11:10 +02:00
|
|
|
concurrentLimiter <- struct{}{}
|
|
|
|
go func(url string) {
|
2024-09-19 13:49:28 +02:00
|
|
|
defer func() {
|
|
|
|
<-concurrentLimiter
|
|
|
|
}()
|
2024-09-16 16:11:10 +02:00
|
|
|
sp.startConnection(parentCtx, connResultChan, url)
|
|
|
|
}(url)
|
|
|
|
}
|
|
|
|
|
|
|
|
go sp.processConnResults(connResultChan, successChan)
|
|
|
|
|
|
|
|
select {
|
|
|
|
case cr, ok := <-successChan:
|
|
|
|
if !ok {
|
|
|
|
return nil, errors.New("failed to connect to any relay server: all attempts failed")
|
|
|
|
}
|
|
|
|
log.Infof("chosen home Relay server: %s", cr.Url)
|
|
|
|
return cr.RelayClient, nil
|
|
|
|
case <-ctx.Done():
|
|
|
|
return nil, fmt.Errorf("failed to connect to any relay server: %w", ctx.Err())
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (sp *ServerPicker) startConnection(ctx context.Context, resultChan chan connResult, url string) {
|
|
|
|
log.Infof("try to connecting to relay server: %s", url)
|
|
|
|
relayClient := NewClient(ctx, url, sp.TokenStore, sp.PeerID)
|
|
|
|
err := relayClient.Connect()
|
|
|
|
resultChan <- connResult{
|
|
|
|
RelayClient: relayClient,
|
|
|
|
Url: url,
|
|
|
|
Err: err,
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (sp *ServerPicker) processConnResults(resultChan chan connResult, successChan chan connResult) {
|
|
|
|
var hasSuccess bool
|
2024-09-19 13:49:28 +02:00
|
|
|
for numOfResults := 0; numOfResults < cap(resultChan); numOfResults++ {
|
|
|
|
cr := <-resultChan
|
2024-09-16 16:11:10 +02:00
|
|
|
if cr.Err != nil {
|
|
|
|
log.Debugf("failed to connect to Relay server: %s: %v", cr.Url, cr.Err)
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
log.Infof("connected to Relay server: %s", cr.Url)
|
|
|
|
|
|
|
|
if hasSuccess {
|
|
|
|
log.Infof("closing unnecessary Relay connection to: %s", cr.Url)
|
|
|
|
if err := cr.RelayClient.Close(); err != nil {
|
|
|
|
log.Errorf("failed to close connection to %s: %v", cr.Url, err)
|
|
|
|
}
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
|
|
|
|
hasSuccess = true
|
|
|
|
successChan <- cr
|
|
|
|
}
|
|
|
|
close(successChan)
|
|
|
|
}
|