dbus_new_handlers_p2p.c 57 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146
  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, "display"))
  395. wps_method = WPS_PIN_DISPLAY;
  396. else if (!os_strcmp(entry.str_value, "keypad"))
  397. wps_method = WPS_PIN_KEYPAD;
  398. else
  399. goto inv_args_clear;
  400. } else if (!os_strcmp(entry.key, "pin") &&
  401. (entry.type == DBUS_TYPE_STRING)) {
  402. pin = os_strdup(entry.str_value);
  403. } else
  404. goto inv_args_clear;
  405. wpa_dbus_dict_entry_clear(&entry);
  406. }
  407. if (!peer_object_path || (wps_method == WPS_NOT_READY) ||
  408. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  409. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  410. goto inv_args;
  411. /*
  412. * Validate the wps_method specified and the pin value.
  413. */
  414. if ((!pin || !pin[0]) && (wps_method == WPS_PIN_KEYPAD))
  415. goto inv_args;
  416. new_pin = wpas_p2p_connect(wpa_s, addr, pin, wps_method,
  417. persistent_group, join, authorize_only,
  418. go_intent, freq);
  419. if (new_pin >= 0) {
  420. reply = dbus_message_new_method_return(message);
  421. dbus_message_append_args(reply, DBUS_TYPE_INT32,
  422. &new_pin, DBUS_TYPE_INVALID);
  423. } else {
  424. switch (new_pin) {
  425. case -2:
  426. err_msg = "connect failed due to channel "
  427. "unavailability.";
  428. iface = WPAS_DBUS_ERROR_CONNECT_CHANNEL_UNAVAILABLE;
  429. break;
  430. case -3:
  431. err_msg = "connect failed due to unsupported channel.";
  432. iface = WPAS_DBUS_ERROR_CONNECT_CHANNEL_UNSUPPORTED;
  433. break;
  434. default:
  435. err_msg = "connect failed due to unspecified error.";
  436. iface = WPAS_DBUS_ERROR_CONNECT_UNSPECIFIED_ERROR;
  437. break;
  438. }
  439. /*
  440. * TODO:
  441. * Do we need specialized errors corresponding to above
  442. * error conditions as against just returning a different
  443. * error message?
  444. */
  445. reply = dbus_message_new_error(message, iface, err_msg);
  446. }
  447. out:
  448. os_free(peer_object_path);
  449. os_free(pin);
  450. return reply;
  451. inv_args_clear:
  452. wpa_dbus_dict_entry_clear(&entry);
  453. inv_args:
  454. reply = wpas_dbus_error_invalid_args(message, NULL);
  455. goto out;
  456. }
  457. DBusMessage * wpas_dbus_handler_p2p_invite(DBusMessage *message,
  458. struct wpa_supplicant *wpa_s)
  459. {
  460. DBusMessageIter iter_dict;
  461. DBusMessage *reply = NULL;
  462. DBusMessageIter iter;
  463. struct wpa_dbus_dict_entry entry;
  464. char *peer_object_path = NULL;
  465. char *pg_object_path = NULL;
  466. char *iface = NULL;
  467. char *net_id_str = NULL;
  468. u8 peer_addr[ETH_ALEN];
  469. unsigned int group_id = 0;
  470. int persistent = 0;
  471. struct wpa_ssid *ssid;
  472. if (!wpa_dbus_p2p_check_enabled(wpa_s, message, &reply, NULL))
  473. return reply;
  474. dbus_message_iter_init(message, &iter);
  475. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  476. goto err;
  477. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  478. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  479. goto err;
  480. if (!os_strcmp(entry.key, "peer") &&
  481. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  482. peer_object_path = os_strdup(entry.str_value);
  483. wpa_dbus_dict_entry_clear(&entry);
  484. } else if (!os_strcmp(entry.key, "persistent_group_object") &&
  485. (entry.type == DBUS_TYPE_OBJECT_PATH)) {
  486. pg_object_path = os_strdup(entry.str_value);
  487. persistent = 1;
  488. wpa_dbus_dict_entry_clear(&entry);
  489. } else {
  490. wpa_dbus_dict_entry_clear(&entry);
  491. goto err;
  492. }
  493. }
  494. if (!peer_object_path ||
  495. (parse_peer_object_path(peer_object_path, peer_addr) < 0) ||
  496. (p2p_get_peer_info(wpa_s->global->p2p,
  497. peer_addr, 0, NULL, 0) < 0)) {
  498. goto err;
  499. }
  500. if (persistent) {
  501. /*
  502. * A group ID is defined meaning we want to re-invoke a
  503. * persistant group
  504. */
  505. iface = wpas_dbus_new_decompose_object_path(pg_object_path, 1,
  506. &net_id_str, NULL);
  507. if (iface == NULL ||
  508. os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  509. reply = wpas_dbus_error_invalid_args(message,
  510. pg_object_path);
  511. goto out;
  512. }
  513. group_id = strtoul(net_id_str, NULL, 10);
  514. if (errno == EINVAL) {
  515. reply = wpas_dbus_error_invalid_args(
  516. message, pg_object_path);
  517. goto out;
  518. }
  519. /* Get the SSID structure form the persistant group id */
  520. ssid = wpa_config_get_network(wpa_s->conf, group_id);
  521. if (ssid == NULL || ssid->disabled != 2)
  522. goto err;
  523. if (wpas_p2p_invite(wpa_s, peer_addr, ssid, NULL) < 0) {
  524. reply = wpas_dbus_error_unknown_error(
  525. message,
  526. "Failed to reinvoke a persistent group");
  527. goto out;
  528. }
  529. } else {
  530. /*
  531. * No group ID means propose to a peer to join my active group
  532. */
  533. if (wpas_p2p_invite_group(wpa_s, wpa_s->ifname,
  534. peer_addr, NULL)) {
  535. reply = wpas_dbus_error_unknown_error(
  536. message, "Failed to join to an active group");
  537. goto out;
  538. }
  539. }
  540. out:
  541. os_free(pg_object_path);
  542. os_free(peer_object_path);
  543. return reply;
  544. err:
  545. reply = wpas_dbus_error_invalid_args(message, NULL);
  546. goto out;
  547. }
  548. DBusMessage * wpas_dbus_handler_p2p_prov_disc_req(DBusMessage *message,
  549. struct wpa_supplicant *wpa_s)
  550. {
  551. DBusMessageIter iter;
  552. char *peer_object_path = NULL;
  553. char *config_method = NULL;
  554. u8 peer_addr[ETH_ALEN];
  555. dbus_message_iter_init(message, &iter);
  556. dbus_message_iter_get_basic(&iter, &peer_object_path);
  557. if (parse_peer_object_path(peer_object_path, peer_addr) < 0)
  558. return wpas_dbus_error_invalid_args(message, NULL);
  559. dbus_message_iter_next(&iter);
  560. dbus_message_iter_get_basic(&iter, &config_method);
  561. /*
  562. * Validation checks on config_method are being duplicated here
  563. * to be able to return invalid args reply since the error code
  564. * from p2p module are not granular enough (yet).
  565. */
  566. if (os_strcmp(config_method, "display") &&
  567. os_strcmp(config_method, "keypad") &&
  568. os_strcmp(config_method, "pbc") &&
  569. os_strcmp(config_method, "pushbutton"))
  570. return wpas_dbus_error_invalid_args(message, NULL);
  571. if (wpas_p2p_prov_disc(wpa_s, peer_addr, config_method) < 0)
  572. return wpas_dbus_error_unknown_error(message,
  573. "Failed to send provision discovery request");
  574. return NULL;
  575. }
  576. /*
  577. * P2P Device property accessor methods.
  578. */
  579. dbus_bool_t wpas_dbus_getter_p2p_device_properties(DBusMessageIter *iter,
  580. DBusError *error,
  581. void *user_data)
  582. {
  583. struct wpa_supplicant *wpa_s = user_data;
  584. DBusMessageIter variant_iter, dict_iter;
  585. DBusMessageIter iter_secdev_dict_entry, iter_secdev_dict_val,
  586. iter_secdev_dict_array;
  587. const char *dev_name;
  588. int num_vendor_extensions = 0;
  589. int i;
  590. const struct wpabuf *vendor_ext[P2P_MAX_WPS_VENDOR_EXT];
  591. if (!wpa_dbus_p2p_check_enabled(wpa_s, NULL, NULL, error))
  592. return FALSE;
  593. if (!dbus_message_iter_open_container(iter, DBUS_TYPE_VARIANT,
  594. "a{sv}", &variant_iter) ||
  595. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  596. goto err_no_mem;
  597. /* DeviceName */
  598. dev_name = wpa_s->conf->device_name;
  599. if (dev_name &&
  600. !wpa_dbus_dict_append_string(&dict_iter, "DeviceName", dev_name))
  601. goto err_no_mem;
  602. /* Primary device type */
  603. if (!wpa_dbus_dict_append_byte_array(&dict_iter, "PrimaryDeviceType",
  604. (char *)wpa_s->conf->device_type,
  605. WPS_DEV_TYPE_LEN))
  606. goto err_no_mem;
  607. /* Secondary device types */
  608. if (wpa_s->conf->num_sec_device_types) {
  609. if (!wpa_dbus_dict_begin_array(&dict_iter,
  610. "SecondaryDeviceTypes",
  611. DBUS_TYPE_ARRAY_AS_STRING
  612. DBUS_TYPE_BYTE_AS_STRING,
  613. &iter_secdev_dict_entry,
  614. &iter_secdev_dict_val,
  615. &iter_secdev_dict_array))
  616. goto err_no_mem;
  617. for (i = 0; i < wpa_s->conf->num_sec_device_types; i++)
  618. wpa_dbus_dict_bin_array_add_element(
  619. &iter_secdev_dict_array,
  620. wpa_s->conf->sec_device_type[i],
  621. WPS_DEV_TYPE_LEN);
  622. if (!wpa_dbus_dict_end_array(&dict_iter,
  623. &iter_secdev_dict_entry,
  624. &iter_secdev_dict_val,
  625. &iter_secdev_dict_array))
  626. goto err_no_mem;
  627. }
  628. /* Vendor Extensions */
  629. for (i = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  630. if (wpa_s->conf->wps_vendor_ext[i] == NULL)
  631. continue;
  632. vendor_ext[num_vendor_extensions++] =
  633. wpa_s->conf->wps_vendor_ext[i];
  634. }
  635. if (num_vendor_extensions &&
  636. !wpa_dbus_dict_append_wpabuf_array(&dict_iter,
  637. "VendorExtension",
  638. vendor_ext,
  639. num_vendor_extensions))
  640. goto err_no_mem;
  641. /* GO Intent */
  642. if (!wpa_dbus_dict_append_uint32(&dict_iter, "GOIntent",
  643. wpa_s->conf->p2p_go_intent))
  644. goto err_no_mem;
  645. /* Persistant Reconnect */
  646. if (!wpa_dbus_dict_append_bool(&dict_iter, "PersistantReconnect",
  647. wpa_s->conf->persistent_reconnect))
  648. goto err_no_mem;
  649. /* Listen Reg Class */
  650. if (!wpa_dbus_dict_append_uint32(&dict_iter, "ListenRegClass",
  651. wpa_s->conf->p2p_listen_reg_class))
  652. goto err_no_mem;
  653. /* Listen Channel */
  654. if (!wpa_dbus_dict_append_uint32(&dict_iter, "ListenChannel",
  655. wpa_s->conf->p2p_listen_channel))
  656. goto err_no_mem;
  657. /* Oper Reg Class */
  658. if (!wpa_dbus_dict_append_uint32(&dict_iter, "OperRegClass",
  659. wpa_s->conf->p2p_oper_reg_class))
  660. goto err_no_mem;
  661. /* Oper Channel */
  662. if (!wpa_dbus_dict_append_uint32(&dict_iter, "OperChannel",
  663. wpa_s->conf->p2p_oper_channel))
  664. goto err_no_mem;
  665. /* SSID Postfix */
  666. if (wpa_s->conf->p2p_ssid_postfix &&
  667. !wpa_dbus_dict_append_string(&dict_iter, "SsidPostfix",
  668. wpa_s->conf->p2p_ssid_postfix))
  669. goto err_no_mem;
  670. /* Intra Bss */
  671. if (!wpa_dbus_dict_append_bool(&dict_iter, "IntraBss",
  672. wpa_s->conf->p2p_intra_bss))
  673. goto err_no_mem;
  674. /* Group Idle */
  675. if (!wpa_dbus_dict_append_uint32(&dict_iter, "GroupIdle",
  676. wpa_s->conf->p2p_group_idle))
  677. goto err_no_mem;
  678. /* Dissasociation low ack */
  679. if (!wpa_dbus_dict_append_uint32(&dict_iter, "disassoc_low_ack",
  680. wpa_s->conf->disassoc_low_ack))
  681. goto err_no_mem;
  682. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  683. !dbus_message_iter_close_container(iter, &variant_iter))
  684. goto err_no_mem;
  685. return TRUE;
  686. err_no_mem:
  687. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  688. return FALSE;
  689. }
  690. dbus_bool_t wpas_dbus_setter_p2p_device_properties(DBusMessageIter *iter,
  691. DBusError *error,
  692. void *user_data)
  693. {
  694. struct wpa_supplicant *wpa_s = user_data;
  695. DBusMessageIter variant_iter, iter_dict;
  696. struct wpa_dbus_dict_entry entry = {.type = DBUS_TYPE_STRING };
  697. unsigned int i;
  698. if (!wpa_dbus_p2p_check_enabled(wpa_s, NULL, NULL, error))
  699. return FALSE;
  700. dbus_message_iter_recurse(iter, &variant_iter);
  701. if (!wpa_dbus_dict_open_read(&variant_iter, &iter_dict, error))
  702. return FALSE;
  703. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  704. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry)) {
  705. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  706. "invalid message format");
  707. return FALSE;
  708. }
  709. if (os_strcmp(entry.key, "DeviceName") == 0) {
  710. char *devname;
  711. if (entry.type != DBUS_TYPE_STRING)
  712. goto error;
  713. devname = os_strdup(entry.str_value);
  714. if (devname == NULL)
  715. goto err_no_mem_clear;
  716. os_free(wpa_s->conf->device_name);
  717. wpa_s->conf->device_name = devname;
  718. wpa_s->conf->changed_parameters |=
  719. CFG_CHANGED_DEVICE_NAME;
  720. } else if (os_strcmp(entry.key, "PrimaryDeviceType") == 0) {
  721. if (entry.type != DBUS_TYPE_ARRAY ||
  722. entry.array_type != DBUS_TYPE_BYTE ||
  723. entry.array_len != WPS_DEV_TYPE_LEN)
  724. goto error;
  725. os_memcpy(wpa_s->conf->device_type,
  726. entry.bytearray_value,
  727. WPS_DEV_TYPE_LEN);
  728. wpa_s->conf->changed_parameters |=
  729. CFG_CHANGED_DEVICE_TYPE;
  730. } else if (os_strcmp(entry.key, "SecondaryDeviceTypes") == 0) {
  731. if (entry.type != DBUS_TYPE_ARRAY ||
  732. entry.array_type != WPAS_DBUS_TYPE_BINARRAY ||
  733. entry.array_len > MAX_SEC_DEVICE_TYPES)
  734. goto error;
  735. for (i = 0; i < entry.array_len; i++)
  736. if (wpabuf_len(entry.binarray_value[i]) !=
  737. WPS_DEV_TYPE_LEN)
  738. goto err_no_mem_clear;
  739. for (i = 0; i < entry.array_len; i++)
  740. os_memcpy(wpa_s->conf->sec_device_type[i],
  741. wpabuf_head(entry.binarray_value[i]),
  742. WPS_DEV_TYPE_LEN);
  743. wpa_s->conf->num_sec_device_types = entry.array_len;
  744. wpa_s->conf->changed_parameters |=
  745. CFG_CHANGED_SEC_DEVICE_TYPE;
  746. } else if (os_strcmp(entry.key, "VendorExtension") == 0) {
  747. if ((entry.type != DBUS_TYPE_ARRAY) ||
  748. (entry.array_type != WPAS_DBUS_TYPE_BINARRAY) ||
  749. (entry.array_len > P2P_MAX_WPS_VENDOR_EXT))
  750. goto error;
  751. wpa_s->conf->changed_parameters |=
  752. CFG_CHANGED_VENDOR_EXTENSION;
  753. for (i = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  754. wpabuf_free(wpa_s->conf->wps_vendor_ext[i]);
  755. if (i < entry.array_len) {
  756. wpa_s->conf->wps_vendor_ext[i] =
  757. entry.binarray_value[i];
  758. entry.binarray_value[i] = NULL;
  759. } else
  760. wpa_s->conf->wps_vendor_ext[i] = NULL;
  761. }
  762. } else if ((os_strcmp(entry.key, "GOIntent") == 0) &&
  763. (entry.type == DBUS_TYPE_UINT32) &&
  764. (entry.uint32_value <= 15))
  765. wpa_s->conf->p2p_go_intent = entry.uint32_value;
  766. else if ((os_strcmp(entry.key, "PersistantReconnect") == 0) &&
  767. (entry.type == DBUS_TYPE_BOOLEAN))
  768. wpa_s->conf->persistent_reconnect = entry.bool_value;
  769. else if ((os_strcmp(entry.key, "ListenRegClass") == 0) &&
  770. (entry.type == DBUS_TYPE_UINT32)) {
  771. wpa_s->conf->p2p_listen_reg_class = entry.uint32_value;
  772. wpa_s->conf->changed_parameters |=
  773. CFG_CHANGED_P2P_LISTEN_CHANNEL;
  774. } else if ((os_strcmp(entry.key, "ListenChannel") == 0) &&
  775. (entry.type == DBUS_TYPE_UINT32)) {
  776. wpa_s->conf->p2p_listen_channel = entry.uint32_value;
  777. wpa_s->conf->changed_parameters |=
  778. CFG_CHANGED_P2P_LISTEN_CHANNEL;
  779. } else if ((os_strcmp(entry.key, "OperRegClass") == 0) &&
  780. (entry.type == DBUS_TYPE_UINT32)) {
  781. wpa_s->conf->p2p_oper_reg_class = entry.uint32_value;
  782. wpa_s->conf->changed_parameters |=
  783. CFG_CHANGED_P2P_OPER_CHANNEL;
  784. } else if ((os_strcmp(entry.key, "OperChannel") == 0) &&
  785. (entry.type == DBUS_TYPE_UINT32)) {
  786. wpa_s->conf->p2p_oper_channel = entry.uint32_value;
  787. wpa_s->conf->changed_parameters |=
  788. CFG_CHANGED_P2P_OPER_CHANNEL;
  789. } else if (os_strcmp(entry.key, "SsidPostfix") == 0) {
  790. char *postfix;
  791. if (entry.type != DBUS_TYPE_STRING)
  792. goto error;
  793. postfix = os_strdup(entry.str_value);
  794. if (!postfix)
  795. goto err_no_mem_clear;
  796. os_free(wpa_s->conf->p2p_ssid_postfix);
  797. wpa_s->conf->p2p_ssid_postfix = postfix;
  798. wpa_s->conf->changed_parameters |=
  799. CFG_CHANGED_P2P_SSID_POSTFIX;
  800. } else if ((os_strcmp(entry.key, "IntraBss") == 0) &&
  801. (entry.type == DBUS_TYPE_BOOLEAN)) {
  802. wpa_s->conf->p2p_intra_bss = entry.bool_value;
  803. wpa_s->conf->changed_parameters |=
  804. CFG_CHANGED_P2P_INTRA_BSS;
  805. } else if ((os_strcmp(entry.key, "GroupIdle") == 0) &&
  806. (entry.type == DBUS_TYPE_UINT32))
  807. wpa_s->conf->p2p_group_idle = entry.uint32_value;
  808. else if (os_strcmp(entry.key, "disassoc_low_ack") == 0 &&
  809. entry.type == DBUS_TYPE_UINT32)
  810. wpa_s->conf->disassoc_low_ack = entry.uint32_value;
  811. else
  812. goto error;
  813. wpa_dbus_dict_entry_clear(&entry);
  814. }
  815. if (wpa_s->conf->changed_parameters) {
  816. /* Some changed parameters requires to update config*/
  817. wpa_supplicant_update_config(wpa_s);
  818. }
  819. return TRUE;
  820. error:
  821. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  822. "invalid message format");
  823. wpa_dbus_dict_entry_clear(&entry);
  824. return FALSE;
  825. err_no_mem_clear:
  826. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  827. wpa_dbus_dict_entry_clear(&entry);
  828. return FALSE;
  829. }
  830. dbus_bool_t wpas_dbus_getter_p2p_peers(DBusMessageIter *iter, DBusError *error,
  831. void *user_data)
  832. {
  833. struct wpa_supplicant *wpa_s = user_data;
  834. struct p2p_data *p2p = wpa_s->global->p2p;
  835. int next = 0, i = 0;
  836. int num = 0, out_of_mem = 0;
  837. const u8 *addr;
  838. const struct p2p_peer_info *peer_info = NULL;
  839. dbus_bool_t success = FALSE;
  840. struct dl_list peer_objpath_list;
  841. struct peer_objpath_node {
  842. struct dl_list list;
  843. char path[WPAS_DBUS_OBJECT_PATH_MAX];
  844. } *node, *tmp;
  845. char **peer_obj_paths = NULL;
  846. if (!wpa_dbus_p2p_check_enabled(wpa_s, NULL, NULL, error))
  847. return FALSE;
  848. dl_list_init(&peer_objpath_list);
  849. /* Get the first peer info */
  850. peer_info = p2p_get_peer_found(p2p, NULL, next);
  851. /* Get next and accumulate them */
  852. next = 1;
  853. while (peer_info != NULL) {
  854. node = os_zalloc(sizeof(struct peer_objpath_node));
  855. if (!node) {
  856. out_of_mem = 1;
  857. goto error;
  858. }
  859. addr = peer_info->p2p_device_addr;
  860. os_snprintf(node->path, WPAS_DBUS_OBJECT_PATH_MAX,
  861. "%s/" WPAS_DBUS_NEW_P2P_PEERS_PART
  862. "/" COMPACT_MACSTR,
  863. wpa_s->dbus_new_path, MAC2STR(addr));
  864. dl_list_add_tail(&peer_objpath_list, &node->list);
  865. num++;
  866. peer_info = p2p_get_peer_found(p2p, addr, next);
  867. }
  868. /*
  869. * Now construct the peer object paths in a form suitable for
  870. * array_property_getter helper below.
  871. */
  872. peer_obj_paths = os_zalloc(num * sizeof(char *));
  873. if (!peer_obj_paths) {
  874. out_of_mem = 1;
  875. goto error;
  876. }
  877. dl_list_for_each_safe(node, tmp, &peer_objpath_list,
  878. struct peer_objpath_node, list)
  879. peer_obj_paths[i++] = node->path;
  880. success = wpas_dbus_simple_array_property_getter(iter,
  881. DBUS_TYPE_OBJECT_PATH,
  882. peer_obj_paths, num,
  883. error);
  884. error:
  885. if (peer_obj_paths)
  886. os_free(peer_obj_paths);
  887. dl_list_for_each_safe(node, tmp, &peer_objpath_list,
  888. struct peer_objpath_node, list) {
  889. dl_list_del(&node->list);
  890. os_free(node);
  891. }
  892. if (out_of_mem)
  893. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  894. return success;
  895. }
  896. enum wpas_p2p_role {
  897. WPAS_P2P_ROLE_DEVICE,
  898. WPAS_P2P_ROLE_GO,
  899. WPAS_P2P_ROLE_CLIENT,
  900. };
  901. static enum wpas_p2p_role wpas_get_p2p_role(struct wpa_supplicant *wpa_s)
  902. {
  903. struct wpa_ssid *ssid = wpa_s->current_ssid;
  904. if (!ssid)
  905. return WPAS_P2P_ROLE_DEVICE;
  906. if (wpa_s->wpa_state != WPA_COMPLETED)
  907. return WPAS_P2P_ROLE_DEVICE;
  908. switch (ssid->mode) {
  909. case WPAS_MODE_P2P_GO:
  910. case WPAS_MODE_P2P_GROUP_FORMATION:
  911. return WPAS_P2P_ROLE_GO;
  912. case WPAS_MODE_INFRA:
  913. if (ssid->p2p_group)
  914. return WPAS_P2P_ROLE_CLIENT;
  915. return WPAS_P2P_ROLE_DEVICE;
  916. default:
  917. return WPAS_P2P_ROLE_DEVICE;
  918. }
  919. }
  920. dbus_bool_t wpas_dbus_getter_p2p_role(DBusMessageIter *iter, DBusError *error,
  921. void *user_data)
  922. {
  923. struct wpa_supplicant *wpa_s = user_data;
  924. char *str;
  925. switch (wpas_get_p2p_role(wpa_s)) {
  926. case WPAS_P2P_ROLE_GO:
  927. str = "GO";
  928. break;
  929. case WPAS_P2P_ROLE_CLIENT:
  930. str = "client";
  931. break;
  932. default:
  933. str = "device";
  934. }
  935. return wpas_dbus_simple_property_getter(iter, DBUS_TYPE_STRING, &str,
  936. error);
  937. }
  938. dbus_bool_t wpas_dbus_getter_p2p_group(DBusMessageIter *iter, DBusError *error,
  939. void *user_data)
  940. {
  941. struct wpa_supplicant *wpa_s = user_data;
  942. if (wpa_s->dbus_groupobj_path == NULL)
  943. return FALSE;
  944. return wpas_dbus_simple_property_getter(iter, DBUS_TYPE_OBJECT_PATH,
  945. &wpa_s->dbus_groupobj_path,
  946. error);
  947. }
  948. dbus_bool_t wpas_dbus_getter_p2p_peergo(DBusMessageIter *iter,
  949. DBusError *error, void *user_data)
  950. {
  951. struct wpa_supplicant *wpa_s = user_data;
  952. char go_peer_obj_path[WPAS_DBUS_OBJECT_PATH_MAX], *path;
  953. if (wpas_get_p2p_role(wpa_s) != WPAS_P2P_ROLE_CLIENT)
  954. return FALSE;
  955. os_snprintf(go_peer_obj_path, WPAS_DBUS_OBJECT_PATH_MAX,
  956. "%s/" WPAS_DBUS_NEW_P2P_PEERS_PART "/" COMPACT_MACSTR,
  957. wpa_s->dbus_new_path, MAC2STR(wpa_s->go_dev_addr));
  958. path = go_peer_obj_path;
  959. return wpas_dbus_simple_property_getter(iter, DBUS_TYPE_OBJECT_PATH,
  960. &path, error);
  961. }
  962. /*
  963. * Peer object properties accessor methods
  964. */
  965. dbus_bool_t wpas_dbus_getter_p2p_peer_properties(DBusMessageIter *iter,
  966. DBusError *error, void *user_data)
  967. {
  968. struct peer_handler_args *peer_args = user_data;
  969. DBusMessageIter variant_iter, dict_iter;
  970. const struct p2p_peer_info *info = NULL;
  971. const struct wpabuf *vendor_extension[P2P_MAX_WPS_VENDOR_EXT];
  972. int i, num;
  973. if (!wpa_dbus_p2p_check_enabled(peer_args->wpa_s, NULL, NULL, error))
  974. return FALSE;
  975. /* get the peer info */
  976. info = p2p_get_peer_found(peer_args->wpa_s->global->p2p,
  977. peer_args->p2p_device_addr, 0);
  978. if (info == NULL) {
  979. dbus_set_error(error, DBUS_ERROR_FAILED, "failed to find peer");
  980. return FALSE;
  981. }
  982. if (!dbus_message_iter_open_container(iter, DBUS_TYPE_VARIANT,
  983. "a{sv}", &variant_iter) ||
  984. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  985. goto err_no_mem;
  986. /* Fill out the dictionary */
  987. if (!wpa_dbus_dict_append_string(&dict_iter, "DeviceName",
  988. info->device_name))
  989. goto err_no_mem;
  990. if (!wpa_dbus_dict_append_byte_array(&dict_iter, "PrimaryDeviceType",
  991. (char *)info->pri_dev_type,
  992. WPS_DEV_TYPE_LEN))
  993. goto err_no_mem;
  994. if (!wpa_dbus_dict_append_uint16(&dict_iter, "config_method",
  995. info->config_methods))
  996. goto err_no_mem;
  997. if (!wpa_dbus_dict_append_int32(&dict_iter, "level",
  998. info->level))
  999. goto err_no_mem;
  1000. if (!wpa_dbus_dict_append_byte(&dict_iter, "devicecapability",
  1001. info->dev_capab))
  1002. goto err_no_mem;
  1003. if (!wpa_dbus_dict_append_byte(&dict_iter, "groupcapability",
  1004. info->group_capab))
  1005. goto err_no_mem;
  1006. if (info->wps_sec_dev_type_list_len) {
  1007. const u8 *sec_dev_type_list = info->wps_sec_dev_type_list;
  1008. int num_sec_dev_types =
  1009. info->wps_sec_dev_type_list_len / WPS_DEV_TYPE_LEN;
  1010. DBusMessageIter iter_secdev_dict_entry, iter_secdev_dict_val,
  1011. iter_secdev_dict_array;
  1012. if (num_sec_dev_types) {
  1013. if (!wpa_dbus_dict_begin_array(&dict_iter,
  1014. "SecondaryDeviceTypes",
  1015. DBUS_TYPE_ARRAY_AS_STRING
  1016. DBUS_TYPE_BYTE_AS_STRING,
  1017. &iter_secdev_dict_entry,
  1018. &iter_secdev_dict_val,
  1019. &iter_secdev_dict_array))
  1020. goto err_no_mem;
  1021. for (i = 0; i < num_sec_dev_types; i++) {
  1022. wpa_dbus_dict_bin_array_add_element(
  1023. &iter_secdev_dict_array,
  1024. sec_dev_type_list,
  1025. WPS_DEV_TYPE_LEN);
  1026. sec_dev_type_list += WPS_DEV_TYPE_LEN;
  1027. }
  1028. if (!wpa_dbus_dict_end_array(&dict_iter,
  1029. &iter_secdev_dict_entry,
  1030. &iter_secdev_dict_val,
  1031. &iter_secdev_dict_array))
  1032. goto err_no_mem;
  1033. }
  1034. }
  1035. /* Add WPS vendor extensions attribute */
  1036. for (i = 0, num = 0; i < P2P_MAX_WPS_VENDOR_EXT; i++) {
  1037. if (info->wps_vendor_ext[i] == NULL)
  1038. continue;
  1039. vendor_extension[num] = info->wps_vendor_ext[i];
  1040. num++;
  1041. }
  1042. if (!wpa_dbus_dict_append_wpabuf_array(&dict_iter, "VendorExtension",
  1043. vendor_extension, num))
  1044. goto err_no_mem;
  1045. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  1046. !dbus_message_iter_close_container(iter, &variant_iter))
  1047. goto err_no_mem;
  1048. return TRUE;
  1049. err_no_mem:
  1050. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1051. return FALSE;
  1052. }
  1053. dbus_bool_t wpas_dbus_getter_p2p_peer_ies(DBusMessageIter *iter,
  1054. DBusError *error, void *user_data)
  1055. {
  1056. /* struct peer_handler_args *peer_args = user_data; */
  1057. dbus_set_error_const(error, DBUS_ERROR_FAILED, "not implemented");
  1058. return FALSE;
  1059. }
  1060. /**
  1061. * wpas_dbus_getter_persistent_groups - Get array of peristent group objects
  1062. * @iter: Pointer to incoming dbus message iter
  1063. * @error: Location to store error on failure
  1064. * @user_data: Function specific data
  1065. * Returns: TRUE on success, FALSE on failure
  1066. *
  1067. * Getter for "PersistentGroups" property.
  1068. */
  1069. dbus_bool_t wpas_dbus_getter_persistent_groups(DBusMessageIter *iter,
  1070. DBusError *error,
  1071. void *user_data)
  1072. {
  1073. struct wpa_supplicant *wpa_s = user_data;
  1074. struct wpa_ssid *ssid;
  1075. char **paths;
  1076. unsigned int i = 0, num = 0;
  1077. dbus_bool_t success = FALSE;
  1078. if (wpa_s->conf == NULL) {
  1079. wpa_printf(MSG_ERROR, "dbus: %s: "
  1080. "An error occurred getting persistent groups list",
  1081. __func__);
  1082. dbus_set_error_const(error, DBUS_ERROR_FAILED, "an error "
  1083. "occurred getting persistent groups list");
  1084. return FALSE;
  1085. }
  1086. for (ssid = wpa_s->conf->ssid; ssid; ssid = ssid->next)
  1087. if (network_is_persistent_group(ssid))
  1088. num++;
  1089. paths = os_zalloc(num * sizeof(char *));
  1090. if (!paths) {
  1091. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1092. return FALSE;
  1093. }
  1094. /* Loop through configured networks and append object path of each */
  1095. for (ssid = wpa_s->conf->ssid; ssid; ssid = ssid->next) {
  1096. if (!network_is_persistent_group(ssid))
  1097. continue;
  1098. paths[i] = os_zalloc(WPAS_DBUS_OBJECT_PATH_MAX);
  1099. if (paths[i] == NULL) {
  1100. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY,
  1101. "no memory");
  1102. goto out;
  1103. }
  1104. /* Construct the object path for this network. */
  1105. os_snprintf(paths[i++], WPAS_DBUS_OBJECT_PATH_MAX,
  1106. "%s/" WPAS_DBUS_NEW_PERSISTENT_GROUPS_PART "/%d",
  1107. wpa_s->dbus_new_path, ssid->id);
  1108. }
  1109. success = wpas_dbus_simple_array_property_getter(iter,
  1110. DBUS_TYPE_OBJECT_PATH,
  1111. paths, num, error);
  1112. out:
  1113. while (i)
  1114. os_free(paths[--i]);
  1115. os_free(paths);
  1116. return success;
  1117. }
  1118. /**
  1119. * wpas_dbus_getter_persistent_group_properties - Get options for a persistent
  1120. * group
  1121. * @iter: Pointer to incoming dbus message iter
  1122. * @error: Location to store error on failure
  1123. * @user_data: Function specific data
  1124. * Returns: TRUE on success, FALSE on failure
  1125. *
  1126. * Getter for "Properties" property of a persistent group.
  1127. */
  1128. dbus_bool_t wpas_dbus_getter_persistent_group_properties(DBusMessageIter *iter,
  1129. DBusError *error,
  1130. void *user_data)
  1131. {
  1132. struct network_handler_args *net = user_data;
  1133. /* Leveraging the fact that persistent group object is still
  1134. * represented in same manner as network within.
  1135. */
  1136. return wpas_dbus_getter_network_properties(iter, error, net);
  1137. }
  1138. /**
  1139. * wpas_dbus_setter_persistent_group_properties - Get options for a persistent
  1140. * group
  1141. * @iter: Pointer to incoming dbus message iter
  1142. * @error: Location to store error on failure
  1143. * @user_data: Function specific data
  1144. * Returns: TRUE on success, FALSE on failure
  1145. *
  1146. * Setter for "Properties" property of a persistent group.
  1147. */
  1148. dbus_bool_t wpas_dbus_setter_persistent_group_properties(DBusMessageIter *iter,
  1149. DBusError *error,
  1150. void *user_data)
  1151. {
  1152. struct network_handler_args *net = user_data;
  1153. struct wpa_ssid *ssid = net->ssid;
  1154. DBusMessageIter variant_iter;
  1155. /*
  1156. * Leveraging the fact that persistent group object is still
  1157. * represented in same manner as network within.
  1158. */
  1159. dbus_message_iter_recurse(iter, &variant_iter);
  1160. return set_network_properties(net->wpa_s, ssid, &variant_iter, error);
  1161. }
  1162. /**
  1163. * wpas_dbus_new_iface_add_persistent_group - Add a new configured
  1164. * persistent_group
  1165. * @message: Pointer to incoming dbus message
  1166. * @wpa_s: wpa_supplicant structure for a network interface
  1167. * Returns: A dbus message containing the object path of the new
  1168. * persistent group
  1169. *
  1170. * Handler function for "AddPersistentGroup" method call of a P2P Device
  1171. * interface.
  1172. */
  1173. DBusMessage * wpas_dbus_handler_add_persistent_group(
  1174. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1175. {
  1176. DBusMessage *reply = NULL;
  1177. DBusMessageIter iter;
  1178. struct wpa_ssid *ssid = NULL;
  1179. char path_buf[WPAS_DBUS_OBJECT_PATH_MAX], *path = path_buf;
  1180. DBusError error;
  1181. dbus_message_iter_init(message, &iter);
  1182. ssid = wpa_config_add_network(wpa_s->conf);
  1183. if (ssid == NULL) {
  1184. wpa_printf(MSG_ERROR, "dbus: %s: "
  1185. "Cannot add new persistent group", __func__);
  1186. reply = wpas_dbus_error_unknown_error(
  1187. message,
  1188. "wpa_supplicant could not add "
  1189. "a persistent group on this interface.");
  1190. goto err;
  1191. }
  1192. /* Mark the ssid as being a persistent group before the notification */
  1193. ssid->disabled = 2;
  1194. ssid->p2p_persistent_group = 1;
  1195. wpas_notify_persistent_group_added(wpa_s, ssid);
  1196. wpa_config_set_network_defaults(ssid);
  1197. dbus_error_init(&error);
  1198. if (!set_network_properties(wpa_s, ssid, &iter, &error)) {
  1199. wpa_printf(MSG_DEBUG, "dbus: %s: "
  1200. "Control interface could not set persistent group "
  1201. "properties", __func__);
  1202. reply = wpas_dbus_reply_new_from_error(message, &error,
  1203. DBUS_ERROR_INVALID_ARGS,
  1204. "Failed to set network "
  1205. "properties");
  1206. dbus_error_free(&error);
  1207. goto err;
  1208. }
  1209. /* Construct the object path for this network. */
  1210. os_snprintf(path, WPAS_DBUS_OBJECT_PATH_MAX,
  1211. "%s/" WPAS_DBUS_NEW_PERSISTENT_GROUPS_PART "/%d",
  1212. wpa_s->dbus_new_path, ssid->id);
  1213. reply = dbus_message_new_method_return(message);
  1214. if (reply == NULL) {
  1215. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1216. NULL);
  1217. goto err;
  1218. }
  1219. if (!dbus_message_append_args(reply, DBUS_TYPE_OBJECT_PATH, &path,
  1220. DBUS_TYPE_INVALID)) {
  1221. dbus_message_unref(reply);
  1222. reply = dbus_message_new_error(message, DBUS_ERROR_NO_MEMORY,
  1223. NULL);
  1224. goto err;
  1225. }
  1226. return reply;
  1227. err:
  1228. if (ssid) {
  1229. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1230. wpa_config_remove_network(wpa_s->conf, ssid->id);
  1231. }
  1232. return reply;
  1233. }
  1234. /**
  1235. * wpas_dbus_handler_remove_persistent_group - Remove a configured persistent
  1236. * group
  1237. * @message: Pointer to incoming dbus message
  1238. * @wpa_s: wpa_supplicant structure for a network interface
  1239. * Returns: NULL on success or dbus error on failure
  1240. *
  1241. * Handler function for "RemovePersistentGroup" method call of a P2P Device
  1242. * interface.
  1243. */
  1244. DBusMessage * wpas_dbus_handler_remove_persistent_group(
  1245. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1246. {
  1247. DBusMessage *reply = NULL;
  1248. const char *op;
  1249. char *iface = NULL, *persistent_group_id = NULL;
  1250. int id;
  1251. struct wpa_ssid *ssid;
  1252. dbus_message_get_args(message, NULL, DBUS_TYPE_OBJECT_PATH, &op,
  1253. DBUS_TYPE_INVALID);
  1254. /*
  1255. * Extract the network ID and ensure the network is actually a child of
  1256. * this interface.
  1257. */
  1258. iface = wpas_dbus_new_decompose_object_path(op, 1,
  1259. &persistent_group_id,
  1260. NULL);
  1261. if (iface == NULL || os_strcmp(iface, wpa_s->dbus_new_path) != 0) {
  1262. reply = wpas_dbus_error_invalid_args(message, op);
  1263. goto out;
  1264. }
  1265. id = strtoul(persistent_group_id, NULL, 10);
  1266. if (errno == EINVAL) {
  1267. reply = wpas_dbus_error_invalid_args(message, op);
  1268. goto out;
  1269. }
  1270. ssid = wpa_config_get_network(wpa_s->conf, id);
  1271. if (ssid == NULL) {
  1272. reply = wpas_dbus_error_persistent_group_unknown(message);
  1273. goto out;
  1274. }
  1275. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1276. if (wpa_config_remove_network(wpa_s->conf, id) < 0) {
  1277. wpa_printf(MSG_ERROR, "dbus: %s: "
  1278. "error occurred when removing persistent group %d",
  1279. __func__, id);
  1280. reply = wpas_dbus_error_unknown_error(
  1281. message,
  1282. "error removing the specified persistent group on "
  1283. "this interface.");
  1284. goto out;
  1285. }
  1286. out:
  1287. os_free(iface);
  1288. os_free(persistent_group_id);
  1289. return reply;
  1290. }
  1291. static void remove_persistent_group(struct wpa_supplicant *wpa_s,
  1292. struct wpa_ssid *ssid)
  1293. {
  1294. wpas_notify_persistent_group_removed(wpa_s, ssid);
  1295. if (wpa_config_remove_network(wpa_s->conf, ssid->id) < 0) {
  1296. wpa_printf(MSG_ERROR, "dbus: %s: "
  1297. "error occurred when removing persistent group %d",
  1298. __func__, ssid->id);
  1299. return;
  1300. }
  1301. }
  1302. /**
  1303. * wpas_dbus_handler_remove_all_persistent_groups - Remove all configured
  1304. * persistent groups
  1305. * @message: Pointer to incoming dbus message
  1306. * @wpa_s: wpa_supplicant structure for a network interface
  1307. * Returns: NULL on success or dbus error on failure
  1308. *
  1309. * Handler function for "RemoveAllPersistentGroups" method call of a
  1310. * P2P Device interface.
  1311. */
  1312. DBusMessage * wpas_dbus_handler_remove_all_persistent_groups(
  1313. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1314. {
  1315. struct wpa_ssid *ssid, *next;
  1316. struct wpa_config *config;
  1317. config = wpa_s->conf;
  1318. ssid = config->ssid;
  1319. while (ssid) {
  1320. next = ssid->next;
  1321. if (network_is_persistent_group(ssid))
  1322. remove_persistent_group(wpa_s, ssid);
  1323. ssid = next;
  1324. }
  1325. return NULL;
  1326. }
  1327. /*
  1328. * Group object properties accessor methods
  1329. */
  1330. dbus_bool_t wpas_dbus_getter_p2p_group_members(DBusMessageIter *iter,
  1331. DBusError *error,
  1332. void *user_data)
  1333. {
  1334. struct wpa_supplicant *wpa_s = user_data;
  1335. struct wpa_ssid *ssid;
  1336. unsigned int num_members;
  1337. char **paths;
  1338. unsigned int i;
  1339. void *next = NULL;
  1340. const u8 *addr;
  1341. dbus_bool_t success = FALSE;
  1342. /* Ensure we are a GO */
  1343. if (wpa_s->wpa_state != WPA_COMPLETED)
  1344. return FALSE;
  1345. ssid = wpa_s->conf->ssid;
  1346. /* At present WPAS P2P_GO mode only applicable for p2p_go */
  1347. if (ssid->mode != WPAS_MODE_P2P_GO &&
  1348. ssid->mode != WPAS_MODE_AP &&
  1349. ssid->mode != WPAS_MODE_P2P_GROUP_FORMATION)
  1350. return FALSE;
  1351. num_members = p2p_get_group_num_members(wpa_s->p2p_group);
  1352. paths = os_zalloc(num_members * sizeof(char *));
  1353. if (!paths)
  1354. goto out_of_memory;
  1355. i = 0;
  1356. while ((addr = p2p_iterate_group_members(wpa_s->p2p_group, &next))) {
  1357. paths[i] = os_zalloc(WPAS_DBUS_OBJECT_PATH_MAX);
  1358. if (!paths[i])
  1359. goto out_of_memory;
  1360. os_snprintf(paths[i], WPAS_DBUS_OBJECT_PATH_MAX,
  1361. "%s/" WPAS_DBUS_NEW_P2P_GROUPMEMBERS_PART
  1362. "/" COMPACT_MACSTR,
  1363. wpa_s->dbus_groupobj_path, MAC2STR(addr));
  1364. i++;
  1365. }
  1366. success = wpas_dbus_simple_array_property_getter(iter,
  1367. DBUS_TYPE_OBJECT_PATH,
  1368. paths, num_members,
  1369. error);
  1370. for (i = 0; i < num_members; i++)
  1371. os_free(paths[i]);
  1372. os_free(paths);
  1373. return success;
  1374. out_of_memory:
  1375. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1376. if (paths) {
  1377. for (i = 0; i < num_members; i++)
  1378. os_free(paths[i]);
  1379. os_free(paths);
  1380. }
  1381. return FALSE;
  1382. }
  1383. dbus_bool_t wpas_dbus_getter_p2p_group_properties(DBusMessageIter *iter,
  1384. DBusError *error,
  1385. void *user_data)
  1386. {
  1387. struct wpa_supplicant *wpa_s = user_data;
  1388. DBusMessageIter variant_iter, dict_iter;
  1389. struct hostapd_data *hapd = wpa_s->ap_iface->bss[0];
  1390. const struct wpabuf *vendor_ext[MAX_WPS_VENDOR_EXTENSIONS];
  1391. int num_vendor_ext = 0;
  1392. int i;
  1393. if (!hapd) {
  1394. dbus_set_error_const(error, DBUS_ERROR_FAILED,
  1395. "internal error");
  1396. return FALSE;
  1397. }
  1398. if (!dbus_message_iter_open_container(iter, DBUS_TYPE_VARIANT,
  1399. "a{sv}", &variant_iter) ||
  1400. !wpa_dbus_dict_open_write(&variant_iter, &dict_iter))
  1401. goto err_no_mem;
  1402. /* Parse WPS Vendor Extensions sent in Beacon/Probe Response */
  1403. for (i = 0; i < MAX_WPS_VENDOR_EXTENSIONS; i++) {
  1404. if (hapd->conf->wps_vendor_ext[i] == NULL)
  1405. continue;
  1406. vendor_ext[num_vendor_ext++] = hapd->conf->wps_vendor_ext[i];
  1407. }
  1408. if (!wpa_dbus_dict_append_wpabuf_array(&dict_iter,
  1409. "WPSVendorExtensions",
  1410. vendor_ext, num_vendor_ext))
  1411. goto err_no_mem;
  1412. if (!wpa_dbus_dict_close_write(&variant_iter, &dict_iter) ||
  1413. !dbus_message_iter_close_container(iter, &variant_iter))
  1414. goto err_no_mem;
  1415. return TRUE;
  1416. err_no_mem:
  1417. dbus_set_error_const(error, DBUS_ERROR_NO_MEMORY, "no memory");
  1418. return FALSE;
  1419. }
  1420. dbus_bool_t wpas_dbus_setter_p2p_group_properties(DBusMessageIter *iter,
  1421. DBusError *error,
  1422. void *user_data)
  1423. {
  1424. struct wpa_supplicant *wpa_s = user_data;
  1425. DBusMessageIter variant_iter, iter_dict;
  1426. struct wpa_dbus_dict_entry entry = { .type = DBUS_TYPE_STRING };
  1427. unsigned int i;
  1428. struct hostapd_data *hapd = wpa_s->ap_iface->bss[0];
  1429. if (!hapd) {
  1430. dbus_set_error_const(error, DBUS_ERROR_FAILED,
  1431. "internal error");
  1432. return FALSE;
  1433. }
  1434. dbus_message_iter_recurse(iter, &variant_iter);
  1435. if (!wpa_dbus_dict_open_read(&variant_iter, &iter_dict, error))
  1436. return FALSE;
  1437. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1438. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry)) {
  1439. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  1440. "invalid message format");
  1441. return FALSE;
  1442. }
  1443. if (os_strcmp(entry.key, "WPSVendorExtensions") == 0) {
  1444. if (entry.type != DBUS_TYPE_ARRAY ||
  1445. entry.array_type != WPAS_DBUS_TYPE_BINARRAY ||
  1446. entry.array_len > MAX_WPS_VENDOR_EXTENSIONS)
  1447. goto error;
  1448. for (i = 0; i < MAX_WPS_VENDOR_EXTENSIONS; i++) {
  1449. if (i < entry.array_len) {
  1450. hapd->conf->wps_vendor_ext[i] =
  1451. entry.binarray_value[i];
  1452. entry.binarray_value[i] = NULL;
  1453. } else
  1454. hapd->conf->wps_vendor_ext[i] = NULL;
  1455. }
  1456. hostapd_update_wps(hapd);
  1457. } else
  1458. goto error;
  1459. wpa_dbus_dict_entry_clear(&entry);
  1460. }
  1461. return TRUE;
  1462. error:
  1463. wpa_dbus_dict_entry_clear(&entry);
  1464. dbus_set_error_const(error, DBUS_ERROR_INVALID_ARGS,
  1465. "invalid message format");
  1466. return FALSE;
  1467. }
  1468. DBusMessage * wpas_dbus_handler_p2p_add_service(DBusMessage *message,
  1469. struct wpa_supplicant *wpa_s)
  1470. {
  1471. DBusMessageIter iter_dict;
  1472. DBusMessage *reply = NULL;
  1473. DBusMessageIter iter;
  1474. struct wpa_dbus_dict_entry entry;
  1475. int upnp = 0;
  1476. int bonjour = 0;
  1477. char *service = NULL;
  1478. struct wpabuf *query = NULL;
  1479. struct wpabuf *resp = NULL;
  1480. u8 version = 0;
  1481. dbus_message_iter_init(message, &iter);
  1482. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1483. goto error;
  1484. if (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1485. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1486. goto error;
  1487. if (!os_strcmp(entry.key, "service_type") &&
  1488. (entry.type == DBUS_TYPE_STRING)) {
  1489. if (!os_strcmp(entry.str_value, "upnp"))
  1490. upnp = 1;
  1491. else if (!os_strcmp(entry.str_value, "bonjour"))
  1492. bonjour = 1;
  1493. else
  1494. goto error_clear;
  1495. wpa_dbus_dict_entry_clear(&entry);
  1496. }
  1497. }
  1498. if (upnp == 1) {
  1499. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1500. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1501. goto error;
  1502. if (!os_strcmp(entry.key, "version") &&
  1503. entry.type == DBUS_TYPE_INT32)
  1504. version = entry.uint32_value;
  1505. else if (!os_strcmp(entry.key, "service") &&
  1506. entry.type == DBUS_TYPE_STRING)
  1507. service = os_strdup(entry.str_value);
  1508. wpa_dbus_dict_entry_clear(&entry);
  1509. }
  1510. if (version <= 0 || service == NULL)
  1511. goto error;
  1512. if (wpas_p2p_service_add_upnp(wpa_s, version, service) != 0)
  1513. goto error;
  1514. os_free(service);
  1515. } else if (bonjour == 1) {
  1516. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1517. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1518. goto error;
  1519. if (!os_strcmp(entry.key, "query")) {
  1520. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1521. (entry.array_type != DBUS_TYPE_BYTE))
  1522. goto error_clear;
  1523. query = wpabuf_alloc_copy(
  1524. entry.bytearray_value,
  1525. entry.array_len);
  1526. } else if (!os_strcmp(entry.key, "response")) {
  1527. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1528. (entry.array_type != DBUS_TYPE_BYTE))
  1529. goto error_clear;
  1530. resp = wpabuf_alloc_copy(entry.bytearray_value,
  1531. entry.array_len);
  1532. }
  1533. wpa_dbus_dict_entry_clear(&entry);
  1534. }
  1535. if (query == NULL || resp == NULL)
  1536. goto error;
  1537. if (wpas_p2p_service_add_bonjour(wpa_s, query, resp) < 0) {
  1538. wpabuf_free(query);
  1539. wpabuf_free(resp);
  1540. goto error;
  1541. }
  1542. } else
  1543. goto error;
  1544. return reply;
  1545. error_clear:
  1546. wpa_dbus_dict_entry_clear(&entry);
  1547. error:
  1548. return wpas_dbus_error_invalid_args(message, NULL);
  1549. }
  1550. DBusMessage * wpas_dbus_handler_p2p_delete_service(
  1551. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1552. {
  1553. DBusMessageIter iter_dict;
  1554. DBusMessage *reply = NULL;
  1555. DBusMessageIter iter;
  1556. struct wpa_dbus_dict_entry entry;
  1557. int upnp = 0;
  1558. int bonjour = 0;
  1559. int ret = 0;
  1560. char *service = NULL;
  1561. struct wpabuf *query = NULL;
  1562. u8 version = 0;
  1563. dbus_message_iter_init(message, &iter);
  1564. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1565. goto error;
  1566. if (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1567. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1568. goto error;
  1569. if (!os_strcmp(entry.key, "service_type") &&
  1570. (entry.type == DBUS_TYPE_STRING)) {
  1571. if (!os_strcmp(entry.str_value, "upnp"))
  1572. upnp = 1;
  1573. else if (!os_strcmp(entry.str_value, "bonjour"))
  1574. bonjour = 1;
  1575. else
  1576. goto error_clear;
  1577. wpa_dbus_dict_entry_clear(&entry);
  1578. }
  1579. }
  1580. if (upnp == 1) {
  1581. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1582. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1583. goto error;
  1584. if (!os_strcmp(entry.key, "version") &&
  1585. entry.type == DBUS_TYPE_INT32)
  1586. version = entry.uint32_value;
  1587. else if (!os_strcmp(entry.key, "service") &&
  1588. entry.type == DBUS_TYPE_STRING)
  1589. service = os_strdup(entry.str_value);
  1590. else
  1591. goto error_clear;
  1592. wpa_dbus_dict_entry_clear(&entry);
  1593. }
  1594. if (version <= 0 || service == NULL)
  1595. goto error;
  1596. ret = wpas_p2p_service_del_upnp(wpa_s, version, service);
  1597. os_free(service);
  1598. if (ret != 0)
  1599. goto error;
  1600. } else if (bonjour == 1) {
  1601. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1602. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1603. goto error;
  1604. if (!os_strcmp(entry.key, "query")) {
  1605. if ((entry.type != DBUS_TYPE_ARRAY) ||
  1606. (entry.array_type != DBUS_TYPE_BYTE))
  1607. goto error_clear;
  1608. query = wpabuf_alloc_copy(
  1609. entry.bytearray_value,
  1610. entry.array_len);
  1611. } else
  1612. goto error_clear;
  1613. wpa_dbus_dict_entry_clear(&entry);
  1614. }
  1615. if (query == NULL)
  1616. goto error;
  1617. ret = wpas_p2p_service_del_bonjour(wpa_s, query);
  1618. if (ret != 0)
  1619. goto error;
  1620. wpabuf_free(query);
  1621. } else
  1622. goto error;
  1623. return reply;
  1624. error_clear:
  1625. wpa_dbus_dict_entry_clear(&entry);
  1626. error:
  1627. return wpas_dbus_error_invalid_args(message, NULL);
  1628. }
  1629. DBusMessage * wpas_dbus_handler_p2p_flush_service(DBusMessage *message,
  1630. struct wpa_supplicant *wpa_s)
  1631. {
  1632. wpas_p2p_service_flush(wpa_s);
  1633. return NULL;
  1634. }
  1635. DBusMessage * wpas_dbus_handler_p2p_service_sd_req(
  1636. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1637. {
  1638. DBusMessageIter iter_dict;
  1639. DBusMessage *reply = NULL;
  1640. DBusMessageIter iter;
  1641. struct wpa_dbus_dict_entry entry;
  1642. int upnp = 0;
  1643. char *service = NULL;
  1644. char *peer_object_path = NULL;
  1645. struct wpabuf *tlv = NULL;
  1646. u8 version = 0;
  1647. u64 ref = 0;
  1648. u8 addr[ETH_ALEN];
  1649. dbus_message_iter_init(message, &iter);
  1650. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1651. goto error;
  1652. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1653. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1654. goto error;
  1655. if (!os_strcmp(entry.key, "peer_object") &&
  1656. entry.type == DBUS_TYPE_OBJECT_PATH) {
  1657. peer_object_path = os_strdup(entry.str_value);
  1658. } else if (!os_strcmp(entry.key, "service_type") &&
  1659. entry.type == DBUS_TYPE_STRING) {
  1660. if (!os_strcmp(entry.str_value, "upnp"))
  1661. upnp = 1;
  1662. else
  1663. goto error_clear;
  1664. } else if (!os_strcmp(entry.key, "version") &&
  1665. entry.type == DBUS_TYPE_INT32) {
  1666. version = entry.uint32_value;
  1667. } else if (!os_strcmp(entry.key, "service") &&
  1668. entry.type == DBUS_TYPE_STRING) {
  1669. service = os_strdup(entry.str_value);
  1670. } else if (!os_strcmp(entry.key, "tlv")) {
  1671. if (entry.type != DBUS_TYPE_ARRAY ||
  1672. entry.array_type != DBUS_TYPE_BYTE)
  1673. goto error_clear;
  1674. tlv = wpabuf_alloc_copy(entry.bytearray_value,
  1675. entry.array_len);
  1676. } else
  1677. goto error_clear;
  1678. wpa_dbus_dict_entry_clear(&entry);
  1679. }
  1680. if (!peer_object_path ||
  1681. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  1682. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  1683. goto error;
  1684. if (upnp == 1) {
  1685. if (version <= 0 || service == NULL)
  1686. goto error;
  1687. ref = (unsigned long) wpas_p2p_sd_request_upnp(wpa_s, addr,
  1688. version,
  1689. service);
  1690. } else {
  1691. if (tlv == NULL)
  1692. goto error;
  1693. ref = (unsigned long)wpas_p2p_sd_request(wpa_s, addr, tlv);
  1694. wpabuf_free(tlv);
  1695. }
  1696. if (ref != 0) {
  1697. reply = dbus_message_new_method_return(message);
  1698. dbus_message_append_args(reply, DBUS_TYPE_UINT64,
  1699. &ref, DBUS_TYPE_INVALID);
  1700. } else {
  1701. reply = wpas_dbus_error_unknown_error(
  1702. message, "Unable to send SD request");
  1703. }
  1704. out:
  1705. os_free(service);
  1706. os_free(peer_object_path);
  1707. return reply;
  1708. error_clear:
  1709. wpa_dbus_dict_entry_clear(&entry);
  1710. error:
  1711. if (tlv)
  1712. wpabuf_free(tlv);
  1713. reply = wpas_dbus_error_invalid_args(message, NULL);
  1714. goto out;
  1715. }
  1716. DBusMessage * wpas_dbus_handler_p2p_service_sd_res(
  1717. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1718. {
  1719. DBusMessageIter iter_dict;
  1720. DBusMessage *reply = NULL;
  1721. DBusMessageIter iter;
  1722. struct wpa_dbus_dict_entry entry;
  1723. char *peer_object_path = NULL;
  1724. struct wpabuf *tlv = NULL;
  1725. int freq = 0;
  1726. int dlg_tok = 0;
  1727. u8 addr[ETH_ALEN];
  1728. dbus_message_iter_init(message, &iter);
  1729. if (!wpa_dbus_dict_open_read(&iter, &iter_dict, NULL))
  1730. goto error;
  1731. while (wpa_dbus_dict_has_dict_entry(&iter_dict)) {
  1732. if (!wpa_dbus_dict_get_entry(&iter_dict, &entry))
  1733. goto error;
  1734. if (!os_strcmp(entry.key, "peer_object") &&
  1735. entry.type == DBUS_TYPE_OBJECT_PATH) {
  1736. peer_object_path = os_strdup(entry.str_value);
  1737. } else if (!os_strcmp(entry.key, "frequency") &&
  1738. entry.type == DBUS_TYPE_INT32) {
  1739. freq = entry.uint32_value;
  1740. } else if (!os_strcmp(entry.key, "dialog_token") &&
  1741. entry.type == DBUS_TYPE_UINT32) {
  1742. dlg_tok = entry.uint32_value;
  1743. } else if (!os_strcmp(entry.key, "tlvs")) {
  1744. if (entry.type != DBUS_TYPE_ARRAY ||
  1745. entry.array_type != DBUS_TYPE_BYTE)
  1746. goto error_clear;
  1747. tlv = wpabuf_alloc_copy(entry.bytearray_value,
  1748. entry.array_len);
  1749. } else
  1750. goto error_clear;
  1751. wpa_dbus_dict_entry_clear(&entry);
  1752. }
  1753. if (!peer_object_path ||
  1754. (parse_peer_object_path(peer_object_path, addr) < 0) ||
  1755. (p2p_get_peer_info(wpa_s->global->p2p, addr, 0, NULL, 0) < 0))
  1756. goto error;
  1757. if (tlv == NULL)
  1758. goto error;
  1759. wpas_p2p_sd_response(wpa_s, freq, addr, (u8) dlg_tok, tlv);
  1760. wpabuf_free(tlv);
  1761. out:
  1762. os_free(peer_object_path);
  1763. return reply;
  1764. error_clear:
  1765. wpa_dbus_dict_entry_clear(&entry);
  1766. error:
  1767. reply = wpas_dbus_error_invalid_args(message, NULL);
  1768. goto out;
  1769. }
  1770. DBusMessage * wpas_dbus_handler_p2p_service_sd_cancel_req(
  1771. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1772. {
  1773. DBusMessageIter iter;
  1774. u64 req = 0;
  1775. dbus_message_iter_init(message, &iter);
  1776. dbus_message_iter_get_basic(&iter, &req);
  1777. if (req == 0)
  1778. goto error;
  1779. if (!wpas_p2p_sd_cancel_request(wpa_s, (void *)(unsigned long) req))
  1780. goto error;
  1781. return NULL;
  1782. error:
  1783. return wpas_dbus_error_invalid_args(message, NULL);
  1784. }
  1785. DBusMessage * wpas_dbus_handler_p2p_service_update(
  1786. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1787. {
  1788. wpas_p2p_sd_service_update(wpa_s);
  1789. return NULL;
  1790. }
  1791. DBusMessage * wpas_dbus_handler_p2p_serv_disc_external(
  1792. DBusMessage *message, struct wpa_supplicant *wpa_s)
  1793. {
  1794. DBusMessageIter iter;
  1795. int ext = 0;
  1796. dbus_message_iter_init(message, &iter);
  1797. dbus_message_iter_get_basic(&iter, &ext);
  1798. wpa_s->p2p_sd_over_ctrl_iface = ext;
  1799. return NULL;
  1800. }