Compare commits

..

4 Commits

Author SHA1 Message Date
amery c8c330d93a Merge branch 'pr-amery-k8s_token' into next-amery 2024-03-02 21:35:28 +00:00
amery 111951a86c Merge branch 'pr-amery-wireguard-ini' into next-amery 2024-03-02 21:35:24 +00:00
amery 3efe9c1d20 cluster: remove k8s_token files from zones on write if found
Signed-off-by: Alejandro Mery <amery@jpi.io>
2024-03-02 21:34:37 +00:00
amery 464c968381 cluster: introduce Region.Cluster and m/{region}/k8s_token
Signed-off-by: Alejandro Mery <amery@jpi.io>
2024-03-02 21:30:37 +00:00
2 changed files with 21 additions and 11 deletions
+16 -11
View File
@@ -4,6 +4,7 @@ import (
"io/fs"
"path"
"sort"
"strings"
"darvaza.org/core"
)
@@ -225,22 +226,26 @@ func (z *Zone) loadRegions() error {
}
func (z *Zone) loadClusterToken() error {
var token string
filename := path.Join(z.Name, RegionClusterTokenFileName)
lines, err := z.zones.ReadLines(filename)
if err == nil {
var token string
if err != nil {
return err
}
for _, s := range lines {
if s != "" {
token = s
break
}
// first non-empty line
for _, s := range lines {
s = strings.TrimSpace(s)
if s != "" {
token = s
break
}
}
err = z.zones.setRegionClusterToken(z.Name, token)
if err != nil {
err = core.Wrap(err, filename)
}
err = z.zones.setRegionClusterToken(z.Name, token)
if err != nil {
err = core.Wrap(err, filename)
}
return err
+5
View File
@@ -204,6 +204,11 @@ func (z *Zone) SyncRegions() error {
} else {
err = p.WriteStringFile("none\n", "region")
}
if err == nil {
err = p.RemoveFile(RegionClusterTokenFileName)
}
return err != nil
})
}