X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Ftest_subs.h;h=d831c96414cf37ef351a5631761ecee8b62cf94a;hb=21294a186445672e15db465618064642443cc39a;hp=2c33d55e6c34283bf6bf178081d2474b6f364e8a;hpb=e86af0d54882624aafd1281eebaa3972921d1a01;p=ric-app%2Fhw.git

diff --git a/test/test_subs.h b/test/test_subs.h
index 2c33d55..d831c96 100644
--- a/test/test_subs.h
+++ b/test/test_subs.h
@@ -60,5 +60,37 @@ TEST(SUBSCRIPTION, Request){
 
 }
 
+//create a MOck e2term
+TEST (MOCK, E2TERM){
+
+	 const char* meid = "test1";
+	 const char* sub_id = "sub1";
+	 //Send the Subscription Response.
+	 xapp_rmr_header hdr;
+	 hdr.message_type = RIC_SUB_RESP;
+	 clock_gettime(CLOCK_REALTIME, &(hdr.ts));
+	 const char* strMsg = "Subscription Response for MEID: test1";
+	 hdr.payload_length = strlen(strMsg);
+	 strcpy((char*)hdr.meid, meid);
+	 strcpy((char*)hdr.sid,sub_id);
+	 int total_num_msgs = 2;
+	 int num_attempts = 10;
+
+	 std::unique_ptr<XappRmr> rmr;
+	 rmr = std::make_unique<XappRmr>("4591",num_attempts);
+	 rmr->xapp_rmr_init(true);
+
+	 XappSettings config;
+
+	 std::unique_ptr<Xapp> hw_xapp = std::make_unique<Xapp>(std::ref(config),std::ref(*rmr));
+	 while(1){
+		 bool res_msg = rmr->xapp_rmr_send(&hdr,(void*)strMsg);
+		 if(res_msg){
+			 mdclog_write(MDCLOG_INFO, "Message Sent Successfully");
+			 break;
+		 }
+		 sleep(10);
+	 }
+}
 
 #endif /* TEST_TEST_SUBS_H_ */