A1 Mediator enhancements for A1-EI

[ric-plt/a1.git] / a1 / messages.py

diff --git a/a1/messages.py b/a1/messages.py
index fc22bcb..3663053 100644 (file)
--- a/a1/messages.py
+++ b/a1/messages.py
@@ -29,3 +29,13 @@ def a1_to_handler(operation, policy_type_id, policy_instance_id, payload=None):
         "policy_instance_id": policy_instance_id,
         "payload": payload,
     }
+
+
+def ei_to_handler(ei_job_id, payload=None):
+    """
+    used to create the payloads that get sent to downstream policy handlers
+    """
+    return {
+        "ei_job_id": ei_job_id,
+        "payload": payload,
+    }