X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1-go%2Fpkg%2Fresthooks%2Fresthooks.go;h=c57c2e84d00f5d27f3d42e285a9424e8703f192f;hb=2705dc9e68c52693a510aca78a8c74c7fb042c7c;hp=e0060f1b9632d3136044a347b001292099568458;hpb=52ef1de13a1c245638264c3025eea0bf2fb8eb42;p=ric-plt%2Fa1.git

diff --git a/a1-go/pkg/resthooks/resthooks.go b/a1-go/pkg/resthooks/resthooks.go
index e0060f1..c57c2e8 100644
--- a/a1-go/pkg/resthooks/resthooks.go
+++ b/a1-go/pkg/resthooks/resthooks.go
@@ -42,6 +42,8 @@ const (
 	a1InstancePrefix         = "a1.policy_instance."
 	a1InstanceMetadataPrefix = "a1.policy_inst_metadata."
 	a1HandlerPrefix          = "a1.policy_handler."
+	a1PolicyRequest          = 20010
+	a1EIDataDelivery         = 20017
 )
 
 var typeAlreadyError = errors.New("Policy Type already exists")
@@ -382,7 +384,7 @@ func (rh *Resthook) CreatePolicyInstance(policyTypeId models.PolicyTypeID, polic
 			a1.Logger.Error("error : %v", err)
 			return err
 		}
-		isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage)
+		isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1PolicyRequest)
 		if isSent {
 			a1.Logger.Debug("rmrSendToXapp : message sent")
 		} else {
@@ -671,7 +673,7 @@ func (rh *Resthook) DeletePolicyInstance(policyTypeId models.PolicyTypeID, polic
 		a1.Logger.Error("error : %v", err)
 		return err
 	}
-	isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage)
+	isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1PolicyRequest)
 	if isSent {
 		a1.Logger.Debug("rmrSendToXapp : message sent")
 	} else {
@@ -681,3 +683,22 @@ func (rh *Resthook) DeletePolicyInstance(policyTypeId models.PolicyTypeID, polic
 
 	return nil
 }
+
+func (rh *Resthook) DataDelivery(httpBody interface{}) error {
+	a1.Logger.Debug("httpbody : %+v", httpBody)
+	mymap := httpBody.(map[string]interface{})
+	message := rmr.Message{}
+	rmrMessage, err := message.A1EIMessage(mymap["job"].(string), mymap["payload"].(string))
+	if err != nil {
+		a1.Logger.Error("error : %v", err)
+		return err
+	}
+	a1.Logger.Debug("rmrSendToXapp :rmrMessage %+v", rmrMessage)
+	isSent := rh.iRmrSenderInst.RmrSendToXapp(rmrMessage, a1EIDataDelivery)
+	if isSent {
+		a1.Logger.Debug("rmrSendToXapp : message sent")
+	} else {
+		a1.Logger.Error("rmrSendToXapp : message not sent")
+	}
+	return nil
+}