import (
"fmt"
"rsm/configuration"
+ "rsm/converters"
+ "rsm/e2pdus"
"rsm/logger"
- "rsm/managers"
"rsm/managers/rmrmanagers"
"rsm/mocks"
"rsm/rmrcgo"
+ "rsm/services"
"rsm/tests"
"rsm/tests/testhelper"
"testing"
if err != nil {
t.Errorf("#... - failed to parse configuration error: %s", err)
}
- resourceStatusInitiateManager := managers.NewResourceStatusInitiateManager(logger, rnibDataService, rmrSender)
+ resourceStatusService := services.NewResourceStatusService(logger, rmrSender)
rmrMessenger := initRmrMessenger(logger)
- manager := rmrmanagers.NewRmrMessageManager(logger, config, rnibDataService, rmrSender, resourceStatusInitiateManager, nil)
+ unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
+ manager := rmrmanagers.NewRmrMessageManager(logger, config, rnibDataService, rmrSender, resourceStatusService, converters.NewResourceStatusResponseConverter(unpacker), converters.NewResourceStatusFailureConverter(unpacker))
return NewRmrReceiver(logger, rmrMessenger, manager)
}