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.
17 ==================================================================================
21 Abstract: Routing Manager Main file. Implemets the following functions:
22 - parseArgs: reading command line arguments
23 - init:Rtmgr initializing the service modules
24 - serve: running the loop
40 const SERVICENAME = "rtmgr"
41 const INTERVAL time.Duration = 2
44 args map[string]*string
48 // TODO: arguments should be validated (filename; xm-url; sbi-if)
49 args = make(map[string]*string)
50 args["nbi"] = flag.String("nbi", "httpGetter", "Northbound interface module to be used. Valid values are: 'httpGetter'")
51 args["sbi"] = flag.String("sbi", "nngpush", "Southbound interface module to be used. Valid values are: 'nngpush | nngpub'")
52 args["rpe"] = flag.String("rpe", "rmrpush", "Route Policy Engine to be used. Valid values are: 'rmrpush | rmrpub'")
53 args["sdl"] = flag.String("sdl", "file", "Datastore enginge to be used. Valid values are: 'file'")
54 args["xm-url"] = flag.String("xm-url", "http://localhost:3000/xapps", "HTTP URL where xApp Manager exposes the entire xApp List")
55 args["sbi-if"] = flag.String("sbi-if", "0.0.0.0", "IPv4 address of interface where Southbound socket to be opened")
56 args["filename"] = flag.String("filename", "/db/rt.json", "Absolute path of file where the route information to be stored")
57 args["loglevel"] = flag.String("loglevel", "INFO", "INFO | WARN | ERROR | DEBUG")
61 func initRtmgr() (*nbi.NbiEngineConfig, *sbi.SbiEngineConfig, *sdl.SdlEngineConfig, *rpe.RpeEngineConfig, error) {
63 var nbii *nbi.NbiEngineConfig
64 var sbii *sbi.SbiEngineConfig
65 var sdli *sdl.SdlEngineConfig
66 var rpei *rpe.RpeEngineConfig
67 if nbii, err = nbi.GetNbi(*args["nbi"]); err == nil && nbii != nil {
68 if sbii, err = sbi.GetSbi(*args["sbi"]); err == nil && sbii != nil {
69 if sdli, err = sdl.GetSdl(*args["sdl"]); err == nil && sdli != nil {
70 if rpei, err = rpe.GetRpe(*args["rpe"]); err == nil && rpei != nil {
71 return nbii, sbii, sdli, rpei, nil
76 return nil, nil, nil, nil, err
79 func serve(nbii *nbi.NbiEngineConfig, sbii *sbi.SbiEngineConfig, sdli *sdl.SdlEngineConfig, rpei *rpe.RpeEngineConfig) {
80 err := sbii.OpenSocket(*args["sbi-if"])
82 rtmgr.Logger.Info("fail to open pub socket due to: " + err.Error())
85 defer sbii.CloseSocket()
87 time.Sleep(INTERVAL * time.Second)
88 data, err := nbii.BatchFetch(*args["xm-url"])
90 rtmgr.Logger.Error("cannot get data from " + nbii.Engine.Name + " interface dute to: " + err.Error())
92 sdli.WriteAll(*args["filename"], data)
94 data, err = sdli.ReadAll(*args["filename"])
95 if err != nil || data == nil {
96 rtmgr.Logger.Error("cannot get data from " + sdli.Engine.Name + " interface dute to: " + err.Error())
99 sbi.UpdateEndpointList(data, sbii)
100 policies := rpei.GeneratePolicies(rtmgr.Eps)
101 err = sbii.DistributeAll(policies)
103 rtmgr.Logger.Error("routing rable cannot be published due to: " + err.Error())
110 rtmgr.SetLogLevel(*args["loglevel"])
111 nbii, sbii, sdli, rpei, err := initRtmgr()
113 rtmgr.Logger.Error(err.Error())
116 rtmgr.Logger.Info("Start " + SERVICENAME + " service")
117 rtmgr.Eps = make(rtmgr.Endpoints)
118 serve(nbii, sbii, sdli, rpei)