Incorporating A1 HealthCheck functionality
[ric-app/hw.git] / src / xapp-mgmt / msgs_proc.hpp
index ed9941f..8637440 100644 (file)
 #include <rmr/RIC_message_types.h>
 #include <mdclog/mdclog.h>
 
-
-#include <subscription_request.hpp>
-#include <subscription_response.hpp>
-#include <subscription_delete_request.hpp>
-#include <subscription_delete_response.hpp>
-#include "subscription_request.hpp"
+#include "e2ap_control.hpp"
+#include "e2ap_control_response.hpp"
+#include "e2ap_indication.hpp"
+#include "subscription_delete_request.hpp"
+#include "subscription_delete_response.hpp"
 #include "subscription_helper.hpp"
+#include "subscription_request.hpp"
+#include "subscription_request.hpp"
+#include "subscription_response.hpp"
 #include "e2sm.hpp"
-#include <e2ap_indication.hpp>
-#include <e2ap_control.hpp>
-#include <e2ap_control_response.hpp>
+#include "format_helper.hpp"
 
 #define MAX_RMR_RECV_SIZE 2<<15
 
 class XappMsgHandler{
 
 private:
-       unsigned char* message_buffer;
-       size_t* message_length;
-
+       std::string xapp_id;
 public:
+       //constructor for xapp_id.
+        XappMsgHandler(std::string xid){xapp_id=xid;};
         void operator() (rmr_mbuf_t *, bool*);
 
         bool encode_subscription_request(unsigned char*, size_t* );
@@ -61,6 +61,7 @@ public:
         bool decode_subscription_response_failure(unsigned char*, size_t );
         bool decode_subscription_delete_response_failure(unsigned char*, size_t );
 
+        bool a1_policy_handler(char *, int* , a1_policy_helper &);
 
 };