const E2TAddress = "10.10.2.15:9800"
const E2TAddress2 = "10.10.2.16:9800"
+const PodName = "som_ pod_name"
func initE2TInstancesManagerTest(t *testing.T) (*mocks.RnibReaderMock, *mocks.RnibWriterMock, *E2TInstancesManager) {
logger, err := logger.InitLogger(logger.DebugLevel)
func TestAddNewE2TInstanceSaveE2TInstanceFailure(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(common.NewInternalError(errors.New("Error")))
- err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress, PodName)
assert.NotNil(t, err)
rnibReaderMock.AssertNotCalled(t, "GetE2TAddresses")
}
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
e2tAddresses := []string{}
rnibReaderMock.On("GetE2TAddresses").Return(e2tAddresses, common.NewInternalError(errors.New("Error")))
- err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress, PodName)
assert.NotNil(t, err)
rnibReaderMock.AssertNotCalled(t, "SaveE2TAddresses")
}
rnibReaderMock.On("GetE2TAddresses").Return(E2TAddresses, nil)
E2TAddresses = append(E2TAddresses, E2TAddress)
rnibWriterMock.On("SaveE2TAddresses", E2TAddresses).Return(common.NewResourceNotFoundError(""))
- err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress, PodName)
assert.NotNil(t, err)
}
rnibReaderMock.On("GetE2TAddresses").Return(e2tAddresses, common.NewResourceNotFoundError(""))
e2tAddresses = append(e2tAddresses, E2TAddress)
rnibWriterMock.On("SaveE2TAddresses", e2tAddresses).Return(nil)
- err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress, PodName)
assert.Nil(t, err)
rnibWriterMock.AssertCalled(t, "SaveE2TAddresses", e2tAddresses)
}
rnibReaderMock.On("GetE2TAddresses").Return(e2tAddresses, nil)
e2tAddresses = append(e2tAddresses, E2TAddress)
rnibWriterMock.On("SaveE2TAddresses", e2tAddresses).Return(nil)
- err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress, PodName)
assert.Nil(t, err)
rnibWriterMock.AssertCalled(t, "SaveE2TAddresses", e2tAddresses)
}
rnibReaderMock.On("GetE2TAddresses").Return(E2TAddresses, nil)
E2TAddresses = append(E2TAddresses, E2TAddress)
rnibWriterMock.On("SaveE2TAddresses", E2TAddresses).Return(nil)
- err := e2tInstancesManager.AddE2TInstance(E2TAddress)
+ err := e2tInstancesManager.AddE2TInstance(E2TAddress, PodName)
assert.Nil(t, err)
}
func TestGetE2TInstanceSuccess(t *testing.T) {
rnibReaderMock, _, e2tInstancesManager := initE2TInstancesManagerTest(t)
address := "10.10.2.15:9800"
- e2tInstance := entities.NewE2TInstance(address)
+ e2tInstance := entities.NewE2TInstance(address, PodName)
rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, nil)
res, err := e2tInstancesManager.GetE2TInstance(address)
assert.Nil(t, err)
func TestAddRanToInstanceSaveInstanceFailure(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance1, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(common.NewInternalError(fmt.Errorf("for test")))
func TestAddRanToInstanceSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance := entities.NewE2TInstance(E2TAddress)
+ e2tInstance := entities.NewE2TInstance(E2TAddress, PodName)
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance, nil)
updateE2TInstance := *e2tInstance
func TestRemoveRanFromInstanceSaveInstanceFailure(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance1, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(common.NewInternalError(fmt.Errorf("for test")))
func TestRemoveRanFromInstanceSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance := entities.NewE2TInstance(E2TAddress)
+ e2tInstance := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance.AssociatedRanList = []string{"test0", "test1"}
updatedE2TInstance := *e2tInstance
updatedE2TInstance.AssociatedRanList = []string{"test0"}
func TestSelectE2TInstancesNoActiveE2TInstance(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
addresses := []string{E2TAddress, E2TAddress2}
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.State = entities.ToBeDeleted
e2tInstance1.AssociatedRanList = []string{"test1", "test2", "test3"}
- e2tInstance2 := entities.NewE2TInstance(E2TAddress2)
+ e2tInstance2 := entities.NewE2TInstance(E2TAddress2, PodName)
e2tInstance2.State = entities.ToBeDeleted
e2tInstance2.AssociatedRanList = []string{"test4", "test5", "test6", "test7"}
func TestSelectE2TInstancesSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
addresses := []string{E2TAddress, E2TAddress2}
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.AssociatedRanList = []string{"test1", "test2", "test3"}
- e2tInstance2 := entities.NewE2TInstance(E2TAddress2)
+ e2tInstance2 := entities.NewE2TInstance(E2TAddress2, PodName)
e2tInstance2.AssociatedRanList = []string{"test4", "test5", "test6", "test7"}
rnibReaderMock.On("GetE2TAddresses").Return(addresses, nil)
func TestActivateE2TInstanceSuccess(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.State = entities.ToBeDeleted
e2tInstance1.AssociatedRanList = []string{"test1","test2","test3"}
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance1, nil)
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
address := "10.10.2.15:9800"
- e2tInstance := entities.NewE2TInstance(address)
+ e2tInstance := entities.NewE2TInstance(address, PodName)
rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, common.NewInternalError(errors.New("Error")))
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
address := "10.10.2.15:9800"
- e2tInstance := entities.NewE2TInstance(address)
+ e2tInstance := entities.NewE2TInstance(address, PodName)
rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(common.NewInternalError(errors.New("Error")))
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
address := "10.10.2.15:9800"
- e2tInstance := entities.NewE2TInstance(address)
+ e2tInstance := entities.NewE2TInstance(address, PodName)
rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
address := "10.10.2.15:9800"
- e2tInstance := entities.NewE2TInstance(address)
+ e2tInstance := entities.NewE2TInstance(address, PodName)
e2tInstance.State = entities.ToBeDeleted
rnibReaderMock.On("GetE2TInstance", address).Return(e2tInstance, nil)
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
e2tAddresses := []string{E2TAddress, E2TAddress2}
rnibReaderMock.On("GetE2TAddresses").Return(e2tAddresses, nil)
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.State = entities.ToBeDeleted
- e2tInstance2 := entities.NewE2TInstance(E2TAddress2)
+ e2tInstance2 := entities.NewE2TInstance(E2TAddress2, PodName)
e2tInstance2.State = entities.ToBeDeleted
rnibReaderMock.On("GetE2TInstances", e2tAddresses).Return([]*entities.E2TInstance{e2tInstance1, e2tInstance2}, nil)
e2tInstancesManager.ResetKeepAliveTimestampsForAllE2TInstances()
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
e2tAddresses := []string{E2TAddress, E2TAddress2}
rnibReaderMock.On("GetE2TAddresses").Return(e2tAddresses, nil)
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.State = entities.Active
- e2tInstance2 := entities.NewE2TInstance(E2TAddress2)
+ e2tInstance2 := entities.NewE2TInstance(E2TAddress2, PodName)
e2tInstance2.State = entities.ToBeDeleted
rnibReaderMock.On("GetE2TInstances", e2tAddresses).Return([]*entities.E2TInstance{e2tInstance1, e2tInstance2}, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(nil)
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
e2tAddresses := []string{E2TAddress, E2TAddress2}
rnibReaderMock.On("GetE2TAddresses").Return(e2tAddresses, nil)
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.State = entities.Active
- e2tInstance2 := entities.NewE2TInstance(E2TAddress2)
+ e2tInstance2 := entities.NewE2TInstance(E2TAddress2, PodName)
e2tInstance2.State = entities.ToBeDeleted
rnibReaderMock.On("GetE2TInstances", e2tAddresses).Return([]*entities.E2TInstance{e2tInstance1, e2tInstance2}, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(common.NewInternalError(errors.New("Error")))
func TestSetE2tInstanceStateCurrentStateHasChanged(t *testing.T) {
rnibReaderMock, _, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance := entities.NewE2TInstance(E2TAddress)
+ e2tInstance := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance.State = entities.Active
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance, nil)
func TestSetE2tInstanceStateErrorInSaveE2TInstance(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
- e2tInstance := entities.NewE2TInstance(E2TAddress)
+ e2tInstance := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance.State = entities.ToBeDeleted
rnibReaderMock.On("GetE2TInstance", E2TAddress).Return(e2tInstance, nil)
rnibWriterMock.On("SaveE2TInstance", mock.Anything).Return(common.NewInternalError(fmt.Errorf("for testing")))
func TestClearRansOfAllE2TInstancesErrorInSaveE2TInstance(t *testing.T) {
rnibReaderMock, rnibWriterMock, e2tInstancesManager := initE2TInstancesManagerTest(t)
addresses := []string{E2TAddress, E2TAddress2}
- e2tInstance1 := entities.NewE2TInstance(E2TAddress)
+ e2tInstance1 := entities.NewE2TInstance(E2TAddress, PodName)
e2tInstance1.AssociatedRanList = []string{"test1", "test2", "test3"}
- e2tInstance2 := entities.NewE2TInstance(E2TAddress2)
+ e2tInstance2 := entities.NewE2TInstance(E2TAddress2, PodName)
e2tInstance2.AssociatedRanList = []string{"test4", "test5", "test6", "test7"}
rnibReaderMock.On("GetE2TAddresses").Return(addresses, nil)