benjamyn/any-sync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix decode node types

Browse Source
This commit is contained in:
Sergey Cherepanov 2023-04-17 17:16:26 +02:00
parent cc24e38081
commit 7348f39eff
No known key found for this signature in database
GPG Key ID: 87F8EDE8FBDF637C
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
coordinator/nodeconfsource/nodeconfsource.go
View File

@ -4,6 +4,7 @@ import (
"context" "context"
"github.com/anytypeio/any-sync/app" "github.com/anytypeio/any-sync/app"
"github.com/anytypeio/any-sync/coordinator/coordinatorclient" "github.com/anytypeio/any-sync/coordinator/coordinatorclient"
"github.com/anytypeio/any-sync/coordinator/coordinatorproto"
"github.com/anytypeio/any-sync/nodeconf" "github.com/anytypeio/any-sync/nodeconf"
"time" "time"
) )
@ -41,9 +42,16 @@ func (n *nodeConfSource) GetLast(ctx context.Context, currentId string) (c nodec
} }
nodes := make([]nodeconf.Node, len(res.Nodes)) nodes := make([]nodeconf.Node, len(res.Nodes))
for i, node := range res.Nodes { for i, node := range res.Nodes {
types := make([]nodeconf.NodeType, len(node.Types)) types := make([]nodeconf.NodeType, 0, len(node.Types))
for j, nt := range node.Types { for _, nt := range node.Types {
types[j] = nodeconf.NodeType(nt) switch nt {
case coordinatorproto.NodeType_FileAPI:
types = append(types, nodeconf.NodeTypeFile)
case coordinatorproto.NodeType_CoordinatorAPI:
types = append(types, nodeconf.NodeTypeCoordinator)
case coordinatorproto.NodeType_TreeAPI:
types = append(types, nodeconf.NodeTypeTree)
}
} }
nodes[i] = nodeconf.Node{ nodes[i] = nodeconf.Node{
PeerId: node.PeerId, PeerId: node.PeerId,