Adding Bouncer code for RIC-Benchmarking
[ric-app/bouncer.git] / Bouncer / src / xapp-asn / e2ap / response_helper.hpp
1 /*
2 ==================================================================================
3         Copyright (c) 2019-2020 AT&T Intellectual Property.
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 #pragma once
20
21 #ifndef S_RESPONSE_HELPER_
22 #define S_RESPONSE_HELPER_
23
24 #include <vector>
25 #include <memory>
26
27 /* Simple structure to store action for RICaction of the Subscription response based on E2 v0.31 */
28 struct ActionResponse {
29 public:
30   ActionResponse(int id): _is_admit(true), _id(id), _cause(-1), _sub_cause(-1){};
31   ActionResponse(int id, int cause, int sub_cause): _is_admit(false), _id(id), _cause(cause), _sub_cause(sub_cause){};
32   
33   int get_id() const{
34     return _id;
35   };
36
37   int get_cause() const{
38     return _cause;
39   };
40
41   int get_sub_cause() const{
42     return _sub_cause;
43   };
44
45   bool is_admitted(void){
46     return _is_admit;
47   };
48   
49 private:
50
51   bool _is_admit;
52   int _id, _cause, _sub_cause;
53   
54 };
55
56
57 struct subscription_response_helper {
58   
59 public:
60
61   using action_t = std::vector<ActionResponse>;
62   
63   subscription_response_helper(void){
64     _action_admitted_ref = std::make_unique<action_t>();
65     _action_not_admitted_ref = std::make_unique<action_t>();
66     
67   };
68   
69   // copy operator
70   subscription_response_helper(const subscription_response_helper &he ){
71     _action_admitted_ref = std::make_unique<action_t>();
72     _action_not_admitted_ref = std::make_unique<action_t>();
73     
74     _req_id = he.get_request_id();
75     _req_seq_no = he.get_req_seq();
76     _func_id = he.get_function_id();
77     
78     // Take care of the actions
79     for (auto const & e: *(he.get_admitted_list())){
80       add_action(e.get_id());
81     }
82     
83     for(auto const  & e: *(he.get_not_admitted_list())){
84       add_action(e.get_id(), e.get_cause(), e.get_sub_cause());
85     };
86   }
87   
88
89   // assignment operator
90   void operator=(const subscription_response_helper & he){
91     _action_admitted_ref = std::make_unique<action_t>();
92     _action_not_admitted_ref = std::make_unique<action_t>();
93     
94     _req_id = he.get_request_id();
95     _req_seq_no = he.get_req_seq();
96     _func_id = he.get_function_id();
97     
98     
99     // Take care of the actions
100     for (auto  const & e: *(he.get_admitted_list())){
101       add_action(e.get_id());
102     }
103   
104     for(auto const  & e: *(he.get_not_admitted_list())){
105       add_action(e.get_id(), e.get_cause(), e.get_sub_cause());
106     };
107     
108   }
109   
110   action_t * get_admitted_list (void ) const {return _action_admitted_ref.get();};
111   action_t * get_not_admitted_list (void ) const{return _action_not_admitted_ref.get();};
112   
113   void set_request(int id, int seq_no){
114     _req_id = id;
115     _req_seq_no = seq_no;
116     
117   };
118
119   void clear(void){
120     _action_admitted_ref.get()->clear();
121     _action_not_admitted_ref.get()->clear();
122   }
123
124   
125   void set_function_id(int id){
126     _func_id = id;
127   };
128
129   void add_action(int id){
130     ActionResponse a(id) ;
131     _action_admitted_ref.get()->push_back(a);
132   };
133
134   void add_action(int id, int cause, int sub_cause){
135     ActionResponse a (id, cause, sub_cause);
136     _action_not_admitted_ref.get()->push_back(a);
137   };
138
139
140   int  get_request_id(void) const{
141     return _req_id;
142   }
143   
144   int get_req_seq(void) const{
145     return _req_seq_no;
146   }
147
148   int  get_function_id(void) const{
149     return _func_id;
150   }
151  
152   std::string  to_string(void){
153     std::string Info;
154     Info += "Request ID = " + std::to_string(_req_id) + "\n";
155     Info += "Request Sequence No = "  + std::to_string(_req_seq_no) + "\n";
156     Info += "RAN Function ID = " + std::to_string(_func_id) + "\n";
157     Info += "Actions Admitted =\n";
158     int i = 0;
159     for(auto & e: *(_action_admitted_ref)){
160         Info += std::to_string(i)  + ": ID=" + std::to_string(e.get_id()) + "\n";
161         i++;
162     }    
163     Info += "Actions Not Admitted =\n";
164     i = 0;
165     for(auto & e: *(_action_not_admitted_ref)){
166       Info += std::to_string(i)  + ": ID=" + std::to_string(e.get_id()) +  ": Cause =" + std::to_string(e.get_cause()) + ": Sub-Cause=" + std::to_string(e.get_sub_cause()) + "\n";
167       i++;
168     }    
169   
170     return Info;
171   } 
172
173 private:
174   int _req_id, _req_seq_no, _func_id;
175   std::unique_ptr<action_t> _action_admitted_ref;
176   std::unique_ptr<action_t> _action_not_admitted_ref;
177   
178 };
179   
180
181 #endif