"e2mgr/services/rmrreceiver"
"e2mgr/services/rmrsender"
"fmt"
+ "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
"gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/reader"
"gerrit.o-ran-sc.org/r/ric-plt/sdlgo"
"os"
"strconv"
)
+const GeneralKeyDefaultValue = "{\"enableRic\":true}"
+
+func initKeys(logger *logger.Logger, sdl *sdlgo.SyncStorage) error {
+ ok, err := sdl.SetIfNotExists(common.GetRNibNamespace(), common.BuildGeneralConfigurationKey(), GeneralKeyDefaultValue)
+
+ if err != nil {
+ logger.Errorf("#app.main - Failed setting GENERAL key")
+ return err
+ }
+
+ if ok {
+ logger.Infof("#app.main - Successfully set GENERAL key")
+ } else {
+ logger.Infof("#app.main - GENERAL key exists, no need to set")
+ }
+
+ return nil
+
+}
+
func main() {
config := configuration.ParseConfiguration()
logLevel, _ := logger.LogLevelTokenToLevel(config.Logging.LogLevel)
os.Exit(1)
}
logger.Infof("#app.main - Configuration %s", config)
- db := sdlgo.NewDatabase()
- sdl := sdlgo.NewSdlInstance("e2Manager", db)
+ sdl := sdlgo.NewSyncStorage()
+ err = initKeys(logger, sdl)
+
+ if err != nil {
+ os.Exit(1)
+ }
+
defer sdl.Close()
- rnibDataService := services.NewRnibDataService(logger, config, reader.GetRNibReader(sdl), rNibWriter.GetRNibWriter(sdl, config.RnibWriter))
+ rnibDataService := services.NewRnibDataService(logger, config, reader.GetNewRNibReader(sdl), rNibWriter.GetRNibWriter(sdl, config.RnibWriter))
ranListManager := managers.NewRanListManager(logger, rnibDataService)
rootController := controllers.NewRootController(rnibDataService)
nodebController := controllers.NewNodebController(logger, httpMsgHandlerProvider)
e2tController := controllers.NewE2TController(logger, httpMsgHandlerProvider)
- _ = httpserver.Run(logger, config.Http.Port, rootController, nodebController, e2tController)
+ symptomController := controllers.NewSymptomdataController(logger, httpMsgHandlerProvider, rnibDataService, ranListManager)
+ _ = httpserver.Run(logger, config.Http.Port, rootController, nodebController, e2tController, symptomController)
}