armbian-router/main.go

package main

import (
	"github.com/go-chi/chi/v5"
	"github.com/go-chi/chi/v5/middleware"
	"github.com/oschwald/maxminddb-golang"
	"github.com/prometheus/client_golang/prometheus"
	"github.com/prometheus/client_golang/prometheus/promauto"
	"github.com/prometheus/client_golang/prometheus/promhttp"
	log "github.com/sirupsen/logrus"
	"github.com/spf13/viper"
	"net"
	"net/http"
	"net/url"
	"strings"
	"sync"
)

var (
	db      *maxminddb.Reader
	servers ServerList

	dlMap map[string]string

	redirectsServed = promauto.NewCounter(prometheus.CounterOpts{
		Name: "armbian_router_redirects",
		Help: "The total number of processed redirects",
	})

	downloadsMapped = promauto.NewCounter(prometheus.CounterOpts{
		Name: "armbian_router_download_maps",
		Help: "The total number of mapped download paths",
	})
)

// City represents a MaxmindDB city
type City struct {
	Location struct {
		Latitude  float64 `maxminddb:"latitude"`
		Longitude float64 `maxminddb:"longitude"`
	} `maxminddb:"location"`
}

func main() {
	viper.SetDefault("bind", ":8080")

	viper.SetConfigName("dlrouter")        // name of config file (without extension)
	viper.SetConfigType("yaml")            // REQUIRED if the config file does not have the extension in the name
	viper.AddConfigPath("/etc/dlrouter/")  // path to look for the config file in
	viper.AddConfigPath("$HOME/.dlrouter") // call multiple times to add many search paths
	viper.AddConfigPath(".")               // optionally look for config in the working directory
	err := viper.ReadInConfig()            // Find and read the config file

	if err != nil { // Handle errors reading the config file
		log.WithError(err).Fatalln("Unable to load config file")
	}

	db, err = maxminddb.Open(viper.GetString("geodb"))

	if err != nil {
		log.WithError(err).Fatalln("Unable to open database")
	}

	if mapFile := viper.GetString("dl_map"); mapFile != "" {
		log.WithField("file", mapFile).Info("Loading download map")

		dlMap, err = loadMap(mapFile)

		if err != nil {
			log.WithError(err).Fatalln("Unable to load download map")
		}
	}

	serverList := viper.GetStringSlice("servers")

	var wg sync.WaitGroup

	for _, server := range serverList {
		wg.Add(1)

		go func(server string) {
			defer wg.Done()

			addServer(server)
		}(server)
	}

	wg.Wait()

	log.Info("Servers added, checking statuses")

	// Start check loop
	go servers.checkLoop()

	log.Info("Starting")

	r := chi.NewRouter()

	r.Use(RealIPMiddleware)
	r.Use(middleware.Logger)

	r.HandleFunc("/status", statusHandler)
	r.HandleFunc("/mirrors", mirrorsHandler)
	r.HandleFunc("/reload", reloadHandler)
	r.HandleFunc("/dl_map", dlMapHandler)
	r.Handle("/metrics", promhttp.Handler())
	r.HandleFunc("/", redirectHandler)

	http.ListenAndServe(viper.GetString("bind"), r)
}

var metricReplacer = strings.NewReplacer(".", "_", "-", "_")

func addServer(server string) {
	var prefix string

	if !strings.HasPrefix(server, "http") {
		prefix = "https://"
	}

	u, err := url.Parse(prefix + server)

	if err != nil {
		log.WithFields(log.Fields{
			"error":  err,
			"server": server,
		}).Warning("Server is invalid")
		return
	}

	ips, err := net.LookupIP(u.Host)

	if err != nil {
		log.WithFields(log.Fields{
			"error":  err,
			"server": server,
		}).Warning("Could not resolve address")
		return
	}

	var city City
	err = db.Lookup(ips[0], &city)

	if err != nil {
		log.WithFields(log.Fields{
			"error":  err,
			"server": server,
		}).Warning("Could not geolocate address")
		return
	}

	redirects := promauto.NewCounter(prometheus.CounterOpts{
		Name: "armbian_router_redirects_" + metricReplacer.Replace(u.Host),
		Help: "The number of redirects for server " + u.Host,
	})

	servers = append(servers, &Server{
		Host:      u.Host,
		Path:      u.Path,
		Latitude:  city.Location.Latitude,
		Longitude: city.Location.Longitude,
		Redirects: redirects,
	})

	log.WithFields(log.Fields{
		"server":    u.Host,
		"path":      u.Path,
		"latitude":  city.Location.Latitude,
		"longitude": city.Location.Longitude,
	}).Info("Added server")
}