h := NewX2ResetRequestNotificationHandler(readerProvider)
xaction := []byte("RanName")
- mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload),"RanName", &payload, &xaction)
+ mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload), "RanName", &payload, &xaction)
notificationRequest := models.NotificationRequest{RanName: mBuf.Meid, Len: mBuf.Len, Payload: *mBuf.Payload,
StartTime: time.Now(), TransactionId: string(xaction)}
- nb := &entities.NodebInfo{RanName:mBuf.Meid, ConnectionStatus:entities.ConnectionStatus_CONNECTED,}
+ nb := &entities.NodebInfo{RanName: mBuf.Meid, ConnectionStatus: entities.ConnectionStatus_CONNECTED,}
var rnibErr error
readerMock.On("GetNodeb", mBuf.Meid).Return(nb, rnibErr)
messageChannel := make(chan *models.NotificationResponse)
- go h.Handle(log,nil, ¬ificationRequest, messageChannel)
+ go h.Handle(log, ¬ificationRequest, messageChannel)
result := <-messageChannel
assert.Equal(t, result.RanName, mBuf.Meid)
h := NewX2ResetRequestNotificationHandler(readerProvider)
xaction := []byte("RanName")
- mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload),"RanName", &payload, &xaction)
+ mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload), "RanName", &payload, &xaction)
notificationRequest := models.NotificationRequest{RanName: mBuf.Meid, Len: mBuf.Len, Payload: *mBuf.Payload,
StartTime: time.Now(), TransactionId: string(xaction)}
- nb := &entities.NodebInfo{RanName:mBuf.Meid, ConnectionStatus:entities.ConnectionStatus_SHUTTING_DOWN,}
+ nb := &entities.NodebInfo{RanName: mBuf.Meid, ConnectionStatus: entities.ConnectionStatus_SHUTTING_DOWN,}
var rnibErr error
readerMock.On("GetNodeb", mBuf.Meid).Return(nb, rnibErr)
- h.Handle(log,nil, ¬ificationRequest, nil)
+ h.Handle(log, ¬ificationRequest, nil)
}
func TestHandleX2ResetRequestNotifDisconnectStatus(t *testing.T) {
h := NewX2ResetRequestNotificationHandler(readerProvider)
xaction := []byte("RanName")
- mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload),"RanName", &payload, &xaction)
+ mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload), "RanName", &payload, &xaction)
notificationRequest := models.NotificationRequest{RanName: mBuf.Meid, Len: mBuf.Len, Payload: *mBuf.Payload,
StartTime: time.Now(), TransactionId: string(xaction)}
- nb := &entities.NodebInfo{RanName:mBuf.Meid, ConnectionStatus:entities.ConnectionStatus_DISCONNECTED,}
+ nb := &entities.NodebInfo{RanName: mBuf.Meid, ConnectionStatus: entities.ConnectionStatus_DISCONNECTED,}
var rnibErr error
readerMock.On("GetNodeb", mBuf.Meid).Return(nb, rnibErr)
- h.Handle(log,nil, ¬ificationRequest, nil)
+ h.Handle(log, ¬ificationRequest, nil)
}
-func TestHandleX2ResetRequestNotifGetNodebFailed(t *testing.T){
+func TestHandleX2ResetRequestNotifGetNodebFailed(t *testing.T) {
log := initLog(t)
var payload []byte
h := NewX2ResetRequestNotificationHandler(readerProvider)
xaction := []byte("RanName")
- mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload),"RanName", &payload, &xaction)
+ mBuf := rmrCgo.NewMBuf(tests.MessageType, len(payload), "RanName", &payload, &xaction)
notificationRequest := models.NotificationRequest{RanName: mBuf.Meid, Len: mBuf.Len, Payload: *mBuf.Payload,
StartTime: time.Now(), TransactionId: string(xaction)}
var nb *entities.NodebInfo
- rnibErr := &common.ResourceNotFoundError{}
+ rnibErr := &common.ResourceNotFoundError{}
readerMock.On("GetNodeb", mBuf.Meid).Return(nb, rnibErr)
- h.Handle(log,nil, ¬ificationRequest, nil)
-}
\ No newline at end of file
+ h.Handle(log, ¬ificationRequest, nil)
+}