Function createMergeableStore

docs/pseudo.esm.sh/tinybase@9.0.0/index.js:2552–2969

(uniqueId, getNow)

  )
);
var createMergeableStore = (uniqueId, getNow) => {
  let listeningToRawStoreChanges = 1;
  let contentStampMap = newContentStampMap();
  let defaultingContent = 0;
  let mutated = 0;
  const touchedCells = mapNew();
  const touchedValues = setNew();
  const [getNextHlc, seenHlc] = getHlcFunctions(uniqueId, getNow);
  const store = createStore();
  const disableListeningToRawStoreChanges = (actions) => {
    const wasListening = listeningToRawStoreChanges;
    listeningToRawStoreChanges = 0;
    actions();
    listeningToRawStoreChanges = wasListening;
    return mergeableStore;
  };
  const mergeContentOrChanges = (contentOrChanges, isContent = 0) => {
    const tablesChanges = {};
    const valuesChanges = {};
    const [
      [tablesObj, incomingTablesHlc = EMPTY_STRING, incomingTablesHash = 0],
      values
    ] = contentOrChanges;
    const [tablesStampMap, valuesStampMap] = contentStampMap;
    const [tableStampMaps, oldTablesHlc, oldTablesHash] = tablesStampMap;
    let tablesHash = isContent ? incomingTablesHash : oldTablesHash;
    let tablesHlc = incomingTablesHlc;
    objForEach(
      tablesObj,
      ([rowsObj, incomingTableHlc = EMPTY_STRING, incomingTableHash = 0], tableId) => {
        const tableStampMap = mapEnsure(tableStampMaps, tableId, stampNewMap);
        const [rowStampMaps, oldTableHlc, oldTableHash] = tableStampMap;
        let tableHash = isContent ? incomingTableHash : oldTableHash;
        let tableHlc = incomingTableHlc;
        objForEach(rowsObj, (row, rowId) => {
          const [rowHlc, oldRowHash, rowHash] = mergeCellsOrValues(
            row,
            mapEnsure(rowStampMaps, rowId, stampNewMap),
            objEnsure(objEnsure(tablesChanges, tableId, objNew), rowId, objNew),
            isContent
          );
          tableHash ^= isContent ? 0 : addOrRemoveHash(
            oldRowHash ? getValueInValuesHash(rowId, oldRowHash) : 0,
            getValueInValuesHash(rowId, rowHash)
          );
          tableHlc = getLatestHlc(tableHlc, rowHlc);
        });
        tableHash ^= isContent ? 0 : replaceHlcHash(oldTableHlc, incomingTableHlc);
        stampUpdate(tableStampMap, incomingTableHlc, tableHash);
        tablesHash ^= isContent ? 0 : addOrRemoveHash(
          oldTableHash ? getValueInValuesHash(tableId, oldTableHash) : 0,
          getValueInValuesHash(tableId, tableStampMap[2])
        );
        tablesHlc = getLatestHlc(tablesHlc, tableHlc);
      }
    );
    tablesHash ^= isContent ? 0 : replaceHlcHash(oldTablesHlc, incomingTablesHlc);
    stampUpdate(tablesStampMap, incomingTablesHlc, tablesHash);