utils.js 9.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331
  1. /**
  2. * DevExtreme (data/utils.js)
  3. * Version: 19.1.16
  4. * Build date: Tue Oct 18 2022
  5. *
  6. * Copyright (c) 2012 - 2022 Developer Express Inc. ALL RIGHTS RESERVED
  7. * Read about DevExtreme licensing here: https://js.devexpress.com/Licensing/
  8. */
  9. "use strict";
  10. var _type = require("../core/utils/type");
  11. var _type2 = _interopRequireDefault(_type);
  12. var _dom_adapter = require("../core/dom_adapter");
  13. var _dom_adapter2 = _interopRequireDefault(_dom_adapter);
  14. var _ready_callbacks = require("../core/utils/ready_callbacks");
  15. var _window = require("../core/utils/window");
  16. var _iterator = require("../core/utils/iterator");
  17. var _data = require("../core/utils/data");
  18. var _deferred = require("../core/utils/deferred");
  19. function _interopRequireDefault(obj) {
  20. return obj && obj.__esModule ? obj : {
  21. "default": obj
  22. }
  23. }
  24. function _toConsumableArray(arr) {
  25. return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _unsupportedIterableToArray(arr) || _nonIterableSpread()
  26. }
  27. function _nonIterableSpread() {
  28. throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")
  29. }
  30. function _unsupportedIterableToArray(o, minLen) {
  31. if (!o) {
  32. return
  33. }
  34. if ("string" === typeof o) {
  35. return _arrayLikeToArray(o, minLen)
  36. }
  37. var n = Object.prototype.toString.call(o).slice(8, -1);
  38. if ("Object" === n && o.constructor) {
  39. n = o.constructor.name
  40. }
  41. if ("Map" === n || "Set" === n) {
  42. return Array.from(o)
  43. }
  44. if ("Arguments" === n || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) {
  45. return _arrayLikeToArray(o, minLen)
  46. }
  47. }
  48. function _iterableToArray(iter) {
  49. if ("undefined" !== typeof Symbol && null != iter[Symbol.iterator] || null != iter["@@iterator"]) {
  50. return Array.from(iter)
  51. }
  52. }
  53. function _arrayWithoutHoles(arr) {
  54. if (Array.isArray(arr)) {
  55. return _arrayLikeToArray(arr)
  56. }
  57. }
  58. function _arrayLikeToArray(arr, len) {
  59. if (null == len || len > arr.length) {
  60. len = arr.length
  61. }
  62. for (var i = 0, arr2 = new Array(len); i < len; i++) {
  63. arr2[i] = arr[i]
  64. }
  65. return arr2
  66. }
  67. var XHR_ERROR_UNLOAD = "DEVEXTREME_XHR_ERROR_UNLOAD";
  68. var normalizeBinaryCriterion = function(crit) {
  69. return [crit[0], crit.length < 3 ? "=" : String(crit[1]).toLowerCase(), crit.length < 2 ? true : crit[crit.length - 1]]
  70. };
  71. var normalizeSortingInfo = function(info) {
  72. if (!Array.isArray(info)) {
  73. info = [info]
  74. }
  75. return (0, _iterator.map)(info, function(i) {
  76. var result = {
  77. selector: (0, _type.isFunction)(i) || "string" === typeof i ? i : i.getter || i.field || i.selector,
  78. desc: !!(i.desc || "d" === String(i.dir).charAt(0).toLowerCase())
  79. };
  80. if (i.compare) {
  81. result.compare = i.compare
  82. }
  83. return result
  84. })
  85. };
  86. var errorMessageFromXhr = function() {
  87. var textStatusMessages = {
  88. timeout: "Network connection timeout",
  89. error: "Unspecified network error",
  90. parsererror: "Unexpected server response"
  91. };
  92. var explainTextStatus = function(textStatus) {
  93. var result = textStatusMessages[textStatus];
  94. if (!result) {
  95. return textStatus
  96. }
  97. return result
  98. };
  99. var unloading;
  100. (0, _ready_callbacks.add)(function() {
  101. var window = (0, _window.getWindow)();
  102. _dom_adapter2.default.listen(window, "beforeunload", function() {
  103. unloading = true
  104. })
  105. });
  106. return function(xhr, textStatus) {
  107. if (unloading) {
  108. return XHR_ERROR_UNLOAD
  109. }
  110. if (xhr.status < 400) {
  111. return explainTextStatus(textStatus)
  112. }
  113. return xhr.statusText
  114. }
  115. }();
  116. var aggregators = {
  117. count: {
  118. seed: 0,
  119. step: function(count) {
  120. return 1 + count
  121. }
  122. },
  123. sum: {
  124. seed: 0,
  125. step: function(sum, item) {
  126. return sum + item
  127. }
  128. },
  129. min: {
  130. step: function(min, item) {
  131. return item < min ? item : min
  132. }
  133. },
  134. max: {
  135. step: function(max, item) {
  136. return item > max ? item : max
  137. }
  138. },
  139. avg: {
  140. seed: [0, 0],
  141. step: function(pair, value) {
  142. return [pair[0] + value, pair[1] + 1]
  143. },
  144. finalize: function(pair) {
  145. return pair[1] ? pair[0] / pair[1] : NaN
  146. }
  147. }
  148. };
  149. var processRequestResultLock = function() {
  150. var lockCount = 0;
  151. var lockDeferred;
  152. var obtain = function() {
  153. if (0 === lockCount) {
  154. lockDeferred = new _deferred.Deferred
  155. }
  156. lockCount++
  157. };
  158. var release = function() {
  159. lockCount--;
  160. if (lockCount < 1) {
  161. lockDeferred.resolve()
  162. }
  163. };
  164. var promise = function() {
  165. var deferred = 0 === lockCount ? (new _deferred.Deferred).resolve() : lockDeferred;
  166. return deferred.promise()
  167. };
  168. var reset = function() {
  169. lockCount = 0;
  170. if (lockDeferred) {
  171. lockDeferred.resolve()
  172. }
  173. };
  174. return {
  175. obtain: obtain,
  176. release: release,
  177. promise: promise,
  178. reset: reset
  179. }
  180. }();
  181. function isDisjunctiveOperator(condition) {
  182. return /^(or|\|\||\|)$/i.test(condition)
  183. }
  184. function isConjunctiveOperator(condition) {
  185. return /^(and|&&|&)$/i.test(condition)
  186. }
  187. var keysEqual = function(keyExpr, key1, key2) {
  188. if (Array.isArray(keyExpr)) {
  189. var names = (0, _iterator.map)(key1, function(v, k) {
  190. return k
  191. });
  192. var name;
  193. for (var i = 0; i < names.length; i++) {
  194. name = names[i];
  195. if ((0, _data.toComparable)(key1[name], true) != (0, _data.toComparable)(key2[name], true)) {
  196. return false
  197. }
  198. }
  199. return true
  200. }
  201. return (0, _data.toComparable)(key1, true) == (0, _data.toComparable)(key2, true)
  202. };
  203. var BASE64_CHARS = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=";
  204. var base64_encode = function(input) {
  205. if (!Array.isArray(input)) {
  206. input = stringToByteArray(String(input))
  207. }
  208. var result = "";
  209. function getBase64Char(index) {
  210. return BASE64_CHARS.charAt(index)
  211. }
  212. for (var i = 0; i < input.length; i += 3) {
  213. var octet1 = input[i];
  214. var octet2 = input[i + 1];
  215. var octet3 = input[i + 2];
  216. result += (0, _iterator.map)([octet1 >> 2, (3 & octet1) << 4 | octet2 >> 4, isNaN(octet2) ? 64 : (15 & octet2) << 2 | octet3 >> 6, isNaN(octet3) ? 64 : 63 & octet3], getBase64Char).join("")
  217. }
  218. return result
  219. };
  220. var stringToByteArray = function(str) {
  221. var bytes = [];
  222. var code;
  223. var i;
  224. for (i = 0; i < str.length; i++) {
  225. code = str.charCodeAt(i);
  226. if (code < 128) {
  227. bytes.push(code)
  228. } else {
  229. if (code < 2048) {
  230. bytes.push(192 + (code >> 6), 128 + (63 & code))
  231. } else {
  232. if (code < 65536) {
  233. bytes.push(224 + (code >> 12), 128 + (code >> 6 & 63), 128 + (63 & code))
  234. } else {
  235. if (code < 2097152) {
  236. bytes.push(240 + (code >> 18), 128 + (code >> 12 & 63), 128 + (code >> 6 & 63), 128 + (63 & code))
  237. }
  238. }
  239. }
  240. }
  241. }
  242. return bytes
  243. };
  244. var isUnaryOperation = function(crit) {
  245. return "!" === crit[0] && Array.isArray(crit[1])
  246. };
  247. var isGroupOperator = function(value) {
  248. return "and" === value || "or" === value
  249. };
  250. var isGroupCriterion = function(crit) {
  251. var first = crit[0];
  252. var second = crit[1];
  253. if (Array.isArray(first)) {
  254. return true
  255. }
  256. if (_type2.default.isFunction(first)) {
  257. if (Array.isArray(second) || _type2.default.isFunction(second) || isGroupOperator(second)) {
  258. return true
  259. }
  260. }
  261. return false
  262. };
  263. var trivialPromise = function() {
  264. var d = new _deferred.Deferred;
  265. return d.resolve.apply(d, arguments).promise()
  266. };
  267. var rejectedPromise = function() {
  268. var d = new _deferred.Deferred;
  269. return d.reject.apply(d, arguments).promise()
  270. };
  271. function throttle(func, timeout) {
  272. var timeoutId;
  273. var lastArgs;
  274. return function() {
  275. var _this = this;
  276. lastArgs = arguments;
  277. if (!timeoutId) {
  278. timeoutId = setTimeout(function() {
  279. timeoutId = void 0;
  280. if (lastArgs) {
  281. func.call(_this, lastArgs)
  282. }
  283. }, (0, _type.isFunction)(timeout) ? timeout() : timeout)
  284. }
  285. return timeoutId
  286. }
  287. }
  288. function throttleChanges(func, timeout) {
  289. var cache = [];
  290. var throttled = throttle(function() {
  291. func.call(this, cache);
  292. cache = []
  293. }, timeout);
  294. return function(changes) {
  295. if (Array.isArray(changes)) {
  296. var _cache;
  297. (_cache = cache).push.apply(_cache, _toConsumableArray(changes))
  298. }
  299. return throttled.call(this, cache)
  300. }
  301. }
  302. var utils = {
  303. XHR_ERROR_UNLOAD: XHR_ERROR_UNLOAD,
  304. normalizeBinaryCriterion: normalizeBinaryCriterion,
  305. normalizeSortingInfo: normalizeSortingInfo,
  306. errorMessageFromXhr: errorMessageFromXhr,
  307. aggregators: aggregators,
  308. keysEqual: keysEqual,
  309. throttleChanges: throttleChanges,
  310. trivialPromise: trivialPromise,
  311. rejectedPromise: rejectedPromise,
  312. isDisjunctiveOperator: isDisjunctiveOperator,
  313. isConjunctiveOperator: isConjunctiveOperator,
  314. processRequestResultLock: processRequestResultLock,
  315. isUnaryOperation: isUnaryOperation,
  316. isGroupCriterion: isGroupCriterion,
  317. base64_encode: base64_encode
  318. };
  319. module.exports = utils;