From e1c8d44762ce7bcb30d64740b0a8e47be9fc3ecd Mon Sep 17 00:00:00 2001
From: Kevin Carter <kecarter@redhat.com>
Date: Mon, 3 Feb 2020 17:33:24 -0600
Subject: [PATCH] Remove mistral from the config_download_export workflow

This change removes mistral from the config_download_export workflow by
managing the mistral context and calling the required methods directly.

Story: 2007212
Task: 38428

Change-Id: I9b8f15a92ffe75c0dcd091a89c93d842b6c6c16a
Signed-off-by: Kevin Carter <kecarter@redhat.com>
---
 tripleoclient/workflows/deployment.py | 52 ++++++++++++++++-----------
 1 file changed, 31 insertions(+), 21 deletions(-)

diff --git a/tripleoclient/workflows/deployment.py b/tripleoclient/workflows/deployment.py
index 4a63f7197..b5ad7827f 100644
--- a/tripleoclient/workflows/deployment.py
+++ b/tripleoclient/workflows/deployment.py
@@ -19,7 +19,9 @@ import yaml
 
 from heatclient.common import event_utils
 from openstackclient import shell
+from tripleo_common.actions import config
 from tripleo_common.actions import deployment
+from tripleo_common.actions import swifthelper
 
 from tripleoclient.constants import ANSIBLE_TRIPLEO_PLAYBOOKS
 from tripleoclient import exceptions
@@ -315,29 +317,37 @@ def config_download(log, clients, stack, templates,
         raise exceptions.DeploymentError("Overcloud configuration failed.")
 
 
-def config_download_export(clients, **workflow_input):
-    workflow_client = clients.workflow_engine
-    tripleoclients = clients.tripleoclient
+def config_download_export(clients, plan, config_type):
+    """Export a given config.
 
-    with tripleoclients.messaging_websocket() as ws:
-        execution = base.start_workflow(
-            workflow_client,
-            'tripleo.deployment.v1.config_download_export',
-            workflow_input=workflow_input
+    :param clients: application client object.
+    :type clients: Object
+
+    :param plan: Plan name.
+    :type plan: String
+
+    :param config_type: List of config type options.
+    :type config_type: List
+
+    :returns: string
+    """
+
+    context = clients.tripleoclient.create_mistral_context()
+    container_config = '{}-config'.format(plan)
+    config.GetOvercloudConfig(
+        container=plan,
+        config_type=config_type,
+        container_config=container_config
+    ).run(context=context)
+    print(
+        'Config Download export complete for {}. Creating temp URL.'.format(
+            plan
         )
-
-        for payload in base.wait_for_messages(workflow_client, ws, execution,
-                                              _WORKFLOW_TIMEOUT):
-            message = payload.get('message')
-            if message:
-                print(message)
-
-    if payload['status'] == 'SUCCESS':
-        return payload['tempurl']
-    else:
-        raise exceptions.WorkflowServiceError(
-            'Exception exporting config-download: {}'.format(
-                payload['message']))
+    )
+    return swifthelper.SwiftTempUrlAction(
+        container=container_config,
+        obj='{}.tar.gz'.format(container_config)
+    ).run(context=context)
 
 
 def get_horizon_url(stack):