X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=e2ap%2Fpkg%2Fe2ap%2Fe2ap_tests%2Fmsg_e2ap_subscription.go;fp=e2ap%2Fpkg%2Fe2ap%2Fe2ap_tests%2Fmsg_e2ap_subscription.go;h=348fe4e37b2c4c08140a5504fb51ea707c110fe1;hb=ff8dccd02d76eebfccc0b509ce0b42a2c1760e12;hp=0000000000000000000000000000000000000000;hpb=f1d0eb6a82e11f14f60e3636d526299ced0173ea;p=ric-plt%2Fsubmgr.git diff --git a/e2ap/pkg/e2ap/e2ap_tests/msg_e2ap_subscription.go b/e2ap/pkg/e2ap/e2ap_tests/msg_e2ap_subscription.go new file mode 100644 index 0000000..348fe4e --- /dev/null +++ b/e2ap/pkg/e2ap/e2ap_tests/msg_e2ap_subscription.go @@ -0,0 +1,233 @@ +/* +================================================================================== + Copyright (c) 2019 AT&T Intellectual Property. + Copyright (c) 2019 Nokia + + 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 e2ap_tests + +import ( + "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap" + "testing" +) + +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- + +func (testCtxt *E2ApTests) E2ApTestMsgSubscriptionRequestWithData(t *testing.T, areqenc *e2ap.E2APSubscriptionRequest) { + + e2SubsReq := testCtxt.packerif.NewPackerSubscriptionRequest() + + testCtxt.testPrint("########## ##########") + testCtxt.testPrint("init") + seterr := e2SubsReq.Set(areqenc) + if seterr != nil { + testCtxt.testError(t, "set err: %s", seterr.Error()) + return + } + testCtxt.testPrint("print:\n%s", e2SubsReq.String()) + testCtxt.testPrint("pack") + err, packedMsg := e2SubsReq.Pack(nil) + if err != nil { + testCtxt.testError(t, "Pack failed: %s", err.Error()) + return + } + testCtxt.testPrint("unpack") + err = e2SubsReq.UnPack(packedMsg) + if err != nil { + testCtxt.testError(t, "UnPack failed: %s", err.Error()) + return + } + testCtxt.testPrint("print:\n%s", e2SubsReq.String()) + geterr, areqdec := e2SubsReq.Get() + if geterr != nil { + testCtxt.testError(t, "get nil: %s", geterr.Error()) + return + } + testCtxt.testValueEquality(t, "msg", areqenc, areqdec) + testCtxt.testValueEquality(t, "EventTriggerDefinition", &areqenc.EventTriggerDefinition, &areqdec.EventTriggerDefinition) +} + +func (testCtxt *E2ApTests) E2ApTestMsgSubscriptionRequest(t *testing.T) { + + areqenc := e2ap.E2APSubscriptionRequest{} + areqenc.RequestId.Id = 1 + areqenc.RequestId.Seq = 22 + areqenc.FunctionId = 33 + //Bits 20, 28(works), 18, 21 (asn1 problems) + areqenc.EventTriggerDefinition.InterfaceDirection = e2ap.E2AP_InterfaceDirectionIncoming + areqenc.EventTriggerDefinition.ProcedureCode = 35 + areqenc.EventTriggerDefinition.TypeOfMessage = e2ap.E2AP_InitiatingMessage + for index := 0; index < 16; index++ { + item := e2ap.ActionToBeSetupItem{} + item.ActionId = uint64(index) + item.ActionType = e2ap.E2AP_ActionTypeInsert + // NOT SUPPORTED CURRENTLY + //item.ActionDefinition.Present = true + //item.ActionDefinition.StyleId = 255 + //item.ActionDefinition.ParamId = 222 + item.SubsequentAction.Present = true + item.SubsequentAction.Type = e2ap.E2AP_SubSeqActionTypeContinue + item.SubsequentAction.TimetoWait = e2ap.E2AP_TimeToWaitW100ms + areqenc.ActionSetups = append(areqenc.ActionSetups, item) + } + + areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.Present = true + areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.PlmnIdentity.StringPut("310150") + areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Bits = e2ap.E2AP_ENBIDHomeBits28 + areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Id = 202251 + testCtxt.SetDesc("SubsReq-28bit") + testCtxt.E2ApTestMsgSubscriptionRequestWithData(t, &areqenc) + + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.Present = true + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.PlmnIdentity.StringPut("310150") + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Bits = e2ap.E2AP_ENBIDShortMacroits18 + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Id = 55 + //testCtxt.SetDesc("SubsReq-18bit") + //testCtxt.E2ApTestMsgSubscriptionRequestWithData(t,&areqenc) + + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.Present = true + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.PlmnIdentity.StringPut("310150") + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Bits = e2ap.E2AP_ENBIDMacroPBits20 + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Id = 55 + //testCtxt.SetDesc("SubsReq-20bit") + //testCtxt.E2ApTestMsgSubscriptionRequestWithData(t,&areqenc) + + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.Present = true + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.PlmnIdentity.StringPut("310150") + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Bits = e2ap.E2AP_ENBIDlongMacroBits21 + //areqenc.EventTriggerDefinition.InterfaceId.GlobalEnbId.NodeId.Id = 55 + //testCtxt.SetDesc("SubsReq-21bit") + //testCtxt.E2ApTestMsgSubscriptionRequestWithData(t,&areqenc) + +} + +func (testCtxt *E2ApTests) E2ApTestMsgSubscriptionResponse(t *testing.T) { + + testCtxt.SetDesc("SubsResp") + + e2SubsResp := testCtxt.packerif.NewPackerSubscriptionResponse() + + testCtxt.testPrint("########## ##########") + testCtxt.testPrint("init") + + arespenc := e2ap.E2APSubscriptionResponse{} + arespenc.RequestId.Id = 1 + arespenc.RequestId.Seq = 22 + arespenc.FunctionId = 33 + for index := uint64(0); index < 16; index++ { + item := e2ap.ActionAdmittedItem{} + item.ActionId = index + arespenc.ActionAdmittedList.Items = append(arespenc.ActionAdmittedList.Items, item) + } + for index := uint64(0); index < 16; index++ { + item := e2ap.ActionNotAdmittedItem{} + item.ActionId = index + item.Cause.Content = 1 + item.Cause.CauseVal = 1 + arespenc.ActionNotAdmittedList.Items = append(arespenc.ActionNotAdmittedList.Items, item) + } + + seterr := e2SubsResp.Set(&arespenc) + if seterr != nil { + testCtxt.testError(t, "set err: %s", seterr.Error()) + return + } + testCtxt.testPrint("print:\n%s", e2SubsResp.String()) + testCtxt.testPrint("pack") + err, packedMsg := e2SubsResp.Pack(nil) + if err != nil { + testCtxt.testError(t, "Pack failed: %s", err.Error()) + return + } + testCtxt.testPrint("unpack") + err = e2SubsResp.UnPack(packedMsg) + if err != nil { + testCtxt.testError(t, "UnPack failed: %s", err.Error()) + return + } + testCtxt.testPrint("print:\n%s", e2SubsResp.String()) + geterr, arespdec := e2SubsResp.Get() + if geterr != nil { + testCtxt.testError(t, "get nil: %s", geterr.Error()) + return + } + testCtxt.testValueEquality(t, "msg", &arespenc, arespdec) +} + +func (testCtxt *E2ApTests) E2ApTestMsgSubscriptionFailure(t *testing.T) { + + testCtxt.SetDesc("SubsFail") + + e2SubsFail := testCtxt.packerif.NewPackerSubscriptionFailure() + + testCtxt.testPrint("########## ##########") + testCtxt.testPrint("init") + + afailenc := e2ap.E2APSubscriptionFailure{} + afailenc.RequestId.Id = 1 + afailenc.RequestId.Seq = 22 + afailenc.FunctionId = 33 + for index := uint64(0); index < 16; index++ { + item := e2ap.ActionNotAdmittedItem{} + item.ActionId = index + item.Cause.Content = 1 + item.Cause.CauseVal = 1 + afailenc.ActionNotAdmittedList.Items = append(afailenc.ActionNotAdmittedList.Items, item) + } + // NOT SUPPORTED CURRENTLY + afailenc.CriticalityDiagnostics.Present = false + // afailenc.CriticalityDiagnostics.ProcCodePresent = true + // afailenc.CriticalityDiagnostics.ProcCode = 1 + // afailenc.CriticalityDiagnostics.TrigMsgPresent = true + // afailenc.CriticalityDiagnostics.TrigMsg = 2 + // afailenc.CriticalityDiagnostics.ProcCritPresent = true + // afailenc.CriticalityDiagnostics.ProcCrit = e2ap.E2AP_CriticalityReject + // for index := uint32(0); index < 256; index++ { + // ieitem := e2ap.CriticalityDiagnosticsIEListItem{} + // ieitem.IeCriticality = e2ap.E2AP_CriticalityReject + // ieitem.IeID = index + // ieitem.TypeOfError = 1 + // afailenc.CriticalityDiagnostics.CriticalityDiagnosticsIEList.Items = append(afailenc.CriticalityDiagnostics.CriticalityDiagnosticsIEList.Items, ieitem) + // } + + seterr := e2SubsFail.Set(&afailenc) + if seterr != nil { + testCtxt.testError(t, "set err: %s", seterr.Error()) + return + } + testCtxt.testPrint("print:\n%s", e2SubsFail.String()) + testCtxt.testPrint("pack") + err, packedMsg := e2SubsFail.Pack(nil) + if err != nil { + testCtxt.testError(t, "Pack failed: %s", err.Error()) + return + } + testCtxt.testPrint("unpack") + err = e2SubsFail.UnPack(packedMsg) + if err != nil { + testCtxt.testError(t, "UnPack failed: %s", err.Error()) + return + } + testCtxt.testPrint("print:\n%s", e2SubsFail.String()) + geterr, afaildec := e2SubsFail.Get() + if geterr != nil { + testCtxt.testError(t, "get nil: %s", geterr.Error()) + return + } + testCtxt.testValueEquality(t, "msg", &afailenc, afaildec) +}