Function replicate

test/replication.test.js:1805–1830

(source, target, since, next)

  const _since = {};
  function replicate(source, target, since, next) {
    if (typeof since === 'function') {
      next = since;
      since = undefined;
    }

    const sinceIx = source.modelName + ':to:' + target.modelName;
    if (since === undefined) {
      since = useSinceFilter ?
        _since[sinceIx] || -1 :
        -1;
    }

    debug('replicate from %s to %s since %j',
      source.modelName, target.modelName, since);

    source.replicate(since, target, function(err, conflicts, cps) {
      if (err) return next(err);

      if (conflicts.length === 0) {
        _since[sinceIx] = cps;
      }

      next(err, conflicts, cps);
    });
  }

  function createModel(Model, data) {
    return function create(next) {