diff --git a/pkg/morph/event/neofs/ir_update.go b/pkg/morph/event/neofs/ir_update.go new file mode 100644 index 0000000000..4230ab7f99 --- /dev/null +++ b/pkg/morph/event/neofs/ir_update.go @@ -0,0 +1,54 @@ +package neofs + +import ( + "crypto/elliptic" + + "github.com/nspcc-dev/neo-go/pkg/crypto/keys" + "github.com/nspcc-dev/neo-go/pkg/smartcontract" + "github.com/nspcc-dev/neofs-node/pkg/morph/client" + "github.com/nspcc-dev/neofs-node/pkg/morph/event" + "github.com/pkg/errors" +) + +type UpdateInnerRing struct { + keys []*keys.PublicKey +} + +// MorphEvent implements Neo:Morph Event interface. +func (UpdateInnerRing) MorphEvent() {} + +func (u UpdateInnerRing) Keys() []*keys.PublicKey { return u.keys } + +func ParseUpdateInnerRing(params []smartcontract.Parameter) (event.Event, error) { + var ( + ev UpdateInnerRing + err error + ) + + if ln := len(params); ln != 1 { + return nil, event.WrongNumberOfParameters(1, ln) + } + + // parse keys + irKeys, err := client.ArrayFromStackParameter(params[0]) + if err != nil { + return nil, errors.Wrap(err, "could not get updated inner ring keys") + } + + ev.keys = make([]*keys.PublicKey, 0, len(irKeys)) + for i := range irKeys { + rawKey, err := client.BytesFromStackParameter(irKeys[i]) + if err != nil { + return nil, errors.Wrap(err, "could not get updated inner ring public key") + } + + key, err := keys.NewPublicKeyFromBytes(rawKey, elliptic.P256()) + if err != nil { + return nil, errors.Wrap(err, "could not parse updated inner ring public key") + } + + ev.keys = append(ev.keys, key) + } + + return ev, nil +} diff --git a/pkg/morph/event/neofs/ir_update_test.go b/pkg/morph/event/neofs/ir_update_test.go new file mode 100644 index 0000000000..1aae124c43 --- /dev/null +++ b/pkg/morph/event/neofs/ir_update_test.go @@ -0,0 +1,77 @@ +package neofs + +import ( + "crypto/ecdsa" + "crypto/elliptic" + "testing" + + "github.com/nspcc-dev/neo-go/pkg/crypto/keys" + "github.com/nspcc-dev/neo-go/pkg/smartcontract" + crypto "github.com/nspcc-dev/neofs-crypto" + "github.com/nspcc-dev/neofs-crypto/test" + "github.com/nspcc-dev/neofs-node/pkg/morph/event" + "github.com/stretchr/testify/require" +) + +func TestParseUpdateInnerRing(t *testing.T) { + var ( + publicKeys = []*ecdsa.PublicKey{ + &test.DecodeKey(1).PublicKey, + &test.DecodeKey(2).PublicKey, + &test.DecodeKey(3).PublicKey, + } + ) + + t.Run("wrong number of parameters", func(t *testing.T) { + prms := []smartcontract.Parameter{ + {}, + {}, + } + + _, err := ParseUpdateInnerRing(prms) + require.EqualError(t, err, event.WrongNumberOfParameters(1, len(prms)).Error()) + }) + + t.Run("wrong first parameter", func(t *testing.T) { + _, err := ParseUpdateInnerRing([]smartcontract.Parameter{ + { + Type: smartcontract.ByteArrayType, + }, + }) + + require.Error(t, err) + }) + + t.Run("correct", func(t *testing.T) { + ev, err := ParseUpdateInnerRing([]smartcontract.Parameter{ + { + Type: smartcontract.ArrayType, + Value: []smartcontract.Parameter{ + { + Type: smartcontract.ByteArrayType, + Value: crypto.MarshalPublicKey(publicKeys[0]), + }, + { + Type: smartcontract.ByteArrayType, + Value: crypto.MarshalPublicKey(publicKeys[1]), + }, + { + Type: smartcontract.ByteArrayType, + Value: crypto.MarshalPublicKey(publicKeys[2]), + }, + }, + }, + }) + require.NoError(t, err) + + expKeys := make([]*keys.PublicKey, len(publicKeys)) + for i := range publicKeys { + expKeys[i], err = keys.NewPublicKeyFromBytes(crypto.MarshalPublicKey(publicKeys[i]), elliptic.P256()) + require.NoError(t, err) + } + + require.Equal(t, UpdateInnerRing{ + keys: expKeys, + }, ev) + }) +}