obs-data.c 56 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318
  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_INDENT(4));
  593. json_decref(root);
  594. return data->json;
  595. }
  596. bool obs_data_save_json(obs_data_t *data, const char *file)
  597. {
  598. const char *json = obs_data_get_json(data);
  599. if (json && *json) {
  600. return os_quick_write_utf8_file(file, json, strlen(json),
  601. false);
  602. }
  603. return false;
  604. }
  605. bool obs_data_save_json_safe(obs_data_t *data, const char *file,
  606. const char *temp_ext, const char *backup_ext)
  607. {
  608. const char *json = obs_data_get_json(data);
  609. if (json && *json) {
  610. return os_quick_write_utf8_file_safe(
  611. file, json, strlen(json), false, temp_ext, backup_ext);
  612. }
  613. return false;
  614. }
  615. static void get_defaults_array_cb(obs_data_t *data, void *vp)
  616. {
  617. obs_data_array_t *defs = (obs_data_array_t *)vp;
  618. obs_data_t *obs_defaults = obs_data_get_defaults(data);
  619. obs_data_array_push_back(defs, obs_defaults);
  620. obs_data_release(obs_defaults);
  621. }
  622. obs_data_t *obs_data_get_defaults(obs_data_t *data)
  623. {
  624. obs_data_t *defaults = obs_data_create();
  625. if (!data)
  626. return defaults;
  627. struct obs_data_item *item = data->first_item;
  628. while (item) {
  629. const char *name = get_item_name(item);
  630. switch (item->type) {
  631. case OBS_DATA_NULL:
  632. break;
  633. case OBS_DATA_STRING: {
  634. const char *str =
  635. obs_data_get_default_string(data, name);
  636. obs_data_set_string(defaults, name, str);
  637. break;
  638. }
  639. case OBS_DATA_NUMBER: {
  640. switch (obs_data_item_numtype(item)) {
  641. case OBS_DATA_NUM_DOUBLE: {
  642. double val =
  643. obs_data_get_default_double(data, name);
  644. obs_data_set_double(defaults, name, val);
  645. break;
  646. }
  647. case OBS_DATA_NUM_INT: {
  648. long long val =
  649. obs_data_get_default_int(data, name);
  650. obs_data_set_int(defaults, name, val);
  651. break;
  652. }
  653. case OBS_DATA_NUM_INVALID:
  654. break;
  655. }
  656. break;
  657. }
  658. case OBS_DATA_BOOLEAN: {
  659. bool val = obs_data_get_default_bool(data, name);
  660. obs_data_set_bool(defaults, name, val);
  661. break;
  662. }
  663. case OBS_DATA_OBJECT: {
  664. obs_data_t *val = obs_data_get_default_obj(data, name);
  665. obs_data_t *defs = obs_data_get_defaults(val);
  666. obs_data_set_obj(defaults, name, defs);
  667. obs_data_release(defs);
  668. obs_data_release(val);
  669. break;
  670. }
  671. case OBS_DATA_ARRAY: {
  672. obs_data_array_t *arr =
  673. obs_data_get_default_array(data, name);
  674. obs_data_array_t *defs = obs_data_array_create();
  675. obs_data_array_enum(arr, get_defaults_array_cb,
  676. (void *)defs);
  677. obs_data_set_array(defaults, name, defs);
  678. obs_data_array_release(defs);
  679. obs_data_array_release(arr);
  680. break;
  681. }
  682. }
  683. item = item->next;
  684. }
  685. return defaults;
  686. }
  687. static struct obs_data_item *get_item(struct obs_data *data, const char *name)
  688. {
  689. if (!data)
  690. return NULL;
  691. struct obs_data_item *item = data->first_item;
  692. while (item) {
  693. if (strcmp(get_item_name(item), name) == 0)
  694. return item;
  695. item = item->next;
  696. }
  697. return NULL;
  698. }
  699. static void set_item_data(struct obs_data *data, struct obs_data_item **item,
  700. const char *name, const void *ptr, size_t size,
  701. enum obs_data_type type, bool default_data,
  702. bool autoselect_data)
  703. {
  704. obs_data_item_t *new_item = NULL;
  705. if ((!item || !*item) && data) {
  706. new_item = obs_data_item_create(name, ptr, size, type,
  707. default_data, autoselect_data);
  708. obs_data_item_t *prev = obs_data_first(data);
  709. obs_data_item_t *next = obs_data_first(data);
  710. obs_data_item_next(&next);
  711. for (; prev && next;
  712. obs_data_item_next(&prev), obs_data_item_next(&next)) {
  713. if (strcmp(get_item_name(next), name) > 0)
  714. break;
  715. }
  716. new_item->parent = data;
  717. if (prev && strcmp(get_item_name(prev), name) < 0) {
  718. prev->next = new_item;
  719. new_item->next = next;
  720. } else {
  721. data->first_item = new_item;
  722. new_item->next = prev;
  723. }
  724. if (!prev)
  725. data->first_item = new_item;
  726. obs_data_item_release(&prev);
  727. obs_data_item_release(&next);
  728. } else if (default_data) {
  729. obs_data_item_set_default_data(item, ptr, size, type);
  730. } else if (autoselect_data) {
  731. obs_data_item_set_autoselect_data(item, ptr, size, type);
  732. } else {
  733. obs_data_item_setdata(item, ptr, size, type);
  734. }
  735. }
  736. static inline void set_item(struct obs_data *data, obs_data_item_t **item,
  737. const char *name, const void *ptr, size_t size,
  738. enum obs_data_type type)
  739. {
  740. obs_data_item_t *actual_item = NULL;
  741. if (!data && !item)
  742. return;
  743. if (!item) {
  744. actual_item = get_item(data, name);
  745. item = &actual_item;
  746. }
  747. set_item_data(data, item, name, ptr, size, type, false, false);
  748. }
  749. static inline void set_item_def(struct obs_data *data, obs_data_item_t **item,
  750. const char *name, const void *ptr, size_t size,
  751. enum obs_data_type type)
  752. {
  753. obs_data_item_t *actual_item = NULL;
  754. if (!data && !item)
  755. return;
  756. if (!item) {
  757. actual_item = get_item(data, name);
  758. item = &actual_item;
  759. }
  760. if (*item && (*item)->type != type)
  761. return;
  762. set_item_data(data, item, name, ptr, size, type, true, false);
  763. }
  764. static inline void set_item_auto(struct obs_data *data, obs_data_item_t **item,
  765. const char *name, const void *ptr, size_t size,
  766. enum obs_data_type type)
  767. {
  768. obs_data_item_t *actual_item = NULL;
  769. if (!data && !item)
  770. return;
  771. if (!item) {
  772. actual_item = get_item(data, name);
  773. item = &actual_item;
  774. }
  775. set_item_data(data, item, name, ptr, size, type, false, true);
  776. }
  777. static void copy_obj(struct obs_data *data, const char *name,
  778. struct obs_data *obj,
  779. void (*callback)(obs_data_t *, const char *, obs_data_t *))
  780. {
  781. if (obj) {
  782. obs_data_t *new_obj = obs_data_create();
  783. obs_data_apply(new_obj, obj);
  784. callback(data, name, new_obj);
  785. obs_data_release(new_obj);
  786. }
  787. }
  788. static void copy_array(struct obs_data *data, const char *name,
  789. struct obs_data_array *array,
  790. void (*callback)(obs_data_t *, const char *,
  791. obs_data_array_t *))
  792. {
  793. if (array) {
  794. obs_data_array_t *new_array = obs_data_array_create();
  795. da_reserve(new_array->objects, array->objects.num);
  796. for (size_t i = 0; i < array->objects.num; i++) {
  797. obs_data_t *new_obj = obs_data_create();
  798. obs_data_t *obj = array->objects.array[i];
  799. obs_data_apply(new_obj, obj);
  800. obs_data_array_push_back(new_array, new_obj);
  801. obs_data_release(new_obj);
  802. }
  803. callback(data, name, new_array);
  804. obs_data_array_release(new_array);
  805. }
  806. }
  807. static inline void copy_item(struct obs_data *data, struct obs_data_item *item)
  808. {
  809. const char *name = get_item_name(item);
  810. void *ptr = get_item_data(item);
  811. if (item->type == OBS_DATA_OBJECT) {
  812. obs_data_t **obj = item->data_size ? ptr : NULL;
  813. if (obj)
  814. copy_obj(data, name, *obj, obs_data_set_obj);
  815. } else if (item->type == OBS_DATA_ARRAY) {
  816. obs_data_array_t **array = item->data_size ? ptr : NULL;
  817. if (array)
  818. copy_array(data, name, *array, obs_data_set_array);
  819. } else {
  820. if (item->data_size)
  821. set_item(data, NULL, name, ptr, item->data_size,
  822. item->type);
  823. }
  824. }
  825. void obs_data_apply(obs_data_t *target, obs_data_t *apply_data)
  826. {
  827. struct obs_data_item *item;
  828. if (!target || !apply_data || target == apply_data)
  829. return;
  830. item = apply_data->first_item;
  831. while (item) {
  832. copy_item(target, item);
  833. item = item->next;
  834. }
  835. }
  836. void obs_data_erase(obs_data_t *data, const char *name)
  837. {
  838. struct obs_data_item *item = get_item(data, name);
  839. if (item) {
  840. obs_data_item_detach(item);
  841. obs_data_item_release(&item);
  842. }
  843. }
  844. static inline void clear_item(struct obs_data_item *item)
  845. {
  846. void *ptr = get_item_data(item);
  847. size_t size;
  848. if (item->data_len) {
  849. if (item->type == OBS_DATA_OBJECT) {
  850. obs_data_t **obj = item->data_size ? ptr : NULL;
  851. if (obj && *obj)
  852. obs_data_release(*obj);
  853. } else if (item->type == OBS_DATA_ARRAY) {
  854. obs_data_array_t **array = item->data_size ? ptr : NULL;
  855. if (array && *array)
  856. obs_data_array_release(*array);
  857. }
  858. size = item->default_len + item->autoselect_size;
  859. if (size)
  860. memmove(ptr, (uint8_t *)ptr + item->data_len, size);
  861. item->data_size = 0;
  862. item->data_len = 0;
  863. }
  864. }
  865. void obs_data_clear(obs_data_t *target)
  866. {
  867. struct obs_data_item *item;
  868. if (!target)
  869. return;
  870. item = target->first_item;
  871. while (item) {
  872. clear_item(item);
  873. item = item->next;
  874. }
  875. }
  876. typedef void (*set_item_t)(obs_data_t *, obs_data_item_t **, const char *,
  877. const void *, size_t, enum obs_data_type);
  878. static inline void obs_set_string(obs_data_t *data, obs_data_item_t **item,
  879. const char *name, const char *val,
  880. set_item_t set_item_)
  881. {
  882. if (!val)
  883. val = "";
  884. set_item_(data, item, name, val, strlen(val) + 1, OBS_DATA_STRING);
  885. }
  886. static inline void obs_set_int(obs_data_t *data, obs_data_item_t **item,
  887. const char *name, long long val,
  888. set_item_t set_item_)
  889. {
  890. struct obs_data_number num;
  891. num.type = OBS_DATA_NUM_INT;
  892. num.int_val = val;
  893. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  894. OBS_DATA_NUMBER);
  895. }
  896. static inline void obs_set_double(obs_data_t *data, obs_data_item_t **item,
  897. const char *name, double val,
  898. set_item_t set_item_)
  899. {
  900. struct obs_data_number num;
  901. num.type = OBS_DATA_NUM_DOUBLE;
  902. num.double_val = val;
  903. set_item_(data, item, name, &num, sizeof(struct obs_data_number),
  904. OBS_DATA_NUMBER);
  905. }
  906. static inline void obs_set_bool(obs_data_t *data, obs_data_item_t **item,
  907. const char *name, bool val,
  908. set_item_t set_item_)
  909. {
  910. set_item_(data, item, name, &val, sizeof(bool), OBS_DATA_BOOLEAN);
  911. }
  912. static inline void obs_set_obj(obs_data_t *data, obs_data_item_t **item,
  913. const char *name, obs_data_t *obj,
  914. set_item_t set_item_)
  915. {
  916. set_item_(data, item, name, &obj, sizeof(obs_data_t *),
  917. OBS_DATA_OBJECT);
  918. }
  919. static inline void obs_set_array(obs_data_t *data, obs_data_item_t **item,
  920. const char *name, obs_data_array_t *array,
  921. set_item_t set_item_)
  922. {
  923. set_item_(data, item, name, &array, sizeof(obs_data_t *),
  924. OBS_DATA_ARRAY);
  925. }
  926. static inline void obs_take_obj(obs_data_t *data, obs_data_item_t **item,
  927. const char *name, obs_data_t *obj,
  928. set_item_t set_item_)
  929. {
  930. obs_set_obj(data, item, name, obj, set_item_);
  931. obs_data_release(obj);
  932. }
  933. void obs_data_set_string(obs_data_t *data, const char *name, const char *val)
  934. {
  935. obs_set_string(data, NULL, name, val, set_item);
  936. }
  937. void obs_data_set_int(obs_data_t *data, const char *name, long long val)
  938. {
  939. obs_set_int(data, NULL, name, val, set_item);
  940. }
  941. void obs_data_set_double(obs_data_t *data, const char *name, double val)
  942. {
  943. obs_set_double(data, NULL, name, val, set_item);
  944. }
  945. void obs_data_set_bool(obs_data_t *data, const char *name, bool val)
  946. {
  947. obs_set_bool(data, NULL, name, val, set_item);
  948. }
  949. void obs_data_set_obj(obs_data_t *data, const char *name, obs_data_t *obj)
  950. {
  951. obs_set_obj(data, NULL, name, obj, set_item);
  952. }
  953. void obs_data_set_array(obs_data_t *data, const char *name,
  954. obs_data_array_t *array)
  955. {
  956. obs_set_array(data, NULL, name, array, set_item);
  957. }
  958. void obs_data_set_default_string(obs_data_t *data, const char *name,
  959. const char *val)
  960. {
  961. obs_set_string(data, NULL, name, val, set_item_def);
  962. }
  963. void obs_data_set_default_int(obs_data_t *data, const char *name, long long val)
  964. {
  965. obs_set_int(data, NULL, name, val, set_item_def);
  966. }
  967. void obs_data_set_default_double(obs_data_t *data, const char *name, double val)
  968. {
  969. obs_set_double(data, NULL, name, val, set_item_def);
  970. }
  971. void obs_data_set_default_bool(obs_data_t *data, const char *name, bool val)
  972. {
  973. obs_set_bool(data, NULL, name, val, set_item_def);
  974. }
  975. void obs_data_set_default_obj(obs_data_t *data, const char *name,
  976. obs_data_t *obj)
  977. {
  978. obs_set_obj(data, NULL, name, obj, set_item_def);
  979. }
  980. void obs_data_set_default_array(obs_data_t *data, const char *name,
  981. obs_data_array_t *arr)
  982. {
  983. obs_set_array(data, NULL, name, arr, set_item_def);
  984. }
  985. void obs_data_set_autoselect_string(obs_data_t *data, const char *name,
  986. const char *val)
  987. {
  988. obs_set_string(data, NULL, name, val, set_item_auto);
  989. }
  990. void obs_data_set_autoselect_int(obs_data_t *data, const char *name,
  991. long long val)
  992. {
  993. obs_set_int(data, NULL, name, val, set_item_auto);
  994. }
  995. void obs_data_set_autoselect_double(obs_data_t *data, const char *name,
  996. double val)
  997. {
  998. obs_set_double(data, NULL, name, val, set_item_auto);
  999. }
  1000. void obs_data_set_autoselect_bool(obs_data_t *data, const char *name, bool val)
  1001. {
  1002. obs_set_bool(data, NULL, name, val, set_item_auto);
  1003. }
  1004. void obs_data_set_autoselect_obj(obs_data_t *data, const char *name,
  1005. obs_data_t *obj)
  1006. {
  1007. obs_set_obj(data, NULL, name, obj, set_item_auto);
  1008. }
  1009. void obs_data_set_autoselect_array(obs_data_t *data, const char *name,
  1010. obs_data_array_t *arr)
  1011. {
  1012. obs_set_array(data, NULL, name, arr, set_item_auto);
  1013. }
  1014. const char *obs_data_get_string(obs_data_t *data, const char *name)
  1015. {
  1016. return obs_data_item_get_string(get_item(data, name));
  1017. }
  1018. long long obs_data_get_int(obs_data_t *data, const char *name)
  1019. {
  1020. return obs_data_item_get_int(get_item(data, name));
  1021. }
  1022. double obs_data_get_double(obs_data_t *data, const char *name)
  1023. {
  1024. return obs_data_item_get_double(get_item(data, name));
  1025. }
  1026. bool obs_data_get_bool(obs_data_t *data, const char *name)
  1027. {
  1028. return obs_data_item_get_bool(get_item(data, name));
  1029. }
  1030. obs_data_t *obs_data_get_obj(obs_data_t *data, const char *name)
  1031. {
  1032. return obs_data_item_get_obj(get_item(data, name));
  1033. }
  1034. obs_data_array_t *obs_data_get_array(obs_data_t *data, const char *name)
  1035. {
  1036. return obs_data_item_get_array(get_item(data, name));
  1037. }
  1038. const char *obs_data_get_default_string(obs_data_t *data, const char *name)
  1039. {
  1040. return obs_data_item_get_default_string(get_item(data, name));
  1041. }
  1042. long long obs_data_get_default_int(obs_data_t *data, const char *name)
  1043. {
  1044. return obs_data_item_get_default_int(get_item(data, name));
  1045. }
  1046. double obs_data_get_default_double(obs_data_t *data, const char *name)
  1047. {
  1048. return obs_data_item_get_default_double(get_item(data, name));
  1049. }
  1050. bool obs_data_get_default_bool(obs_data_t *data, const char *name)
  1051. {
  1052. return obs_data_item_get_default_bool(get_item(data, name));
  1053. }
  1054. obs_data_t *obs_data_get_default_obj(obs_data_t *data, const char *name)
  1055. {
  1056. return obs_data_item_get_default_obj(get_item(data, name));
  1057. }
  1058. obs_data_array_t *obs_data_get_default_array(obs_data_t *data, const char *name)
  1059. {
  1060. return obs_data_item_get_default_array(get_item(data, name));
  1061. }
  1062. const char *obs_data_get_autoselect_string(obs_data_t *data, const char *name)
  1063. {
  1064. return obs_data_item_get_autoselect_string(get_item(data, name));
  1065. }
  1066. long long obs_data_get_autoselect_int(obs_data_t *data, const char *name)
  1067. {
  1068. return obs_data_item_get_autoselect_int(get_item(data, name));
  1069. }
  1070. double obs_data_get_autoselect_double(obs_data_t *data, const char *name)
  1071. {
  1072. return obs_data_item_get_autoselect_double(get_item(data, name));
  1073. }
  1074. bool obs_data_get_autoselect_bool(obs_data_t *data, const char *name)
  1075. {
  1076. return obs_data_item_get_autoselect_bool(get_item(data, name));
  1077. }
  1078. obs_data_t *obs_data_get_autoselect_obj(obs_data_t *data, const char *name)
  1079. {
  1080. return obs_data_item_get_autoselect_obj(get_item(data, name));
  1081. }
  1082. obs_data_array_t *obs_data_get_autoselect_array(obs_data_t *data,
  1083. const char *name)
  1084. {
  1085. return obs_data_item_get_autoselect_array(get_item(data, name));
  1086. }
  1087. obs_data_array_t *obs_data_array_create()
  1088. {
  1089. struct obs_data_array *array = bzalloc(sizeof(struct obs_data_array));
  1090. array->ref = 1;
  1091. return array;
  1092. }
  1093. void obs_data_array_addref(obs_data_array_t *array)
  1094. {
  1095. if (array)
  1096. os_atomic_inc_long(&array->ref);
  1097. }
  1098. static inline void obs_data_array_destroy(obs_data_array_t *array)
  1099. {
  1100. if (array) {
  1101. for (size_t i = 0; i < array->objects.num; i++)
  1102. obs_data_release(array->objects.array[i]);
  1103. da_free(array->objects);
  1104. bfree(array);
  1105. }
  1106. }
  1107. void obs_data_array_release(obs_data_array_t *array)
  1108. {
  1109. if (!array)
  1110. return;
  1111. if (os_atomic_dec_long(&array->ref) == 0)
  1112. obs_data_array_destroy(array);
  1113. }
  1114. size_t obs_data_array_count(obs_data_array_t *array)
  1115. {
  1116. return array ? array->objects.num : 0;
  1117. }
  1118. obs_data_t *obs_data_array_item(obs_data_array_t *array, size_t idx)
  1119. {
  1120. obs_data_t *data;
  1121. if (!array)
  1122. return NULL;
  1123. data = (idx < array->objects.num) ? array->objects.array[idx] : NULL;
  1124. if (data)
  1125. os_atomic_inc_long(&data->ref);
  1126. return data;
  1127. }
  1128. size_t obs_data_array_push_back(obs_data_array_t *array, obs_data_t *obj)
  1129. {
  1130. if (!array || !obj)
  1131. return 0;
  1132. os_atomic_inc_long(&obj->ref);
  1133. return da_push_back(array->objects, &obj);
  1134. }
  1135. void obs_data_array_insert(obs_data_array_t *array, size_t idx, obs_data_t *obj)
  1136. {
  1137. if (!array || !obj)
  1138. return;
  1139. os_atomic_inc_long(&obj->ref);
  1140. da_insert(array->objects, idx, &obj);
  1141. }
  1142. void obs_data_array_push_back_array(obs_data_array_t *array,
  1143. obs_data_array_t *array2)
  1144. {
  1145. if (!array || !array2)
  1146. return;
  1147. for (size_t i = 0; i < array2->objects.num; i++) {
  1148. obs_data_t *obj = array2->objects.array[i];
  1149. obs_data_addref(obj);
  1150. }
  1151. da_push_back_da(array->objects, array2->objects);
  1152. }
  1153. void obs_data_array_erase(obs_data_array_t *array, size_t idx)
  1154. {
  1155. if (array) {
  1156. obs_data_release(array->objects.array[idx]);
  1157. da_erase(array->objects, idx);
  1158. }
  1159. }
  1160. void obs_data_array_enum(obs_data_array_t *array,
  1161. void (*cb)(obs_data_t *data, void *param), void *param)
  1162. {
  1163. if (array && cb) {
  1164. for (size_t i = 0; i < array->objects.num; i++) {
  1165. cb(array->objects.array[i], param);
  1166. }
  1167. }
  1168. }
  1169. /* ------------------------------------------------------------------------- */
  1170. /* Item status inspection */
  1171. bool obs_data_has_user_value(obs_data_t *data, const char *name)
  1172. {
  1173. return data && obs_data_item_has_user_value(get_item(data, name));
  1174. }
  1175. bool obs_data_has_default_value(obs_data_t *data, const char *name)
  1176. {
  1177. return data && obs_data_item_has_default_value(get_item(data, name));
  1178. }
  1179. bool obs_data_has_autoselect_value(obs_data_t *data, const char *name)
  1180. {
  1181. return data && obs_data_item_has_autoselect_value(get_item(data, name));
  1182. }
  1183. bool obs_data_item_has_user_value(obs_data_item_t *item)
  1184. {
  1185. return item && item->data_size;
  1186. }
  1187. bool obs_data_item_has_default_value(obs_data_item_t *item)
  1188. {
  1189. return item && item->default_size;
  1190. }
  1191. bool obs_data_item_has_autoselect_value(obs_data_item_t *item)
  1192. {
  1193. return item && item->autoselect_size;
  1194. }
  1195. /* ------------------------------------------------------------------------- */
  1196. /* Clearing data values */
  1197. void obs_data_unset_user_value(obs_data_t *data, const char *name)
  1198. {
  1199. obs_data_item_unset_user_value(get_item(data, name));
  1200. }
  1201. void obs_data_unset_default_value(obs_data_t *data, const char *name)
  1202. {
  1203. obs_data_item_unset_default_value(get_item(data, name));
  1204. }
  1205. void obs_data_unset_autoselect_value(obs_data_t *data, const char *name)
  1206. {
  1207. obs_data_item_unset_autoselect_value(get_item(data, name));
  1208. }
  1209. void obs_data_item_unset_user_value(obs_data_item_t *item)
  1210. {
  1211. if (!item || !item->data_size)
  1212. return;
  1213. void *old_non_user_data = get_default_data_ptr(item);
  1214. item_data_release(item);
  1215. item->data_size = 0;
  1216. item->data_len = 0;
  1217. if (item->default_size || item->autoselect_size)
  1218. move_data(item, old_non_user_data, item,
  1219. get_default_data_ptr(item),
  1220. item->default_len + item->autoselect_size);
  1221. }
  1222. void obs_data_item_unset_default_value(obs_data_item_t *item)
  1223. {
  1224. if (!item || !item->default_size)
  1225. return;
  1226. void *old_autoselect_data = get_autoselect_data_ptr(item);
  1227. item_default_data_release(item);
  1228. item->default_size = 0;
  1229. item->default_len = 0;
  1230. if (item->autoselect_size)
  1231. move_data(item, old_autoselect_data, item,
  1232. get_autoselect_data_ptr(item), item->autoselect_size);
  1233. }
  1234. void obs_data_item_unset_autoselect_value(obs_data_item_t *item)
  1235. {
  1236. if (!item || !item->autoselect_size)
  1237. return;
  1238. item_autoselect_data_release(item);
  1239. item->autoselect_size = 0;
  1240. }
  1241. /* ------------------------------------------------------------------------- */
  1242. /* Item iteration */
  1243. obs_data_item_t *obs_data_first(obs_data_t *data)
  1244. {
  1245. if (!data)
  1246. return NULL;
  1247. if (data->first_item)
  1248. os_atomic_inc_long(&data->first_item->ref);
  1249. return data->first_item;
  1250. }
  1251. obs_data_item_t *obs_data_item_byname(obs_data_t *data, const char *name)
  1252. {
  1253. if (!data)
  1254. return NULL;
  1255. struct obs_data_item *item = get_item(data, name);
  1256. if (item)
  1257. os_atomic_inc_long(&item->ref);
  1258. return item;
  1259. }
  1260. bool obs_data_item_next(obs_data_item_t **item)
  1261. {
  1262. if (item && *item) {
  1263. obs_data_item_t *next = (*item)->next;
  1264. obs_data_item_release(item);
  1265. *item = next;
  1266. if (next) {
  1267. os_atomic_inc_long(&next->ref);
  1268. return true;
  1269. }
  1270. }
  1271. return false;
  1272. }
  1273. void obs_data_item_release(obs_data_item_t **item)
  1274. {
  1275. if (item && *item) {
  1276. long ref = os_atomic_dec_long(&(*item)->ref);
  1277. if (!ref) {
  1278. obs_data_item_destroy(*item);
  1279. *item = NULL;
  1280. }
  1281. }
  1282. }
  1283. void obs_data_item_remove(obs_data_item_t **item)
  1284. {
  1285. if (item && *item) {
  1286. obs_data_item_detach(*item);
  1287. obs_data_item_release(item);
  1288. }
  1289. }
  1290. enum obs_data_type obs_data_item_gettype(obs_data_item_t *item)
  1291. {
  1292. return item ? item->type : OBS_DATA_NULL;
  1293. }
  1294. enum obs_data_number_type obs_data_item_numtype(obs_data_item_t *item)
  1295. {
  1296. struct obs_data_number *num;
  1297. if (!item || item->type != OBS_DATA_NUMBER)
  1298. return OBS_DATA_NUM_INVALID;
  1299. num = get_item_data(item);
  1300. if (!num)
  1301. return OBS_DATA_NUM_INVALID;
  1302. return num->type;
  1303. }
  1304. const char *obs_data_item_get_name(obs_data_item_t *item)
  1305. {
  1306. if (!item)
  1307. return NULL;
  1308. return get_item_name(item);
  1309. }
  1310. void obs_data_item_set_string(obs_data_item_t **item, const char *val)
  1311. {
  1312. obs_set_string(NULL, item, NULL, val, set_item);
  1313. }
  1314. void obs_data_item_set_int(obs_data_item_t **item, long long val)
  1315. {
  1316. obs_set_int(NULL, item, NULL, val, set_item);
  1317. }
  1318. void obs_data_item_set_double(obs_data_item_t **item, double val)
  1319. {
  1320. obs_set_double(NULL, item, NULL, val, set_item);
  1321. }
  1322. void obs_data_item_set_bool(obs_data_item_t **item, bool val)
  1323. {
  1324. obs_set_bool(NULL, item, NULL, val, set_item);
  1325. }
  1326. void obs_data_item_set_obj(obs_data_item_t **item, obs_data_t *val)
  1327. {
  1328. obs_set_obj(NULL, item, NULL, val, set_item);
  1329. }
  1330. void obs_data_item_set_array(obs_data_item_t **item, obs_data_array_t *val)
  1331. {
  1332. obs_set_array(NULL, item, NULL, val, set_item);
  1333. }
  1334. void obs_data_item_set_default_string(obs_data_item_t **item, const char *val)
  1335. {
  1336. obs_set_string(NULL, item, NULL, val, set_item_def);
  1337. }
  1338. void obs_data_item_set_default_int(obs_data_item_t **item, long long val)
  1339. {
  1340. obs_set_int(NULL, item, NULL, val, set_item_def);
  1341. }
  1342. void obs_data_item_set_default_double(obs_data_item_t **item, double val)
  1343. {
  1344. obs_set_double(NULL, item, NULL, val, set_item_def);
  1345. }
  1346. void obs_data_item_set_default_bool(obs_data_item_t **item, bool val)
  1347. {
  1348. obs_set_bool(NULL, item, NULL, val, set_item_def);
  1349. }
  1350. void obs_data_item_set_default_obj(obs_data_item_t **item, obs_data_t *val)
  1351. {
  1352. obs_set_obj(NULL, item, NULL, val, set_item_def);
  1353. }
  1354. void obs_data_item_set_default_array(obs_data_item_t **item,
  1355. obs_data_array_t *val)
  1356. {
  1357. obs_set_array(NULL, item, NULL, val, set_item_def);
  1358. }
  1359. void obs_data_item_set_autoselect_string(obs_data_item_t **item,
  1360. const char *val)
  1361. {
  1362. obs_set_string(NULL, item, NULL, val, set_item_auto);
  1363. }
  1364. void obs_data_item_set_autoselect_int(obs_data_item_t **item, long long val)
  1365. {
  1366. obs_set_int(NULL, item, NULL, val, set_item_auto);
  1367. }
  1368. void obs_data_item_set_autoselect_double(obs_data_item_t **item, double val)
  1369. {
  1370. obs_set_double(NULL, item, NULL, val, set_item_auto);
  1371. }
  1372. void obs_data_item_set_autoselect_bool(obs_data_item_t **item, bool val)
  1373. {
  1374. obs_set_bool(NULL, item, NULL, val, set_item_auto);
  1375. }
  1376. void obs_data_item_set_autoselect_obj(obs_data_item_t **item, obs_data_t *val)
  1377. {
  1378. obs_set_obj(NULL, item, NULL, val, set_item_auto);
  1379. }
  1380. void obs_data_item_set_autoselect_array(obs_data_item_t **item,
  1381. obs_data_array_t *val)
  1382. {
  1383. obs_set_array(NULL, item, NULL, val, set_item_auto);
  1384. }
  1385. static inline bool item_valid(struct obs_data_item *item,
  1386. enum obs_data_type type)
  1387. {
  1388. return item && item->type == type;
  1389. }
  1390. typedef void *(*get_data_t)(obs_data_item_t *);
  1391. static inline const char *data_item_get_string(obs_data_item_t *item,
  1392. get_data_t get_data)
  1393. {
  1394. return item_valid(item, OBS_DATA_STRING) && get_data(item)
  1395. ? get_data(item)
  1396. : "";
  1397. }
  1398. static inline long long item_int(struct obs_data_item *item,
  1399. get_data_t get_data)
  1400. {
  1401. if (item && get_data(item)) {
  1402. struct obs_data_number *num = get_data(item);
  1403. return (num->type == OBS_DATA_NUM_INT)
  1404. ? num->int_val
  1405. : (long long)num->double_val;
  1406. }
  1407. return 0;
  1408. }
  1409. static inline long long data_item_get_int(obs_data_item_t *item,
  1410. get_data_t get_data)
  1411. {
  1412. return item_int(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1413. get_data);
  1414. }
  1415. static inline double item_double(struct obs_data_item *item,
  1416. get_data_t get_data)
  1417. {
  1418. if (item && get_data(item)) {
  1419. struct obs_data_number *num = get_data(item);
  1420. return (num->type == OBS_DATA_NUM_INT) ? (double)num->int_val
  1421. : num->double_val;
  1422. }
  1423. return 0.0;
  1424. }
  1425. static inline double data_item_get_double(obs_data_item_t *item,
  1426. get_data_t get_data)
  1427. {
  1428. return item_double(item_valid(item, OBS_DATA_NUMBER) ? item : NULL,
  1429. get_data);
  1430. }
  1431. static inline bool data_item_get_bool(obs_data_item_t *item,
  1432. get_data_t get_data)
  1433. {
  1434. return item_valid(item, OBS_DATA_BOOLEAN) && get_data(item)
  1435. ? *(bool *)get_data(item)
  1436. : false;
  1437. }
  1438. typedef obs_data_t *(*get_obj_t)(obs_data_item_t *);
  1439. static inline obs_data_t *data_item_get_obj(obs_data_item_t *item,
  1440. get_obj_t get_obj)
  1441. {
  1442. obs_data_t *obj = item_valid(item, OBS_DATA_OBJECT) ? get_obj(item)
  1443. : NULL;
  1444. if (obj)
  1445. os_atomic_inc_long(&obj->ref);
  1446. return obj;
  1447. }
  1448. typedef obs_data_array_t *(*get_array_t)(obs_data_item_t *);
  1449. static inline obs_data_array_t *data_item_get_array(obs_data_item_t *item,
  1450. get_array_t get_array)
  1451. {
  1452. obs_data_array_t *array =
  1453. item_valid(item, OBS_DATA_ARRAY) ? get_array(item) : NULL;
  1454. if (array)
  1455. os_atomic_inc_long(&array->ref);
  1456. return array;
  1457. }
  1458. const char *obs_data_item_get_string(obs_data_item_t *item)
  1459. {
  1460. return data_item_get_string(item, get_item_data);
  1461. }
  1462. long long obs_data_item_get_int(obs_data_item_t *item)
  1463. {
  1464. return data_item_get_int(item, get_item_data);
  1465. }
  1466. double obs_data_item_get_double(obs_data_item_t *item)
  1467. {
  1468. return data_item_get_double(item, get_item_data);
  1469. }
  1470. bool obs_data_item_get_bool(obs_data_item_t *item)
  1471. {
  1472. return data_item_get_bool(item, get_item_data);
  1473. }
  1474. obs_data_t *obs_data_item_get_obj(obs_data_item_t *item)
  1475. {
  1476. return data_item_get_obj(item, get_item_obj);
  1477. }
  1478. obs_data_array_t *obs_data_item_get_array(obs_data_item_t *item)
  1479. {
  1480. return data_item_get_array(item, get_item_array);
  1481. }
  1482. const char *obs_data_item_get_default_string(obs_data_item_t *item)
  1483. {
  1484. return data_item_get_string(item, get_item_default_data);
  1485. }
  1486. long long obs_data_item_get_default_int(obs_data_item_t *item)
  1487. {
  1488. return data_item_get_int(item, get_item_default_data);
  1489. }
  1490. double obs_data_item_get_default_double(obs_data_item_t *item)
  1491. {
  1492. return data_item_get_double(item, get_item_default_data);
  1493. }
  1494. bool obs_data_item_get_default_bool(obs_data_item_t *item)
  1495. {
  1496. return data_item_get_bool(item, get_item_default_data);
  1497. }
  1498. obs_data_t *obs_data_item_get_default_obj(obs_data_item_t *item)
  1499. {
  1500. return data_item_get_obj(item, get_item_default_obj);
  1501. }
  1502. obs_data_array_t *obs_data_item_get_default_array(obs_data_item_t *item)
  1503. {
  1504. return data_item_get_array(item, get_item_default_array);
  1505. }
  1506. const char *obs_data_item_get_autoselect_string(obs_data_item_t *item)
  1507. {
  1508. return data_item_get_string(item, get_item_autoselect_data);
  1509. }
  1510. long long obs_data_item_get_autoselect_int(obs_data_item_t *item)
  1511. {
  1512. return data_item_get_int(item, get_item_autoselect_data);
  1513. }
  1514. double obs_data_item_get_autoselect_double(obs_data_item_t *item)
  1515. {
  1516. return data_item_get_double(item, get_item_autoselect_data);
  1517. }
  1518. bool obs_data_item_get_autoselect_bool(obs_data_item_t *item)
  1519. {
  1520. return data_item_get_bool(item, get_item_autoselect_data);
  1521. }
  1522. obs_data_t *obs_data_item_get_autoselect_obj(obs_data_item_t *item)
  1523. {
  1524. return data_item_get_obj(item, get_item_autoselect_obj);
  1525. }
  1526. obs_data_array_t *obs_data_item_get_autoselect_array(obs_data_item_t *item)
  1527. {
  1528. return data_item_get_array(item, get_item_autoselect_array);
  1529. }
  1530. /* ------------------------------------------------------------------------- */
  1531. /* Helper functions for certain structures */
  1532. typedef void (*set_obj_t)(obs_data_t *, const char *, obs_data_t *);
  1533. static inline void set_vec2(obs_data_t *data, const char *name,
  1534. const struct vec2 *val, set_obj_t set_obj)
  1535. {
  1536. obs_data_t *obj = obs_data_create();
  1537. obs_data_set_double(obj, "x", val->x);
  1538. obs_data_set_double(obj, "y", val->y);
  1539. set_obj(data, name, obj);
  1540. obs_data_release(obj);
  1541. }
  1542. static inline void set_vec3(obs_data_t *data, const char *name,
  1543. const struct vec3 *val, set_obj_t set_obj)
  1544. {
  1545. obs_data_t *obj = obs_data_create();
  1546. obs_data_set_double(obj, "x", val->x);
  1547. obs_data_set_double(obj, "y", val->y);
  1548. obs_data_set_double(obj, "z", val->z);
  1549. set_obj(data, name, obj);
  1550. obs_data_release(obj);
  1551. }
  1552. static inline void set_vec4(obs_data_t *data, const char *name,
  1553. const struct vec4 *val, set_obj_t set_obj)
  1554. {
  1555. obs_data_t *obj = obs_data_create();
  1556. obs_data_set_double(obj, "x", val->x);
  1557. obs_data_set_double(obj, "y", val->y);
  1558. obs_data_set_double(obj, "z", val->z);
  1559. obs_data_set_double(obj, "w", val->w);
  1560. set_obj(data, name, obj);
  1561. obs_data_release(obj);
  1562. }
  1563. static inline void set_quat(obs_data_t *data, const char *name,
  1564. const struct quat *val, set_obj_t set_obj)
  1565. {
  1566. obs_data_t *obj = obs_data_create();
  1567. obs_data_set_double(obj, "x", val->x);
  1568. obs_data_set_double(obj, "y", val->y);
  1569. obs_data_set_double(obj, "z", val->z);
  1570. obs_data_set_double(obj, "w", val->w);
  1571. set_obj(data, name, obj);
  1572. obs_data_release(obj);
  1573. }
  1574. void obs_data_set_vec2(obs_data_t *data, const char *name,
  1575. const struct vec2 *val)
  1576. {
  1577. set_vec2(data, name, val, obs_data_set_obj);
  1578. }
  1579. void obs_data_set_vec3(obs_data_t *data, const char *name,
  1580. const struct vec3 *val)
  1581. {
  1582. set_vec3(data, name, val, obs_data_set_obj);
  1583. }
  1584. void obs_data_set_vec4(obs_data_t *data, const char *name,
  1585. const struct vec4 *val)
  1586. {
  1587. set_vec4(data, name, val, obs_data_set_obj);
  1588. }
  1589. void obs_data_set_quat(obs_data_t *data, const char *name,
  1590. const struct quat *val)
  1591. {
  1592. set_quat(data, name, val, obs_data_set_obj);
  1593. }
  1594. void obs_data_set_default_vec2(obs_data_t *data, const char *name,
  1595. const struct vec2 *val)
  1596. {
  1597. set_vec2(data, name, val, obs_data_set_default_obj);
  1598. }
  1599. void obs_data_set_default_vec3(obs_data_t *data, const char *name,
  1600. const struct vec3 *val)
  1601. {
  1602. set_vec3(data, name, val, obs_data_set_default_obj);
  1603. }
  1604. void obs_data_set_default_vec4(obs_data_t *data, const char *name,
  1605. const struct vec4 *val)
  1606. {
  1607. set_vec4(data, name, val, obs_data_set_default_obj);
  1608. }
  1609. void obs_data_set_default_quat(obs_data_t *data, const char *name,
  1610. const struct quat *val)
  1611. {
  1612. set_quat(data, name, val, obs_data_set_default_obj);
  1613. }
  1614. void obs_data_set_autoselect_vec2(obs_data_t *data, const char *name,
  1615. const struct vec2 *val)
  1616. {
  1617. set_vec2(data, name, val, obs_data_set_autoselect_obj);
  1618. }
  1619. void obs_data_set_autoselect_vec3(obs_data_t *data, const char *name,
  1620. const struct vec3 *val)
  1621. {
  1622. set_vec3(data, name, val, obs_data_set_autoselect_obj);
  1623. }
  1624. void obs_data_set_autoselect_vec4(obs_data_t *data, const char *name,
  1625. const struct vec4 *val)
  1626. {
  1627. set_vec4(data, name, val, obs_data_set_autoselect_obj);
  1628. }
  1629. void obs_data_set_autoselect_quat(obs_data_t *data, const char *name,
  1630. const struct quat *val)
  1631. {
  1632. set_quat(data, name, val, obs_data_set_autoselect_obj);
  1633. }
  1634. static inline void get_vec2(obs_data_t *obj, struct vec2 *val)
  1635. {
  1636. if (!obj)
  1637. return;
  1638. val->x = (float)obs_data_get_double(obj, "x");
  1639. val->y = (float)obs_data_get_double(obj, "y");
  1640. obs_data_release(obj);
  1641. }
  1642. static inline void get_vec3(obs_data_t *obj, struct vec3 *val)
  1643. {
  1644. if (!obj)
  1645. return;
  1646. val->x = (float)obs_data_get_double(obj, "x");
  1647. val->y = (float)obs_data_get_double(obj, "y");
  1648. val->z = (float)obs_data_get_double(obj, "z");
  1649. obs_data_release(obj);
  1650. }
  1651. static inline void get_vec4(obs_data_t *obj, struct vec4 *val)
  1652. {
  1653. if (!obj)
  1654. return;
  1655. val->x = (float)obs_data_get_double(obj, "x");
  1656. val->y = (float)obs_data_get_double(obj, "y");
  1657. val->z = (float)obs_data_get_double(obj, "z");
  1658. val->w = (float)obs_data_get_double(obj, "w");
  1659. obs_data_release(obj);
  1660. }
  1661. static inline void get_quat(obs_data_t *obj, struct quat *val)
  1662. {
  1663. if (!obj)
  1664. return;
  1665. val->x = (float)obs_data_get_double(obj, "x");
  1666. val->y = (float)obs_data_get_double(obj, "y");
  1667. val->z = (float)obs_data_get_double(obj, "z");
  1668. val->w = (float)obs_data_get_double(obj, "w");
  1669. obs_data_release(obj);
  1670. }
  1671. void obs_data_get_vec2(obs_data_t *data, const char *name, struct vec2 *val)
  1672. {
  1673. get_vec2(obs_data_get_obj(data, name), val);
  1674. }
  1675. void obs_data_get_vec3(obs_data_t *data, const char *name, struct vec3 *val)
  1676. {
  1677. get_vec3(obs_data_get_obj(data, name), val);
  1678. }
  1679. void obs_data_get_vec4(obs_data_t *data, const char *name, struct vec4 *val)
  1680. {
  1681. get_vec4(obs_data_get_obj(data, name), val);
  1682. }
  1683. void obs_data_get_quat(obs_data_t *data, const char *name, struct quat *val)
  1684. {
  1685. get_quat(obs_data_get_obj(data, name), val);
  1686. }
  1687. void obs_data_get_default_vec2(obs_data_t *data, const char *name,
  1688. struct vec2 *val)
  1689. {
  1690. get_vec2(obs_data_get_default_obj(data, name), val);
  1691. }
  1692. void obs_data_get_default_vec3(obs_data_t *data, const char *name,
  1693. struct vec3 *val)
  1694. {
  1695. get_vec3(obs_data_get_default_obj(data, name), val);
  1696. }
  1697. void obs_data_get_default_vec4(obs_data_t *data, const char *name,
  1698. struct vec4 *val)
  1699. {
  1700. get_vec4(obs_data_get_default_obj(data, name), val);
  1701. }
  1702. void obs_data_get_default_quat(obs_data_t *data, const char *name,
  1703. struct quat *val)
  1704. {
  1705. get_quat(obs_data_get_default_obj(data, name), val);
  1706. }
  1707. void obs_data_get_autoselect_vec2(obs_data_t *data, const char *name,
  1708. struct vec2 *val)
  1709. {
  1710. get_vec2(obs_data_get_autoselect_obj(data, name), val);
  1711. }
  1712. void obs_data_get_autoselect_vec3(obs_data_t *data, const char *name,
  1713. struct vec3 *val)
  1714. {
  1715. get_vec3(obs_data_get_autoselect_obj(data, name), val);
  1716. }
  1717. void obs_data_get_autoselect_vec4(obs_data_t *data, const char *name,
  1718. struct vec4 *val)
  1719. {
  1720. get_vec4(obs_data_get_autoselect_obj(data, name), val);
  1721. }
  1722. void obs_data_get_autoselect_quat(obs_data_t *data, const char *name,
  1723. struct quat *val)
  1724. {
  1725. get_quat(obs_data_get_autoselect_obj(data, name), val);
  1726. }
  1727. /* ------------------------------------------------------------------------- */
  1728. /* Helper functions for media_frames_per_seconds */
  1729. static inline obs_data_t *
  1730. make_frames_per_second(struct media_frames_per_second fps, const char *option)
  1731. {
  1732. obs_data_t *obj = obs_data_create();
  1733. if (!option) {
  1734. obs_data_set_double(obj, "numerator", fps.numerator);
  1735. obs_data_set_double(obj, "denominator", fps.denominator);
  1736. } else {
  1737. obs_data_set_string(obj, "option", option);
  1738. }
  1739. return obj;
  1740. }
  1741. void obs_data_set_frames_per_second(obs_data_t *data, const char *name,
  1742. struct media_frames_per_second fps,
  1743. const char *option)
  1744. {
  1745. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1746. set_item);
  1747. }
  1748. void obs_data_set_default_frames_per_second(obs_data_t *data, const char *name,
  1749. struct media_frames_per_second fps,
  1750. const char *option)
  1751. {
  1752. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1753. set_item_def);
  1754. }
  1755. void obs_data_set_autoselect_frames_per_second(
  1756. obs_data_t *data, const char *name, struct media_frames_per_second fps,
  1757. const char *option)
  1758. {
  1759. obs_take_obj(data, NULL, name, make_frames_per_second(fps, option),
  1760. set_item_auto);
  1761. }
  1762. static inline bool get_option(obs_data_t *data, const char **option)
  1763. {
  1764. if (!option)
  1765. return false;
  1766. struct obs_data_item *opt = obs_data_item_byname(data, "option");
  1767. if (!opt)
  1768. return false;
  1769. *option = obs_data_item_get_string(opt);
  1770. obs_data_item_release(&opt);
  1771. obs_data_release(data);
  1772. return true;
  1773. }
  1774. #define CLAMP(x, min, max) ((x) < min ? min : ((x) > max ? max : (x)))
  1775. static inline bool get_frames_per_second(obs_data_t *data,
  1776. struct media_frames_per_second *fps,
  1777. const char **option)
  1778. {
  1779. if (!data)
  1780. return false;
  1781. if (get_option(data, option))
  1782. return true;
  1783. if (!fps)
  1784. goto free;
  1785. struct obs_data_item *num = obs_data_item_byname(data, "numerator");
  1786. struct obs_data_item *den = obs_data_item_byname(data, "denominator");
  1787. if (!num || !den) {
  1788. obs_data_item_release(&num);
  1789. obs_data_item_release(&den);
  1790. goto free;
  1791. }
  1792. long long num_ll = obs_data_item_get_int(num);
  1793. long long den_ll = obs_data_item_get_int(den);
  1794. fps->numerator = (uint32_t)CLAMP(num_ll, 0, (long long)UINT32_MAX);
  1795. fps->denominator = (uint32_t)CLAMP(den_ll, 0, (long long)UINT32_MAX);
  1796. obs_data_item_release(&num);
  1797. obs_data_item_release(&den);
  1798. obs_data_release(data);
  1799. return media_frames_per_second_is_valid(*fps);
  1800. free:
  1801. obs_data_release(data);
  1802. return false;
  1803. }
  1804. bool obs_data_get_frames_per_second(obs_data_t *data, const char *name,
  1805. struct media_frames_per_second *fps,
  1806. const char **option)
  1807. {
  1808. return get_frames_per_second(obs_data_get_obj(data, name), fps, option);
  1809. }
  1810. bool obs_data_get_default_frames_per_second(obs_data_t *data, const char *name,
  1811. struct media_frames_per_second *fps,
  1812. const char **option)
  1813. {
  1814. return get_frames_per_second(obs_data_get_default_obj(data, name), fps,
  1815. option);
  1816. }
  1817. bool obs_data_get_autoselect_frames_per_second(
  1818. obs_data_t *data, const char *name, struct media_frames_per_second *fps,
  1819. const char **option)
  1820. {
  1821. return get_frames_per_second(obs_data_get_autoselect_obj(data, name),
  1822. fps, option);
  1823. }
  1824. void obs_data_item_set_frames_per_second(obs_data_item_t **item,
  1825. struct media_frames_per_second fps,
  1826. const char *option)
  1827. {
  1828. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1829. set_item);
  1830. }
  1831. void obs_data_item_set_default_frames_per_second(
  1832. obs_data_item_t **item, struct media_frames_per_second fps,
  1833. const char *option)
  1834. {
  1835. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1836. set_item_def);
  1837. }
  1838. void obs_data_item_set_autoselect_frames_per_second(
  1839. obs_data_item_t **item, struct media_frames_per_second fps,
  1840. const char *option)
  1841. {
  1842. obs_take_obj(NULL, item, NULL, make_frames_per_second(fps, option),
  1843. set_item_auto);
  1844. }
  1845. bool obs_data_item_get_frames_per_second(obs_data_item_t *item,
  1846. struct media_frames_per_second *fps,
  1847. const char **option)
  1848. {
  1849. return get_frames_per_second(obs_data_item_get_obj(item), fps, option);
  1850. }
  1851. bool obs_data_item_get_default_frames_per_second(
  1852. obs_data_item_t *item, struct media_frames_per_second *fps,
  1853. const char **option)
  1854. {
  1855. return get_frames_per_second(obs_data_item_get_default_obj(item), fps,
  1856. option);
  1857. }
  1858. bool obs_data_item_get_autoselect_frames_per_second(
  1859. obs_data_item_t *item, struct media_frames_per_second *fps,
  1860. const char **option)
  1861. {
  1862. return get_frames_per_second(obs_data_item_get_autoselect_obj(item),
  1863. fps, option);
  1864. }