tests/e2e_tests: drop synchronous test client

Due to `fastapi` version change, the newer `TestClient` from
`fastapi` is causing issues by creating its own different event
loop (Reference: https://www.starlette.io/testclient/).
That conflicts with the event loop of database client created in
the app startup handler.
Fix the below error by using async test client for all the tests:
```
@pytest.fixture(scope='session')
def test_client():
    """Fixture to get FastAPI Test client instance"""
       with TestClient(app=versioned_app, base_url=BASE_URL) as client:

tests/e2e_tests/conftest.py:36:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

api/main.py:87: in initialize_beanie
    await db.initialize_beanie()
api/db.py:51: in initialize_beanie
    await init_beanie(
.local/lib/python3.11/site-packages/beanie/odm/utils/init.py:750: in init_beanie
    await Initializer(
.local/lib/python3.11/site-packages/beanie/odm/utils/init.py:128: in __await__
    yield from self.init_class(model).__await__()
.local/lib/python3.11/site-packages/beanie/odm/utils/init.py:713: in init_class
    await self.init_document(cls)
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <beanie.odm.utils.init.Initializer object at 0x7457d1843cd0>
cls = <class 'api.models.User'>

>      build_info = await self.database.command({"buildInfo": 1})
E      RuntimeError: Task <Task pending name='anyio.from_thread.BlockingPortal._call_func' coro=<BlockingPortal._call_func() running at /home/kernelci/.local/lib/python3.11/site-packages/anyio/from_thread.py:217> cb=[TaskGroup._spawn.<locals>.task_done() at /home/kernelci/.local/lib/python3.11/site-packages/anyio/_backends/_asyncio.py:699]> got Future <Future pending cb=[_chain_future.<locals>._call_check_cancel() at /usr/local/lib/python3.11/asyncio/futures.py:387]> attached to a different loop

.local/lib/python3.11/site-packages/beanie/odm/utils/init.py:545: RuntimeError
```

Signed-off-by: Jeny Sadadia <jeny.sadadia@collabora.com>

Author: Jeny Sadadia

tests/e2e_tests/conftest.py

@@ -10,8 +10,6 @@
 from httpx import AsyncClient
 from motor.motor_asyncio import AsyncIOMotorClient
 
-from fastapi.testclient import TestClient
-
 from api.main import versioned_app
 from kernelci.api.models import Node, Regression
 
@@ -30,12 +28,6 @@
     'offset',
 }
 
-@pytest.fixture(scope='session')
-def test_client():
-    """Fixture to get FastAPI Test client instance"""
-    with TestClient(app=versioned_app, base_url=BASE_URL) as client:
-        yield client
-
 
 @pytest.fixture(scope='session')
 async def test_async_client():

tests/e2e_tests/test_count_handler.py

@@ -10,33 +10,35 @@
 import pytest
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=[
         'tests/e2e_tests/test_pipeline.py::test_node_pipeline'],
     scope='session')
-def test_count_nodes(test_client):
+async def test_count_nodes(test_async_client):
     """
     Test Case : Test KernelCI API GET /count endpoint
     Expected Result :
         HTTP Response Code 200 OK
         Total number of nodes available
     """
-    response = test_client.get("count")
+    response = await test_async_client.get("count")
     assert response.status_code == 200
     assert response.json() >= 0
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=[
         'tests/e2e_tests/test_pipeline.py::test_node_pipeline'],
     scope='session')
-def test_count_nodes_matching_attributes(test_client):
+async def test_count_nodes_matching_attributes(test_async_client):
     """
     Test Case : Test KernelCI API GET /count endpoint with attributes
     Expected Result :
         HTTP Response Code 200 OK
         Number of nodes matching attributes
     """
-    response = test_client.get("count?name=checkout")
+    response = await test_async_client.get("count?name=checkout")
     assert response.status_code == 200
     assert response.json() >= 0

tests/e2e_tests/test_root_handler.py

@@ -5,9 +5,12 @@
 
 """End-to-end test functions for KernelCI API root handler"""
 
+import pytest
 
-def test_root_endpoint(test_client):
+
+@pytest.mark.asyncio
+async def test_root_endpoint(test_async_client):
     """Test root handler"""
-    response = test_client.get("/latest")
+    response = await test_async_client.get("/")
     assert response.status_code == 200
     assert response.json() == {"message": "KernelCI API"}

tests/e2e_tests/test_subscribe_handler.py

@@ -9,18 +9,19 @@
 import pytest
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=['tests/e2e_tests/test_user_creation.py::test_create_regular_user'],
     scope='session')
 @pytest.mark.order(3)
-def test_subscribe_node_channel(test_client):
+async def test_subscribe_node_channel(test_async_client):
     """
     Test Case : Test KernelCI API '/subscribe' endpoint with 'node' channel
     Expected Result :
         HTTP Response Code 200 OK
         JSON with subscription 'id' and 'channel' keys
     """
-    response = test_client.post(
+    response = await test_async_client.post(
         "subscribe/node",
         headers={
             "Authorization": f"Bearer {pytest.BEARER_TOKEN}"  # pylint: disable=no-member
@@ -32,18 +33,19 @@ def test_subscribe_node_channel(test_client):
     assert response.json().get('channel') == 'node'
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=['tests/e2e_tests/test_user_creation.py::test_create_regular_user'],
     scope='session')
 @pytest.mark.order(3)
-def test_subscribe_test_channel(test_client):
+async def test_subscribe_test_channel(test_async_client):
     """
     Test Case : Test KernelCI API '/subscribe' endpoint with 'test_channel'
     Expected Result :
         HTTP Response Code 200 OK
         JSON with subscription 'id' and 'channel' keys
     """
-    response = test_client.post(
+    response = await test_async_client.post(
         "subscribe/test_channel",
         headers={
             "Authorization": f"Bearer {pytest.BEARER_TOKEN}"  # pylint: disable=no-member
@@ -55,19 +57,20 @@ def test_subscribe_test_channel(test_client):
     assert response.json().get('channel') == 'test_channel'
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=['tests/e2e_tests/test_user_creation.py::test_create_regular_user'],
     scope='session')
 @pytest.mark.order(3)
-def test_subscribe_user_group_channel(test_client):
+async def test_subscribe_user_group_channel(test_async_client):
     """
     Test Case : Test KernelCI API '/subscribe' endpoint with 'user_group'
     channel
     Expected Result :
         HTTP Response Code 200 OK
         JSON with subscription 'id' and 'channel' keys
     """
-    response = test_client.post(
+    response = await test_async_client.post(
         "subscribe/user_group",
         headers={
             "Authorization": f"Bearer {pytest.BEARER_TOKEN}"  # pylint: disable=no-member

tests/e2e_tests/test_unsubscribe_handler.py

@@ -9,18 +9,19 @@
 import pytest
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=[
         'tests/e2e_tests/test_subscribe_handler.py::test_subscribe_node_channel'],
     scope='session')
 @pytest.mark.order("last")
-def test_unsubscribe_node_channel(test_client):
+async def test_unsubscribe_node_channel(test_async_client):
     """
     Test Case : Test KernelCI API '/unsubscribe' endpoint with 'node' channel
     Expected Result :
         HTTP Response Code 200 OK
     """
-    response = test_client.post(
+    response = await test_async_client.post(
         f"unsubscribe/{pytest.node_channel_subscription_id}",  # pylint: disable=no-member
         headers={
             "Authorization": f"Bearer {pytest.BEARER_TOKEN}"  # pylint: disable=no-member
@@ -29,18 +30,19 @@ def test_unsubscribe_node_channel(test_client):
     assert response.status_code == 200
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(
     depends=[
         'tests/e2e_tests/test_subscribe_handler.py::test_subscribe_test_channel'],
     scope='session')
 @pytest.mark.order("last")
-def test_unsubscribe_test_channel(test_client):
+async def test_unsubscribe_test_channel(test_async_client):
     """
     Test Case : Test KernelCI API '/unsubscribe' endpoint with 'test_channel'
     Expected Result :
         HTTP Response Code 200 OK
     """
-    response = test_client.post(
+    response = await test_async_client.post(
         f"unsubscribe/{pytest.test_channel_subscription_id}",  # pylint: disable=no-member
         headers={
             "Authorization": f"Bearer {pytest.BEARER_TOKEN}"  # pylint: disable=no-member

tests/e2e_tests/test_user_creation.py

@@ -118,16 +118,17 @@ async def test_create_regular_user(test_async_client):
     pytest.BEARER_TOKEN = response.json()['access_token']
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(depends=["test_create_regular_user"])
-def test_whoami(test_client):
+async def test_whoami(test_async_client):
     """
     Test Case : Test KernelCI API /whoami endpoint
     Expected Result :
         HTTP Response Code 200 OK
         JSON with 'id', 'email', username', 'groups', 'is_superuser'
         'is_verified' and 'is_active' keys
     """
-    response = test_client.get(
+    response = await test_async_client.get(
         "whoami",
         headers={
             "Accept": "application/json",
@@ -140,16 +141,17 @@ def test_whoami(test_client):
     assert response.json()['username'] == 'test_user'
 
 
+@pytest.mark.asyncio
 @pytest.mark.dependency(depends=["test_create_regular_user"])
-def test_create_user_negative(test_client):
+async def test_create_user_negative(test_async_client):
     """
     Test Case : Test KernelCI API /user/register endpoint when requested
     with regular user's bearer token.
     Expected Result :
         HTTP Response Code 403 Forbidden
         JSON with 'detail' key denoting 'Forbidden' error
     """
-    response = test_client.post(
+    response = await test_async_client.post(
         "user/register",
         headers={
                 "Accept": "application/json",