E2Manager/handlers/httpmsghandlers/x2_reset_request_handler_test.go

   1 //
   2 // Copyright 2019 AT&T Intellectual Property
   3 // Copyright 2019 Nokia
   4 //
   5 // Licensed under the Apache License, Version 2.0 (the "License");
   6 // you may not use this file except in compliance with the License.
   7 // You may obtain a copy of the License at
   8 //
   9 //      http://www.apache.org/licenses/LICENSE-2.0
  10 //
  11 // Unless required by applicable law or agreed to in writing, software
  12 // distributed under the License is distributed on an "AS IS" BASIS,
  13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 // See the License for the specific language governing permissions and
  15 // limitations under the License.
  16
  17 //  This source code is part of the near-RT RIC (RAN Intelligent Controller)
  18 //  platform project (RICP).
  19
  20
  21 package httpmsghandlers
  22
  23 import (
  24         "e2mgr/configuration"
  25         "e2mgr/e2managererrors"
  26         "e2mgr/mocks"
  27         "e2mgr/models"
  28         "e2mgr/rmrCgo"
  29         "e2mgr/services"
  30         "fmt"
  31         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
  32         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
  33         "github.com/stretchr/testify/assert"
  34         "testing"
  35         "unsafe"
  36 )
  37
  38 func setupX2ResetRequestHandlerTest(t *testing.T) (*X2ResetRequestHandler, *mocks.RmrMessengerMock, *mocks.RnibReaderMock) {
  39         log := initLog(t)
  40         config := &configuration.Configuration{RnibRetryIntervalMs: 10, MaxRnibConnectionAttempts: 3}
  41         readerMock := &mocks.RnibReaderMock{}
  42         writerMock := &mocks.RnibWriterMock{}
  43         rnibDataService := services.NewRnibDataService(log, config, readerMock, writerMock)
  44         rmrMessengerMock := &mocks.RmrMessengerMock{}
  45         rmrSender := getRmrSender(rmrMessengerMock, log)
  46         handler := NewX2ResetRequestHandler(log, rmrSender, rnibDataService)
  47
  48         return handler, rmrMessengerMock, readerMock
  49 }
  50 func TestHandleSuccessfulDefaultCause(t *testing.T) {
  51         handler, rmrMessengerMock, readerMock := setupX2ResetRequestHandlerTest(t)
  52
  53         ranName := "test1"
  54         // o&m intervention
  55         payload := []byte{0x00, 0x07, 0x00, 0x08, 0x00, 0x00, 0x01, 0x00, 0x05, 0x40, 0x01, 0x64}
  56         var xAction[]byte
  57         var msgSrc unsafe.Pointer
  58         msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_RESET, len(payload), ranName, &payload, &xAction, msgSrc)
  59
  60         rmrMessengerMock.On("SendMsg", msg, true).Return(msg, nil)
  61
  62         var nodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED}
  63         readerMock.On("GetNodeb", ranName).Return(nodeb, nil)
  64
  65         _, actual := handler.Handle(models.ResetRequest{RanName: ranName})
  66
  67         assert.Nil(t, actual)
  68 }
  69
  70 func TestHandleSuccessfulRequestedCause(t *testing.T) {
  71         handler, rmrMessengerMock, readerMock := setupX2ResetRequestHandlerTest(t)
  72
  73         ranName := "test1"
  74         payload := []byte{0x00, 0x07, 0x00, 0x08, 0x00, 0x00, 0x01, 0x00, 0x05, 0x40, 0x01, 0x40}
  75         var xAction[]byte
  76         var msgSrc unsafe.Pointer
  77         msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_RESET, len(payload), ranName, &payload, &xAction, msgSrc)
  78         rmrMessengerMock.On("SendMsg", msg, true).Return(msg, nil)
  79
  80         var nodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED}
  81         readerMock.On("GetNodeb", ranName).Return(nodeb, nil)
  82
  83         _, actual := handler.Handle(models.ResetRequest{RanName: ranName, Cause: "protocol:transfer-syntax-error"})
  84
  85         assert.Nil(t, actual)
  86 }
  87
  88 func TestHandleFailureUnknownCause(t *testing.T) {
  89         handler, _, readerMock := setupX2ResetRequestHandlerTest(t)
  90
  91         ranName := "test1"
  92         var nodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED}
  93         readerMock.On("GetNodeb", ranName).Return(nodeb, nil)
  94
  95         _, actual := handler.Handle(models.ResetRequest{RanName: ranName, Cause: "XXX"})
  96
  97         assert.IsType(t, e2managererrors.NewRequestValidationError(), actual)
  98
  99 }
 100
 101 func TestHandleFailureWrongState(t *testing.T) {
 102         handler, _, readerMock := setupX2ResetRequestHandlerTest(t)
 103
 104         ranName := "test1"
 105         var nodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_DISCONNECTED}
 106         readerMock.On("GetNodeb", ranName).Return(nodeb, nil)
 107
 108         _, actual := handler.Handle(models.ResetRequest{RanName: ranName})
 109
 110         assert.IsType(t, e2managererrors.NewWrongStateError(X2_RESET_ACTIVITY_NAME, entities.ConnectionStatus_name[int32(nodeb.ConnectionStatus)]), actual)
 111 }
 112
 113 func TestHandleFailureRanNotFound(t *testing.T) {
 114         handler, _, readerMock := setupX2ResetRequestHandlerTest(t)
 115
 116         ranName := "test1"
 117
 118         readerMock.On("GetNodeb", ranName).Return(&entities.NodebInfo{}, common.NewResourceNotFoundError("nodeb not found"))
 119
 120         _, actual := handler.Handle(models.ResetRequest{RanName: ranName})
 121
 122         assert.IsType(t, e2managererrors.NewResourceNotFoundError(), actual)
 123 }
 124
 125 func TestHandleFailureRnibError(t *testing.T) {
 126         handler, _, readerMock := setupX2ResetRequestHandlerTest(t)
 127
 128         ranName := "test1"
 129
 130         readerMock.On("GetNodeb", ranName).Return(&entities.NodebInfo{}, common.NewInternalError(fmt.Errorf("internal error")))
 131
 132         _, actual := handler.Handle(models.ResetRequest{RanName: ranName})
 133
 134         assert.IsType(t, e2managererrors.NewRnibDbError(), actual)
 135 }
 136
 137 func TestHandleFailureRmrError(t *testing.T) {
 138         handler, rmrMessengerMock, readerMock := setupX2ResetRequestHandlerTest(t)
 139
 140         ranName := "test1"
 141         // o&m intervention
 142         payload := []byte{0x00, 0x07, 0x00, 0x08, 0x00, 0x00, 0x01, 0x00, 0x05, 0x40, 0x01, 0x64}
 143         var xAction[]byte
 144         var msgSrc unsafe.Pointer
 145         msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_RESET, len(payload), ranName, &payload, &xAction, msgSrc)
 146         rmrMessengerMock.On("SendMsg", msg, true).Return(&rmrCgo.MBuf{}, fmt.Errorf("rmr error"))
 147
 148         var nodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED}
 149         readerMock.On("GetNodeb", ranName).Return(nodeb, nil)
 150
 151         _, actual := handler.Handle(models.ResetRequest{RanName: ranName})
 152
 153         assert.IsType(t, e2managererrors.NewRmrError(), actual)
 154 }