Compare commits
16 Commits
v20220306.
...
v20220307.
Author | SHA1 | Date | |
---|---|---|---|
7f01d016a4 | |||
5f3f234fff | |||
18f5d74402 | |||
71611fd754 | |||
310f59e03c | |||
a6992b2373 | |||
31859569fc | |||
d31571fc50 | |||
5eefe15b3b | |||
dbb84f0c0c | |||
6c839d7196 | |||
d2de3225b0 | |||
130a048394 | |||
0be7f66582 | |||
0f014cf9f3 | |||
230e89e2b7 |
7
.github/workflows/go.yml
vendored
7
.github/workflows/go.yml
vendored
@ -19,7 +19,12 @@ jobs:
|
|||||||
|
|
||||||
- name: Test
|
- name: Test
|
||||||
run: go test -v ./...
|
run: go test -v ./...
|
||||||
|
|
||||||
|
- name: Lint source code
|
||||||
|
run: |
|
||||||
|
make tools lint
|
||||||
|
rm -rf .bin
|
||||||
|
|
||||||
- name: Create release tag
|
- name: Create release tag
|
||||||
run: |
|
run: |
|
||||||
git tag "v$(git show -s --format=%cd --date=format:%Y%m%d.%H%M%S)"
|
git tag "v$(git show -s --format=%cd --date=format:%Y%m%d.%H%M%S)"
|
||||||
|
26
.golangci.yaml
Normal file
26
.golangci.yaml
Normal file
@ -0,0 +1,26 @@
|
|||||||
|
linters:
|
||||||
|
disable-all: true
|
||||||
|
enable:
|
||||||
|
- deadcode
|
||||||
|
- errcheck
|
||||||
|
- gofmt
|
||||||
|
- goimports
|
||||||
|
- gosimple
|
||||||
|
- ineffassign
|
||||||
|
- misspell
|
||||||
|
- staticcheck
|
||||||
|
- structcheck
|
||||||
|
- unconvert
|
||||||
|
- unused
|
||||||
|
- varcheck
|
||||||
|
- govet
|
||||||
|
|
||||||
|
linters-settings:
|
||||||
|
goimports:
|
||||||
|
local-prefixes: github.com/bastiandoetsch/mullvad-best-server
|
||||||
|
|
||||||
|
output:
|
||||||
|
format: tab
|
||||||
|
|
||||||
|
run:
|
||||||
|
deadline: 10m
|
@ -1,19 +1,20 @@
|
|||||||
project_name: mullvad-best-server
|
project_name: mullvad-best-server
|
||||||
# This is an example .goreleaser.yml file with some sensible defaults.
|
|
||||||
# Make sure to check the documentation at https://goreleaser.com
|
|
||||||
before:
|
before:
|
||||||
hooks:
|
hooks:
|
||||||
# You may remove this if you don't use go modules.
|
|
||||||
- go mod tidy
|
- go mod tidy
|
||||||
# you may remove this if you don't need go generate
|
|
||||||
- go generate ./...
|
|
||||||
builds:
|
builds:
|
||||||
|
- flags:
|
||||||
|
- -trimpath
|
||||||
- env:
|
- env:
|
||||||
- CGO_ENABLED=0
|
- CGO_ENABLED=0
|
||||||
goos:
|
goos:
|
||||||
- linux
|
- linux
|
||||||
- windows
|
- windows
|
||||||
- darwin
|
- darwin
|
||||||
|
mod_timestamp: "{{ .CommitTimestamp }}"
|
||||||
|
|
||||||
archives:
|
archives:
|
||||||
- replacements:
|
- replacements:
|
||||||
darwin: Darwin
|
darwin: Darwin
|
||||||
@ -21,10 +22,15 @@ archives:
|
|||||||
windows: Windows
|
windows: Windows
|
||||||
386: i386
|
386: i386
|
||||||
amd64: x86_64
|
amd64: x86_64
|
||||||
|
format: binary
|
||||||
|
name_template: "{{ .ProjectName }}_{{ .Version }}_{{ .Os }}_{{ .Arch }}"
|
||||||
|
|
||||||
checksum:
|
checksum:
|
||||||
name_template: 'checksums.txt'
|
name_template: 'checksums.txt'
|
||||||
|
|
||||||
snapshot:
|
snapshot:
|
||||||
name_template: "{{ incpatch .Version }}-next"
|
name_template: "{{ incpatch .Version }}-next"
|
||||||
|
|
||||||
changelog:
|
changelog:
|
||||||
sort: asc
|
sort: asc
|
||||||
filters:
|
filters:
|
||||||
|
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.
|
60
Makefile
Normal file
60
Makefile
Normal file
@ -0,0 +1,60 @@
|
|||||||
|
# project variables
|
||||||
|
PROJECT_NAME := mullvad-best-server
|
||||||
|
|
||||||
|
# build variables
|
||||||
|
.DEFAULT_GOAL = lint
|
||||||
|
BUILD_DIR := dist
|
||||||
|
DEV_GOARCH := $(shell go env GOARCH)
|
||||||
|
DEV_GOOS := $(shell go env GOOS)
|
||||||
|
|
||||||
|
|
||||||
|
## tools: Install required tooling.
|
||||||
|
.PHONY: tools
|
||||||
|
tools:
|
||||||
|
ifeq (,$(wildcard ./.bin/golangci-lint*))
|
||||||
|
@curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s -- -b .bin/ v1.44.2
|
||||||
|
else
|
||||||
|
@echo "==> Required tooling is already installed"
|
||||||
|
endif
|
||||||
|
|
||||||
|
## clean: Delete the build directory
|
||||||
|
.PHONY: clean
|
||||||
|
clean:
|
||||||
|
@echo "==> Removing '$(BUILD_DIR)' directory..."
|
||||||
|
@rm -rf $(BUILD_DIR)
|
||||||
|
|
||||||
|
## lint: Lint code with golangci-lint.
|
||||||
|
.PHONY: lint
|
||||||
|
lint: tools
|
||||||
|
@echo "==> Linting code with 'golangci-lint'..."
|
||||||
|
@.bin/golangci-lint run ./...
|
||||||
|
|
||||||
|
## test: Run all unit tests.
|
||||||
|
.PHONY: test
|
||||||
|
test:
|
||||||
|
@echo "==> Running unit tests..."
|
||||||
|
@mkdir -p $(BUILD_DIR)
|
||||||
|
@go test -count=1 -v -cover -coverprofile=$(BUILD_DIR)/coverage.out -parallel=4 ./...
|
||||||
|
|
||||||
|
## build: Build binary for default local system's OS and architecture.
|
||||||
|
.PHONY: build
|
||||||
|
build:
|
||||||
|
@echo "==> Building binary..."
|
||||||
|
@echo " running go build for GOOS=$(DEV_GOOS) GOARCH=$(DEV_GOARCH)"
|
||||||
|
# workaround for missing .exe extension on Windows
|
||||||
|
ifeq ($(OS),Windows_NT)
|
||||||
|
@go build -o $(BUILD_DIR)/$(PROJECT_NAME).$(DEV_GOOS).$(DEV_GOARCH).exe
|
||||||
|
else
|
||||||
|
@go build -o $(BUILD_DIR)/$(PROJECT_NAME).$(DEV_GOOS).$(DEV_GOARCH)
|
||||||
|
endif
|
||||||
|
|
||||||
|
.PHONY: run
|
||||||
|
run:
|
||||||
|
@echo "==> Running $(PROJECT_NAME)"
|
||||||
|
@go run main.go
|
||||||
|
|
||||||
|
help: Makefile
|
||||||
|
@echo "Usage: make <command>"
|
||||||
|
@echo ""
|
||||||
|
@echo "Commands:"
|
||||||
|
@sed -n 's/^##//p' $< | column -t -s ':' | sed -e 's/^/ /'
|
35
README.md
35
README.md
@ -1,13 +1,44 @@
|
|||||||
# mullvad-best-server
|
# mullvad-best-server
|
||||||
Determines the mullvat.net server with the lowest latency.
|

|
||||||
|
|
||||||
|
Determines the mullvad.net server with the lowest latency.
|
||||||
|
|
||||||
## Installation
|
## Installation
|
||||||
|
|
||||||
Download binary from releases for your platform and unpack.
|
Download binary from releases for your platform and unpack.
|
||||||
|
|
||||||
## Usage
|
## 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.
|
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
|
## Background
|
||||||
The program uses `https://api.mullvad.net/www/relays/wireguard/` to get the current server list, pings the ones with the right country
|
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.
|
and outputs the server with the lowest ping.
|
||||||
|
|
||||||
|
## Integration into a script
|
||||||
|
I use it on my router like this (yes, I know I could have done the whole thing with jq and shell scripting, but wanted to use go for maintainability).
|
||||||
|
```
|
||||||
|
#!/bin/sh
|
||||||
|
set -e
|
||||||
|
LATEST_RELEASE=$(curl -sSL https://api.github.com/repos/bastiandoetsch/mullvad-best-server/releases/latest | jq -r '.assets[]| .browser_download_url' | grep Linux_arm64)
|
||||||
|
curl -sSL $LATEST_RELEASE > /root/mullvad-best-server
|
||||||
|
chmod +x /root/mullvad-best-server
|
||||||
|
/usr/bin/wg-quick down $(wg show|grep interface | cut -d: -f2) || echo "nothing to shut down"
|
||||||
|
/usr/bin/wg-quick up "mullvad-$(/root/mullvad-best-server -c de)"
|
||||||
|
```
|
||||||
|
58
main.go
58
main.go
@ -2,43 +2,52 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"flag"
|
||||||
"fmt"
|
"fmt"
|
||||||
"github.com/go-ping/ping"
|
|
||||||
"github.com/rs/zerolog"
|
|
||||||
"github.com/rs/zerolog/log"
|
|
||||||
"io"
|
"io"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
)
|
|
||||||
|
|
||||||
var pings = make(map[string]time.Duration)
|
"github.com/go-ping/ping"
|
||||||
|
"github.com/rs/zerolog"
|
||||||
|
"github.com/rs/zerolog/log"
|
||||||
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
zerolog.SetGlobalLevel(zerolog.InfoLevel)
|
zerolog.SetGlobalLevel(zerolog.InfoLevel)
|
||||||
servers := getServers()
|
var outputFlag = flag.String("o", "", "Output format. 'json' outputs server json")
|
||||||
bestIndex := selectBestServerIndex(servers)
|
var countryFlag = flag.String("c", "ch", "Server country code, e.g. ch for Switzerland")
|
||||||
log.Debug().Interface("server", servers[bestIndex]).Msg("Best latency server found.")
|
var typeFlag = flag.String("t", "wireguard", "Server type, e.g. wireguard")
|
||||||
hostname := strings.Split(servers[bestIndex].Hostname, "-")[0]
|
flag.Parse()
|
||||||
fmt.Println(hostname)
|
|
||||||
|
servers := getServers(*typeFlag)
|
||||||
|
bestIndex := selectBestServerIndex(servers, *countryFlag)
|
||||||
|
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
|
bestIndex := -1
|
||||||
bestIndex := 0
|
var bestPing time.Duration
|
||||||
allowedCountries := map[string]string{}
|
|
||||||
allowedCountries["de"] = "1"
|
|
||||||
allowedCountries["ch"] = "1"
|
|
||||||
allowedCountries["at"] = "1"
|
|
||||||
for i, server := range servers {
|
for i, server := range servers {
|
||||||
if server.Active && allowedCountries[server.CountryCode] != "" {
|
if server.Active && server.CountryCode == country {
|
||||||
duration, err := serverLatency(server)
|
duration, err := serverLatency(server)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
pings[server.Hostname] = duration
|
if bestIndex == -1 || bestPing > duration {
|
||||||
if best == "" || pings[best] > pings[server.Hostname] {
|
|
||||||
best = server.Hostname
|
|
||||||
bestIndex = i
|
bestIndex = i
|
||||||
|
bestPing = duration
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -46,8 +55,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)
|
||||||
}
|
}
|
||||||
@ -58,6 +67,9 @@ func getServers() []server {
|
|||||||
log.Err(err)
|
log.Err(err)
|
||||||
}
|
}
|
||||||
}(resp.Body)
|
}(resp.Body)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal().Err(err)
|
||||||
|
}
|
||||||
var servers []server
|
var servers []server
|
||||||
err = json.Unmarshal(responseBody, &servers)
|
err = json.Unmarshal(responseBody, &servers)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Reference in New Issue
Block a user