Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| c8c330d93a | |||
| 111951a86c | |||
| 3efe9c1d20 | |||
| 464c968381 |
+16
-11
@@ -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
|
||||
|
||||
@@ -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
|
||||
})
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user