4.6.0 policy-handler - active-passive

DCAEGEN2-931:
- exposed POST /reconfigure endpoint on the web-server
  that initiates the reconfigure process right away

DCAEGEN2-932:
- mode_of_operation: active or passive
  = active is as before this change
  = in passive mode the policy-handler
    * closes the web-socket to PDP
    * skips the periodic catch_ups
    * still periodically checks for reconfigure
    * still allows usig the web-server to retrieve policies from PDP
- default is active

- when mode_of_operation changes from passive to active,
  the policy-handler invokes the catch_up right away

- config-kv contains the optional override field mode_of_operation
  = changing the mode_of_operation in config-kv and invoking
    POST /reconfigure will bring the new value and change the
    mode of operation of the policy-handler if no service_activator
    section is provided in consul-kv record

- if config-kv contains the service_activator section,
  = the policy-handler registers with service_activator - untested
  = and receives the mode_of_operation - untested
  = service_activator can POST-notify the policy-handler to
    initiate the /reconfigure

- reduced the default web-socket ping interval from 180 to 30
  seconds because PDP changed its default timeout on the web-socket
  from 400 seconds to 50 seconds

Change-Id: If7dd21c008d9906aca97939be65dfa9c2f007535
Signed-off-by: Alex Shatov <alexs@att.com>
Issue-ID: DCAEGEN2-931
Issue-ID: DCAEGEN2-932

1 files changed, 8 insertions, 5 deletions

diff --git a/policyhandler/onap/audit.py b/policyhandler/onap/audit.py
index d63d0b2..db4498a 100644
--- a/policyhandler/onap/audit.py
+++ b/policyhandler/onap/audit.py
@@ -1,5 +1,5 @@
 # ================================================================================
-# Copyright (c) 2017-2018 AT&T Intellectual Property. All rights reserved.
+# Copyright (c) 2017-2019 AT&T Intellectual Property. All rights reserved.
 # ================================================================================
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -185,12 +185,15 @@ class _Audit(object):
 
 
     @staticmethod
-    def register_item_health(health_name, health_getter):
+    def register_item_health(health_name, health_getter=None):
         """
         register the health-checker for the additional item
         by its health_name and the function health_getter that returns its health status as json
         """
-        _Audit._health_checkers[health_name] = health_getter
+        if health_getter:
+            _Audit._health_checkers[health_name] = health_getter
+        elif health_name in _Audit._health_checkers:
+            del _Audit._health_checkers[health_name]
 
     def health(self, full=False):
         """returns json for health check"""
@@ -401,8 +404,8 @@ class Audit(_Audit):
         self._started = time.time()
         self._start_event = Audit._logger_audit.getStartRecordEvent()
 
-        self.info("new audit{0} request_id {1}, msg({2}), kwargs({3})"\
-            .format(created_req, self.request_id, self.req_message, json.dumps(self.kwargs)))
+        self.info("new audit{0} request_id {1}, msg({2}), kwargs({3})"
+                  .format(created_req, self.request_id, self.req_message, json.dumps(self.kwargs)))
 
 
     def audit_done(self, result=None, **kwargs):