From 81c12b3f24a1d0512606e812739c14cb65d1ba5a Mon Sep 17 00:00:00 2001 From: Evgenii Stratonikov Date: Tue, 19 Oct 2021 16:47:03 +0300 Subject: [PATCH] Revert "[#152] netmap: allow only alphabet calls in `addPeer`" This reverts commit c008910157df3974f1feabccf91ea2fcac4e1ccf. --- netmap/netmap_contract.go | 25 +++++++++++------------- tests/netmap_test.go | 41 ++++++++++++--------------------------- 2 files changed, 23 insertions(+), 43 deletions(-) diff --git a/netmap/netmap_contract.go b/netmap/netmap_contract.go index e4b0d8f..dd5e80a 100644 --- a/netmap/netmap_contract.go +++ b/netmap/netmap_contract.go @@ -199,30 +199,27 @@ func AddPeer(nodeInfo []byte) { notaryDisabled := storage.Get(ctx, notaryDisabledKey).(bool) var ( // for invocation collection without notary - alphabet []common.IRNode - nodeKey []byte + alphabet []common.IRNode + nodeKey []byte + alphabetCall bool ) - publicKey := nodeInfo[2:35] // offset:2, len:33 - if notaryDisabled { alphabet = common.AlphabetNodes() nodeKey = common.InnerRingInvoker(alphabet) - if len(nodeKey) == 0 { - if !runtime.CheckWitness(publicKey) { - panic("addPeer: witness check failed") - } - runtime.Notify("AddPeer", nodeInfo) - return - } + alphabetCall = len(nodeKey) != 0 } else { multiaddr := common.AlphabetAddress() + alphabetCall = runtime.CheckWitness(multiaddr) + } + + if !alphabetCall { + publicKey := nodeInfo[2:35] // offset:2, len:33 if !runtime.CheckWitness(publicKey) { panic("addPeer: witness check failed") } - if !runtime.CheckWitness(multiaddr) { - panic("addPeer: alphabet witness check failed") - } + runtime.Notify("AddPeer", nodeInfo) + return } candidate := storageNode{ diff --git a/tests/netmap_test.go b/tests/netmap_test.go index 6f1cf25..bace4a6 100644 --- a/tests/netmap_test.go +++ b/tests/netmap_test.go @@ -68,46 +68,29 @@ func TestAddPeer(t *testing.T) { acc := NewAccount(t, bc) dummyInfo := dummyNodeInfo(acc) - tx := PrepareInvoke(t, bc, CommitteeAcc, h, "addPeer", dummyInfo) + acc1 := NewAccount(t, bc) + tx := PrepareInvoke(t, bc, acc1, h, "addPeer", dummyInfo) AddBlock(t, bc, tx) - CheckFault(t, bc, tx.Hash(), "addPeer: witness check failed") + CheckFault(t, bc, tx.Hash(), "witness check failed") tx = PrepareInvoke(t, bc, acc, h, "addPeer", dummyInfo) AddBlock(t, bc, tx) - CheckFault(t, bc, tx.Hash(), "addPeer: alphabet witness check failed") - - tx = PrepareInvoke(t, bc, []*wallet.Account{CommitteeAcc, acc}, h, "addPeer", dummyInfo) - AddBlockCheckHalt(t, bc, tx) - - tx = PrepareInvoke(t, bc, acc, h, "netmapCandidates") - AddBlock(t, bc, tx) - - checkNode := func(t *testing.T, info []byte, state int64, actual stackitem.Item) { - // Actual is netmap.netmapNode. - require.Equal(t, stackitem.NewStruct([]stackitem.Item{ - stackitem.NewStruct([]stackitem.Item{ - stackitem.NewByteArray(dummyInfo), - }), - stackitem.NewBigInteger(big.NewInt(state)), - }), actual) - } aer := CheckHalt(t, bc, tx.Hash()) - nodes, _ := aer.Stack[0].Value().([]stackitem.Item) - require.Equal(t, 1, len(nodes)) - checkNode(t, dummyInfo, 1, nodes[0]) + require.Equal(t, 1, len(aer.Events)) + require.Equal(t, "AddPeer", aer.Events[0].Name) + require.Equal(t, stackitem.NewArray([]stackitem.Item{stackitem.NewByteArray(dummyInfo)}), + aer.Events[0].Item) dummyInfo[0] ^= 0xFF - tx = PrepareInvoke(t, bc, []*wallet.Account{CommitteeAcc, acc}, h, "addPeer", dummyInfo) - AddBlockCheckHalt(t, bc, tx) - - tx = PrepareInvoke(t, bc, acc, h, "netmapCandidates") + tx = PrepareInvoke(t, bc, acc, h, "addPeer", dummyInfo) AddBlock(t, bc, tx) aer = CheckHalt(t, bc, tx.Hash()) - nodes, _ = aer.Stack[0].Value().([]stackitem.Item) - require.Equal(t, 1, len(nodes)) - checkNode(t, dummyInfo, 1, nodes[0]) + require.Equal(t, 1, len(aer.Events)) + require.Equal(t, "AddPeer", aer.Events[0].Name) + require.Equal(t, stackitem.NewArray([]stackitem.Item{stackitem.NewByteArray(dummyInfo)}), + aer.Events[0].Item) } func TestUpdateState(t *testing.T) {