-func TestSetupHandleNewRanSave_Error(t *testing.T) {
- readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
-
- ranName := "RanName"
- rnibErr := &common.ResourceNotFoundError{}
- sr := models.SetupRequest{"127.0.0.1", 8080, ranName,}
-
- nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST}
- readerMock.On("GetNodeb", ranName).Return(nb, rnibErr)
-
- vErr := &common.ValidationError{}
- updatedNb, _ := rnibBuilders.CreateInitialNodeInfo(&sr, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
- writerMock.On("SaveNodeb", mock.Anything, updatedNb).Return(vErr)
-
- var nbUpdated = &entities.NodebInfo{RanName: ranName, Ip: sr.RanIp, Port: uint32(sr.RanPort), ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 1}
- writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
-
- payload := e2pdus.PackedEndcX2setupRequest
- xaction := []byte(ranName)
- msg := rmrCgo.NewMBuf(rmrCgo.RIC_ENDC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
-
- rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
-
- _, actual := handler.Handle(sr)
- expected := &e2managererrors.RnibDbError{}
-
- if reflect.TypeOf(actual) != reflect.TypeOf(expected) {
- t.Errorf("Error actual = %v, and Expected = %v.", actual, expected)
- }
-
- writerMock.AssertNumberOfCalls(t, "SaveNodeb", 1)
- writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 0)
- rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 0)
-}
-
-func TestSetupHandleNewRan_Success(t *testing.T) {
- readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
-
- ranName := "RanName"
- rnibErr := &common.ResourceNotFoundError{}
- sr := models.SetupRequest{"127.0.0.1", 8080, ranName,}
-
- nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST}
- readerMock.On("GetNodeb", ranName).Return(nb, rnibErr)
-
- updatedNb, _ := rnibBuilders.CreateInitialNodeInfo(&sr, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
- writerMock.On("SaveNodeb", mock.Anything, updatedNb).Return(nil)
-
- var nbUpdated = &entities.NodebInfo{RanName: ranName, Ip: sr.RanIp, Port: uint32(sr.RanPort), ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 1}
- writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
-
- payload := e2pdus.PackedEndcX2setupRequest
- xaction := []byte(ranName)
- msg := rmrCgo.NewMBuf(rmrCgo.RIC_ENDC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
-
- rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
-
- _, actual := handler.Handle(sr)
-
- assert.Nil(t, actual)
-
- writerMock.AssertNumberOfCalls(t, "SaveNodeb", 1)
- writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
- rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
-}
-
-func TestEndcSetupHandleRmr_Error(t *testing.T) {
- readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
-
- ranName := "RanName"
- nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST}
- readerMock.On("GetNodeb", ranName).Return(nb, nil)
-
- var nbUpdated = &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 1}
- writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
-
- var nbDisconnected = &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_DISCONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 0}
- writerMock.On("UpdateNodebInfo", nbDisconnected).Return(nil)
-
- payload := e2pdus.PackedEndcX2setupRequest
- xaction := []byte(ranName)
- msg := rmrCgo.NewMBuf(rmrCgo.RIC_ENDC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
-
- rmrErr := &e2managererrors.RmrError{}
- rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, rmrErr)
-
- sr := models.SetupRequest{"127.0.0.1", 8080, ranName,}
- _, actual := handler.Handle(sr)
-
- if reflect.TypeOf(actual) != reflect.TypeOf(rmrErr) {
- t.Errorf("Error actual = %v, and Expected = %v.", actual, rmrErr)
- }
-
- writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
- rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
-}
-
-func TestEndcSetupHandleExistingDisconnectedRan_Success(t *testing.T) {
- readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
-
- ranName := "RanName"
- nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_DISCONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST}
- readerMock.On("GetNodeb", ranName).Return(nb, nil)
-
- var nbUpdated = &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 1}
- writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
-
- payload := e2pdus.PackedEndcX2setupRequest
- xaction := []byte(ranName)
- msg := rmrCgo.NewMBuf(rmrCgo.RIC_ENDC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
-
- rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
-
- sr := models.SetupRequest{"127.0.0.1", 8080, ranName,}
- _, actual := handler.Handle(sr)
-
- assert.Nil(t, actual)
-
- writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
- rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
-}
-
-func TestX2SetupHandleExistingConnectedRan_Success(t *testing.T) {
- readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_X2_SETUP_REQUEST)
-
- ranName := "RanName"
- nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
- readerMock.On("GetNodeb", ranName).Return(nb, nil)
-
- var nbUpdated = &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
- writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
-
- payload := e2pdus.PackedX2setupRequest
- xaction := []byte(ranName)
- msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
-
- rmrMessengerMock.On("SendMsg", mock.Anything, mock.Anything).Return(msg, nil)
+//func TestSetupHandleNewRanSave_Error(t *testing.T) {
+// readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
+//
+// ranName := "RanName"
+// rnibErr := &common.ResourceNotFoundError{}
+// sr := models.SetupRequest{"127.0.0.1", 8080, ranName,}
+//
+// nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST}
+// readerMock.On("GetNodeb", ranName).Return(nb, rnibErr)
+//
+// vErr := &common.ValidationError{}
+// updatedNb, _ := createInitialNodeInfo(&sr, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
+// writerMock.On("SaveNodeb", mock.Anything, updatedNb).Return(vErr)
+//
+// var nbUpdated = &entities.NodebInfo{RanName: ranName, Ip: sr.RanIp, Port: uint32(sr.RanPort), ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 1}
+// writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
+//
+// payload := e2pdus.PackedEndcX2setupRequest
+// xaction := []byte(ranName)
+// msg := rmrCgo.NewMBuf(rmrCgo.RIC_ENDC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
+//
+// rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
+//
+// _, actual := handler.Handle(sr)
+// expected := &e2managererrors.RnibDbError{}
+//
+// if reflect.TypeOf(actual) != reflect.TypeOf(expected) {
+// t.Errorf("Error actual = %v, and Expected = %v.", actual, expected)
+// }
+//
+// writerMock.AssertNumberOfCalls(t, "SaveNodeb", 1)
+// writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 0)
+// rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 0)
+//}
+//
+//func TestSetupHandleNewRan_Success(t *testing.T) {
+// readerMock, writerMock, handler, rmrMessengerMock := initSetupRequestTest(t, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
+//
+// ranName := "RanName"
+// rnibErr := &common.ResourceNotFoundError{}
+// sr := models.SetupRequest{"127.0.0.1", 8080, ranName,}
+//
+// nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST}
+// readerMock.On("GetNodeb", ranName).Return(nb, rnibErr)
+//
+// updatedNb, _ := createInitialNodeInfo(&sr, entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
+// writerMock.On("SaveNodeb", mock.Anything, updatedNb).Return(nil)
+//
+// var nbUpdated = &entities.NodebInfo{RanName: ranName, Ip: sr.RanIp, Port: uint32(sr.RanPort), ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST, ConnectionAttempts: 1}
+// writerMock.On("UpdateNodebInfo", nbUpdated).Return(nil)
+//
+// payload := e2pdus.PackedEndcX2setupRequest
+// xaction := []byte(ranName)
+// msg := rmrCgo.NewMBuf(rmrCgo.RIC_ENDC_X2_SETUP_REQ, len(payload), ranName, &payload, &xaction)
+//
+// rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
+//
+// _, actual := handler.Handle(sr)
+//
+// assert.Nil(t, actual)
+//
+// writerMock.AssertNumberOfCalls(t, "SaveNodeb", 1)
+// writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
+// rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
+//}