Function test_preprocess

tests/test_state.py:2387–2426

Test that a state hydrate event is processed correctly. Args: app_module_mock: The app module that will be returned by get_app(). token: A token. test_state: State to process event. expected: Expected delta. mocker: pytest mock object.

(app_module_mock, token, test_state, expected, mocker)

    ],
)
async def test_preprocess(app_module_mock, token, test_state, expected, mocker):
    """Test that a state hydrate event is processed correctly.

    Args:
        app_module_mock: The app module that will be returned by get_app().
        token: A token.
        test_state: State to process event.
        expected: Expected delta.
        mocker: pytest mock object.
    """
    mocker.patch("nextpy.state.State.class_subclasses", {test_state})
    app = app_module_mock.app = App(
        state=State, load_events={"index": [test_state.test_handler]}
    )
    state = State()

    updates = []
    async for update in xt.app.process(
        app=app,
        event=Event(
            token=token,
            name=f"{state.get_name()}.{CompileVars.ON_LOAD_INTERNAL}",
            router_data={RouteVar.PATH: "/", RouteVar.ORIGIN: "/", RouteVar.QUERY: {}},
        ),
        sid="sid",
        headers={},
        client_ip="",
    ):
        assert isinstance(update, StateUpdate)
        updates.append(update)
    assert len(updates) == 1
    assert updates[0].delta["state"].pop("router") is not None
    assert updates[0].delta == exp_is_hydrated(state, False)

    events = updates[0].events
    assert len(events) == 2
    assert (await state._process(events[0]).__anext__()).delta == {
        test_state.get_full_name(): {"num": 1}
    }
    assert (await state._process(events[1]).__anext__()).delta == exp_is_hydrated(state)


@pytest.mark.asyncio