anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Test fixes

Browse source
This commit is contained in:
mcrakhman 2024-06-17 23:23:28 +02:00
parent d6f75498de
commit b83feba0cc
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
6 changed files with 17 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

3
commonspace/spaceutils_test.go
View file

@ -560,6 +560,7 @@ func (c *streamOpener) OpenStream(ctx context.Context, p peer.Peer) (stream drpc
}
if err = objectStream.Send(&spacesyncproto.ObjectSyncMessage{
Payload: payload,
SpaceId: c.spaceId,
}); err != nil {
return
}
@ -639,6 +640,7 @@ func newFixtureWithData(t *testing.T, spaceId string, keys *accountdata.AccountK
Register(peerPool).
Register(rpctest.NewTestServer()).
Register(synctest.NewPeerProvider(keys.PeerId)).
Register(pool.New()).
Register(credentialprovider.NewNoOp()).
Register(&mockStatusServiceProvider{}).
Register(mockCoordinatorClient{}).
@ -735,5 +737,6 @@ func newMultiPeerFixture(t *testing.T, peerNum int) *multiPeerFixture {
func Test(t *testing.T) {
mpFixture := newMultiPeerFixture(t, 3)
time.Sleep(100 * time.Second)
mpFixture.Close()
}