X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=RSM%2Fproviders%2Frmrmsghandlerprovider%2Fmessage_handler_provider_test.go;h=fadcd5c1b018a8de3f82f2ae566b04a33229fb92;hb=60652d98d51ee23c1eaca2e8bc2bf19c74c57658;hp=a43f641ed63481e146b803b1d1ea3ce76119c99e;hpb=b8d3ff3abf409da49ecab244cd6d2c2124dbce7c;p=ric-plt%2Fresource-status-manager.git

diff --git a/RSM/providers/rmrmsghandlerprovider/message_handler_provider_test.go b/RSM/providers/rmrmsghandlerprovider/message_handler_provider_test.go
index a43f641..fadcd5c 100644
--- a/RSM/providers/rmrmsghandlerprovider/message_handler_provider_test.go
+++ b/RSM/providers/rmrmsghandlerprovider/message_handler_provider_test.go
@@ -23,8 +23,10 @@ package rmrmsghandlerprovider
 import (
 	"fmt"
 	"rsm/configuration"
+	"rsm/converters"
+	"rsm/e2pdus"
 	"rsm/handlers/rmrmsghandlers"
-	"rsm/managers"
+	"rsm/services"
 	"rsm/tests/testhelper"
 	"strings"
 	"testing"
@@ -42,18 +44,18 @@ func TestGetNotificationHandlerSuccess(t *testing.T) {
 	if err != nil {
 		t.Errorf("#... - failed to parse configuration error: %s", err)
 	}
-	resourceStatusInitiateManager := managers.NewResourceStatusInitiateManager(logger, rnibDataService, rmrSender)
-
+	resourceStatusService := services.NewResourceStatusService(logger, rmrSender)
+	unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
 	var testCases = []struct {
 		msgType int
 		handler rmrmsghandlers.RmrMessageHandler
 	}{
-		{rmrcgo.RanConnected, rmrmsghandlers.NewResourceStatusInitiateNotificationHandler(logger, config, resourceStatusInitiateManager, RanConnected)},
-		{rmrcgo.RanRestarted, rmrmsghandlers.NewResourceStatusInitiateNotificationHandler(logger, config, resourceStatusInitiateManager, RanRestarted)},
+		{rmrcgo.RanConnected, rmrmsghandlers.NewResourceStatusInitiateNotificationHandler(logger, rnibDataService, resourceStatusService, RanConnected)},
+		{rmrcgo.RanRestarted, rmrmsghandlers.NewResourceStatusInitiateNotificationHandler(logger, rnibDataService, resourceStatusService, RanRestarted)},
 	}
 
 	for _, tc := range testCases {
-		provider := NewMessageHandlerProvider(logger, config, rnibDataService, rmrSender, resourceStatusInitiateManager, nil)
+		provider := NewMessageHandlerProvider(logger, config, rnibDataService, rmrSender, resourceStatusService, converters.NewResourceStatusResponseConverter(unpacker), converters.NewResourceStatusFailureConverter(unpacker))
 		t.Run(fmt.Sprintf("%d", tc.msgType), func(t *testing.T) {
 			handler, err := provider.GetMessageHandler(tc.msgType)
 			if err != nil {
@@ -77,7 +79,8 @@ func TestGetNotificationHandlerFailure(t *testing.T) {
 	if err != nil {
 		t.Errorf("#... - failed to parse configuration error: %s", err)
 	}
-	resourceStatusInitiateManager := managers.NewResourceStatusInitiateManager(logger, rnibDataService, rmrSender)
+	resourceStatusService := services.NewResourceStatusService(logger, rmrSender)
+	unpacker := converters.NewX2apPduUnpacker(logger, e2pdus.MaxAsn1CodecMessageBufferSize)
 
 	var testCases = []struct {
 		msgType   int
@@ -86,7 +89,7 @@ func TestGetNotificationHandlerFailure(t *testing.T) {
 		{9999 /*unknown*/, "notification handler not found"},
 	}
 	for _, tc := range testCases {
-		provider := NewMessageHandlerProvider(logger, config, rnibDataService, rmrSender, resourceStatusInitiateManager, nil)
+		provider := NewMessageHandlerProvider(logger, config, rnibDataService, rmrSender, resourceStatusService, converters.NewResourceStatusResponseConverter(unpacker), converters.NewResourceStatusFailureConverter(unpacker))
 		t.Run(fmt.Sprintf("%d", tc.msgType), func(t *testing.T) {
 			_, err := provider.GetMessageHandler(tc.msgType)
 			if err == nil {