X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=RSM%2Fmanagers%2Frmrmanagers%2Frmr_message_manager_test.go;h=56aa30d1df19862d20740611c610b3d37e73a0b3;hb=refs%2Fchanges%2F70%2F2070%2F1;hp=23c6379baf783dea1595649071e476bee8f8de95;hpb=7b80668df78103cebafdfb7caa0070dc92ed3779;p=ric-plt%2Fresource-status-manager.git

diff --git a/RSM/managers/rmrmanagers/rmr_message_manager_test.go b/RSM/managers/rmrmanagers/rmr_message_manager_test.go
index 23c6379..56aa30d 100644
--- a/RSM/managers/rmrmanagers/rmr_message_manager_test.go
+++ b/RSM/managers/rmrmanagers/rmr_message_manager_test.go
@@ -13,13 +13,18 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
-//
+
+//  This source code is part of the near-RT RIC (RAN Intelligent Controller)
+//  platform project (RICP).
+
 package rmrmanagers
 
 import (
 	"rsm/configuration"
-	"rsm/managers"
+	"rsm/converters"
+	"rsm/e2pdus"
 	"rsm/rmrcgo"
+	"rsm/services"
 	"rsm/tests/testhelper"
 	"testing"
 )
@@ -28,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")
@@ -43,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")