Column updates

source_merge_updates.js

function mergeUpdates(data) {
  let output = {};
  Object.entries(data).forEach(function(entry) {
    let key = entry[0];
    let value = entry[1];
    
    if (key.startsWith(fieldName + '.')) {
      let column = key.split('.')[1];
      output[column] = value;
      return
    }
    
    output[key] = value;
  })
  
  return;
}

return mergeUpdates(source)

updates.js

function getUpdates(fieldName) {
  let updates = {};
  
  Object.entries(source).forEach(function(entry) {
    let key = entry[0];
    let value = entry[1];

    if (key.startsWith(fieldName + '.')) {
      let column = key.split('.')[1];
      updates[column] = value;
    }
  });
  
  return updates;
}

return {
 "_id": source._id,
 "a": source.a,
 "map_col": Object.assign({}, source.map_col, getUpdates('map_col'))
}

updates_v2.js

function getMapValue(fieldName) {
  let updates = source[fieldName] || {};
  
  Object.entries(source).forEach(function(entry) {
    let key = entry[0];
    let value = entry[1];

    if (key.startsWith(fieldName + '.')) {
      let column = key.split('.')[1];
      updates[column] = value;
    }
  });
  
  return updates;
}

return {
 "_id": source._id,
 "a": source.a,
 "map_col": getMapValue('map_col')
}