2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
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
9 // http://www.apache.org/licenses/LICENSE-2.0
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.
18 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
19 // platform project (RICP).
21 package rmrmsghandlers
34 "e2mgr/services/rmrsender"
37 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
38 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
39 "github.com/pkg/errors"
40 "github.com/stretchr/testify/mock"
46 const e2tInstanceAddress = "10.0.2.15"
47 const e2tInitPayload = "{\"address\":\"10.0.2.15\", \"fqdn\":\"\"}"
49 func initRanLostConnectionTest(t *testing.T) (*logger.Logger, E2TermInitNotificationHandler, *mocks.RnibReaderMock, *mocks.RnibWriterMock, *mocks.RmrMessengerMock, *mocks.E2TInstancesManagerMock, *mocks.RoutingManagerClientMock) {
52 config := &configuration.Configuration{RnibRetryIntervalMs: 10, MaxRnibConnectionAttempts: 3}
54 rmrMessengerMock := &mocks.RmrMessengerMock{}
56 readerMock := &mocks.RnibReaderMock{}
58 writerMock := &mocks.RnibWriterMock{}
60 routingManagerClientMock := &mocks.RoutingManagerClientMock{}
62 rnibDataService := services.NewRnibDataService(logger, config, readerMock, writerMock)
64 e2tInstancesManagerMock := &mocks.E2TInstancesManagerMock{}
65 e2tAssociationManager := managers.NewE2TAssociationManager(logger, rnibDataService, e2tInstancesManagerMock, routingManagerClientMock)
67 ranReconnectionManager := managers.NewRanDisconnectionManager(logger, configuration.ParseConfiguration(), rnibDataService, e2tAssociationManager)
68 handler := NewE2TermInitNotificationHandler(logger, ranReconnectionManager, e2tInstancesManagerMock, routingManagerClientMock)
70 return logger, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, routingManagerClientMock
73 func initRanLostConnectionTestWithRealE2tInstanceManager(t *testing.T) (*logger.Logger, *configuration.Configuration, E2TermInitNotificationHandler, *mocks.RnibReaderMock, *mocks.RnibWriterMock, *mocks.RmrMessengerMock, *mocks.HttpClientMock) {
76 config := configuration.ParseConfiguration()
78 rmrMessengerMock := &mocks.RmrMessengerMock{}
80 readerMock := &mocks.RnibReaderMock{}
82 writerMock := &mocks.RnibWriterMock{}
83 httpClientMock := &mocks.HttpClientMock{}
85 routingManagerClient := clients.NewRoutingManagerClient(logger, config, httpClientMock)
86 rnibDataService := services.NewRnibDataService(logger, config, readerMock, writerMock)
88 e2tInstancesManager := managers.NewE2TInstancesManager(rnibDataService, logger)
89 e2tAssociationManager := managers.NewE2TAssociationManager(logger, rnibDataService, e2tInstancesManager, routingManagerClient)
90 ranReconnectionManager := managers.NewRanDisconnectionManager(logger, configuration.ParseConfiguration(), rnibDataService, e2tAssociationManager)
91 handler := NewE2TermInitNotificationHandler(logger, ranReconnectionManager, e2tInstancesManager, routingManagerClient)
92 return logger, config, handler, readerMock, writerMock, rmrMessengerMock, httpClientMock
95 func TestE2TermInitUnmarshalPayloadFailure(t *testing.T) {
96 _, handler, _, _, _, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
97 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte("asd")}
98 handler.Handle(notificationRequest)
99 e2tInstancesManagerMock.AssertNotCalled(t, "GetE2TInstance")
100 e2tInstancesManagerMock.AssertNotCalled(t, "AddE2TInstance")
103 func TestE2TermInitEmptyE2TAddress(t *testing.T) {
104 _, handler, _, _, _, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
105 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte("{\"address\":\"\"}")}
106 handler.Handle(notificationRequest)
107 e2tInstancesManagerMock.AssertNotCalled(t, "GetE2TInstance")
108 e2tInstancesManagerMock.AssertNotCalled(t, "AddE2TInstance")
111 func TestE2TermInitGetE2TInstanceFailure(t *testing.T) {
112 _, handler, _, _, _, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
113 var e2tInstance *entities.E2TInstance
114 e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, common.NewInternalError(fmt.Errorf("internal error")))
115 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
116 handler.Handle(notificationRequest)
117 e2tInstancesManagerMock.AssertNotCalled(t, "AddE2TInstance")
120 func TestE2TermInitGetE2TInstanceDbFailure(t *testing.T) {
121 _, _, handler, readerMock, writerMock, rmrMessengerMock,_ := initRanLostConnectionTestWithRealE2tInstanceManager(t)
122 var e2tInstance *entities.E2TInstance
123 readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, common.NewInternalError(fmt.Errorf("internal error")))
124 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
125 handler.Handle(notificationRequest)
126 writerMock.AssertNotCalled(t, "UpdateNodebInfo")
127 rmrMessengerMock.AssertNotCalled(t, "SendMsg")
130 func TestE2TermInitNewE2TInstance(t *testing.T) {
131 _, config, handler, readerMock, writerMock, _, httpClientMock := initRanLostConnectionTestWithRealE2tInstanceManager(t)
132 var e2tInstance *entities.E2TInstance
134 readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, common.NewResourceNotFoundError("not found"))
135 writerMock.On("SaveE2TInstance", mock.Anything).Return(nil)
137 respBody := ioutil.NopCloser(bytes.NewBufferString(""))
138 url := config.RoutingManager.BaseUrl + clients.AddE2TInstanceApiSuffix
139 httpClientMock.On("Post", url, mock.Anything, mock.Anything).Return(&http.Response{StatusCode: http.StatusCreated, Body: respBody}, nil)
141 e2tAddresses := []string{}
142 readerMock.On("GetE2TAddresses").Return(e2tAddresses, common.NewResourceNotFoundError(""))
144 e2tAddresses = append(e2tAddresses, e2tInstanceAddress)
145 writerMock.On("SaveE2TAddresses", e2tAddresses).Return(nil)
147 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
148 handler.Handle(notificationRequest)
150 httpClientMock.AssertCalled(t, "Post", url, mock.Anything, mock.Anything)
151 writerMock.AssertCalled(t, "SaveE2TInstance", mock.Anything)
152 writerMock.AssertCalled(t, "SaveE2TAddresses", e2tAddresses)
155 func TestE2TermInitNewE2TInstance_RoutingManagerError(t *testing.T) {
156 _, config, handler, readerMock, writerMock, _, httpClientMock := initRanLostConnectionTestWithRealE2tInstanceManager(t)
157 var e2tInstance *entities.E2TInstance
159 readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, common.NewResourceNotFoundError("not found"))
161 url := config.RoutingManager.BaseUrl + clients.AddE2TInstanceApiSuffix
162 httpClientMock.On("Post", url, mock.Anything, mock.Anything).Return(&http.Response{}, errors.New("error"))
164 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
165 handler.Handle(notificationRequest)
167 httpClientMock.AssertCalled(t, "Post", url, mock.Anything, mock.Anything)
168 writerMock.AssertNotCalled(t, "SaveE2TInstance", mock.Anything)
169 writerMock.AssertNotCalled(t, "SaveE2TAddresses", mock.Anything)
172 func TestE2TermInitExistingE2TInstanceNoAssociatedRans(t *testing.T) {
173 _, handler, _, _, _, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
174 e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
175 e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
176 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
177 handler.Handle(notificationRequest)
178 e2tInstancesManagerMock.AssertCalled(t, "GetE2TInstance", e2tInstanceAddress)
181 //func TestE2TermInitHandlerSuccessOneRan(t *testing.T) {
182 // _, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
185 // var initialNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
186 // readerMock.On("GetNodeb", RanName).Return(initialNodeb, rnibErr)
188 // var argNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
189 // writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
191 // payload := e2pdus.PackedX2setupRequest
192 // xaction := []byte(RanName)
193 // msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
195 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
197 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
198 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName)
199 // e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
200 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
202 // handler.Handle(notificationRequest)
204 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
205 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
208 func TestE2TermInitHandlerSuccessOneRanShuttingdown(t *testing.T) {
209 _, _, handler, readerMock, writerMock, rmrMessengerMock,_ := initRanLostConnectionTestWithRealE2tInstanceManager(t)
212 var initialNodeb = &entities.NodebInfo{RanName: RanName, ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
213 readerMock.On("GetNodeb", RanName).Return(initialNodeb, rnibErr)
215 var argNodeb = &entities.NodebInfo{RanName: RanName, ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 0}
216 writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
218 payload := e2pdus.PackedX2setupRequest
219 xaction := []byte(RanName)
220 msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
222 rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
224 e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
225 e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName)
226 readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
227 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
229 handler.Handle(notificationRequest)
231 writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
232 rmrMessengerMock.AssertNotCalled(t, "SendMsg")
235 func TestE2TermInitHandlerSuccessOneRan_ToBeDeleted(t *testing.T) {
236 _, _, handler, readerMock, writerMock, rmrMessengerMock, httpClientMock:= initRanLostConnectionTestWithRealE2tInstanceManager(t)
239 var initialNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
240 readerMock.On("GetNodeb", RanName).Return(initialNodeb, rnibErr)
242 var argNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
243 writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
245 payload := e2pdus.PackedX2setupRequest
246 xaction := []byte(RanName)
247 msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
249 rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
251 e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
252 e2tInstance.State = entities.ToBeDeleted
253 e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName)
255 readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
256 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
258 handler.Handle(notificationRequest)
260 httpClientMock.AssertNotCalled(t, "Post", mock.Anything, mock.Anything, mock.Anything)
261 writerMock.AssertNotCalled(t, "UpdateNodebInfo")
262 rmrMessengerMock.AssertNotCalled(t, "SendMsg")
265 //func TestE2TermInitHandlerSuccessTwoRans_RoutingManagerFailure(t *testing.T) {
266 // _, _, handler, readerMock, writerMock, rmrMessengerMock, httpClientMock:= initRanLostConnectionTestWithRealE2tInstanceManager(t)
269 // var initialNodeb0 = &entities.NodebInfo{RanName: RanName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
270 // var initialNodeb1 = &entities.NodebInfo{RanName: "test2", ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
271 // readerMock.On("GetNodeb", RanName).Return(initialNodeb0, rnibErr)
272 // readerMock.On("GetNodeb", "test2").Return(initialNodeb1, rnibErr)
273 // writerMock.On("UpdateNodebInfo", mock.Anything).Return(rnibErr)
275 // payload := e2pdus.PackedX2setupRequest
276 // xaction := []byte(RanName)
277 // msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
279 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
281 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
282 // e2tInstance.State = entities.RoutingManagerFailure
283 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName, "test2")
285 // readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
286 // writerMock.On("SaveE2TInstance", mock.Anything).Return(nil)
288 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
290 // handler.Handle(notificationRequest)
292 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
293 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
295 // httpClientMock.AssertNotCalled(t, "Post", mock.Anything, mock.Anything, mock.Anything)
296 // writerMock.AssertCalled(t, "SaveE2TInstance", mock.Anything)
299 func TestE2TermInitHandlerSuccessOneRan_RoutingManagerFailure_Error(t *testing.T) {
300 _, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
303 var initialNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
304 readerMock.On("GetNodeb", RanName).Return(initialNodeb, rnibErr)
306 var argNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
307 writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
309 payload := e2pdus.PackedX2setupRequest
310 xaction := []byte(RanName)
311 msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
313 rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
315 e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
316 e2tInstance.State = entities.RoutingManagerFailure
317 e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName)
319 e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
320 e2tInstancesManagerMock.On("SetE2tInstanceState", e2tInstanceAddress, e2tInstance.State, entities.Active).Return(fmt.Errorf(" Error "))
321 writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
323 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
325 handler.Handle(notificationRequest)
327 writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 0)
328 rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 0)
331 //func TestE2TermInitHandlerSuccessTwoRans(t *testing.T) {
332 // _, _, handler, readerMock, writerMock, rmrMessengerMock, httpClientMock:= initRanLostConnectionTestWithRealE2tInstanceManager(t)
334 // var initialNodeb0 = &entities.NodebInfo{RanName: RanName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
335 // var initialNodeb1 = &entities.NodebInfo{RanName: "test2", ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
336 // readerMock.On("GetNodeb", RanName).Return(initialNodeb0, rnibErr)
337 // readerMock.On("GetNodeb", "test2").Return(initialNodeb1, rnibErr)
338 // writerMock.On("UpdateNodebInfo", mock.Anything).Return(rnibErr)
340 // payload := e2pdus.PackedX2setupRequest
341 // xaction := []byte(RanName)
342 // msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
344 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
346 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
347 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName, "test2")
348 // readerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
349 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
351 // handler.Handle(notificationRequest)
353 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
354 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
355 // httpClientMock.AssertNotCalled(t, "Post", mock.Anything, mock.Anything, mock.Anything)
358 //func TestE2TermInitHandlerSuccessTwoRansSecondRanShutdown(t *testing.T) {
359 // _, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
361 // var initialNodeb0 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
362 // var initialNodeb1 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_SHUT_DOWN, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
363 // readerMock.On("GetNodeb", RanName).Return(initialNodeb0, rnibErr)
364 // readerMock.On("GetNodeb", "test2").Return(initialNodeb1, rnibErr)
366 // var argNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
367 // writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
369 // payload := e2pdus.PackedX2setupRequest
370 // xaction := []byte(RanName)
371 // msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
373 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
375 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
376 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName, "test2")
377 // e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
378 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
380 // handler.Handle(notificationRequest)
382 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
383 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
384 // writerMock.AssertExpectations(t)
387 //func TestE2TermInitHandlerSuccessThreeRansFirstRmrFailure(t *testing.T) {
388 // log, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
391 // ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}, {InventoryName: "test3"}}
393 // var initialNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
394 // var initialNodeb1 = &entities.NodebInfo{RanName: ids[1].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
395 // var initialNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
396 // readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
397 // readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, rnibErr)
398 // readerMock.On("GetNodeb", ids[2].InventoryName).Return(initialNodeb2, rnibErr)
400 // var argNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
401 // var argNodeb0Fail = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_DISCONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 0}
402 // writerMock.On("UpdateNodebInfo", argNodeb0).Return(rnibErr)
403 // writerMock.On("UpdateNodebInfo", argNodeb0Fail).Return(rnibErr)
405 // payload := models.NewE2RequestMessage(ids[0].InventoryName /*tid*/, "", 0, ids[0].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
406 // xaction := []byte(ids[0].InventoryName)
407 // msg0 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
409 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg0, fmt.Errorf("RMR Error"))
411 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
412 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, "test1", "test2", "test3")
413 // e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
414 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
416 // handler.Handle(notificationRequest)
418 // //test1 (before send +1, after failure +1), test2 (0) test3 (0)
419 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
420 // //test1 failure (+1), test2 (0). test3 (0)
421 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
424 //func TestE2TermInitHandlerSuccessThreeRansSecondNotFoundFailure(t *testing.T) {
425 // log, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
428 // ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}, {InventoryName: "test3"}}
430 // var initialNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
431 // var initialNodeb1 = &entities.NodebInfo{RanName: ids[1].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
432 // var initialNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
433 // readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
434 // readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, common.NewResourceNotFoundError("not found"))
435 // readerMock.On("GetNodeb", ids[2].InventoryName).Return(initialNodeb2, rnibErr)
437 // var argNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
438 // var argNodeb0Success = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
439 // writerMock.On("UpdateNodebInfo", argNodeb0).Return(rnibErr)
440 // writerMock.On("UpdateNodebInfo", argNodeb0Success).Return(rnibErr)
442 // var argNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
443 // var argNodeb2Success = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
444 // writerMock.On("UpdateNodebInfo", argNodeb2).Return(rnibErr)
445 // writerMock.On("UpdateNodebInfo", argNodeb2Success).Return(rnibErr)
447 // payload := models.NewE2RequestMessage(ids[0].InventoryName /*tid*/, "", 0, ids[0].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
448 // xaction := []byte(ids[0].InventoryName)
449 // msg0 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
451 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg0, nil)
453 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
454 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, "test1", "test2", "test3")
455 // e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
456 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
458 // handler.Handle(notificationRequest)
460 // readerMock.AssertNumberOfCalls(t, "GetNodeb", 3)
461 // //test1 (+1), test2 failure (0) test3 (+1)
462 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
463 // //test1 success (+1), test2 (0). test3 (+1)
464 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
467 //func TestE2TermInitHandlerSuccessThreeRansSecondRnibInternalErrorFailure(t *testing.T) {
468 // log, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
471 // ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}, {InventoryName: "test3"}}
473 // var initialNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
474 // var initialNodeb1 = &entities.NodebInfo{RanName: ids[1].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
475 // var initialNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
476 // readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
477 // readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, common.NewInternalError(fmt.Errorf("internal error")))
478 // readerMock.On("GetNodeb", ids[2].InventoryName).Return(initialNodeb2, rnibErr)
480 // var argNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
481 // var argNodeb0Success = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
482 // writerMock.On("UpdateNodebInfo", argNodeb0).Return(rnibErr)
483 // writerMock.On("UpdateNodebInfo", argNodeb0Success).Return(rnibErr)
485 // var argNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
486 // var argNodeb2Success = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
487 // writerMock.On("UpdateNodebInfo", argNodeb2).Return(rnibErr)
488 // writerMock.On("UpdateNodebInfo", argNodeb2Success).Return(rnibErr)
490 // payload := models.NewE2RequestMessage(ids[0].InventoryName /*tid*/, "", 0, ids[0].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
491 // xaction := []byte(ids[0].InventoryName)
492 // msg0 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
494 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg0, nil)
496 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
497 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, "test1", "test2", "test3")
498 // e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
499 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
501 // handler.Handle(notificationRequest)
503 // readerMock.AssertNumberOfCalls(t, "GetNodeb", 2)
504 // //test1 (+1), test2 failure (0) test3 (0)
505 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
506 // //test1 success (+1), test2 (0). test3 (+1)
507 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
510 func TestE2TermInitHandlerSuccessZeroRans(t *testing.T) {
511 _, handler, _, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
513 e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
514 e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
515 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
517 handler.Handle(notificationRequest)
519 writerMock.AssertNotCalled(t, "UpdateNodebInfo")
520 rmrMessengerMock.AssertNotCalled(t, "SendMsg")
523 func TestE2TermInitHandlerFailureGetNodebInternalError(t *testing.T) {
524 _, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
526 var nodebInfo *entities.NodebInfo
527 readerMock.On("GetNodeb", "test1").Return(nodebInfo, common.NewInternalError(fmt.Errorf("internal error")))
529 e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
530 e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, "test1")
531 e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
532 notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
533 handler.Handle(notificationRequest)
535 writerMock.AssertNotCalled(t, "UpdateNodebInfo")
536 rmrMessengerMock.AssertNotCalled(t, "SendMsg")
539 //func TestE2TermInitHandlerSuccessTwoRansSecondIsDisconnected(t *testing.T) {
540 // _, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock, _ := initRanLostConnectionTest(t)
542 // var initialNodeb0 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
543 // var initialNodeb1 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_DISCONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
544 // readerMock.On("GetNodeb", RanName).Return(initialNodeb0, rnibErr)
545 // readerMock.On("GetNodeb", "test2").Return(initialNodeb1, rnibErr)
547 // var argNodeb1 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
548 // writerMock.On("UpdateNodebInfo", argNodeb1).Return(rnibErr)
550 // payload := e2pdus.PackedX2setupRequest
551 // xaction := []byte(RanName)
552 // msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), RanName, &payload, &xaction)
554 // rmrMessengerMock.On("SendMsg", mock.Anything, true).Return(msg, nil)
556 // e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
557 // e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, RanName, "test2")
558 // e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
559 // notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInitPayload)}
561 // handler.Handle(notificationRequest)
563 // writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
564 // rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
568 // TODO: extract to test_utils
569 func initRmrSender(rmrMessengerMock *mocks.RmrMessengerMock, log *logger.Logger) *rmrsender.RmrSender {
570 rmrMessenger := rmrCgo.RmrMessenger(rmrMessengerMock)
571 rmrMessengerMock.On("Init", tests.GetPort(), tests.MaxMsgSize, tests.Flags, log).Return(&rmrMessenger)
572 return rmrsender.NewRmrSender(log, rmrMessenger)
575 // TODO: extract to test_utils
576 func initLog(t *testing.T) *logger.Logger {
577 log, err := logger.InitLogger(logger.InfoLevel)
579 t.Errorf("#delete_all_request_handler_test.TestHandleSuccessFlow - failed to initialize logger, error: %s", err)