X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fcontrollers%2Fnodeb_controller.go;h=7b8a86fd3852f5f1d2023a74c05bf35cc8c1d51e;hb=a5f90ced0f8e4e9aeb89de647ca78089a91c1995;hp=fdfebe0519413c6c1fc0a8eb8374eaaaeebaf5e9;hpb=33f84e1a0998af025880be3e8eb087fac34af731;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/controllers/nodeb_controller.go b/E2Manager/controllers/nodeb_controller.go index fdfebe0..7b8a86f 100644 --- a/E2Manager/controllers/nodeb_controller.go +++ b/E2Manager/controllers/nodeb_controller.go @@ -13,151 +13,246 @@ // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. -// + +// This source code is part of the near-RT RIC (RAN Intelligent Controller) +// platform project (RICP). + package controllers import ( + "e2mgr/e2managererrors" "e2mgr/logger" "e2mgr/models" - "e2mgr/rNibWriter" - "e2mgr/services" - "e2mgr/sessions" - "e2mgr/utils" + "e2mgr/providers/httpmsghandlerprovider" "encoding/json" - "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common" - "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/reader" - "github.com/golang/protobuf/jsonpb" "github.com/gorilla/mux" + "io" + "io/ioutil" "net/http" - "time" + "net/http/httputil" + "strings" ) const ( - validationErrorCode int = 402 - notFoundErrorCode int = 404 - internalErrorCode int = 501 - validationFailedMessage = "Validation failed" - notFoundErrorMessage = "Resource not found" - internalErrorMessage = "Internal Server Error. Please try again later" + ParamRanName = "ranName" + LimitRequest = 2000 ) -var E2Sessions = make(sessions.E2Sessions) - -var messageChannel chan *models.E2RequestMessage -var errorChannel chan error - type INodebController interface { - GetNodebIdList (writer http.ResponseWriter, request *http.Request) - GetNodeb(writer http.ResponseWriter, request *http.Request) - HandleHealthCheckRequest(writer http.ResponseWriter, request *http.Request) + Shutdown(writer http.ResponseWriter, r *http.Request) + X2Reset(writer http.ResponseWriter, r *http.Request) + X2Setup(writer http.ResponseWriter, r *http.Request) + EndcSetup(writer http.ResponseWriter, r *http.Request) + GetNodeb(writer http.ResponseWriter, r *http.Request) + GetNodebIdList(writer http.ResponseWriter, r *http.Request) } type NodebController struct { - rmrService *services.RmrService - Logger *logger.Logger - rnibReaderProvider func() reader.RNibReader - rnibWriterProvider func() rNibWriter.RNibWriter + logger *logger.Logger + handlerProvider *httpmsghandlerprovider.IncomingRequestHandlerProvider } -func NewNodebController(logger *logger.Logger, rmrService *services.RmrService, rnibReaderProvider func() reader.RNibReader, rnibWriterProvider func() rNibWriter.RNibWriter) *NodebController { - messageChannel = make(chan *models.E2RequestMessage) - errorChannel = make(chan error) +func NewNodebController(logger *logger.Logger, handlerProvider *httpmsghandlerprovider.IncomingRequestHandlerProvider) *NodebController { return &NodebController{ - rmrService: rmrService, - Logger: logger, - rnibReaderProvider: rnibReaderProvider, - rnibWriterProvider: rnibWriterProvider, + logger: logger, + handlerProvider: handlerProvider, + } +} + +func (c *NodebController) GetNodebIdList(writer http.ResponseWriter, r *http.Request) { + c.logger.Infof("[Client -> E2 Manager] #NodebController.GetNodebIdList - request: %v", c.prettifyRequest(r)) + + c.handleRequest(writer, &r.Header, httpmsghandlerprovider.GetNodebIdListRequest, nil, false) +} + +func (c *NodebController) GetNodeb(writer http.ResponseWriter, r *http.Request) { + c.logger.Infof("[Client -> E2 Manager] #NodebController.GetNodeb - request: %v", c.prettifyRequest(r)) + vars := mux.Vars(r) + ranName := vars["ranName"] + request := models.GetNodebRequest{RanName: ranName} + c.handleRequest(writer, &r.Header, httpmsghandlerprovider.GetNodebRequest, request, false) +} + +func (c *NodebController) Shutdown(writer http.ResponseWriter, r *http.Request) { + c.logger.Infof("[Client -> E2 Manager] #NodebController.Shutdown - request: %v", c.prettifyRequest(r)) + c.handleRequest(writer, &r.Header, httpmsghandlerprovider.ShutdownRequest, nil, false) +} + +func (c *NodebController) X2Reset(writer http.ResponseWriter, r *http.Request) { + c.logger.Infof("[Client -> E2 Manager] #NodebController.X2Reset - request: %v", c.prettifyRequest(r)) + request := models.ResetRequest{} + vars := mux.Vars(r) + ranName := vars[ParamRanName] + + if r.ContentLength > 0 && !c.extractJsonBody(r, &request, writer) { + return } + request.RanName = ranName + c.handleRequest(writer, &r.Header, httpmsghandlerprovider.ResetRequest, request, false) } -func (rc NodebController) GetNodebIdList (writer http.ResponseWriter, request *http.Request) { - startTime := time.Now() - rnibReaderService := services.NewRnibReaderService(rc.rnibReaderProvider) - nodebIdList, rnibError := rnibReaderService.GetNodebIdList() +func (c *NodebController) X2Setup(writer http.ResponseWriter, r *http.Request) { + c.logger.Infof("[Client -> E2 Manager] #NodebController.X2Setup - request: %v", c.prettifyRequest(r)) + + request := models.SetupRequest{} - if rnibError != nil { - rc.Logger.Errorf("%v", rnibError); - httpStatusCode, errorCode, errorMessage := rnibErrorToHttpError(rnibError) - handleErrorResponse(rc.Logger, httpStatusCode, errorCode, errorMessage, writer, startTime) - return; + if !c.extractJsonBody(r, &request, writer) { + return } - pmList := utils.ConvertNodebIdListToProtoMessageList(nodebIdList) - result, err := utils.MarshalProtoMessageListToJsonArray(pmList) + c.handleRequest(writer, &r.Header, httpmsghandlerprovider.X2SetupRequest, request, true) +} + +func (c *NodebController) EndcSetup(writer http.ResponseWriter, r *http.Request) { + c.logger.Infof("[Client -> E2 Manager] #NodebController.EndcSetup - request: %v", c.prettifyRequest(r)) + + request := models.SetupRequest{} + + if !c.extractJsonBody(r, &request, writer) { + return + } + + c.handleRequest(writer, &r.Header, httpmsghandlerprovider.EndcSetupRequest, request, true) +} + +func (c *NodebController) extractJsonBody(r *http.Request, request models.Request, writer http.ResponseWriter) bool { + defer r.Body.Close() + body, err := ioutil.ReadAll(io.LimitReader(r.Body, LimitRequest)) if err != nil { - rc.Logger.Errorf("%v", err); - handleErrorResponse(rc.Logger, http.StatusInternalServerError, internalErrorCode, internalErrorMessage, writer, startTime) - return; + c.logger.Errorf("[Client -> E2 Manager] #NodebController.extractJsonBody - unable to extract json body - error: %s", err) + c.handleErrorResponse(e2managererrors.NewInvalidJsonError(), writer) + return false } - writer.Header().Set("Content-Type", "application/json") - rc.Logger.Infof("[E2 Manager -> Client] #nodeb_controller.GetNodebIdList - response: %s", result) - writer.Write([]byte(result)) + err = json.Unmarshal(body, &request) + if err != nil { + c.logger.Errorf("[Client -> E2 Manager] #NodebController.extractJsonBody - unable to extract json body - error: %s", err) + c.handleErrorResponse(e2managererrors.NewInvalidJsonError(), writer) + return false + } + + return true } -func (rc NodebController) GetNodeb(writer http.ResponseWriter, request *http.Request) { - startTime := time.Now() - vars := mux.Vars(request) - ranName := vars["ranName"] - // WAS: respondingNode, rnibError := reader.GetRNibReader().GetNodeb(ranName) - rnibReaderService := services.NewRnibReaderService(rc.rnibReaderProvider) - respondingNode, rnibError := rnibReaderService.GetNodeb(ranName) - if rnibError != nil { - rc.Logger.Errorf("%v", rnibError) - httpStatusCode, errorCode, errorMessage := rnibErrorToHttpError(rnibError) - handleErrorResponse(rc.Logger, httpStatusCode, errorCode, errorMessage, writer, startTime) +func (c *NodebController) handleRequest(writer http.ResponseWriter, header *http.Header, requestName httpmsghandlerprovider.IncomingRequest, request models.Request, validateHeader bool) { + + if validateHeader { + + err := c.validateRequestHeader(header) + if err != nil { + c.handleErrorResponse(err, writer) + return + } + } + + handler, err := c.handlerProvider.GetHandler(requestName) + + if err != nil { + c.handleErrorResponse(err, writer) return } - m := jsonpb.Marshaler{} - result, err := m.MarshalToString(respondingNode) + response, err := handler.Handle(request) if err != nil { - rc.Logger.Errorf("%v", err) - handleErrorResponse(rc.Logger, http.StatusInternalServerError, internalErrorCode, internalErrorMessage, writer, startTime) + c.handleErrorResponse(err, writer) return } + if response == nil { + writer.WriteHeader(http.StatusNoContent) + c.logger.Infof("[E2 Manager -> Client] #NodebController.handleRequest - status response: %v", http.StatusNoContent) + return + } + + result, err := response.Marshal() + + if err != nil { + c.handleErrorResponse(err, writer) + return + } + + c.logger.Infof("[E2 Manager -> Client] #NodebController.handleRequest - response: %s", result) writer.Header().Set("Content-Type", "application/json") - rc.Logger.Infof("[E2 Manager -> Client] #nodeb_controller.GetNodeb - response: %s", result) - writer.Write([]byte(result)) + writer.Write(result) } -func (rc NodebController) HandleHealthCheckRequest(writer http.ResponseWriter, request *http.Request) { - //fmt.Println("[X-APP -> Client] #HandleHealthCheckRequest - http status: 200") - writer.WriteHeader(http.StatusOK) +func (c *NodebController) validateRequestHeader(header *http.Header) error { + + if header.Get("Content-Type") != "application/json" { + c.logger.Errorf("#NodebController.validateRequestHeader - validation failure, incorrect content type") + + return e2managererrors.NewHeaderValidationError() + } + return nil } -func handleErrorResponse(logger *logger.Logger, httpStatus int, errorCode int, errorMessage string, writer http.ResponseWriter, startTime time.Time) { - errorResponseDetails := models.ErrorResponse{errorCode, errorMessage} - errorResponse, _ := json.Marshal(errorResponseDetails) - printHandlingRequestElapsedTimeInMs(logger, startTime) - logger.Infof("[E2 Manager -> Client] #nodeb_controller.handleErrorResponse - http status: %d, error response: %+v", httpStatus, errorResponseDetails) - writer.Header().Set("Content-Type", "application/json") - writer.WriteHeader(httpStatus) - _, err := writer.Write(errorResponse) +func (c *NodebController) handleErrorResponse(err error, writer http.ResponseWriter) { + + var errorResponseDetails models.ErrorResponse + var httpError int if err != nil { - logger.Errorf("#nodeb_controller.handleErrorResponse - Cannot send response. writer:%v", writer) + switch err.(type) { + case *e2managererrors.RnibDbError: + e2Error, _ := err.(*e2managererrors.RnibDbError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusInternalServerError + case *e2managererrors.CommandAlreadyInProgressError: + e2Error, _ := err.(*e2managererrors.CommandAlreadyInProgressError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusMethodNotAllowed + case *e2managererrors.HeaderValidationError: + e2Error, _ := err.(*e2managererrors.HeaderValidationError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusUnsupportedMediaType + case *e2managererrors.WrongStateError: + e2Error, _ := err.(*e2managererrors.WrongStateError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusBadRequest + case *e2managererrors.RequestValidationError: + e2Error, _ := err.(*e2managererrors.RequestValidationError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusBadRequest + case *e2managererrors.InvalidJsonError: + e2Error, _ := err.(*e2managererrors.InvalidJsonError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusBadRequest + case *e2managererrors.RmrError: + e2Error, _ := err.(*e2managererrors.RmrError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusInternalServerError + case *e2managererrors.ResourceNotFoundError: + e2Error, _ := err.(*e2managererrors.ResourceNotFoundError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusNotFound + case *e2managererrors.E2TInstanceAbsenceError: + e2Error, _ := err.(*e2managererrors.E2TInstanceAbsenceError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusServiceUnavailable + case *e2managererrors.RoutingManagerError: + e2Error, _ := err.(*e2managererrors.RoutingManagerError) + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusServiceUnavailable + default: + e2Error := e2managererrors.NewInternalError() + errorResponseDetails = models.ErrorResponse{Code: e2Error.Code, Message: e2Error.Message} + httpError = http.StatusInternalServerError + } } -} + errorResponse, _ := json.Marshal(errorResponseDetails) -func printHandlingRequestElapsedTimeInMs(logger *logger.Logger, startTime time.Time) { - logger.Infof("Summary: #nodeb_controller.printElapsedTimeInMs - Elapsed time for handling request from client to E2 termination: %f ms", - float64(time.Since(startTime))/float64(time.Millisecond)) + c.logger.Errorf("[E2 Manager -> Client] #NodebController.handleErrorResponse - http status: %d, error response: %+v", httpError, errorResponseDetails) + + writer.Header().Set("Content-Type", "application/json") + writer.WriteHeader(httpError) + _, err = writer.Write(errorResponse) } -func rnibErrorToHttpError(rnibError error) (int, int, string) { - switch rnibError.(type) { - case *common.ResourceNotFoundError: - return http.StatusNotFound, notFoundErrorCode, notFoundErrorMessage - case *common.InternalError: - return http.StatusInternalServerError, internalErrorCode, internalErrorMessage - case *common.ValidationError: - return http.StatusBadRequest, validationErrorCode, validationFailedMessage - default: - return http.StatusInternalServerError, internalErrorCode, internalErrorMessage - } +func (c *NodebController) prettifyRequest(request *http.Request) string { + dump, _ := httputil.DumpRequest(request, true) + requestPrettyPrint := strings.Replace(string(dump), "\r\n", " ", -1) + return strings.Replace(requestPrettyPrint, "\n", "", -1) }