refactor: start dashmate services depending on status

ansible/roles/dashmate/tasks/install.yml

@@ -17,3 +17,4 @@
   ansible.builtin.apt:
     deb: "{{ release_info.json.assets | selectattr('name', 'search', '_' + deb_architecture.stdout + '.deb') | map(attribute='browser_download_url') | first }}"
     allow_downgrade: true
+  register: dashmate_install_result

ansible/roles/dashmate/tasks/main.yml

@@ -103,6 +103,7 @@
     owner: '{{ dashmate_user }}'
     group: '{{ dashmate_group }}'
     mode: "0644"
+  register: template_result
 
 - name: Generate self-signed SSL certificate for DAPI
   ansible.builtin.import_tasks: ./ssl/self_signed.yml
@@ -131,7 +132,7 @@
   when: dashmate_branch is defined
 
 - name: Update dashmate images
-  ansible.builtin.command: "{{ dashmate_cmd }} update --verbose"
+  ansible.builtin.command: "{{ dashmate_cmd }} update --format=json"
   become: true
   become_user: dashmate
   register: dashmate_update
@@ -148,30 +149,113 @@
   changed_when: true
   when: dashmate_branch is defined
 
-# TODO: we should use status command to figure out if dashmate is running
-#   to get the status from the response
-# Restart dashmate if already running
-- name: Restart dashmate services
-  ansible.builtin.command: "{{ dashmate_cmd }} restart --verbose"
+- name: Get status
+  ansible.builtin.command: "{{ dashmate_cmd }} status --format=json"
   become: true
   become_user: dashmate
+  changed_when: true
   args:
     chdir: '{{ dashmate_cwd }}'
-  register: dashmate_restart
-  changed_when: dashmate_restart.rc == 0
-  ignore_errors: true
+  register: dashmate_status
+
+- name: Get service status
+  ansible.builtin.set_fact:
+    core_docker_status: "{{ dashmate_status.stdout | from_json | json_query('core.dockerStatus') }}"
+    tenderdash_docker_status: "{{ dashmate_status.stdout | from_json | json_query('platform.tenderdash.dockerStatus') }}"
+    core_images_updated: >-
+      {{
+        dashmate_update.stdout |
+        from_json |
+        json_query('[?name==`core`||name==`sentinel`]') |
+        sort(attribute='updated', reverse=true) |
+        first() |
+        json_query('updated')
+      }}
+    platform_images_updated: >-
+      {{
+        dashmate_update.stdout |
+        from_json |
+        json_query('[?name!=`core`&&name!=`sentinel`]') |
+        sort(attribute='updated', reverse=true) |
+        first() |
+        json_query('updated')
+      }}
+    dashmate_package_changed: "{{ dashmate_install_result.changed }}"
+    dashmate_config_changed: "{{ template_result.changed }}"
+
+- name: Print status
+  ansible.builtin.debug:
+    msg: "\n
+Core Status: {{ core_docker_status }}\n
+Tenderdash Status: {{ tenderdash_docker_status }}\n
+Core Images Updated: {{ core_images_updated }}\n
+Platform Images Updated: {{ platform_images_updated }}\n
+Dashmate Package Updated: {{ dashmate_package_changed }}\n
+Dashmate Config Changed: {{ dashmate_config_changed }}
+"
+
+# Start logic:
+# start ALL when (core is down and platform is down)
+# start platform when (core is up and platform is down)
 
-# Start if not already running
+# Start all if everything is stopped (not started yet)
 - name: Start dashmate services
   ansible.builtin.command: "{{ dashmate_cmd }} start --verbose"
   become: true
   become_user: dashmate
   args:
     chdir: '{{ dashmate_cwd }}'
   register: dashmate_start
-  when: "dashmate_restart.rc != 0"
+  when:
+    - core_docker_status == 'not_started'
+    - tenderdash_docker_status == 'not_started'
   changed_when: dashmate_start.rc == 0
 
+# Start platform in case core is running
+- name: Start dashmate platform services
+  ansible.builtin.command: "{{ dashmate_cmd }} start --platform --verbose"
+  become: true
+  become_user: dashmate
+  args:
+    chdir: '{{ dashmate_cwd }}'
+  register: dashmate_start_platform
+  when:
+    - core_docker_status == 'running'
+    - tenderdash_docker_status == 'not_started'
+  changed_when: dashmate_start_platform.rc == 0
+
+# Restart logic
+# if any of platform images were updated => restart platform
+# if core or sentinel images updated => restart all
+# dashmate version is changed => restart all
+# dashmate config is changed => restart all
+
+- name: Restart dashmate platform services
+  ansible.builtin.command: "{{ dashmate_cmd }} restart --platform --verbose"
+  become: true
+  become_user: dashmate
+  args:
+    chdir: '{{ dashmate_cwd }}'
+  register: dashmate_restart
+  when:
+    - core_docker_status == 'running' and tenderdash_docker_status == 'running'
+    - core_images_updated is false and platform_images_updated is true
+    - dashmate_package_changed is false and dashmate_config_changed is false
+  changed_when: dashmate_restart.rc == 0
+
+- name: Restart dashmate services
+  ansible.builtin.command: "{{ dashmate_cmd }} restart --verbose"
+  become: true
+  become_user: dashmate
+  args:
+    chdir: '{{ dashmate_cwd }}'
+  register: dashmate_restart
+  when:
+    - core_docker_status == 'running' and tenderdash_docker_status == 'running'
+    - platform_images_updated is false
+    - core_images_updated is true or dashmate_package_changed is true or dashmate_config_changed is true
+  changed_when: dashmate_restart.rc == 0
+
 # TODO Convenient tasks until we have this functionality in dashmate
 # - name: Replace parameters in tenderdash config
 #  ansible.builtin.lineinfile:

ansible/roles/dashmate/templates/dashmate.json.j2

@@ -1,5 +1,5 @@
 {
-  "configFormatVersion": "{{ dashmate_version | default('999.0.0') }}",
+  "configFormatVersion": "{{ dashmate_version | default(dashmate_config_version | default('999.0.0')) }}",
   "defaultConfigName": "{{ dash_network_name}}",
   "defaultGroupName": null,
   "configs": {
@@ -18,12 +18,10 @@
         "p2p": {
           "port": {{ dashd_port }},
           "seeds": [
-          {% for seed in template_bootstrap_peers %}
-            {
+            {% for seed in template_bootstrap_peers %}{
               "host": "{{ hostvars[seed].public_ip }}",
               "port": {{ dashd_port }}
-            }{% if not loop.last %},{% endif %}
-            {% endfor %}
+            }{% if not loop.last %},{% endif %}{% endfor %}
           ]
         },
         "rpc": {
@@ -60,9 +58,9 @@
           }
         },
         "devnet": {
-            "name": {% if dash_network == 'devnet' %}"{{ dash_devnet_name }}"{% else %}null{% endif %},
-            "minimumDifficultyBlocks": {{ dashd_minimumdifficultyblocks }},
-            "powTargetSpacing": {{ dashd_powtargetspacing }}
+          "name": {% if dash_network == 'devnet' %}"{{ dash_devnet_name }}"{% else %}null{% endif %},
+          "minimumDifficultyBlocks": {{ dashd_minimumdifficultyblocks }},
+          "powTargetSpacing": {{ dashd_powtargetspacing }}
         },
         "logIps": 0,
         "indexes": true,
@@ -145,9 +143,8 @@
                    "id": "{{ seed_nodes[seed].node_key.id }}",
                    "host": "{{ hostvars[seed].public_ip }}",
                    "port": {{ tendermint_p2p_port }}
-                 }{% if not loop.last %},{% endif %}
-                 {% endfor %}
-               ]
+                 }{% if not loop.last %},{% endif %}{% endfor %}
+              ]
             },
             "rpc": {
               "port": {{ tendermint_rpc_port }}
@@ -238,7 +235,7 @@
         },
         "withdrawals": {
           "contract": {
-           "id": "4fJLR2GYTPFdomuTVvNy3VRrvWgvkKPzqehEBpNf2nk6"
+            "id": "4fJLR2GYTPFdomuTVvNy3VRrvWgvkKPzqehEBpNf2nk6"
           },
           "masterPublicKey": "{{ withdrawals_hd_master_public_key }}",
           "secondPublicKey": "{{ withdrawals_hd_second_public_key }}"
@@ -251,7 +248,7 @@
           },
           "api": {
             "enable": true,
-            "port": "{{ dashmate_api_port }}"
+            "port": {{ dashmate_api_port }}
           }
         }
       },