X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Frtmgr%2Frtmgr.go;h=e5e0dcb8aa88afcb11f0cf447bf5bb5e72279835;hb=ab07a4edbce65cc015e025109f51ea32022b2040;hp=daf84b84ee41cf3dbd9ddd26e91b03bbde62efc6;hpb=a8596ec6db91b8a45a1a21421a726b9b05ce7d48;p=ric-plt%2Frtmgr.git

diff --git a/pkg/rtmgr/rtmgr.go b/pkg/rtmgr/rtmgr.go
index daf84b8..e5e0dcb 100644
--- a/pkg/rtmgr/rtmgr.go
+++ b/pkg/rtmgr/rtmgr.go
@@ -35,6 +35,7 @@ import (
 	"github.com/ghodss/yaml"
 	"io/ioutil"
 	"os"
+	"strings"
 )
 
 var (
@@ -51,6 +52,8 @@ var (
 		"X2Setup":                          "6",
 		"Reset":                            "7",
 		"E2_TERM_INIT":                     "1100",
+		"E2_TERM_KEEP_ALIVE_REQ":            "1101",
+		"E2_TERM_KEEP_ALIVE_RESP":           "1102",
 		"RAN_CONNECTED":                    "1200",
 		"RAN_RESTARTED":                    "1210",
 		"RAN_RECONFIGURED":                 "1220",
@@ -119,11 +122,16 @@ var (
 
 	Eps  Endpoints
 	Subs SubscriptionList
+	PrsCfg  *PlatformRoutes
+	Mtype MessageTypeList
+	DynamicRouteList []string
 )
 
 func GetPlatformComponents(configfile string) (*PlatformComponents, error) {
 	xapp.Logger.Debug("Invoked rtmgr.GetPlatformComponents(" + configfile + ")")
 	var rcfg ConfigRtmgr
+	var rtroutes RtmgrRoutes
+	var mtypes MessageTypeIdentifier
 	yamlFile, err := os.Open(configfile)
 	if err != nil {
 		return nil, errors.New("cannot open the file due to: " + err.Error())
@@ -137,6 +145,22 @@ func GetPlatformComponents(configfile string) (*PlatformComponents, error) {
 	if err != nil {
 		return nil, errors.New("cannot read the file due to: " + err.Error())
 	}
+	err = json.Unmarshal(jsonByteValue,&rtroutes)
+        if err != nil {
+               return nil, errors.New("cannot parse data due to: " + err.Error())
+        }
+        PrsCfg = &(rtroutes.Prs)
+
+	err = json.Unmarshal(jsonByteValue,&mtypes)
+        if err != nil {
+               return nil, errors.New("cannot parse data due to: " + err.Error())
+        } else {
+		xapp.Logger.Debug("Messgaetypes = %v", mtypes)
+		for _,m := range mtypes.Mit {
+			splitstr := strings.Split(m,"=")
+			Mtype[splitstr[0]] = splitstr[1]
+		}
+	}
 	err = json.Unmarshal(jsonByteValue, &rcfg)
 	if err != nil {
 		return nil, errors.New("cannot parse data due to: " + err.Error())