Fix typo in rabbitmq var

Author: falvaradorodriguez

.env.docker

@@ -1,3 +1,3 @@
 REDIS_URL=redis://redis:6379/0
 DATABASE_URL=postgresql+asyncpg://postgres:postgres@db:5432/postgres
-RABBITMQ_AMPQ_URL=amqp://guest:guest@rabbitmq:5672/
+RABBITMQ_AMQP_URL=amqp://guest:guest@rabbitmq:5672/

.env.sample

@@ -1,3 +1,3 @@
 REDIS_URL=redis://redis:6379/0
 DATABASE_URL=postgresql+asyncpg://postgres:postgres@db:5432/postgres
-RABBITMQ_AMPQ_URL=amqp://guest:guest@rabbitmq:5672/
+RABBITMQ_AMQP_URL=amqp://guest:guest@rabbitmq:5672/

app/config.py

@@ -20,7 +20,7 @@ class Settings(BaseSettings):
     DATABASE_URL: str = "psql://postgres:"
     DATABASE_POOL_CLASS: str = "AsyncAdaptedQueuePool"
     DATABASE_POOL_SIZE: int = 10
-    RABBITMQ_AMPQ_URL: str = "amqp://guest:guest@"
+    RABBITMQ_AMQP_URL: str = "amqp://guest:guest@"
     RABBITMQ_AMQP_EXCHANGE: str = "safe-transaction-service-events"
     RABBITMQ_DECODER_EVENTS_QUEUE_NAME: str = "safe-decoder-service"
     SECRET_KEY: str = secrets.token_urlsafe(

app/datasources/queue/queue_provider.py

@@ -42,7 +42,7 @@ async def _connect(self, loop: AbstractEventLoop) -> None:
         """
         try:
             self._connection = await aio_pika.connect_robust(
-                url=settings.RABBITMQ_AMPQ_URL, loop=loop
+                url=settings.RABBITMQ_AMQP_URL, loop=loop
             )
         except aio_pika.exceptions.AMQPConnectionError as e:
             raise QueueProviderUnableToConnectException(e)

app/tests/datasources/queue/test_queue_provider.py

@@ -25,7 +25,7 @@ async def test_connect_success(self):
     async def test_connect_failure(self):
         provider = QueueProvider()
 
-        with patch("app.config.settings.RABBITMQ_AMPQ_URL", "amqp://invalid-url"):
+        with patch("app.config.settings.RABBITMQ_AMQP_URL", "amqp://invalid-url"):
             with self.assertRaises(QueueProviderUnableToConnectException):
                 await provider.connect(self.loop)