main.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802
  1. /*
  2. * lws-api-test-lws_struct-json
  3. *
  4. * Written in 2010-2020 by Andy Green <[email protected]>
  5. *
  6. * This file is made available under the Creative Commons CC0 1.0
  7. * Universal Public Domain Dedication.
  8. *
  9. * lws_struct apis are used to serialize and deserialize your C structs and
  10. * linked-lists in a standardized way that's very modest on memory but
  11. * convenient and easy to maintain.
  12. *
  13. * The API test shows how to serialize and deserialize a struct with a linked-
  14. * list of child structs in JSON using lws_struct APIs.
  15. */
  16. #include <libwebsockets.h>
  17. typedef struct {
  18. lws_dll2_t list;
  19. struct gpiod_line *line;
  20. const char *name;
  21. const char *wire;
  22. int chip_idx;
  23. int offset;
  24. int safe;
  25. } sai_jig_gpio_t;
  26. typedef struct {
  27. lws_dll2_t list;
  28. sai_jig_gpio_t *gpio; /* null = wait ms */
  29. const char *gpio_name;
  30. int value;
  31. } sai_jig_seq_item_t;
  32. typedef struct {
  33. lws_dll2_t list;
  34. lws_dll2_owner_t seq_owner;
  35. const char *name;
  36. } sai_jig_sequence_t;
  37. typedef struct {
  38. lws_dll2_t list;
  39. lws_dll2_owner_t gpio_owner;
  40. lws_dll2_owner_t seq_owner;
  41. lws_sorted_usec_list_t sul; /* next step in ongoing seq */
  42. sai_jig_seq_item_t *current; /* next seq step */
  43. const char *name;
  44. struct lws *wsi;
  45. } sai_jig_target_t;
  46. typedef struct {
  47. lws_dll2_owner_t target_owner;
  48. struct gpiod_chip *chip[16];
  49. struct lwsac *ac_conf;
  50. int port;
  51. const char *iface;
  52. struct lws_context *ctx;
  53. } sai_jig_t;
  54. /*
  55. * We read the JSON config using lws_struct... instrument the related structures
  56. */
  57. static const lws_struct_map_t lsm_sai_jig_gpio[] = {
  58. LSM_UNSIGNED (sai_jig_gpio_t, chip_idx, "chip_idx"),
  59. LSM_UNSIGNED (sai_jig_gpio_t, offset, "offset"),
  60. LSM_UNSIGNED (sai_jig_gpio_t, safe, "safe"),
  61. LSM_STRING_PTR (sai_jig_gpio_t, name, "name"),
  62. LSM_STRING_PTR (sai_jig_gpio_t, wire, "wire"),
  63. };
  64. static const lws_struct_map_t lsm_sai_jig_seq_item[] = {
  65. LSM_STRING_PTR (sai_jig_seq_item_t, gpio_name, "gpio_name"),
  66. LSM_UNSIGNED (sai_jig_seq_item_t, value, "value"),
  67. };
  68. static const lws_struct_map_t lsm_sai_jig_sequence[] = {
  69. LSM_STRING_PTR (sai_jig_sequence_t, name, "name"),
  70. LSM_LIST (sai_jig_sequence_t, seq_owner,
  71. sai_jig_seq_item_t, list,
  72. NULL, lsm_sai_jig_seq_item, "seq"),
  73. };
  74. static const lws_struct_map_t lsm_sai_jig_target[] = {
  75. LSM_STRING_PTR (sai_jig_target_t, name, "name"),
  76. LSM_LIST (sai_jig_target_t, gpio_owner, sai_jig_gpio_t, list,
  77. NULL, lsm_sai_jig_gpio, "gpios"),
  78. LSM_LIST (sai_jig_target_t, seq_owner, sai_jig_sequence_t, list,
  79. NULL, lsm_sai_jig_sequence, "sequences"),
  80. };
  81. static const lws_struct_map_t lsm_sai_jig[] = {
  82. LSM_STRING_PTR (sai_jig_t, iface, "iface"),
  83. LSM_UNSIGNED (sai_jig_t, port, "port"),
  84. LSM_LIST (sai_jig_t, target_owner, sai_jig_target_t, list,
  85. NULL, lsm_sai_jig_target, "targets"),
  86. };
  87. static const lws_struct_map_t lsm_jig_schema[] = {
  88. LSM_SCHEMA (sai_jig_t, NULL, lsm_sai_jig, "sai-jig"),
  89. };
  90. static const char * const jig_conf =
  91. "{"
  92. "\"schema\": \"sai-jig\","
  93. "\"port\": 44000,"
  94. "\"targets\": ["
  95. "{"
  96. "\"name\": \"linkit-7697-1\","
  97. "\"gpios\": ["
  98. "{"
  99. "\"chip_index\": 0,"
  100. "\"name\": \"nReset\","
  101. "\"offset\": 17,"
  102. "\"wire\": \"RST\","
  103. "\"safe\": 0"
  104. "}, {"
  105. "\"name\": \"usr\","
  106. "\"chip_index\": 0,"
  107. "\"offset\": 22,"
  108. "\"wire\": \"P6\","
  109. "\"safe\": 0"
  110. "}"
  111. "], \"sequences\": ["
  112. "{"
  113. "\"name\": \"reset\","
  114. "\"seq\": ["
  115. "{ \"gpio_name\": \"nReset\", \"value\": 0 },"
  116. "{ \"gpio_name\": \"usr\", \"value\": 0 },"
  117. "{ \"value\": 300 },"
  118. "{ \"gpio_name\": \"nReset\", \"value\": 1 }"
  119. "]"
  120. "}, {"
  121. "\"name\": \"flash\","
  122. "\"seq\": ["
  123. "{ \"gpio_name\": \"nReset\", \"value\": 0 },"
  124. "{ \"gpio_name\": \"usr\", \"value\": 1 },"
  125. "{ \"value\": 300 },"
  126. "{ \"gpio_name\": \"nReset\", \"value\": 1 },"
  127. "{ \"value\": 100 },"
  128. "{ \"gpio_name\": \"usr\", \"value\": 0 }"
  129. "]"
  130. "}"
  131. "]"
  132. "}"
  133. "]"
  134. "}";
  135. extern int test2(void);
  136. /*
  137. * in this example, the JSON is for one "builder" object, which may specify
  138. * a child list "targets" of zero or more "target" objects.
  139. */
  140. static const char * const json_tests[] = {
  141. "{" /* test 1 */
  142. "\"schema\":\"com-warmcat-sai-builder\","
  143. "\"hostname\":\"learn\","
  144. "\"nspawn_timeout\":1800,"
  145. "\"targets\":["
  146. "{"
  147. "\"name\":\"target1\","
  148. "\"someflag\":true"
  149. "},"
  150. "{"
  151. "\"name\":\"target2\","
  152. "\"someflag\":false"
  153. "}"
  154. "]"
  155. "}",
  156. "{" /* test 2 */
  157. "\"schema\":\"com-warmcat-sai-builder\","
  158. "\"hostname\":\"learn\","
  159. "\"targets\":["
  160. "{"
  161. "\"name\":\"target1\""
  162. "},"
  163. "{"
  164. "\"name\":\"target2\""
  165. "},"
  166. "{"
  167. "\"name\":\"target3\""
  168. "}"
  169. "]"
  170. "}", "{" /* test 3 */
  171. "\"schema\":\"com-warmcat-sai-builder\","
  172. "\"hostname\":\"learn\","
  173. "\"nspawn_timeout\":1800,"
  174. "\"targets\":["
  175. "{"
  176. "\"name\":\"target1\","
  177. "\"unrecognized\":\"xyz\","
  178. "\"child\": {"
  179. "\"somename\": \"abc\","
  180. "\"junk\": { \"x\": \"y\" }"
  181. "}"
  182. "},"
  183. "{"
  184. "\"name\":\"target2\""
  185. "}"
  186. "]"
  187. "}",
  188. "{" /* test 4 */
  189. "\"schema\":\"com-warmcat-sai-builder\","
  190. "\"hostname\":\"learn\","
  191. "\"nspawn_timeout\":1800"
  192. "}",
  193. "{" /* test 5 */
  194. "\"schema\":\"com-warmcat-sai-builder\""
  195. "}",
  196. "{" /* test 6 ... check huge strings into smaller fixed char array */
  197. "\"schema\":\"com-warmcat-sai-builder\","
  198. "\"hostname\":\""
  199. "PYvtan6kqppjnS0KpYTCaiOLsJkc7XecAr1kcE0aCIciewYB+JcLG82mO1Vb1mJtjDwUjBxy2I6A"
  200. "zefzoWUWmqZbsv4MXR55j9bKlyz1liiSX63iO0x6JAwACMtE2MkgcLwR86TSWAD9D1QKIWqg5RJ/"
  201. "CRuVsW0DKAUMD52ql4JmPFuJpJgTq28z6PhYNzN3yI3bmQt6bzhA+A/xAsFzSBnb3MHYWzGMprr5"
  202. "3FAP1ISo5Ec9i+2ehV40sG6Q470sH3PGQZ0YRPO7Sh/SyrSQ/scONmxRc3AcXl7X/CSs417ii+CV"
  203. "8sq3ZgcxKNB7tNfN7idNx3upZ00G2BZy9jSy03cLKKLNaNUt0TQsxXbH55uDHzSEeZWvxJgT6zB1"
  204. "NoMhdC02w+oXim94M6z6COCnqT3rgkGk8PHMry9Bkh4yVpRmzIRfMmln/lEhdZgxky2+g5hhlSIG"
  205. "JYDCrdynD9kCfvfy6KGOpNIi1X+mhbbWn4lnL9ZKihL/RrfOV+oV4R26IDq+KqUiJBENeo8/GXkG"
  206. "LUH/87iPyzXKEMavr6fkrK0vTGto8yEYxmOyaVz8phG5rwf4jJgmYNoMbGo8gWvhqO7UAGy2g7MW"
  207. "v+B/t1eZZ+1euLsNrWAsFJiFbQKgdFfQT3RjB14iU8knlQ8usoy+pXssY2ddGJGVcGC21oZvstK9"
  208. "eu1eRZftda/wP+N5unT1Hw7kCoVzqxHieiYt47EGIOaaQ7XjZDK6qPN6O/grHnvJZm2vBkxuXgsY"
  209. "VkRQ7AuTWIecphqFsq7Wbc1YNbMW47SVU5zMD0WaCqbaaI0t4uIzRvPlD8cpiiTzFTrEHlIBTf8/"
  210. "uZjjEGGLhJR1jPqA9D1Ej3ChV+ye6F9JTUMlozRMsGuF8U4btDzH5xdnmvRS4Ar6LKEtAXGkj2yu"
  211. "yJln+v4RIWj2xOGPJovOqiXwi0FyM61f8U8gj0OiNA2/QlvrqQVDF7sMXgjvaE7iQt5vMETteZlx"
  212. "+z3f+jTFM/aon511W4+ZkRD+6AHwucvM9BEC\""
  213. "}",
  214. "{" /* test 7 ... check huge strings into char * */
  215. "\"schema\":\"com-warmcat-sai-builder\","
  216. "\"targets\":["
  217. "{"
  218. "\"name\":\""
  219. "PYvtan6kqppjnS0KpYTCaiOLsJkc7XecAr1kcE0aCIciewYB+JcLG82mO1Vb1mJtjDwUjBxy2I6A"
  220. "zefzoWUWmqZbsv4MXR55j9bKlyz1liiSX63iO0x6JAwACMtE2MkgcLwR86TSWAD9D1QKIWqg5RJ/"
  221. "CRuVsW0DKAUMD52ql4JmPFuJpJgTq28z6PhYNzN3yI3bmQt6bzhA+A/xAsFzSBnb3MHYWzGMprr5"
  222. "3FAP1ISo5Ec9i+2ehV40sG6Q470sH3PGQZ0YRPO7Sh/SyrSQ/scONmxRc3AcXl7X/CSs417ii+CV"
  223. "8sq3ZgcxKNB7tNfN7idNx3upZ00G2BZy9jSy03cLKKLNaNUt0TQsxXbH55uDHzSEeZWvxJgT6zB1"
  224. "NoMhdC02w+oXim94M6z6COCnqT3rgkGk8PHMry9Bkh4yVpRmzIRfMmln/lEhdZgxky2+g5hhlSIG"
  225. "JYDCrdynD9kCfvfy6KGOpNIi1X+mhbbWn4lnL9ZKihL/RrfOV+oV4R26IDq+KqUiJBENeo8/GXkG"
  226. "LUH/87iPyzXKEMavr6fkrK0vTGto8yEYxmOyaVz8phG5rwf4jJgmYNoMbGo8gWvhqO7UAGy2g7MW"
  227. "v+B/t1eZZ+1euLsNrWAsFJiFbQKgdFfQT3RjB14iU8knlQ8usoy+pXssY2ddGJGVcGC21oZvstK9"
  228. "eu1eRZftda/wP+N5unT1Hw7kCoVzqxHieiYt47EGIOaaQ7XjZDK6qPN6O/grHnvJZm2vBkxuXgsY"
  229. "VkRQ7AuTWIecphqFsq7Wbc1YNbMW47SVU5zMD0WaCqbaaI0t4uIzRvPlD8cpiiTzFTrEHlIBTf8/"
  230. "uZjjEGGLhJR1jPqA9D1Ej3ChV+ye6F9JTUMlozRMsGuF8U4btDzH5xdnmvRS4Ar6LKEtAXGkj2yu"
  231. "yJln+v4RIWj2xOGPJovOqiXwi0FyM61f8U8gj0OiNA2/QlvrqQVDF7sMXgjvaE7iQt5vMETteZlx"
  232. "+z3f+jTFM/aon511W4+ZkRD+6AHwucvM9BEC\"}]}"
  233. "}",
  234. "{" /* test 8 the "other" schema */
  235. "\"schema\":\"com-warmcat-sai-other\","
  236. "\"name\":\"somename\""
  237. "}",
  238. };
  239. /*
  240. * These are the expected outputs for each test, without pretty formatting.
  241. *
  242. * There are some differences to do with missing elements being rendered with
  243. * default values.
  244. */
  245. static const char * const json_expected[] = {
  246. "{\"schema\":\"com-warmcat-sai-builder\",\"hostname\":\"learn\","
  247. "\"nspawn_timeout\":1800,\"targets\":[{\"name\":\"target1\",\"someflag\":true},"
  248. "{\"name\":\"target2\",\"someflag\":false}]}",
  249. "{\"schema\":\"com-warmcat-sai-builder\",\"hostname\":\"learn\","
  250. "\"nspawn_timeout\":0,\"targets\":[{\"name\":\"target1\",\"someflag\":false},"
  251. "{\"name\":\"target2\",\"someflag\":false},{\"name\":\"target3\",\"someflag\":false}]}",
  252. "{\"schema\":\"com-warmcat-sai-builder\",\"hostname\":\"learn\","
  253. "\"nspawn_timeout\":1800,\"targets\":[{\"name\":\"target1\",\"someflag\":false,"
  254. "\"child\":{\"somename\":\"abc\"}},{\"name\":\"target2\",\"someflag\":false}]}",
  255. "{\"schema\":\"com-warmcat-sai-builder\","
  256. "\"hostname\":\"learn\",\"nspawn_timeout\":1800}",
  257. "{\"schema\":\"com-warmcat-sai-builder\",\"hostname\":\"\","
  258. "\"nspawn_timeout\":0}",
  259. "{\"schema\":\"com-warmcat-sai-builder\",\"hostname\":"
  260. "\"PYvtan6kqppjnS0KpYTCaiOLsJkc7Xe\","
  261. "\"nspawn_timeout\":0}",
  262. "{\"schema\":\"com-warmcat-sai-builder\",\"hostname\":\"\","
  263. "\"nspawn_timeout\":0,\"targets\":[{\"name\":\"PYvtan6kqppjnS0KpYTC"
  264. "aiOLsJkc7XecAr1kcE0aCIciewYB+JcLG82mO1Vb1mJtjDwUjBxy2I6Azefz"
  265. "oWUWmqZbsv4MXR55j9bKlyz1liiSX63iO0x6JAwACMtE2MkgcLwR86TSWAD9"
  266. "D1QKIWqg5RJ/CRuVsW0DKAUMD52ql4JmPFuJpJgTq28z6PhYNzN3yI3bmQt6"
  267. "bzhA+A/xAsFzSBnb3MHYWzGMprr53FAP1ISo5Ec9i+2ehV40sG6Q470sH3PG"
  268. "QZ0YRPO7Sh/SyrSQ/scONmxRc3AcXl7X/CSs417ii+CV8sq3ZgcxKNB7tNfN"
  269. "7idNx3upZ00G2BZy9jSy03cLKKLNaNUt0TQsxXbH55uDHzSEeZWvxJgT6zB1"
  270. "NoMhdC02w+oXim94M6z6COCnqT3rgkGk8PHMry9Bkh4yVpRmzIRfMmln/lEh"
  271. "dZgxky2+g5hhlSIGJYDCrdynD9kCfvfy6KGOpNIi1X+mhbbWn4lnL9ZKihL/"
  272. "RrfOV+oV4R26IDq+KqUiJBENeo8/GXkGLUH/87iPyzXKEMavr6fkrK0vTGto"
  273. "8yEYxmOyaVz8phG5rwf4jJgmYNoMbGo8gWvhqO7UAGy2g7MWv+B/t1eZZ+1e"
  274. "uLsNrWAsFJiFbQKgdFfQT3RjB14iU8knlQ8usoy+pXssY2ddGJGVcGC21oZv"
  275. "stK9eu1eRZftda/wP+N5unT1Hw7kCoVzqxHieiYt47EGIOaaQ7XjZDK6qPN6"
  276. "O/grHnvJZm2vBkxuXgsYVkRQ7AuTWIecphqFsq7Wbc1YNbMW47SVU5zMD0Wa"
  277. "CqbaaI0t4uIzRvPlD8cpiiTzFTrEHlIBTf8/uZjjEGGLhJR1jPqA9D1Ej3Ch"
  278. "V+ye6F9JTUMlozRMsGuF8U4btDzH5xdnmvRS4Ar6LKEtAXGkj2yuyJln+v4R"
  279. "IWj2xOGPJovOqiXwi0FyM61f8U8gj0OiNA2/QlvrqQVDF7sMXgjvaE7iQt5v"
  280. "METteZlx+z3f+jTFM/aon511W4+ZkRD+6AHwucvM9BEC\""
  281. ",\"someflag\":false}]}",
  282. "{\"schema\":\"com-warmcat-sai-other\",\"name\":\"somename\"}"
  283. };
  284. /*
  285. * These annotate the members in the struct that will be serialized and
  286. * deserialized with type and size information, as well as the name to use
  287. * in the serialization format.
  288. *
  289. * Struct members that aren't annotated like this won't be serialized and
  290. * when the struct is created during deserialiation, the will be set to 0
  291. * or NULL.
  292. */
  293. /* child object */
  294. typedef struct sai_child {
  295. const char * somename;
  296. } sai_child_t;
  297. lws_struct_map_t lsm_child[] = { /* describes serializable members */
  298. LSM_STRING_PTR (sai_child_t, somename, "somename"),
  299. };
  300. /* target object */
  301. typedef struct sai_target {
  302. struct lws_dll2 target_list;
  303. sai_child_t * child;
  304. const char * name;
  305. char someflag;
  306. } sai_target_t;
  307. static const lws_struct_map_t lsm_target[] = {
  308. LSM_STRING_PTR (sai_target_t, name, "name"),
  309. LSM_BOOLEAN (sai_target_t, someflag, "someflag"),
  310. LSM_CHILD_PTR (sai_target_t, child, sai_child_t,
  311. NULL, lsm_child, "child"),
  312. };
  313. /* the first kind of struct / schema we can receive */
  314. /* builder object */
  315. typedef struct sai_builder {
  316. struct lws_dll2_owner targets;
  317. char hostname[32];
  318. unsigned int nspawn_timeout;
  319. } sai_builder_t;
  320. static const lws_struct_map_t lsm_builder[] = {
  321. LSM_CARRAY (sai_builder_t, hostname, "hostname"),
  322. LSM_UNSIGNED (sai_builder_t, nspawn_timeout, "nspawn_timeout"),
  323. LSM_LIST (sai_builder_t, targets,
  324. sai_target_t, target_list,
  325. NULL, lsm_target, "targets"),
  326. };
  327. /*
  328. * the second kind of struct / schema we can receive
  329. */
  330. typedef struct sai_other {
  331. char name[32];
  332. } sai_other_t;
  333. static const lws_struct_map_t lsm_other[] = {
  334. LSM_CARRAY (sai_other_t, name, "name"),
  335. };
  336. /*
  337. * meta composed pointers test
  338. *
  339. * We serialize a struct that consists of members that point to other objects,
  340. * we expect this kind of thing
  341. *
  342. * {
  343. * "schema": "meta",
  344. * "t": { ... },
  345. * "e": { ...}
  346. * }
  347. */
  348. typedef struct meta {
  349. sai_target_t *t;
  350. sai_builder_t *b;
  351. } meta_t;
  352. static const lws_struct_map_t lsm_meta[] = {
  353. LSM_CHILD_PTR (meta_t, t, sai_target_t, NULL, lsm_target, "t"),
  354. LSM_CHILD_PTR (meta_t, b, sai_child_t, NULL, lsm_builder, "e"),
  355. };
  356. static const lws_struct_map_t lsm_schema_meta[] = {
  357. LSM_SCHEMA (meta_t, NULL, lsm_meta, "meta.schema"),
  358. };
  359. /*
  360. * Schema table
  361. *
  362. * Before we can understand the serialization top level format, we must read
  363. * the schema, use the table below to create the right toplevel object for the
  364. * schema name, and select the correct map tables to interpret the rest of the
  365. * serialization.
  366. *
  367. * In this example there are two completely separate structs / schemas possible
  368. * to receive, and we disambiguate and create the correct one using the schema
  369. * JSON node.
  370. *
  371. * Therefore the schema table below is the starting point for the JSON
  372. * deserialization.
  373. */
  374. static const lws_struct_map_t lsm_schema_map[] = {
  375. LSM_SCHEMA (sai_builder_t, NULL,
  376. lsm_builder, "com-warmcat-sai-builder"),
  377. LSM_SCHEMA (sai_other_t, NULL,
  378. lsm_other, "com-warmcat-sai-other"),
  379. };
  380. typedef struct sai_cancel {
  381. char task_uuid[65];
  382. } sai_cancel_t;
  383. const lws_struct_map_t lsm_task_cancel[] = {
  384. LSM_CARRAY (sai_cancel_t, task_uuid, "uuid"),
  385. };
  386. static const lws_struct_map_t t2_map[] = {
  387. LSM_SCHEMA (sai_cancel_t, NULL, lsm_task_cancel,
  388. "com.warmcat.sai.taskinfo"),
  389. LSM_SCHEMA (sai_cancel_t, NULL, lsm_task_cancel,
  390. "com.warmcat.sai.eventinfo"),
  391. LSM_SCHEMA (sai_cancel_t, NULL, lsm_task_cancel,
  392. /* shares struct */ "com.warmcat.sai.taskreset"),
  393. LSM_SCHEMA (sai_cancel_t, NULL, lsm_task_cancel,
  394. /* shares struct */ "com.warmcat.sai.eventreset"),
  395. LSM_SCHEMA (sai_cancel_t, NULL, lsm_task_cancel,
  396. /* shares struct */ "com.warmcat.sai.eventdelete"),
  397. LSM_SCHEMA (sai_cancel_t, NULL, lsm_task_cancel,
  398. "com.warmcat.sai.taskcan"),
  399. };
  400. static const char *t2 =
  401. "{\"schema\":\"com.warmcat.sai.taskcan\","
  402. "\"uuid\": \"071ab46ab4296e5de674c628fec17c55088254679f7714ad991f8c4873dca\"}\x01\x02\xff\xff\xff\xff";
  403. typedef struct xlws_wifi_creds {
  404. lws_dll2_t list;
  405. char ssid[33];
  406. char passphrase[64];
  407. int alg;
  408. char bssid[6];
  409. } xlws_wifi_creds_t;
  410. typedef struct xlws_netdevs {
  411. lws_dll2_owner_t owner_creds;
  412. } xlws_netdevs_t;
  413. static const lws_struct_map_t lsm_wifi_creds[] = {
  414. LSM_CARRAY (xlws_wifi_creds_t, ssid, "ssid"),
  415. LSM_CARRAY (xlws_wifi_creds_t, passphrase, "passphrase"),
  416. LSM_UNSIGNED (xlws_wifi_creds_t, alg, "alg"),
  417. LSM_STRING_PTR (xlws_wifi_creds_t, bssid, "bssid"),
  418. };
  419. static const lws_struct_map_t lsm_netdev_credentials[] = {
  420. LSM_LIST (xlws_netdevs_t, owner_creds, xlws_wifi_creds_t, list,
  421. NULL, lsm_wifi_creds, "credentials"),
  422. };
  423. static const lws_struct_map_t lsm_netdev_schema[] = {
  424. LSM_SCHEMA (xlws_netdevs_t, NULL, lsm_netdev_credentials,
  425. "com.warmcat.sai.taskinfo"),
  426. };
  427. static int
  428. show_target(struct lws_dll2 *d, void *user)
  429. {
  430. sai_target_t *t = lws_container_of(d, sai_target_t, target_list);
  431. lwsl_notice(" target.name '%s' (target %p)\n", t->name, t);
  432. if (t->child)
  433. lwsl_notice(" child %p, target.child.somename '%s'\n",
  434. t->child, t->child->somename);
  435. return 0;
  436. }
  437. int main(int argc, const char **argv)
  438. {
  439. int n, m, e = 0, logs = LLL_USER | LLL_ERR | LLL_WARN | LLL_NOTICE;
  440. #if 1
  441. lws_struct_serialize_t *ser;
  442. uint8_t buf[4096];
  443. size_t written;
  444. #endif
  445. struct lejp_ctx ctx;
  446. lws_struct_args_t a;
  447. sai_builder_t *b, mb;
  448. sai_target_t mt;
  449. sai_other_t *o;
  450. const char *p;
  451. meta_t meta;
  452. if ((p = lws_cmdline_option(argc, argv, "-d")))
  453. logs = atoi(p);
  454. lws_set_log_level(logs, NULL);
  455. lwsl_user("LWS API selftest: lws_struct JSON\n");
  456. for (m = 0; m < (int)LWS_ARRAY_SIZE(json_tests); m++) {
  457. /* 1. deserialize the canned JSON into structs */
  458. lwsl_notice("%s: ++++++++++++++++ test %d\n", __func__, m + 1);
  459. memset(&a, 0, sizeof(a));
  460. a.map_st[0] = lsm_schema_map;
  461. a.map_entries_st[0] = LWS_ARRAY_SIZE(lsm_schema_map);
  462. a.ac_block_size = 512;
  463. lws_struct_json_init_parse(&ctx, NULL, &a);
  464. n = lejp_parse(&ctx, (uint8_t *)json_tests[m],
  465. (int)strlen(json_tests[m]));
  466. if (n < 0) {
  467. lwsl_err("%s: notification JSON decode failed '%s'\n",
  468. __func__, lejp_error_to_string(n));
  469. e++;
  470. goto done;
  471. }
  472. lwsac_info(a.ac);
  473. if (m + 1 != 8) {
  474. b = a.dest;
  475. if (!b) {
  476. lwsl_err("%s: didn't produce any output\n", __func__);
  477. e++;
  478. goto done;
  479. }
  480. if (a.top_schema_index) {
  481. lwsl_err("%s: wrong top_schema_index\n", __func__);
  482. e++;
  483. goto done;
  484. }
  485. lwsl_notice("builder.hostname = '%s', timeout = %d, targets (%d)\n",
  486. b->hostname, b->nspawn_timeout,
  487. b->targets.count);
  488. lws_dll2_foreach_safe(&b->targets, NULL, show_target);
  489. } else {
  490. o = a.dest;
  491. if (!o) {
  492. lwsl_err("%s: didn't produce any output\n", __func__);
  493. e++;
  494. goto done;
  495. }
  496. if (a.top_schema_index != 1) {
  497. lwsl_err("%s: wrong top_schema_index\n", __func__);
  498. e++;
  499. goto done;
  500. }
  501. lwsl_notice("other.name = '%s'\n", o->name);
  502. }
  503. /* 2. serialize the structs into JSON and confirm */
  504. lwsl_notice("%s: .... strarting serialization of test %d\n",
  505. __func__, m + 1);
  506. if (m + 1 != 8) {
  507. ser = lws_struct_json_serialize_create(lsm_schema_map,
  508. LWS_ARRAY_SIZE(lsm_schema_map),
  509. 0//LSSERJ_FLAG_PRETTY
  510. , b);
  511. } else {
  512. ser = lws_struct_json_serialize_create(&lsm_schema_map[1],
  513. 1,
  514. 0//LSSERJ_FLAG_PRETTY
  515. , o);
  516. }
  517. if (!ser) {
  518. lwsl_err("%s: unable to init serialization\n", __func__);
  519. goto bail;
  520. }
  521. do {
  522. n = lws_struct_json_serialize(ser, buf, sizeof(buf),
  523. &written);
  524. switch (n) {
  525. case LSJS_RESULT_FINISH:
  526. puts((const char *)buf);
  527. break;
  528. case LSJS_RESULT_CONTINUE:
  529. case LSJS_RESULT_ERROR:
  530. goto bail;
  531. }
  532. } while(n == LSJS_RESULT_CONTINUE);
  533. if (strcmp(json_expected[m], (char *)buf)) {
  534. lwsl_err("%s: test %d: expected %s\n", __func__, m + 1,
  535. json_expected[m]);
  536. e++;
  537. goto done;
  538. }
  539. lws_struct_json_serialize_destroy(&ser);
  540. done:
  541. lwsac_free(&a.ac);
  542. }
  543. if (e)
  544. goto bail;
  545. /* ad-hoc tests */
  546. memset(&meta, 0, sizeof(meta));
  547. memset(&mb, 0, sizeof(mb));
  548. memset(&mt, 0, sizeof(mt));
  549. meta.t = &mt;
  550. meta.b = &mb;
  551. meta.t->name = "mytargetname";
  552. lws_strncpy(meta.b->hostname, "myhostname", sizeof(meta.b->hostname));
  553. ser = lws_struct_json_serialize_create(lsm_schema_meta, 1, 0,
  554. &meta);
  555. if (!ser) {
  556. lwsl_err("%s: failed to create json\n", __func__);
  557. }
  558. do {
  559. n = lws_struct_json_serialize(ser, buf, sizeof(buf), &written);
  560. switch (n) {
  561. case LSJS_RESULT_CONTINUE:
  562. case LSJS_RESULT_FINISH:
  563. puts((const char *)buf);
  564. if (strcmp((const char *)buf,
  565. "{\"schema\":\"meta.schema\","
  566. "\"t\":{\"name\":\"mytargetname\","
  567. "\"someflag\":false},"
  568. "\"e\":{\"hostname\":\"myhostname\","
  569. "\"nspawn_timeout\":0}}")) {
  570. lwsl_err("%s: meta test fail\n", __func__);
  571. goto bail;
  572. }
  573. break;
  574. case LSJS_RESULT_ERROR:
  575. goto bail;
  576. }
  577. } while(n == LSJS_RESULT_CONTINUE);
  578. lws_struct_json_serialize_destroy(&ser);
  579. lwsl_notice("Test set 2\n");
  580. memset(&a, 0, sizeof(a));
  581. a.map_st[0] = t2_map;
  582. a.map_entries_st[0] = LWS_ARRAY_SIZE(t2_map);
  583. a.ac_block_size = 128;
  584. lws_struct_json_init_parse(&ctx, NULL, &a);
  585. m = lejp_parse(&ctx, (uint8_t *)t2, (int)strlen(t2));
  586. if (m < 0 || !a.dest) {
  587. lwsl_notice("%s: notification JSON decode failed '%s'\n",
  588. __func__, lejp_error_to_string(m));
  589. goto bail;
  590. }
  591. lwsl_notice("Test set 2: %d: %s\n", m,
  592. ((sai_cancel_t *)a.dest)->task_uuid);
  593. lwsac_free(&a.ac);
  594. if (test2())
  595. goto bail;
  596. {
  597. lws_struct_serialize_t *js;
  598. xlws_wifi_creds_t creds;
  599. xlws_netdevs_t netdevs;
  600. unsigned char *buf;
  601. size_t w;
  602. int n;
  603. memset(&creds, 0, sizeof(creds));
  604. memset(&netdevs, 0, sizeof(netdevs));
  605. lws_strncpy(creds.ssid, "xxx", sizeof(creds.ssid));
  606. lws_strncpy(creds.passphrase, "yyy", sizeof(creds.passphrase));
  607. lws_dll2_add_tail(&creds.list, &netdevs.owner_creds);
  608. buf = malloc(2048); /* length should be computed */
  609. js = lws_struct_json_serialize_create(lsm_netdev_schema,
  610. LWS_ARRAY_SIZE(lsm_netdev_schema), 0, &netdevs);
  611. if (!js)
  612. goto bail;
  613. n = lws_struct_json_serialize(js, buf, 2048, &w);
  614. lws_struct_json_serialize_destroy(&js);
  615. if (n != LSJS_RESULT_FINISH)
  616. goto bail;
  617. if (strcmp("{\"schema\":\"com.warmcat.sai.taskinfo\",\"credentials\":[{\"ssid\":\"xxx\",\"passphrase\":\"yyy\",\"alg\":0}]}", (const char *)buf)) {
  618. puts((const char *)buf);
  619. goto bail;
  620. }
  621. free(buf);
  622. }
  623. {
  624. struct x { lws_dll2_t list; const char *sz; };
  625. struct x x1, x2, *xp;
  626. lws_dll2_owner_t o;
  627. lws_dll2_owner_clear(&o);
  628. memset(&x1, 0, sizeof(x1));
  629. memset(&x2, 0, sizeof(x2));
  630. x1.sz = "nope";
  631. x2.sz = "yes";
  632. lws_dll2_add_tail(&x1.list, &o);
  633. lws_dll2_add_tail(&x2.list, &o);
  634. xp = lws_dll2_search_sz_pl(&o, "yes", 3, struct x, list, sz);
  635. if (xp != &x2) {
  636. lwsl_err("%s: 1 xp %p\n", __func__, xp);
  637. goto bail;
  638. }
  639. xp = lws_dll2_search_sz_pl(&o, "nope", 4, struct x, list, sz);
  640. if (xp != &x1) {
  641. lwsl_err("%s: 2 xp %p\n", __func__, xp);
  642. goto bail;
  643. }
  644. xp = lws_dll2_search_sz_pl(&o, "wrong", 4, struct x, list, sz);
  645. if (xp) {
  646. lwsl_err("%s: 3 xp %p\n", __func__, xp);
  647. goto bail;
  648. }
  649. }
  650. {
  651. lws_struct_args_t a;
  652. struct lejp_ctx ctx;
  653. int m;
  654. memset(&a, 0, sizeof(a));
  655. a.map_st[0] = lsm_jig_schema;
  656. a.map_entries_st[0] = LWS_ARRAY_SIZE(lsm_jig_schema);
  657. a.ac_block_size = 512;
  658. lws_struct_json_init_parse(&ctx, NULL, &a);
  659. m = lejp_parse(&ctx, (uint8_t *)jig_conf, (int)strlen(jig_conf));
  660. if (m < 0 || !a.dest) {
  661. lwsl_err("%s: line %d: JSON decode failed '%s'\n",
  662. __func__, ctx.line, lejp_error_to_string(m));
  663. goto bail;
  664. }
  665. }
  666. lwsl_user("Completed: PASS\n");
  667. return 0;
  668. bail:
  669. if (test2())
  670. return 1;
  671. lwsl_user("Completed: FAIL\n");
  672. return 1;
  673. }