From aa2922da3cf8b83306a49a09bd85114817ae1eba Mon Sep 17 00:00:00 2001
From: Michael Hwang <mhwang@research.att.com>
Date: Thu, 1 Mar 2018 23:17:21 -0500
Subject: Revert "Update docker plugin to use dcaepolicy .."

This reverts commit d2ce7db538f97bc7f86b87e15fe6fcda2b089294.

Change-Id: Ia1eb2a55b9c92253ed5f2d85b87455c4fb2683c7
Issue-ID: DCAEGEN2-377
Signed-off-by: Michael Hwang <mhwang@research.att.com>
---
 docker/dockerplugin/tasks.py | 44 +++++++++++++++++++++++++++-----------------
 1 file changed, 27 insertions(+), 17 deletions(-)

(limited to 'docker/dockerplugin')

diff --git a/docker/dockerplugin/tasks.py b/docker/dockerplugin/tasks.py
index d64a65c..899f4ed 100644
--- a/docker/dockerplugin/tasks.py
+++ b/docker/dockerplugin/tasks.py
@@ -25,7 +25,7 @@ from cloudify import ctx
 from cloudify.decorators import operation
 from cloudify.exceptions import NonRecoverableError, RecoverableError
 import dockering as doc
-from onap_dcae_dcaepolicy_lib import Policies
+from onap_dcae_dcaepolicy_lib import Policies, POLICIES, POLICY_MESSAGE_TYPE
 from dockerplugin import discovery as dis
 from dockerplugin.decorators import monkeypatch_loggers, wrap_error_handling_start, \
     merge_inputs_for_start, merge_inputs_for_create
@@ -113,10 +113,15 @@ def _done_for_create(**kwargs):
     ctx.logger.info("Done setting up: {0}".format(name))
     return kwargs
 
+def _merge_policy_updates(**kwargs):
+    app_config = kwargs[APPLICATION_CONFIG]
+    kwargs[APPLICATION_CONFIG] = Policies.shallow_merge_policies_into(app_config)
+    return kwargs
+
 
 @merge_inputs_for_create
 @monkeypatch_loggers
-@Policies.gather_policies_to_node()
+@Policies.gather_policies_to_node
 @operation
 def create_for_components(**create_inputs):
     """Create step for Docker containers that are components
@@ -128,8 +133,9 @@ def create_for_components(**create_inputs):
     """
     _done_for_create(
             **_setup_for_discovery(
+                **_merge_policy_updates(
                     **_generate_component_name(
-                        **create_inputs)))
+                        **create_inputs))))
 
 
 def _parse_streams(**kwargs):
@@ -198,7 +204,7 @@ def _setup_for_discovery_streams(**kwargs):
 
 @merge_inputs_for_create
 @monkeypatch_loggers
-@Policies.gather_policies_to_node()
+@Policies.gather_policies_to_node
 @operation
 def create_for_components_with_streams(**create_inputs):
     """Create step for Docker containers that are components that use DMaaP
@@ -213,9 +219,10 @@ def create_for_components_with_streams(**create_inputs):
     _done_for_create(
             **_setup_for_discovery(
                 **_setup_for_discovery_streams(
+                    **_merge_policy_updates(
                         **_parse_streams(
                             **_generate_component_name(
-                                **create_inputs)))))
+                                **create_inputs))))))
 
 
 @merge_inputs_for_create
@@ -579,7 +586,6 @@ def stop_and_remove_container(**kwargs):
         raise NonRecoverableError(e)
 
 @monkeypatch_loggers
-@Policies.cleanup_policies_on_node
 @operation
 def cleanup_discovery(**kwargs):
     """Delete configuration from Consul"""
@@ -600,15 +606,11 @@ def _notify_container(**kwargs):
         if dc["policy"]["trigger_type"] == "docker":
             # REVIEW: Need to finalize on the docker config policy data structure
             script_path = dc["policy"]["script_path"]
+            app_config = kwargs["application_config"]
             updated_policies = kwargs["updated_policies"]
-            removed_policies = kwargs["removed_policies"]
-            policies = kwargs["policies"]
             cmd = doc.build_policy_update_cmd(script_path, use_sh=False,
-                    msg_type="policies",
                     updated_policies=updated_policies,
-                    removed_policies=removed_policies,
-                    policies=policies
-                    )
+                    application_config=app_config)
 
             docker_host = kwargs[SELECTED_CONTAINER_DESTINATION]
             docker_host_ip = _lookup_service(docker_host)
@@ -622,10 +624,16 @@ def _notify_container(**kwargs):
 
     return kwargs
 
+def _done_for_policy_update(**kwargs):
+    name = kwargs['name']
+    ctx.instance.runtime_properties.update(kwargs)
+    ctx.logger.info("Done updating for policy: {0}".format(name))
+    return kwargs
+
 @monkeypatch_loggers
-@Policies.update_policies_on_node()
+@Policies.update_policies_on_node(configs_only=True)
 @operation
-def policy_update(updated_policies, removed_policies=None, policies=None, **kwargs):
+def policy_update(updated_policies, **kwargs):
     """Policy update task
 
     This method is responsible for updating the application configuration and
@@ -637,10 +645,12 @@ def policy_update(updated_policies, removed_policies=None, policies=None, **kwar
     """
     update_inputs = copy.deepcopy(ctx.instance.runtime_properties)
     update_inputs["updated_policies"] = updated_policies
-    update_inputs["removed_policies"] = removed_policies
-    update_inputs["policies"] = policies
 
-    _notify_container(**update_inputs)
+    # Merge in policy updates into application config and make available
+    _done_for_policy_update(
+            **_notify_container(
+                **_setup_for_discovery(
+                    **_merge_policy_updates(**update_inputs))))
 
 
 # Lifecycle interface calls for dcae.nodes.DockerHost
-- 
cgit 1.2.3-korg