tests(aiohttp): adapt tests to OTel usage.

Signed-off-by: Paulo Vital <[email protected]>

Author: pvital

tests/apps/aiohttp_app2/__init__.py

@@ -0,0 +1,13 @@
+# (c) Copyright IBM Corp. 2024
+
+import os
+import sys
+from tests.apps.aiohttp_app2.app import aiohttp_server as server
+from tests.apps.utils import launch_background_thread
+
+APP_THREAD = None
+
+if not any((os.environ.get('GEVENT_STARLETTE_TEST'),
+            os.environ.get('CASSANDRA_TEST'),
+            sys.version_info < (3, 5, 3))):
+    APP_THREAD = launch_background_thread(server, "AIOHTTP")

tests/apps/aiohttp_app2/app.py

@@ -0,0 +1,40 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+# (c) Copyright IBM Corp. 2024
+
+import asyncio
+
+from aiohttp import web
+
+from tests.helpers import testenv
+
+testenv["aiohttp_port"] = 10810
+testenv["aiohttp_server"] = f"http://127.0.0.1:{testenv['aiohttp_port']}"
+
+
+def say_hello(request):
+    return web.Response(text="Hello, world")
+
+
+@web.middleware
+async def middleware1(request, handler):
+    print("Middleware 1 called")
+    response = await handler(request)
+    print("Middleware 1 finished")
+    return response
+
+
+def aiohttp_server():
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
+
+    app = web.Application(middlewares=[middleware1])
+    app.add_routes([web.get("/", say_hello)])
+
+    runner = web.AppRunner(app)
+    loop.run_until_complete(runner.setup())
+    site = web.TCPSite(runner, "127.0.0.1", testenv["aiohttp_port"])
+
+    loop.run_until_complete(site.start())
+    loop.run_forever()

tests/conftest.py

@@ -44,7 +44,6 @@
 collect_ignore_glob.append("*clients/test_redis*")
 collect_ignore_glob.append("*clients/test_sql*")
 
-collect_ignore_glob.append("*frameworks/test_aiohttp*")
 collect_ignore_glob.append("*frameworks/test_celery*")
 collect_ignore_glob.append("*frameworks/test_gevent*")
 collect_ignore_glob.append("*frameworks/test_grpcio*")