[self-tests] add support for pytest-asyncio 1.0.0+

[stanislavlevin]

pytest-asyncio 1.0.0

removed the deprecated event_loop fixture. (#1106)

https://pytest-asyncio.readthedocs.io/en/latest/reference/changelog.html

This leads to tests errors like:

______________________ ERROR at setup of test_login_twice ______________________
file /usr/src/RPM/BUILD/python3-module-aioimaplib-2.0.1/tests/test_imapserver_imaplib2.py, line 43
  @pytest.mark.asyncio()
  async def test_login_twice(with_server):
      with pytest.raises(imaplib2.IMAP4.error) as expected:
          imap_client = await login_user('user', 'pass', lib=imaplib2.IMAP4)

          await asyncio.wait_for(
              asyncio.get_running_loop().run_in_executor(None, functools.partial(imap_client.login, 'user', 'pass')), 1)

          assert expected == 'command LOGIN illegal in state AUTH'
file /usr/src/RPM/BUILD/python3-module-aioimaplib-2.0.1/tests/server_fixture.py, line 38
  @pytest.fixture()
  def with_server(event_loop, request):
E       fixture 'event_loop' not found
>       available fixtures: _class_scoped_runner, _function_scoped_runner, _module_scoped_runner, _package_scoped_runner, _session_scoped_runner, anyio_backend, anyio_backend_name, anyio_backend_options, cache, capfd, capfdbinary, caplog, capsys, capsysbinary, capteesys, doctest_namespace, event_loop_policy, free_tcp_port, free_tcp_port_factory, free_udp_port, free_udp_port_factory, monkeypatch, pytestconfig, record_property, record_testsuite_property, record_xml_attribute, recwarn, tmp_path, tmp_path_factory, tmpdir, tmpdir_factory, unused_tcp_port, unused_tcp_port_factory, unused_udp_port, unused_udp_port_factory, with_server
>       use 'pytest --fixtures [testpath]' for help on them.

/usr/src/RPM/BUILD/python3-module-aioimaplib-2.0.1/tests/server_fixture.py:38

[cjwatson]

I tried to fix this, but I couldn't even get the tests to run with the version of pytest-asyncio listed in pyproject.toml. I just get lots of TimeoutError exceptions, like this:

pytest output

______________________________________________________________________________________________________________ test_file_with_attachment _______________________________________________________________________________________________________________

fut = <coroutine object IMAP4ClientProtocol.wait at 0x7f1bd179f1f0>, timeout = 1

    async def wait_for(fut, timeout):
        """Wait for the single Future or coroutine to complete, with timeout.

        Coroutine will be wrapped in Task.

        Returns result of the Future or coroutine.  When a timeout occurs,
        it cancels the task and raises TimeoutError.  To avoid the task
        cancellation, wrap it in shield().

        If the wait is cancelled, the task is also cancelled.

        If the task suppresses the cancellation and returns a value instead,
        that value is returned.

        This function is a coroutine.
        """
        # The special case for timeout <= 0 is for the following case:
        #
        # async def test_waitfor():
        #     func_started = False
        #
        #     async def func():
        #         nonlocal func_started
        #         func_started = True
        #
        #     try:
        #         await asyncio.wait_for(func(), 0)
        #     except asyncio.TimeoutError:
        #         assert not func_started
        #     else:
        #         assert False
        #
        # asyncio.run(test_waitfor())


        if timeout is not None and timeout <= 0:
            fut = ensure_future(fut)

            if fut.done():
                return fut.result()

            await _cancel_and_wait(fut)
            try:
                return fut.result()
            except exceptions.CancelledError as exc:
                raise TimeoutError from exc

        async with timeouts.timeout(timeout):
>           return await fut

/usr/lib/python3.13/asyncio/tasks.py:507:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
aioimaplib/aioimaplib.py:626: in wait
    await self.state_condition.wait_for(lambda: state_re.match(self.state))
/usr/lib/python3.13/asyncio/locks.py:313: in wait_for
    await self.wait()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <asyncio.locks.Condition object at 0x7f1bd17bb8c0 [unlocked]>

    async def wait(self):
        """Wait until notified.

        If the calling task has not acquired the lock when this
        method is called, a RuntimeError is raised.

        This method releases the underlying lock, and then blocks
        until it is awakened by a notify() or notify_all() call for
        the same condition variable in another task.  Once
        awakened, it re-acquires the lock and returns True.

        This method may return spuriously,
        which is why the caller should always
        re-check the state and be prepared to wait() again.
        """
        if not self.locked():
            raise RuntimeError('cannot wait on un-acquired lock')

        fut = self._get_loop().create_future()
        self.release()
        try:
            try:
                self._waiters.append(fut)
                try:
>                   await fut
E                   asyncio.exceptions.CancelledError

/usr/lib/python3.13/asyncio/locks.py:272: CancelledError

The above exception was the direct cause of the following exception:

with_server = <aioimaplib.imap_testing_server.MockImapServer object at 0x7f1bd22a0ad0>

    @pytest.mark.asyncio()
    async def test_file_with_attachment(with_server):
        with open(os.path.join(os.path.dirname(os.path.realpath(__file__)), 'data/test_attachment.eml'), mode='br') as msg:
>           imap_client = await login_user_async('user@mail', 'pass', select=True)

tests/test_acceptance_aioimaplib.py:31:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
tests/server_fixture.py:94: in login_user_async
    await imap_client.wait_hello_from_server()
aioimaplib/aioimaplib.py:727: in wait_hello_from_server
    await asyncio.wait_for(self.protocol.wait('AUTH|NONAUTH'), self.timeout)
/usr/lib/python3.13/asyncio/tasks.py:506: in wait_for
    async with timeouts.timeout(timeout):
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <Timeout [expired]>, exc_type = <class 'asyncio.exceptions.CancelledError'>, exc_val = CancelledError(), exc_tb = <traceback object at 0x7f1bd16cd800>

    async def __aexit__(
        self,
        exc_type: Optional[Type[BaseException]],
        exc_val: Optional[BaseException],
        exc_tb: Optional[TracebackType],
    ) -> Optional[bool]:
        assert self._state in (_State.ENTERED, _State.EXPIRING)

        if self._timeout_handler is not None:
            self._timeout_handler.cancel()
            self._timeout_handler = None

        if self._state is _State.EXPIRING:
            self._state = _State.EXPIRED

            if self._task.uncancel() <= self._cancelling and exc_type is not None:
                # Since there are no new cancel requests, we're
                # handling this.
                if issubclass(exc_type, exceptions.CancelledError):
>                   raise TimeoutError from exc_val
E                   TimeoutError

/usr/lib/python3.13/asyncio/timeouts.py:116: TimeoutError

Help? If I can get a passing baseline I can deal with the port to current pytest-asyncio ...