packages.valory.skills.abstract`_`round`_`abci.tests.test`_`handlers

Test the handlers.py module of the skill.

test`_`exception`_`to`_`info`_`msg

def test_exception_to_info_msg() -> None

Test 'exception_to_info_msg' helper function.

TestABCIRoundHandler Objects

class TestABCIRoundHandler()

Test 'ABCIRoundHandler'.

setup`_`method

def setup_method() -> None

Set up the tests.

test`_`info

def test_info() -> None

Test the 'info' handler method.

test`_`init`_`chain

@pytest.mark.parametrize("app_hash", (b"", b"test"))
def test_init_chain(app_hash: bytes) -> None

Test the 'init_chain' handler method.

test`_`begin`_`block

def test_begin_block() -> None

Test the 'begin_block' handler method.

test`_`check`_`tx

@mock.patch.object(handlers, "Transaction")
def test_check_tx(*_: Any) -> None

Test the 'check_tx' handler method.

test`_`check`_`tx`_`negative

@mock.patch.object(
    Transaction,
    "decode",
    side_effect=SignatureNotValidError,
)
def test_check_tx_negative(*_: Any) -> None

Test the 'check_tx' handler method, negative case.

test`_`deliver`_`tx

@mock.patch.object(handlers, "Transaction")
def test_deliver_tx(*_: Any) -> None

Test the 'deliver_tx' handler method.

test`_`deliver`_`tx`_`negative

@mock.patch.object(
    Transaction,
    "decode",
    side_effect=SignatureNotValidError,
)
def test_deliver_tx_negative(*_: Any) -> None

Test the 'deliver_tx' handler method, negative case.

test`_`deliver`_`bad`_`tx

@mock.patch.object(handlers, "Transaction")
def test_deliver_bad_tx(*_: Any) -> None

Test the 'deliver_tx' handler method, when the transaction is not ok.

test`_`end`_`block

@pytest.mark.parametrize("request_height", tuple(range(3)))
def test_end_block(request_height: int) -> None

Test the 'end_block' handler method.

test`_`commit

def test_commit() -> None

Test the 'commit' handler method.

test`_`commit`_`negative

def test_commit_negative() -> None

Test the 'commit' handler method, negative case.

ConcreteResponseHandler Objects

class ConcreteResponseHandler(AbstractResponseHandler)

A concrete response handler for testing purposes.

TestAbstractResponseHandler Objects

class TestAbstractResponseHandler()

Test 'AbstractResponseHandler'.

setup`_`method

def setup_method() -> None

Set up the tests.

test`_`handle

def test_handle() -> None

Test the 'handle' method.

test`_`handle`_`negative`_`cannot`_`recover`_`dialogues

@mock.patch.object(AbstractResponseHandler,
                   "_recover_protocol_dialogues",
                   return_value=None)
def test_handle_negative_cannot_recover_dialogues(*_: Any) -> None

Test the 'handle' method, negative case (cannot recover dialogues).

test`_`handle`_`negative`_`cannot`_`update`_`dialogues

@mock.patch.object(AbstractResponseHandler, "_recover_protocol_dialogues")
def test_handle_negative_cannot_update_dialogues(
        mock_dialogues_fn: Any) -> None

Test the 'handle' method, negative case (cannot update dialogues).

test`_`handle`_`negative`_`performative`_`not`_`allowed

def test_handle_negative_performative_not_allowed() -> None

Test the 'handle' method, negative case (performative not allowed).

test`_`handle`_`negative`_`cannot`_`find`_`callback

def test_handle_negative_cannot_find_callback() -> None

Test the 'handle' method, negative case (cannot find callback).

test`_`handle`_`swallows`_`and`_`logs`_`callback`_`exception

def test_handle_swallows_and_logs_callback_exception() -> None

A callback raising must be caught and logged, not propagated.

Drives the defensive except Exception branch added to AbstractResponseHandler.handle: without it, a faulty callback would tear the round behaviour down for the rest of the FSM.

TestTendermintHandler Objects

class TestTendermintHandler()

Test Tendermint Handler

setup`_`method

def setup_method() -> None

Set up the tests.

dummy`_`validator`_`config

@property
def dummy_validator_config() -> Dict[str, Dict[str, str]]

Dummy validator config

make`_`error`_`message

@staticmethod
def make_error_message() -> TendermintMessage

Make dummy error message

test`_`handle`_`unidentified`_`tendermint`_`dialogue

def test_handle_unidentified_tendermint_dialogue(
        caplog: LogCaptureFixture) -> None

Test unidentified tendermint dialogue

test`_`handle`_`no`_`addresses`_`retrieved`_`yet

def test_handle_no_addresses_retrieved_yet(caplog: LogCaptureFixture) -> None

Test handle request no registered addresses

test`_`handle`_`not`_`in`_`registered`_`addresses

def test_handle_not_in_registered_addresses(caplog: LogCaptureFixture) -> None

Test handle response sender not in registered addresses

test`_`handle`_`replies`_`when`_`acn`_`container`_`raises`_`value`_`error

def test_handle_replies_when_acn_container_raises_value_error(
        caplog: LogCaptureFixture) -> None

acn_container raises ValueError before FSM setup completes.

SharedState.round_sequence raises ValueError("round sequence not available") when the FSM hasn't started yet, and that propagates out of acn_container. The handler must catch it and reply with the canonical "FSM not yet initialised" Tendermint error instead of letting the exception escape the FSM loop.

test`_`handle`_`get`_`genesis`_`info

def test_handle_get_genesis_info(caplog: LogCaptureFixture) -> None

Test handle request for genesis info

test`_`handle`_`response`_`invalid`_`addresses

def test_handle_response_invalid_addresses(caplog: LogCaptureFixture) -> None

Test handle response for genesis info with invalid address.

test`_`handle`_`genesis`_`info

def test_handle_genesis_info(caplog: LogCaptureFixture) -> None

Test handle response for genesis info with valid address

test`_`recovery`_`params

@pytest.mark.parametrize("registered", (True, False))
@pytest.mark.parametrize(
    "performative",
    (
        TendermintMessage.Performative.RECOVERY_PARAMS,
        TendermintMessage.Performative.GET_RECOVERY_PARAMS,
    ),
)
def test_recovery_params(registered: bool,
                         performative: TendermintMessage.Performative,
                         caplog: LogCaptureFixture) -> None

Test handle response for recovery parameters.

test`_`recovery`_`params`_`error

@pytest.mark.parametrize(
    "side_effect, expected_exception",
    (
        (
            json.decoder.JSONDecodeError("", "", 0),
            ": line 1 column 1 (char 0)",
        ),
        (
            {"not a dict"},
            "argument after ** must be a mapping, not str",
        ),
    ),
)
def test_recovery_params_error(side_effect: Any, expected_exception: str,
                               caplog: LogCaptureFixture) -> None

Test handle response for recovery parameters.

test`_`handle`_`error

def test_handle_error(caplog: LogCaptureFixture) -> None

Test handle error

test`_`handle`_`error`_`no`_`target`_`message`_`retrieved

def test_handle_error_no_target_message_retrieved(
        caplog: LogCaptureFixture) -> None

Test handle error no target message retrieved

test`_`handle`_`performative`_`not`_`recognized

def test_handle_performative_not_recognized(caplog: LogCaptureFixture) -> None

Test performative no recognized

test`_`sender`_`not`_`in`_`registered`_`addresses

def test_sender_not_in_registered_addresses(caplog: LogCaptureFixture) -> None

Test sender not in registered addresses.

packages.valory.skills.abstract_round_abci.tests.test_handlers

test_exception_to_info_msg

TestABCIRoundHandler Objects

setup_method

test_info

test_init_chain

test_begin_block

test_check_tx

test_check_tx_negative

test_deliver_tx

test_deliver_tx_negative

test_deliver_bad_tx

test_end_block

test_commit

test_commit_negative

ConcreteResponseHandler Objects

TestAbstractResponseHandler Objects

setup_method

test_handle

test_handle_negative_cannot_recover_dialogues

test_handle_negative_cannot_update_dialogues

test_handle_negative_performative_not_allowed

test_handle_negative_cannot_find_callback

test_handle_swallows_and_logs_callback_exception

TestTendermintHandler Objects

setup_method

dummy_validator_config

make_error_message

test_handle_unidentified_tendermint_dialogue

test_handle_no_addresses_retrieved_yet

test_handle_not_in_registered_addresses

test_handle_replies_when_acn_container_raises_value_error

test_handle_get_genesis_info

test_handle_response_invalid_addresses

test_handle_genesis_info

test_recovery_params

test_recovery_params_error

test_handle_error

test_handle_error_no_target_message_retrieved

test_handle_performative_not_recognized

test_sender_not_in_registered_addresses

packages.valory.skills.abstract`_`round`_`abci.tests.test`_`handlers

test`_`exception`_`to`_`info`_`msg

setup`_`method

test`_`info

test`_`init`_`chain

test`_`begin`_`block

test`_`check`_`tx

test`_`check`_`tx`_`negative

test`_`deliver`_`tx

test`_`deliver`_`tx`_`negative

test`_`deliver`_`bad`_`tx

test`_`end`_`block

test`_`commit

test`_`commit`_`negative

setup`_`method

test`_`handle

test`_`handle`_`negative`_`cannot`_`recover`_`dialogues

test`_`handle`_`negative`_`cannot`_`update`_`dialogues

test`_`handle`_`negative`_`performative`_`not`_`allowed

test`_`handle`_`negative`_`cannot`_`find`_`callback

test`_`handle`_`swallows`_`and`_`logs`_`callback`_`exception

setup`_`method

dummy`_`validator`_`config

make`_`error`_`message

test`_`handle`_`unidentified`_`tendermint`_`dialogue

test`_`handle`_`no`_`addresses`_`retrieved`_`yet

test`_`handle`_`not`_`in`_`registered`_`addresses

test`_`handle`_`replies`_`when`_`acn`_`container`_`raises`_`value`_`error

test`_`handle`_`get`_`genesis`_`info

test`_`handle`_`response`_`invalid`_`addresses

test`_`handle`_`genesis`_`info

test`_`recovery`_`params

test`_`recovery`_`params`_`error

test`_`handle`_`error

test`_`handle`_`error`_`no`_`target`_`message`_`retrieved

test`_`handle`_`performative`_`not`_`recognized

test`_`sender`_`not`_`in`_`registered`_`addresses