readerMock.AssertNotCalled(t, "GetNodeb")
}
-func TestX2SetupHandleGetNodebFailure(t *testing.T) {
+func TestSetupGetNodebFailure(t *testing.T) {
readerMock, _, handler, _, _ := initSetupRequestTest(t, entities.E2ApplicationProtocol_X2_SETUP_REQUEST)
rnibErr := &common.ValidationError{}
ranSetupManagerMock.AssertNotCalled(t, "ExecuteSetup")
}
-func TestSetupExistingRanWithoutAssocE2TInstanceSelectErrorDisconnected(t *testing.T) {
+func TestSetupExistingRanWithoutAssocE2TInstanceSelectErrorAlreadyDisconnected(t *testing.T) {
readerMock, writerMock, handler, e2tInstancesManagerMock, ranSetupManagerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_X2_SETUP_REQUEST)
nb := &entities.NodebInfo{RanName: RanName, AssociatedE2TInstanceAddress:"", ConnectionStatus:entities.ConnectionStatus_DISCONNECTED}
readerMock.On("GetNodeb", RanName).Return(nb , nil)
ranSetupManagerMock.AssertNotCalled(t, "ExecuteSetup")
}
-func TestSetupExistingConnectedRanWithAssocE2TInstanceSuccess(t *testing.T) {
+func TestSetupExistingRanWithAssocE2TInstanceConnectedSuccess(t *testing.T) {
readerMock, writerMock, handler, e2tInstancesManagerMock, ranSetupManagerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_X2_SETUP_REQUEST)
nb := &entities.NodebInfo{RanName: RanName, AssociatedE2TInstanceAddress:E2TAddress, ConnectionStatus: entities.ConnectionStatus_CONNECTED}
readerMock.On("GetNodeb", RanName).Return(nb , nil)
e2tInstancesManagerMock.AssertCalled(t, "GetE2TInstance", e2tInstanceAddress)
}
-func TestE2TerminInitHandlerSuccessOneRan(t *testing.T) {
+func TestE2TermInitHandlerSuccessOneRan(t *testing.T) {
_, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
var rnibErr error
rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
}
-func TestE2TerminInitHandlerSuccessTwoRans(t *testing.T) {
+func TestE2TermInitHandlerSuccessTwoRans(t *testing.T) {
_, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
var rnibErr error
-
-
var initialNodeb0 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
var initialNodeb1 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
readerMock.On("GetNodeb", RanName).Return(initialNodeb0, rnibErr)
rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
}
-func TestE2TerminInitHandlerSuccessThreeRansFirstRmrFailure(t *testing.T) {
+func TestE2TermInitHandlerSuccessThreeRansFirstRmrFailure(t *testing.T) {
log, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
var rnibErr error
rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
}
-func TestE2TerminInitHandlerSuccessThreeRansSecondNotFoundFailure(t *testing.T) {
+func TestE2TermInitHandlerSuccessThreeRansSecondNotFoundFailure(t *testing.T) {
log, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
var rnibErr error
rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
}
-func TestE2TerminInitHandlerSuccessThreeRansSecondRnibInternalErrorFailure(t *testing.T) {
+func TestE2TermInitHandlerSuccessThreeRansSecondRnibInternalErrorFailure(t *testing.T) {
log, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
var rnibErr error
rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
}
-func TestE2TerminInitHandlerSuccessZeroRans(t *testing.T) {
+func TestE2TermInitHandlerSuccessZeroRans(t *testing.T) {
_, handler, _, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 0)
}
-func TestE2TerminInitHandlerFailureGetListNodebIds(t *testing.T) {
+func TestE2TermInitHandlerFailureGetListNodebIds(t *testing.T) {
_, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock := initRanLostConnectionTest(t)
var nodebInfo *entities.NodebInfo
rnibReaderMock.AssertNotCalled(t, "SaveE2TAddresses")
}
-func TestAddNewE2TInstanceNoE2TAddresses(t *testing.T) {
+func TestAddNewE2TInstanceSaveE2TAddressesFailure(t *testing.T) {
+ rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
+ rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
+ E2TAddresses := []string{}
+ rnibReaderMock.On("GetE2TAddresses").Return(E2TAddresses, nil)
+ E2TAddresses = append(E2TAddresses, E2TAddress)
+ rnibWriterMock.On("SaveE2TAddresses", E2TAddresses).Return(common.NewResourceNotFoundError(""))
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ assert.NotNil(t, err)
+}
+
+func TestAddNewE2TInstanceNoE2TAddressesSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
e2tAddresses := []string{}
rnibWriterMock.AssertCalled(t, "SaveE2TAddresses", e2tAddresses)
}
-func TestAddNewE2TInstanceEmptyE2TAddresses(t *testing.T) {
+func TestAddNewE2TInstanceEmptyE2TAddressesSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
e2tAddresses := []string{}
rnibWriterMock.AssertCalled(t, "SaveE2TAddresses", e2tAddresses)
}
-func TestAddNewE2TInstanceSaveE2TAddressesFailure(t *testing.T) {
+func TestAddNewE2TInstanceExistingE2TAddressesSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
- E2TAddresses := []string{}
+ E2TAddresses := []string{"10.0.1.15:3030"}
rnibReaderMock.On("GetE2TAddresses").Return(E2TAddresses, nil)
E2TAddresses = append(E2TAddresses, E2TAddress)
- rnibWriterMock.On("SaveE2TAddresses", E2TAddresses).Return(common.NewResourceNotFoundError(""))
+ rnibWriterMock.On("SaveE2TAddresses", E2TAddresses).Return(nil)
err := e2tInstancesManager.AddE2TInstance(E2TAddress)
- assert.NotNil(t, err)
-}
-
-func TestGetE2TInstanceSuccess(t *testing.T) {
- rnibReaderMock, _, e2tInstancesManager := initE2TInstancesManagerTest(t)
- address := "10.10.2.15:9800"
- e2tInstance := entities.NewE2TInstance(address)
- rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, nil)
- res, err := e2tInstancesManager.GetE2TInstance(address)
assert.Nil(t, err)
- assert.Equal(t, e2tInstance, res)
}
func TestGetE2TInstanceFailure(t *testing.T) {
assert.Nil(t, res)
}
-func TestAssociateRanSuccess(t *testing.T) {
- rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance := entities.NewE2TInstance(E2TAddress)
- rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance, nil)
-
- updateE2TInstance := *e2tInstance
- updateE2TInstance.AssociatedRanList = append(updateE2TInstance.AssociatedRanList, "test1")
-
- rnibWriterMock.On("SaveE2TInstance", &updateE2TInstance).Return(nil)
-
- err := e2tInstancesManager.AssociateRan("test1", E2TAddress)
+func TestGetE2TInstanceSuccess(t *testing.T) {
+ rnibReaderMock, _, e2tInstancesManager := initE2TInstancesManagerTest(t)
+ address := "10.10.2.15:9800"
+ e2tInstance := entities.NewE2TInstance(address)
+ rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, nil)
+ res, err := e2tInstancesManager.GetE2TInstance(address)
assert.Nil(t, err)
- rnibReaderMock.AssertExpectations(t)
- rnibWriterMock.AssertExpectations(t)
+ assert.Equal(t, e2tInstance, res)
}
func TestAssociateRanGetInstanceFailure(t *testing.T) {
rnibWriterMock.AssertExpectations(t)
}
-func TestDissociateRanSuccess(t *testing.T) {
+func TestAssociateRanSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
-
- e2tInstance := entities.NewE2TInstance(E2TAddress)
- e2tInstance.AssociatedRanList = []string{"test0","test1"}
- updatedE2TInstance := *e2tInstance
- updatedE2TInstance.AssociatedRanList = []string{"test0"}
+ e2tInstance := entities.NewE2TInstance(E2TAddress)
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance, nil)
- rnibWriterMock.On("SaveE2TInstance", &updatedE2TInstance).Return(nil)
- err := e2tInstancesManager.DissociateRan("test1", E2TAddress)
+ updateE2TInstance := *e2tInstance
+ updateE2TInstance.AssociatedRanList = append(updateE2TInstance.AssociatedRanList, "test1")
+
+ rnibWriterMock.On("SaveE2TInstance", &updateE2TInstance).Return(nil)
+
+ err := e2tInstancesManager.AssociateRan("test1", E2TAddress)
assert.Nil(t, err)
rnibReaderMock.AssertExpectations(t)
rnibWriterMock.AssertExpectations(t)
rnibWriterMock.AssertExpectations(t)
}
+func TestDissociateRanSuccess(t *testing.T) {
+ rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
+
+ e2tInstance := entities.NewE2TInstance(E2TAddress)
+ e2tInstance.AssociatedRanList = []string{"test0","test1"}
+ updatedE2TInstance := *e2tInstance
+ updatedE2TInstance.AssociatedRanList = []string{"test0"}
+ rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance, nil)
+ rnibWriterMock.On("SaveE2TInstance", &updatedE2TInstance).Return(nil)
+
+ err := e2tInstancesManager.DissociateRan("test1", E2TAddress)
+ assert.Nil(t, err)
+ rnibReaderMock.AssertExpectations(t)
+ rnibWriterMock.AssertExpectations(t)
+}
+
func TestSelectE2TInstancesGetE2TAddressesFailure(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)