Function test_dynamic_var_event

tests/units/test_app.py:528–563

Test that the default handler of a dynamic generated var works as expected. Args: test_state: State Fixture. mock_base_state_event_processor: BaseStateEventProcessor Fixture. emitted_deltas: List to store emitted deltas. token: a Token. clean_registra

(
    test_state: type[ATestState],
    mock_base_state_event_processor: BaseStateEventProcessor,
    emitted_deltas: list[tuple[str, dict[str, dict[str, Any]]]],
    token: str,
    clean_registration_context: RegistrationContext,
)

@pytest.mark.asyncio
async def test_dynamic_var_event(
    test_state: type[ATestState],
    mock_base_state_event_processor: BaseStateEventProcessor,
    emitted_deltas: list[tuple[str, dict[str, dict[str, Any]]]],
    token: str,
    clean_registration_context: RegistrationContext,
):
    """Test that the default handler of a dynamic generated var
    works as expected.

    Args:
        test_state: State Fixture.
        mock_base_state_event_processor: BaseStateEventProcessor Fixture.
        emitted_deltas: List to store emitted deltas.
        token: a Token.
        clean_registration_context: The registration context fixture, which is cleared before each test.
    """
    clean_registration_context.register_base_state(test_state)
    state = test_state()  # pyright: ignore [reportCallIssue]
    state.add_var("int_val", int, 0)

    def set_int_val(self, value: int):
        self.int_val = value

    state._add_event_handler("set_int_val", set_int_val)
    async with mock_base_state_event_processor as processor:
        await processor.enqueue(
            token,
            Event(
                name=f"{test_state.get_name()}.set_int_val",
                payload={"value": 50},
            ),
        )
    assert emitted_deltas == [
        (token, {test_state.get_name(): {"int_val" + FIELD_MARKER: 50}})
    ]


@pytest.fixture