Restoring E2AP changes
[o-du/l2.git] / src / o1 / InitConfig.cpp
1 /*******************************************************************************
2 ################################################################################
3 #   Copyright (c) [2020] [HCL Technologies Ltd.]                               #
4 #                                                                              #
5 #   Licensed under the Apache License, Version 2.0 (the "License");            #
6 #   you may not use this file except in compliance with the License.           #
7 #   You may obtain a copy of the License at                                    #
8 #                                                                              #
9 #       http://www.apache.org/licenses/LICENSE-2.0                             #
10 #                                                                              #
11 #   Unless required by applicable law or agreed to in writing, software        #
12 #   distributed under the License is distributed on an "AS IS" BASIS,          #
13 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #
14 #   See the License for the specific language governing permissions and        #
15 #   limitations under the License.                                             #
16 ################################################################################
17 *******************************************************************************/
18
19 /* This file contains methods of InitConfig and Interfaces to
20    YANG modules */
21
22 #include "InitConfig.hpp"
23 #include<string>
24 #include <string.h>
25 using namespace std;
26
27
28 /* Default constructor */
29 InitConfig::InitConfig()
30 {    
31 }
32
33
34 /* Destructor */
35 InitConfig::~InitConfig()
36 {  
37 }
38
39 /*******************************************************************
40  *
41  * @brief Initialize Configuration
42  *
43  * @details
44  *
45  *    Function : init 
46  *
47  *    Functionality:
48  *      - Initialize Configuration
49  *
50  * @params[in] Reference to S_Session 
51  * @return bool
52  *
53  ******************************************************************/
54
55 bool InitConfig::init(sysrepo::S_Session sess)
56 {
57    O1_LOG("\nInitConfig::init started ");
58    mSess =  sess;
59    getInterfaceConfig(sess);
60    return true;
61 }
62
63 /*******************************************************************
64  *
65  * @brief Get running Interface Configuration
66  *
67  * @details
68  *
69  *    Function : getCurrInterfaceConfig 
70  *
71  *    Functionality:
72  *      - Get running Interface Configuration
73  *
74  * @params[in] Reference of StartupConfig
75  * @return bool
76  *
77  ******************************************************************/
78
79 bool InitConfig::getCurrInterfaceConfig(StartupConfig & cfg)
80 {
81    //O1_LOG("\n InitConfig::getCurrInterfaceConfig entry");
82    InitConfig::InterfaceMap::iterator it;
83    for (it=mInterfaceList.begin(); it != mInterfaceList.end(); it++)
84    {
85       //O1_LOG("\n InitConfig::getCurrInterfaceConfig iterator");
86       switch (it->first)
87       {
88          case Interface::ODU :
89             if(it->second.first != "0")
90                strcpy(cfg.DU_IPV4_Addr, it->second.first.c_str());
91             else
92                strcpy(cfg.DU_IPV4_Addr, DEFAULT_DU_IPV4_ADDR);
93             //O1_LOG("\n InitConfig::getCurrInterfaceConfig cfg.DU_IPV4_Addr = \
94                        %s", cfg.DU_IPV4_Addr);
95
96             if(it->second.second != 0)
97                cfg.DU_Port = (uint16_t)it->second.second;
98             else
99                cfg.DU_Port = (uint16_t) DEFAULT_DU_PORT;
100             //O1_LOG("\n InitConfig::getCurrInterfaceConfig cfg.DU_Port = %d", \
101                        cfg.DU_Port);
102             break;
103  
104          case Interface::OCU :
105            
106             if(it->second.first != "0")
107                strcpy(cfg.CU_IPV4_Addr, it->second.first.c_str());
108             else
109                strcpy(cfg.CU_IPV4_Addr, DEFAULT_CU_IPV4_ADDR);
110             
111             //O1_LOG("\n InitConfig::getCurrInterfaceConfig cfg.CU_IPV4_Addr = \
112                        %s", cfg.CU_IPV4_Addr);
113           
114             if(it->second.second != 0)
115                cfg.CU_Port = (uint16_t) it->second.second;
116             else
117                cfg.CU_Port = (uint16_t) DEFAULT_CU_PORT; 
118          
119             //O1_LOG("\n InitConfig::getCurrInterfaceConfig cfg.CU_Port = %d", \
120                        cfg.CU_Port);
121             break;
122
123          case Interface::RIC :
124
125             if(it->second.first != "0")
126                strcpy(cfg.RIC_IPV4_Addr, it->second.first.c_str());
127             else
128                strcpy(cfg.RIC_IPV4_Addr, DEFAULT_RIC_IPV4_ADDR);
129                
130             //O1_LOG("\n InitConfig::getCurrInterfaceConfig cfg.RIC_IPV4_Addr = \
131                        %s", cfg.RIC_IPV4_Addr);
132             
133             if(it->second.second != 0)
134                cfg.RIC_Port = (uint16_t) it->second.second;
135             else
136                cfg.RIC_Port = (uint16_t) DEFAULT_RIC_PORT; 
137
138             //O1_LOG("\n InitConfig::getCurrInterfaceConfig cfg.RIC_Port = %d", \
139                        cfg.RIC_Port);
140             break;
141
142          default :
143             O1_LOG("\nno matching interface");
144             break;
145     }
146    }
147    return true;
148 }
149
150 /*******************************************************************
151  *
152  * @brief Get Interface Configuration
153  *
154  * @details
155  *
156  *    Function : getInterfaceConfig 
157  *
158  *    Functionality:
159  *      - Get running Interface Configuration
160  *
161  * @params[in] Reference of S_Session
162  * @return reference of InterfaceMap
163  *
164  ******************************************************************/
165 InitConfig::InterfaceMap InitConfig::getInterfaceConfig(sysrepo::S_Session sess)
166 {
167    O1_LOG("\nInitConfig::getInterfaceConfig started");
168    mInterfaceList.insert(std::make_pair(Interface::ODU, \
169                                         getInterfaceData(sess,Interface::ODU)));
170    mInterfaceList.insert(std::make_pair(Interface::OCU, \
171                                         getInterfaceData(sess,Interface::OCU)));
172    mInterfaceList.insert(std::make_pair(Interface::RIC, \
173                                         getInterfaceData(sess,Interface::RIC)));
174    return mInterfaceList;
175 }
176
177 /*******************************************************************
178  *
179  * @brief Get Interface Data
180  *
181  * @details
182  *
183  *    Function : getInterfaceData 
184  *
185  *    Functionality:
186  *      - Get running Interface Data 
187  *
188  * @params[in] Reference of S_Session and Interface
189  * @return reference of Address
190  *
191  ******************************************************************/
192 InitConfig::Address InitConfig::getInterfaceData(sysrepo::S_Session sess, \
193                                                  Interface inf)
194 {
195    O1_LOG("\nInitConfig::getInterfaceData started");
196    string sInf = interfaceToString(inf);
197    return std::make_pair(getData(sess, getInterfaceXpath(sInf, IP_ADDRESS)), \
198                          atoi(getData(sess, getInterfaceXpath(sInf, PORT)).c_str()));
199 }
200
201 /*******************************************************************
202  *
203  * @brief create xpath for interfaces
204  *
205  * @details
206  *
207  *    Function : getInterfaceXpath
208  *
209  *    Functionality:
210  *      - create xpath for interfaces
211  *
212  * @params[in] String of sInf and String of param
213  * @return pointer to xpath
214  *
215  ******************************************************************/
216 char * InitConfig::getInterfaceXpath( string sInf, string param)
217 {
218    sprintf(xpath, "%s/interfaces/interface[interface-name='%s']/%s", \
219            INTERFACE_MODULE_NAME_ORAN, sInf.c_str(),param.c_str());
220    return xpath;
221 }
222
223 /*******************************************************************
224  *
225  * @brief  Get data of the xpath
226  *
227  * @details
228  *
229  *    Function : getData
230  *
231  *    Functionality:
232  *      -  get data of the xpath
233  *
234  * @params[in] reference of S_Session and pointer to xpath
235  * @return value against the xpath
236  *
237  ******************************************************************/
238
239 string InitConfig::getData(sysrepo::S_Session sess,char* xpath)
240 {
241    //O1_LOG("\nInitConfig::getData of xpath = %s", \
242               xpath); //enable for debugging only
243    try
244    {
245    auto value = sess->get_item(xpath);
246    if (value == nullptr)
247    {
248       //O1_LOG("\nget_item value are null for xpath = %s", \
249                  xpath); //enable for debugging only
250       return "0";
251    }
252    string mVal = value->val_to_string();
253    return mVal;
254
255    }
256    catch (...)
257    {
258       //O1_LOG("\nInitConfig::getData exception occured for block xpath= %s", \
259                 xpath); //enable for debugging only
260       return "0";
261    }
262 }
263  
264 /*******************************************************************
265  *
266  * @brief  Convert interface value to string
267  *
268  * @details
269  *
270  *    Function : interfaceToString
271  *
272  *    Functionality:
273  *      -  Convert interface value to string
274  *
275  * @params[in] reference to Interface
276  * @return string value of Interface
277  *
278  ******************************************************************/
279 string InitConfig::interfaceToString(Interface inf)
280 {
281    string interface;
282     switch (inf)
283     {
284         case Interface::ODU :
285            interface = "odu";
286            break; 
287    case Interface::OCU :
288            interface = "ocu"; 
289            break;
290         case Interface::RIC :
291            interface = "ric";
292            break;
293    default :
294           O1_LOG("\n\n no matching interface ");
295           break;
296     }
297     return interface;
298  
299 }
300
301
302 /*******************************************************************
303  *
304  * @brief  Print Interface configuration
305  *
306  * @details
307  *
308  *    Function : printInterfaceConfig
309  *
310  *    Functionality:
311  *      -  Print Interface configuration
312  *
313  * @params[in] void
314  * @return bool
315  *
316  ******************************************************************/
317 bool InitConfig::printInterfaceConfig()
318 {
319    InitConfig::InterfaceMap::iterator it;
320    for (it=mInterfaceList.begin(); it != mInterfaceList.end(); it++)
321    {
322       O1_LOG("\ninterface [%s] : \n \t IP = %s \n \t Port = %d", \
323               interfaceToString(it->first).c_str(), it->second.first.c_str(), \
324               it->second.second);
325    }
326    return true;
327 }
328
329 /**********************************************************************
330          End of file
331 **********************************************************************/