gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-06 20:05:46 +08:00
Code Issues Projects Releases Packages Wiki Activity

add migrate fix on tags init

Browse source
This commit is contained in:
abhishek9686 2024-11-08 10:55:43 +04:00
parent a7ccf13cc8
commit ce93c9e0c1
2 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
logic/gateway.go
View file

@ -180,6 +180,9 @@ func CreateIngressGateway(netid string, nodeid string, ingress models.IngressReq
if node.Metadata == "" { if node.Metadata == "" {
node.Metadata = "This host can be used for remote access" node.Metadata = "This host can be used for remote access"
} }
if node.Tags == nil {
node.Tags = make(map[models.TagID]struct{})
}
node.Tags[models.TagID(fmt.Sprintf("%s.%s", netid, models.RemoteAccessTagName))] = struct{}{} node.Tags[models.TagID(fmt.Sprintf("%s.%s", netid, models.RemoteAccessTagName))] = struct{}{}
err = UpsertNode(&node) err = UpsertNode(&node)
if err != nil { if err != nil {

4
migrate/migrate.go
View file

@ -198,6 +198,10 @@ func updateNodes() {
} }
for _, node := range nodes { for _, node := range nodes {
node := node node := node
if node.Tags == nil {
node.Tags = make(map[models.TagID]struct{})
logic.UpsertNode(&node)
}
if node.IsIngressGateway { if node.IsIngressGateway {
tagID := models.TagID(fmt.Sprintf("%s.%s", node.Network, tagID := models.TagID(fmt.Sprintf("%s.%s", node.Network,
models.RemoteAccessTagName)) models.RemoteAccessTagName))