X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=E2Manager%2Fconverters%2Fendc_setup_failure_response_converter_test.go;fp=E2Manager%2Fconverters%2Fendc_setup_failure_response_converter_test.go;h=77c60b5ef621ba88d9701cca8c5e6bdc611800ea;hb=efcb4528362460aa2249d319c9752b63bb720fe2;hp=0000000000000000000000000000000000000000;hpb=b6c5a882f986ed2d6440cf9be83d69740179c53d;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/converters/endc_setup_failure_response_converter_test.go b/E2Manager/converters/endc_setup_failure_response_converter_test.go
new file mode 100644
index 0000000..77c60b5
--- /dev/null
+++ b/E2Manager/converters/endc_setup_failure_response_converter_test.go
@@ -0,0 +1,120 @@
+/*
+ *   Copyright (c) 2019 AT&T Intellectual Property.
+ *
+ *   Licensed under the Apache License, Version 2.0 (the "License");
+ *   you may not use this file except in compliance with the License.
+ *   You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *   Unless required by applicable law or agreed to in writing, software
+ *   distributed under the License is distributed on an "AS IS" BASIS,
+ *   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 converters
+
+import (
+	"e2mgr/logger"
+	"fmt"
+	"gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
+	"strings"
+	"testing"
+)
+
+/*
+Test permutations of x2 setup response to protobuf enb
+*/
+
+func TestUnpackEndcX2SetupFailureResponseAndExtract(t *testing.T) {
+	logger, _ := logger.InitLogger(logger.InfoLevel)
+
+	var testCases = []struct {
+		response  string
+		packedPdu string
+		failure   error
+	}{
+		{
+			response: "CONNECTED_SETUP_FAILED network_layer_cause:HANDOVER_DESIRABLE_FOR_RADIO_REASONS time_to_wait:V1S criticality_diagnostics:<procedure_code:33 triggering_message:UNSUCCESSFUL_OUTCOME procedure_criticality:NOTIFY information_element_criticality_diagnostics:<ie_criticality:REJECT ie_id:128 type_of_error:MISSING > > ",
+			/*
+				E2AP-PDU:
+				 unsuccessfulOutcome_t
+				  procedureCode_t = 0x24
+				  criticality_t = 0
+				  ENDCX2SetupFailure
+				   protocolIEs_t:
+				    ProtocolIE_Container_elm
+				     id_t = 0x5
+				     criticality_t = 0x1
+				     Cause:
+				      radioNetwork_t = 0
+				    ProtocolIE_Container_elm
+				     id_t = 0x16
+				     criticality_t = 0x1
+				     TimeToWait = 0
+				    ProtocolIE_Container_elm
+				     id_t = 0x11
+				     criticality_t = 0x1
+				     CriticalityDiagnostics
+				      procedureCode_t = 0x21
+				      triggeringMessage_t = 0x2
+				      procedureCriticality_t = 0x2
+				      iEsCriticalityDiagnostics_t:
+				       CriticalityDiagnostics_IE_List_elm
+				        iECriticality_t = 0
+				        iE_ID_t = 0x80
+				        typeOfError_t = 0x1
+			*/
+			packedPdu: "4024001a0000030005400200000016400100001140087821a00000008040"},
+
+		/**** shares the same code with x2setup failure response to protobuf ****/
+	}
+
+	converter := NewEndcSetupFailureResponseConverter(logger)
+
+	for _, tc := range testCases {
+		t.Run(tc.packedPdu, func(t *testing.T) {
+
+			var payload []byte
+			_, err := fmt.Sscanf(tc.packedPdu, "%x", &payload)
+			if err != nil {
+				t.Errorf("convert inputPayloadAsStr to payloadAsByte. Error: %v\n", err)
+			}
+
+			response, err := converter.UnpackEndcSetupFailureResponseAndExtract(payload)
+
+			if err != nil {
+				if tc.failure == nil {
+					t.Errorf("want: success, got: error: %v\n", err)
+				} else {
+					if strings.Compare(err.Error(), tc.failure.Error()) != 0 {
+						t.Errorf("want: %s, got: %s", tc.failure, err)
+					}
+				}
+			}
+
+			if response == nil {
+				if tc.failure == nil {
+					t.Errorf("want: response=%s, got: empty response", tc.response)
+				}
+			} else {
+				nb := &entities.NodebInfo{}
+				nb.ConnectionStatus = entities.ConnectionStatus_CONNECTED_SETUP_FAILED
+				nb.SetupFailure = response
+				nb.FailureType = entities.Failure_X2_SETUP_FAILURE
+				respStr := fmt.Sprintf("%s %s", nb.ConnectionStatus, response)
+				if !strings.EqualFold(respStr, tc.response) {
+					t.Errorf("want: response=[%s], got: [%s]", tc.response, respStr)
+				}
+
+			}
+		})
+	}
+}