- result := <-messageChannel
- assert.Equal(t, result.RanName, mBuf.Meid)
- assert.Equal(t, result.MgsType, rmrCgo.RIC_X2_RESET_RESP)
+func TestHandleX2ResetRequestNotificationSuccess(t *testing.T) {
+ h, readerMock, rmrMessengerMock := initX2ResetRequestNotificationHandlerTest(t)
+ ranName := "test"
+ xAction := []byte("123456aa")
+ notificationRequest := models.NewNotificationRequest(ranName, []byte{}, time.Now(), xAction, nil)
+
+ nb := &entities.NodebInfo{RanName: ranName, ConnectionStatus: entities.ConnectionStatus_CONNECTED, NodeType: entities.Node_ENB}
+ var err error
+ readerMock.On("GetNodeb", ranName).Return(nb, err)
+ var msgSrc unsafe.Pointer
+ resetResponseMbuf := rmrCgo.NewMBuf(rmrCgo.RIC_X2_RESET_RESP, len(e2pdus.PackedX2ResetResponse), ranName, &e2pdus.PackedX2ResetResponse, &xAction, msgSrc)
+ rmrMessengerMock.On("SendMsg", resetResponseMbuf, true).Return(&rmrCgo.MBuf{}, err)
+ ranRestartedMbuf := getRanRestartedMbuf(nb.NodeType, enums.RAN_TO_RIC)
+ rmrMessengerMock.On("SendMsg", ranRestartedMbuf, true).Return(&rmrCgo.MBuf{}, err)
+ h.Handle(notificationRequest)
+ rmrMessengerMock.AssertCalled(t, "SendMsg", resetResponseMbuf, true)
+ rmrMessengerMock.AssertCalled(t, "SendMsg", ranRestartedMbuf, true)