E2Manager/handlers/endc_x2setupFailureResponseToProtobuf_test.go

/*******************************************************************************
 *
 *   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.
 *
 *******************************************************************************/
package handlers

import (
	"gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
	"e2mgr/logger"
	"e2mgr/rNibWriter"
	"fmt"
	"strings"
	"testing"
)

/*
Test permutations of x2 setup response to protobuf enb
 */

func TestUnpackEndcX2SetupFailureResponseAndExtract(t *testing.T) {
	logger, _ := logger.InitLogger(logger.InfoLevel)

	var testCases = []struct {
		saveToRNib       bool
		response              string
		packedPdu        string
		failure          error
	}{
		{
			saveToRNib: false, //TODO: use MOCK?
			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 ****/
	}

    initDb_f := true
	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 := unpackEndcX2SetupFailureResponseAndExtract(logger, MaxAsn1CodecAllocationBufferSize /*allocation buffer*/, len(payload), payload, MaxAsn1CodecMessageBufferSize /*message buffer*/)

			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)
				}

				// Save to rNib
				if tc.saveToRNib {
					if initDb_f {
						rNibWriter.Init("e2Manager", 1)
						initDb_f = false
					}
					nbIdentity := &entities.NbIdentity{InventoryName:"RanName"}
					if rNibErr := rNibWriter.GetRNibWriter().SaveNodeb(nbIdentity, nb); rNibErr != nil {
						if tc.failure == nil {
							t.Errorf("rNibWriter failed to save ENB. Error: %s\n", rNibErr.Error())
						} else {
							if strings.Compare(rNibErr.Error(), tc.failure.Error()) != 0 {
								t.Errorf("want: %s, got: %s", tc.failure, rNibErr.Error())
							}
						}
					}
				}
			}
		})
	}
}