mirror of
https://github.com/MeshCore-Beacon/beacon-server.git
synced 2026-10-23 04:11:26 +00:00
MrAlders0n
0e242574fb
Imported boundaries override borderFile on the border map and for foreign marking, falling back to the manual border when MeshMapper has none.
99 lines
3.1 KiB
Go
99 lines
3.1 KiB
Go
// Copyright 2026 Beacon Contributors
|
|
// SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
package config
|
|
|
|
import (
|
|
"fmt"
|
|
"net/url"
|
|
"regexp"
|
|
"slices"
|
|
"time"
|
|
)
|
|
|
|
// MaxScopeSources bounds both network refresh work and imported matching keys.
|
|
const MaxScopeSources = 16
|
|
|
|
type MeshMapperConfig struct {
|
|
Scopes MeshMapperScopesConfig `yaml:"scopes"`
|
|
Zones MeshMapperZonesConfig `yaml:"zones"`
|
|
}
|
|
|
|
// MeshMapperZonesConfig imports each region IATA's published boundary, overriding borderFile.
|
|
type MeshMapperZonesConfig struct {
|
|
Enabled bool `yaml:"enabled"`
|
|
RefreshInterval duration `yaml:"refresh_interval"`
|
|
}
|
|
|
|
func (c MeshMapperZonesConfig) Interval() time.Duration {
|
|
if c.RefreshInterval.Duration == 0 {
|
|
return 24 * time.Hour
|
|
}
|
|
return c.RefreshInterval.Duration
|
|
}
|
|
|
|
// RegionIATAs returns the sorted, unique IATAs of every configured region.
|
|
func (c *Config) RegionIATAs() []string {
|
|
var iatas []string
|
|
for _, region := range c.Regions {
|
|
iatas = append(iatas, region.IATAs...)
|
|
}
|
|
slices.Sort(iatas)
|
|
return slices.Compact(iatas)
|
|
}
|
|
|
|
// MeshMapperScopesConfig augments, but never replaces, the manual scopes list.
|
|
type MeshMapperScopesConfig struct {
|
|
Enabled bool `yaml:"enabled"`
|
|
Sources map[string]string `yaml:"sources"` // configured IATA -> published regional endpoint
|
|
RefreshInterval duration `yaml:"refresh_interval"`
|
|
}
|
|
|
|
func (c MeshMapperScopesConfig) Interval() time.Duration {
|
|
if c.RefreshInterval.Duration == 0 {
|
|
return time.Hour
|
|
}
|
|
return c.RefreshInterval.Duration
|
|
}
|
|
|
|
var meshMapperHost = regexp.MustCompile(`^[a-z0-9][a-z0-9-]*\.meshmapper\.net$`)
|
|
|
|
func (c *Config) validateMeshMapper() error {
|
|
if z := c.MeshMapper.Zones; z.Enabled {
|
|
// The Zones API asks clients not to poll more than once an hour.
|
|
if z.Interval() < time.Hour || z.Interval() > 7*24*time.Hour {
|
|
return fmt.Errorf("meshmapper.zones.refresh_interval must be between 1h and 168h")
|
|
}
|
|
if len(c.RegionIATAs()) == 0 {
|
|
return fmt.Errorf("meshmapper.zones needs at least one configured region IATA")
|
|
}
|
|
}
|
|
s := c.MeshMapper.Scopes
|
|
if !s.Enabled {
|
|
return nil
|
|
}
|
|
if len(s.Sources) == 0 || len(s.Sources) > MaxScopeSources {
|
|
return fmt.Errorf("meshmapper.scopes.sources must contain 1-%d regional endpoints", MaxScopeSources)
|
|
}
|
|
if s.Interval() < 5*time.Minute || s.Interval() > 24*time.Hour {
|
|
return fmt.Errorf("meshmapper.scopes.refresh_interval must be between 5m and 24h")
|
|
}
|
|
configured := map[string]bool{}
|
|
for _, region := range c.Regions {
|
|
for _, iata := range region.IATAs {
|
|
configured[iata] = true
|
|
}
|
|
}
|
|
for iata, endpoint := range s.Sources {
|
|
if !configured[iata] {
|
|
return fmt.Errorf("meshmapper.scopes source %q must belong to a configured region", iata)
|
|
}
|
|
u, err := url.Parse(endpoint)
|
|
if err != nil || u.Scheme != "https" || u.User != nil || !meshMapperHost.MatchString(u.Host) ||
|
|
u.Path != "/get_scopes.php" || u.RawPath != "" || u.RawQuery != "" || u.ForceQuery || u.Fragment != "" {
|
|
return fmt.Errorf("meshmapper.scopes source %q must be a published https://<region>.meshmapper.net/get_scopes.php endpoint without credentials or parameters", iata)
|
|
}
|
|
}
|
|
return nil
|
|
}
|