data-joint.common.js 9.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317
  1. 'use strict';
  2. var indexBy = require('index-array-by');
  3. function _interopDefaultLegacy (e) { return e && typeof e === 'object' && 'default' in e ? e : { 'default': e }; }
  4. var indexBy__default = /*#__PURE__*/_interopDefaultLegacy(indexBy);
  5. function ownKeys(object, enumerableOnly) {
  6. var keys = Object.keys(object);
  7. if (Object.getOwnPropertySymbols) {
  8. var symbols = Object.getOwnPropertySymbols(object);
  9. if (enumerableOnly) {
  10. symbols = symbols.filter(function (sym) {
  11. return Object.getOwnPropertyDescriptor(object, sym).enumerable;
  12. });
  13. }
  14. keys.push.apply(keys, symbols);
  15. }
  16. return keys;
  17. }
  18. function _objectSpread2(target) {
  19. for (var i = 1; i < arguments.length; i++) {
  20. var source = arguments[i] != null ? arguments[i] : {};
  21. if (i % 2) {
  22. ownKeys(Object(source), true).forEach(function (key) {
  23. _defineProperty(target, key, source[key]);
  24. });
  25. } else if (Object.getOwnPropertyDescriptors) {
  26. Object.defineProperties(target, Object.getOwnPropertyDescriptors(source));
  27. } else {
  28. ownKeys(Object(source)).forEach(function (key) {
  29. Object.defineProperty(target, key, Object.getOwnPropertyDescriptor(source, key));
  30. });
  31. }
  32. }
  33. return target;
  34. }
  35. function _defineProperty(obj, key, value) {
  36. if (key in obj) {
  37. Object.defineProperty(obj, key, {
  38. value: value,
  39. enumerable: true,
  40. configurable: true,
  41. writable: true
  42. });
  43. } else {
  44. obj[key] = value;
  45. }
  46. return obj;
  47. }
  48. function _objectWithoutPropertiesLoose(source, excluded) {
  49. if (source == null) return {};
  50. var target = {};
  51. var sourceKeys = Object.keys(source);
  52. var key, i;
  53. for (i = 0; i < sourceKeys.length; i++) {
  54. key = sourceKeys[i];
  55. if (excluded.indexOf(key) >= 0) continue;
  56. target[key] = source[key];
  57. }
  58. return target;
  59. }
  60. function _objectWithoutProperties(source, excluded) {
  61. if (source == null) return {};
  62. var target = _objectWithoutPropertiesLoose(source, excluded);
  63. var key, i;
  64. if (Object.getOwnPropertySymbols) {
  65. var sourceSymbolKeys = Object.getOwnPropertySymbols(source);
  66. for (i = 0; i < sourceSymbolKeys.length; i++) {
  67. key = sourceSymbolKeys[i];
  68. if (excluded.indexOf(key) >= 0) continue;
  69. if (!Object.prototype.propertyIsEnumerable.call(source, key)) continue;
  70. target[key] = source[key];
  71. }
  72. }
  73. return target;
  74. }
  75. function _slicedToArray(arr, i) {
  76. return _arrayWithHoles(arr) || _iterableToArrayLimit(arr, i) || _unsupportedIterableToArray(arr, i) || _nonIterableRest();
  77. }
  78. function _toConsumableArray(arr) {
  79. return _arrayWithoutHoles(arr) || _iterableToArray(arr) || _unsupportedIterableToArray(arr) || _nonIterableSpread();
  80. }
  81. function _arrayWithoutHoles(arr) {
  82. if (Array.isArray(arr)) return _arrayLikeToArray(arr);
  83. }
  84. function _arrayWithHoles(arr) {
  85. if (Array.isArray(arr)) return arr;
  86. }
  87. function _iterableToArray(iter) {
  88. if (typeof Symbol !== "undefined" && iter[Symbol.iterator] != null || iter["@@iterator"] != null) return Array.from(iter);
  89. }
  90. function _iterableToArrayLimit(arr, i) {
  91. var _i = arr && (typeof Symbol !== "undefined" && arr[Symbol.iterator] || arr["@@iterator"]);
  92. if (_i == null) return;
  93. var _arr = [];
  94. var _n = true;
  95. var _d = false;
  96. var _s, _e;
  97. try {
  98. for (_i = _i.call(arr); !(_n = (_s = _i.next()).done); _n = true) {
  99. _arr.push(_s.value);
  100. if (i && _arr.length === i) break;
  101. }
  102. } catch (err) {
  103. _d = true;
  104. _e = err;
  105. } finally {
  106. try {
  107. if (!_n && _i["return"] != null) _i["return"]();
  108. } finally {
  109. if (_d) throw _e;
  110. }
  111. }
  112. return _arr;
  113. }
  114. function _unsupportedIterableToArray(o, minLen) {
  115. if (!o) return;
  116. if (typeof o === "string") return _arrayLikeToArray(o, minLen);
  117. var n = Object.prototype.toString.call(o).slice(8, -1);
  118. if (n === "Object" && o.constructor) n = o.constructor.name;
  119. if (n === "Map" || n === "Set") return Array.from(o);
  120. if (n === "Arguments" || /^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n)) return _arrayLikeToArray(o, minLen);
  121. }
  122. function _arrayLikeToArray(arr, len) {
  123. if (len == null || len > arr.length) len = arr.length;
  124. for (var i = 0, arr2 = new Array(len); i < len; i++) arr2[i] = arr[i];
  125. return arr2;
  126. }
  127. function _nonIterableSpread() {
  128. throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.");
  129. }
  130. function _nonIterableRest() {
  131. throw new TypeError("Invalid attempt to destructure non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.");
  132. }
  133. function diffArrays(prev, next, idAccessor) {
  134. var result = {
  135. enter: [],
  136. update: [],
  137. exit: []
  138. };
  139. if (!idAccessor) {
  140. // use object references for comparison
  141. var prevSet = new Set(prev);
  142. var nextSet = new Set(next);
  143. new Set([].concat(_toConsumableArray(prevSet), _toConsumableArray(nextSet))).forEach(function (item) {
  144. var type = !prevSet.has(item) ? 'enter' : !nextSet.has(item) ? 'exit' : 'update';
  145. result[type].push(type === 'update' ? [item, item] : item);
  146. });
  147. } else {
  148. // compare by id (duplicate keys are ignored)
  149. var prevById = indexBy__default['default'](prev, idAccessor, false);
  150. var nextById = indexBy__default['default'](next, idAccessor, false);
  151. var byId = Object.assign({}, prevById, nextById);
  152. Object.entries(byId).forEach(function (_ref) {
  153. var _ref2 = _slicedToArray(_ref, 2),
  154. id = _ref2[0],
  155. item = _ref2[1];
  156. var type = !prevById.hasOwnProperty(id) ? 'enter' : !nextById.hasOwnProperty(id) ? 'exit' : 'update';
  157. result[type].push(type === 'update' ? [prevById[id], nextById[id]] : item);
  158. });
  159. }
  160. return result;
  161. }
  162. function dataBindDiff(data, existingObjs, _ref3) {
  163. var _ref3$objBindAttr = _ref3.objBindAttr,
  164. objBindAttr = _ref3$objBindAttr === void 0 ? '__obj' : _ref3$objBindAttr,
  165. _ref3$dataBindAttr = _ref3.dataBindAttr,
  166. dataBindAttr = _ref3$dataBindAttr === void 0 ? '__data' : _ref3$dataBindAttr,
  167. idAccessor = _ref3.idAccessor,
  168. _ref3$purge = _ref3.purge,
  169. purge = _ref3$purge === void 0 ? false : _ref3$purge;
  170. var isObjValid = function isObjValid(obj) {
  171. return obj.hasOwnProperty(dataBindAttr);
  172. };
  173. var removeObjs = existingObjs.filter(function (obj) {
  174. return !isObjValid(obj);
  175. });
  176. var prevD = existingObjs.filter(isObjValid).map(function (obj) {
  177. return obj[dataBindAttr];
  178. });
  179. var nextD = data;
  180. var diff = purge ? {
  181. enter: nextD,
  182. exit: prevD,
  183. update: []
  184. } // don't diff data in purge mode
  185. : diffArrays(prevD, nextD, idAccessor);
  186. diff.update = diff.update.map(function (_ref4) {
  187. var _ref5 = _slicedToArray(_ref4, 2),
  188. prevD = _ref5[0],
  189. nextD = _ref5[1];
  190. if (prevD !== nextD) {
  191. // transfer obj to new data point (if different)
  192. nextD[objBindAttr] = prevD[objBindAttr];
  193. nextD[objBindAttr][dataBindAttr] = nextD;
  194. }
  195. return nextD;
  196. });
  197. diff.exit = diff.exit.concat(removeObjs.map(function (obj) {
  198. return _defineProperty({}, objBindAttr, obj);
  199. }));
  200. return diff;
  201. }
  202. function viewDigest(data, existingObjs, // list
  203. appendObj, // item => {...} function
  204. removeObj, // item => {...} function
  205. _ref7) {
  206. var _ref7$createObj = _ref7.createObj,
  207. createObj = _ref7$createObj === void 0 ? function (d) {
  208. return {};
  209. } : _ref7$createObj,
  210. _ref7$updateObj = _ref7.updateObj,
  211. updateObj = _ref7$updateObj === void 0 ? function (obj, d) {} : _ref7$updateObj,
  212. _ref7$exitObj = _ref7.exitObj,
  213. exitObj = _ref7$exitObj === void 0 ? function (obj) {} : _ref7$exitObj,
  214. _ref7$objBindAttr = _ref7.objBindAttr,
  215. objBindAttr = _ref7$objBindAttr === void 0 ? '__obj' : _ref7$objBindAttr,
  216. _ref7$dataBindAttr = _ref7.dataBindAttr,
  217. dataBindAttr = _ref7$dataBindAttr === void 0 ? '__data' : _ref7$dataBindAttr,
  218. dataDiffOptions = _objectWithoutProperties(_ref7, ["createObj", "updateObj", "exitObj", "objBindAttr", "dataBindAttr"]);
  219. var _dataBindDiff = dataBindDiff(data, existingObjs, _objectSpread2({
  220. objBindAttr: objBindAttr,
  221. dataBindAttr: dataBindAttr
  222. }, dataDiffOptions)),
  223. enter = _dataBindDiff.enter,
  224. update = _dataBindDiff.update,
  225. exit = _dataBindDiff.exit; // Remove exiting points
  226. exit.forEach(function (d) {
  227. var obj = d[objBindAttr];
  228. delete d[objBindAttr]; // unbind obj
  229. exitObj(obj);
  230. removeObj(obj);
  231. });
  232. var newObjs = createObjs(enter);
  233. var pointsData = [].concat(_toConsumableArray(enter), _toConsumableArray(update));
  234. updateObjs(pointsData); // Add new points
  235. newObjs.forEach(appendObj); //
  236. function createObjs(data) {
  237. var newObjs = [];
  238. data.forEach(function (d) {
  239. var obj = createObj(d);
  240. if (obj) {
  241. obj[dataBindAttr] = d;
  242. d[objBindAttr] = obj;
  243. newObjs.push(obj);
  244. }
  245. });
  246. return newObjs;
  247. }
  248. function updateObjs(data) {
  249. data.forEach(function (d) {
  250. var obj = d[objBindAttr];
  251. if (obj) {
  252. obj[dataBindAttr] = d;
  253. updateObj(obj, d);
  254. }
  255. });
  256. }
  257. }
  258. module.exports = viewDigest;