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" "io/fs"
"path" "path"
"sort" "sort"
"strings"
"darvaza.org/core" "darvaza.org/core"
) )
@@ -225,22 +226,26 @@ func (z *Zone) loadRegions() error {
} }
func (z *Zone) loadClusterToken() error { func (z *Zone) loadClusterToken() error {
var token string
filename := path.Join(z.Name, RegionClusterTokenFileName) filename := path.Join(z.Name, RegionClusterTokenFileName)
lines, err := z.zones.ReadLines(filename) lines, err := z.zones.ReadLines(filename)
if err == nil { if err != nil {
var token string return err
}
for _, s := range lines { // first non-empty line
if s != "" { for _, s := range lines {
token = s s = strings.TrimSpace(s)
break if s != "" {
} token = s
break
} }
}
err = z.zones.setRegionClusterToken(z.Name, token) err = z.zones.setRegionClusterToken(z.Name, token)
if err != nil { if err != nil {
err = core.Wrap(err, filename) err = core.Wrap(err, filename)
}
} }
return err return err
+5
View File
@@ -204,6 +204,11 @@ func (z *Zone) SyncRegions() error {
} else { } else {
err = p.WriteStringFile("none\n", "region") err = p.WriteStringFile("none\n", "region")
} }
if err == nil {
err = p.RemoveFile(RegionClusterTokenFileName)
}
return err != nil return err != nil
}) })
} }