Compare commits
15 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 6a6cdfcfe8 | |||
| 8866650a47 | |||
| b1544c251c | |||
| 7ea3906d63 | |||
| 6e0bf95fdf | |||
| 472b014a74 | |||
| 30b15da87d | |||
| da38250465 | |||
| bdf0192ac5 | |||
| 194f03c86a | |||
| 634941a1ef | |||
| 1da505fd3d | |||
| 8d62bb0aae | |||
| e748babf08 | |||
| 71fafb1f21 |
+1
-1
@@ -52,7 +52,7 @@ func populateDNSManager(mgr *dns.Manager, m *cluster.Cluster) error {
|
|||||||
|
|
||||||
m.ForEachZone(func(z *cluster.Zone) bool {
|
m.ForEachZone(func(z *cluster.Zone) bool {
|
||||||
z.ForEachMachine(func(p *cluster.Machine) bool {
|
z.ForEachMachine(func(p *cluster.Machine) bool {
|
||||||
err = mgr.AddHost(ctx, z.Name, p.ID, p.IsActive(), p.PublicAddresses...)
|
err = mgr.AddHost(ctx, z.Name, p.ID, true, p.PublicAddresses...)
|
||||||
return err != nil
|
return err != nil
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
@@ -17,7 +17,6 @@ require (
|
|||||||
github.com/spf13/cobra v1.7.0
|
github.com/spf13/cobra v1.7.0
|
||||||
golang.org/x/crypto v0.14.0
|
golang.org/x/crypto v0.14.0
|
||||||
golang.org/x/net v0.17.0
|
golang.org/x/net v0.17.0
|
||||||
gopkg.in/gcfg.v1 v1.2.3
|
|
||||||
gopkg.in/yaml.v3 v3.0.1
|
gopkg.in/yaml.v3 v3.0.1
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -48,5 +47,4 @@ require (
|
|||||||
golang.org/x/text v0.13.0 // indirect
|
golang.org/x/text v0.13.0 // indirect
|
||||||
golang.org/x/tools v0.14.0 // indirect
|
golang.org/x/tools v0.14.0 // indirect
|
||||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
|
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
|
||||||
gopkg.in/warnings.v0 v0.1.2 // indirect
|
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -114,10 +114,6 @@ golang.org/x/tools v0.14.0/go.mod h1:uYBEerGOWcJyEORxN+Ek8+TT266gXkNlHdJBwexUsBg
|
|||||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
|
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
|
||||||
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
|
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
|
||||||
gopkg.in/gcfg.v1 v1.2.3 h1:m8OOJ4ccYHnx2f4gQwpno8nAX5OGOh7RLaaz0pj3Ogs=
|
|
||||||
gopkg.in/gcfg.v1 v1.2.3/go.mod h1:yesOnuUOFQAhST5vPY4nbZsb/huCgGGXlipJsBn0b3o=
|
|
||||||
gopkg.in/warnings.v0 v0.1.2 h1:wFXVbFY8DY5/xOe1ECiWdKCzZlxgshcYVNkBHstARME=
|
|
||||||
gopkg.in/warnings.v0 v0.1.2/go.mod h1:jksf8JmL6Qr/oQM2OXTHunEvvTAsrWBLb6OOjuVWRNI=
|
|
||||||
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||||
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
|
||||||
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||||
|
|||||||
@@ -67,6 +67,15 @@ func (m *Cluster) ReadFile(name string, args ...any) ([]byte, error) {
|
|||||||
return fs.ReadFile(m.dir, name)
|
return fs.ReadFile(m.dir, name)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// MkdirAll creates directories relative to the cluster's config directory
|
||||||
|
func (m *Cluster) MkdirAll(name string, args ...any) error {
|
||||||
|
if len(args) > 0 {
|
||||||
|
name = fmt.Sprintf(name, args...)
|
||||||
|
}
|
||||||
|
|
||||||
|
return fs.MkdirAll(m.dir, name, 0755)
|
||||||
|
}
|
||||||
|
|
||||||
// ReadLines reads a file from the cluster's config directory,
|
// ReadLines reads a file from the cluster's config directory,
|
||||||
// split by lines, trimmed, and accepting `#` to comment lines out.
|
// split by lines, trimmed, and accepting `#` to comment lines out.
|
||||||
func (m *Cluster) ReadLines(name string, args ...any) ([]string, error) {
|
func (m *Cluster) ReadLines(name string, args ...any) ([]string, error) {
|
||||||
@@ -104,12 +113,3 @@ func (m *Cluster) WriteStringFile(value string, name string, args ...any) error
|
|||||||
_, err = buf.WriteTo(f)
|
_, err = buf.WriteTo(f)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
// MkdirAll creates directories relative to the cluster's config directory
|
|
||||||
func (m *Cluster) MkdirAll(name string, args ...any) error {
|
|
||||||
if len(args) > 0 {
|
|
||||||
name = fmt.Sprintf(name, args...)
|
|
||||||
}
|
|
||||||
|
|
||||||
return fs.MkdirAll(m.dir, name, 0755)
|
|
||||||
}
|
|
||||||
|
|||||||
+26
-87
@@ -2,25 +2,17 @@ package cluster
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"io/fs"
|
"io/fs"
|
||||||
"path"
|
|
||||||
"sort"
|
"sort"
|
||||||
|
|
||||||
"darvaza.org/core"
|
"darvaza.org/core"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
|
||||||
// ZoneRegionsFileName indicates the file containing
|
|
||||||
// region names as references
|
|
||||||
ZoneRegionsFileName = "regions"
|
|
||||||
)
|
|
||||||
|
|
||||||
func (m *Cluster) scan(opts *ScanOptions) error {
|
func (m *Cluster) scan(opts *ScanOptions) error {
|
||||||
for _, fn := range []func(*ScanOptions) error{
|
for _, fn := range []func(*ScanOptions) error{
|
||||||
m.scanDirectory,
|
m.scanDirectory,
|
||||||
m.scanMachines,
|
m.scanMachines,
|
||||||
m.scanZoneIDs,
|
m.scanZoneIDs,
|
||||||
m.scanSort,
|
m.scanSort,
|
||||||
m.initRegions,
|
|
||||||
m.scanGateways,
|
m.scanGateways,
|
||||||
m.scanCephMonitors,
|
m.scanCephMonitors,
|
||||||
} {
|
} {
|
||||||
@@ -32,7 +24,7 @@ func (m *Cluster) scan(opts *ScanOptions) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Cluster) scanDirectory(opts *ScanOptions) error {
|
func (m *Cluster) scanDirectory(_ *ScanOptions) error {
|
||||||
// each directory is a zone
|
// each directory is a zone
|
||||||
entries, err := fs.ReadDir(m.dir, ".")
|
entries, err := fs.ReadDir(m.dir, ".")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -41,14 +33,16 @@ func (m *Cluster) scanDirectory(opts *ScanOptions) error {
|
|||||||
|
|
||||||
for _, e := range entries {
|
for _, e := range entries {
|
||||||
if e.IsDir() {
|
if e.IsDir() {
|
||||||
ok, err := m.scanSubdirectory(opts, e.Name())
|
z, err := m.newZone(e.Name())
|
||||||
switch {
|
switch {
|
||||||
case err != nil:
|
case err != nil:
|
||||||
return core.Wrap(err, e.Name())
|
return core.Wrap(err, e.Name())
|
||||||
case !ok:
|
case z.Machines.Len() == 0:
|
||||||
m.warn(nil).
|
z.warn(nil).
|
||||||
WithField("zone", e.Name()).
|
WithField("zone", z.Name).
|
||||||
Print("empty")
|
Print("empty")
|
||||||
|
default:
|
||||||
|
m.Zones = append(m.Zones, z)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -56,27 +50,6 @@ func (m *Cluster) scanDirectory(opts *ScanOptions) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Cluster) scanSubdirectory(_ *ScanOptions, name string) (bool, error) {
|
|
||||||
z, err := m.newZone(name)
|
|
||||||
switch {
|
|
||||||
case err != nil:
|
|
||||||
// somewhere went wrong scanning the subdirectory
|
|
||||||
return false, err
|
|
||||||
case z.Machines.Len() > 0:
|
|
||||||
// zones have machines and the regions they belong
|
|
||||||
m.Zones = append(m.Zones, z)
|
|
||||||
return true, nil
|
|
||||||
case len(z.Regions) > 0:
|
|
||||||
// regions have no machines but can include
|
|
||||||
// other regions
|
|
||||||
m.appendRegionRegions(name, z.Regions...)
|
|
||||||
return true, nil
|
|
||||||
default:
|
|
||||||
// empty
|
|
||||||
return false, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Cluster) newZone(name string) (*Zone, error) {
|
func (m *Cluster) newZone(name string) (*Zone, error) {
|
||||||
z := &Zone{
|
z := &Zone{
|
||||||
zones: m,
|
zones: m,
|
||||||
@@ -181,68 +154,34 @@ func (z *Zone) scan() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for _, e := range entries {
|
for _, e := range entries {
|
||||||
name := e.Name()
|
if e.IsDir() {
|
||||||
|
m := &Machine{
|
||||||
|
zone: z,
|
||||||
|
logger: z,
|
||||||
|
Name: e.Name(),
|
||||||
|
}
|
||||||
|
|
||||||
switch {
|
m.debug().
|
||||||
case name == ZoneRegionsFileName:
|
WithField("node", m.Name).
|
||||||
err = z.loadRegions()
|
|
||||||
case e.IsDir():
|
|
||||||
err = z.scanSubdirectory(name)
|
|
||||||
default:
|
|
||||||
z.warn(nil).
|
|
||||||
WithField("zone", z.Name).
|
WithField("zone", z.Name).
|
||||||
WithField("filename", name).
|
Print("found")
|
||||||
Print("unknown")
|
|
||||||
}
|
|
||||||
|
|
||||||
if err != nil {
|
if err := m.init(); err != nil {
|
||||||
return err
|
m.error(err).
|
||||||
|
WithField("node", m.Name).
|
||||||
|
WithField("zone", z.Name).
|
||||||
|
Print()
|
||||||
|
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
z.Machines = append(z.Machines, m)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (z *Zone) loadRegions() error {
|
|
||||||
filename := path.Join(z.Name, ZoneRegionsFileName)
|
|
||||||
regions, err := z.zones.ReadLines(filename)
|
|
||||||
|
|
||||||
if err == nil {
|
|
||||||
// parsed
|
|
||||||
err = z.appendRegions(regions...)
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, filename)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (z *Zone) scanSubdirectory(name string) error {
|
|
||||||
m := &Machine{
|
|
||||||
zone: z,
|
|
||||||
logger: z,
|
|
||||||
Name: name,
|
|
||||||
}
|
|
||||||
|
|
||||||
m.debug().
|
|
||||||
WithField("node", m.Name).
|
|
||||||
WithField("zone", z.Name).
|
|
||||||
Print("found")
|
|
||||||
|
|
||||||
if err := m.init(); err != nil {
|
|
||||||
m.error(err).
|
|
||||||
WithField("node", m.Name).
|
|
||||||
WithField("zone", z.Name).
|
|
||||||
Print()
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
z.Machines = append(z.Machines, m)
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetGateway returns the first gateway found, if none
|
// GetGateway returns the first gateway found, if none
|
||||||
// files will be created to enable the first [Machine] to
|
// files will be created to enable the first [Machine] to
|
||||||
// be one
|
// be one
|
||||||
|
|||||||
@@ -15,7 +15,6 @@ type Machine struct {
|
|||||||
ID int
|
ID int
|
||||||
Name string `json:"-" yaml:"-"`
|
Name string `json:"-" yaml:"-"`
|
||||||
|
|
||||||
Inactive bool `json:"inactive,omitempty" yaml:"inactive,omitempty"`
|
|
||||||
CephMonitor bool `json:"ceph_monitor,omitempty" yaml:"ceph_monitor,omitempty"`
|
CephMonitor bool `json:"ceph_monitor,omitempty" yaml:"ceph_monitor,omitempty"`
|
||||||
PublicAddresses []netip.Addr `json:"public,omitempty" yaml:"public,omitempty"`
|
PublicAddresses []netip.Addr `json:"public,omitempty" yaml:"public,omitempty"`
|
||||||
Rings []*RingInfo `json:"rings,omitempty" yaml:"rings,omitempty"`
|
Rings []*RingInfo `json:"rings,omitempty" yaml:"rings,omitempty"`
|
||||||
@@ -44,11 +43,6 @@ func (m *Machine) FullName() string {
|
|||||||
return strings.Join(name, ".")
|
return strings.Join(name, ".")
|
||||||
}
|
}
|
||||||
|
|
||||||
// IsActive indicates the machine is to be included in regions' DNS entries
|
|
||||||
func (m *Machine) IsActive() bool {
|
|
||||||
return !m.Inactive
|
|
||||||
}
|
|
||||||
|
|
||||||
// IsGateway tells if the Machine is a ring0 gateway
|
// IsGateway tells if the Machine is a ring0 gateway
|
||||||
func (m *Machine) IsGateway() bool {
|
func (m *Machine) IsGateway() bool {
|
||||||
_, ok := m.getRingInfo(0)
|
_, ok := m.getRingInfo(0)
|
||||||
|
|||||||
@@ -53,14 +53,6 @@ func (m *Machine) ReadFile(name string, args ...any) ([]byte, error) {
|
|||||||
return m.zone.zones.ReadFile(fullName)
|
return m.zone.zones.ReadFile(fullName)
|
||||||
}
|
}
|
||||||
|
|
||||||
// ReadLines reads a file from the machine's config directory,
|
|
||||||
// split by lines, trimmed, and accepting `#` to comment lines out.
|
|
||||||
func (m *Machine) ReadLines(name string, args ...any) ([]string, error) {
|
|
||||||
fullName := m.getFilename(name, args...)
|
|
||||||
|
|
||||||
return m.zone.zones.ReadLines(fullName)
|
|
||||||
}
|
|
||||||
|
|
||||||
// WriteStringFile writes the given content to a file on the machine's config directory
|
// WriteStringFile writes the given content to a file on the machine's config directory
|
||||||
func (m *Machine) WriteStringFile(value string, name string, args ...any) error {
|
func (m *Machine) WriteStringFile(value string, name string, args ...any) error {
|
||||||
fullName := m.getFilename(name, args...)
|
fullName := m.getFilename(name, args...)
|
||||||
|
|||||||
@@ -3,7 +3,6 @@ package cluster
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"net/netip"
|
"net/netip"
|
||||||
"os"
|
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
@@ -82,30 +81,7 @@ func (m *Machine) scan(_ *ScanOptions) error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return m.loadInactive()
|
return nil
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Machine) loadInactive() error {
|
|
||||||
data, err := m.ReadLines("region")
|
|
||||||
switch {
|
|
||||||
case os.IsNotExist(err):
|
|
||||||
// no file
|
|
||||||
return nil
|
|
||||||
case err != nil:
|
|
||||||
// read error
|
|
||||||
return err
|
|
||||||
default:
|
|
||||||
// look for "none"
|
|
||||||
for _, r := range data {
|
|
||||||
switch r {
|
|
||||||
case "none":
|
|
||||||
m.Inactive = true
|
|
||||||
default:
|
|
||||||
m.Inactive = false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// scanWrapUp is called once all machines have been scanned
|
// scanWrapUp is called once all machines have been scanned
|
||||||
|
|||||||
+4
-103
@@ -1,10 +1,5 @@
|
|||||||
package cluster
|
package cluster
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"path/filepath"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
var (
|
||||||
_ MachineIterator = (*Region)(nil)
|
_ MachineIterator = (*Region)(nil)
|
||||||
_ ZoneIterator = (*Region)(nil)
|
_ ZoneIterator = (*Region)(nil)
|
||||||
@@ -37,9 +32,7 @@ func (r *Region) ForEachMachine(fn func(*Machine) bool) {
|
|||||||
var term bool
|
var term bool
|
||||||
|
|
||||||
z.ForEachMachine(func(p *Machine) bool {
|
z.ForEachMachine(func(p *Machine) bool {
|
||||||
if p.IsActive() {
|
term = fn(p)
|
||||||
term = fn(p)
|
|
||||||
}
|
|
||||||
return term
|
return term
|
||||||
})
|
})
|
||||||
|
|
||||||
@@ -73,7 +66,7 @@ func (m *Cluster) initRegions(_ *ScanOptions) error {
|
|||||||
|
|
||||||
// bind first level regions and their zones
|
// bind first level regions and their zones
|
||||||
for name, zones := range regions {
|
for name, zones := range regions {
|
||||||
m.setRegionZones(name, zones...)
|
m.syncRegions(name, zones...)
|
||||||
}
|
}
|
||||||
|
|
||||||
// and combine zones to produce larger regions
|
// and combine zones to produce larger regions
|
||||||
@@ -86,10 +79,8 @@ func (m *Cluster) initRegions(_ *ScanOptions) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Cluster) setRegionZones(name string, zones ...*Zone) {
|
func (m *Cluster) syncRegions(name string, zones ...*Zone) {
|
||||||
for i := range m.Regions {
|
for _, r := range m.Regions {
|
||||||
r := &m.Regions[i]
|
|
||||||
|
|
||||||
if r.Name == name {
|
if r.Name == name {
|
||||||
// found
|
// found
|
||||||
r.m = m
|
r.m = m
|
||||||
@@ -106,38 +97,6 @@ func (m *Cluster) setRegionZones(name string, zones ...*Zone) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *Cluster) appendRegionRegions(name string, subs ...string) {
|
|
||||||
for i := range m.Regions {
|
|
||||||
r := &m.Regions[i]
|
|
||||||
|
|
||||||
if name == r.Name {
|
|
||||||
// found
|
|
||||||
r.Regions = append(r.Regions, subs...)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// new
|
|
||||||
m.Regions = append(m.Regions, Region{
|
|
||||||
Name: name,
|
|
||||||
Regions: subs,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
func (z *Zone) appendRegions(regions ...string) error {
|
|
||||||
for _, s := range regions {
|
|
||||||
// TODO: validate
|
|
||||||
z.debug().
|
|
||||||
WithField("zone", z.Name).
|
|
||||||
WithField("region", s).
|
|
||||||
Print("attached")
|
|
||||||
|
|
||||||
z.Regions = append(z.Regions, s)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *Cluster) finishRegion(r *Region) {
|
func (m *Cluster) finishRegion(r *Region) {
|
||||||
if r.m != nil {
|
if r.m != nil {
|
||||||
// ready
|
// ready
|
||||||
@@ -171,61 +130,3 @@ func (m *Cluster) getRegion(name string) (*Region, bool) {
|
|||||||
|
|
||||||
return nil, false
|
return nil, false
|
||||||
}
|
}
|
||||||
|
|
||||||
// SyncRegions writes to the file system the regions this [Zone]
|
|
||||||
// belongs to.
|
|
||||||
func (z *Zone) SyncRegions() error {
|
|
||||||
err := z.syncZoneRegions()
|
|
||||||
if err == nil {
|
|
||||||
z.ForEachMachine(func(p *Machine) bool {
|
|
||||||
if p.IsActive() {
|
|
||||||
err = p.RemoveFile("region")
|
|
||||||
} else {
|
|
||||||
err = p.WriteStringFile("none\n", "region")
|
|
||||||
}
|
|
||||||
return err != nil
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
func (z *Zone) syncZoneRegions() error {
|
|
||||||
name := filepath.Join(z.Name, "regions")
|
|
||||||
|
|
||||||
if len(z.Regions) > 0 {
|
|
||||||
var buf bytes.Buffer
|
|
||||||
|
|
||||||
for _, s := range z.Regions {
|
|
||||||
_, _ = buf.WriteString(s)
|
|
||||||
_, _ = buf.WriteRune('\n')
|
|
||||||
}
|
|
||||||
|
|
||||||
return z.zones.WriteStringFile(buf.String(), name)
|
|
||||||
}
|
|
||||||
|
|
||||||
return z.zones.RemoveFile(name)
|
|
||||||
}
|
|
||||||
|
|
||||||
// SyncRegions writes to the file system the regions covered
|
|
||||||
// by this meta-region
|
|
||||||
func (r *Region) SyncRegions() error {
|
|
||||||
name := filepath.Join(r.Name, "regions")
|
|
||||||
|
|
||||||
if len(r.Regions) > 0 {
|
|
||||||
var buf bytes.Buffer
|
|
||||||
|
|
||||||
for _, s := range r.Regions {
|
|
||||||
_, _ = buf.WriteString(s)
|
|
||||||
_, _ = buf.WriteRune('\n')
|
|
||||||
}
|
|
||||||
|
|
||||||
if err := r.m.MkdirAll(r.Name); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.m.WriteStringFile(buf.String(), name)
|
|
||||||
}
|
|
||||||
|
|
||||||
return r.m.RemoveFile(name)
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -6,7 +6,6 @@ func (m *Cluster) SyncAll() error {
|
|||||||
m.SyncMkdirAll,
|
m.SyncMkdirAll,
|
||||||
m.SyncAllWireguard,
|
m.SyncAllWireguard,
|
||||||
m.SyncAllCeph,
|
m.SyncAllCeph,
|
||||||
m.SyncAllRegions,
|
|
||||||
m.WriteHosts,
|
m.WriteHosts,
|
||||||
} {
|
} {
|
||||||
if err := fn(); err != nil {
|
if err := fn(); err != nil {
|
||||||
@@ -59,24 +58,3 @@ func (m *Cluster) SyncAllCeph() error {
|
|||||||
|
|
||||||
return m.WriteCephConfig(cfg)
|
return m.WriteCephConfig(cfg)
|
||||||
}
|
}
|
||||||
|
|
||||||
// SyncAllRegions rewrites all region data
|
|
||||||
func (m *Cluster) SyncAllRegions() error {
|
|
||||||
var err error
|
|
||||||
|
|
||||||
m.ForEachZone(func(z *Zone) bool {
|
|
||||||
err := z.SyncRegions()
|
|
||||||
return err != nil
|
|
||||||
})
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
m.ForEachRegion(func(r *Region) bool {
|
|
||||||
err = r.SyncRegions()
|
|
||||||
return err != nil
|
|
||||||
})
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|||||||
+9
-112
@@ -2,7 +2,6 @@ package wireguard
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"errors"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
"io"
|
"io"
|
||||||
"net/netip"
|
"net/netip"
|
||||||
@@ -10,8 +9,8 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"text/template"
|
"text/template"
|
||||||
|
|
||||||
|
"asciigoat.org/ini/basic"
|
||||||
"darvaza.org/core"
|
"darvaza.org/core"
|
||||||
"gopkg.in/gcfg.v1"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var configTemplate = template.Must(template.New("config").Funcs(template.FuncMap{
|
var configTemplate = template.Must(template.New("config").Funcs(template.FuncMap{
|
||||||
@@ -132,100 +131,6 @@ func (ep *EndpointAddress) FromString(s string) error {
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
type intermediateConfig struct {
|
|
||||||
Interface interfaceConfig
|
|
||||||
Peer peersConfig
|
|
||||||
}
|
|
||||||
|
|
||||||
func (v *intermediateConfig) Export() (*Config, error) {
|
|
||||||
var out Config
|
|
||||||
var err error
|
|
||||||
|
|
||||||
// Interface
|
|
||||||
out.Interface, err = v.Interface.Export()
|
|
||||||
if err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
// Peers
|
|
||||||
peers, ok := v.PeersCount()
|
|
||||||
if !ok {
|
|
||||||
return nil, errors.New("inconsistent Peer data")
|
|
||||||
}
|
|
||||||
|
|
||||||
for i := 0; i < peers; i++ {
|
|
||||||
p, err := v.ExportPeer(i)
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, "Peer[%v]:", i)
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
out.Peer = append(out.Peer, p)
|
|
||||||
}
|
|
||||||
|
|
||||||
return &out, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
type interfaceConfig struct {
|
|
||||||
Address netip.Addr
|
|
||||||
PrivateKey string
|
|
||||||
ListenPort uint16
|
|
||||||
}
|
|
||||||
|
|
||||||
func (p interfaceConfig) Export() (InterfaceConfig, error) {
|
|
||||||
var err error
|
|
||||||
|
|
||||||
out := InterfaceConfig{
|
|
||||||
Address: p.Address,
|
|
||||||
ListenPort: p.ListenPort,
|
|
||||||
}
|
|
||||||
|
|
||||||
if p.PrivateKey != "" {
|
|
||||||
out.PrivateKey, err = PrivateKeyFromBase64(p.PrivateKey)
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, "PrivateKey")
|
|
||||||
return InterfaceConfig{}, err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return out, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
type peersConfig struct {
|
|
||||||
PublicKey []string
|
|
||||||
Endpoint []string
|
|
||||||
AllowedIPs []string
|
|
||||||
}
|
|
||||||
|
|
||||||
func (v *intermediateConfig) ExportPeer(i int) (PeerConfig, error) {
|
|
||||||
var out PeerConfig
|
|
||||||
|
|
||||||
// Endpoint
|
|
||||||
s := v.Peer.Endpoint[i]
|
|
||||||
err := out.Endpoint.FromString(s)
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, "Endpoint")
|
|
||||||
return out, err
|
|
||||||
}
|
|
||||||
|
|
||||||
// PublicKey
|
|
||||||
out.PublicKey, err = PublicKeyFromBase64(v.Peer.PublicKey[i])
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, "PublicKey")
|
|
||||||
return out, err
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllowedIPs
|
|
||||||
s = v.Peer.AllowedIPs[i]
|
|
||||||
out.AllowedIPs, err = parseAllowedIPs(s)
|
|
||||||
if err != nil {
|
|
||||||
err = core.Wrap(err, "AllowedIPs")
|
|
||||||
return out, err
|
|
||||||
}
|
|
||||||
|
|
||||||
return out, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func parseAllowedIPs(data string) ([]netip.Prefix, error) {
|
func parseAllowedIPs(data string) ([]netip.Prefix, error) {
|
||||||
var out []netip.Prefix
|
var out []netip.Prefix
|
||||||
|
|
||||||
@@ -242,25 +147,17 @@ func parseAllowedIPs(data string) ([]netip.Prefix, error) {
|
|||||||
return out, nil
|
return out, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (v *intermediateConfig) PeersCount() (int, bool) {
|
|
||||||
c0 := len(v.Peer.Endpoint)
|
|
||||||
c1 := len(v.Peer.PublicKey)
|
|
||||||
c2 := len(v.Peer.AllowedIPs)
|
|
||||||
|
|
||||||
if c0 != c1 || c1 != c2 {
|
|
||||||
return 0, false
|
|
||||||
}
|
|
||||||
|
|
||||||
return c0, true
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewConfigFromReader parses a wgN.conf file
|
// NewConfigFromReader parses a wgN.conf file
|
||||||
func NewConfigFromReader(r io.Reader) (*Config, error) {
|
func NewConfigFromReader(r io.Reader) (*Config, error) {
|
||||||
temp := &intermediateConfig{}
|
doc, err := basic.Decode(r)
|
||||||
|
if err != nil {
|
||||||
if err := gcfg.ReadInto(temp, r); err != nil {
|
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
return temp.Export()
|
cfg, err := newConfigFromDocument(doc)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return cfg, nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,169 @@
|
|||||||
|
package wireguard
|
||||||
|
|
||||||
|
import (
|
||||||
|
"io/fs"
|
||||||
|
"strconv"
|
||||||
|
|
||||||
|
"asciigoat.org/ini/basic"
|
||||||
|
"darvaza.org/core"
|
||||||
|
)
|
||||||
|
|
||||||
|
type sectionHandler func(*Config, *basic.Section) error
|
||||||
|
|
||||||
|
var sectionMap = map[string]func(*Config, *basic.Section) error{
|
||||||
|
"Interface": loadInterfaceConfSection,
|
||||||
|
"Peer": loadPeerConfSection,
|
||||||
|
}
|
||||||
|
|
||||||
|
func loadConfSection(out *Config, src *basic.Section) error {
|
||||||
|
h, ok := sectionMap[src.Key]
|
||||||
|
if !ok {
|
||||||
|
return core.Wrap(fs.ErrInvalid, "unknown section %q", src.Key)
|
||||||
|
}
|
||||||
|
|
||||||
|
return h(out, src)
|
||||||
|
}
|
||||||
|
|
||||||
|
func loadInterfaceConfSection(out *Config, src *basic.Section) error {
|
||||||
|
var cfg InterfaceConfig
|
||||||
|
|
||||||
|
for _, field := range src.Fields {
|
||||||
|
if err := loadInterfaceConfField(&cfg, field); err != nil {
|
||||||
|
return core.Wrap(err, "Interface")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
out.Interface = cfg
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func loadPeerConfSection(out *Config, src *basic.Section) error {
|
||||||
|
var cfg PeerConfig
|
||||||
|
|
||||||
|
for _, field := range src.Fields {
|
||||||
|
if err := loadPeerConfField(&cfg, field); err != nil {
|
||||||
|
return core.Wrap(err, "Peer[%v]", len(out.Peer))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
out.Peer = append(out.Peer, cfg)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// revive:disable:cyclomatic
|
||||||
|
// revive:disable:cognitive-complexity
|
||||||
|
|
||||||
|
func loadInterfaceConfField(cfg *InterfaceConfig, field basic.Field) error {
|
||||||
|
// revive:enable:cyclomatic
|
||||||
|
// revive:enable:cognitive-complexity
|
||||||
|
|
||||||
|
// TODO: refactor when asciigoat's ini parser learns to do reflection
|
||||||
|
switch field.Key {
|
||||||
|
case "Address":
|
||||||
|
if !core.IsZero(cfg.Address) {
|
||||||
|
return core.Wrap(fs.ErrInvalid, "duplicate field %q", field.Key)
|
||||||
|
}
|
||||||
|
|
||||||
|
err := cfg.Address.UnmarshalText([]byte(field.Value))
|
||||||
|
switch {
|
||||||
|
case err != nil:
|
||||||
|
return core.Wrap(err, field.Key)
|
||||||
|
default:
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
case "PrivateKey":
|
||||||
|
if !core.IsZero(cfg.PrivateKey) {
|
||||||
|
return core.Wrap(fs.ErrInvalid, "duplicate field %q", field.Key)
|
||||||
|
}
|
||||||
|
|
||||||
|
err := cfg.PrivateKey.UnmarshalText([]byte(field.Value))
|
||||||
|
switch {
|
||||||
|
case err != nil:
|
||||||
|
return core.Wrap(err, field.Key)
|
||||||
|
default:
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
case "ListenPort":
|
||||||
|
if cfg.ListenPort > 0 {
|
||||||
|
return core.Wrap(fs.ErrInvalid, "duplicate field %q", field.Key)
|
||||||
|
}
|
||||||
|
|
||||||
|
u64, err := strconv.ParseUint(field.Value, 10, 16)
|
||||||
|
switch {
|
||||||
|
case err != nil:
|
||||||
|
return core.Wrap(err, field.Key)
|
||||||
|
case u64 == 0:
|
||||||
|
return core.Wrap(fs.ErrInvalid, "invalid %q value", field.Key)
|
||||||
|
default:
|
||||||
|
cfg.ListenPort = uint16(u64)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
return core.Wrap(fs.ErrInvalid, "unknown field %q", field.Key)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// revive:disable:cyclomatic
|
||||||
|
// revive:disable:cognitive-complexity
|
||||||
|
|
||||||
|
func loadPeerConfField(cfg *PeerConfig, field basic.Field) error {
|
||||||
|
// revive:enable:cyclomatic
|
||||||
|
// revive:enable:cognitive-complexity
|
||||||
|
|
||||||
|
switch field.Key {
|
||||||
|
case "PublicKey":
|
||||||
|
if !core.IsZero(cfg.PublicKey) {
|
||||||
|
return core.Wrap(fs.ErrInvalid, "duplicate field %q", field.Key)
|
||||||
|
}
|
||||||
|
|
||||||
|
err := cfg.PublicKey.UnmarshalText([]byte(field.Value))
|
||||||
|
switch {
|
||||||
|
case err != nil:
|
||||||
|
return core.Wrap(err, field.Key)
|
||||||
|
default:
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
case "Endpoint":
|
||||||
|
if cfg.Endpoint.String() != "" {
|
||||||
|
return core.Wrap(fs.ErrInvalid, "duplicate field %q", field.Key)
|
||||||
|
}
|
||||||
|
|
||||||
|
err := cfg.Endpoint.UnmarshalText([]byte(field.Value))
|
||||||
|
switch {
|
||||||
|
case err != nil:
|
||||||
|
return core.Wrap(err, field.Key)
|
||||||
|
default:
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
case "AllowedIPs":
|
||||||
|
s, err := parseAllowedIPs(field.Value)
|
||||||
|
switch {
|
||||||
|
case err != nil:
|
||||||
|
return core.Wrap(err, field.Key)
|
||||||
|
case len(s) > 0:
|
||||||
|
cfg.AllowedIPs = append(cfg.AllowedIPs, s...)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
default:
|
||||||
|
return core.Wrap(fs.ErrInvalid, "unknown field %q", field.Key)
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func newConfigFromDocument(doc *basic.Document) (*Config, error) {
|
||||||
|
var out Config
|
||||||
|
|
||||||
|
if len(doc.Global) > 0 {
|
||||||
|
err := core.Wrap(fs.ErrInvalid, "fields before the first section")
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
for i := range doc.Sections {
|
||||||
|
src := &doc.Sections[i]
|
||||||
|
if err := loadConfSection(&out, src); err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return &out, nil
|
||||||
|
}
|
||||||
+10
-8
@@ -54,23 +54,25 @@ func (pub PublicKey) String() string {
|
|||||||
// UnmarshalText loads the value from base64
|
// UnmarshalText loads the value from base64
|
||||||
func (key *PrivateKey) UnmarshalText(b []byte) error {
|
func (key *PrivateKey) UnmarshalText(b []byte) error {
|
||||||
v, err := PrivateKeyFromBase64(string(b))
|
v, err := PrivateKeyFromBase64(string(b))
|
||||||
if err != nil {
|
switch {
|
||||||
|
case err != nil:
|
||||||
return err
|
return err
|
||||||
|
default:
|
||||||
|
*key = v
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
*key = v
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// UnmarshalText loads the value from base64
|
// UnmarshalText loads the value from base64
|
||||||
func (pub *PublicKey) UnmarshalText(b []byte) error {
|
func (pub *PublicKey) UnmarshalText(b []byte) error {
|
||||||
v, err := PublicKeyFromBase64(string(b))
|
v, err := PublicKeyFromBase64(string(b))
|
||||||
if err != nil {
|
switch {
|
||||||
|
case err != nil:
|
||||||
return err
|
return err
|
||||||
|
default:
|
||||||
|
*pub = v
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
*pub = v
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// MarshalJSON encodes the key for JSON, omitting empty.
|
// MarshalJSON encodes the key for JSON, omitting empty.
|
||||||
|
|||||||
Reference in New Issue
Block a user