X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fsbi%2Fsbi_test.go;h=52436ed3a15e849b3b4e16a8cf9ae2edd8efe59c;hb=refs%2Fchanges%2F94%2F2094%2F3;hp=5c7e848acd1266cb910671e73a667a25e02a876e;hpb=92162653c9741f2417d1a36ec1c211d6863d0a68;p=ric-plt%2Frtmgr.git diff --git a/pkg/sbi/sbi_test.go b/pkg/sbi/sbi_test.go index 5c7e848..52436ed 100644 --- a/pkg/sbi/sbi_test.go +++ b/pkg/sbi/sbi_test.go @@ -14,6 +14,10 @@ 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). + ================================================================================== */ /* @@ -24,17 +28,18 @@ package sbi import ( - "testing" - "reflect" "errors" + "reflect" + "testing" + "routing-manager/pkg/rtmgr" ) func TestGetSbi(t *testing.T) { var errtype = errors.New("") - var sbitype = new(NngPub) + var sbitype = new(NngPush) var invalids = []string{"nngpus", ""} - sbii, err := GetSbi("nngpub") + sbii, err := GetSbi("nngpush") if err != nil { t.Errorf("GetSbi(nngpub) was incorrect, got: %v, want: %v.", reflect.TypeOf(err), nil) } @@ -49,3 +54,31 @@ func TestGetSbi(t *testing.T) { } } } + +func TestUpdateE2TendPoint(t *testing.T) { + var err error + var sbi = Sbi{} + sbii, err := GetSbi("nngpush") + var E2map = make(map[string]rtmgr.E2TInstance) + + E2map["1.2.3.4:100"] = rtmgr.E2TInstance{ + Name: "E2Tinstance1", + Fqdn: "1.2.3.4:100", + Ranlist: []string{"1","2"}, + } + + sbi.updateE2TEndpoints(&E2map,sbii) + t.Log(err) +} + +func TestpruneEndpointList(t *testing.T) { + var sbi = Sbi{} + var err error + sbii, err := GetSbi("nngpush") + + var EP = make(map[string]*rtmgr.Endpoint) + EP["10.0.0.1:0"] = &rtmgr.Endpoint{Uuid: "10.0.0.1:0", Name: "E2TERM", XAppType: "app1", Ip: "", Port: 0, TxMessages: []string{"", ""}, RxMessages: []string{"", ""}, Socket: nil, IsReady: true, Keepalive: true} + rtmgr.Eps = EP + sbi.pruneEndpointList(sbii) + t.Log(err) +}