Fix tests
This commit is contained in:
parent
0243ec0fca
commit
2d977ed535
@ -17,7 +17,6 @@ type Config struct {
|
|||||||
PeerId string `yaml:"peerId"`
|
PeerId string `yaml:"peerId"`
|
||||||
PeerKey string `yaml:"peerKey"`
|
PeerKey string `yaml:"peerKey"`
|
||||||
SigningKey string `yaml:"signingKey"`
|
SigningKey string `yaml:"signingKey"`
|
||||||
EncryptionKey string `yaml:"encryptionKey"`
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type ConfigGetter interface {
|
type ConfigGetter interface {
|
||||||
|
|||||||
@ -9,6 +9,7 @@ import (
|
|||||||
|
|
||||||
aclrecordproto "github.com/anytypeio/any-sync/commonspace/object/acl/aclrecordproto"
|
aclrecordproto "github.com/anytypeio/any-sync/commonspace/object/acl/aclrecordproto"
|
||||||
list "github.com/anytypeio/any-sync/commonspace/object/acl/list"
|
list "github.com/anytypeio/any-sync/commonspace/object/acl/list"
|
||||||
|
crypto "github.com/anytypeio/any-sync/util/crypto"
|
||||||
gomock "github.com/golang/mock/gomock"
|
gomock "github.com/golang/mock/gomock"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -160,6 +161,20 @@ func (mr *MockAclListMockRecorder) IterateFrom(arg0, arg1 interface{}) *gomock.C
|
|||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "IterateFrom", reflect.TypeOf((*MockAclList)(nil).IterateFrom), arg0, arg1)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "IterateFrom", reflect.TypeOf((*MockAclList)(nil).IterateFrom), arg0, arg1)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// KeyStorage mocks base method.
|
||||||
|
func (m *MockAclList) KeyStorage() crypto.KeyStorage {
|
||||||
|
m.ctrl.T.Helper()
|
||||||
|
ret := m.ctrl.Call(m, "KeyStorage")
|
||||||
|
ret0, _ := ret[0].(crypto.KeyStorage)
|
||||||
|
return ret0
|
||||||
|
}
|
||||||
|
|
||||||
|
// KeyStorage indicates an expected call of KeyStorage.
|
||||||
|
func (mr *MockAclListMockRecorder) KeyStorage() *gomock.Call {
|
||||||
|
mr.mock.ctrl.T.Helper()
|
||||||
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "KeyStorage", reflect.TypeOf((*MockAclList)(nil).KeyStorage))
|
||||||
|
}
|
||||||
|
|
||||||
// Lock mocks base method.
|
// Lock mocks base method.
|
||||||
func (m *MockAclList) Lock() {
|
func (m *MockAclList) Lock() {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
|
|||||||
@ -2,10 +2,10 @@ package exporter
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/acl/liststorage"
|
"github.com/anytypeio/any-sync/commonspace/object/acl/liststorage"
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/keychain"
|
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/tree/objecttree"
|
"github.com/anytypeio/any-sync/commonspace/object/tree/objecttree"
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/tree/treechangeproto"
|
"github.com/anytypeio/any-sync/commonspace/object/tree/treechangeproto"
|
||||||
"github.com/anytypeio/any-sync/commonspace/object/tree/treestorage"
|
"github.com/anytypeio/any-sync/commonspace/object/tree/treestorage"
|
||||||
|
"github.com/anytypeio/any-sync/util/crypto"
|
||||||
)
|
)
|
||||||
|
|
||||||
type DataConverter interface {
|
type DataConverter interface {
|
||||||
@ -48,7 +48,7 @@ func (t *treeExporter) ExportUnencrypted(tree objecttree.ReadableObjectTree) (er
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
changeBuilder := objecttree.NewChangeBuilder(keychain.NewKeychain(), tree.Header())
|
changeBuilder := objecttree.NewChangeBuilder(crypto.NewKeyStorage(), tree.Header())
|
||||||
putStorage := func(change *objecttree.Change) (err error) {
|
putStorage := func(change *objecttree.Change) (err error) {
|
||||||
var raw *treechangeproto.RawTreeChangeWithId
|
var raw *treechangeproto.RawTreeChangeWithId
|
||||||
raw, err = changeBuilder.Marshall(change)
|
raw, err = changeBuilder.Marshall(change)
|
||||||
@ -68,7 +68,7 @@ func (t *treeExporter) ExportUnencrypted(tree objecttree.ReadableObjectTree) (er
|
|||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
// that means that change is unencrypted
|
// that means that change is unencrypted
|
||||||
change.ReadKeyId = 0
|
change.ReadKeyId = ""
|
||||||
change.Data = data
|
change.Data = data
|
||||||
err = putStorage(change)
|
err = putStorage(change)
|
||||||
return err == nil
|
return err == nil
|
||||||
|
|||||||
@ -14,7 +14,6 @@ import (
|
|||||||
"github.com/anytypeio/any-sync/commonspace/settings/settingsstate"
|
"github.com/anytypeio/any-sync/commonspace/settings/settingsstate"
|
||||||
"github.com/anytypeio/any-sync/commonspace/settings/settingsstate/mock_settingsstate"
|
"github.com/anytypeio/any-sync/commonspace/settings/settingsstate/mock_settingsstate"
|
||||||
"github.com/anytypeio/any-sync/commonspace/spacestorage/mock_spacestorage"
|
"github.com/anytypeio/any-sync/commonspace/spacestorage/mock_spacestorage"
|
||||||
"github.com/anytypeio/any-sync/util/crypto"
|
|
||||||
"github.com/golang/mock/gomock"
|
"github.com/golang/mock/gomock"
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
"sync"
|
"sync"
|
||||||
@ -146,17 +145,12 @@ func TestSettingsObject_DeleteObject(t *testing.T) {
|
|||||||
fx.doc.state = &settingsstate.State{LastIteratedId: "someId"}
|
fx.doc.state = &settingsstate.State{LastIteratedId: "someId"}
|
||||||
fx.changeFactory.EXPECT().CreateObjectDeleteChange(delId, fx.doc.state, false).Return(res, nil)
|
fx.changeFactory.EXPECT().CreateObjectDeleteChange(delId, fx.doc.state, false).Return(res, nil)
|
||||||
|
|
||||||
accountData := &accountdata.AccountKeys{
|
accountData, err := accountdata.NewRandom()
|
||||||
Identity: []byte("id"),
|
require.NoError(t, err)
|
||||||
PeerKey: nil,
|
|
||||||
SignKey: &crypto.Ed25519PrivKey{},
|
|
||||||
EncKey: nil,
|
|
||||||
}
|
|
||||||
fx.account.EXPECT().Account().Return(accountData)
|
fx.account.EXPECT().Account().Return(accountData)
|
||||||
fx.syncTree.EXPECT().AddContent(gomock.Any(), objecttree.SignableChangeContent{
|
fx.syncTree.EXPECT().AddContent(gomock.Any(), objecttree.SignableChangeContent{
|
||||||
Data: res,
|
Data: res,
|
||||||
Key: accountData.SignKey,
|
Key: accountData.SignKey,
|
||||||
Identity: accountData.Identity,
|
|
||||||
IsSnapshot: false,
|
IsSnapshot: false,
|
||||||
IsEncrypted: false,
|
IsEncrypted: false,
|
||||||
}).Return(objecttree.AddResult{}, nil)
|
}).Return(objecttree.AddResult{}, nil)
|
||||||
|
|||||||
@ -27,7 +27,6 @@ func (c *Conn) Write(p []byte) (n int, err error) {
|
|||||||
if e := c.Conn.SetWriteDeadline(time.Now().Add(c.timeout)); e != nil {
|
if e := c.Conn.SetWriteDeadline(time.Now().Add(c.timeout)); e != nil {
|
||||||
log.Warn("can't set write deadline", zap.String("remoteAddr", c.RemoteAddr().String()))
|
log.Warn("can't set write deadline", zap.String("remoteAddr", c.RemoteAddr().String()))
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
nn, err := c.Conn.Write(p[n:])
|
nn, err := c.Conn.Write(p[n:])
|
||||||
n += nn
|
n += nn
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user