dbus_new_handlers_p2p.c 57 KB

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