From 1eb6c80e0d65ab4373fa0327ec839eae38cc07f8 Mon Sep 17 00:00:00 2001 From: Advay Patil Date: Sun, 17 Aug 2025 17:11:24 -0700 Subject: [PATCH] Strip MQ environment variables too --- server/mq/core/connection_manager.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/server/mq/core/connection_manager.py b/server/mq/core/connection_manager.py index 8404360..87d7cb7 100644 --- a/server/mq/core/connection_manager.py +++ b/server/mq/core/connection_manager.py @@ -63,11 +63,11 @@ def on_connection_open_error(self, connection, err): self._connected = False def _build_amqp_url(self) -> str: - user = os.getenv("SERVER_RABBIT_USER", "guest") - password = os.getenv("SERVER_RABBIT_PASS", "guest") - host = os.getenv("RABBIT_HOST", "rabbitmq-host") - port = os.getenv("RABBIT_PORT", "5672") - vhost = os.getenv("RABBIT_VHOST", "/") + user = os.getenv("SERVER_RABBIT_USER", "guest").strip() + password = os.getenv("SERVER_RABBIT_PASS", "guest").strip() + host = os.getenv("RABBIT_HOST", "rabbitmq-host").strip() + port = os.getenv("RABBIT_PORT", "5672").strip() + vhost = os.getenv("RABBIT_VHOST", "/").strip() vhost = urllib.parse.quote(vhost, safe="") return f"amqp://{user}:{password}@{host}:{port}/{vhost}"