E2Manager/handlers/rmrmsghandlers/e2_term_init_notification_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 package rmrmsghandlers
  18
  19 import (
  20         "e2mgr/configuration"
  21         "e2mgr/logger"
  22         "e2mgr/managers"
  23         "e2mgr/mocks"
  24         "e2mgr/models"
  25         "e2mgr/rmrCgo"
  26         "e2mgr/services"
  27         "e2mgr/services/rmrsender"
  28         "e2mgr/tests"
  29         "fmt"
  30         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
  31         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
  32         "testing"
  33 )
  34
  35 func initRanLostConnectionTest(t *testing.T) (*logger.Logger, E2TermInitNotificationHandler, *mocks.RnibReaderMock, *mocks.RnibWriterMock, *mocks.RmrMessengerMock, *mocks.E2TInstancesManagerMock) {
  36
  37         logger := initLog(t)
  38         config := &configuration.Configuration{RnibRetryIntervalMs: 10, MaxRnibConnectionAttempts: 3}
  39
  40         rmrMessengerMock := &mocks.RmrMessengerMock{}
  41         rmrSender := initRmrSender(rmrMessengerMock, logger)
  42
  43         readerMock := &mocks.RnibReaderMock{}
  44
  45         writerMock := &mocks.RnibWriterMock{}
  46
  47         rnibDataService := services.NewRnibDataService(logger, config, readerMock, writerMock)
  48         ranSetupManager := managers.NewRanSetupManager(logger, rmrSender, rnibDataService)
  49
  50         e2tInstancesManagerMock := &mocks.E2TInstancesManagerMock{}
  51         ranReconnectionManager := managers.NewRanReconnectionManager(logger, configuration.ParseConfiguration(), rnibDataService, ranSetupManager, e2tInstancesManagerMock)
  52         handler := NewE2TermInitNotificationHandler(logger, ranReconnectionManager, rnibDataService, e2tInstancesManagerMock)
  53         return logger, handler, readerMock, writerMock, rmrMessengerMock, e2tInstancesManagerMock
  54 }
  55
  56 func TestE2TermInitGetE2TInstanceFailure(t *testing.T) {
  57         _, handler, _, _, _, e2tInstancesManagerMock := initRanLostConnectionTest(t)
  58         e2tInstanceAddress := "10.0.2.15"
  59         var e2tInstance *entities.E2TInstance
  60         e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, common.NewInternalError(fmt.Errorf("internal error")))
  61         notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInstanceAddress)}
  62         handler.Handle(notificationRequest)
  63         e2tInstancesManagerMock.AssertNotCalled(t, "AddE2TInstance")
  64 }
  65
  66 func TestE2TermInitNewE2TInstance(t *testing.T) {
  67         _, handler, _, _, _, e2tInstancesManagerMock := initRanLostConnectionTest(t)
  68         e2tInstanceAddress := "10.0.2.15"
  69         var e2tInstance *entities.E2TInstance
  70         e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, common.NewResourceNotFoundError("not found"))
  71         e2tInstance = entities.NewE2TInstance(e2tInstanceAddress)
  72         e2tInstancesManagerMock.On("AddE2TInstance", e2tInstanceAddress).Return(nil)
  73         notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInstanceAddress)}
  74         handler.Handle(notificationRequest)
  75         e2tInstancesManagerMock.AssertCalled(t, "AddE2TInstance", e2tInstanceAddress)
  76 }
  77
  78 func TestE2TermInitExistingE2TInstanceNoAssociatedRans(t *testing.T) {
  79         _, handler, _, _, _, e2tInstancesManagerMock := initRanLostConnectionTest(t)
  80         e2tInstanceAddress := "10.0.2.15"
  81         e2tInstance := entities.NewE2TInstance(e2tInstanceAddress)
  82         e2tInstancesManagerMock.On("GetE2TInstance", e2tInstanceAddress).Return(e2tInstance, nil)
  83         notificationRequest := &models.NotificationRequest{RanName: RanName, Payload: []byte(e2tInstanceAddress)}
  84         handler.Handle(notificationRequest)
  85         e2tInstancesManagerMock.AssertCalled(t, "GetE2TInstance", e2tInstanceAddress)
  86 }
  87
  88 //func TestE2TerminInitHandlerSuccessOneRan(t *testing.T) {
  89 //      _, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
  90 //      var rnibErr error
  91 //
  92 //      ids := []*entities.NbIdentity{{InventoryName: "test1"}}
  93 //      readerMock.On("GetListNodebIds").Return(ids, rnibErr)
  94 //
  95 //      var initialNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
  96 //      readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb, rnibErr)
  97 //
  98 //      var argNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
  99 //      writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
 100 //
 101 //      payload := e2pdus.PackedX2setupRequest
 102 //      xaction := []byte(ids[0].InventoryName)
 103 //      msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
 104 //
 105 //      rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
 106 //
 107 //      handler.Handle(nil)
 108 //
 109 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
 110 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
 111 //}
 112 //
 113 //func TestE2TerminInitHandlerSuccessTwoRans(t *testing.T) {
 114 //      _, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
 115 //      var rnibErr error
 116 //
 117 //      ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}}
 118 //      readerMock.On("GetListNodebIds").Return(ids, rnibErr)
 119 //
 120 //      var initialNodeb0 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 121 //      var initialNodeb1 = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 122 //      readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
 123 //      readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, rnibErr)
 124 //
 125 //      var argNodeb = &entities.NodebInfo{ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 126 //      writerMock.On("UpdateNodebInfo", argNodeb).Return(rnibErr)
 127 //
 128 //      payload := e2pdus.PackedX2setupRequest
 129 //      xaction := []byte(ids[0].InventoryName)
 130 //      msg := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
 131 //
 132 //      rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg, nil)
 133 //
 134 //      handler.Handle(nil)
 135 //
 136 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
 137 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
 138 //}
 139 //
 140 //func TestE2TerminInitHandlerSuccessThreeRansFirstRmrFailure(t *testing.T) {
 141 //      log, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
 142 //      var rnibErr error
 143 //
 144 //      ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}, {InventoryName: "test3"}}
 145 //      readerMock.On("GetListNodebIds").Return(ids, rnibErr)
 146 //
 147 //      var initialNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 148 //      var initialNodeb1 = &entities.NodebInfo{RanName: ids[1].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 149 //      var initialNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 150 //      readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
 151 //      readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, rnibErr)
 152 //      readerMock.On("GetNodeb", ids[2].InventoryName).Return(initialNodeb2, rnibErr)
 153 //
 154 //      var argNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 155 //      var argNodeb0Fail = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_DISCONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 0}
 156 //      writerMock.On("UpdateNodebInfo", argNodeb0).Return(rnibErr)
 157 //      writerMock.On("UpdateNodebInfo", argNodeb0Fail).Return(rnibErr)
 158 //
 159 //      payload := models.NewE2RequestMessage(ids[0].InventoryName /*tid*/, "", 0, ids[0].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
 160 //      xaction := []byte(ids[0].InventoryName)
 161 //      msg0 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
 162 //
 163 //      // Cannot use Mock because request MBuf contains pointers
 164 //      //payload =models.NewE2RequestMessage(ids[1].InventoryName /*tid*/, "", 0,ids[1].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
 165 //      //xaction = []byte(ids[1].InventoryName)
 166 //      //msg1 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[1].InventoryName, &payload, &xaction)
 167 //
 168 //      rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg0, fmt.Errorf("RMR Error"))
 169 //
 170 //      handler.Handle(nil)
 171 //
 172 //      //test1 (before send +1, after failure +1), test2 (0) test3 (0)
 173 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
 174 //      //test1 failure (+1), test2  (0). test3 (0)
 175 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
 176 //}
 177 //
 178 //func TestE2TerminInitHandlerSuccessThreeRansSecondNotFoundFailure(t *testing.T) {
 179 //      log, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
 180 //      var rnibErr error
 181 //
 182 //      ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}, {InventoryName: "test3"}}
 183 //      readerMock.On("GetListNodebIds").Return(ids, rnibErr)
 184 //
 185 //      var initialNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 186 //      var initialNodeb1 = &entities.NodebInfo{RanName: ids[1].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 187 //      var initialNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 188 //      readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
 189 //      readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, common.NewResourceNotFoundError("not found"))
 190 //      readerMock.On("GetNodeb", ids[2].InventoryName).Return(initialNodeb2, rnibErr)
 191 //
 192 //      var argNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 193 //      var argNodeb0Success = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 194 //      writerMock.On("UpdateNodebInfo", argNodeb0).Return(rnibErr)
 195 //      writerMock.On("UpdateNodebInfo", argNodeb0Success).Return(rnibErr)
 196 //
 197 //      var argNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 198 //      var argNodeb2Success = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 199 //      writerMock.On("UpdateNodebInfo", argNodeb2).Return(rnibErr)
 200 //      writerMock.On("UpdateNodebInfo", argNodeb2Success).Return(rnibErr)
 201 //
 202 //      payload := models.NewE2RequestMessage(ids[0].InventoryName /*tid*/, "", 0, ids[0].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
 203 //      xaction := []byte(ids[0].InventoryName)
 204 //      msg0 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
 205 //
 206 //      // Cannot use Mock because request MBuf contains pointers
 207 //      //payload =models.NewE2RequestMessage(ids[1].InventoryName /*tid*/, "", 0,ids[1].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
 208 //      //xaction = []byte(ids[1].InventoryName)
 209 //      //msg1 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[1].InventoryName, &payload, &xaction)
 210 //
 211 //      rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg0, nil)
 212 //
 213 //      handler.Handle(nil)
 214 //
 215 //      readerMock.AssertNumberOfCalls(t, "GetNodeb", 3)
 216 //      //test1 (+1), test2 failure (0) test3 (+1)
 217 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 2)
 218 //      //test1 success (+1), test2  (0). test3 (+1)
 219 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 2)
 220 //}
 221 //
 222 //func TestE2TerminInitHandlerSuccessThreeRansSecondRnibInternalErrorFailure(t *testing.T) {
 223 //      log, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
 224 //      var rnibErr error
 225 //
 226 //      ids := []*entities.NbIdentity{{InventoryName: "test1"}, {InventoryName: "test2"}, {InventoryName: "test3"}}
 227 //      readerMock.On("GetListNodebIds").Return(ids, rnibErr)
 228 //
 229 //      var initialNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 230 //      var initialNodeb1 = &entities.NodebInfo{RanName: ids[1].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 231 //      var initialNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST}
 232 //      readerMock.On("GetNodeb", ids[0].InventoryName).Return(initialNodeb0, rnibErr)
 233 //      readerMock.On("GetNodeb", ids[1].InventoryName).Return(initialNodeb1, common.NewInternalError(fmt.Errorf("internal error")))
 234 //      readerMock.On("GetNodeb", ids[2].InventoryName).Return(initialNodeb2, rnibErr)
 235 //
 236 //      var argNodeb0 = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 237 //      var argNodeb0Success = &entities.NodebInfo{RanName: ids[0].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 238 //      writerMock.On("UpdateNodebInfo", argNodeb0).Return(rnibErr)
 239 //      writerMock.On("UpdateNodebInfo", argNodeb0Success).Return(rnibErr)
 240 //
 241 //      var argNodeb2 = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTING, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 242 //      var argNodeb2Success = &entities.NodebInfo{RanName: ids[2].InventoryName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, E2ApplicationProtocol: entities.E2ApplicationProtocol_X2_SETUP_REQUEST, ConnectionAttempts: 1}
 243 //      writerMock.On("UpdateNodebInfo", argNodeb2).Return(rnibErr)
 244 //      writerMock.On("UpdateNodebInfo", argNodeb2Success).Return(rnibErr)
 245 //
 246 //      payload := models.NewE2RequestMessage(ids[0].InventoryName /*tid*/, "", 0, ids[0].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
 247 //      xaction := []byte(ids[0].InventoryName)
 248 //      msg0 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[0].InventoryName, &payload, &xaction)
 249 //
 250 //      // Cannot use Mock because request MBuf contains pointers
 251 //      //payload =models.NewE2RequestMessage(ids[1].InventoryName /*tid*/, "", 0,ids[1].InventoryName, e2pdus.PackedX2setupRequest).GetMessageAsBytes(log)
 252 //      //xaction = []byte(ids[1].InventoryName)
 253 //      //msg1 := rmrCgo.NewMBuf(rmrCgo.RIC_X2_SETUP_REQ, len(payload), ids[1].InventoryName, &payload, &xaction)
 254 //
 255 //      rmrMessengerMock.On("SendMsg", mock.Anything).Return(msg0, nil)
 256 //
 257 //      handler.Handle(nil)
 258 //
 259 //      readerMock.AssertNumberOfCalls(t, "GetNodeb", 2)
 260 //      //test1 (+1), test2 failure (0) test3 (0)
 261 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 1)
 262 //      //test1 success (+1), test2  (0). test3 (+1)
 263 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 1)
 264 //}
 265 //
 266 //func TestE2TerminInitHandlerSuccessZeroRans(t *testing.T) {
 267 //      _, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
 268 //      var rnibErr error
 269 //
 270 //      readerMock.On("GetListNodebIds").Return([]*entities.NbIdentity{}, rnibErr)
 271 //
 272 //      handler.Handle(nil)
 273 //
 274 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 0)
 275 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 0)
 276 //}
 277 //
 278 //func TestE2TerminInitHandlerFailureGetListNodebIds(t *testing.T) {
 279 //      _, handler, readerMock, writerMock, rmrMessengerMock, _ := initRanLostConnectionTest(t)
 280 //
 281 //      readerMock.On("GetListNodebIds").Return([]*entities.NbIdentity{}, common.NewInternalError(fmt.Errorf("internal error")))
 282 //
 283 //      handler.Handle(nil)
 284 //
 285 //      writerMock.AssertNumberOfCalls(t, "UpdateNodebInfo", 0)
 286 //      rmrMessengerMock.AssertNumberOfCalls(t, "SendMsg", 0)
 287 //}
 288
 289 // TODO: extract to test_utils
 290 func initRmrSender(rmrMessengerMock *mocks.RmrMessengerMock, log *logger.Logger) *rmrsender.RmrSender {
 291         rmrMessenger := rmrCgo.RmrMessenger(rmrMessengerMock)
 292         rmrMessengerMock.On("Init", tests.GetPort(), tests.MaxMsgSize, tests.Flags, log).Return(&rmrMessenger)
 293         return rmrsender.NewRmrSender(log, rmrMessenger)
 294 }
 295
 296 // TODO: extract to test_utils
 297 func initLog(t *testing.T) *logger.Logger {
 298         log, err := logger.InitLogger(logger.InfoLevel)
 299         if err != nil {
 300                 t.Errorf("#delete_all_request_handler_test.TestHandleSuccessFlow - failed to initialize logger, error: %s", err)
 301         }
 302         return log
 303 }