Use default area when area is not requested
[apps/agl-service-windowmanager.git] / src / policy_manager / policy_manager.cpp
1 /*
2  * Copyright (c) 2018 TOYOTA MOTOR CORPORATION
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16
17
18 #include <fstream>
19 #include <sstream>
20 #include <istream>
21 #include <thread>
22 #include <map>
23 #include <systemd/sd-event.h>
24 #include <json-c/json.h>
25 #include "policy_manager.hpp"
26 #include "hmi-debug.h"
27
28 namespace stm {
29 extern "C" {
30 #include "dummy_stm.h"
31 }
32 } // namespace stm
33
34
35 namespace pm {
36 typedef struct AreaState {
37     std::string name;
38     std::string category;
39     std::string role;
40 } AreaState;
41
42 typedef std::vector<AreaState> AreaList;
43 typedef struct LayoutState {
44     std::string name;
45     std::map<std::string, int> category_num;
46     AreaList area_list;
47     std::map<std::string, std::vector<std::string>> role_history;
48 } LayoutState;
49
50 typedef struct LayerState {
51     std::string name;
52     LayoutState layout_state;
53     int changed;
54 } LayerState;
55
56 typedef struct CarElement {
57     std::string state;
58     int changed;
59 } CarElement;
60
61 struct sd_event* event_loop;
62 std::map<int, struct sd_event_source*> event_source_list;
63 std::map<int, std::string> g_req_role_list;
64 PolicyManager::CallbackTable callback;
65
66 std::unordered_map<std::string, CarElement> g_prv_car_elements;
67 std::unordered_map<std::string, CarElement> g_crr_car_elements;
68
69 std::unordered_map<std::string, LayerState> g_prv_layers;
70 std::unordered_map<std::string, LayerState> g_crr_layers;
71
72 std::unordered_map<std::string, LayerState> g_prv_layers_car_stop;
73
74 std::unordered_map<std::string, LayoutState> g_default_layouts;
75 }  // namespace pm
76
77
78 PolicyManager::PolicyManager() :
79   eventname2no(),
80   categoryname2no(),
81   areaname2no(),
82   role2category(),
83   category2role(),
84   role2defaultarea()
85 {
86     HMI_DEBUG("wm:pm", "Call");
87 }
88
89 int PolicyManager::initialize() {
90     HMI_DEBUG("wm:pm", "Call");
91
92     int ret = 0;
93
94     // Create convert map
95     for (int i = stm::gStmEventNoMin; i <= stm::gStmEventNoMax; i++) {
96         HMI_DEBUG("wm:pm", "event name:%s no:%d", stm::gStmEventName[i], stm::gStmEventNo[i]);
97         this->eventname2no[stm::gStmEventName[i]] = stm::gStmEventNo[i];
98     }
99
100     for (int i = stm::gStmCategoryNoMin; i <= stm::gStmCategoryNoMax; i++) {
101         HMI_DEBUG("wm:pm", "category name:%s no:%d", stm::gStmCategoryName[i], stm::gStmCategoryNo[i]);
102         this->categoryname2no[stm::gStmCategoryName[i]] = stm::gStmCategoryNo[i];
103     }
104
105     for (int i = stm::gStmAreaNoMin; i <= stm::gStmAreaNoMax; i++) {
106         HMI_DEBUG("wm:pm", "area name:%s no:%d", stm::gStmAreaName[i], stm::gStmAreaNo[i]);
107         this->areaname2no[stm::gStmAreaName[i]] = stm::gStmAreaNo[i];
108     }
109
110     // Load role.db
111     ret = this->loadRoleDb();
112     if (0 > ret) {
113         HMI_ERROR("wm:pm", "Load role.db Error!!");
114         return ret;
115     }
116
117     // Load layout.db
118     ret = this->loadLayoutDb();
119     if (0 > ret) {
120         HMI_ERROR("wm:pm", "Load layout.db Error!!");
121         return ret;
122     }
123
124     // Initialize state which is managed by PolicyManager
125     this->initializeLocalState();
126
127     // Initialize StateTransitioner
128     stm::stmInitialize();
129
130     // Initialize sd_event loop
131     ret = this->initializeSdEventLoop();
132     if (0 > ret) {
133         HMI_ERROR("wm:pm", "Failed to initializeSdEventLoop!!");
134         return ret;
135     }
136
137     return ret;
138 }
139
140 static void initializeLocalCarElementState() {
141     pm::CarElement init_car_ele;
142     init_car_ele.state   = "none";
143     init_car_ele.changed = 0;
144
145     for (int i = stm::gStmCarElementNoMin; i <= stm::gStmCarElementNoMax; i++) {
146         const char* car_ele_name = stm::gStmCarElementName[i];
147         pm::g_crr_car_elements[car_ele_name] = init_car_ele;
148     }
149
150     pm::g_prv_car_elements = pm::g_crr_car_elements;
151 }
152
153 static void initializeLocalLayerState() {
154     pm::AreaState init_area;
155     pm::LayoutState init_layout;
156     init_area.name     = stm::gStmAreaName[stm::gStmAreaNoNone];
157     init_area.category = "";
158     init_area.role     = "";
159     init_layout.name   = stm::gStmLayoutName[stm::gStmLayoutNoNone];
160     init_layout.area_list.push_back(init_area);
161
162     for (int i = stm::gStmLayerNoMin; i <= stm::gStmLayerNoMax; i++) {
163         const char* layer_name = stm::gStmLayerName[i];
164         pm::g_crr_layers[layer_name].name         = layer_name;
165         pm::g_crr_layers[layer_name].layout_state = init_layout;
166         pm::g_crr_layers[layer_name].changed      = 0;
167     }
168
169     pm::g_prv_layers = pm::g_crr_layers;
170 }
171
172 void PolicyManager::initializeLocalState() {
173     initializeLocalCarElementState();
174     initializeLocalLayerState();
175 }
176
177 int PolicyManager::initializeSdEventLoop() {
178     // Get default event loop object
179     int ret = sd_event_new(&(pm::event_loop));
180     if (0 > ret) {
181         HMI_ERROR("wm:pm", "Faild to sd_event_default: errno:%d", ret);
182         return -1;
183     }
184
185     // Create thread for sd_event and detach
186     std::thread sd_event_loop([this]() {
187         while (1) {
188             sd_event_run(pm::event_loop, 1000);
189         }
190     });
191     sd_event_loop.detach();
192
193     return 0;
194 }
195
196 static void addStateToJson(
197   const char* name, int changed, std::string state, json_object** json_out) {
198     if ((nullptr == name) || (1 < changed) || (nullptr == json_out)) {
199         HMI_ERROR("wm:pm", "Invalid argument!!!");
200         return;
201     }
202
203     json_object_object_add(*json_out, "name", json_object_new_string(name));
204     json_object_object_add(*json_out, "state", json_object_new_string(state.c_str()));
205     json_object_object_add(*json_out, "changed", json_object_new_boolean(changed));
206 }
207
208 static void addStateToJson(const char* layer_name, unsigned int changed,
209                            pm::AreaList area_list, json_object** json_out) {
210     if ((nullptr == layer_name) || (1 < changed) || (nullptr == json_out)) {
211         HMI_ERROR("wm:pm", "Invalid argument!!!");
212         return;
213     }
214
215     json_object* json_areas = json_object_new_array();
216     json_object* json_tmp;
217     for (pm::AreaState as : area_list) {
218         json_tmp = json_object_new_object();
219         json_object_object_add(json_tmp, "name", json_object_new_string(as.name.c_str()));
220         json_object_object_add(json_tmp, "role", json_object_new_string(as.role.c_str()));
221         json_object_array_add(json_areas, json_tmp);
222     }
223
224     json_object_object_add(*json_out, "name", json_object_new_string(layer_name));
225     json_object_object_add(*json_out, "changed", json_object_new_boolean(changed));
226     json_object_object_add(*json_out, "areas", json_areas);
227 }
228
229 static void updateLocalCarElementState(stm::stm_state_t crr_state) {
230     int car_state_no;
231     std::string car_state;
232     bool changed;
233
234     // Store previous layers
235     pm::g_prv_car_elements = pm::g_crr_car_elements;
236
237     // Update car elements
238     HMI_DEBUG("wm:pm", ">>> CAR ELEMENT");
239     for (int car_ele_no = stm::gStmCarElementNoMin;
240          car_ele_no <= stm::gStmCarElementNoMax; car_ele_no++) {
241         const char* car_ele_name = stm::gStmCarElementName[car_ele_no];
242
243         car_state_no = crr_state.car_element[car_ele_no].state;
244         car_state = stm::gStmCarStateNameList[car_ele_no][car_state_no];
245         changed = crr_state.car_element[car_ele_no].changed;
246
247         pm::g_crr_car_elements[car_ele_name].state = car_state;
248         pm::g_crr_car_elements[car_ele_name].changed = changed;
249
250         HMI_DEBUG("wm:pm", ">>> >>> NAME: %s", car_ele_name);
251         HMI_DEBUG("wm:pm", ">>> >>> >>> STATE:%s", car_state.c_str());
252         HMI_DEBUG("wm:pm", ">>> >>> >>> CHANGED:%d", changed);
253     }
254 }
255
256 static void updateLocalLayerState(int event_data, stm::stm_state_t crr_state) {
257     int event_no, category_no, area_no;
258
259     event_no    = (event_data & STM_MSK_EVT_NO) - 1;
260     category_no = ((event_data & STM_MSK_CTG_NO) >> 8) - 1;
261     area_no     = ((event_data & STM_MSK_ARA_NO) >> 16) - 1;
262
263     std::string req_evt = std::string(stm::gStmEventName[event_no]);
264     std::string req_ctg = std::string(stm::gStmCategoryName[category_no]);
265     std::string req_area = std::string(stm::gStmAreaName[area_no]);
266     std::string req_role = pm::g_req_role_list[event_data];
267     HMI_DEBUG("wm:pm", "REQ: event:%s role:%s category:%s area:%s",
268         req_evt.c_str(), req_role.c_str(), req_ctg.c_str(), req_area.c_str());
269
270     // Store previous layers
271     pm::g_prv_layers = pm::g_crr_layers;
272
273     // Update layers
274     for (int layer_no = stm::gStmLayerNoMin;
275          layer_no <= stm::gStmLayerNoMax; layer_no++) {
276         const char* layer_name = stm::gStmLayerName[layer_no];
277         HMI_DEBUG("wm:pm", "LAYER:%s", layer_name);
278
279 #if 1
280         // If restriction mode is changed off -> on,
281         // store current state for state of restriction mode off
282         if ((crr_state.car_element[stm::gStmCarElementNoRestrictionMode].changed)
283             && (stm::gStmRestrictionModeStateNoOn == crr_state.car_element[stm::gStmCarElementNoRestrictionMode].state)) {
284             HMI_DEBUG("wm:lm", "Store current state for state of restriction mode off");
285             pm::g_prv_layers_car_stop[layer_name] = pm::g_crr_layers[layer_name];
286         }
287 #else
288         // If car state is changed car_stop -> car_run,
289         // store current state for state of car stop
290         if ((crr_state.car.changed)
291             && (stm::gStmRunningNoRun == crr_state.car.state)) {
292             HMI_DEBUG("wm:lm", "Store current state for state of car stop");
293             pm::g_prv_layers_car_stop[layer_name] = pm::g_crr_layers[layer_name];
294         }
295 #endif
296
297
298         // This layer is changed?
299         if (crr_state.layer[layer_no].changed) {
300             // Get previous layout name of this layer
301             pm::LayoutState prv_layout_state =  pm::g_prv_layers[layer_name].layout_state;
302             std::string prv_layout_name = prv_layout_state.name;
303
304             // Get current layout name of this layer
305             int crr_layout_state_no =  crr_state.layer[layer_no].state;
306             std::string crr_layout_name = std::string(stm::gStmLayoutName[crr_layout_state_no]);
307
308             pm::LayoutState crr_layout_state;
309 #if 1
310             if ((crr_state.car_element[stm::gStmCarElementNoRestrictionMode].changed)
311                 && (stm::gStmRestrictionModeStateNoOff == crr_state.car_element[stm::gStmCarElementNoRestrictionMode].state)) {
312                 // If restriction mode is changed on -> off,
313                 // restore state of restriction mode off
314                 HMI_DEBUG("wm:lm", "Restriction mode is changed on -> off, so restore state of restriction mode off");
315                 crr_layout_state = pm::g_prv_layers_car_stop[layer_name].layout_state;
316 #else
317             if ((crr_state.car_element[gStmCarElementNoRunning].changed)
318                 && (stm::gStmCarElementNoStop == crr_state.car_element[gStmCarElementNoRunning].state)) {
319                 // If car state is changed car_run -> car_stop,
320                 // restore state of car stop
321                 HMI_DEBUG("wm:lm", "Car state is changed car_run -> car_stop, so restore state of car stop");
322                 crr_layout_state = pm::g_prv_layers_car_stop[layer_name].layout_state;
323 #endif
324             }
325             else {
326                 // Copy previous layout state for current
327                 crr_layout_state = prv_layout_state;
328
329                 if (prv_layout_name == crr_layout_name) {
330                     HMI_DEBUG("wm:lm", "Previous layout is same with current");
331                 }
332                 else {
333                     // If previous layout is NOT same with current,
334                     // current areas is set with default value
335                     HMI_DEBUG("wm:lm", "Previous layout is NOT same with current");
336                     crr_layout_state.name         = pm::g_default_layouts[crr_layout_name].name;
337                     crr_layout_state.category_num = pm::g_default_layouts[crr_layout_name].category_num;
338                     crr_layout_state.area_list    = pm::g_default_layouts[crr_layout_name].area_list;
339                 }
340
341                 // Create candidate list
342                 std::map<std::string, pm::AreaList> cand_list;
343                 for (int ctg_no=stm::gStmCategoryNoMin;
344                      ctg_no<=stm::gStmCategoryNoMax; ctg_no++) {
345                     const char* ctg = stm::gStmCategoryName[ctg_no];
346                     HMI_DEBUG("wm:pm", "ctg:%s", ctg);
347
348                     // Create candidate list for category from the previous displayed categories
349                     pm::AreaList tmp_cand_list;
350                     for (pm::AreaState area_state : prv_layout_state.area_list) {
351                         if (std::string(ctg) == area_state.category) {
352                             // If there is the category which is same with new category in previous layout,
353                             // push it to list
354                             HMI_DEBUG("wm:pm", "Push to candidate list category:%s role:%s",
355                                       area_state.category.c_str(), area_state.role.c_str());
356                             tmp_cand_list.push_back(area_state);
357                         }
358                     }
359
360                     int candidate_num = prv_layout_state.category_num[ctg];
361                     int blank_num = crr_layout_state.category_num[ctg];
362                     HMI_DEBUG("wm:pm", "blank_num:%d candidate_num:%d", blank_num, candidate_num);
363
364                     // If requested event is "activate"
365                     // and there are requested category and area,
366                     // update area with requested role in current layout.
367                     bool request_for_this_layer = false;
368                     bool updated = false;
369                     if ((ctg == req_ctg) && ("activate" == req_evt) ) {
370                         HMI_DEBUG("wm:pm", "requested event is activate");
371                         for (pm::AreaState &as : crr_layout_state.area_list) {
372                             if (as.category == req_ctg) {
373                                 request_for_this_layer = true;
374
375                                 if (as.name == req_area) {
376                                     HMI_DEBUG("wm:pm", "Update current layout: area:%s category:%s role:%s",
377                                               as.name.c_str(), as.category.c_str(), as.role.c_str());
378                                     as.role = req_role;
379                                     blank_num--;
380                                     updated = true;
381                                     break;
382                                 }
383                             }
384                         }
385
386                         // If NOT updated: there is not requested area in new layout, 
387                         // so push requested role to candidate list
388                         if (request_for_this_layer && (!updated)) {
389                             HMI_DEBUG("wm:pm", "Push request to candidate list");
390                             pm::AreaState area_state;
391                             area_state.name = req_area;
392                             area_state.category = req_ctg;
393                             area_state.role = req_role;
394                             tmp_cand_list.push_back(area_state);
395                         }
396                     }
397
398                     // Compare number of candidate/blank,
399                     // And remove role in order of the oldest as necessary
400                     if (candidate_num < blank_num) {
401                         // Refer history stack
402                         // and add to the top of tmp_cand_list in order to the newest
403                         while (candidate_num != blank_num) {
404                             pm::AreaState area_state;
405                             area_state.name = "";
406                             area_state.category = ctg;
407                             if (0 != crr_layout_state.role_history[ctg].size()) {
408                                 HMI_ERROR("wm:pm", "Use role in history stack:%s",
409                                           crr_layout_state.role_history[ctg].back().c_str());
410                                 area_state.role = crr_layout_state.role_history[ctg].back();
411                                 crr_layout_state.role_history[ctg].pop_back();
412                             }
413                             else {
414                                 HMI_ERROR("wm:pm", "There is no role in history stack!!");
415                                 area_state.role = "";
416                             }
417                             tmp_cand_list.push_back(area_state);
418                             candidate_num++;
419                         }
420                     }
421                     else if (candidate_num > blank_num) {
422                         HMI_DEBUG("wm:pm", "candidate_num > blank_num");
423
424                         // Remove the oldest role from candidate list
425                         while (candidate_num != blank_num) {
426                             std::string removed_role = tmp_cand_list.begin()->role;
427                             HMI_DEBUG("wm:pm", "Remove the oldest data(role:%s) from tmp_cand_list",
428                                       removed_role.c_str());
429                             tmp_cand_list.erase(tmp_cand_list.begin());
430                             candidate_num--;
431
432                             // Push removed data to history stack
433                             crr_layout_state.role_history[ctg].push_back(removed_role);
434                         }
435                     }
436                     else {  // (candidate_num == blank_num)
437                         // nop
438                     }
439
440                     cand_list[ctg] = tmp_cand_list;
441                 }
442
443                 // Update areas
444                 for (pm::AreaState &as : crr_layout_state.area_list) {
445                     HMI_DEBUG("wm:pm", "Current area info area:%s category:%s",
446                               as.name.c_str(), as.category.c_str());
447                     if ("" == as.role) {
448                         HMI_DEBUG("wm:pm", "Update this area with role:%s",
449                                   cand_list[as.category].begin()->role.c_str());
450                         as.role = cand_list[as.category].begin()->role;
451                         cand_list[as.category].erase(cand_list[as.category].begin());
452                     }
453                 }
454             }
455             // Update current layout of this layer
456             pm::g_crr_layers[layer_name].layout_state = crr_layout_state;
457             pm::g_crr_layers[layer_name].changed = crr_state.layer[layer_no].changed;
458         }
459     }
460
461     // Erase role for the event_data from list
462     pm::g_req_role_list.erase(event_data);
463
464     // Check
465     for (auto itr : pm::g_crr_layers) {
466         pm::LayerState ls = itr.second;
467         HMI_DEBUG("wm:pm", ">>> LAYER:%s",ls.name.c_str());
468         HMI_DEBUG("wm:pm", ">>> >>> LAYOUT:%s", ls.layout_state.name.c_str());
469
470         for (pm::AreaState as : ls.layout_state.area_list) {
471             HMI_DEBUG("wm:pm", ">>> >>> >>> AREA:%s", as.name.c_str());
472             HMI_DEBUG("wm:pm", ">>> >>> >>> >>> CTG:%s", as.category.c_str());
473             HMI_DEBUG("wm:pm", ">>> >>> >>> >>> ROLE:%s", as.role.c_str());
474         }
475         HMI_DEBUG("wm:pm", ">>> >>> CHANGED:%d", ls.changed);
476     }
477 }
478
479 static void updateLocalState(int event_data, stm::stm_state_t crr_state) {
480     updateLocalCarElementState(crr_state);
481     updateLocalLayerState(event_data, crr_state);
482 }
483
484 static void createOutputInformation(stm::stm_state_t crr_state, json_object **json_out) {
485     json_object* json_tmp;
486
487     // Create car element information
488     // {
489     //     "car_elements": [
490     //     {
491     //         "parking_brake": {
492     //             "changed": <bool>,
493     //             "state": <const char*>
494     //         },
495     //         ...
496     //     },
497     json_object* json_car_ele = json_object_new_array();
498     const char* car_ele_name;
499     for (int car_ele_no = stm::gStmCarElementNoMin;
500          car_ele_no <= stm::gStmCarElementNoMax; car_ele_no++) {
501         car_ele_name = stm::gStmCarElementName[car_ele_no];
502         json_tmp = json_object_new_object();
503         addStateToJson(car_ele_name,
504                        pm::g_crr_car_elements[car_ele_name].changed,
505                        pm::g_crr_car_elements[car_ele_name].state,
506                        &json_tmp);
507         json_object_array_add(json_car_ele, json_tmp);
508     }
509     json_object_object_add(*json_out, "car_elements", json_car_ele);
510
511     // Create layout information
512     //
513     //     "layers": [
514     //     {
515     //         "homescreen": {
516     //             "changed": <bool>,
517     //             "areas": [
518     //             {
519     //                 "name":<const char*>,
520     //                 "role":<const char*>
521     //             }.
522     //             ...
523     //             ]
524     //         }
525     //     },
526     //     ...
527     json_object* json_layer = json_object_new_array();
528     const char* layer_name;
529     for (int layer_no = stm::gStmLayerNoMin;
530          layer_no <= stm::gStmLayerNoMax; layer_no++) {
531         layer_name = stm::gStmLayerName[layer_no];
532         json_tmp = json_object_new_object();
533         addStateToJson(layer_name,
534                        pm::g_crr_layers[layer_name].changed,
535                        pm::g_crr_layers[layer_name].layout_state.area_list,
536                        &json_tmp);
537         json_object_array_add(json_layer, json_tmp);
538     }
539     json_object_object_add(*json_out, "layers", json_layer);
540 }
541
542 static int checkPolicyEntry(int event, uint64_t delay_ms, std::string role);
543 static void controlTimerEvent(stm::stm_state_t crr_state) {
544     if (crr_state.car_element[stm::gStmCarElementNoRunning].changed) {
545         if (stm::gStmRunningNoRun == crr_state.car_element[stm::gStmCarElementNoRunning].state) {
546             // Set delay event(restriction mode on)
547             checkPolicyEntry(STM_EVT_NO_RESTRICTION_MODE_ON, 3000, "");
548         }
549         else if (stm::gStmRunningNoStop == crr_state.car_element[stm::gStmCarElementNoRunning].state) {
550             // Stop timer for restriction on event
551             if (pm::event_source_list.find(STM_EVT_NO_RESTRICTION_MODE_ON)
552               != pm::event_source_list.end()) {
553                 HMI_DEBUG("wm:pm", "Stop timer for restriction on");
554                 sd_event_source *event_source
555                     = pm::event_source_list[STM_EVT_NO_RESTRICTION_MODE_ON];
556                 int ret = sd_event_source_set_enabled(event_source, SD_EVENT_OFF);
557                 if (0 > ret) {
558                     HMI_ERROR("wm:pm", "Failed to stop timer");
559                 }
560             }
561
562             // Set event(restriction mode off)
563             checkPolicyEntry(STM_EVT_NO_RESTRICTION_MODE_OFF, 0, "");
564         }
565     }
566 }
567
568 static int checkPolicy(sd_event_source *source, void *data) {
569     HMI_DEBUG("wm:pm", "Call");
570     HMI_DEBUG("wm:pm", ">>>>>>>>>> START CHECK POLICY");
571
572     int event_data = *((int*)data);
573
574     int event_no, category_no, area_no;
575     event_no    = (event_data & STM_MSK_EVT_NO) - 1;
576     category_no = ((event_data & STM_MSK_CTG_NO) >> 8) - 1;
577     area_no     = ((event_data & STM_MSK_ARA_NO) >> 16) - 1;
578     HMI_DEBUG("wm:pm", ">>>>>>>>>> event:%s category:%s area:%s",
579               stm::gStmEventName[event_no],
580               stm::gStmCategoryName[category_no],
581               stm::gStmAreaName[area_no]);
582
583     // Transition state
584     stm::stm_state_t crr_state;
585     int ret = stm::stmTransitionState(event_data, &crr_state);
586     if (0 > ret) {
587         HMI_ERROR("wm:pm", "Failed transition state");
588         if (nullptr != pm::callback.onError) {
589             json_object* json_out = json_object_new_object();
590             json_object_object_add(json_out, "message",
591                                    json_object_new_string("Failed to transition state"));
592             json_object_object_add(json_out, "event",
593                                    json_object_new_string(stm::gStmEventName[event_no]));
594             json_object_object_add(json_out, "role",
595                                    json_object_new_string(pm::g_req_role_list[event_data].c_str()));
596             json_object_object_add(json_out, "area",
597                                    json_object_new_string(stm::gStmAreaName[area_no]));
598             pm::callback.onError(json_out);
599             json_object_put(json_out);
600         }
601         return -1;
602     }
603
604     // Update state which is managed by PolicyManager
605     updateLocalState(event_data, crr_state);
606
607     // Create output information for ResourceManager
608     json_object* json_out = json_object_new_object();
609     createOutputInformation(crr_state, &json_out);
610
611     // Notify changed state
612     if (nullptr != pm::callback.onStateTransitioned) {
613         pm::callback.onStateTransitioned(json_out);
614     }
615
616     // Start/Stop timer events
617     controlTimerEvent(crr_state);
618
619     // Release json_object
620     json_object_put(json_out);
621
622     // Release data
623     delete (int*)data;
624
625     // Destroy sd_event_source object
626     sd_event_source_unref(source);
627
628     // Remove event source from list
629     if (pm::event_source_list.find(event_data) != pm::event_source_list.end()) {
630         pm::event_source_list.erase(event_data);
631     }
632
633     HMI_DEBUG("wm:pm", ">>>>>>>>>> FINISH CHECK POLICY");
634     return 0;
635 }
636
637 static int timerEvent(sd_event_source *source, uint64_t usec, void *data) {
638     HMI_DEBUG("wm:pm", "Call");
639
640     int ret = checkPolicy(source, data);
641     return ret;
642 }
643
644 static int checkPolicyEntry(int event, uint64_t delay_ms, std::string role)
645 {
646     HMI_DEBUG("wm:pm", "Call");
647     HMI_DEBUG("wm:pm", "event:0x%x delay:%d role:%s", event, delay_ms, role.c_str());
648
649     // Store requested role
650     pm::g_req_role_list[event] = role;
651
652     if (0 == delay_ms) {
653         int ret = sd_event_add_defer(pm::event_loop, NULL,
654                                      &checkPolicy, new int(event));
655         if (0 > ret) {
656             HMI_ERROR("wm:pm", "Faild to sd_event_add_defer: errno:%d", ret);
657             pm::g_req_role_list.erase(event);
658             return -1;
659         }
660     }
661     else {
662         // Get current time
663         struct timespec time_spec;
664         clock_gettime(CLOCK_MONOTONIC, &time_spec);
665
666         // Calculate timer fired time
667         uint64_t usec = (time_spec.tv_sec * 1000000)
668             + (time_spec.tv_nsec / 1000)
669             + (delay_ms * 1000);
670
671         // Set timer
672         struct sd_event_source* event_source;
673         int ret = sd_event_add_time(pm::event_loop, &event_source, CLOCK_MONOTONIC, usec, 1,
674                                     &timerEvent, new int(event));
675         if (0 > ret) {
676             HMI_ERROR("wm:pm", "Faild to sd_event_add_time: errno:%d", ret);
677             pm::g_req_role_list.erase(event);
678             return -1;
679         }
680
681         // Store event source
682         pm::event_source_list[event] = event_source;
683     }
684
685     return 0;
686 }
687
688 void PolicyManager::registerCallback(CallbackTable callback) {
689     HMI_DEBUG("wm:pm", "Call");
690
691     pm::callback.onStateTransitioned = callback.onStateTransitioned;
692     pm::callback.onError             = callback.onError;
693 }
694
695 int PolicyManager::setInputEventData(json_object* json_in) {
696     HMI_DEBUG("wm:pm", "Call");
697
698     // Check arguments
699     if (nullptr == json_in) {
700         HMI_ERROR("wm:pm", "Argument is NULL!!");
701         return -1;
702     }
703
704     // Get event from json_object
705     const char* event = this->getStringFromJson(json_in, "event");
706     int event_no = 0;
707     if (nullptr != event) {
708         // Convert name to number
709         event_no = this->eventname2no[event];
710         HMI_DEBUG("wm:pm", "event(%s:%d)", event, event_no);
711     }
712
713     // Get role from json_object
714     const char* role = this->getStringFromJson(json_in, "role");
715     int category_no = 0;
716     if (nullptr != role) {
717         HMI_DEBUG("wm:pm", "role(%s)", role);
718
719         // Convert role to category
720         const char* category = this->role2category[role].c_str();
721         if (0 == strcmp("", category)) {
722             HMI_ERROR("wm:pm", "Error!!");
723             return -1;
724         }
725         HMI_DEBUG("wm:pm", "category(%s)", category);
726
727         // Convert name to number
728         category_no = categoryname2no[category];
729         HMI_DEBUG("wm:pm", "role(%s), category(%s:%d)", role, category, category_no);
730     }
731
732     // Get areat from json_object
733     const char* area = this->getStringFromJson(json_in, "area");
734     int area_no = 0;
735     if (nullptr != area) {
736         area_no = this->areaname2no[area];
737     }
738     else if (nullptr != role) {
739         area_no = this->areaname2no[this->role2defaultarea[role]];
740     }
741     HMI_DEBUG("wm:pm", "area(%s:%d)", area, area_no);
742
743     // Set event info to the queue
744     EventInfo event_info;
745     event_info.event = (event_no | category_no | area_no);
746     if (nullptr == role) {
747         event_info.role = std::string("");
748     }
749     else {
750         event_info.role = std::string(role);
751     }
752     event_info.delay = 0;
753     this->event_info_queue.push(event_info);
754
755     return 0;
756 }
757
758 int PolicyManager::executeStateTransition() {
759     HMI_DEBUG("wm:pm", "Call");
760
761     int ret;
762     EventInfo event_info;
763
764     while (!this->event_info_queue.empty()) {
765         // Get event info from queue and delete
766         event_info = this->event_info_queue.front();
767         this->event_info_queue.pop();
768
769         // Set event info for checking policy
770         ret = checkPolicyEntry(event_info.event, event_info.delay, event_info.role);
771     }
772     return ret;
773 }
774
775 void PolicyManager::undoState() {
776     HMI_DEBUG("wm:pm", "Call");
777
778     // Undo state of STM
779     stm::stmUndoState();
780
781     pm::g_crr_layers = pm::g_prv_layers;
782 }
783
784 extern const char* kDefaultRoleDb;
785 int PolicyManager::loadRoleDb() {
786     HMI_DEBUG("wm:pm", "Call");
787
788     std::string file_name;
789
790     // Get afm application installed dir
791     char const *afm_app_install_dir = getenv("AFM_APP_INSTALL_DIR");
792     HMI_DEBUG("wm:pm", "afm_app_install_dir:%s", afm_app_install_dir);
793
794     if (!afm_app_install_dir) {
795         HMI_ERROR("wm:pm", "AFM_APP_INSTALL_DIR is not defined");
796     }
797     else {
798         file_name = std::string(afm_app_install_dir) + std::string("/etc/role.db");
799     }
800
801     // Load role.db
802     json_object* json_obj;
803     int ret = this->inputJsonFilie(file_name.c_str(), &json_obj);
804     if (0 > ret) {
805         HMI_ERROR("wm:pm", "Could not open role.db, so use default role information");
806         json_obj = json_tokener_parse(kDefaultRoleDb);
807     }
808     HMI_DEBUG("wm:pm", "json_obj dump:%s", json_object_get_string(json_obj));
809
810     json_object* json_roles;
811     if (!json_object_object_get_ex(json_obj, "roles", &json_roles)) {
812         HMI_ERROR("wm:pm", "Parse Error!!");
813         return -1;
814     }
815
816     int len = json_object_array_length(json_roles);
817     HMI_DEBUG("wm:pm", "json_cfg len:%d", len);
818     HMI_DEBUG("wm:pm", "json_cfg dump:%s", json_object_get_string(json_roles));
819
820     json_object* json_tmp;
821     const char* category;
822     const char* roles;
823     const char* areas;
824     for (int i=0; i<len; i++) {
825         json_tmp = json_object_array_get_idx(json_roles, i);
826
827         category = this->getStringFromJson(json_tmp, "category");
828         roles =  this->getStringFromJson(json_tmp, "role");
829         areas =  this->getStringFromJson(json_tmp, "area");
830
831         if ((nullptr == category) || (nullptr == roles) || (nullptr == areas)) {
832             HMI_ERROR("wm:pm", "Parse Error!!");
833             return -1;
834         }
835
836         // Parse roles by '|'
837         std::vector<std::string> vct_roles;
838         vct_roles = this->parseString(std::string(roles), '|');
839
840         // Parse areas by '|'
841         std::vector<std::string> vct_areas;
842         vct_areas = this->parseString(std::string(areas), '|');
843
844         // Set role, category, default area
845         for (auto itr = vct_roles.begin(); itr != vct_roles.end(); ++itr) {
846             // Delete space from role and area name
847             std::string role = this->deleteSpace(*itr);
848             std::string area = this->deleteSpace(vct_areas[0]);
849
850             this->role2category[role] = std::string(category);
851             this->role2defaultarea[role] = area;
852         }
853
854         this->category2role[std::string(category)] = std::string(roles);
855     }
856
857     // Check
858     HMI_DEBUG("wm:pm", "Check role2category");
859     for (auto& x:this->role2category){
860         HMI_DEBUG("wm:pm", "key:%s, val:%s", x.first.c_str(), x.second.c_str());
861     }
862
863     HMI_DEBUG("wm:pm", "Check role2defaultarea");
864     for (auto& x:this->role2defaultarea){
865         HMI_DEBUG("wm:pm", "key:%s, val:%s", x.first.c_str(), x.second.c_str());
866     }
867
868     HMI_DEBUG("wm:pm", "Check category2role");
869     for (auto& x:this->category2role){
870         HMI_DEBUG("wm:pm", "key:%s, val:%s", x.first.c_str(), x.second.c_str());
871     }
872
873     return 0;
874 }
875
876 extern const char* kDefaultLayoutDb;
877 int PolicyManager::loadLayoutDb() {
878     HMI_DEBUG("wm:lm", "Call");
879
880     // Get afm application installed dir
881     char const *afm_app_install_dir = getenv("AFM_APP_INSTALL_DIR");
882     HMI_DEBUG("wm:pm", "afm_app_install_dir:%s", afm_app_install_dir);
883
884     std::string file_name;
885     if (!afm_app_install_dir) {
886         HMI_ERROR("wm:pm", "AFM_APP_INSTALL_DIR is not defined");
887     }
888     else {
889         file_name = std::string(afm_app_install_dir) + std::string("/etc/layout.db");
890     }
891
892     // Load layout.db
893     json_object* json_obj;
894     int ret = this->inputJsonFilie(file_name.c_str(), &json_obj);
895     if (0 > ret) {
896         HMI_DEBUG("wm:pm", "Could not open layout.db, so use default layout information");
897         json_obj = json_tokener_parse(kDefaultLayoutDb);
898     }
899     HMI_DEBUG("wm:pm", "json_obj dump:%s", json_object_get_string(json_obj));
900
901     // Perse layouts
902     HMI_DEBUG("wm:pm", "Perse layouts");
903     json_object* json_cfg;
904     if (!json_object_object_get_ex(json_obj, "layouts", &json_cfg)) {
905         HMI_ERROR("wm:pm", "Parse Error!!");
906         return -1;
907     }
908
909     int len = json_object_array_length(json_cfg);
910     HMI_DEBUG("wm:pm", "json_cfg len:%d", len);
911     HMI_DEBUG("wm:pm", "json_cfg dump:%s", json_object_get_string(json_cfg));
912
913     const char* layout;
914     const char* role;
915     const char* category;
916     for (int i=0; i<len; i++) {
917         json_object* json_tmp = json_object_array_get_idx(json_cfg, i);
918
919         layout = this->getStringFromJson(json_tmp, "name");
920         if (nullptr == layout) {
921             HMI_ERROR("wm:pm", "Parse Error!!");
922             return -1;
923         }
924         HMI_DEBUG("wm:pm", "> layout:%s", layout);
925
926         json_object* json_area_array;
927         if (!json_object_object_get_ex(json_tmp, "areas", &json_area_array)) {
928           HMI_ERROR("wm:pm", "Parse Error!!");
929           return -1;
930         }
931
932         int len_area = json_object_array_length(json_area_array);
933         HMI_DEBUG("wm:pm", "json_area_array len:%d", len_area);
934         HMI_DEBUG("wm:pm", "json_area_array dump:%s", json_object_get_string(json_area_array));
935
936         pm::LayoutState layout_state;
937         pm::AreaState area_state;
938         std::map<std::string, int> category_num;
939         for (int ctg_no = stm::gStmCategoryNoMin;
940              ctg_no <= stm::gStmCategoryNoMax; ctg_no++) {
941             const char* ctg_name = stm::gStmCategoryName[ctg_no];
942             category_num[ctg_name] = 0;
943         }
944
945         for (int j=0; j<len_area; j++) {
946             json_object* json_area = json_object_array_get_idx(json_area_array, j);
947
948             // Get area name
949             const char* area = this->getStringFromJson(json_area, "name");
950             if (nullptr == area) {
951               HMI_ERROR("wm:pm", "Parse Error!!");
952               return -1;
953             }
954             area_state.name = std::string(area);
955             HMI_DEBUG("wm:pm", ">> area:%s", area);
956
957             // Get app attribute of the area
958             category = this->getStringFromJson(json_area, "category");
959             if (nullptr == category) {
960                 HMI_ERROR("wm:pm", "Parse Error!!");
961                 return -1;
962             }
963             area_state.category = std::string(category);
964             category_num[category]++;
965             HMI_DEBUG("wm:pm", ">>> category:%s", category);
966
967             role = this->getStringFromJson(json_area, "role");
968             if (nullptr != role) {
969                 // Role is NOT essential here
970                 area_state.role = std::string(role);
971             }
972             else {
973                 area_state.role = std::string("");
974
975             }
976             HMI_DEBUG("wm:pm", ">>> role:%s", role);
977
978             layout_state.area_list.push_back(area_state);
979
980         }
981
982         layout_state.name = layout;
983         layout_state.category_num = category_num;
984         pm::g_default_layouts[layout] = layout_state;
985     }
986
987     // initialize for none layout
988     pm::LayoutState none_layout_state;
989     memset(&none_layout_state, 0, sizeof(none_layout_state));
990     none_layout_state.name                 = "none";
991     pm::g_default_layouts["none"] = none_layout_state;
992
993     // Check
994     for(auto itr_layout = pm::g_default_layouts.begin();
995       itr_layout != pm::g_default_layouts.end(); ++itr_layout) {
996         HMI_DEBUG("wm:pm", ">>> layout:%s", itr_layout->first.c_str());
997
998         for (auto itr_area = itr_layout->second.area_list.begin();
999           itr_area != itr_layout->second.area_list.end(); ++itr_area) {
1000             HMI_DEBUG("wm:pm", ">>> >>> area    :%s", itr_area->name.c_str());
1001             HMI_DEBUG("wm:pm", ">>> >>> category:%s", itr_area->category.c_str());
1002             HMI_DEBUG("wm:pm", ">>> >>> role    :%s", itr_area->role.c_str());
1003         }
1004     }
1005
1006     // Release json_object
1007     json_object_put(json_obj);
1008
1009     return 0;
1010 }
1011
1012 // TODO:
1013 // This function will be removed because json_helper has same function.
1014 // json_helper should be library.
1015 const char* PolicyManager::getStringFromJson(json_object* obj, const char* key) {
1016     if ((nullptr == obj) || (nullptr == key)) {
1017         HMI_ERROR("wm:pm", "Argument is nullptr!!!");
1018         return nullptr;
1019     }
1020
1021     json_object* tmp;
1022     if (!json_object_object_get_ex(obj, key, &tmp)) {
1023         HMI_DEBUG("wm:pm", "Not found key \"%s\"", key);
1024         return nullptr;
1025     }
1026
1027     return json_object_get_string(tmp);
1028 }
1029
1030 // TODO:
1031 // This function will be removed because json_helper has same function.
1032 // json_helper should be library.
1033 int PolicyManager::inputJsonFilie(const char* file, json_object** obj) {
1034     const int input_size = 128;
1035     int ret = -1;
1036
1037     if ((nullptr == file) || (nullptr == obj)) {
1038         HMI_ERROR("wm:jh", "Argument is nullptr!!!");
1039         return ret;
1040     }
1041
1042     HMI_DEBUG("wm:jh", "Input file: %s", file);
1043
1044     // Open json file
1045     FILE *fp = fopen(file, "rb");
1046     if (nullptr == fp) {
1047         HMI_ERROR("wm:jh", "Could not open file");
1048         return ret;
1049     }
1050
1051     // Parse file data
1052     struct json_tokener *tokener = json_tokener_new();
1053     enum json_tokener_error json_error;
1054     char buffer[input_size];
1055     int block_cnt = 1;
1056     while (1) {
1057         size_t len = fread(buffer, sizeof(char), input_size, fp);
1058         *obj = json_tokener_parse_ex(tokener, buffer, len);
1059         if (nullptr != *obj) {
1060             HMI_DEBUG("wm:jh", "File input is success");
1061             ret = 0;
1062             break;
1063         }
1064
1065         json_error = json_tokener_get_error(tokener);
1066         if ((json_tokener_continue != json_error)
1067             || (input_size > len)) {
1068             HMI_ERROR("wm:jh", "Failed to parse file (byte:%d err:%s)",
1069                       (input_size * block_cnt), json_tokener_error_desc(json_error));
1070             HMI_ERROR("wm:jh", "\n%s", buffer);
1071             *obj = nullptr;
1072             break;
1073         }
1074         block_cnt++;
1075     }
1076
1077     // Close json file
1078     fclose(fp);
1079
1080     // Free json_tokener
1081     json_tokener_free(tokener);
1082
1083     return ret;
1084 }
1085
1086 std::vector<std::string> PolicyManager::parseString(std::string str, char delimiter) {
1087     // Parse string by delimiter
1088     std::vector<std::string> vct;
1089     std::stringstream ss{str};
1090     std::string buf;
1091     while (std::getline(ss, buf, delimiter)) {
1092       if (!buf.empty()) {
1093         vct.push_back(buf);
1094       }
1095     }
1096     return vct;
1097 }
1098
1099 std::string PolicyManager::deleteSpace(std::string str) {
1100     std::string ret = str;
1101     size_t pos;
1102     while ((pos = ret.find_first_of(" ")) != std::string::npos) {
1103       ret.erase(pos, 1);
1104     }
1105     return ret;
1106 }
1107
1108 const char* kDefaultRoleDb = "{ \
1109     \"roles\":[ \
1110     { \
1111         \"category\": \"homescreen\", \
1112         \"role\": \"homescreen\", \
1113         \"area\": \"full\", \
1114     }, \
1115     { \
1116         \"category\": \"map\", \
1117         \"role\": \"map\", \
1118         \"area\": \"full | normal | split.main\", \
1119     }, \
1120     { \
1121         \"category\": \"general\", \
1122         \"role\": \"poi | music | video | browser | sdl | settings | mixer | radio | hvac | dashboard | debug\", \
1123         \"area\": \"normal\", \
1124     }, \
1125     { \
1126         \"category\": \"phone\", \
1127         \"role\": \"phone\", \
1128         \"area\": \"normal\", \
1129     }, \
1130     { \
1131         \"category\": \"splitable\", \
1132         \"role\": \"splitable1 | splitable2\", \
1133         \"area\": \"normal | split.main | split.sub\", \
1134     }, \
1135     { \
1136         \"category\": \"popup\", \
1137         \"role\": \"popup\", \
1138         \"area\": \"on_screen\", \
1139     }, \
1140     { \
1141         \"category\": \"system_alert\", \
1142         \"role\": \"system_alert\", \
1143         \"area\": \"on_screen\", \
1144     }, \
1145     { \
1146         \"category\": \"tbt\", \
1147         \"role\": \"tbt\", \
1148         \"area\": \"hud\", \
1149     } \
1150     ] \
1151 }";
1152
1153
1154 const char* kDefaultLayoutDb = "{ \
1155     \"layouts\": [ \
1156         { \
1157             \"name\": \"pu\", \
1158             \"layer\": \"on_screen\", \
1159             \"areas\": [ \
1160                 { \
1161                     \"name\": \"pop_up\", \
1162                     \"role\": \"incomming_call\" \
1163                 } \
1164             ] \
1165         }, \
1166         { \
1167             \"name\": \"sa\", \
1168             \"layer\": \"on_screen\", \
1169             \"areas\": [ \
1170                 { \
1171                     \"name\": \"system_alert\", \
1172                     \"role\": \"system_alert\" \
1173                 } \
1174             ] \
1175         }, \
1176         { \
1177             \"name\": \"m1\", \
1178             \"layer\": \"apps\", \
1179             \"areas\": [ \
1180                 { \
1181                     \"name\": \"normal\", \
1182                     \"role\": \"map\" \
1183                 } \
1184             ] \
1185         }, \
1186         { \
1187             \"name\": \"m2\", \
1188             \"layer\": \"apps\", \
1189             \"areas\": [ \
1190                 { \
1191                     \"name\": \"split.main\", \
1192                     \"role\": \"map\" \
1193                 }, \
1194                 { \
1195                     \"name\": \"split.sub\", \
1196                     \"category\": \"hvac\" \
1197                 } \
1198             ] \
1199         }, \
1200         { \
1201             \"name\": \"mf\", \
1202             \"layer\": \"apps\", \
1203             \"areas\": [ \
1204                 { \
1205                     \"name\": \"full\", \
1206                     \"role\": \"map\" \
1207                 } \
1208             ] \
1209         }, \
1210         { \
1211             \"name\": \"s1\", \
1212             \"layer\": \"apps\", \
1213             \"areas\": [ \
1214                 { \
1215                     \"name\": \"normal\", \
1216                     \"category\": \"splitable\" \
1217                 } \
1218             ] \
1219         }, \
1220         { \
1221             \"name\": \"s2\", \
1222             \"layer\": \"apps\", \
1223             \"areas\": [ \
1224                 { \
1225                     \"name\": \"split.main\", \
1226                     \"category\": \"splitable\" \
1227                 }, \
1228                 { \
1229                     \"name\": \"split.sub\", \
1230                     \"category\": \"splitable\" \
1231                 } \
1232             ] \
1233         }, \
1234         { \
1235             \"name\": \"g\", \
1236             \"layer\": \"apps\", \
1237             \"areas\": [ \
1238                 { \
1239                     \"name\": \"normal\", \
1240                     \"category\": \"general\" \
1241                 } \
1242             ] \
1243         }, \
1244         { \
1245             \"name\": \"hs\", \
1246             \"layer\": \"homescreen\", \
1247             \"areas\": [ \
1248                 { \
1249                     \"name\": \"full\", \
1250                     \"role\": \"homescreen\" \
1251                 } \
1252             ] \
1253         } \
1254     ], \
1255     \"areas\": [ \
1256         { \
1257             \"name\": \"normal\", \
1258             \"rect\": { \
1259                 \"x\": 0, \
1260                 \"y\": 218, \
1261                 \"w\": 1080, \
1262                 \"h\": 1488 \
1263             } \
1264         }, \
1265         { \
1266             \"name\": \"split.main\", \
1267             \"rect\": { \
1268                 \"x\": 0, \
1269                 \"y\": 218, \
1270                 \"w\": 1080, \
1271                 \"h\": 744 \
1272             } \
1273         }, \
1274         { \
1275             \"name\": \"split.sub\", \
1276             \"rect\": { \
1277                 \"x\": 0, \
1278                 \"y\": 962, \
1279                 \"w\": 1080, \
1280                 \"h\": 744 \
1281             } \
1282         }, \
1283         { \
1284             \"name\": \"full\", \
1285             \"rect\": { \
1286                 \"x\": 0, \
1287                 \"y\": 0, \
1288                 \"w\": 1080, \
1289                 \"h\": 1920 \
1290             } \
1291         }, \
1292         { \
1293             \"name\": \"pop_up\", \
1294             \"rect\": { \
1295                 \"x\": 0, \
1296                 \"y\": 640, \
1297                 \"w\": 1080, \
1298                 \"h\": 640 \
1299             } \
1300         }, \
1301         { \
1302             \"name\": \"system_alert\", \
1303             \"rect\": { \
1304                 \"x\": 0, \
1305                 \"y\": 640, \
1306                 \"w\": 1080, \
1307                 \"h\": 640 \
1308             } \
1309         } \
1310     ] \
1311 }";