Copy latest code to master

[ric-plt/resource-status-manager.git] / RSM / managers / rmrmanagers / rmr_message_manager_test.go

diff --git a/RSM/managers/rmrmanagers/rmr_message_manager_test.go b/RSM/managers/rmrmanagers/rmr_message_manager_test.go
index 5184e62..56aa30d 100644 (file)
--- 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")