Function getTransactionMergeableChangesImpl

src/mergeable-store/index.ts:423–483

(
    withHashes: boolean,
    encoded = false,
  )

  ];

  const getTransactionMergeableChangesImpl = (
    withHashes: boolean,
    encoded = false,
  ): MergeableChanges<typeof withHashes> => {
    const [
      [tableStampMaps, tablesHlc, tablesHash],
      [valueStampMaps, valuesHlc, valuesHash],
    ] = contentStampMap;

    const newStamp = withHashes ? stampNewWithHash : stampNew;

    const tablesObj: TablesStamp<typeof withHashes>[0] = {};
    collForEach(touchedCells, (touchedTable, tableId) =>
      ifNotUndefined(
        mapGet(tableStampMaps, tableId),
        ([rowStampMaps, tableHlc, tableHash]) => {
          const tableObj: TableStamp<typeof withHashes>[0] = {};
          collForEach(touchedTable, (touchedRow, rowId) =>
            ifNotUndefined(
              mapGet(rowStampMaps, rowId),
              ([cellStampMaps, rowHlc, rowHash]) => {
                const rowObj: RowStamp<typeof withHashes>[0] = {};
                collForEach(touchedRow, (cellId) => {
                  ifNotUndefined(
                    mapGet(cellStampMaps, cellId),
                    ([cell, time, hash]) =>
                      (rowObj[cellId] = newStamp(
                        encoded ? cell : decodeIfJson(cell),
                        time,
                        hash,
                      )),
                  );
                });
                tableObj[rowId] = newStamp(rowObj, rowHlc, rowHash);
              },
            ),
          );
          tablesObj[tableId] = newStamp(tableObj, tableHlc, tableHash);
        },
      ),
    );

    const valuesObj: ValuesStamp<typeof withHashes>[0] = {};
    collForEach(touchedValues, (valueId) =>
      ifNotUndefined(
        mapGet(valueStampMaps, valueId),
        ([value, time, hash]) =>
          (valuesObj[valueId] = newStamp(
            encoded ? value : decodeIfJson(value),
            time,
            hash,
          )),
      ),
    );

    return [
      newStamp(tablesObj, tablesHlc, tablesHash),
      newStamp(valuesObj, valuesHlc, valuesHash),