🐛 Fix server remove in haproxy while already exist

Signed-off-by: Muhammed Hussein Karimi <info@karimi.dev>
ParminCloud · Nov 4, 2024 · 4afa304 · 4afa304
1 parent dcb9da2
commit 4afa304
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/charts/haproxy-redis-sentinel/Chart.yaml b/charts/haproxy-redis-sentinel/Chart.yaml
@@ -1,6 +1,6 @@
 apiVersion: v2
 name: haproxy-redis-sentinel
 description: A Helm chart for HAProxy with Redis Sentinel
-version: 0.0.7
-appVersion: "0.0.4"
+version: 0.0.8
+appVersion: "0.0.5"
 
diff --git a/haproxy_redis_sentinel/cli.py b/haproxy_redis_sentinel/cli.py
@@ -103,8 +103,10 @@ def run(
     info(f"Setting initial master address: {address}")
 
     # Remove server in case of restarts
-    out = send_command(haproxy_socket, f"del server {
-                       haproxy_backend}/{haproxy_server_name}")
+    out = send_command(haproxy_socket, [
+                       f"set server {
+                           haproxy_backend}/{haproxy_server_name} state maint",
+                       f"del server {haproxy_backend}/{haproxy_server_name}"])
     if out not in {HAProxyOutput.SERVER_DELETED,
                    HAProxyOutput.SERVER_NOT_FOUND,
                    HAProxyOutput.BACKEND_NOT_FOUND}:
@@ -130,8 +132,8 @@ def run(
         port = data[4]
         info("Master Changed, Terminating clients")
         info(send_command(haproxy_socket,
-             [f"set server {haproxy_backend}/current_master state maint",
-              f"shutdown sessions server {haproxy_backend}/current_master"]))
+             [f"set server {haproxy_backend}/{haproxy_server_name} state maint",
+              f"shutdown sessions server {haproxy_backend}/{haproxy_server_name}"]))  # noqa: E501
         info(f"Switching to new master Host: {host}, Port: {port}")
         info(send_command(haproxy_socket,
                           f"set server {haproxy_backend}/{haproxy_server_name} addr {host} port {port} state ready"))  # noqa: E501