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

Make sync test

Browse Source
This commit is contained in:
mcrakhman 2022-09-30 14:21:48 +02:00 committed by Mikhail Iudin
parent 379a750f4e
commit 8c97888410
No known key found for this signature in database
GPG Key ID: FAAAA8BAABDFF1C0
2 changed files with 25 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
common/commonspace/diffservice/diffsyncer.go
View File

@ -27,12 +27,13 @@ func newDiffSyncer(
clientFactory spacesyncproto.ClientFactory, clientFactory spacesyncproto.ClientFactory,
log *zap.Logger) DiffSyncer { log *zap.Logger) DiffSyncer {
return &diffSyncer{ return &diffSyncer{
diff: diff, diff: diff,
nconf: nconf, nconf: nconf,
spaceId: spaceId, spaceId: spaceId,
cache: cache, cache: cache,
storage: storage, storage: storage,
log: log, clientFactory: clientFactory,
log: log,
} }
} }

19
common/commonspace/diffservice/diffsyncer_test.go
View File

@ -4,8 +4,10 @@ import (
"context" "context"
"github.com/anytypeio/go-anytype-infrastructure-experiments/app/logger" "github.com/anytypeio/go-anytype-infrastructure-experiments/app/logger"
"github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/cache" "github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/cache"
"github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/remotediff"
"github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/spacesyncproto" "github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/spacesyncproto"
"github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/storage" "github.com/anytypeio/go-anytype-infrastructure-experiments/common/commonspace/storage"
"github.com/anytypeio/go-anytype-infrastructure-experiments/common/net/peer"
"github.com/anytypeio/go-anytype-infrastructure-experiments/common/nodeconf" "github.com/anytypeio/go-anytype-infrastructure-experiments/common/nodeconf"
"github.com/anytypeio/go-anytype-infrastructure-experiments/pkg/ldiff" "github.com/anytypeio/go-anytype-infrastructure-experiments/pkg/ldiff"
"github.com/golang/mock/gomock" "github.com/golang/mock/gomock"
@ -30,5 +32,20 @@ func TestDiffSyncer_Sync(t *testing.T) {
spaceId := "spaceId" spaceId := "spaceId"
l := logger.NewNamed(spaceId) l := logger.NewNamed(spaceId)
diffSyncer := newDiffSyncer(spaceId, diffMock, nconfMock, cacheMock, stMock, factory, l) diffSyncer := newDiffSyncer(spaceId, diffMock, nconfMock, cacheMock, stMock, factory, l)
diffSyncer.Sync(ctx)
t.Run("diff syncer sync simple", func(t *testing.T) {
nconfMock.EXPECT().
ResponsiblePeers(gomock.Any(), spaceId).
Return([]peer.Peer{nil}, nil)
diffMock.EXPECT().
Diff(gomock.Any(), gomock.Eq(remotediff.NewRemoteDiff(spaceId, clientMock))).
Return([]string{"new"}, []string{"changed"}, nil, nil)
cacheMock.EXPECT().
GetTree(gomock.Any(), spaceId, "new").
Return(cache.TreeResult{}, nil)
cacheMock.EXPECT().
GetTree(gomock.Any(), spaceId, "changed").
Return(cache.TreeResult{}, nil)
_ = diffSyncer.Sync(ctx)
})
} }