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

Nodes descriptions added

Browse Source
This commit is contained in:
Dmitry 2022-12-27 17:57:17 +08:00
parent 70163c3aaf
commit f86337ffc8
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
util/cmd/debug/commands/scripts.go
View File

@ -164,15 +164,15 @@ func (s *service) registerScripts() {
return space.Id
}
doesNodesContainDocument := func(docId string, spaceId string) map[string]bool {
var dictionary = map[string]bool{}
nodesDocumentHeads := func(docId string, spaceId string) map[string][]string {
var dictionary = map[string][]string{}
for _, node := range nodes {
resp, _ := s.node.TreeParams(context.Background(), node.address, &nodeproto.TreeParamsRequest{
SpaceId: spaceId,
DocumentId: docId,
})
dictionary[node.name] = resp.GetHeadIds() != nil
dictionary[node.name] = resp.GetHeadIds()
}
return dictionary
@ -211,7 +211,7 @@ func (s *service) registerScripts() {
if !contains {
print(fmt.Sprintf("%s doesn't contain a document %s", client.name, documentId))
fmt.Println(doesNodesContainDocument(documentId, spaceId))
fmt.Println(nodesDocumentHeads(documentId, spaceId))
} else {
print(fmt.Sprintf("%s contains a document %s", client.name, documentId))
}
@ -289,6 +289,7 @@ func (s *service) registerScripts() {
print(fmt.Sprintf("%s document %s head is %v", client2.name, docId, rs2.GetHeadIds()))
if rs1.GetHeadIds() == nil || rs1.GetHeadIds() == nil {
fmt.Println(nodesDocumentHeads(docId, spaceId))
print("Some head is nil")
return false
}