src/replicate.js

import { sendJsonToNode, checkNodeOnline } from './utils';


export function createReplicatorDoc (source, target, options) {
  return {
    source: {
      url: source
    },

    target: {
      url: target
    },

    continuous: options.continuous,
    'create_target': options.create_target
  };
}

export function replicate (clusterUrl, replicatorUrl, doc) {
  return checkNodeOnline(clusterUrl)
  .then(() => {
    return sendJsonToNode(replicatorUrl, doc);
  });
}