Compare commits
12 Commits
v20220306.
...
v20220306.
Author | SHA1 | Date | |
---|---|---|---|
5eefe15b3b | |||
dbb84f0c0c | |||
6c839d7196 | |||
d2de3225b0 | |||
130a048394 | |||
0be7f66582 | |||
0f014cf9f3 | |||
230e89e2b7 | |||
20e1092604 | |||
2998e1d39d | |||
5821d890b8 | |||
2dfdb1ad74 |
2
.github/workflows/go.yml
vendored
2
.github/workflows/go.yml
vendored
@ -9,6 +9,8 @@ jobs:
|
|||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
|
with:
|
||||||
|
fetch-depth: 0
|
||||||
|
|
||||||
- name: Set up Go
|
- name: Set up Go
|
||||||
uses: actions/setup-go@v2
|
uses: actions/setup-go@v2
|
||||||
|
21
LICENSE
Normal file
21
LICENSE
Normal file
@ -0,0 +1,21 @@
|
|||||||
|
MIT License
|
||||||
|
|
||||||
|
Copyright (c) 2022 Bastian Doetsch
|
||||||
|
|
||||||
|
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
|
of this software and associated documentation files (the "Software"), to deal
|
||||||
|
in the Software without restriction, including without limitation the rights
|
||||||
|
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||||
|
copies of the Software, and to permit persons to whom the Software is
|
||||||
|
furnished to do so, subject to the following conditions:
|
||||||
|
|
||||||
|
The above copyright notice and this permission notice shall be included in all
|
||||||
|
copies or substantial portions of the Software.
|
||||||
|
|
||||||
|
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||||
|
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||||
|
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||||
|
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||||
|
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||||
|
SOFTWARE.
|
32
README.md
Normal file
32
README.md
Normal file
@ -0,0 +1,32 @@
|
|||||||
|
# mullvad-best-server
|
||||||
|

|
||||||
|
|
||||||
|
Determines the mullvat.net wireguard server with the lowest latency.
|
||||||
|
|
||||||
|
## Installation
|
||||||
|
|
||||||
|
Download binary from releases for your platform and unpack.
|
||||||
|
|
||||||
|
## Usage
|
||||||
|
### Default usage
|
||||||
|
Execute `mullvad-best-server`. It outputs the code, e.g. `de05`. You can then connect to it with e.g. wireguard using the normal shell scripts.
|
||||||
|
|
||||||
|
### Command line parameters
|
||||||
|
|
||||||
|
```angular2html
|
||||||
|
Usage of dist/mullvad-best-server_darwin_amd64/mullvad-best-server:
|
||||||
|
-c string
|
||||||
|
Server country code, e.g. ch for Switzerland (default "ch")
|
||||||
|
-o string
|
||||||
|
Output format. 'json' outputs server json
|
||||||
|
-t string
|
||||||
|
Server type, e.g. wireguard (default "wireguard")
|
||||||
|
```
|
||||||
|
|
||||||
|
If you want the full server information, execute `mullvad-best-server -o json`. It returns the full json output of the server information.
|
||||||
|
The `-c` flag allows to give a country code. Else `ch` will be used.
|
||||||
|
|
||||||
|
|
||||||
|
## Background
|
||||||
|
The program uses `https://api.mullvad.net/www/relays/<SERVER_TYPE/` to get the current server list, pings the ones with the right country
|
||||||
|
and outputs the server with the lowest ping.
|
48
main.go
48
main.go
@ -2,36 +2,60 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"flag"
|
||||||
|
"fmt"
|
||||||
"github.com/go-ping/ping"
|
"github.com/go-ping/ping"
|
||||||
|
"github.com/rs/zerolog"
|
||||||
"github.com/rs/zerolog/log"
|
"github.com/rs/zerolog/log"
|
||||||
"io"
|
"io"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
var pings = make(map[string]time.Duration)
|
var pings = make(map[string]time.Duration)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
zerolog.SetGlobalLevel(zerolog.InfoLevel)
|
||||||
|
var outputFlag = flag.String("o", "", "Output format. 'json' outputs server json")
|
||||||
|
var countryFlag = flag.String("c", "ch", "Server country code, e.g. ch for Switzerland")
|
||||||
|
var typeFlag = flag.String("t", "wireguard", "Server type, e.g. wireguard")
|
||||||
|
flag.Parse()
|
||||||
|
|
||||||
servers := getServers()
|
servers := getServers(*typeFlag)
|
||||||
bestIndex := selectBestServerIndex(servers)
|
bestIndex := selectBestServerIndex(servers, countryFlag)
|
||||||
log.Info().Interface("best", servers[bestIndex]).Msg("Best Latency Server found.")
|
best := servers[bestIndex]
|
||||||
|
log.Debug().Interface("server", best).Msg("Best latency server found.")
|
||||||
|
hostname := strings.TrimSuffix(best.Hostname, "-wireguard")
|
||||||
|
if *outputFlag != "json" {
|
||||||
|
fmt.Println(hostname)
|
||||||
|
} else {
|
||||||
|
serverJson, err := json.Marshal(best)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal().Err(err)
|
||||||
|
}
|
||||||
|
fmt.Println(string(serverJson))
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func selectBestServerIndex(servers []server) int {
|
func selectBestServerIndex(servers []server, country *string) int {
|
||||||
best := servers[0].Hostname
|
best := servers[0].Hostname
|
||||||
bestIndex := 0
|
bestIndex := -1
|
||||||
allowedCountries := map[string]string{}
|
allowedCountries := map[string]string{}
|
||||||
allowedCountries["de"] = "1"
|
if *country == "" {
|
||||||
allowedCountries["ch"] = "1"
|
allowedCountries["de"] = "1"
|
||||||
allowedCountries["at"] = "1"
|
allowedCountries["ch"] = "1"
|
||||||
|
allowedCountries["at"] = "1"
|
||||||
|
} else {
|
||||||
|
allowedCountries[*country] = "1"
|
||||||
|
}
|
||||||
for i, server := range servers {
|
for i, server := range servers {
|
||||||
if server.Active && allowedCountries[server.CountryCode] != "" {
|
if server.Active && allowedCountries[server.CountryCode] != "" {
|
||||||
duration, err := serverLatency(server)
|
duration, err := serverLatency(server)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
pings[server.Hostname] = duration
|
pings[server.Hostname] = duration
|
||||||
if best == "" || pings[best] > pings[server.Hostname] {
|
if bestIndex == -1 || pings[best] > pings[server.Hostname] {
|
||||||
best = server.Hostname
|
best = server.Hostname
|
||||||
bestIndex = i
|
bestIndex = i
|
||||||
}
|
}
|
||||||
@ -41,8 +65,8 @@ func selectBestServerIndex(servers []server) int {
|
|||||||
return bestIndex
|
return bestIndex
|
||||||
}
|
}
|
||||||
|
|
||||||
func getServers() []server {
|
func getServers(serverType string) []server {
|
||||||
resp, err := http.Get("https://api.mullvad.net/www/relays/wireguard/")
|
resp, err := http.Get("https://api.mullvad.net/www/relays/" + serverType + "/")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal().Err(err)
|
log.Fatal().Err(err)
|
||||||
}
|
}
|
||||||
@ -69,7 +93,7 @@ func serverLatency(s server) (time.Duration, error) {
|
|||||||
}
|
}
|
||||||
var duration time.Duration
|
var duration time.Duration
|
||||||
pinger.OnRecv = func(pkt *ping.Packet) {
|
pinger.OnRecv = func(pkt *ping.Packet) {
|
||||||
log.Info().Str("Server", s.Hostname).IPAddr("IP", pkt.IPAddr.IP).Dur("RTT", pkt.Rtt).Msg("Added server latency.")
|
log.Debug().Str("Server", s.Hostname).IPAddr("IP", pkt.IPAddr.IP).Dur("RTT", pkt.Rtt).Msg("Added server latency.")
|
||||||
duration = pkt.Rtt
|
duration = pkt.Rtt
|
||||||
}
|
}
|
||||||
err = pinger.Run()
|
err = pinger.Run()
|
||||||
|
Reference in New Issue
Block a user