func (c *RoutingManagerClient) AssociateRanToE2TInstance(e2tAddress string, ranName string) error {
- data := models.NewRoutingManagerE2TData(e2tAddress, ranName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(e2tAddress, ranName)}
url := c.config.RoutingManager.BaseUrl + AssociateRanToE2TInstanceApiSuffix
return c.PostMessage(data, url)
func (c *RoutingManagerClient) DissociateRanE2TInstance(e2tAddress string, ranName string) error {
- data := models.NewRoutingManagerE2TData(e2tAddress, ranName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(e2tAddress, ranName)}
url := c.config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix
return c.PostMessage(data, url)
}
-func (c *RoutingManagerClient) PostMessage(data *models.RoutingManagerE2TData, url string) error {
+func (c *RoutingManagerClient) DissociateAllRans(e2tAddresses []string) error {
+
+ data := mapE2TAddressesToE2DataList(e2tAddresses)
+ url := c.config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix
+
+ return c.PostMessage(data, url)
+}
+
+func (c *RoutingManagerClient) PostMessage(data interface{}, url string) error {
marshaled, err := json.Marshal(data)
if err != nil {
c.logger.Errorf("[Routing Manager -> E2M] #RoutingManagerClient.PostMessage - failure. http status code: %d", resp.StatusCode)
return e2managererrors.NewRoutingManagerError()
-}
\ No newline at end of file
+}
+
+func mapE2TAddressesToE2DataList(e2tAddresses []string) models.RoutingManagerE2TDataList {
+ e2tDataList := make(models.RoutingManagerE2TDataList, len(e2tAddresses))
+
+ for i, v := range e2tAddresses {
+ e2tDataList[i] = models.NewRoutingManagerE2TData(v)
+ }
+
+ return e2tDataList
+}
func TestAssociateRanToE2TInstance_Success(t *testing.T) {
rmClient, httpClientMock, config := initRoutingManagerClientTest(t)
- data := models.NewRoutingManagerE2TData(E2TAddress,RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress,RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := config.RoutingManager.BaseUrl + AssociateRanToE2TInstanceApiSuffix
func TestAssociateRanToE2TInstance_RoutingManagerError(t *testing.T) {
rmClient, httpClientMock, config := initRoutingManagerClientTest(t)
- data := models.NewRoutingManagerE2TData(E2TAddress,RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress,RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := config.RoutingManager.BaseUrl + AssociateRanToE2TInstanceApiSuffix
func TestAssociateRanToE2TInstance_RoutingManager_400(t *testing.T) {
rmClient, httpClientMock, config := initRoutingManagerClientTest(t)
- data := models.NewRoutingManagerE2TData(E2TAddress,RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress,RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := config.RoutingManager.BaseUrl + AssociateRanToE2TInstanceApiSuffix
func TestDissociateRanE2TInstance_Success(t *testing.T) {
rmClient, httpClientMock, config := initRoutingManagerClientTest(t)
- data := models.NewRoutingManagerE2TData(E2TAddress,RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress,RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix
func TestDissociateRanE2TInstance_RoutingManagerError(t *testing.T) {
rmClient, httpClientMock, config := initRoutingManagerClientTest(t)
- data := models.NewRoutingManagerE2TData(E2TAddress,RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress,RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix
func TestDissociateRanE2TInstance_RoutingManager_400(t *testing.T) {
rmClient, httpClientMock, config := initRoutingManagerClientTest(t)
- data := models.NewRoutingManagerE2TData(E2TAddress,RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress,RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := config.RoutingManager.BaseUrl + DissociateRanE2TInstanceApiSuffix
}
func mockHttpClientAssociateRan(httpClientMock *mocks.HttpClientMock) {
- data := models.NewRoutingManagerE2TData(E2TAddress, RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress, RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := BaseRMUrl + clients.AssociateRanToE2TInstanceApiSuffix
}
func mockHttpClientAssociateRan(httpClientMock *mocks.HttpClientMock, isSuccessful bool) {
- data := models.NewRoutingManagerE2TData(E2TAddress, RanName)
+ data := models.RoutingManagerE2TDataList{models.NewRoutingManagerE2TData(E2TAddress, RanName)}
marshaled, _ := json.Marshal(data)
body := bytes.NewBuffer(marshaled)
url := BaseRMUrl + clients.AssociateRanToE2TInstanceApiSuffix
--- /dev/null
+//
+// Copyright 2019 AT&T Intellectual Property
+// Copyright 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.
+
+// This source code is part of the near-RT RIC (RAN Intelligent Controller)
+// platform project (RICP).
+
+package models
+
+type RoutingManagerE2TDataList []*RoutingManagerE2TData