dbus_new_handlers_p2p.c 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149
  1. /*
  2. * WPA Supplicant / dbus-based control interface (P2P)
  3. *
  4. * This program is free software; you can redistribute it and/or modify
  5. * it under the terms of the GNU General Public License version 2 as
  6. * published by the Free Software Foundation.
  7. *
  8. * Alternatively, this software may be distributed under the terms of BSD
  9. * license.
  10. *
  11. * See README and COPYING for more details.
  12. */
  13. #include "includes.h"
  14. #include "utils/includes.h"
  15. #include "common.h"
  16. #include "../config.h"
  17. #include "../wpa_supplicant_i.h"
  18. #include "../wps_supplicant.h"
  19. #include "../notify.h"
  20. #include "dbus_new_helpers.h"
  21. #include "dbus_new.h"
  22. #include "dbus_new_handlers.h"
  23. #include "dbus_new_handlers_p2p.h"
  24. #include "dbus_dict_helpers.h"
  25. #include "p2p/p2p.h"
  26. #include "common/ieee802_11_defs.h"
  27. #include "ap/hostapd.h"
  28. #include "ap/ap_config.h"
  29. #include "ap/wps_hostapd.h"
  30. #include "../p2p_supplicant.h"
  31. /**
  32. * Parses out the mac address from the peer object path.
  33. * @peer_path - object path of the form
  34. * /fi/w1/wpa_supplicant1/Interfaces/n/Peers/00112233445566 (no colons)
  35. * @addr - out param must be of ETH_ALEN size
  36. * Returns 0 if valid (including MAC), -1 otherwise
  37. */
  38. static int parse_peer_object_path(char *peer_path, u8 addr[ETH_ALEN])
  39. {
  40. char *p;
  41. if (!peer_path)
  42. return -1;
  43. p = strrchr(peer_path, '/');
  44. if (!p)
  45. return -1;
  46. p++;
  47. return hwaddr_compact_aton(p, addr);
  48. }
  49. /**
  50. * wpas_dbus_error_persistent_group_unknown - Return a new PersistentGroupUnknown
  51. * error message
  52. * @message: Pointer to incoming dbus message this error refers to
  53. * Returns: a dbus error message
  54. *
  55. * Convenience function to create and return an invalid persistent group error.
  56. */
  57. static DBusMessage * wpas_dbus_error_persistent_group_unknown(
  58. DBusMessage *message)
  59. {
  60. return dbus_message_new_error(message, WPAS_DBUS_ERROR_NETWORK_UNKNOWN,
  61. "There is no such persistent group in "
  62. "this P2P device.");
  63. }
  64. DBusMessage * wpas_dbus_handler_p2p_find(DBusMessage *message,
  65. struct wpa_supplicant *wpa_s)
  66. {
  67. struct wpa_dbus_dict_entry entry;
  68. DBusMessage *reply = NULL;
  69. DBusMessageIter iter;
  70. DBusMessageIter iter_dict;
  71. unsigned int timeout = 0;
  72. enum p2p_discovery_type type = P2P_FIND_ONLY_SOCIAL;
  73. int num_req_dev_types = 0;
  74. unsigned int i;
  75. u8 *req_dev_types = NULL;
  76. dbus_message_iter_init(message, &iter);
  77. entry.key = NULL;
  78. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  79. goto error;
  80. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  81. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  82. goto error;
  83. if (!os_strcmp(entry.key, "Timeout") &&
  84. (entry.type == DBUS_TYPE_INT32)) {
  85. timeout = entry.uint32_value;
  86. } else if (os_strcmp(entry.key, "RequestedDeviceTypes") == 0) {
  87. if ((entry.type != DBUS_TYPE_ARRAY) ||
  88. (entry.array_type != WPAS_DBUS_TYPE_BINARRAY))
  89. goto error_clear;
  90. req_dev_types =
  91. os_malloc(WPS_DEV_TYPE_LEN * entry.array_len);
  92. if (!req_dev_types)
  93. goto error_clear;
  94. for (i = 0; i < entry.array_len; i++) {
  95. if (wpabuf_len(entry.binarray_value[i]) !=
  96. WPS_DEV_TYPE_LEN)
  97. goto error_clear;
  98. os_memcpy(req_dev_types + i * WPS_DEV_TYPE_LEN,
  99. wpabuf_head(entry.binarray_value[i]),
  100. WPS_DEV_TYPE_LEN);
  101. }
  102. num_req_dev_types = entry.array_len;
  103. } else
  104. goto error_clear;
  105. wpa_dbus_dict_entry_clear(&entry);
  106. }
  107. wpas_p2p_find(wpa_s, timeout, type, num_req_dev_types, req_dev_types);
  108. os_free(req_dev_types);
  109. return reply;
  110. error_clear:
  111. wpa_dbus_dict_entry_clear(&entry);
  112. error:
  113. os_free(req_dev_types);
  114. reply = wpas_dbus_error_invalid_args(message, entry.key);
  115. return reply;
  116. }
  117. DBusMessage * wpas_dbus_handler_p2p_stop_find(DBusMessage *message,
  118. struct wpa_supplicant *wpa_s)
  119. {
  120. wpas_p2p_stop_find(wpa_s);
  121. return NULL;
  122. }
  123. DBusMessage * wpas_dbus_handler_p2p_rejectpeer(DBusMessage *message,
  124. struct wpa_supplicant *wpa_s)
  125. {
  126. DBusMessageIter iter;
  127. char *peer_object_path = NULL;
  128. u8 peer_addr[ETH_ALEN];
  129. dbus_message_iter_init(message, &iter);
  130. dbus_message_iter_get_basic(&iter, &peer_object_path);
  131. if (parse_peer_object_path(peer_object_path, peer_addr) < 0)
  132. return wpas_dbus_error_invalid_args(message, NULL);
  133. if (wpas_p2p_reject(wpa_s, peer_addr) < 0)
  134. return wpas_dbus_error_unknown_error(message,
  135. "Failed to call wpas_p2p_reject method.");
  136. return NULL;
  137. }
  138. DBusMessage * wpas_dbus_handler_p2p_listen(DBusMessage *message,
  139. struct wpa_supplicant *wpa_s)
  140. {
  141. dbus_int32_t timeout = 0;
  142. if (!dbus_message_get_args(message, NULL, DBUS_TYPE_INT32, &timeout,
  143. DBUS_TYPE_INVALID))
  144. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  145. NULL);
  146. if (wpas_p2p_listen(wpa_s, (unsigned int)timeout))
  147. return dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  148. NULL);
  149. return NULL;
  150. }
  151. DBusMessage * wpas_dbus_handler_p2p_extendedlisten(
  152. DBusMessage *message, struct wpa_supplicant *wpa_s)
  153. {
  154. unsigned int period = 0, interval = 0;
  155. struct wpa_dbus_dict_entry entry;
  156. DBusMessageIter iter;
  157. DBusMessageIter iter_dict;
  158. dbus_message_iter_init(message, &iter);
  159. entry.key = NULL;
  160. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  161. goto error;
  162. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  163. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  164. goto error;
  165. if (!os_strcmp(entry.key, "period") &&
  166. (entry.type == DBUS_TYPE_INT32))
  167. period = entry.uint32_value;
  168. else if (!os_strcmp(entry.key, "interval") &&
  169. (entry.type == DBUS_TYPE_INT32))
  170. interval = entry.uint32_value;
  171. else
  172. goto error_clear;
  173. wpa_dbus_dict_entry_clear(&entry);
  174. }
  175. if (wpas_p2p_ext_listen(wpa_s, period, interval))
  176. return wpas_dbus_error_unknown_error(
  177. message, "failed to initiate a p2p_ext_listen.");
  178. return NULL;
  179. error_clear:
  180. wpa_dbus_dict_entry_clear(&entry);
  181. error:
  182. return wpas_dbus_error_invalid_args(message, entry.key);
  183. }
  184. DBusMessage * wpas_dbus_handler_p2p_presence_request(
  185. DBusMessage *message, struct wpa_supplicant *wpa_s)
  186. {
  187. unsigned int dur1 = 0, int1 = 0, dur2 = 0, int2 = 0;
  188. struct wpa_dbus_dict_entry entry;
  189. DBusMessageIter iter;
  190. DBusMessageIter iter_dict;
  191. dbus_message_iter_init(message, &iter);
  192. entry.key = NULL;
  193. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  194. goto error;
  195. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  196. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  197. goto error;
  198. if (!os_strcmp(entry.key, "duration1") &&
  199. (entry.type == DBUS_TYPE_INT32))
  200. dur1 = entry.uint32_value;
  201. else if (!os_strcmp(entry.key, "interval1") &&
  202. entry.type == DBUS_TYPE_INT32)
  203. int1 = entry.uint32_value;
  204. else if (!os_strcmp(entry.key, "duration2") &&
  205. entry.type == DBUS_TYPE_INT32)
  206. dur2 = entry.uint32_value;
  207. else if (!os_strcmp(entry.key, "interval2") &&
  208. entry.type == DBUS_TYPE_INT32)
  209. int2 = entry.uint32_value;
  210. else
  211. goto error_clear;
  212. wpa_dbus_dict_entry_clear(&entry);
  213. }
  214. if (wpas_p2p_presence_req(wpa_s, dur1, int1, dur2, int2) < 0)
  215. return wpas_dbus_error_unknown_error(message,
  216. "Failed to invoke presence request.");
  217. return NULL;
  218. error_clear:
  219. wpa_dbus_dict_entry_clear(&entry);
  220. error:
  221. return wpas_dbus_error_invalid_args(message, entry.key);
  222. }
  223. DBusMessage * wpas_dbus_handler_p2p_group_add(DBusMessage *message,
  224. struct wpa_supplicant *wpa_s)
  225. {
  226. DBusMessageIter iter_dict;
  227. DBusMessage *reply = NULL;
  228. DBusMessageIter iter;
  229. struct wpa_dbus_dict_entry entry;
  230. char *pg_object_path = NULL;
  231. int persistent_group = 0;
  232. int freq = 0;
  233. char *iface = NULL;
  234. char *net_id_str = NULL;
  235. unsigned int group_id = 0;
  236. struct wpa_ssid *ssid;
  237. dbus_message_iter_init(message, &iter);
  238. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  239. goto inv_args;
  240. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  241. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  242. goto inv_args;
  243. if (!os_strcmp(entry.key, "persistent") &&
  244. (entry.type == DBUS_TYPE_BOOLEAN)) {
  245. persistent_group = (entry.bool_value == TRUE) ? 1 : 0;
  246. } else if (!os_strcmp(entry.key, "frequency") &&
  247. (entry.type == DBUS_TYPE_INT32)) {
  248. freq = entry.int32_value;
  249. if (freq <= 0)
  250. goto inv_args_clear;
  251. } else if (!os_strcmp(entry.key, "persistent_group_object") &&
  252. entry.type == DBUS_TYPE_OBJECT_PATH)
  253. pg_object_path = os_strdup(entry.str_value);
  254. else
  255. goto inv_args_clear;
  256. wpa_dbus_dict_entry_clear(&entry);
  257. }
  258. if (pg_object_path != NULL) {
  259. /*
  260. * A persistent group Object Path is defined meaning we want
  261. * to re-invoke a persistent group.
  262. */
  263. iface = wpas_dbus_new_decompose_object_path(pg_object_path, 1,
  264. &net_id_str, NULL);
  265. if (iface == NULL ||
  266. os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  267. reply =
  268. wpas_dbus_error_invalid_args(message,
  269. pg_object_path);
  270. goto out;
  271. }
  272. group_id = strtoul(net_id_str, NULL, 10);
  273. if (errno == EINVAL) {
  274. reply = wpas_dbus_error_invalid_args(
  275. message, pg_object_path);
  276. goto out;
  277. }
  278. /* Get the SSID structure form the persistant group id */
  279. ssid = wpa_config_get_network(wpa_s->conf, group_id);
  280. if (ssid == NULL || ssid->disabled != 2)
  281. goto inv_args;
  282. if (wpas_p2p_group_add_persistent(wpa_s, ssid, 0, freq)) {
  283. reply = wpas_dbus_error_unknown_error(
  284. message,
  285. "Failed to reinvoke a persistent group");
  286. goto out;
  287. }
  288. } else if (wpas_p2p_group_add(wpa_s, persistent_group, freq))
  289. goto inv_args;
  290. out:
  291. os_free(pg_object_path);
  292. os_free(net_id_str);
  293. os_free(iface);
  294. return reply;
  295. inv_args_clear:
  296. wpa_dbus_dict_entry_clear(&entry);
  297. inv_args:
  298. reply = wpas_dbus_error_invalid_args(message, NULL);
  299. goto out;
  300. }
  301. DBusMessage * wpas_dbus_handler_p2p_disconnect(DBusMessage *message,
  302. struct wpa_supplicant *wpa_s)
  303. {
  304. if (wpas_p2p_disconnect(wpa_s))
  305. return wpas_dbus_error_unknown_error(message,
  306. "failed to disconnect");
  307. return NULL;
  308. }
  309. static dbus_bool_t wpa_dbus_p2p_check_enabled(struct wpa_supplicant *wpa_s,
  310. DBusMessage *message,
  311. DBusMessage **out_reply,
  312. DBusError *error)
  313. {
  314. /* Return an error message or an error if P2P isn't available */
  315. if (wpa_s->global->p2p_disabled || wpa_s->global->p2p == NULL) {
  316. if (out_reply) {
  317. *out_reply = dbus_message_new_error(
  318. message, DBUS_ERROR_FAILED,
  319. "P2P is not available for this interface");
  320. }
  321. dbus_set_error_const(error, DBUS_ERROR_FAILED,
  322. "P2P is not available for this "
  323. "interface");
  324. return FALSE;
  325. }
  326. return TRUE;
  327. }
  328. DBusMessage * wpas_dbus_handler_p2p_flush(DBusMessage *message,
  329. struct wpa_supplicant *wpa_s)
  330. {
  331. DBusMessage *reply = NULL;
  332. if (!wpa_dbus_p2p_check_enabled(wpa_s, message, &reply, NULL))
  333. return reply;
  334. os_memset(wpa_s->p2p_auth_invite, 0, ETH_ALEN);
  335. wpa_s->force_long_sd = 0;
  336. p2p_flush(wpa_s->global->p2p);
  337. return NULL;
  338. }
  339. DBusMessage * wpas_dbus_handler_p2p_connect(DBusMessage *message,
  340. struct wpa_supplicant *wpa_s)
  341. {
  342. DBusMessageIter iter_dict;
  343. DBusMessage *reply = NULL;
  344. DBusMessageIter iter;
  345. struct wpa_dbus_dict_entry entry;
  346. char *peer_object_path = NULL;
  347. int persistent_group = 0;
  348. int join = 0;
  349. int authorize_only = 0;
  350. int go_intent = -1;
  351. int freq = 0;
  352. u8 addr[ETH_ALEN];
  353. char *pin = NULL;
  354. enum p2p_wps_method wps_method = WPS_NOT_READY;
  355. int new_pin;
  356. char *err_msg = NULL;
  357. char *iface = NULL;
  358. if (!wpa_dbus_p2p_check_enabled(wpa_s, message, &reply, NULL))
  359. return reply;
  360. dbus_message_iter_init(message, &iter);
  361. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  362. goto inv_args;
  363. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  364. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  365. goto inv_args;
  366. if (!os_strcmp(entry.key, "peer") &&
  367. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  368. peer_object_path = os_strdup(entry.str_value);
  369. } else if (!os_strcmp(entry.key, "persistent") &&
  370. (entry.type == DBUS_TYPE_BOOLEAN)) {
  371. persistent_group = (entry.bool_value == TRUE) ? 1 : 0;
  372. } else if (!os_strcmp(entry.key, "join") &&
  373. (entry.type == DBUS_TYPE_BOOLEAN)) {
  374. join = (entry.bool_value == TRUE) ? 1 : 0;
  375. } else if (!os_strcmp(entry.key, "authorize_only") &&
  376. (entry.type == DBUS_TYPE_BOOLEAN)) {
  377. authorize_only = (entry.bool_value == TRUE) ? 1 : 0;
  378. } else if (!os_strcmp(entry.key, "frequency") &&
  379. (entry.type == DBUS_TYPE_INT32)) {
  380. freq = entry.int32_value;
  381. if (freq <= 0)
  382. goto inv_args_clear;
  383. } else if (!os_strcmp(entry.key, "go_intent") &&
  384. (entry.type == DBUS_TYPE_INT32)) {
  385. go_intent = entry.int32_value;
  386. if ((go_intent < 0) || (go_intent > 15))
  387. goto inv_args_clear;
  388. } else if (!os_strcmp(entry.key, "wps_method") &&
  389. (entry.type == DBUS_TYPE_STRING)) {
  390. if (!os_strcmp(entry.str_value, "pbc"))
  391. wps_method = WPS_PBC;
  392. else if (!os_strcmp(entry.str_value, "pin"))
  393. wps_method = WPS_PIN_DISPLAY;
  394. else if (!os_strcmp(entry.str_value, "label"))
  395. wps_method = WPS_PIN_LABEL;
  396. else if (!os_strcmp(entry.str_value, "display"))
  397. wps_method = WPS_PIN_DISPLAY;
  398. else if (!os_strcmp(entry.str_value, "keypad"))
  399. wps_method = WPS_PIN_KEYPAD;
  400. else
  401. goto inv_args_clear;
  402. } else if (!os_strcmp(entry.key, "pin") &&
  403. (entry.type == DBUS_TYPE_STRING)) {
  404. pin = os_strdup(entry.str_value);
  405. } else
  406. goto inv_args_clear;
  407. wpa_dbus_dict_entry_clear(&entry);
  408. }
  409. if (!peer_object_path || (wps_method == WPS_NOT_READY) ||
  410. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  411. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  412. goto inv_args;
  413. /*
  414. * Validate the wps_method specified and the pin value.
  415. */
  416. if ((!pin || !pin[0]) &&
  417. ((wps_method == WPS_PIN_LABEL) || (wps_method == WPS_PIN_KEYPAD)))
  418. goto inv_args;
  419. new_pin = wpas_p2p_connect(wpa_s, addr, pin, wps_method,
  420. persistent_group, join, authorize_only,
  421. go_intent, freq);
  422. if (new_pin >= 0) {
  423. reply = dbus_message_new_method_return(message);
  424. dbus_message_append_args(reply, DBUS_TYPE_INT32,
  425. &new_pin, DBUS_TYPE_INVALID);
  426. } else {
  427. switch (new_pin) {
  428. case -2:
  429. err_msg = "connect failed due to channel "
  430. "unavailability.";
  431. iface = WPAS_DBUS_ERROR_CONNECT_CHANNEL_UNAVAILABLE;
  432. break;
  433. case -3:
  434. err_msg = "connect failed due to unsupported channel.";
  435. iface = WPAS_DBUS_ERROR_CONNECT_CHANNEL_UNSUPPORTED;
  436. break;
  437. default:
  438. err_msg = "connect failed due to unspecified error.";
  439. iface = WPAS_DBUS_ERROR_CONNECT_UNSPECIFIED_ERROR;
  440. break;
  441. }
  442. /*
  443. * TODO:
  444. * Do we need specialized errors corresponding to above
  445. * error conditions as against just returning a different
  446. * error message?
  447. */
  448. reply = dbus_message_new_error(message, iface, err_msg);
  449. }
  450. out:
  451. os_free(peer_object_path);
  452. os_free(pin);
  453. return reply;
  454. inv_args_clear:
  455. wpa_dbus_dict_entry_clear(&entry);
  456. inv_args:
  457. reply = wpas_dbus_error_invalid_args(message, NULL);
  458. goto out;
  459. }
  460. DBusMessage * wpas_dbus_handler_p2p_invite(DBusMessage *message,
  461. struct wpa_supplicant *wpa_s)
  462. {
  463. DBusMessageIter iter_dict;
  464. DBusMessage *reply = NULL;
  465. DBusMessageIter iter;
  466. struct wpa_dbus_dict_entry entry;
  467. char *peer_object_path = NULL;
  468. char *pg_object_path = NULL;
  469. char *iface = NULL;
  470. char *net_id_str = NULL;
  471. u8 peer_addr[ETH_ALEN];
  472. unsigned int group_id = 0;
  473. int persistent = 0;
  474. struct wpa_ssid *ssid;
  475. if (!wpa_dbus_p2p_check_enabled(wpa_s, message, &reply, NULL))
  476. return reply;
  477. dbus_message_iter_init(message, &iter);
  478. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  479. goto err;
  480. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  481. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  482. goto err;
  483. if (!os_strcmp(entry.key, "peer") &&
  484. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  485. peer_object_path = os_strdup(entry.str_value);
  486. wpa_dbus_dict_entry_clear(&entry);
  487. } else if (!os_strcmp(entry.key, "persistent_group_object") &&
  488. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  489. pg_object_path = os_strdup(entry.str_value);
  490. persistent = 1;
  491. wpa_dbus_dict_entry_clear(&entry);
  492. } else {
  493. wpa_dbus_dict_entry_clear(&entry);
  494. goto err;
  495. }
  496. }
  497. if (!peer_object_path ||
  498. (parse_peer_object_path(peer_object_path, peer_addr) < 0) ||
  499. (p2p_get_peer_info(wpa_s->global->p2p,
  500. peer_addr, 0, NULL, 0) < 0)) {
  501. goto err;
  502. }
  503. if (persistent) {
  504. /*
  505. * A group ID is defined meaning we want to re-invoke a
  506. * persistant group
  507. */
  508. iface = wpas_dbus_new_decompose_object_path(pg_object_path, 1,
  509. &net_id_str, NULL);
  510. if (iface == NULL ||
  511. os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  512. reply = wpas_dbus_error_invalid_args(message,
  513. pg_object_path);
  514. goto out;
  515. }
  516. group_id = strtoul(net_id_str, NULL, 10);
  517. if (errno == EINVAL) {
  518. reply = wpas_dbus_error_invalid_args(
  519. message, pg_object_path);
  520. goto out;
  521. }
  522. /* Get the SSID structure form the persistant group id */
  523. ssid = wpa_config_get_network(wpa_s->conf, group_id);
  524. if (ssid == NULL || ssid->disabled != 2)
  525. goto err;
  526. if (wpas_p2p_invite(wpa_s, peer_addr, ssid, NULL) < 0) {
  527. reply = wpas_dbus_error_unknown_error(
  528. message,
  529. "Failed to reinvoke a persistent group");
  530. goto out;
  531. }
  532. } else {
  533. /*
  534. * No group ID means propose to a peer to join my active group
  535. */
  536. if (wpas_p2p_invite_group(wpa_s, wpa_s->ifname,
  537. peer_addr, NULL)) {
  538. reply = wpas_dbus_error_unknown_error(
  539. message, "Failed to join to an active group");
  540. goto out;
  541. }
  542. }
  543. out:
  544. os_free(pg_object_path);
  545. os_free(peer_object_path);
  546. return reply;
  547. err:
  548. reply = wpas_dbus_error_invalid_args(message, NULL);
  549. goto out;
  550. }
  551. DBusMessage * wpas_dbus_handler_p2p_prov_disc_req(DBusMessage *message,
  552. struct wpa_supplicant *wpa_s)
  553. {
  554. DBusMessageIter iter;
  555. char *peer_object_path = NULL;
  556. char *config_method = NULL;
  557. u8 peer_addr[ETH_ALEN];
  558. dbus_message_iter_init(message, &iter);
  559. dbus_message_iter_get_basic(&iter, &peer_object_path);
  560. if (parse_peer_object_path(peer_object_path, peer_addr) < 0)
  561. return wpas_dbus_error_invalid_args(message, NULL);
  562. dbus_message_iter_next(&iter);
  563. dbus_message_iter_get_basic(&iter, &config_method);
  564. /*
  565. * Validation checks on config_method are being duplicated here
  566. * to be able to return invalid args reply since the error code
  567. * from p2p module are not granular enough (yet).
  568. */
  569. if (os_strcmp(config_method, "display") &&
  570. os_strcmp(config_method, "keypad") &&
  571. os_strcmp(config_method, "pbc") &&
  572. os_strcmp(config_method, "pushbutton"))
  573. return wpas_dbus_error_invalid_args(message, NULL);
  574. if (wpas_p2p_prov_disc(wpa_s, peer_addr, config_method) < 0)
  575. return wpas_dbus_error_unknown_error(message,
  576. "Failed to send provision discovery request");
  577. return NULL;
  578. }
  579. /*
  580. * P2P Device property accessor methods.
  581. */
  582. dbus_bool_t wpas_dbus_getter_p2p_device_properties(DBusMessageIter *iter,
  583. DBusError *error,
  584. void *user_data)
  585. {
  586. struct wpa_supplicant *wpa_s = user_data;
  587. DBusMessageIter variant_iter, dict_iter;
  588. DBusMessageIter iter_secdev_dict_entry, iter_secdev_dict_val,
  589. iter_secdev_dict_array;
  590. const char *dev_name;
  591. int num_vendor_extensions = 0;
  592. int i;
  593. const struct wpabuf *vendor_ext[P2P_MAX_WPS_VENDOR_EXT];
  594. if (!wpa_dbus_p2p_check_enabled(wpa_s, NULL, NULL, error))
  595. return FALSE;
  596. if (!dbus_message_iter_open_container(iter, DBUS_TYPE_VARIANT,
  597. "a{sv}", &variant_iter) ||
  598. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  599. goto err_no_mem;
  600. /* DeviceName */
  601. dev_name = wpa_s->conf->device_name;
  602. if (dev_name &&
  603. !wpa_dbus_dict_append_string(&dict_iter, "DeviceName", dev_name))
  604. goto err_no_mem;
  605. /* Primary device type */
  606. if (!wpa_dbus_dict_append_byte_array(&dict_iter, "PrimaryDeviceType",
  607. (char *)wpa_s->conf->device_type,
  608. WPS_DEV_TYPE_LEN))
  609. goto err_no_mem;
  610. /* Secondary device types */
  611. if (wpa_s->conf->num_sec_device_types) {
  612. if (!wpa_dbus_dict_begin_array(&dict_iter,
  613. "SecondaryDeviceTypes",
  614. DBUS_TYPE_ARRAY_AS_STRING
  615. DBUS_TYPE_BYTE_AS_STRING,
  616. &iter_secdev_dict_entry,
  617. &iter_secdev_dict_val,
  618. &iter_secdev_dict_array))
  619. goto err_no_mem;
  620. for (i = 0; i < wpa_s->conf->num_sec_device_types; i++)
  621. wpa_dbus_dict_bin_array_add_element(
  622. &iter_secdev_dict_array,
  623. wpa_s->conf->sec_device_type[i],
  624. WPS_DEV_TYPE_LEN);
  625. if (!wpa_dbus_dict_end_array(&dict_iter,
  626. &iter_secdev_dict_entry,
  627. &iter_secdev_dict_val,
  628. &iter_secdev_dict_array))
  629. goto err_no_mem;
  630. }
  631. /* Vendor Extensions */
  632. for (i = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  633. if (wpa_s->conf->wps_vendor_ext[i] == NULL)
  634. continue;
  635. vendor_ext[num_vendor_extensions++] =
  636. wpa_s->conf->wps_vendor_ext[i];
  637. }
  638. if (num_vendor_extensions &&
  639. !wpa_dbus_dict_append_wpabuf_array(&dict_iter,
  640. "VendorExtension",
  641. vendor_ext,
  642. num_vendor_extensions))
  643. goto err_no_mem;
  644. /* GO Intent */
  645. if (!wpa_dbus_dict_append_uint32(&dict_iter, "GOIntent",
  646. wpa_s->conf->p2p_go_intent))
  647. goto err_no_mem;
  648. /* Persistant Reconnect */
  649. if (!wpa_dbus_dict_append_bool(&dict_iter, "PersistantReconnect",
  650. wpa_s->conf->persistent_reconnect))
  651. goto err_no_mem;
  652. /* Listen Reg Class */
  653. if (!wpa_dbus_dict_append_uint32(&dict_iter, "ListenRegClass",
  654. wpa_s->conf->p2p_listen_reg_class))
  655. goto err_no_mem;
  656. /* Listen Channel */
  657. if (!wpa_dbus_dict_append_uint32(&dict_iter, "ListenChannel",
  658. wpa_s->conf->p2p_listen_channel))
  659. goto err_no_mem;
  660. /* Oper Reg Class */
  661. if (!wpa_dbus_dict_append_uint32(&dict_iter, "OperRegClass",
  662. wpa_s->conf->p2p_oper_reg_class))
  663. goto err_no_mem;
  664. /* Oper Channel */
  665. if (!wpa_dbus_dict_append_uint32(&dict_iter, "OperChannel",
  666. wpa_s->conf->p2p_oper_channel))
  667. goto err_no_mem;
  668. /* SSID Postfix */
  669. if (wpa_s->conf->p2p_ssid_postfix &&
  670. !wpa_dbus_dict_append_string(&dict_iter, "SsidPostfix",
  671. wpa_s->conf->p2p_ssid_postfix))
  672. goto err_no_mem;
  673. /* Intra Bss */
  674. if (!wpa_dbus_dict_append_bool(&dict_iter, "IntraBss",
  675. wpa_s->conf->p2p_intra_bss))
  676. goto err_no_mem;
  677. /* Group Idle */
  678. if (!wpa_dbus_dict_append_uint32(&dict_iter, "GroupIdle",
  679. wpa_s->conf->p2p_group_idle))
  680. goto err_no_mem;
  681. /* Dissasociation low ack */
  682. if (!wpa_dbus_dict_append_uint32(&dict_iter, "disassoc_low_ack",
  683. wpa_s->conf->disassoc_low_ack))
  684. goto err_no_mem;
  685. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  686. !dbus_message_iter_close_container(iter, &variant_iter))
  687. goto err_no_mem;
  688. return TRUE;
  689. err_no_mem:
  690. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  691. return FALSE;
  692. }
  693. dbus_bool_t wpas_dbus_setter_p2p_device_properties(DBusMessageIter *iter,
  694. DBusError *error,
  695. void *user_data)
  696. {
  697. struct wpa_supplicant *wpa_s = user_data;
  698. DBusMessageIter variant_iter, iter_dict;
  699. struct wpa_dbus_dict_entry entry = {.type = DBUS_TYPE_STRING };
  700. unsigned int i;
  701. if (!wpa_dbus_p2p_check_enabled(wpa_s, NULL, NULL, error))
  702. return FALSE;
  703. dbus_message_iter_recurse(iter, &variant_iter);
  704. if (!wpa_dbus_dict_open_read(&variant_iter, &iter_dict, error))
  705. return FALSE;
  706. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  707. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry)) {
  708. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  709. "invalid message format");
  710. return FALSE;
  711. }
  712. if (os_strcmp(entry.key, "DeviceName") == 0) {
  713. char *devname;
  714. if (entry.type != DBUS_TYPE_STRING)
  715. goto error;
  716. devname = os_strdup(entry.str_value);
  717. if (devname == NULL)
  718. goto err_no_mem_clear;
  719. os_free(wpa_s->conf->device_name);
  720. wpa_s->conf->device_name = devname;
  721. wpa_s->conf->changed_parameters |=
  722. CFG_CHANGED_DEVICE_NAME;
  723. } else if (os_strcmp(entry.key, "PrimaryDeviceType") == 0) {
  724. if (entry.type != DBUS_TYPE_ARRAY ||
  725. entry.array_type != DBUS_TYPE_BYTE ||
  726. entry.array_len != WPS_DEV_TYPE_LEN)
  727. goto error;
  728. os_memcpy(wpa_s->conf->device_type,
  729. entry.bytearray_value,
  730. WPS_DEV_TYPE_LEN);
  731. wpa_s->conf->changed_parameters |=
  732. CFG_CHANGED_DEVICE_TYPE;
  733. } else if (os_strcmp(entry.key, "SecondaryDeviceTypes") == 0) {
  734. if (entry.type != DBUS_TYPE_ARRAY ||
  735. entry.array_type != WPAS_DBUS_TYPE_BINARRAY ||
  736. entry.array_len > MAX_SEC_DEVICE_TYPES)
  737. goto error;
  738. for (i = 0; i < entry.array_len; i++)
  739. if (wpabuf_len(entry.binarray_value[i]) !=
  740. WPS_DEV_TYPE_LEN)
  741. goto err_no_mem_clear;
  742. for (i = 0; i < entry.array_len; i++)
  743. os_memcpy(wpa_s->conf->sec_device_type[i],
  744. wpabuf_head(entry.binarray_value[i]),
  745. WPS_DEV_TYPE_LEN);
  746. wpa_s->conf->num_sec_device_types = entry.array_len;
  747. wpa_s->conf->changed_parameters |=
  748. CFG_CHANGED_SEC_DEVICE_TYPE;
  749. } else if (os_strcmp(entry.key, "VendorExtension") == 0) {
  750. if ((entry.type != DBUS_TYPE_ARRAY) ||
  751. (entry.array_type != WPAS_DBUS_TYPE_BINARRAY) ||
  752. (entry.array_len > P2P_MAX_WPS_VENDOR_EXT))
  753. goto error;
  754. wpa_s->conf->changed_parameters |=
  755. CFG_CHANGED_VENDOR_EXTENSION;
  756. for (i = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  757. wpabuf_free(wpa_s->conf->wps_vendor_ext[i]);
  758. if (i < entry.array_len) {
  759. wpa_s->conf->wps_vendor_ext[i] =
  760. entry.binarray_value[i];
  761. entry.binarray_value[i] = NULL;
  762. } else
  763. wpa_s->conf->wps_vendor_ext[i] = NULL;
  764. }
  765. } else if ((os_strcmp(entry.key, "GOIntent") == 0) &&
  766. (entry.type == DBUS_TYPE_UINT32) &&
  767. (entry.uint32_value <= 15))
  768. wpa_s->conf->p2p_go_intent = entry.uint32_value;
  769. else if ((os_strcmp(entry.key, "PersistantReconnect") == 0) &&
  770. (entry.type == DBUS_TYPE_BOOLEAN))
  771. wpa_s->conf->persistent_reconnect = entry.bool_value;
  772. else if ((os_strcmp(entry.key, "ListenRegClass") == 0) &&
  773. (entry.type == DBUS_TYPE_UINT32)) {
  774. wpa_s->conf->p2p_listen_reg_class = entry.uint32_value;
  775. wpa_s->conf->changed_parameters |=
  776. CFG_CHANGED_P2P_LISTEN_CHANNEL;
  777. } else if ((os_strcmp(entry.key, "ListenChannel") == 0) &&
  778. (entry.type == DBUS_TYPE_UINT32)) {
  779. wpa_s->conf->p2p_listen_channel = entry.uint32_value;
  780. wpa_s->conf->changed_parameters |=
  781. CFG_CHANGED_P2P_LISTEN_CHANNEL;
  782. } else if ((os_strcmp(entry.key, "OperRegClass") == 0) &&
  783. (entry.type == DBUS_TYPE_UINT32)) {
  784. wpa_s->conf->p2p_oper_reg_class = entry.uint32_value;
  785. wpa_s->conf->changed_parameters |=
  786. CFG_CHANGED_P2P_OPER_CHANNEL;
  787. } else if ((os_strcmp(entry.key, "OperChannel") == 0) &&
  788. (entry.type == DBUS_TYPE_UINT32)) {
  789. wpa_s->conf->p2p_oper_channel = entry.uint32_value;
  790. wpa_s->conf->changed_parameters |=
  791. CFG_CHANGED_P2P_OPER_CHANNEL;
  792. } else if (os_strcmp(entry.key, "SsidPostfix") == 0) {
  793. char *postfix;
  794. if (entry.type != DBUS_TYPE_STRING)
  795. goto error;
  796. postfix = os_strdup(entry.str_value);
  797. if (!postfix)
  798. goto err_no_mem_clear;
  799. os_free(wpa_s->conf->p2p_ssid_postfix);
  800. wpa_s->conf->p2p_ssid_postfix = postfix;
  801. wpa_s->conf->changed_parameters |=
  802. CFG_CHANGED_P2P_SSID_POSTFIX;
  803. } else if ((os_strcmp(entry.key, "IntraBss") == 0) &&
  804. (entry.type == DBUS_TYPE_BOOLEAN)) {
  805. wpa_s->conf->p2p_intra_bss = entry.bool_value;
  806. wpa_s->conf->changed_parameters |=
  807. CFG_CHANGED_P2P_INTRA_BSS;
  808. } else if ((os_strcmp(entry.key, "GroupIdle") == 0) &&
  809. (entry.type == DBUS_TYPE_UINT32))
  810. wpa_s->conf->p2p_group_idle = entry.uint32_value;
  811. else if (os_strcmp(entry.key, "disassoc_low_ack") == 0 &&
  812. entry.type == DBUS_TYPE_UINT32)
  813. wpa_s->conf->disassoc_low_ack = entry.uint32_value;
  814. else
  815. goto error;
  816. wpa_dbus_dict_entry_clear(&entry);
  817. }
  818. if (wpa_s->conf->changed_parameters) {
  819. /* Some changed parameters requires to update config*/
  820. wpa_supplicant_update_config(wpa_s);
  821. }
  822. return TRUE;
  823. error:
  824. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  825. "invalid message format");
  826. wpa_dbus_dict_entry_clear(&entry);
  827. return FALSE;
  828. err_no_mem_clear:
  829. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  830. wpa_dbus_dict_entry_clear(&entry);
  831. return FALSE;
  832. }
  833. dbus_bool_t wpas_dbus_getter_p2p_peers(DBusMessageIter *iter, DBusError *error,
  834. void *user_data)
  835. {
  836. struct wpa_supplicant *wpa_s = user_data;
  837. struct p2p_data *p2p = wpa_s->global->p2p;
  838. int next = 0, i = 0;
  839. int num = 0, out_of_mem = 0;
  840. const u8 *addr;
  841. const struct p2p_peer_info *peer_info = NULL;
  842. dbus_bool_t success = FALSE;
  843. struct dl_list peer_objpath_list;
  844. struct peer_objpath_node {
  845. struct dl_list list;
  846. char path[WPAS_DBUS_OBJECT_PATH_MAX];
  847. } *node, *tmp;
  848. char **peer_obj_paths = NULL;
  849. if (!wpa_dbus_p2p_check_enabled(wpa_s, NULL, NULL, error))
  850. return FALSE;
  851. dl_list_init(&peer_objpath_list);
  852. /* Get the first peer info */
  853. peer_info = p2p_get_peer_found(p2p, NULL, next);
  854. /* Get next and accumulate them */
  855. next = 1;
  856. while (peer_info != NULL) {
  857. node = os_zalloc(sizeof(struct peer_objpath_node));
  858. if (!node) {
  859. out_of_mem = 1;
  860. goto error;
  861. }
  862. addr = peer_info->p2p_device_addr;
  863. os_snprintf(node->path, WPAS_DBUS_OBJECT_PATH_MAX,
  864. "%s/" WPAS_DBUS_NEW_P2P_PEERS_PART
  865. "/" COMPACT_MACSTR,
  866. wpa_s->dbus_new_path, MAC2STR(addr));
  867. dl_list_add_tail(&peer_objpath_list, &node->list);
  868. num++;
  869. peer_info = p2p_get_peer_found(p2p, addr, next);
  870. }
  871. /*
  872. * Now construct the peer object paths in a form suitable for
  873. * array_property_getter helper below.
  874. */
  875. peer_obj_paths = os_zalloc(num * sizeof(char *));
  876. if (!peer_obj_paths) {
  877. out_of_mem = 1;
  878. goto error;
  879. }
  880. dl_list_for_each_safe(node, tmp, &peer_objpath_list,
  881. struct peer_objpath_node, list)
  882. peer_obj_paths[i++] = node->path;
  883. success = wpas_dbus_simple_array_property_getter(iter,
  884. DBUS_TYPE_OBJECT_PATH,
  885. peer_obj_paths, num,
  886. error);
  887. error:
  888. if (peer_obj_paths)
  889. os_free(peer_obj_paths);
  890. dl_list_for_each_safe(node, tmp, &peer_objpath_list,
  891. struct peer_objpath_node, list) {
  892. dl_list_del(&node->list);
  893. os_free(node);
  894. }
  895. if (out_of_mem)
  896. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  897. return success;
  898. }
  899. enum wpas_p2p_role {
  900. WPAS_P2P_ROLE_DEVICE,
  901. WPAS_P2P_ROLE_GO,
  902. WPAS_P2P_ROLE_CLIENT,
  903. };
  904. static enum wpas_p2p_role wpas_get_p2p_role(struct wpa_supplicant *wpa_s)
  905. {
  906. struct wpa_ssid *ssid = wpa_s->current_ssid;
  907. if (!ssid)
  908. return WPAS_P2P_ROLE_DEVICE;
  909. if (wpa_s->wpa_state != WPA_COMPLETED)
  910. return WPAS_P2P_ROLE_DEVICE;
  911. switch (ssid->mode) {
  912. case WPAS_MODE_P2P_GO:
  913. case WPAS_MODE_P2P_GROUP_FORMATION:
  914. return WPAS_P2P_ROLE_GO;
  915. case WPAS_MODE_INFRA:
  916. if (ssid->p2p_group)
  917. return WPAS_P2P_ROLE_CLIENT;
  918. return WPAS_P2P_ROLE_DEVICE;
  919. default:
  920. return WPAS_P2P_ROLE_DEVICE;
  921. }
  922. }
  923. dbus_bool_t wpas_dbus_getter_p2p_role(DBusMessageIter *iter, DBusError *error,
  924. void *user_data)
  925. {
  926. struct wpa_supplicant *wpa_s = user_data;
  927. char *str;
  928. switch (wpas_get_p2p_role(wpa_s)) {
  929. case WPAS_P2P_ROLE_GO:
  930. str = "GO";
  931. break;
  932. case WPAS_P2P_ROLE_CLIENT:
  933. str = "client";
  934. break;
  935. default:
  936. str = "device";
  937. }
  938. return wpas_dbus_simple_property_getter(iter, DBUS_TYPE_STRING, &str,
  939. error);
  940. }
  941. dbus_bool_t wpas_dbus_getter_p2p_group(DBusMessageIter *iter, DBusError *error,
  942. void *user_data)
  943. {
  944. struct wpa_supplicant *wpa_s = user_data;
  945. if (wpa_s->dbus_groupobj_path == NULL)
  946. return FALSE;
  947. return wpas_dbus_simple_property_getter(iter, DBUS_TYPE_OBJECT_PATH,
  948. &wpa_s->dbus_groupobj_path,
  949. error);
  950. }
  951. dbus_bool_t wpas_dbus_getter_p2p_peergo(DBusMessageIter *iter,
  952. DBusError *error, void *user_data)
  953. {
  954. struct wpa_supplicant *wpa_s = user_data;
  955. char go_peer_obj_path[WPAS_DBUS_OBJECT_PATH_MAX], *path;
  956. if (wpas_get_p2p_role(wpa_s) != WPAS_P2P_ROLE_CLIENT)
  957. return FALSE;
  958. os_snprintf(go_peer_obj_path, WPAS_DBUS_OBJECT_PATH_MAX,
  959. "%s/" WPAS_DBUS_NEW_P2P_PEERS_PART "/" COMPACT_MACSTR,
  960. wpa_s->dbus_new_path, MAC2STR(wpa_s->go_dev_addr));
  961. path = go_peer_obj_path;
  962. return wpas_dbus_simple_property_getter(iter, DBUS_TYPE_OBJECT_PATH,
  963. &path, error);
  964. }
  965. /*
  966. * Peer object properties accessor methods
  967. */
  968. dbus_bool_t wpas_dbus_getter_p2p_peer_properties(DBusMessageIter *iter,
  969. DBusError *error, void *user_data)
  970. {
  971. struct peer_handler_args *peer_args = user_data;
  972. DBusMessageIter variant_iter, dict_iter;
  973. const struct p2p_peer_info *info = NULL;
  974. const struct wpabuf *vendor_extension[P2P_MAX_WPS_VENDOR_EXT];
  975. int i, num;
  976. if (!wpa_dbus_p2p_check_enabled(peer_args->wpa_s, NULL, NULL, error))
  977. return FALSE;
  978. /* get the peer info */
  979. info = p2p_get_peer_found(peer_args->wpa_s->global->p2p,
  980. peer_args->p2p_device_addr, 0);
  981. if (info == NULL) {
  982. dbus_set_error(error, DBUS_ERROR_FAILED, "failed to find peer");
  983. return FALSE;
  984. }
  985. if (!dbus_message_iter_open_container(iter, DBUS_TYPE_VARIANT,
  986. "a{sv}", &variant_iter) ||
  987. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  988. goto err_no_mem;
  989. /* Fill out the dictionary */
  990. if (!wpa_dbus_dict_append_string(&dict_iter, "DeviceName",
  991. info->device_name))
  992. goto err_no_mem;
  993. if (!wpa_dbus_dict_append_byte_array(&dict_iter, "PrimaryDeviceType",
  994. (char *)info->pri_dev_type,
  995. WPS_DEV_TYPE_LEN))
  996. goto err_no_mem;
  997. if (!wpa_dbus_dict_append_uint16(&dict_iter, "config_method",
  998. info->config_methods))
  999. goto err_no_mem;
  1000. if (!wpa_dbus_dict_append_int32(&dict_iter, "level",
  1001. info->level))
  1002. goto err_no_mem;
  1003. if (!wpa_dbus_dict_append_byte(&dict_iter, "devicecapability",
  1004. info->dev_capab))
  1005. goto err_no_mem;
  1006. if (!wpa_dbus_dict_append_byte(&dict_iter, "groupcapability",
  1007. info->group_capab))
  1008. goto err_no_mem;
  1009. if (info->wps_sec_dev_type_list_len) {
  1010. const u8 *sec_dev_type_list = info->wps_sec_dev_type_list;
  1011. int num_sec_dev_types =
  1012. info->wps_sec_dev_type_list_len / WPS_DEV_TYPE_LEN;
  1013. DBusMessageIter iter_secdev_dict_entry, iter_secdev_dict_val,
  1014. iter_secdev_dict_array;
  1015. if (num_sec_dev_types) {
  1016. if (!wpa_dbus_dict_begin_array(&dict_iter,
  1017. "SecondaryDeviceTypes",
  1018. DBUS_TYPE_ARRAY_AS_STRING
  1019. DBUS_TYPE_BYTE_AS_STRING,
  1020. &iter_secdev_dict_entry,
  1021. &iter_secdev_dict_val,
  1022. &iter_secdev_dict_array))
  1023. goto err_no_mem;
  1024. for (i = 0; i < num_sec_dev_types; i++) {
  1025. wpa_dbus_dict_bin_array_add_element(
  1026. &iter_secdev_dict_array,
  1027. sec_dev_type_list,
  1028. WPS_DEV_TYPE_LEN);
  1029. sec_dev_type_list += WPS_DEV_TYPE_LEN;
  1030. }
  1031. if (!wpa_dbus_dict_end_array(&dict_iter,
  1032. &iter_secdev_dict_entry,
  1033. &iter_secdev_dict_val,
  1034. &iter_secdev_dict_array))
  1035. goto err_no_mem;
  1036. }
  1037. }
  1038. /* Add WPS vendor extensions attribute */
  1039. for (i = 0, num = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  1040. if (info->wps_vendor_ext[i] == NULL)
  1041. continue;
  1042. vendor_extension[num] = info->wps_vendor_ext[i];
  1043. num++;
  1044. }
  1045. if (!wpa_dbus_dict_append_wpabuf_array(&dict_iter, "VendorExtension",
  1046. vendor_extension, num))
  1047. goto err_no_mem;
  1048. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  1049. !dbus_message_iter_close_container(iter, &variant_iter))
  1050. goto err_no_mem;
  1051. return TRUE;
  1052. err_no_mem:
  1053. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1054. return FALSE;
  1055. }
  1056. dbus_bool_t wpas_dbus_getter_p2p_peer_ies(DBusMessageIter *iter,
  1057. DBusError *error, void *user_data)
  1058. {
  1059. /* struct peer_handler_args *peer_args = user_data; */
  1060. dbus_set_error_const(error, DBUS_ERROR_FAILED, "not implemented");
  1061. return FALSE;
  1062. }
  1063. /**
  1064. * wpas_dbus_getter_persistent_groups - Get array of peristent group objects
  1065. * @iter: Pointer to incoming dbus message iter
  1066. * @error: Location to store error on failure
  1067. * @user_data: Function specific data
  1068. * Returns: TRUE on success, FALSE on failure
  1069. *
  1070. * Getter for "PersistentGroups" property.
  1071. */
  1072. dbus_bool_t wpas_dbus_getter_persistent_groups(DBusMessageIter *iter,
  1073. DBusError *error,
  1074. void *user_data)
  1075. {
  1076. struct wpa_supplicant *wpa_s = user_data;
  1077. struct wpa_ssid *ssid;
  1078. char **paths;
  1079. unsigned int i = 0, num = 0;
  1080. dbus_bool_t success = FALSE;
  1081. if (wpa_s->conf == NULL) {
  1082. wpa_printf(MSG_ERROR, "dbus: %s: "
  1083. "An error occurred getting persistent groups list",
  1084. __func__);
  1085. dbus_set_error_const(error, DBUS_ERROR_FAILED, "an error "
  1086. "occurred getting persistent groups list");
  1087. return FALSE;
  1088. }
  1089. for (ssid = wpa_s->conf->ssid; ssid; ssid = ssid->next)
  1090. if (network_is_persistent_group(ssid))
  1091. num++;
  1092. paths = os_zalloc(num * sizeof(char *));
  1093. if (!paths) {
  1094. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1095. return FALSE;
  1096. }
  1097. /* Loop through configured networks and append object path of each */
  1098. for (ssid = wpa_s->conf->ssid; ssid; ssid = ssid->next) {
  1099. if (!network_is_persistent_group(ssid))
  1100. continue;
  1101. paths[i] = os_zalloc(WPAS_DBUS_OBJECT_PATH_MAX);
  1102. if (paths[i] == NULL) {
  1103. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY,
  1104. "no memory");
  1105. goto out;
  1106. }
  1107. /* Construct the object path for this network. */
  1108. os_snprintf(paths[i++], WPAS_DBUS_OBJECT_PATH_MAX,
  1109. "%s/" WPAS_DBUS_NEW_PERSISTENT_GROUPS_PART "/%d",
  1110. wpa_s->dbus_new_path, ssid->id);
  1111. }
  1112. success = wpas_dbus_simple_array_property_getter(iter,
  1113. DBUS_TYPE_OBJECT_PATH,
  1114. paths, num, error);
  1115. out:
  1116. while (i)
  1117. os_free(paths[--i]);
  1118. os_free(paths);
  1119. return success;
  1120. }
  1121. /**
  1122. * wpas_dbus_getter_persistent_group_properties - Get options for a persistent
  1123. * group
  1124. * @iter: Pointer to incoming dbus message iter
  1125. * @error: Location to store error on failure
  1126. * @user_data: Function specific data
  1127. * Returns: TRUE on success, FALSE on failure
  1128. *
  1129. * Getter for "Properties" property of a persistent group.
  1130. */
  1131. dbus_bool_t wpas_dbus_getter_persistent_group_properties(DBusMessageIter *iter,
  1132. DBusError *error,
  1133. void *user_data)
  1134. {
  1135. struct network_handler_args *net = user_data;
  1136. /* Leveraging the fact that persistent group object is still
  1137. * represented in same manner as network within.
  1138. */
  1139. return wpas_dbus_getter_network_properties(iter, error, net);
  1140. }
  1141. /**
  1142. * wpas_dbus_setter_persistent_group_properties - Get options for a persistent
  1143. * group
  1144. * @iter: Pointer to incoming dbus message iter
  1145. * @error: Location to store error on failure
  1146. * @user_data: Function specific data
  1147. * Returns: TRUE on success, FALSE on failure
  1148. *
  1149. * Setter for "Properties" property of a persistent group.
  1150. */
  1151. dbus_bool_t wpas_dbus_setter_persistent_group_properties(DBusMessageIter *iter,
  1152. DBusError *error,
  1153. void *user_data)
  1154. {
  1155. struct network_handler_args *net = user_data;
  1156. struct wpa_ssid *ssid = net->ssid;
  1157. DBusMessageIter variant_iter;
  1158. /*
  1159. * Leveraging the fact that persistent group object is still
  1160. * represented in same manner as network within.
  1161. */
  1162. dbus_message_iter_recurse(iter, &variant_iter);
  1163. return set_network_properties(net->wpa_s, ssid, &variant_iter, error);
  1164. }
  1165. /**
  1166. * wpas_dbus_new_iface_add_persistent_group - Add a new configured
  1167. * persistent_group
  1168. * @message: Pointer to incoming dbus message
  1169. * @wpa_s: wpa_supplicant structure for a network interface
  1170. * Returns: A dbus message containing the object path of the new
  1171. * persistent group
  1172. *
  1173. * Handler function for "AddPersistentGroup" method call of a P2P Device
  1174. * interface.
  1175. */
  1176. DBusMessage * wpas_dbus_handler_add_persistent_group(
  1177. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1178. {
  1179. DBusMessage *reply = NULL;
  1180. DBusMessageIter iter;
  1181. struct wpa_ssid *ssid = NULL;
  1182. char path_buf[WPAS_DBUS_OBJECT_PATH_MAX], *path = path_buf;
  1183. DBusError error;
  1184. dbus_message_iter_init(message, &iter);
  1185. ssid = wpa_config_add_network(wpa_s->conf);
  1186. if (ssid == NULL) {
  1187. wpa_printf(MSG_ERROR, "dbus: %s: "
  1188. "Cannot add new persistent group", __func__);
  1189. reply = wpas_dbus_error_unknown_error(
  1190. message,
  1191. "wpa_supplicant could not add "
  1192. "a persistent group on this interface.");
  1193. goto err;
  1194. }
  1195. /* Mark the ssid as being a persistent group before the notification */
  1196. ssid->disabled = 2;
  1197. ssid->p2p_persistent_group = 1;
  1198. wpas_notify_persistent_group_added(wpa_s, ssid);
  1199. wpa_config_set_network_defaults(ssid);
  1200. dbus_error_init(&error);
  1201. if (!set_network_properties(wpa_s, ssid, &iter, &error)) {
  1202. wpa_printf(MSG_DEBUG, "dbus: %s: "
  1203. "Control interface could not set persistent group "
  1204. "properties", __func__);
  1205. reply = wpas_dbus_reply_new_from_error(message, &error,
  1206. DBUS_ERROR_INVALID_ARGS,
  1207. "Failed to set network "
  1208. "properties");
  1209. dbus_error_free(&error);
  1210. goto err;
  1211. }
  1212. /* Construct the object path for this network. */
  1213. os_snprintf(path, WPAS_DBUS_OBJECT_PATH_MAX,
  1214. "%s/" WPAS_DBUS_NEW_PERSISTENT_GROUPS_PART "/%d",
  1215. wpa_s->dbus_new_path, ssid->id);
  1216. reply = dbus_message_new_method_return(message);
  1217. if (reply == NULL) {
  1218. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1219. NULL);
  1220. goto err;
  1221. }
  1222. if (!dbus_message_append_args(reply, DBUS_TYPE_OBJECT_PATH, &path,
  1223. DBUS_TYPE_INVALID)) {
  1224. dbus_message_unref(reply);
  1225. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1226. NULL);
  1227. goto err;
  1228. }
  1229. return reply;
  1230. err:
  1231. if (ssid) {
  1232. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1233. wpa_config_remove_network(wpa_s->conf, ssid->id);
  1234. }
  1235. return reply;
  1236. }
  1237. /**
  1238. * wpas_dbus_handler_remove_persistent_group - Remove a configured persistent
  1239. * group
  1240. * @message: Pointer to incoming dbus message
  1241. * @wpa_s: wpa_supplicant structure for a network interface
  1242. * Returns: NULL on success or dbus error on failure
  1243. *
  1244. * Handler function for "RemovePersistentGroup" method call of a P2P Device
  1245. * interface.
  1246. */
  1247. DBusMessage * wpas_dbus_handler_remove_persistent_group(
  1248. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1249. {
  1250. DBusMessage *reply = NULL;
  1251. const char *op;
  1252. char *iface = NULL, *persistent_group_id = NULL;
  1253. int id;
  1254. struct wpa_ssid *ssid;
  1255. dbus_message_get_args(message, NULL, DBUS_TYPE_OBJECT_PATH, &op,
  1256. DBUS_TYPE_INVALID);
  1257. /*
  1258. * Extract the network ID and ensure the network is actually a child of
  1259. * this interface.
  1260. */
  1261. iface = wpas_dbus_new_decompose_object_path(op, 1,
  1262. &persistent_group_id,
  1263. NULL);
  1264. if (iface == NULL || os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  1265. reply = wpas_dbus_error_invalid_args(message, op);
  1266. goto out;
  1267. }
  1268. id = strtoul(persistent_group_id, NULL, 10);
  1269. if (errno == EINVAL) {
  1270. reply = wpas_dbus_error_invalid_args(message, op);
  1271. goto out;
  1272. }
  1273. ssid = wpa_config_get_network(wpa_s->conf, id);
  1274. if (ssid == NULL) {
  1275. reply = wpas_dbus_error_persistent_group_unknown(message);
  1276. goto out;
  1277. }
  1278. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1279. if (wpa_config_remove_network(wpa_s->conf, id) < 0) {
  1280. wpa_printf(MSG_ERROR, "dbus: %s: "
  1281. "error occurred when removing persistent group %d",
  1282. __func__, id);
  1283. reply = wpas_dbus_error_unknown_error(
  1284. message,
  1285. "error removing the specified persistent group on "
  1286. "this interface.");
  1287. goto out;
  1288. }
  1289. out:
  1290. os_free(iface);
  1291. os_free(persistent_group_id);
  1292. return reply;
  1293. }
  1294. static void remove_persistent_group(struct wpa_supplicant *wpa_s,
  1295. struct wpa_ssid *ssid)
  1296. {
  1297. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1298. if (wpa_config_remove_network(wpa_s->conf, ssid->id) < 0) {
  1299. wpa_printf(MSG_ERROR, "dbus: %s: "
  1300. "error occurred when removing persistent group %d",
  1301. __func__, ssid->id);
  1302. return;
  1303. }
  1304. }
  1305. /**
  1306. * wpas_dbus_handler_remove_all_persistent_groups - Remove all configured
  1307. * persistent groups
  1308. * @message: Pointer to incoming dbus message
  1309. * @wpa_s: wpa_supplicant structure for a network interface
  1310. * Returns: NULL on success or dbus error on failure
  1311. *
  1312. * Handler function for "RemoveAllPersistentGroups" method call of a
  1313. * P2P Device interface.
  1314. */
  1315. DBusMessage * wpas_dbus_handler_remove_all_persistent_groups(
  1316. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1317. {
  1318. struct wpa_ssid *ssid, *next;
  1319. struct wpa_config *config;
  1320. config = wpa_s->conf;
  1321. ssid = config->ssid;
  1322. while (ssid) {
  1323. next = ssid->next;
  1324. if (network_is_persistent_group(ssid))
  1325. remove_persistent_group(wpa_s, ssid);
  1326. ssid = next;
  1327. }
  1328. return NULL;
  1329. }
  1330. /*
  1331. * Group object properties accessor methods
  1332. */
  1333. dbus_bool_t wpas_dbus_getter_p2p_group_members(DBusMessageIter *iter,
  1334. DBusError *error,
  1335. void *user_data)
  1336. {
  1337. struct wpa_supplicant *wpa_s = user_data;
  1338. struct wpa_ssid *ssid;
  1339. unsigned int num_members;
  1340. char **paths;
  1341. unsigned int i;
  1342. void *next = NULL;
  1343. const u8 *addr;
  1344. dbus_bool_t success = FALSE;
  1345. /* Ensure we are a GO */
  1346. if (wpa_s->wpa_state != WPA_COMPLETED)
  1347. return FALSE;
  1348. ssid = wpa_s->conf->ssid;
  1349. /* At present WPAS P2P_GO mode only applicable for p2p_go */
  1350. if (ssid->mode != WPAS_MODE_P2P_GO &&
  1351. ssid->mode != WPAS_MODE_AP &&
  1352. ssid->mode != WPAS_MODE_P2P_GROUP_FORMATION)
  1353. return FALSE;
  1354. num_members = p2p_get_group_num_members(wpa_s->p2p_group);
  1355. paths = os_zalloc(num_members * sizeof(char *));
  1356. if (!paths)
  1357. goto out_of_memory;
  1358. i = 0;
  1359. while ((addr = p2p_iterate_group_members(wpa_s->p2p_group, &next))) {
  1360. paths[i] = os_zalloc(WPAS_DBUS_OBJECT_PATH_MAX);
  1361. if (!paths[i])
  1362. goto out_of_memory;
  1363. os_snprintf(paths[i], WPAS_DBUS_OBJECT_PATH_MAX,
  1364. "%s/" WPAS_DBUS_NEW_P2P_GROUPMEMBERS_PART
  1365. "/" COMPACT_MACSTR,
  1366. wpa_s->dbus_groupobj_path, MAC2STR(addr));
  1367. i++;
  1368. }
  1369. success = wpas_dbus_simple_array_property_getter(iter,
  1370. DBUS_TYPE_OBJECT_PATH,
  1371. paths, num_members,
  1372. error);
  1373. for (i = 0; i < num_members; i++)
  1374. os_free(paths[i]);
  1375. os_free(paths);
  1376. return success;
  1377. out_of_memory:
  1378. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1379. if (paths) {
  1380. for (i = 0; i < num_members; i++)
  1381. os_free(paths[i]);
  1382. os_free(paths);
  1383. }
  1384. return FALSE;
  1385. }
  1386. dbus_bool_t wpas_dbus_getter_p2p_group_properties(DBusMessageIter *iter,
  1387. DBusError *error,
  1388. void *user_data)
  1389. {
  1390. struct wpa_supplicant *wpa_s = user_data;
  1391. DBusMessageIter variant_iter, dict_iter;
  1392. struct hostapd_data *hapd = wpa_s->ap_iface->bss[0];
  1393. const struct wpabuf *vendor_ext[MAX_WPS_VENDOR_EXTENSIONS];
  1394. int num_vendor_ext = 0;
  1395. int i;
  1396. if (!hapd) {
  1397. dbus_set_error_const(error, DBUS_ERROR_FAILED,
  1398. "internal error");
  1399. return FALSE;
  1400. }
  1401. if (!dbus_message_iter_open_container(iter, DBUS_TYPE_VARIANT,
  1402. "a{sv}", &variant_iter) ||
  1403. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  1404. goto err_no_mem;
  1405. /* Parse WPS Vendor Extensions sent in Beacon/Probe Response */
  1406. for (i = 0; i < MAX_WPS_VENDOR_EXTENSIONS; i++) {
  1407. if (hapd->conf->wps_vendor_ext[i] == NULL)
  1408. continue;
  1409. vendor_ext[num_vendor_ext++] = hapd->conf->wps_vendor_ext[i];
  1410. }
  1411. if (!wpa_dbus_dict_append_wpabuf_array(&dict_iter,
  1412. "WPSVendorExtensions",
  1413. vendor_ext, num_vendor_ext))
  1414. goto err_no_mem;
  1415. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  1416. !dbus_message_iter_close_container(iter, &variant_iter))
  1417. goto err_no_mem;
  1418. return TRUE;
  1419. err_no_mem:
  1420. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1421. return FALSE;
  1422. }
  1423. dbus_bool_t wpas_dbus_setter_p2p_group_properties(DBusMessageIter *iter,
  1424. DBusError *error,
  1425. void *user_data)
  1426. {
  1427. struct wpa_supplicant *wpa_s = user_data;
  1428. DBusMessageIter variant_iter, iter_dict;
  1429. struct wpa_dbus_dict_entry entry = { .type = DBUS_TYPE_STRING };
  1430. unsigned int i;
  1431. struct hostapd_data *hapd = wpa_s->ap_iface->bss[0];
  1432. if (!hapd) {
  1433. dbus_set_error_const(error, DBUS_ERROR_FAILED,
  1434. "internal error");
  1435. return FALSE;
  1436. }
  1437. dbus_message_iter_recurse(iter, &variant_iter);
  1438. if (!wpa_dbus_dict_open_read(&variant_iter, &iter_dict, error))
  1439. return FALSE;
  1440. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1441. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry)) {
  1442. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  1443. "invalid message format");
  1444. return FALSE;
  1445. }
  1446. if (os_strcmp(entry.key, "WPSVendorExtensions") == 0) {
  1447. if (entry.type != DBUS_TYPE_ARRAY ||
  1448. entry.array_type != WPAS_DBUS_TYPE_BINARRAY ||
  1449. entry.array_len > MAX_WPS_VENDOR_EXTENSIONS)
  1450. goto error;
  1451. for (i = 0; i < MAX_WPS_VENDOR_EXTENSIONS; i++) {
  1452. if (i < entry.array_len) {
  1453. hapd->conf->wps_vendor_ext[i] =
  1454. entry.binarray_value[i];
  1455. entry.binarray_value[i] = NULL;
  1456. } else
  1457. hapd->conf->wps_vendor_ext[i] = NULL;
  1458. }
  1459. hostapd_update_wps(hapd);
  1460. } else
  1461. goto error;
  1462. wpa_dbus_dict_entry_clear(&entry);
  1463. }
  1464. return TRUE;
  1465. error:
  1466. wpa_dbus_dict_entry_clear(&entry);
  1467. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  1468. "invalid message format");
  1469. return FALSE;
  1470. }
  1471. DBusMessage * wpas_dbus_handler_p2p_add_service(DBusMessage *message,
  1472. struct wpa_supplicant *wpa_s)
  1473. {
  1474. DBusMessageIter iter_dict;
  1475. DBusMessage *reply = NULL;
  1476. DBusMessageIter iter;
  1477. struct wpa_dbus_dict_entry entry;
  1478. int upnp = 0;
  1479. int bonjour = 0;
  1480. char *service = NULL;
  1481. struct wpabuf *query = NULL;
  1482. struct wpabuf *resp = NULL;
  1483. u8 version = 0;
  1484. dbus_message_iter_init(message, &iter);
  1485. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1486. goto error;
  1487. if (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1488. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1489. goto error;
  1490. if (!os_strcmp(entry.key, "service_type") &&
  1491. (entry.type == DBUS_TYPE_STRING)) {
  1492. if (!os_strcmp(entry.str_value, "upnp"))
  1493. upnp = 1;
  1494. else if (!os_strcmp(entry.str_value, "bonjour"))
  1495. bonjour = 1;
  1496. else
  1497. goto error_clear;
  1498. wpa_dbus_dict_entry_clear(&entry);
  1499. }
  1500. }
  1501. if (upnp == 1) {
  1502. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1503. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1504. goto error;
  1505. if (!os_strcmp(entry.key, "version") &&
  1506. entry.type == DBUS_TYPE_INT32)
  1507. version = entry.uint32_value;
  1508. else if (!os_strcmp(entry.key, "service") &&
  1509. entry.type == DBUS_TYPE_STRING)
  1510. service = os_strdup(entry.str_value);
  1511. wpa_dbus_dict_entry_clear(&entry);
  1512. }
  1513. if (version <= 0 || service == NULL)
  1514. goto error;
  1515. if (wpas_p2p_service_add_upnp(wpa_s, version, service) != 0)
  1516. goto error;
  1517. os_free(service);
  1518. } else if (bonjour == 1) {
  1519. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1520. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1521. goto error;
  1522. if (!os_strcmp(entry.key, "query")) {
  1523. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1524. (entry.array_type != DBUS_TYPE_BYTE))
  1525. goto error_clear;
  1526. query = wpabuf_alloc_copy(
  1527. entry.bytearray_value,
  1528. entry.array_len);
  1529. } else if (!os_strcmp(entry.key, "response")) {
  1530. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1531. (entry.array_type != DBUS_TYPE_BYTE))
  1532. goto error_clear;
  1533. resp = wpabuf_alloc_copy(entry.bytearray_value,
  1534. entry.array_len);
  1535. }
  1536. wpa_dbus_dict_entry_clear(&entry);
  1537. }
  1538. if (query == NULL || resp == NULL)
  1539. goto error;
  1540. if (wpas_p2p_service_add_bonjour(wpa_s, query, resp) < 0) {
  1541. wpabuf_free(query);
  1542. wpabuf_free(resp);
  1543. goto error;
  1544. }
  1545. } else
  1546. goto error;
  1547. return reply;
  1548. error_clear:
  1549. wpa_dbus_dict_entry_clear(&entry);
  1550. error:
  1551. return wpas_dbus_error_invalid_args(message, NULL);
  1552. }
  1553. DBusMessage * wpas_dbus_handler_p2p_delete_service(
  1554. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1555. {
  1556. DBusMessageIter iter_dict;
  1557. DBusMessage *reply = NULL;
  1558. DBusMessageIter iter;
  1559. struct wpa_dbus_dict_entry entry;
  1560. int upnp = 0;
  1561. int bonjour = 0;
  1562. int ret = 0;
  1563. char *service = NULL;
  1564. struct wpabuf *query = NULL;
  1565. u8 version = 0;
  1566. dbus_message_iter_init(message, &iter);
  1567. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1568. goto error;
  1569. if (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1570. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1571. goto error;
  1572. if (!os_strcmp(entry.key, "service_type") &&
  1573. (entry.type == DBUS_TYPE_STRING)) {
  1574. if (!os_strcmp(entry.str_value, "upnp"))
  1575. upnp = 1;
  1576. else if (!os_strcmp(entry.str_value, "bonjour"))
  1577. bonjour = 1;
  1578. else
  1579. goto error_clear;
  1580. wpa_dbus_dict_entry_clear(&entry);
  1581. }
  1582. }
  1583. if (upnp == 1) {
  1584. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1585. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1586. goto error;
  1587. if (!os_strcmp(entry.key, "version") &&
  1588. entry.type == DBUS_TYPE_INT32)
  1589. version = entry.uint32_value;
  1590. else if (!os_strcmp(entry.key, "service") &&
  1591. entry.type == DBUS_TYPE_STRING)
  1592. service = os_strdup(entry.str_value);
  1593. else
  1594. goto error_clear;
  1595. wpa_dbus_dict_entry_clear(&entry);
  1596. }
  1597. if (version <= 0 || service == NULL)
  1598. goto error;
  1599. ret = wpas_p2p_service_del_upnp(wpa_s, version, service);
  1600. os_free(service);
  1601. if (ret != 0)
  1602. goto error;
  1603. } else if (bonjour == 1) {
  1604. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1605. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1606. goto error;
  1607. if (!os_strcmp(entry.key, "query")) {
  1608. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1609. (entry.array_type != DBUS_TYPE_BYTE))
  1610. goto error_clear;
  1611. query = wpabuf_alloc_copy(
  1612. entry.bytearray_value,
  1613. entry.array_len);
  1614. } else
  1615. goto error_clear;
  1616. wpa_dbus_dict_entry_clear(&entry);
  1617. }
  1618. if (query == NULL)
  1619. goto error;
  1620. ret = wpas_p2p_service_del_bonjour(wpa_s, query);
  1621. if (ret != 0)
  1622. goto error;
  1623. wpabuf_free(query);
  1624. } else
  1625. goto error;
  1626. return reply;
  1627. error_clear:
  1628. wpa_dbus_dict_entry_clear(&entry);
  1629. error:
  1630. return wpas_dbus_error_invalid_args(message, NULL);
  1631. }
  1632. DBusMessage * wpas_dbus_handler_p2p_flush_service(DBusMessage *message,
  1633. struct wpa_supplicant *wpa_s)
  1634. {
  1635. wpas_p2p_service_flush(wpa_s);
  1636. return NULL;
  1637. }
  1638. DBusMessage * wpas_dbus_handler_p2p_service_sd_req(
  1639. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1640. {
  1641. DBusMessageIter iter_dict;
  1642. DBusMessage *reply = NULL;
  1643. DBusMessageIter iter;
  1644. struct wpa_dbus_dict_entry entry;
  1645. int upnp = 0;
  1646. char *service = NULL;
  1647. char *peer_object_path = NULL;
  1648. struct wpabuf *tlv = NULL;
  1649. u8 version = 0;
  1650. u64 ref = 0;
  1651. u8 addr[ETH_ALEN];
  1652. dbus_message_iter_init(message, &iter);
  1653. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1654. goto error;
  1655. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1656. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1657. goto error;
  1658. if (!os_strcmp(entry.key, "peer_object") &&
  1659. entry.type == DBUS_TYPE_OBJECT_PATH) {
  1660. peer_object_path = os_strdup(entry.str_value);
  1661. } else if (!os_strcmp(entry.key, "service_type") &&
  1662. entry.type == DBUS_TYPE_STRING) {
  1663. if (!os_strcmp(entry.str_value, "upnp"))
  1664. upnp = 1;
  1665. else
  1666. goto error_clear;
  1667. } else if (!os_strcmp(entry.key, "version") &&
  1668. entry.type == DBUS_TYPE_INT32) {
  1669. version = entry.uint32_value;
  1670. } else if (!os_strcmp(entry.key, "service") &&
  1671. entry.type == DBUS_TYPE_STRING) {
  1672. service = os_strdup(entry.str_value);
  1673. } else if (!os_strcmp(entry.key, "tlv")) {
  1674. if (entry.type != DBUS_TYPE_ARRAY ||
  1675. entry.array_type != DBUS_TYPE_BYTE)
  1676. goto error_clear;
  1677. tlv = wpabuf_alloc_copy(entry.bytearray_value,
  1678. entry.array_len);
  1679. } else
  1680. goto error_clear;
  1681. wpa_dbus_dict_entry_clear(&entry);
  1682. }
  1683. if (!peer_object_path ||
  1684. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  1685. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  1686. goto error;
  1687. if (upnp == 1) {
  1688. if (version <= 0 || service == NULL)
  1689. goto error;
  1690. ref = (unsigned long) wpas_p2p_sd_request_upnp(wpa_s, addr,
  1691. version,
  1692. service);
  1693. } else {
  1694. if (tlv == NULL)
  1695. goto error;
  1696. ref = (unsigned long)wpas_p2p_sd_request(wpa_s, addr, tlv);
  1697. wpabuf_free(tlv);
  1698. }
  1699. if (ref != 0) {
  1700. reply = dbus_message_new_method_return(message);
  1701. dbus_message_append_args(reply, DBUS_TYPE_UINT64,
  1702. &ref, DBUS_TYPE_INVALID);
  1703. } else {
  1704. reply = wpas_dbus_error_unknown_error(
  1705. message, "Unable to send SD request");
  1706. }
  1707. out:
  1708. os_free(service);
  1709. os_free(peer_object_path);
  1710. return reply;
  1711. error_clear:
  1712. wpa_dbus_dict_entry_clear(&entry);
  1713. error:
  1714. if (tlv)
  1715. wpabuf_free(tlv);
  1716. reply = wpas_dbus_error_invalid_args(message, NULL);
  1717. goto out;
  1718. }
  1719. DBusMessage * wpas_dbus_handler_p2p_service_sd_res(
  1720. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1721. {
  1722. DBusMessageIter iter_dict;
  1723. DBusMessage *reply = NULL;
  1724. DBusMessageIter iter;
  1725. struct wpa_dbus_dict_entry entry;
  1726. char *peer_object_path = NULL;
  1727. struct wpabuf *tlv = NULL;
  1728. int freq = 0;
  1729. int dlg_tok = 0;
  1730. u8 addr[ETH_ALEN];
  1731. dbus_message_iter_init(message, &iter);
  1732. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1733. goto error;
  1734. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1735. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1736. goto error;
  1737. if (!os_strcmp(entry.key, "peer_object") &&
  1738. entry.type == DBUS_TYPE_OBJECT_PATH) {
  1739. peer_object_path = os_strdup(entry.str_value);
  1740. } else if (!os_strcmp(entry.key, "frequency") &&
  1741. entry.type == DBUS_TYPE_INT32) {
  1742. freq = entry.uint32_value;
  1743. } else if (!os_strcmp(entry.key, "dialog_token") &&
  1744. entry.type == DBUS_TYPE_UINT32) {
  1745. dlg_tok = entry.uint32_value;
  1746. } else if (!os_strcmp(entry.key, "tlvs")) {
  1747. if (entry.type != DBUS_TYPE_ARRAY ||
  1748. entry.array_type != DBUS_TYPE_BYTE)
  1749. goto error_clear;
  1750. tlv = wpabuf_alloc_copy(entry.bytearray_value,
  1751. entry.array_len);
  1752. } else
  1753. goto error_clear;
  1754. wpa_dbus_dict_entry_clear(&entry);
  1755. }
  1756. if (!peer_object_path ||
  1757. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  1758. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  1759. goto error;
  1760. if (tlv == NULL)
  1761. goto error;
  1762. wpas_p2p_sd_response(wpa_s, freq, addr, (u8) dlg_tok, tlv);
  1763. wpabuf_free(tlv);
  1764. out:
  1765. os_free(peer_object_path);
  1766. return reply;
  1767. error_clear:
  1768. wpa_dbus_dict_entry_clear(&entry);
  1769. error:
  1770. reply = wpas_dbus_error_invalid_args(message, NULL);
  1771. goto out;
  1772. }
  1773. DBusMessage * wpas_dbus_handler_p2p_service_sd_cancel_req(
  1774. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1775. {
  1776. DBusMessageIter iter;
  1777. u64 req = 0;
  1778. dbus_message_iter_init(message, &iter);
  1779. dbus_message_iter_get_basic(&iter, &req);
  1780. if (req == 0)
  1781. goto error;
  1782. if (!wpas_p2p_sd_cancel_request(wpa_s, (void *)(unsigned long) req))
  1783. goto error;
  1784. return NULL;
  1785. error:
  1786. return wpas_dbus_error_invalid_args(message, NULL);
  1787. }
  1788. DBusMessage * wpas_dbus_handler_p2p_service_update(
  1789. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1790. {
  1791. wpas_p2p_sd_service_update(wpa_s);
  1792. return NULL;
  1793. }
  1794. DBusMessage * wpas_dbus_handler_p2p_serv_disc_external(
  1795. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1796. {
  1797. DBusMessageIter iter;
  1798. int ext = 0;
  1799. dbus_message_iter_init(message, &iter);
  1800. dbus_message_iter_get_basic(&iter, &ext);
  1801. wpa_s->p2p_sd_over_ctrl_iface = ext;
  1802. return NULL;
  1803. }