obs-data.c 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358
  1. /******************************************************************************
  2. Copyright (C) 2014 by Hugh Bailey <[email protected]>
  3. This program is free software: you can redistribute it and/or modify
  4. it under the terms of the GNU General Public License as published by
  5. the Free Software Foundation, either version 2 of the License, or
  6. (at your option) any later version.
  7. This program is distributed in the hope that it will be useful,
  8. but WITHOUT ANY WARRANTY; without even the implied warranty of
  9. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  10. GNU General Public License for more details.
  11. You should have received a copy of the GNU General Public License
  12. along with this program. If not, see <http://www.gnu.org/licenses/>.
  13. ******************************************************************************/
  14. #include "util/bmem.h"
  15. #include "util/threading.h"
  16. #include "util/dstr.h"
  17. #include "util/darray.h"
  18. #include "util/platform.h"
  19. #include "graphics/vec2.h"
  20. #include "graphics/vec3.h"
  21. #include "graphics/vec4.h"
  22. #include "graphics/quat.h"
  23. #include "obs-data.h"
  24. #include <jansson.h>
  25. struct obs_data_item {
  26. volatile long ref;
  27. struct obs_data *parent;
  28. struct obs_data_item *next;
  29. enum obs_data_type type;
  30. size_t name_len;
  31. size_t data_len;
  32. size_t data_size;
  33. size_t default_len;
  34. size_t default_size;
  35. size_t autoselect_size;
  36. size_t capacity;
  37. };
  38. struct obs_data {
  39. volatile long ref;
  40. char *json;
  41. struct obs_data_item *first_item;
  42. };
  43. struct obs_data_array {
  44. volatile long ref;
  45. DARRAY(obs_data_t *) objects;
  46. };
  47. struct obs_data_number {
  48. enum obs_data_number_type type;
  49. union {
  50. long long int_val;
  51. double double_val;
  52. };
  53. };
  54. /* ------------------------------------------------------------------------- */
  55. /* Item structure, designed to be one allocation only */
  56. static inline size_t get_align_size(size_t size)
  57. {
  58. const size_t alignment = base_get_alignment();
  59. return (size + alignment - 1) & ~(alignment - 1);
  60. }
  61. /* ensures data after the name has alignment (in case of SSE) */
  62. static inline size_t get_name_align_size(const char *name)
  63. {
  64. size_t name_size = strlen(name) + 1;
  65. size_t alignment = base_get_alignment();
  66. size_t total_size;
  67. total_size = sizeof(struct obs_data_item) + (name_size + alignment - 1);
  68. total_size &= ~(alignment - 1);
  69. return total_size - sizeof(struct obs_data_item);
  70. }
  71. static inline char *get_item_name(struct obs_data_item *item)
  72. {
  73. return (char *)item + sizeof(struct obs_data_item);
  74. }
  75. static inline void *get_data_ptr(obs_data_item_t *item)
  76. {
  77. return (uint8_t *)get_item_name(item) + item->name_len;
  78. }
  79. static inline void *get_item_data(struct obs_data_item *item)
  80. {
  81. if (!item->data_size && !item->default_size && !item->autoselect_size)
  82. return NULL;
  83. return get_data_ptr(item);
  84. }
  85. static inline void *get_default_data_ptr(obs_data_item_t *item)
  86. {
  87. return (uint8_t *)get_data_ptr(item) + item->data_len;
  88. }
  89. static inline void *get_item_default_data(struct obs_data_item *item)
  90. {
  91. return item->default_size ? get_default_data_ptr(item) : NULL;
  92. }
  93. static inline void *get_autoselect_data_ptr(obs_data_item_t *item)
  94. {
  95. return (uint8_t *)get_default_data_ptr(item) + item->default_len;
  96. }
  97. static inline void *get_item_autoselect_data(struct obs_data_item *item)
  98. {
  99. return item->autoselect_size ? get_autoselect_data_ptr(item) : NULL;
  100. }
  101. static inline size_t obs_data_item_total_size(struct obs_data_item *item)
  102. {
  103. return sizeof(struct obs_data_item) + item->name_len + item->data_len +
  104. item->default_len + item->autoselect_size;
  105. }
  106. static inline obs_data_t *get_item_obj(struct obs_data_item *item)
  107. {
  108. if (!item)
  109. return NULL;
  110. obs_data_t **data = get_item_data(item);
  111. if (!data)
  112. return NULL;
  113. return *data;
  114. }
  115. static inline obs_data_t *get_item_default_obj(struct obs_data_item *item)
  116. {
  117. if (!item || !item->default_size)
  118. return NULL;
  119. return *(obs_data_t **)get_default_data_ptr(item);
  120. }
  121. static inline obs_data_t *get_item_autoselect_obj(struct obs_data_item *item)
  122. {
  123. if (!item || !item->autoselect_size)
  124. return NULL;
  125. return *(obs_data_t **)get_autoselect_data_ptr(item);
  126. }
  127. static inline obs_data_array_t *get_item_array(struct obs_data_item *item)
  128. {
  129. obs_data_array_t **array;
  130. if (!item)
  131. return NULL;
  132. array = (obs_data_array_t **)get_item_data(item);
  133. return array ? *array : NULL;
  134. }
  135. static inline obs_data_array_t *
  136. get_item_default_array(struct obs_data_item *item)
  137. {
  138. if (!item || !item->default_size)
  139. return NULL;
  140. return *(obs_data_array_t **)get_default_data_ptr(item);
  141. }
  142. static inline obs_data_array_t *
  143. get_item_autoselect_array(struct obs_data_item *item)
  144. {
  145. if (!item || !item->autoselect_size)
  146. return NULL;
  147. return *(obs_data_array_t **)get_autoselect_data_ptr(item);
  148. }
  149. static inline void item_data_release(struct obs_data_item *item)
  150. {
  151. if (!obs_data_item_has_user_value(item))
  152. return;
  153. if (item->type == OBS_DATA_OBJECT) {
  154. obs_data_t *obj = get_item_obj(item);
  155. obs_data_release(obj);
  156. } else if (item->type == OBS_DATA_ARRAY) {
  157. obs_data_array_t *array = get_item_array(item);
  158. obs_data_array_release(array);
  159. }
  160. }
  161. static inline void item_default_data_release(struct obs_data_item *item)
  162. {
  163. if (item->type == OBS_DATA_OBJECT) {
  164. obs_data_t *obj = get_item_default_obj(item);
  165. obs_data_release(obj);
  166. } else if (item->type == OBS_DATA_ARRAY) {
  167. obs_data_array_t *array = get_item_default_array(item);
  168. obs_data_array_release(array);
  169. }
  170. }
  171. static inline void item_autoselect_data_release(struct obs_data_item *item)
  172. {
  173. if (item->type == OBS_DATA_OBJECT) {
  174. obs_data_t *obj = get_item_autoselect_obj(item);
  175. obs_data_release(obj);
  176. } else if (item->type == OBS_DATA_ARRAY) {
  177. obs_data_array_t *array = get_item_autoselect_array(item);
  178. obs_data_array_release(array);
  179. }
  180. }
  181. static inline void item_data_addref(struct obs_data_item *item)
  182. {
  183. if (item->type == OBS_DATA_OBJECT) {
  184. obs_data_t *obj = get_item_obj(item);
  185. obs_data_addref(obj);
  186. } else if (item->type == OBS_DATA_ARRAY) {
  187. obs_data_array_t *array = get_item_array(item);
  188. obs_data_array_addref(array);
  189. }
  190. }
  191. static inline void item_default_data_addref(struct obs_data_item *item)
  192. {
  193. if (!item->data_size)
  194. return;
  195. if (item->type == OBS_DATA_OBJECT) {
  196. obs_data_t *obj = get_item_default_obj(item);
  197. obs_data_addref(obj);
  198. } else if (item->type == OBS_DATA_ARRAY) {
  199. obs_data_array_t *array = get_item_default_array(item);
  200. obs_data_array_addref(array);
  201. }
  202. }
  203. static inline void item_autoselect_data_addref(struct obs_data_item *item)
  204. {
  205. if (item->type == OBS_DATA_OBJECT) {
  206. obs_data_t *obj = get_item_autoselect_obj(item);
  207. obs_data_addref(obj);
  208. } else if (item->type == OBS_DATA_ARRAY) {
  209. obs_data_array_t *array = get_item_autoselect_array(item);
  210. obs_data_array_addref(array);
  211. }
  212. }
  213. static struct obs_data_item *obs_data_item_create(const char *name,
  214. const void *data, size_t size,
  215. enum obs_data_type type,
  216. bool default_data,
  217. bool autoselect_data)
  218. {
  219. struct obs_data_item *item;
  220. size_t name_size, total_size;
  221. if (!name || !data)
  222. return NULL;
  223. name_size = get_name_align_size(name);
  224. total_size = name_size + sizeof(struct obs_data_item) + size;
  225. item = bzalloc(total_size);
  226. item->capacity = total_size;
  227. item->type = type;
  228. item->name_len = name_size;
  229. item->ref = 1;
  230. if (default_data) {
  231. item->default_len = size;
  232. item->default_size = size;
  233. } else if (autoselect_data) {
  234. item->autoselect_size = size;
  235. } else {
  236. item->data_len = size;
  237. item->data_size = size;
  238. }
  239. strcpy(get_item_name(item), name);
  240. memcpy(get_item_data(item), data, size);
  241. item_data_addref(item);
  242. return item;
  243. }
  244. static struct obs_data_item **get_item_prev_next(struct obs_data *data,
  245. struct obs_data_item *current)
  246. {
  247. if (!current || !data)
  248. return NULL;
  249. struct obs_data_item **prev_next = &data->first_item;
  250. struct obs_data_item *item = data->first_item;
  251. while (item) {
  252. if (item == current)
  253. return prev_next;
  254. prev_next = &item->next;
  255. item = item->next;
  256. }
  257. return NULL;
  258. }
  259. static inline void obs_data_item_detach(struct obs_data_item *item)
  260. {
  261. struct obs_data_item **prev_next =
  262. get_item_prev_next(item->parent, item);
  263. if (prev_next) {
  264. *prev_next = item->next;
  265. item->next = NULL;
  266. }
  267. }
  268. static inline void obs_data_item_reattach(struct obs_data_item *old_ptr,
  269. struct obs_data_item *new_ptr)
  270. {
  271. struct obs_data_item **prev_next =
  272. get_item_prev_next(new_ptr->parent, old_ptr);
  273. if (prev_next)
  274. *prev_next = new_ptr;
  275. }
  276. static struct obs_data_item *
  277. obs_data_item_ensure_capacity(struct obs_data_item *item)
  278. {
  279. size_t new_size = obs_data_item_total_size(item);
  280. struct obs_data_item *new_item;
  281. if (item->capacity >= new_size)
  282. return item;
  283. new_item = brealloc(item, new_size);
  284. new_item->capacity = new_size;
  285. obs_data_item_reattach(item, new_item);
  286. return new_item;
  287. }
  288. static inline void obs_data_item_destroy(struct obs_data_item *item)
  289. {
  290. item_data_release(item);
  291. item_default_data_release(item);
  292. item_autoselect_data_release(item);
  293. obs_data_item_detach(item);
  294. bfree(item);
  295. }
  296. static inline void move_data(obs_data_item_t *old_item, void *old_data,
  297. obs_data_item_t *item, void *data, size_t len)
  298. {
  299. ptrdiff_t old_offset = (uint8_t *)old_data - (uint8_t *)old_item;
  300. ptrdiff_t new_offset = (uint8_t *)data - (uint8_t *)item;
  301. if (!old_data)
  302. return;
  303. memmove((uint8_t *)item + new_offset, (uint8_t *)item + old_offset,
  304. len);
  305. }
  306. static inline void obs_data_item_setdata(struct obs_data_item **p_item,
  307. const void *data, size_t size,
  308. enum obs_data_type type)
  309. {
  310. if (!p_item || !*p_item)
  311. return;
  312. struct obs_data_item *item = *p_item;
  313. ptrdiff_t old_default_data_pos =
  314. (uint8_t *)get_default_data_ptr(item) - (uint8_t *)item;
  315. item_data_release(item);
  316. item->data_size = size;
  317. item->type = type;
  318. item->data_len = (item->default_size || item->autoselect_size)
  319. ? get_align_size(size)
  320. : size;
  321. item = obs_data_item_ensure_capacity(item);
  322. if (item->default_size || item->autoselect_size)
  323. memmove(get_default_data_ptr(item),
  324. (uint8_t *)item + old_default_data_pos,
  325. item->default_len + item->autoselect_size);
  326. if (size) {
  327. memcpy(get_item_data(item), data, size);
  328. item_data_addref(item);
  329. }
  330. *p_item = item;
  331. }
  332. static inline void obs_data_item_set_default_data(struct obs_data_item **p_item,
  333. const void *data, size_t size,
  334. enum obs_data_type type)
  335. {
  336. if (!p_item || !*p_item)
  337. return;
  338. struct obs_data_item *item = *p_item;
  339. void *old_autoselect_data = get_autoselect_data_ptr(item);
  340. item_default_data_release(item);
  341. item->type = type;
  342. item->default_size = size;
  343. item->default_len = item->autoselect_size ? get_align_size(size) : size;
  344. item->data_len = item->data_size ? get_align_size(item->data_size) : 0;
  345. item = obs_data_item_ensure_capacity(item);
  346. if (item->autoselect_size)
  347. move_data(*p_item, old_autoselect_data, item,
  348. get_autoselect_data_ptr(item), item->autoselect_size);
  349. if (size) {
  350. memcpy(get_item_default_data(item), data, size);
  351. item_default_data_addref(item);
  352. }
  353. *p_item = item;
  354. }
  355. static inline void
  356. obs_data_item_set_autoselect_data(struct obs_data_item **p_item,
  357. const void *data, size_t size,
  358. enum obs_data_type type)
  359. {
  360. if (!p_item || !*p_item)
  361. return;
  362. struct obs_data_item *item = *p_item;
  363. item_autoselect_data_release(item);
  364. item->autoselect_size = size;
  365. item->type = type;
  366. item->data_len = item->data_size ? get_align_size(item->data_size) : 0;
  367. item->default_len =
  368. item->default_size ? get_align_size(item->default_size) : 0;
  369. item = obs_data_item_ensure_capacity(item);
  370. if (size) {
  371. memcpy(get_item_autoselect_data(item), data, size);
  372. item_autoselect_data_addref(item);
  373. }
  374. *p_item = item;
  375. }
  376. /* ------------------------------------------------------------------------- */
  377. static void obs_data_add_json_item(obs_data_t *data, const char *key,
  378. json_t *json);
  379. static inline void obs_data_add_json_object_data(obs_data_t *data, json_t *jobj)
  380. {
  381. const char *item_key;
  382. json_t *jitem;
  383. json_object_foreach (jobj, item_key, jitem) {
  384. obs_data_add_json_item(data, item_key, jitem);
  385. }
  386. }
  387. static inline void obs_data_add_json_object(obs_data_t *data, const char *key,
  388. json_t *jobj)
  389. {
  390. obs_data_t *sub_obj = obs_data_create();
  391. obs_data_add_json_object_data(sub_obj, jobj);
  392. obs_data_set_obj(data, key, sub_obj);
  393. obs_data_release(sub_obj);
  394. }
  395. static void obs_data_add_json_array(obs_data_t *data, const char *key,
  396. json_t *jarray)
  397. {
  398. obs_data_array_t *array = obs_data_array_create();
  399. size_t idx;
  400. json_t *jitem;
  401. json_array_foreach (jarray, idx, jitem) {
  402. obs_data_t *item;
  403. if (!json_is_object(jitem))
  404. continue;
  405. item = obs_data_create();
  406. obs_data_add_json_object_data(item, jitem);
  407. obs_data_array_push_back(array, item);
  408. obs_data_release(item);
  409. }
  410. obs_data_set_array(data, key, array);
  411. obs_data_array_release(array);
  412. }
  413. static void obs_data_add_json_item(obs_data_t *data, const char *key,
  414. json_t *json)
  415. {
  416. if (json_is_object(json))
  417. obs_data_add_json_object(data, key, json);
  418. else if (json_is_array(json))
  419. obs_data_add_json_array(data, key, json);
  420. else if (json_is_string(json))
  421. obs_data_set_string(data, key, json_string_value(json));
  422. else if (json_is_integer(json))
  423. obs_data_set_int(data, key, json_integer_value(json));
  424. else if (json_is_real(json))
  425. obs_data_set_double(data, key, json_real_value(json));
  426. else if (json_is_true(json))
  427. obs_data_set_bool(data, key, true);
  428. else if (json_is_false(json))
  429. obs_data_set_bool(data, key, false);
  430. }
  431. /* ------------------------------------------------------------------------- */
  432. static inline void set_json_string(json_t *json, const char *name,
  433. obs_data_item_t *item)
  434. {
  435. const char *val = obs_data_item_get_string(item);
  436. json_object_set_new(json, name, json_string(val));
  437. }
  438. static inline void set_json_number(json_t *json, const char *name,
  439. obs_data_item_t *item)
  440. {
  441. enum obs_data_number_type type = obs_data_item_numtype(item);
  442. if (type == OBS_DATA_NUM_INT) {
  443. long long val = obs_data_item_get_int(item);
  444. json_object_set_new(json, name, json_integer(val));
  445. } else {
  446. double val = obs_data_item_get_double(item);
  447. json_object_set_new(json, name, json_real(val));
  448. }
  449. }
  450. static inline void set_json_bool(json_t *json, const char *name,
  451. obs_data_item_t *item)
  452. {
  453. bool val = obs_data_item_get_bool(item);
  454. json_object_set_new(json, name, val ? json_true() : json_false());
  455. }
  456. static json_t *obs_data_to_json(obs_data_t *data);
  457. static inline void set_json_obj(json_t *json, const char *name,
  458. obs_data_item_t *item)
  459. {
  460. obs_data_t *obj = obs_data_item_get_obj(item);
  461. json_object_set_new(json, name, obs_data_to_json(obj));
  462. obs_data_release(obj);
  463. }
  464. static inline void set_json_array(json_t *json, const char *name,
  465. obs_data_item_t *item)
  466. {
  467. json_t *jarray = json_array();
  468. obs_data_array_t *array = obs_data_item_get_array(item);
  469. size_t count = obs_data_array_count(array);
  470. for (size_t idx = 0; idx < count; idx++) {
  471. obs_data_t *sub_item = obs_data_array_item(array, idx);
  472. json_t *jitem = obs_data_to_json(sub_item);
  473. json_array_append_new(jarray, jitem);
  474. obs_data_release(sub_item);
  475. }
  476. json_object_set_new(json, name, jarray);
  477. obs_data_array_release(array);
  478. }
  479. static json_t *obs_data_to_json(obs_data_t *data)
  480. {
  481. json_t *json = json_object();
  482. obs_data_item_t *item = NULL;
  483. for (item = obs_data_first(data); item; obs_data_item_next(&item)) {
  484. enum obs_data_type type = obs_data_item_gettype(item);
  485. const char *name = get_item_name(item);
  486. if (!obs_data_item_has_user_value(item))
  487. continue;
  488. if (type == OBS_DATA_STRING)
  489. set_json_string(json, name, item);
  490. else if (type == OBS_DATA_NUMBER)
  491. set_json_number(json, name, item);
  492. else if (type == OBS_DATA_BOOLEAN)
  493. set_json_bool(json, name, item);
  494. else if (type == OBS_DATA_OBJECT)
  495. set_json_obj(json, name, item);
  496. else if (type == OBS_DATA_ARRAY)
  497. set_json_array(json, name, item);
  498. }
  499. return json;
  500. }
  501. /* ------------------------------------------------------------------------- */
  502. obs_data_t *obs_data_create()
  503. {
  504. struct obs_data *data = bzalloc(sizeof(struct obs_data));
  505. data->ref = 1;
  506. return data;
  507. }
  508. obs_data_t *obs_data_create_from_json(const char *json_string)
  509. {
  510. obs_data_t *data = obs_data_create();
  511. json_error_t error;
  512. json_t *root = json_loads(json_string, JSON_REJECT_DUPLICATES, &error);
  513. if (root) {
  514. obs_data_add_json_object_data(data, root);
  515. json_decref(root);
  516. } else {
  517. blog(LOG_ERROR,
  518. "obs-data.c: [obs_data_create_from_json] "
  519. "Failed reading json string (%d): %s",
  520. error.line, error.text);
  521. obs_data_release(data);
  522. data = NULL;
  523. }
  524. return data;
  525. }
  526. obs_data_t *obs_data_create_from_json_file(const char *json_file)
  527. {
  528. char *file_data = os_quick_read_utf8_file(json_file);
  529. obs_data_t *data = NULL;
  530. if (file_data) {
  531. data = obs_data_create_from_json(file_data);
  532. bfree(file_data);
  533. }
  534. return data;
  535. }
  536. obs_data_t *obs_data_create_from_json_file_safe(const char *json_file,
  537. const char *backup_ext)
  538. {
  539. obs_data_t *file_data = obs_data_create_from_json_file(json_file);
  540. if (!file_data && backup_ext && *backup_ext) {
  541. struct dstr backup_file = {0};
  542. dstr_copy(&backup_file, json_file);
  543. if (*backup_ext != '.')
  544. dstr_cat(&backup_file, ".");
  545. dstr_cat(&backup_file, backup_ext);
  546. if (os_file_exists(backup_file.array)) {
  547. blog(LOG_WARNING,
  548. "obs-data.c: "
  549. "[obs_data_create_from_json_file_safe] "
  550. "attempting backup file");
  551. /* delete current file if corrupt to prevent it from
  552. * being backed up again */
  553. os_rename(backup_file.array, json_file);
  554. file_data = obs_data_create_from_json_file(json_file);
  555. }
  556. dstr_free(&backup_file);
  557. }
  558. return file_data;
  559. }
  560. void obs_data_addref(obs_data_t *data)
  561. {
  562. if (data)
  563. os_atomic_inc_long(&data->ref);
  564. }
  565. static inline void obs_data_destroy(struct obs_data *data)
  566. {
  567. struct obs_data_item *item = data->first_item;
  568. while (item) {
  569. struct obs_data_item *next = item->next;
  570. obs_data_item_release(&item);
  571. item = next;
  572. }
  573. /* NOTE: don't use bfree for json text, allocated by json */
  574. free(data->json);
  575. bfree(data);
  576. }
  577. void obs_data_release(obs_data_t *data)
  578. {
  579. if (!data)
  580. return;
  581. if (os_atomic_dec_long(&data->ref) == 0)
  582. obs_data_destroy(data);
  583. }
  584. const char *obs_data_get_json(obs_data_t *data)
  585. {
  586. if (!data)
  587. return NULL;
  588. /* NOTE: don't use libobs bfree for json text */
  589. free(data->json);
  590. data->json = NULL;
  591. json_t *root = obs_data_to_json(data);
  592. data->json = json_dumps(root, JSON_PRESERVE_ORDER | JSON_COMPACT);
  593. json_decref(root);
  594. return data->json;
  595. }
  596. const char *obs_data_get_json_pretty(obs_data_t *data)
  597. {
  598. if (!data)
  599. return NULL;
  600. /* NOTE: don't use libobs bfree for json text */
  601. free(data->json);
  602. data->json = NULL;
  603. json_t *root = obs_data_to_json(data);
  604. data->json = json_dumps(root, JSON_PRESERVE_ORDER | JSON_INDENT(4));
  605. json_decref(root);
  606. return data->json;
  607. }
  608. const char *obs_data_get_last_json(obs_data_t *data)
  609. {
  610. return data ? data->json : NULL;
  611. }
  612. bool obs_data_save_json(obs_data_t *data, const char *file)
  613. {
  614. const char *json = obs_data_get_json(data);
  615. if (json && *json) {
  616. return os_quick_write_utf8_file(file, json, strlen(json),
  617. false);
  618. }
  619. return false;
  620. }
  621. bool obs_data_save_json_safe(obs_data_t *data, const char *file,
  622. const char *temp_ext, const char *backup_ext)
  623. {
  624. const char *json = obs_data_get_json(data);
  625. if (json && *json) {
  626. return os_quick_write_utf8_file_safe(
  627. file, json, strlen(json), false, temp_ext, backup_ext);
  628. }
  629. return false;
  630. }
  631. bool obs_data_save_json_pretty_safe(obs_data_t *data, const char *file,
  632. const char *temp_ext,
  633. const char *backup_ext)
  634. {
  635. const char *json = obs_data_get_json_pretty(data);
  636. if (json && *json) {
  637. return os_quick_write_utf8_file_safe(
  638. file, json, strlen(json), false, temp_ext, backup_ext);
  639. }
  640. return false;
  641. }
  642. static void get_defaults_array_cb(obs_data_t *data, void *vp)
  643. {
  644. obs_data_array_t *defs = (obs_data_array_t *)vp;
  645. obs_data_t *obs_defaults = obs_data_get_defaults(data);
  646. obs_data_array_push_back(defs, obs_defaults);
  647. obs_data_release(obs_defaults);
  648. }
  649. obs_data_t *obs_data_get_defaults(obs_data_t *data)
  650. {
  651. obs_data_t *defaults = obs_data_create();
  652. if (!data)
  653. return defaults;
  654. struct obs_data_item *item = data->first_item;
  655. while (item) {
  656. const char *name = get_item_name(item);
  657. switch (item->type) {
  658. case OBS_DATA_NULL:
  659. break;
  660. case OBS_DATA_STRING: {
  661. const char *str =
  662. obs_data_get_default_string(data, name);
  663. obs_data_set_string(defaults, name, str);
  664. break;
  665. }
  666. case OBS_DATA_NUMBER: {
  667. switch (obs_data_item_numtype(item)) {
  668. case OBS_DATA_NUM_DOUBLE: {
  669. double val =
  670. obs_data_get_default_double(data, name);
  671. obs_data_set_double(defaults, name, val);
  672. break;
  673. }
  674. case OBS_DATA_NUM_INT: {
  675. long long val =
  676. obs_data_get_default_int(data, name);
  677. obs_data_set_int(defaults, name, val);
  678. break;
  679. }
  680. case OBS_DATA_NUM_INVALID:
  681. break;
  682. }
  683. break;
  684. }
  685. case OBS_DATA_BOOLEAN: {
  686. bool val = obs_data_get_default_bool(data, name);
  687. obs_data_set_bool(defaults, name, val);
  688. break;
  689. }
  690. case OBS_DATA_OBJECT: {
  691. obs_data_t *val = obs_data_get_default_obj(data, name);
  692. obs_data_t *defs = obs_data_get_defaults(val);
  693. obs_data_set_obj(defaults, name, defs);
  694. obs_data_release(defs);
  695. obs_data_release(val);
  696. break;
  697. }
  698. case OBS_DATA_ARRAY: {
  699. obs_data_array_t *arr =
  700. obs_data_get_default_array(data, name);
  701. obs_data_array_t *defs = obs_data_array_create();
  702. obs_data_array_enum(arr, get_defaults_array_cb,
  703. (void *)defs);
  704. obs_data_set_array(defaults, name, defs);
  705. obs_data_array_release(defs);
  706. obs_data_array_release(arr);
  707. break;
  708. }
  709. }
  710. item = item->next;
  711. }
  712. return defaults;
  713. }
  714. static struct obs_data_item *get_item(struct obs_data *data, const char *name)
  715. {
  716. if (!data)
  717. return NULL;
  718. struct obs_data_item *item = data->first_item;
  719. while (item) {
  720. if (strcmp(get_item_name(item), name) == 0)
  721. return item;
  722. item = item->next;
  723. }
  724. return NULL;
  725. }
  726. static void set_item_data(struct obs_data *data, struct obs_data_item **item,
  727. const char *name, const void *ptr, size_t size,
  728. enum obs_data_type type, bool default_data,
  729. bool autoselect_data)
  730. {
  731. obs_data_item_t *new_item = NULL;
  732. if ((!item || !*item) && data) {
  733. new_item = obs_data_item_create(name, ptr, size, type,
  734. default_data, autoselect_data);
  735. obs_data_item_t *prev = obs_data_first(data);
  736. obs_data_item_t *next = obs_data_first(data);
  737. obs_data_item_next(&next);
  738. for (; prev && next;
  739. obs_data_item_next(&prev), obs_data_item_next(&next)) {
  740. if (strcmp(get_item_name(next), name) > 0)
  741. break;
  742. }
  743. new_item->parent = data;
  744. if (prev && strcmp(get_item_name(prev), name) < 0) {
  745. prev->next = new_item;
  746. new_item->next = next;
  747. } else {
  748. data->first_item = new_item;
  749. new_item->next = prev;
  750. }
  751. if (!prev)
  752. data->first_item = new_item;
  753. obs_data_item_release(&prev);
  754. obs_data_item_release(&next);
  755. } else if (default_data) {
  756. obs_data_item_set_default_data(item, ptr, size, type);
  757. } else if (autoselect_data) {
  758. obs_data_item_set_autoselect_data(item, ptr, size, type);
  759. } else {
  760. obs_data_item_setdata(item, ptr, size, type);
  761. }
  762. }
  763. static inline void set_item(struct obs_data *data, obs_data_item_t **item,
  764. const char *name, const void *ptr, size_t size,
  765. enum obs_data_type type)
  766. {
  767. obs_data_item_t *actual_item = NULL;
  768. if (!data && !item)
  769. return;
  770. if (!item) {
  771. actual_item = get_item(data, name);
  772. item = &actual_item;
  773. }
  774. set_item_data(data, item, name, ptr, size, type, false, false);
  775. }
  776. static inline void set_item_def(struct obs_data *data, obs_data_item_t **item,
  777. const char *name, const void *ptr, size_t size,
  778. enum obs_data_type type)
  779. {
  780. obs_data_item_t *actual_item = NULL;
  781. if (!data && !item)
  782. return;
  783. if (!item) {
  784. actual_item = get_item(data, name);
  785. item = &actual_item;
  786. }
  787. if (*item && (*item)->type != type)
  788. return;
  789. set_item_data(data, item, name, ptr, size, type, true, false);
  790. }
  791. static inline void set_item_auto(struct obs_data *data, obs_data_item_t **item,
  792. const char *name, const void *ptr, size_t size,
  793. enum obs_data_type type)
  794. {
  795. obs_data_item_t *actual_item = NULL;
  796. if (!data && !item)
  797. return;
  798. if (!item) {
  799. actual_item = get_item(data, name);
  800. item = &actual_item;
  801. }
  802. set_item_data(data, item, name, ptr, size, type, false, true);
  803. }
  804. static void copy_obj(struct obs_data *data, const char *name,
  805. struct obs_data *obj,
  806. void (*callback)(obs_data_t *, const char *, obs_data_t *))
  807. {
  808. if (obj) {
  809. obs_data_t *new_obj = obs_data_create();
  810. obs_data_apply(new_obj, obj);
  811. callback(data, name, new_obj);
  812. obs_data_release(new_obj);
  813. }
  814. }
  815. static void copy_array(struct obs_data *data, const char *name,
  816. struct obs_data_array *array,
  817. void (*callback)(obs_data_t *, const char *,
  818. obs_data_array_t *))
  819. {
  820. if (array) {
  821. obs_data_array_t *new_array = obs_data_array_create();
  822. da_reserve(new_array->objects, array->objects.num);
  823. for (size_t i = 0; i < array->objects.num; i++) {
  824. obs_data_t *new_obj = obs_data_create();
  825. obs_data_t *obj = array->objects.array[i];
  826. obs_data_apply(new_obj, obj);
  827. obs_data_array_push_back(new_array, new_obj);
  828. obs_data_release(new_obj);
  829. }
  830. callback(data, name, new_array);
  831. obs_data_array_release(new_array);
  832. }
  833. }
  834. static inline void copy_item(struct obs_data *data, struct obs_data_item *item)
  835. {
  836. const char *name = get_item_name(item);
  837. void *ptr = get_item_data(item);
  838. if (item->type == OBS_DATA_OBJECT) {
  839. obs_data_t **obj = item->data_size ? ptr : NULL;
  840. if (obj)
  841. copy_obj(data, name, *obj, obs_data_set_obj);
  842. } else if (item->type == OBS_DATA_ARRAY) {
  843. obs_data_array_t **array = item->data_size ? ptr : NULL;
  844. if (array)
  845. copy_array(data, name, *array, obs_data_set_array);
  846. } else {
  847. if (item->data_size)
  848. set_item(data, NULL, name, ptr, item->data_size,
  849. item->type);
  850. }
  851. }
  852. void obs_data_apply(obs_data_t *target, obs_data_t *apply_data)
  853. {
  854. struct obs_data_item *item;
  855. if (!target || !apply_data || target == apply_data)
  856. return;
  857. item = apply_data->first_item;
  858. while (item) {
  859. copy_item(target, item);
  860. item = item->next;
  861. }
  862. }
  863. void obs_data_erase(obs_data_t *data, const char *name)
  864. {
  865. struct obs_data_item *item = get_item(data, name);
  866. if (item) {
  867. obs_data_item_detach(item);
  868. obs_data_item_release(&item);
  869. }
  870. }
  871. static inline void clear_item(struct obs_data_item *item)
  872. {
  873. void *ptr = get_item_data(item);
  874. size_t size;
  875. if (item->data_len) {
  876. if (item->type == OBS_DATA_OBJECT) {
  877. obs_data_t **obj = item->data_size ? ptr : NULL;
  878. if (obj && *obj)
  879. obs_data_release(*obj);
  880. } else if (item->type == OBS_DATA_ARRAY) {
  881. obs_data_array_t **array = item->data_size ? ptr : NULL;
  882. if (array && *array)
  883. obs_data_array_release(*array);
  884. }
  885. size = item->default_len + item->autoselect_size;
  886. if (size)
  887. memmove(ptr, (uint8_t *)ptr + item->data_len, size);
  888. item->data_size = 0;
  889. item->data_len = 0;
  890. }
  891. }
  892. void obs_data_clear(obs_data_t *target)
  893. {
  894. struct obs_data_item *item;
  895. if (!target)
  896. return;
  897. item = target->first_item;
  898. while (item) {
  899. clear_item(item);
  900. item = item->next;
  901. }
  902. }
  903. typedef void (*set_item_t)(obs_data_t *, obs_data_item_t **, const char *,
  904. const void *, size_t, enum obs_data_type);
  905. static inline void obs_set_string(obs_data_t *data, obs_data_item_t **item,
  906. const char *name, const char *val,
  907. set_item_t set_item_)
  908. {
  909. if (!val)
  910. val = "";
  911. set_item_(data, item, name, val, strlen(val) + 1, OBS_DATA_STRING);
  912. }
  913. static inline void obs_set_int(obs_data_t *data, obs_data_item_t **item,
  914. const char *name, long long val,
  915. set_item_t set_item_)
  916. {
  917. struct obs_data_number num;
  918. num.type = OBS_DATA_NUM_INT;
  919. num.int_val = val;
  920. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  921. OBS_DATA_NUMBER);
  922. }
  923. static inline void obs_set_double(obs_data_t *data, obs_data_item_t **item,
  924. const char *name, double val,
  925. set_item_t set_item_)
  926. {
  927. struct obs_data_number num;
  928. num.type = OBS_DATA_NUM_DOUBLE;
  929. num.double_val = val;
  930. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  931. OBS_DATA_NUMBER);
  932. }
  933. static inline void obs_set_bool(obs_data_t *data, obs_data_item_t **item,
  934. const char *name, bool val,
  935. set_item_t set_item_)
  936. {
  937. set_item_(data, item, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  938. }
  939. static inline void obs_set_obj(obs_data_t *data, obs_data_item_t **item,
  940. const char *name, obs_data_t *obj,
  941. set_item_t set_item_)
  942. {
  943. set_item_(data, item, name, &obj, sizeof(obs_data_t *),
  944. OBS_DATA_OBJECT);
  945. }
  946. static inline void obs_set_array(obs_data_t *data, obs_data_item_t **item,
  947. const char *name, obs_data_array_t *array,
  948. set_item_t set_item_)
  949. {
  950. set_item_(data, item, name, &array, sizeof(obs_data_t *),
  951. OBS_DATA_ARRAY);
  952. }
  953. static inline void obs_take_obj(obs_data_t *data, obs_data_item_t **item,
  954. const char *name, obs_data_t *obj,
  955. set_item_t set_item_)
  956. {
  957. obs_set_obj(data, item, name, obj, set_item_);
  958. obs_data_release(obj);
  959. }
  960. void obs_data_set_string(obs_data_t *data, const char *name, const char *val)
  961. {
  962. obs_set_string(data, NULL, name, val, set_item);
  963. }
  964. void obs_data_set_int(obs_data_t *data, const char *name, long long val)
  965. {
  966. obs_set_int(data, NULL, name, val, set_item);
  967. }
  968. void obs_data_set_double(obs_data_t *data, const char *name, double val)
  969. {
  970. obs_set_double(data, NULL, name, val, set_item);
  971. }
  972. void obs_data_set_bool(obs_data_t *data, const char *name, bool val)
  973. {
  974. obs_set_bool(data, NULL, name, val, set_item);
  975. }
  976. void obs_data_set_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  977. {
  978. obs_set_obj(data, NULL, name, obj, set_item);
  979. }
  980. void obs_data_set_array(obs_data_t *data, const char *name,
  981. obs_data_array_t *array)
  982. {
  983. obs_set_array(data, NULL, name, array, set_item);
  984. }
  985. void obs_data_set_default_string(obs_data_t *data, const char *name,
  986. const char *val)
  987. {
  988. obs_set_string(data, NULL, name, val, set_item_def);
  989. }
  990. void obs_data_set_default_int(obs_data_t *data, const char *name, long long val)
  991. {
  992. obs_set_int(data, NULL, name, val, set_item_def);
  993. }
  994. void obs_data_set_default_double(obs_data_t *data, const char *name, double val)
  995. {
  996. obs_set_double(data, NULL, name, val, set_item_def);
  997. }
  998. void obs_data_set_default_bool(obs_data_t *data, const char *name, bool val)
  999. {
  1000. obs_set_bool(data, NULL, name, val, set_item_def);
  1001. }
  1002. void obs_data_set_default_obj(obs_data_t *data, const char *name,
  1003. obs_data_t *obj)
  1004. {
  1005. obs_set_obj(data, NULL, name, obj, set_item_def);
  1006. }
  1007. void obs_data_set_default_array(obs_data_t *data, const char *name,
  1008. obs_data_array_t *arr)
  1009. {
  1010. obs_set_array(data, NULL, name, arr, set_item_def);
  1011. }
  1012. void obs_data_set_autoselect_string(obs_data_t *data, const char *name,
  1013. const char *val)
  1014. {
  1015. obs_set_string(data, NULL, name, val, set_item_auto);
  1016. }
  1017. void obs_data_set_autoselect_int(obs_data_t *data, const char *name,
  1018. long long val)
  1019. {
  1020. obs_set_int(data, NULL, name, val, set_item_auto);
  1021. }
  1022. void obs_data_set_autoselect_double(obs_data_t *data, const char *name,
  1023. double val)
  1024. {
  1025. obs_set_double(data, NULL, name, val, set_item_auto);
  1026. }
  1027. void obs_data_set_autoselect_bool(obs_data_t *data, const char *name, bool val)
  1028. {
  1029. obs_set_bool(data, NULL, name, val, set_item_auto);
  1030. }
  1031. void obs_data_set_autoselect_obj(obs_data_t *data, const char *name,
  1032. obs_data_t *obj)
  1033. {
  1034. obs_set_obj(data, NULL, name, obj, set_item_auto);
  1035. }
  1036. void obs_data_set_autoselect_array(obs_data_t *data, const char *name,
  1037. obs_data_array_t *arr)
  1038. {
  1039. obs_set_array(data, NULL, name, arr, set_item_auto);
  1040. }
  1041. const char *obs_data_get_string(obs_data_t *data, const char *name)
  1042. {
  1043. return obs_data_item_get_string(get_item(data, name));
  1044. }
  1045. long long obs_data_get_int(obs_data_t *data, const char *name)
  1046. {
  1047. return obs_data_item_get_int(get_item(data, name));
  1048. }
  1049. double obs_data_get_double(obs_data_t *data, const char *name)
  1050. {
  1051. return obs_data_item_get_double(get_item(data, name));
  1052. }
  1053. bool obs_data_get_bool(obs_data_t *data, const char *name)
  1054. {
  1055. return obs_data_item_get_bool(get_item(data, name));
  1056. }
  1057. obs_data_t *obs_data_get_obj(obs_data_t *data, const char *name)
  1058. {
  1059. return obs_data_item_get_obj(get_item(data, name));
  1060. }
  1061. obs_data_array_t *obs_data_get_array(obs_data_t *data, const char *name)
  1062. {
  1063. return obs_data_item_get_array(get_item(data, name));
  1064. }
  1065. const char *obs_data_get_default_string(obs_data_t *data, const char *name)
  1066. {
  1067. return obs_data_item_get_default_string(get_item(data, name));
  1068. }
  1069. long long obs_data_get_default_int(obs_data_t *data, const char *name)
  1070. {
  1071. return obs_data_item_get_default_int(get_item(data, name));
  1072. }
  1073. double obs_data_get_default_double(obs_data_t *data, const char *name)
  1074. {
  1075. return obs_data_item_get_default_double(get_item(data, name));
  1076. }
  1077. bool obs_data_get_default_bool(obs_data_t *data, const char *name)
  1078. {
  1079. return obs_data_item_get_default_bool(get_item(data, name));
  1080. }
  1081. obs_data_t *obs_data_get_default_obj(obs_data_t *data, const char *name)
  1082. {
  1083. return obs_data_item_get_default_obj(get_item(data, name));
  1084. }
  1085. obs_data_array_t *obs_data_get_default_array(obs_data_t *data, const char *name)
  1086. {
  1087. return obs_data_item_get_default_array(get_item(data, name));
  1088. }
  1089. const char *obs_data_get_autoselect_string(obs_data_t *data, const char *name)
  1090. {
  1091. return obs_data_item_get_autoselect_string(get_item(data, name));
  1092. }
  1093. long long obs_data_get_autoselect_int(obs_data_t *data, const char *name)
  1094. {
  1095. return obs_data_item_get_autoselect_int(get_item(data, name));
  1096. }
  1097. double obs_data_get_autoselect_double(obs_data_t *data, const char *name)
  1098. {
  1099. return obs_data_item_get_autoselect_double(get_item(data, name));
  1100. }
  1101. bool obs_data_get_autoselect_bool(obs_data_t *data, const char *name)
  1102. {
  1103. return obs_data_item_get_autoselect_bool(get_item(data, name));
  1104. }
  1105. obs_data_t *obs_data_get_autoselect_obj(obs_data_t *data, const char *name)
  1106. {
  1107. return obs_data_item_get_autoselect_obj(get_item(data, name));
  1108. }
  1109. obs_data_array_t *obs_data_get_autoselect_array(obs_data_t *data,
  1110. const char *name)
  1111. {
  1112. return obs_data_item_get_autoselect_array(get_item(data, name));
  1113. }
  1114. obs_data_array_t *obs_data_array_create()
  1115. {
  1116. struct obs_data_array *array = bzalloc(sizeof(struct obs_data_array));
  1117. array->ref = 1;
  1118. return array;
  1119. }
  1120. void obs_data_array_addref(obs_data_array_t *array)
  1121. {
  1122. if (array)
  1123. os_atomic_inc_long(&array->ref);
  1124. }
  1125. static inline void obs_data_array_destroy(obs_data_array_t *array)
  1126. {
  1127. if (array) {
  1128. for (size_t i = 0; i < array->objects.num; i++)
  1129. obs_data_release(array->objects.array[i]);
  1130. da_free(array->objects);
  1131. bfree(array);
  1132. }
  1133. }
  1134. void obs_data_array_release(obs_data_array_t *array)
  1135. {
  1136. if (!array)
  1137. return;
  1138. if (os_atomic_dec_long(&array->ref) == 0)
  1139. obs_data_array_destroy(array);
  1140. }
  1141. size_t obs_data_array_count(obs_data_array_t *array)
  1142. {
  1143. return array ? array->objects.num : 0;
  1144. }
  1145. obs_data_t *obs_data_array_item(obs_data_array_t *array, size_t idx)
  1146. {
  1147. obs_data_t *data;
  1148. if (!array)
  1149. return NULL;
  1150. data = (idx < array->objects.num) ? array->objects.array[idx] : NULL;
  1151. if (data)
  1152. os_atomic_inc_long(&data->ref);
  1153. return data;
  1154. }
  1155. size_t obs_data_array_push_back(obs_data_array_t *array, obs_data_t *obj)
  1156. {
  1157. if (!array || !obj)
  1158. return 0;
  1159. os_atomic_inc_long(&obj->ref);
  1160. return da_push_back(array->objects, &obj);
  1161. }
  1162. void obs_data_array_insert(obs_data_array_t *array, size_t idx, obs_data_t *obj)
  1163. {
  1164. if (!array || !obj)
  1165. return;
  1166. os_atomic_inc_long(&obj->ref);
  1167. da_insert(array->objects, idx, &obj);
  1168. }
  1169. void obs_data_array_push_back_array(obs_data_array_t *array,
  1170. obs_data_array_t *array2)
  1171. {
  1172. if (!array || !array2)
  1173. return;
  1174. for (size_t i = 0; i < array2->objects.num; i++) {
  1175. obs_data_t *obj = array2->objects.array[i];
  1176. obs_data_addref(obj);
  1177. }
  1178. da_push_back_da(array->objects, array2->objects);
  1179. }
  1180. void obs_data_array_erase(obs_data_array_t *array, size_t idx)
  1181. {
  1182. if (array) {
  1183. obs_data_release(array->objects.array[idx]);
  1184. da_erase(array->objects, idx);
  1185. }
  1186. }
  1187. void obs_data_array_enum(obs_data_array_t *array,
  1188. void (*cb)(obs_data_t *data, void *param), void *param)
  1189. {
  1190. if (array && cb) {
  1191. for (size_t i = 0; i < array->objects.num; i++) {
  1192. cb(array->objects.array[i], param);
  1193. }
  1194. }
  1195. }
  1196. /* ------------------------------------------------------------------------- */
  1197. /* Item status inspection */
  1198. bool obs_data_has_user_value(obs_data_t *data, const char *name)
  1199. {
  1200. return data && obs_data_item_has_user_value(get_item(data, name));
  1201. }
  1202. bool obs_data_has_default_value(obs_data_t *data, const char *name)
  1203. {
  1204. return data && obs_data_item_has_default_value(get_item(data, name));
  1205. }
  1206. bool obs_data_has_autoselect_value(obs_data_t *data, const char *name)
  1207. {
  1208. return data && obs_data_item_has_autoselect_value(get_item(data, name));
  1209. }
  1210. bool obs_data_item_has_user_value(obs_data_item_t *item)
  1211. {
  1212. return item && item->data_size;
  1213. }
  1214. bool obs_data_item_has_default_value(obs_data_item_t *item)
  1215. {
  1216. return item && item->default_size;
  1217. }
  1218. bool obs_data_item_has_autoselect_value(obs_data_item_t *item)
  1219. {
  1220. return item && item->autoselect_size;
  1221. }
  1222. /* ------------------------------------------------------------------------- */
  1223. /* Clearing data values */
  1224. void obs_data_unset_user_value(obs_data_t *data, const char *name)
  1225. {
  1226. obs_data_item_unset_user_value(get_item(data, name));
  1227. }
  1228. void obs_data_unset_default_value(obs_data_t *data, const char *name)
  1229. {
  1230. obs_data_item_unset_default_value(get_item(data, name));
  1231. }
  1232. void obs_data_unset_autoselect_value(obs_data_t *data, const char *name)
  1233. {
  1234. obs_data_item_unset_autoselect_value(get_item(data, name));
  1235. }
  1236. void obs_data_item_unset_user_value(obs_data_item_t *item)
  1237. {
  1238. if (!item || !item->data_size)
  1239. return;
  1240. void *old_non_user_data = get_default_data_ptr(item);
  1241. item_data_release(item);
  1242. item->data_size = 0;
  1243. item->data_len = 0;
  1244. if (item->default_size || item->autoselect_size)
  1245. move_data(item, old_non_user_data, item,
  1246. get_default_data_ptr(item),
  1247. item->default_len + item->autoselect_size);
  1248. }
  1249. void obs_data_item_unset_default_value(obs_data_item_t *item)
  1250. {
  1251. if (!item || !item->default_size)
  1252. return;
  1253. void *old_autoselect_data = get_autoselect_data_ptr(item);
  1254. item_default_data_release(item);
  1255. item->default_size = 0;
  1256. item->default_len = 0;
  1257. if (item->autoselect_size)
  1258. move_data(item, old_autoselect_data, item,
  1259. get_autoselect_data_ptr(item), item->autoselect_size);
  1260. }
  1261. void obs_data_item_unset_autoselect_value(obs_data_item_t *item)
  1262. {
  1263. if (!item || !item->autoselect_size)
  1264. return;
  1265. item_autoselect_data_release(item);
  1266. item->autoselect_size = 0;
  1267. }
  1268. /* ------------------------------------------------------------------------- */
  1269. /* Item iteration */
  1270. obs_data_item_t *obs_data_first(obs_data_t *data)
  1271. {
  1272. if (!data)
  1273. return NULL;
  1274. if (data->first_item)
  1275. os_atomic_inc_long(&data->first_item->ref);
  1276. return data->first_item;
  1277. }
  1278. obs_data_item_t *obs_data_item_byname(obs_data_t *data, const char *name)
  1279. {
  1280. if (!data)
  1281. return NULL;
  1282. struct obs_data_item *item = get_item(data, name);
  1283. if (item)
  1284. os_atomic_inc_long(&item->ref);
  1285. return item;
  1286. }
  1287. bool obs_data_item_next(obs_data_item_t **item)
  1288. {
  1289. if (item && *item) {
  1290. obs_data_item_t *next = (*item)->next;
  1291. obs_data_item_release(item);
  1292. *item = next;
  1293. if (next) {
  1294. os_atomic_inc_long(&next->ref);
  1295. return true;
  1296. }
  1297. }
  1298. return false;
  1299. }
  1300. void obs_data_item_release(obs_data_item_t **item)
  1301. {
  1302. if (item && *item) {
  1303. long ref = os_atomic_dec_long(&(*item)->ref);
  1304. if (!ref) {
  1305. obs_data_item_destroy(*item);
  1306. *item = NULL;
  1307. }
  1308. }
  1309. }
  1310. void obs_data_item_remove(obs_data_item_t **item)
  1311. {
  1312. if (item && *item) {
  1313. obs_data_item_detach(*item);
  1314. obs_data_item_release(item);
  1315. }
  1316. }
  1317. enum obs_data_type obs_data_item_gettype(obs_data_item_t *item)
  1318. {
  1319. return item ? item->type : OBS_DATA_NULL;
  1320. }
  1321. enum obs_data_number_type obs_data_item_numtype(obs_data_item_t *item)
  1322. {
  1323. struct obs_data_number *num;
  1324. if (!item || item->type != OBS_DATA_NUMBER)
  1325. return OBS_DATA_NUM_INVALID;
  1326. num = get_item_data(item);
  1327. if (!num)
  1328. return OBS_DATA_NUM_INVALID;
  1329. return num->type;
  1330. }
  1331. const char *obs_data_item_get_name(obs_data_item_t *item)
  1332. {
  1333. if (!item)
  1334. return NULL;
  1335. return get_item_name(item);
  1336. }
  1337. void obs_data_item_set_string(obs_data_item_t **item, const char *val)
  1338. {
  1339. obs_set_string(NULL, item, NULL, val, set_item);
  1340. }
  1341. void obs_data_item_set_int(obs_data_item_t **item, long long val)
  1342. {
  1343. obs_set_int(NULL, item, NULL, val, set_item);
  1344. }
  1345. void obs_data_item_set_double(obs_data_item_t **item, double val)
  1346. {
  1347. obs_set_double(NULL, item, NULL, val, set_item);
  1348. }
  1349. void obs_data_item_set_bool(obs_data_item_t **item, bool val)
  1350. {
  1351. obs_set_bool(NULL, item, NULL, val, set_item);
  1352. }
  1353. void obs_data_item_set_obj(obs_data_item_t **item, obs_data_t *val)
  1354. {
  1355. obs_set_obj(NULL, item, NULL, val, set_item);
  1356. }
  1357. void obs_data_item_set_array(obs_data_item_t **item, obs_data_array_t *val)
  1358. {
  1359. obs_set_array(NULL, item, NULL, val, set_item);
  1360. }
  1361. void obs_data_item_set_default_string(obs_data_item_t **item, const char *val)
  1362. {
  1363. obs_set_string(NULL, item, NULL, val, set_item_def);
  1364. }
  1365. void obs_data_item_set_default_int(obs_data_item_t **item, long long val)
  1366. {
  1367. obs_set_int(NULL, item, NULL, val, set_item_def);
  1368. }
  1369. void obs_data_item_set_default_double(obs_data_item_t **item, double val)
  1370. {
  1371. obs_set_double(NULL, item, NULL, val, set_item_def);
  1372. }
  1373. void obs_data_item_set_default_bool(obs_data_item_t **item, bool val)
  1374. {
  1375. obs_set_bool(NULL, item, NULL, val, set_item_def);
  1376. }
  1377. void obs_data_item_set_default_obj(obs_data_item_t **item, obs_data_t *val)
  1378. {
  1379. obs_set_obj(NULL, item, NULL, val, set_item_def);
  1380. }
  1381. void obs_data_item_set_default_array(obs_data_item_t **item,
  1382. obs_data_array_t *val)
  1383. {
  1384. obs_set_array(NULL, item, NULL, val, set_item_def);
  1385. }
  1386. void obs_data_item_set_autoselect_string(obs_data_item_t **item,
  1387. const char *val)
  1388. {
  1389. obs_set_string(NULL, item, NULL, val, set_item_auto);
  1390. }
  1391. void obs_data_item_set_autoselect_int(obs_data_item_t **item, long long val)
  1392. {
  1393. obs_set_int(NULL, item, NULL, val, set_item_auto);
  1394. }
  1395. void obs_data_item_set_autoselect_double(obs_data_item_t **item, double val)
  1396. {
  1397. obs_set_double(NULL, item, NULL, val, set_item_auto);
  1398. }
  1399. void obs_data_item_set_autoselect_bool(obs_data_item_t **item, bool val)
  1400. {
  1401. obs_set_bool(NULL, item, NULL, val, set_item_auto);
  1402. }
  1403. void obs_data_item_set_autoselect_obj(obs_data_item_t **item, obs_data_t *val)
  1404. {
  1405. obs_set_obj(NULL, item, NULL, val, set_item_auto);
  1406. }
  1407. void obs_data_item_set_autoselect_array(obs_data_item_t **item,
  1408. obs_data_array_t *val)
  1409. {
  1410. obs_set_array(NULL, item, NULL, val, set_item_auto);
  1411. }
  1412. static inline bool item_valid(struct obs_data_item *item,
  1413. enum obs_data_type type)
  1414. {
  1415. return item && item->type == type;
  1416. }
  1417. typedef void *(*get_data_t)(obs_data_item_t *);
  1418. static inline const char *data_item_get_string(obs_data_item_t *item,
  1419. get_data_t get_data)
  1420. {
  1421. const char *str;
  1422. return item_valid(item, OBS_DATA_STRING) && (str = get_data(item)) ? str
  1423. : "";
  1424. }
  1425. static inline long long item_int(struct obs_data_item *item,
  1426. get_data_t get_data)
  1427. {
  1428. struct obs_data_number *num;
  1429. if (item && (num = get_data(item))) {
  1430. return (num->type == OBS_DATA_NUM_INT)
  1431. ? num->int_val
  1432. : (long long)num->double_val;
  1433. }
  1434. return 0;
  1435. }
  1436. static inline long long data_item_get_int(obs_data_item_t *item,
  1437. get_data_t get_data)
  1438. {
  1439. return item_int(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1440. get_data);
  1441. }
  1442. static inline double item_double(struct obs_data_item *item,
  1443. get_data_t get_data)
  1444. {
  1445. struct obs_data_number *num;
  1446. if (item && (num = get_data(item))) {
  1447. return (num->type == OBS_DATA_NUM_INT) ? (double)num->int_val
  1448. : num->double_val;
  1449. }
  1450. return 0.0;
  1451. }
  1452. static inline double data_item_get_double(obs_data_item_t *item,
  1453. get_data_t get_data)
  1454. {
  1455. return item_double(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1456. get_data);
  1457. }
  1458. static inline bool data_item_get_bool(obs_data_item_t *item,
  1459. get_data_t get_data)
  1460. {
  1461. bool *data;
  1462. return item_valid(item, OBS_DATA_BOOLEAN) && (data = get_data(item))
  1463. ? *data
  1464. : false;
  1465. }
  1466. typedef obs_data_t *(*get_obj_t)(obs_data_item_t *);
  1467. static inline obs_data_t *data_item_get_obj(obs_data_item_t *item,
  1468. get_obj_t get_obj)
  1469. {
  1470. obs_data_t *obj = item_valid(item, OBS_DATA_OBJECT) ? get_obj(item)
  1471. : NULL;
  1472. if (obj)
  1473. os_atomic_inc_long(&obj->ref);
  1474. return obj;
  1475. }
  1476. typedef obs_data_array_t *(*get_array_t)(obs_data_item_t *);
  1477. static inline obs_data_array_t *data_item_get_array(obs_data_item_t *item,
  1478. get_array_t get_array)
  1479. {
  1480. obs_data_array_t *array =
  1481. item_valid(item, OBS_DATA_ARRAY) ? get_array(item) : NULL;
  1482. if (array)
  1483. os_atomic_inc_long(&array->ref);
  1484. return array;
  1485. }
  1486. const char *obs_data_item_get_string(obs_data_item_t *item)
  1487. {
  1488. return data_item_get_string(item, get_item_data);
  1489. }
  1490. long long obs_data_item_get_int(obs_data_item_t *item)
  1491. {
  1492. return data_item_get_int(item, get_item_data);
  1493. }
  1494. double obs_data_item_get_double(obs_data_item_t *item)
  1495. {
  1496. return data_item_get_double(item, get_item_data);
  1497. }
  1498. bool obs_data_item_get_bool(obs_data_item_t *item)
  1499. {
  1500. return data_item_get_bool(item, get_item_data);
  1501. }
  1502. obs_data_t *obs_data_item_get_obj(obs_data_item_t *item)
  1503. {
  1504. return data_item_get_obj(item, get_item_obj);
  1505. }
  1506. obs_data_array_t *obs_data_item_get_array(obs_data_item_t *item)
  1507. {
  1508. return data_item_get_array(item, get_item_array);
  1509. }
  1510. const char *obs_data_item_get_default_string(obs_data_item_t *item)
  1511. {
  1512. return data_item_get_string(item, get_item_default_data);
  1513. }
  1514. long long obs_data_item_get_default_int(obs_data_item_t *item)
  1515. {
  1516. return data_item_get_int(item, get_item_default_data);
  1517. }
  1518. double obs_data_item_get_default_double(obs_data_item_t *item)
  1519. {
  1520. return data_item_get_double(item, get_item_default_data);
  1521. }
  1522. bool obs_data_item_get_default_bool(obs_data_item_t *item)
  1523. {
  1524. return data_item_get_bool(item, get_item_default_data);
  1525. }
  1526. obs_data_t *obs_data_item_get_default_obj(obs_data_item_t *item)
  1527. {
  1528. return data_item_get_obj(item, get_item_default_obj);
  1529. }
  1530. obs_data_array_t *obs_data_item_get_default_array(obs_data_item_t *item)
  1531. {
  1532. return data_item_get_array(item, get_item_default_array);
  1533. }
  1534. const char *obs_data_item_get_autoselect_string(obs_data_item_t *item)
  1535. {
  1536. return data_item_get_string(item, get_item_autoselect_data);
  1537. }
  1538. long long obs_data_item_get_autoselect_int(obs_data_item_t *item)
  1539. {
  1540. return data_item_get_int(item, get_item_autoselect_data);
  1541. }
  1542. double obs_data_item_get_autoselect_double(obs_data_item_t *item)
  1543. {
  1544. return data_item_get_double(item, get_item_autoselect_data);
  1545. }
  1546. bool obs_data_item_get_autoselect_bool(obs_data_item_t *item)
  1547. {
  1548. return data_item_get_bool(item, get_item_autoselect_data);
  1549. }
  1550. obs_data_t *obs_data_item_get_autoselect_obj(obs_data_item_t *item)
  1551. {
  1552. return data_item_get_obj(item, get_item_autoselect_obj);
  1553. }
  1554. obs_data_array_t *obs_data_item_get_autoselect_array(obs_data_item_t *item)
  1555. {
  1556. return data_item_get_array(item, get_item_autoselect_array);
  1557. }
  1558. /* ------------------------------------------------------------------------- */
  1559. /* Helper functions for certain structures */
  1560. typedef void (*set_obj_t)(obs_data_t *, const char *, obs_data_t *);
  1561. static inline void set_vec2(obs_data_t *data, const char *name,
  1562. const struct vec2 *val, set_obj_t set_obj)
  1563. {
  1564. obs_data_t *obj = obs_data_create();
  1565. obs_data_set_double(obj, "x", val->x);
  1566. obs_data_set_double(obj, "y", val->y);
  1567. set_obj(data, name, obj);
  1568. obs_data_release(obj);
  1569. }
  1570. static inline void set_vec3(obs_data_t *data, const char *name,
  1571. const struct vec3 *val, set_obj_t set_obj)
  1572. {
  1573. obs_data_t *obj = obs_data_create();
  1574. obs_data_set_double(obj, "x", val->x);
  1575. obs_data_set_double(obj, "y", val->y);
  1576. obs_data_set_double(obj, "z", val->z);
  1577. set_obj(data, name, obj);
  1578. obs_data_release(obj);
  1579. }
  1580. static inline void set_vec4(obs_data_t *data, const char *name,
  1581. const struct vec4 *val, set_obj_t set_obj)
  1582. {
  1583. obs_data_t *obj = obs_data_create();
  1584. obs_data_set_double(obj, "x", val->x);
  1585. obs_data_set_double(obj, "y", val->y);
  1586. obs_data_set_double(obj, "z", val->z);
  1587. obs_data_set_double(obj, "w", val->w);
  1588. set_obj(data, name, obj);
  1589. obs_data_release(obj);
  1590. }
  1591. static inline void set_quat(obs_data_t *data, const char *name,
  1592. const struct quat *val, set_obj_t set_obj)
  1593. {
  1594. obs_data_t *obj = obs_data_create();
  1595. obs_data_set_double(obj, "x", val->x);
  1596. obs_data_set_double(obj, "y", val->y);
  1597. obs_data_set_double(obj, "z", val->z);
  1598. obs_data_set_double(obj, "w", val->w);
  1599. set_obj(data, name, obj);
  1600. obs_data_release(obj);
  1601. }
  1602. void obs_data_set_vec2(obs_data_t *data, const char *name,
  1603. const struct vec2 *val)
  1604. {
  1605. set_vec2(data, name, val, obs_data_set_obj);
  1606. }
  1607. void obs_data_set_vec3(obs_data_t *data, const char *name,
  1608. const struct vec3 *val)
  1609. {
  1610. set_vec3(data, name, val, obs_data_set_obj);
  1611. }
  1612. void obs_data_set_vec4(obs_data_t *data, const char *name,
  1613. const struct vec4 *val)
  1614. {
  1615. set_vec4(data, name, val, obs_data_set_obj);
  1616. }
  1617. void obs_data_set_quat(obs_data_t *data, const char *name,
  1618. const struct quat *val)
  1619. {
  1620. set_quat(data, name, val, obs_data_set_obj);
  1621. }
  1622. void obs_data_set_default_vec2(obs_data_t *data, const char *name,
  1623. const struct vec2 *val)
  1624. {
  1625. set_vec2(data, name, val, obs_data_set_default_obj);
  1626. }
  1627. void obs_data_set_default_vec3(obs_data_t *data, const char *name,
  1628. const struct vec3 *val)
  1629. {
  1630. set_vec3(data, name, val, obs_data_set_default_obj);
  1631. }
  1632. void obs_data_set_default_vec4(obs_data_t *data, const char *name,
  1633. const struct vec4 *val)
  1634. {
  1635. set_vec4(data, name, val, obs_data_set_default_obj);
  1636. }
  1637. void obs_data_set_default_quat(obs_data_t *data, const char *name,
  1638. const struct quat *val)
  1639. {
  1640. set_quat(data, name, val, obs_data_set_default_obj);
  1641. }
  1642. void obs_data_set_autoselect_vec2(obs_data_t *data, const char *name,
  1643. const struct vec2 *val)
  1644. {
  1645. set_vec2(data, name, val, obs_data_set_autoselect_obj);
  1646. }
  1647. void obs_data_set_autoselect_vec3(obs_data_t *data, const char *name,
  1648. const struct vec3 *val)
  1649. {
  1650. set_vec3(data, name, val, obs_data_set_autoselect_obj);
  1651. }
  1652. void obs_data_set_autoselect_vec4(obs_data_t *data, const char *name,
  1653. const struct vec4 *val)
  1654. {
  1655. set_vec4(data, name, val, obs_data_set_autoselect_obj);
  1656. }
  1657. void obs_data_set_autoselect_quat(obs_data_t *data, const char *name,
  1658. const struct quat *val)
  1659. {
  1660. set_quat(data, name, val, obs_data_set_autoselect_obj);
  1661. }
  1662. static inline void get_vec2(obs_data_t *obj, struct vec2 *val)
  1663. {
  1664. if (!obj)
  1665. return;
  1666. val->x = (float)obs_data_get_double(obj, "x");
  1667. val->y = (float)obs_data_get_double(obj, "y");
  1668. obs_data_release(obj);
  1669. }
  1670. static inline void get_vec3(obs_data_t *obj, struct vec3 *val)
  1671. {
  1672. if (!obj)
  1673. return;
  1674. val->x = (float)obs_data_get_double(obj, "x");
  1675. val->y = (float)obs_data_get_double(obj, "y");
  1676. val->z = (float)obs_data_get_double(obj, "z");
  1677. obs_data_release(obj);
  1678. }
  1679. static inline void get_vec4(obs_data_t *obj, struct vec4 *val)
  1680. {
  1681. if (!obj)
  1682. return;
  1683. val->x = (float)obs_data_get_double(obj, "x");
  1684. val->y = (float)obs_data_get_double(obj, "y");
  1685. val->z = (float)obs_data_get_double(obj, "z");
  1686. val->w = (float)obs_data_get_double(obj, "w");
  1687. obs_data_release(obj);
  1688. }
  1689. static inline void get_quat(obs_data_t *obj, struct quat *val)
  1690. {
  1691. if (!obj)
  1692. return;
  1693. val->x = (float)obs_data_get_double(obj, "x");
  1694. val->y = (float)obs_data_get_double(obj, "y");
  1695. val->z = (float)obs_data_get_double(obj, "z");
  1696. val->w = (float)obs_data_get_double(obj, "w");
  1697. obs_data_release(obj);
  1698. }
  1699. void obs_data_get_vec2(obs_data_t *data, const char *name, struct vec2 *val)
  1700. {
  1701. get_vec2(obs_data_get_obj(data, name), val);
  1702. }
  1703. void obs_data_get_vec3(obs_data_t *data, const char *name, struct vec3 *val)
  1704. {
  1705. get_vec3(obs_data_get_obj(data, name), val);
  1706. }
  1707. void obs_data_get_vec4(obs_data_t *data, const char *name, struct vec4 *val)
  1708. {
  1709. get_vec4(obs_data_get_obj(data, name), val);
  1710. }
  1711. void obs_data_get_quat(obs_data_t *data, const char *name, struct quat *val)
  1712. {
  1713. get_quat(obs_data_get_obj(data, name), val);
  1714. }
  1715. void obs_data_get_default_vec2(obs_data_t *data, const char *name,
  1716. struct vec2 *val)
  1717. {
  1718. get_vec2(obs_data_get_default_obj(data, name), val);
  1719. }
  1720. void obs_data_get_default_vec3(obs_data_t *data, const char *name,
  1721. struct vec3 *val)
  1722. {
  1723. get_vec3(obs_data_get_default_obj(data, name), val);
  1724. }
  1725. void obs_data_get_default_vec4(obs_data_t *data, const char *name,
  1726. struct vec4 *val)
  1727. {
  1728. get_vec4(obs_data_get_default_obj(data, name), val);
  1729. }
  1730. void obs_data_get_default_quat(obs_data_t *data, const char *name,
  1731. struct quat *val)
  1732. {
  1733. get_quat(obs_data_get_default_obj(data, name), val);
  1734. }
  1735. void obs_data_get_autoselect_vec2(obs_data_t *data, const char *name,
  1736. struct vec2 *val)
  1737. {
  1738. get_vec2(obs_data_get_autoselect_obj(data, name), val);
  1739. }
  1740. void obs_data_get_autoselect_vec3(obs_data_t *data, const char *name,
  1741. struct vec3 *val)
  1742. {
  1743. get_vec3(obs_data_get_autoselect_obj(data, name), val);
  1744. }
  1745. void obs_data_get_autoselect_vec4(obs_data_t *data, const char *name,
  1746. struct vec4 *val)
  1747. {
  1748. get_vec4(obs_data_get_autoselect_obj(data, name), val);
  1749. }
  1750. void obs_data_get_autoselect_quat(obs_data_t *data, const char *name,
  1751. struct quat *val)
  1752. {
  1753. get_quat(obs_data_get_autoselect_obj(data, name), val);
  1754. }
  1755. /* ------------------------------------------------------------------------- */
  1756. /* Helper functions for media_frames_per_seconds */
  1757. static inline obs_data_t *
  1758. make_frames_per_second(struct media_frames_per_second fps, const char *option)
  1759. {
  1760. obs_data_t *obj = obs_data_create();
  1761. if (!option) {
  1762. obs_data_set_double(obj, "numerator", fps.numerator);
  1763. obs_data_set_double(obj, "denominator", fps.denominator);
  1764. } else {
  1765. obs_data_set_string(obj, "option", option);
  1766. }
  1767. return obj;
  1768. }
  1769. void obs_data_set_frames_per_second(obs_data_t *data, const char *name,
  1770. struct media_frames_per_second fps,
  1771. const char *option)
  1772. {
  1773. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1774. set_item);
  1775. }
  1776. void obs_data_set_default_frames_per_second(obs_data_t *data, const char *name,
  1777. struct media_frames_per_second fps,
  1778. const char *option)
  1779. {
  1780. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1781. set_item_def);
  1782. }
  1783. void obs_data_set_autoselect_frames_per_second(
  1784. obs_data_t *data, const char *name, struct media_frames_per_second fps,
  1785. const char *option)
  1786. {
  1787. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1788. set_item_auto);
  1789. }
  1790. static inline bool get_option(obs_data_t *data, const char **option)
  1791. {
  1792. if (!option)
  1793. return false;
  1794. struct obs_data_item *opt = obs_data_item_byname(data, "option");
  1795. if (!opt)
  1796. return false;
  1797. *option = obs_data_item_get_string(opt);
  1798. obs_data_item_release(&opt);
  1799. obs_data_release(data);
  1800. return true;
  1801. }
  1802. #define CLAMP(x, min, max) ((x) < min ? min : ((x) > max ? max : (x)))
  1803. static inline bool get_frames_per_second(obs_data_t *data,
  1804. struct media_frames_per_second *fps,
  1805. const char **option)
  1806. {
  1807. if (!data)
  1808. return false;
  1809. if (get_option(data, option))
  1810. return true;
  1811. if (!fps)
  1812. goto free;
  1813. struct obs_data_item *num = obs_data_item_byname(data, "numerator");
  1814. struct obs_data_item *den = obs_data_item_byname(data, "denominator");
  1815. if (!num || !den) {
  1816. obs_data_item_release(&num);
  1817. obs_data_item_release(&den);
  1818. goto free;
  1819. }
  1820. long long num_ll = obs_data_item_get_int(num);
  1821. long long den_ll = obs_data_item_get_int(den);
  1822. fps->numerator = (uint32_t)CLAMP(num_ll, 0, (long long)UINT32_MAX);
  1823. fps->denominator = (uint32_t)CLAMP(den_ll, 0, (long long)UINT32_MAX);
  1824. obs_data_item_release(&num);
  1825. obs_data_item_release(&den);
  1826. obs_data_release(data);
  1827. return media_frames_per_second_is_valid(*fps);
  1828. free:
  1829. obs_data_release(data);
  1830. return false;
  1831. }
  1832. bool obs_data_get_frames_per_second(obs_data_t *data, const char *name,
  1833. struct media_frames_per_second *fps,
  1834. const char **option)
  1835. {
  1836. return get_frames_per_second(obs_data_get_obj(data, name), fps, option);
  1837. }
  1838. bool obs_data_get_default_frames_per_second(obs_data_t *data, const char *name,
  1839. struct media_frames_per_second *fps,
  1840. const char **option)
  1841. {
  1842. return get_frames_per_second(obs_data_get_default_obj(data, name), fps,
  1843. option);
  1844. }
  1845. bool obs_data_get_autoselect_frames_per_second(
  1846. obs_data_t *data, const char *name, struct media_frames_per_second *fps,
  1847. const char **option)
  1848. {
  1849. return get_frames_per_second(obs_data_get_autoselect_obj(data, name),
  1850. fps, option);
  1851. }
  1852. void obs_data_item_set_frames_per_second(obs_data_item_t **item,
  1853. struct media_frames_per_second fps,
  1854. const char *option)
  1855. {
  1856. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1857. set_item);
  1858. }
  1859. void obs_data_item_set_default_frames_per_second(
  1860. obs_data_item_t **item, struct media_frames_per_second fps,
  1861. const char *option)
  1862. {
  1863. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1864. set_item_def);
  1865. }
  1866. void obs_data_item_set_autoselect_frames_per_second(
  1867. obs_data_item_t **item, struct media_frames_per_second fps,
  1868. const char *option)
  1869. {
  1870. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1871. set_item_auto);
  1872. }
  1873. bool obs_data_item_get_frames_per_second(obs_data_item_t *item,
  1874. struct media_frames_per_second *fps,
  1875. const char **option)
  1876. {
  1877. return get_frames_per_second(obs_data_item_get_obj(item), fps, option);
  1878. }
  1879. bool obs_data_item_get_default_frames_per_second(
  1880. obs_data_item_t *item, struct media_frames_per_second *fps,
  1881. const char **option)
  1882. {
  1883. return get_frames_per_second(obs_data_item_get_default_obj(item), fps,
  1884. option);
  1885. }
  1886. bool obs_data_item_get_autoselect_frames_per_second(
  1887. obs_data_item_t *item, struct media_frames_per_second *fps,
  1888. const char **option)
  1889. {
  1890. return get_frames_per_second(obs_data_item_get_autoselect_obj(item),
  1891. fps, option);
  1892. }