1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
|
/*
* Copyright (c) 2019 TOYOTA MOTOR CORPORATION
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "hs-proxy.h"
const char _afm_main[] = "afm-main";
const char _windowmanager[] = "windowmanager";
const char _event[] = "event";
const char _vshl_capabilities[] = "vshl-capabilities";
const char _actions[] = "actions";
/**
* the callback function
*
* #### Parameters
* - closure : the user defined closure pointer 'closure'
* - object : a JSON object returned (can be NULL)
* - error : a string not NULL in case of error but NULL on success
* - info : a string handling some info (can be NULL)
* - api : the api
*
* #### Return
* None
*
*/
static void api_callback(void *closure, struct json_object *object, const char *error, const char *info, afb_api_t api)
{
AFB_INFO("asynchronous call, error=%s, info=%s, object=%s.", error, info, json_object_get_string(object));
if(closure != nullptr) {
reinterpret_cast<api_cb_func>(closure)(object, error, info);
}
}
/**
* call api asynchronous
*
* #### Parameters
* - api : the api serving the request
* - service : the api name of service
* - verb : the verb of service
* - args : parameter
*
* #### Return
* None
*
*/
static void api_call(afb_api_t api, const char *service, const char *verb, struct json_object *args, api_cb_func f = nullptr)
{
AFB_INFO("service=%s verb=%s, args=%s.", service, verb, json_object_get_string(args));
afb_api_call(api, service, verb, args, api_callback, (void*)f);
}
/**
* call api synchronous
*
* #### Parameters
* - api : the api serving the request
* - service : the api name of service
* - verb : the verb of afm-main
* - args : parameter
* - object : return the details of application
*
* #### Return
* 0 : success
* 1 : fail
*
*/
static int api_call_sync(afb_api_t api, const char *service, const char *verb, struct json_object *args, struct json_object **object)
{
char *error = nullptr, *info = nullptr;
int ret = afb_api_call_sync(api, service, verb, args, object, &error, &info);
AFB_INFO("synchronous call, error=%s, info=%s.", error, info);
return ret;
}
/* -------------------------------------HS_AfmMainProxy------------------------------------------ */
/**
* get runnables application list
*
* #### Parameters
* - api : the api serving the request
* - object : return the details of appid
*
* #### Return
* 0 : success
* 1 : fail
*
*/
int HS_AfmMainProxy::runnables(afb_api_t api, struct json_object **object)
{
return api_call_sync(api, _afm_main, __FUNCTION__, nullptr, object);
}
/**
* get details of application
*
* #### Parameters
* - api : the api serving the request
* - id : the id to get details,liked "dashboard@0.1"
* - object : return the details of application
*
* #### Return
* 0 : success
* 1 : fail
*
*/
int HS_AfmMainProxy::detail(afb_api_t api, const std::string &id, struct json_object **object)
{
struct json_object *args = json_object_new_string(id.c_str());
return api_call_sync(api, _afm_main, __FUNCTION__, args, object);
}
/**
* start application
*
* #### Parameters
* - api : the api
* - id : the application id liked "dashboard@0.1"
*
* #### Return
* None
*
*/
void HS_AfmMainProxy::start(afb_api_t api, const std::string &id)
{
struct json_object *args = json_object_new_string(id.c_str());
api_call(api, _afm_main, __FUNCTION__, args);
}
/* -------------------------------------HS_WmProxy------------------------------------------ */
/**
* subscribe windowmanager event
*
* #### Parameters
* - api : the api serving the request
* - event : windowmanager event
* - f : callback function
*
* #### Return
* None
*
*/
void HS_WmProxy::subscribe(afb_api_t api, EventType event, api_cb_func f)
{
struct json_object* push_obj = json_object_new_object();
json_object_object_add(push_obj, _event, json_object_new_int(event));
api_call(api, _windowmanager, "wm_subscribe", push_obj, f);
}
/* -------------------------------------HS_VshlCapabilitiesProxy------------------------------------------ */
/**
* subscribe event
*
* #### Parameters
* - api : the api
* - module : module name
* - ev_list : event list
*
* #### Return
* None
*
*/
void HS_VshlCapabilitiesProxy::subscribe(afb_api_t api, const std::string &module, const std::list<std::string> &ev_list)
{
if(ev_list.empty()) {
return;
}
struct json_object *arr_obj = json_object_new_array();
for(auto &it : ev_list) {
json_object_array_add(arr_obj, json_object_new_string(it.c_str()));
}
struct json_object *args = json_object_new_object();
json_object_object_add(args, _actions, arr_obj);
std::string verb = module + '/' + __FUNCTION__;
api_call(api, _vshl_capabilities, verb.c_str(), args);
}
|
