Add celery task "deleteindex"

src/collective/elastic/ingest/celery.py

@@ -1,3 +1,4 @@
+from .deleteindex import delete_index
 from .ingestion import process_ingest
 from .logging import logger
 from .plone import fetch_content
@@ -84,3 +85,17 @@ def unindex(uid, index_name):
         logger.exception(msg)
         return msg
     return "unindexed {}".format(uid)
+
+
+@app.task(name="collective.elastic.ingest.deleteindex")
+def deleteindex(index_name):
+    try:
+        delete_index(index_name)
+    except RuntimeError:
+        logger.error("Fatal error, stop worker")
+        sys.exit(1)
+    except Exception:
+        msg = "Error while deleting index '{}'".format(index_name)
+        logger.exception(msg)
+        return msg
+    return "Index deleted: {}".format(index_name)

src/collective/elastic/ingest/deleteindex.py

@@ -0,0 +1,13 @@
+from .client import get_client
+from .logging import logger
+
+
+def delete_index(index_name):
+    client = get_client()
+    if client is None:
+        logger.warning("No index client available.")
+        return
+    try:
+        client.indices.delete(index=index_name)
+    except Exception as e:
+        logger.exception(str(e))