X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Frtmgr%2Frtmgr.go;h=5b27d76a6c43ffdbb19be9666fd8be6a69d23da4;hb=92162653c9741f2417d1a36ec1c211d6863d0a68;hp=9dd956ed97d11d2c1681f4e44a2774104b5be619;hpb=419d851344e85fffeeb9a65726cd02e97dbfe7df;p=ric-plt%2Frtmgr.git

diff --git a/pkg/rtmgr/rtmgr.go b/pkg/rtmgr/rtmgr.go
index 9dd956e..5b27d76 100644
--- a/pkg/rtmgr/rtmgr.go
+++ b/pkg/rtmgr/rtmgr.go
@@ -26,11 +26,17 @@ package rtmgr
 
 import (
 	"github.com/jcelliott/lumber"
+	"errors"
+	"strings"
+	"os"
+	"io/ioutil"
+	"encoding/json"
 )
 
 var (
 	//TODO: temporary solution
 	// CamelCase Message Types are for being able to test with old fashioned admin controll xApps
+	// TODO: Add a seperate message definition file (Not using the one from RMR to not create dependency on that library).
 	MESSAGETYPES = map[string]string{
 		"HandoverPreparation":              "0",
 		"HandoverCancel":                   "1",
@@ -51,22 +57,98 @@ var (
 		"RIC_E2_MANAGER_HC_RESPONSE":       "10008",
 		"RIC_CONTROL_XAPP_CONFIG_REQUEST":  "100000",
 		"RIC_CONTROL_XAPP_CONFIG_RESPONSE": "100001",
+
+		"RIC_X2_SETUP_REQ":                 "10060",
+		"RIC_X2_SETUP_RESP":                "10061",
+		"RIC_X2_SETUP_FAILURE":             "10062",
+		"RIC_X2_RESET":                     "10070",
+		"RIC_X2_RESET_RESP":                "10071",
+
+		"RIC_SUB_REQ":                      "12010",
+		"RIC_SUB_RESP":                     "12011",
+		"RIC_SUB_FAILURE":                  "12012",
+		"RIC_SUB_DEL_REQ":                  "12020",
+		"RIC_SUB_DEL_RESP":                 "12021",
+		"RIC_SUB_DEL_FAILURE":              "12022",
+
+		"RIC_CONTROL_REQ":                  "12040",
+		"RIC_CONTROL_ACK":                  "12041",
+		"RIC_CONTROL_FAILURE":              "12042",
+		"RIC_INDICATION":		    "12050",
+		"RIC_ENDC_X2_SETUP_REQ":            "10360",
+		"RIC_ENDC_X2_SETUP_RESP":           "10361",
+		"RIC_ENDC_X2_SETUP_FAILURE":        "10362",
+		"RIC_ENDC_CONF_UPDATE":             "10370",
+		"RIC_ENDC_CONF_UPDATE_ACK":         "10371",
+		"RIC_ENDC_CONF_UPDATE_FAILURE":     "10372",
+		"RIC_RES_STATUS_REQ":               "10090",
+		"RIC_RES_STATUS_RESP":              "10091",
+		"RIC_RES_STATUS_FAILURE":           "10092",
+		"RIC_ENB_CONF_UPDATE":              "10080",
+		"RIC_ENB_CONF_UPDATE_ACK":          "10081",
+		"RIC_ENB_CONF_UPDATE_FAILURE":      "10082",
+		"RIC_ENB_LOAD_INFORMATION":         "10020",
+		"RIC_GNB_STATUS_INDICATION":        "10450",
+		"RIC_RESOURCE_STATUS_UPDATE":       "10100",
+		"RIC_ERROR_INDICATION":             "10030",
+		"DC_ADM_INT_CONTROL":               "20000",
+		"DC_ADM_INT_CONTROL_ACK":           "20001",
 	}
+
+	// Messagetype mappings for the platform components. 
+	// This implements static default routes needed by the RIC. Needs to be changed in case new components/message types needes to be added/updated.
+	// Representation : {"componentName1": {"tx": <tx message type list>, "rx": <rx message type list>}}
+	PLATFORMMESSAGETYPES = map[string]map[string][]string{
+		"E2TERM":   {"tx": []string{"RIC_X2_SETUP_REQ", "RIC_X2_SETUP_RESP", "RIC_X2_SETUP_FAILURE", "RIC_X2_RESET", "RIC_X2_RESET_RESP", "RIC_ENDC_X2_SETUP_REQ", "RIC_ENDC_X2_SETUP_RESP", "RIC_ENDC_X2_SETUP_FAILURE", "RIC_SUB_RESP", "RIC_SUB_FAILURE", "RIC_SUB_DEL_RESP", "RIC_SUB_DEL_FAILURE"}, "rx": []string{"RIC_X2_SETUP_REQ", "RIC_X2_SETUP_RESP", "RIC_X2_SETUP_FAILURE", "RIC_X2_RESET", "RIC_X2_RESET_RESP", "RIC_ENDC_X2_SETUP_REQ", "RIC_ENDC_X2_SETUP_RESP", "RIC_ENDC_X2_SETUP_FAILURE", "RIC_SUB_REQ", "RIC_SUB_DEL_REQ", "RIC_CONTROL_REQ"}},
+		"E2MAN":    {"tx": []string{"RIC_X2_SETUP_REQ", "RIC_X2_SETUP_RESP", "RIC_X2_SETUP_FAILURE", "RIC_X2_RESET", "RIC_X2_RESET_RESP", "RIC_ENDC_X2_SETUP_REQ", "RIC_ENDC_X2_SETUP_RESP", "RIC_ENDC_X2_SETUP_FAILURE"}, "rx": []string{"RIC_X2_SETUP_REQ", "RIC_X2_SETUP_RESP", "RIC_X2_SETUP_FAILURE", "RIC_X2_RESET", "RIC_X2_RESET_RESP", "RIC_ENDC_X2_SETUP_REQ", "RIC_ENDC_X2_SETUP_RESP", "RIC_ENDC_X2_SETUP_FAILURE"}},
+		"SUBMAN":   {"tx": []string{"RIC_SUB_REQ", "RIC_SUB_DEL_REQ"}, "rx": []string{"RIC_SUB_RESP", "RIC_SUB_FAILURE", "RIC_SUB_DEL_RESP", "RIC_SUB_DEL_FAILURE"}},
+		"UEMAN":    {"tx": []string{"RIC_CONTROL_REQ"}, "rx": []string{}},
+	}
+
 	Logger = lumber.NewConsoleLogger(lumber.INFO)
-	Eps Endpoints
+	Eps    Endpoints
+	Subs   SubscriptionList
 )
 
-func SetLogLevel(loglevel string) {
-	switch loglevel {
+func SetLogLevel(loglevel string) error{
+	switch strings.ToUpper(loglevel) {
 	case "INFO":
 		Logger.Level(lumber.INFO)
+		return nil
 	case "WARN":
 		Logger.Level(lumber.WARN)
+		return nil
 	case "ERROR":
 		Logger.Level(lumber.ERROR)
+		return nil
 	case "DEBUG":
 		Logger.Info("debugmode")
 		Logger.Level(lumber.DEBUG)
+		return nil
+	default:
+		Logger.Error("Invalid log mode, setting info")
+		Logger.Level(lumber.INFO)
+		return errors.New("Invalid log level, setting info")
+	}
+}
+
+func GetPlatformComponents(configfile string) (*PlatformComponents, error) {
+	Logger.Debug("Invoked rtmgr.GetPlatformComponents("+ configfile +")")
+	var rcfg RtmgrConfig
+	jsonFile, err := os.Open(configfile)
+	if err != nil {
+		return nil, errors.New("cannot open the file due to: " + err.Error())
+	}
+	defer jsonFile.Close()
+	byteValue, err := ioutil.ReadAll(jsonFile)
+	if err != nil {
+		return nil, errors.New("cannot read the file due to: " + err.Error())
+	}
+	err = json.Unmarshal(byteValue, &rcfg)
+	if err != nil {
+		return nil, errors.New("cannot parse data due to: " + err.Error())
 	}
+	Logger.Debug("Platform components read from the configfile:  %v", rcfg.Pcs)
+	return &(rcfg.Pcs), nil
 }