From d6461ae7b22ade124f518b04dae3259021a0d8c1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Irek=20G=C5=82ownia?=
 <48471627+plirglo@users.noreply.github.com>
Date: Mon, 8 Jun 2020 13:42:22 +0200
Subject: [PATCH] Postgres recovery fix (#1339)

* merge, modify postgres to use new setup

* recovery fix
---
 .../ansible/playbooks/recovery_postgresql.yml |  3 +-
 .../roles/recovery/tasks/postgresql.yml       | 38 +++++++++----------
 2 files changed, 20 insertions(+), 21 deletions(-)

diff --git a/core/src/epicli/data/common/ansible/playbooks/recovery_postgresql.yml b/core/src/epicli/data/common/ansible/playbooks/recovery_postgresql.yml
index 3b504c4375..1e73865bca 100644
--- a/core/src/epicli/data/common/ansible/playbooks/recovery_postgresql.yml
+++ b/core/src/epicli/data/common/ansible/playbooks/recovery_postgresql.yml
@@ -1,10 +1,9 @@
 ---
 # Ansible playbook for recovering Postgresql database
 
-- hosts: postgresql[0]
+- hosts: postgresql
   become: true
   become_method: sudo
-  serial: 1
   tasks:
     - when: specification.components.postgresql.enabled | default(false)
       block:
diff --git a/core/src/epicli/data/common/ansible/playbooks/roles/recovery/tasks/postgresql.yml b/core/src/epicli/data/common/ansible/playbooks/roles/recovery/tasks/postgresql.yml
index 73f934dd6b..7c9acf606a 100644
--- a/core/src/epicli/data/common/ansible/playbooks/roles/recovery/tasks/postgresql.yml
+++ b/core/src/epicli/data/common/ansible/playbooks/roles/recovery/tasks/postgresql.yml
@@ -17,10 +17,10 @@
       - groups['postgresql'][0] == inventory_hostname
 
   when: 
-    - specification.extensions.replication.enabled is defined
-    - specification.extensions.replication.enabled
-    - specification.extensions.replication.use_repmgr is defined
-    - specification.extensions.replication.use_repmgr
+    - component_vars.specification.extensions.replication.enabled is defined
+    - component_vars.specification.extensions.replication.enabled
+    - component_vars.specification.extensions.replication.use_repmgr is defined
+    - component_vars.specification.extensions.replication.use_repmgr
 
 - name: Copy and restore backup files
 
@@ -32,7 +32,7 @@
         snapshot_name: "{{ specification.components.postgresql.snapshot_name }}"
 
     - name: Transfer database backup via rsync
-      import_tasks: upload_via_rsync.yml
+      import_tasks: common/upload_via_rsync.yml
       vars:
         artifacts:
           - "{{ snapshot_path  }}"
@@ -122,12 +122,12 @@
         become: yes
         become_user: postgres
         shell: "{{ repmgr_bindir[ansible_os_family] }}/repmgr -f {{ repmgr_config_dir[ansible_os_family] }}/repmgr.conf
-        --force --superuser={{ specification.extensions.replication.priviledged_user_name }} primary register -F"
+        --force --superuser={{ component_vars.specification.extensions.replication.priviledged_user_name }} primary register -F"
       when:
-        - specification.extensions.replication.enabled is defined
-        - specification.extensions.replication.enabled
-        - specification.extensions.replication.use_repmgr is defined
-        - specification.extensions.replication.use_repmgr
+        - component_vars.specification.extensions.replication.enabled is defined
+        - component_vars.specification.extensions.replication.enabled
+        - component_vars.specification.extensions.replication.use_repmgr is defined
+        - component_vars.specification.extensions.replication.use_repmgr
 
     - name: Remove temporary files
       file:
@@ -189,7 +189,7 @@
 
     - name: Clone content from primary node using repmgr
       become_user: postgres
-      shell: "{{ repmgr_bindir[ansible_os_family] }}/repmgr -f {{ repmgr_config_dir[ansible_os_family] }}/repmgr.conf -h {{ hostvars[groups['postgresql'][0]]['ansible_default_ipv4']['address'] }} -U {{ specification.extensions.replication.priviledged_user_name }} -d {{ specification.extensions.replication.repmgr_database }} -p 5432 -F standby clone"
+      shell: "{{ repmgr_bindir[ansible_os_family] }}/repmgr -f {{ repmgr_config_dir[ansible_os_family] }}/repmgr.conf -h {{ hostvars[groups['postgresql'][0]]['ansible_default_ipv4']['address'] }} -U {{ component_vars.specification.extensions.replication.priviledged_user_name }} -d {{ component_vars.specification.extensions.replication.repmgr_database }} -p 5432 -F standby clone"
 
     - name: Start postgresql service
       service:
@@ -205,18 +205,18 @@
       shell: "{{ repmgr_bindir[ansible_os_family] }}/repmgr -f {{ repmgr_config_dir[ansible_os_family] }}/repmgr.conf standby follow -F"
   when:
     - groups['postgresql'][1] == inventory_hostname
-    - specification.extensions.replication.enabled is defined
-    - specification.extensions.replication.enabled
-    - specification.extensions.replication.use_repmgr is defined
-    - specification.extensions.replication.use_repmgr
+    - component_vars.specification.extensions.replication.enabled is defined
+    - component_vars.specification.extensions.replication.enabled
+    - component_vars.specification.extensions.replication.use_repmgr is defined
+    - component_vars.specification.extensions.replication.use_repmgr
 
 - name: Restart repmgrd service
   service:
     name: "{{ repmgr_service_name[ansible_os_family] }}"
     state: restarted
   when:
-    - specification.extensions.replication.enabled is defined
-    - specification.extensions.replication.enabled
-    - specification.extensions.replication.use_repmgr is defined
-    - specification.extensions.replication.use_repmgr
+    - component_vars.specification.extensions.replication.enabled is defined
+    - component_vars.specification.extensions.replication.enabled
+    - component_vars.specification.extensions.replication.use_repmgr is defined
+    - component_vars.specification.extensions.replication.use_repmgr
     
\ No newline at end of file