common/src/leap/soledad/common/ddocs/syncs/views/changes_to_return/map.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

function(doc) {
  if (doc['_id'] == 'u1db_sync_state' && doc['ongoing_syncs'] != null)
    for (var source_replica_uid in doc['ongoing_syncs']) {
      var changes = doc['ongoing_syncs'][source_replica_uid]['changes_to_return'];
      if (changes == null)
        emit([source_replica_uid, 0], null);
      else if (changes.length == 0)
        emit([source_replica_uid, 0], []);
        for (var i = 0; i < changes['changes_to_return'].length; i++)
          emit(
            [source_replica_uid, i],
            {
              'gen': changes['gen'],
              'trans_id': changes['trans_id'],
              'next_change_to_return': changes['changes_to_return'][i],
            });
    }
}