dbus_new_handlers_p2p.c 57 KB

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