X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fproviders%2Fincoming_request_handler_provider.go;h=dc429667cae4cc8ef30deea69bc3fc72637673af;hb=refs%2Fchanges%2F32%2F732%2F1;hp=731fb25b2cebf2768c7be919a917141dee93eea4;hpb=07ef76dd471a0892a893c90e0ab06713aee34be1;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/providers/incoming_request_handler_provider.go b/E2Manager/providers/incoming_request_handler_provider.go index 731fb25..dc42966 100644 --- a/E2Manager/providers/incoming_request_handler_provider.go +++ b/E2Manager/providers/incoming_request_handler_provider.go @@ -23,6 +23,7 @@ import ( "e2mgr/handlers" "e2mgr/logger" "e2mgr/rNibWriter" + "e2mgr/services" "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/reader" ) @@ -30,6 +31,7 @@ type IncomingRequest string const( ShutdownRequest IncomingRequest = "Shutdown" + ResetRequest IncomingRequest = "Reset" ) type IncomingRequestHandlerProvider struct{ @@ -37,20 +39,21 @@ type IncomingRequestHandlerProvider struct{ logger *logger.Logger } -func NewIncomingRequestHandlerProvider(logger *logger.Logger, config *configuration.Configuration, rNibWriterProvider func() rNibWriter.RNibWriter, +func NewIncomingRequestHandlerProvider(logger *logger.Logger, rmrService *services.RmrService, config *configuration.Configuration, rNibWriterProvider func() rNibWriter.RNibWriter, rNibReaderProvider func() reader.RNibReader) *IncomingRequestHandlerProvider { return &IncomingRequestHandlerProvider{ - requestMap: initRequestHandlerMap(config, rNibWriterProvider, rNibReaderProvider), + requestMap: initRequestHandlerMap(rmrService, config, rNibWriterProvider, rNibReaderProvider), logger: logger, } } -func initRequestHandlerMap(config *configuration.Configuration, rNibWriterProvider func() rNibWriter.RNibWriter, +func initRequestHandlerMap(rmrService *services.RmrService,config *configuration.Configuration, rNibWriterProvider func() rNibWriter.RNibWriter, rNibReaderProvider func() reader.RNibReader) map[IncomingRequest]handlers.RequestHandler { return map[IncomingRequest]handlers.RequestHandler{ - ShutdownRequest: handlers.NewDeleteAllRequestHandler(config, rNibWriterProvider, rNibReaderProvider), //TODO change to pointer + ShutdownRequest: handlers.NewDeleteAllRequestHandler(rmrService, config, rNibWriterProvider, rNibReaderProvider), //TODO change to pointer + ResetRequest: handlers.NewX2ResetRequestHandler(rmrService, config, rNibWriterProvider, rNibReaderProvider), //TODO change to pointer } }