Also test http

Author: bigfootjon

tests/test_database.py

@@ -2,8 +2,9 @@
 from django.test import TestCase
 
 from channels.db import database_sync_to_async
+from channels.generic.http import AsyncHttpConsumer
 from channels.generic.websocket import AsyncWebsocketConsumer
-from channels.testing import WebsocketCommunicator
+from channels.testing import HttpCommunicator, WebsocketCommunicator
 
 
 @database_sync_to_async
@@ -19,8 +20,18 @@ async def connect(self):
         await self.accept("fun")
 
 
+class HttpConsumer(AsyncHttpConsumer):
+    async def handle(self, body):
+        await basic_query()
+        await self.send_response(
+            200,
+            b"",
+            headers={b"Content-Type": b"text/plain"},
+        )
+
+
 class ConnectionClosingTests(TestCase):
-    async def test_doesnt_close_connections_in_test_case(self):
+    async def test_websocket(self):
         self.assertNotRegex(
             db.connections["default"].settings_dict.get("NAME"),
             "memorydb",
@@ -30,3 +41,15 @@ async def test_doesnt_close_connections_in_test_case(self):
         connected, subprotocol = await communicator.connect()
         self.assertTrue(connected)
         self.assertEqual(subprotocol, "fun")
+
+    async def test_http(self):
+        self.assertNotRegex(
+            db.connections["default"].settings_dict.get("NAME"),
+            "memorydb",
+            "This bug only occurs when the database is materialized on disk",
+        )
+        communicator = HttpCommunicator(
+            HttpConsumer.as_asgi(), method="GET", path="/test/"
+        )
+        connected = await communicator.get_response()
+        self.assertTrue(connected)