From 5cff83a953dd296b5bf2b08cd7d20cbc505290d8 Mon Sep 17 00:00:00 2001
From: Robin Schneider <robin.schneider@geberit.com>
Date: Wed, 18 Nov 2020 12:58:47 +0100
Subject: [PATCH] Remove then install plugin if it does not match the installed
 ES version

---
 elasticsearch/plugins.sls | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/elasticsearch/plugins.sls b/elasticsearch/plugins.sls
index 6fabb45..0e9c3de 100644
--- a/elasticsearch/plugins.sls
+++ b/elasticsearch/plugins.sls
@@ -10,8 +10,19 @@ include:
   {%- set plugin_bin = 'plugin' %}
 {% endif %}
 
+{% set es_version = salt['pkg.info_installed']('elasticsearch').get('elasticsearch', {}).get('version') %}
 {% for name, repo in plugins_pillar.items() %}
-elasticsearch-{{ name }}:
+{%   set es_plugin_file = salt['file.find']('/usr/share/elasticsearch/plugins/' + name, type='f', iname=name + '-*.jar')[0] %}
+
+{%   if es_version not in es_plugin_file %}
+elasticsearch-plugin-remove-{{ name }}:
+  cmd.run:
+    - name: /usr/share/elasticsearch/bin/{{ plugin_bin }} remove {{ repo }}
+    - require:
+      - sls: elasticsearch.pkg
+{%   endif %}
+
+elasticsearch-plugin-install-{{ name }}:
   cmd.run:
     - name: /usr/share/elasticsearch/bin/{{ plugin_bin }} install -b {{ repo }}
     - require: