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