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

Further test comments and changes

Browse Source
This commit is contained in:
mcrakhman 2023-04-19 11:52:11 +02:00 committed by Mikhail Iudin
parent bb47f0aa21
commit bfb9ed1d83
No known key found for this signature in database
GPG Key ID: FAAAA8BAABDFF1C0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
commonspace/object/tree/synctree/syncprotocol_test.go
View File

@ -44,7 +44,7 @@ func TestEmptyClientGetsFullHistory(t *testing.T) {
fx.stop() fx.stop()
firstHeads := fx.handlers["peer1"].tree().Heads() firstHeads := fx.handlers["peer1"].tree().Heads()
secondHeads := fx.handlers["peer2"].tree().Heads() secondHeads := fx.handlers["peer2"].tree().Heads()
require.True(t, slice.SortedEquals(firstHeads, secondHeads)) require.True(t, slice.UnsortedEquals(firstHeads, secondHeads))
require.Equal(t, []string{"1"}, firstHeads) require.Equal(t, []string{"1"}, firstHeads)
logMsgs := fx.log.batcher.GetAll() logMsgs := fx.log.batcher.GetAll()
@ -94,6 +94,7 @@ func testTreeMerge(t *testing.T, levels, perlevel int, isSnapshot func() bool) {
prevHeads: []string{treeId}, prevHeads: []string{treeId},
isSnapshot: isSnapshot, isSnapshot: isSnapshot,
} }
// generating initial tree
initialRes := genChanges(changeCreator, params) initialRes := genChanges(changeCreator, params)
err = storage.TransactionAdd(initialRes.changes, initialRes.heads) err = storage.TransactionAdd(initialRes.changes, initialRes.heads)
require.NoError(t, err) require.NoError(t, err)
@ -128,6 +129,7 @@ func testTreeMerge(t *testing.T, levels, perlevel int, isSnapshot func() bool) {
prevHeads: initialRes.heads, prevHeads: initialRes.heads,
isSnapshot: isSnapshot, isSnapshot: isSnapshot,
} }
// generating different additions to the tree for different peers
peer1Res := genChanges(changeCreator, params) peer1Res := genChanges(changeCreator, params)
params.prefix = "peer2" params.prefix = "peer2"
peer2Res := genChanges(changeCreator, params) peer2Res := genChanges(changeCreator, params)