1 files changed, 63 insertions, 0 deletions
diff --git a/tests/main/test_pz_catch_up.py b/tests/main/test_pz_catch_up.py
new file mode 100644
index 0000000..03f5957
--- /dev/null
+++ b/tests/main/test_pz_catch_up.py
@@ -0,0 +1,63 @@
+# ============LICENSE_START=======================================================
+# Copyright (c) 2020 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.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+# ============LICENSE_END=========================================================
+#
+"""test policy catch_up methods directly"""
+
+import json
+import time
+
+import pytest
+
+from policyhandler.onap.audit import Audit
+from policyhandler.policy_receiver import PolicyReceiver
+from policyhandler.utils import Utils
+
+from ..mock_tracker import Tracker
+
+_LOGGER = Utils.get_logger(__file__)
+
+@pytest.mark.usefixtures(
+    "fix_pdp_authorization",
+    "fix_discovery",
+    "fix_pdp_post",
+    "fix_deploy_handler",
+    "fix_dmaap_mr",
+    "fix_auto_catch_up"
+)
+def test_catch_up():
+    """test run policy handler with catchups and failed deployment-handler"""
+    _LOGGER.info("start test_catch_up")
+    assert not PolicyReceiver.is_running()
+    audit = Audit(job_name="test_catch_up", req_message="start test_catch_up")
+    PolicyReceiver.run(audit)
+
+    _LOGGER.info("sleep 12 before shutdown...")
+    time.sleep(12)
+
+    health = audit.health(full=True)
+    audit.audit_done(result=json.dumps(health))
+
+    _LOGGER.info("healthcheck: %s", json.dumps(health))
+    assert bool(health)
+
+    PolicyReceiver.shutdown(audit)
+    time.sleep(5)
+    assert not PolicyReceiver.is_running()
+
+    health = audit.health(full=True)
+    _LOGGER.info("healthcheck: %s", json.dumps(health))
+
+    Tracker.validate()