X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?p=ric-plt%2Fresource-status-manager.git;a=blobdiff_plain;f=RSM%2Fmanagers%2Frmrmanagers%2Frmr_message_manager_test.go;fp=RSM%2Fmanagers%2Frmrmanagers%2Frmr_message_manager_test.go;h=56aa30d1df19862d20740611c610b3d37e73a0b3;hp=5184e621d85fa90fd137083afbe56f7b297eafbc;hb=60652d98d51ee23c1eaca2e8bc2bf19c74c57658;hpb=b8d3ff3abf409da49ecab244cd6d2c2124dbce7c diff --git a/RSM/managers/rmrmanagers/rmr_message_manager_test.go b/RSM/managers/rmrmanagers/rmr_message_manager_test.go index 5184e62..56aa30d 100644 --- a/RSM/managers/rmrmanagers/rmr_message_manager_test.go +++ b/RSM/managers/rmrmanagers/rmr_message_manager_test.go @@ -21,8 +21,10 @@ package rmrmanagers import ( "rsm/configuration" - "rsm/managers" + "rsm/converters" + "rsm/e2pdus" "rsm/rmrcgo" + "rsm/services" "rsm/tests/testhelper" "testing" ) @@ -31,9 +33,9 @@ func TestRmrMessageManagerSuccess(t *testing.T) { rnibDataService, rmrSender, logger := testhelper.InitTestCase(t) config, _ := configuration.ParseConfiguration() - resourceStatusInitiateManager := managers.NewResourceStatusInitiateManager(logger, rnibDataService, rmrSender) - - manager := NewRmrMessageManager(logger, config, rnibDataService, rmrSender, resourceStatusInitiateManager, nil) + resourceStatusService := services.NewResourceStatusService(logger, rmrSender) + unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize) + manager := NewRmrMessageManager(logger, config, rnibDataService, rmrSender, resourceStatusService, converters.NewResourceStatusResponseConverter(unpacker), converters.NewResourceStatusFailureConverter(unpacker)) xactionByteArr := []byte("1111111") payloadByteArr := []byte("payload") @@ -46,9 +48,9 @@ func TestRmrMessageManagerFailure(t *testing.T) { rnibDataService, rmrSender, logger := testhelper.InitTestCase(t) config, _ := configuration.ParseConfiguration() - resourceStatusInitiateManager := managers.NewResourceStatusInitiateManager(logger, rnibDataService, rmrSender) - - manager := NewRmrMessageManager(logger, config, rnibDataService, rmrSender, resourceStatusInitiateManager, nil) + resourceStatusService := services.NewResourceStatusService(logger, rmrSender) + unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize) + manager := NewRmrMessageManager(logger, config, rnibDataService, rmrSender, resourceStatusService, converters.NewResourceStatusResponseConverter(unpacker), converters.NewResourceStatusFailureConverter(unpacker)) xactionByteArr := []byte("1111111") payloadByteArr := []byte("payload")