2 ==================================================================================
3 Copyright (c) 2019 AT&T Intellectual Property.
4 Copyright (c) 2019 Nokia
6 Licensed under the Apache License, Version 2.0 (the "License");
7 you may not use this file except in compliance with the License.
8 You may obtain a copy of the License at
10 http://www.apache.org/licenses/LICENSE-2.0
12 Unless required by applicable law or agreed to in writing, software
13 distributed under the License is distributed on an "AS IS" BASIS,
14 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 See the License for the specific language governing permissions and
16 limitations under the License.
19 This source code is part of the near-RT RIC (RAN Intelligent Controller)
20 platform project (RICP).
22 ==================================================================================
26 Abstract: RMR Route Policy implementation
27 Produces RMR (RIC Management Routing) formatted route messages
34 "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
35 "routing-manager/pkg/models"
36 "routing-manager/pkg/rtmgr"
49 func NewRmrPush() *RmrPush {
50 instance := new(RmrPush)
55 Produces the raw route message consumable by RMR
57 func (r *Rmr) generateRMRPolicies(eps rtmgr.Endpoints, rcs *rtmgr.RicComponents, key string) *[]string {
58 rawrt := []string{key + "newrt|start\n"}
59 rt := r.generateRouteTable(eps)
60 for _, rte := range *rt {
61 rawrte := key + "mse|" + rte.MessageType
62 for _, tx := range rte.TxList {
63 rawrte += "," + tx.Ip + ":" + strconv.Itoa(int(tx.Port))
65 rawrte += "|" + strconv.Itoa(int(rte.SubID)) + "|"
67 for _, rxg := range rte.RxGroups {
69 for _, rx := range rxg {
71 member += rx.Ip + ":" + strconv.Itoa(int(rx.Port))
73 member += "," + rx.Ip + ":" + strconv.Itoa(int(rx.Port))
83 if rte.RouteType == "%meid" {
84 rawrte += "%" + "meid"
89 rawrt = append(rawrt, rawrte+"\n")
91 for _, val := range rtmgr.DynamicRouteList {
92 rawrt = append(rawrt, val)
95 rawrt = append(rawrt, key+"newrt|end\n")
98 rawrt = append(rawrt, key+"meid_map|start\n")
99 keys := make(map[string]RouteIndex)
100 for _, value := range rcs.MeidMap {
101 if _, v := keys[key+value+"\n"]; !v {
102 rawrt = append(rawrt, key+value+"\n")
103 appendedindex := uint16(len(rawrt) - 1)
104 keys[key+value+"\n"] = RouteIndex{true, appendedindex}
107 if strings.Contains(value, "mme_ar") {
108 tmpstr := strings.Split(value, "|")
110 //MEID entry for mme_ar must always contain 3 strings speartred by | i.e "mme_ar|<string1>|<string2>"
111 MEID := strings.TrimSuffix(tmpstr[2], "\n")
113 mapindex := "mme_del|" + MEID + "\n"
114 i := keys[mapindex].index
115 if keys[mapindex].flag {
116 //copy(rawrt[i:], rawrt[i+1:])
117 //rawrt[len(rawrt)-1] = ""
118 //rawrt = rawrt[:len(rawrt)-1]
120 delete(keys, mapindex)
125 rawrt = removeEmptyStrings(rawrt)
126 rawrt = append(rawrt, key+"meid_map|end|"+strconv.Itoa(count)+"\n")
128 xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rawrt)
129 xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rcs)
134 Produces the raw route message consumable by RMR
136 func (r *Rmr) generatePartialRMRPolicies(eps rtmgr.Endpoints, xappSubData *models.XappSubscriptionData, key string, updatetype rtmgr.RMRUpdateType) *[]string {
137 rawrt := []string{key + "updatert|start\n"}
138 rt := r.generatePartialRouteTable(eps, xappSubData, updatetype)
139 for _, rte := range *rt {
140 rawrte := key + "mse|" + rte.MessageType
141 for _, tx := range rte.TxList {
142 rawrte += "," + tx.Ip + ":" + strconv.Itoa(int(tx.Port))
144 rawrte += "|" + strconv.Itoa(int(rte.SubID)) + "|"
146 for _, rxg := range rte.RxGroups {
148 for _, rx := range rxg {
150 member += rx.Ip + ":" + strconv.Itoa(int(rx.Port))
152 member += "," + rx.Ip + ":" + strconv.Itoa(int(rx.Port))
158 group += ";" + member
162 if rte.RouteType == "%meid" {
163 rawrte += "%" + "meid"
168 rawrt = append(rawrt, rawrte+"\n")
171 rawrt = append(rawrt, key+"updatert|end\n")
174 xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rawrt)
177 func (r *RmrPush) GeneratePolicies(eps rtmgr.Endpoints, rcs *rtmgr.RicComponents) *[]string {
178 xapp.Logger.Debug("Invoked rmr.GeneratePolicies, args: %v: ", eps)
179 return r.generateRMRPolicies(eps, rcs, "")
182 func (r *RmrPush) GenerateRouteTable(eps rtmgr.Endpoints) *rtmgr.RouteTable {
183 return r.generateRouteTable(eps)
186 func (r *RmrPush) GeneratePartialPolicies(eps rtmgr.Endpoints, xappSubData *models.XappSubscriptionData, updatetype rtmgr.RMRUpdateType) *[]string {
187 xapp.Logger.Debug("Invoked rmr.GeneratePartialPolicies, args: %v: ", eps)
188 return r.generatePartialRMRPolicies(eps, xappSubData, "", updatetype)
191 func removeEmptyStrings(s []string) []string {
193 for _, str := range s {