Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

INDY-1148 : change test for validation nodes txns #560

Merged
merged 8 commits into from
Mar 6, 2018
+59 −42
Merged

INDY-1148 : change test for validation nodes txns #560

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
f04c726
INDY-1148 - It's possible to create several nodes with the same alias…
Toktar Mar 5, 2018
859ba15
INDY-1148 - It's possible to create several nodes with the same alias…
Toktar Mar 5, 2018
366ca07
INDY-1148 - It's possible to create several nodes with the same alias…
Toktar Mar 5, 2018
e704bf7
Merge branch 'master' of https://github.com/hyperledger/indy-plenum i…
Toktar Mar 6, 2018
fe3e5f5
Merge branch 'master' of https://github.com/hyperledger/indy-plenum i…
Toktar Mar 6, 2018
1dddb8b
Merge branch 'master' of https://github.com/hyperledger/indy-plenum i…
Toktar Mar 6, 2018
e0f7db5
INDY-1148 : change test for validation nodes
Toktar Mar 6, 2018
4cf503b
INDY-1148 : move test for validate node alias
Toktar Mar 6, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 0 additions & 26 deletions plenum/test/pool_transactions/test_node_adding.py
View file
Open in desktop

This file was deleted.

75 changes: 59 additions & 16 deletions plenum/test/pool_transactions/test_nodes_with_pool_txns.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,15 +4,17 @@
import base58
import pytest

from plenum.common.exceptions import RequestRejectedException, RequestNackedException
from plenum.common.exceptions import RequestRejectedException, \
RequestNackedException
from plenum.test.node_request.helper import sdk_ensure_pool_functional

from plenum.common.constants import DATA, TARGET_NYM, \
NODE_IP, NODE_PORT, CLIENT_IP, CLIENT_PORT, STEWARD_STRING
from plenum.common.signer_simple import SimpleSigner
from plenum.common.util import getMaxFailures, randomString
from plenum.test import waits
from plenum.test.helper import sdk_send_random_and_check, sdk_get_and_check_replies
from plenum.test.helper import sdk_send_random_and_check, \
sdk_get_and_check_replies
from plenum.test.pool_transactions.helper import sdk_add_new_node, \
sdk_add_2_nodes, sdk_pool_refresh, sdk_add_new_nym, prepare_new_node_data, \
prepare_node_request, sdk_sign_and_send_prepared_request
Expand All @@ -27,7 +29,10 @@
# initialised a connection for a new node by the time the new node's message
# reaches it

def testStewardCannotAddMoreThanOneNode(looper, txnPoolNodeSet, sdk_pool_handle,


def testStewardCannotAddMoreThanOneNode(looper, txnPoolNodeSet,
sdk_pool_handle,
sdk_wallet_steward, tdir, tconf,
allPluginsPath):
new_node_name = "Epsilon"
Expand Down Expand Up @@ -69,7 +74,8 @@ def testClientConnectsToNewNode(looper,
"""
_, new_node = sdk_node_theta_added
logger.debug("{} connected to the pool".format(new_node))
sdk_send_random_and_check(looper, txnPoolNodeSet, sdk_pool_handle, sdk_wallet_client, 1)
sdk_send_random_and_check(looper, txnPoolNodeSet, sdk_pool_handle,
sdk_wallet_client, 1)


def testAdd2NewNodes(looper, txnPoolNodeSet,
Expand Down Expand Up @@ -112,7 +118,8 @@ def testStewardCannotAddNodeWithOutFullFieldsSet(looper, tdir, tconf,
new_steward_wallet_handle = sdk_add_new_nym(looper,
sdk_pool_handle,
sdk_wallet_steward,
alias='New steward' + randomString(3),
alias='New steward' + randomString(
3),
role=STEWARD_STRING)
sigseed, verkey, bls_key, nodeIp, nodePort, clientIp, clientPort = \
prepare_new_node_data(tconf, tdir, new_node_name)
Expand All @@ -129,12 +136,15 @@ def testStewardCannotAddNodeWithOutFullFieldsSet(looper, tdir, tconf,

# case from the ticket
request_json = json.loads(node_request)
request_json['operation'][DATA][NODE_PORT + ' '] = request_json['operation'][DATA][NODE_PORT]
request_json['operation'][DATA][NODE_PORT + ' '] = \
request_json['operation'][DATA][NODE_PORT]
del request_json['operation'][DATA][NODE_PORT]
node_request1 = json.dumps(request_json)

request_couple = sdk_sign_and_send_prepared_request(looper, new_steward_wallet_handle,
sdk_pool_handle, node_request1)
request_couple = sdk_sign_and_send_prepared_request(looper,
new_steward_wallet_handle,
sdk_pool_handle,
node_request1)
with pytest.raises(RequestNackedException) as e:
sdk_get_and_check_replies(looper, [request_couple])
assert 'unknown field' in e._excinfo[1].args[0]
Expand All @@ -143,8 +153,10 @@ def testStewardCannotAddNodeWithOutFullFieldsSet(looper, tdir, tconf,
request_json = json.loads(node_request)
del request_json['operation'][DATA][fn]
node_request2 = json.dumps(request_json)
request_couple = sdk_sign_and_send_prepared_request(looper, new_steward_wallet_handle,
sdk_pool_handle, node_request2)
request_couple = sdk_sign_and_send_prepared_request(looper,
new_steward_wallet_handle,
sdk_pool_handle,
node_request2)
# wait NAcks with exact message. it does not works for just 'is missed'
# because the 'is missed' will check only first few cases
with pytest.raises(RequestNackedException) as e:
Expand All @@ -156,8 +168,10 @@ def testNodesConnect(txnPoolNodeSet):
pass


def testNodesReceiveClientMsgs(looper, txnPoolNodeSet, sdk_wallet_client, sdk_pool_handle):
sdk_ensure_pool_functional(looper, txnPoolNodeSet, sdk_wallet_client, sdk_pool_handle)
def testNodesReceiveClientMsgs(looper, txnPoolNodeSet, sdk_wallet_client,
sdk_pool_handle):
sdk_ensure_pool_functional(looper, txnPoolNodeSet, sdk_wallet_client,
sdk_pool_handle)


def testAddNewClient(looper, txnPoolNodeSet, sdk_wallet_new_client):
Expand Down Expand Up @@ -207,8 +221,10 @@ def testStewardCannotAddNodeWithNonBase58VerKey(looper, tdir, tconf,
request_json['operation'][TARGET_NYM] = hexVerKey
node_request = json.dumps(request_json)

request_couple = sdk_sign_and_send_prepared_request(looper, sdk_wallet_new_steward,
sdk_pool_handle, node_request)
request_couple = sdk_sign_and_send_prepared_request(looper,
sdk_wallet_new_steward,
sdk_pool_handle,
node_request)
with pytest.raises(RequestNackedException) as e:
sdk_get_and_check_replies(looper, [request_couple])
assert 'should not contain the following chars' in e._excinfo[1].args[0]
Expand Down Expand Up @@ -254,12 +270,39 @@ def testStewardCannotAddNodeWithInvalidHa(looper, tdir, tconf,
request_json = json.loads(node_request)
request_json['operation'][DATA][field] = value
node_request1 = json.dumps(request_json)
request_couple = sdk_sign_and_send_prepared_request(looper, sdk_wallet_new_steward,
sdk_pool_handle, node_request1)
request_couple = sdk_sign_and_send_prepared_request(looper,
sdk_wallet_new_steward,
sdk_pool_handle,
node_request1)
# wait NAcks with exact message. it does not works for just 'is invalid'
# because the 'is invalid' will check only first few cases
with pytest.raises(RequestNackedException) as e:
sdk_get_and_check_replies(looper, [request_couple])
assert 'invalid network ip address' in e._excinfo[1].args[0] or \
'expected types' in e._excinfo[1].args[0] or \
'network port out of the range' in e._excinfo[1].args[0]


def test_add_node_with_not_unique_alias(looper,
tdir,
tconf,
sdk_pool_handle,
sdk_wallet_steward,
allPluginsPath):
new_node_name = "Alpha"
new_steward_wallet, steward_did = sdk_add_new_nym(looper,
sdk_pool_handle,
sdk_wallet_steward,
alias="TEST_STEWARD1",
role='STEWARD')
with pytest.raises(RequestRejectedException) as e:
sdk_add_new_node(looper,
sdk_pool_handle,
(new_steward_wallet, steward_did),
new_node_name,
tdir,
tconf,
allPluginsPath)
assert 'existing data has conflicts with request data' in \
e._excinfo[1].args[0]
sdk_pool_refresh(looper, sdk_pool_handle)