Fixed redis.

Author: s3rius

fastapi_template/template/{{cookiecutter.project_name}}/pyproject.toml

@@ -161,9 +161,6 @@ dev = [
   "pytest-cov >=7.0.0,<8",
   "anyio >=4.11.0,<5",
   "pytest-env >=1.2.0,<2",
-{%- if cookiecutter.enable_redis == "True" %}
-  "fakeredis >=2.32.1,<3",
-{%- endif %}
 {%- if cookiecutter.orm == "tortoise" %}
   "asynctest >=0.13.0,<1",
   "nest-asyncio >=1.6.0,<2",

fastapi_template/template/{{cookiecutter.project_name}}/tests/conftest.py

@@ -8,8 +8,6 @@
 from httpx import AsyncClient, ASGITransport
 
 {%- if cookiecutter.enable_redis == "True" %}
-from fakeredis import FakeServer
-from fakeredis.aioredis import FakeConnection
 from redis.asyncio import ConnectionPool
 from {{cookiecutter.project_name}}.services.redis.dependency import get_redis_pool
 
@@ -479,15 +477,13 @@ async def test_nats() -> AsyncGenerator[Nats, None]:
 
 {% if cookiecutter.enable_redis == "True" -%}
 @pytest.fixture
-async def fake_redis_pool() -> AsyncGenerator[ConnectionPool, None]:
+async def test_redis_pool() -> AsyncGenerator[ConnectionPool, None]:
     """
     Get instance of a fake redis.
 
-    :yield: FakeRedis instance.
+    :yield: ConnectionPool instance.
     """
-    server = FakeServer()
-    server.connected = True
-    pool = ConnectionPool(connection_class=FakeConnection, server=server)
+    pool = ConnectionPool.from_url(str(settings.redis_url))
 
     yield pool
 
@@ -503,7 +499,7 @@ def fastapi_app(
     dbpool: AsyncConnectionPool[Any],
     {%- endif %}
     {% if cookiecutter.enable_redis == "True" -%}
-    fake_redis_pool: ConnectionPool,
+    test_redis_pool: ConnectionPool,
     {%- endif %}
     {%- if cookiecutter.enable_rmq == 'True' %}
     test_rmq_pool: Pool[Channel],
@@ -527,7 +523,7 @@ def fastapi_app(
     application.dependency_overrides[get_db_pool] = lambda: dbpool
     {%- endif %}
     {%- if cookiecutter.enable_redis == "True" %}
-    application.dependency_overrides[get_redis_pool] = lambda: fake_redis_pool
+    application.dependency_overrides[get_redis_pool] = lambda: test_redis_pool
     {%- endif %}
     {%- if cookiecutter.enable_rmq == 'True' %}
     application.dependency_overrides[get_rmq_channel_pool] = lambda: test_rmq_pool

fastapi_template/template/{{cookiecutter.project_name}}/tests/test_redis.py

@@ -1,6 +1,5 @@
 import uuid
 
-import fakeredis
 from fastapi import FastAPI
 from httpx import AsyncClient
 from redis.asyncio import ConnectionPool, Redis
@@ -9,14 +8,14 @@
 
 async def test_setting_value(
     fastapi_app: FastAPI,
-    fake_redis_pool: ConnectionPool,
+    test_redis_pool: ConnectionPool,
     client: AsyncClient,
 ) -> None:
     """
     Tests that you can set value in redis.
 
     :param fastapi_app: current application fixture.
-    :param fake_redis_pool: fake redis pool.
+    :param test_redis_pool: fake redis pool.
     :param client: client fixture.
     """
     {%- if cookiecutter.api_type == 'rest' %}
@@ -51,26 +50,26 @@ async def test_setting_value(
     {%- endif %}
 
     assert response.status_code == status.HTTP_200_OK
-    async with Redis(connection_pool=fake_redis_pool) as redis:
+    async with Redis(connection_pool=test_redis_pool) as redis:
         actual_value = await redis.get(test_key)
     assert actual_value.decode() == test_val
 
 
 async def test_getting_value(
     fastapi_app: FastAPI,
-    fake_redis_pool: ConnectionPool,
+    test_redis_pool: ConnectionPool,
     client: AsyncClient,
 ) -> None:
     """
     Tests that you can get value from redis by key.
 
     :param fastapi_app: current application fixture.
-    :param fake_redis_pool: fake redis pool.
+    :param test_redis_pool: fake redis pool.
     :param client: client fixture.
     """
     test_key = uuid.uuid4().hex
     test_val = uuid.uuid4().hex
-    async with Redis(connection_pool=fake_redis_pool) as redis:
+    async with Redis(connection_pool=test_redis_pool) as redis:
         await redis.set(test_key, test_val)
 
     {%- if cookiecutter.api_type == 'rest' %}