SourceDataClient/client/index.js

var bluebird = require("bluebird");
var restify = require('restify');
 
var client = bluebird.promisifyAll(restify.createJsonClient({
  url: config.url,
  version: '~1.0'
}));
 
exports.deleteUsers = function(serverId){
  return client.delAsync('/api/users/' + serverId)
    .then(function(){
      return serverId;
    });
};

exports.deleteBranchs = function(serverId){
  return client.delAsync('/api/branchs/' + serverId) .then(function(){
      return serverId;
    });
};

exports.deleteAddrGroup = function(serverId){
  return client.delAsync('/api/addrGroup/' + serverId) .then(function(){
      return serverId;
    });
};

exports.deleteAddrGroupMember = function(serverId){
  return client.delAsync('/api/addrGroupMember/' + serverId) .then(function(){
      return serverId;
    });
};

exports.addUsers = function(users){
  while(users.length > 0){
    var tmp = users.length > 50? users.splice(0, 50) : users.splice(0, users.length);
    client.post('/api/users',  tmp, function(err, req, res, obj) {
      if (res)logger.info('%d -> %j', res.statusCode, res.headers);
      logger.info('%j', obj);
    });
  }
};

exports.addBranchs = function(branchs){
    while(branchs.length > 0){
    var tmp = branchs.length > 50? branchs.splice(0, 50) : branchs.splice(0, branchs.length);
    client.post('/api/branchs',  tmp, function(err, req, res, obj) {
      if (res)logger.info('%d -> %j', res.statusCode, res.headers);
      logger.info('%j', obj);
    });
  }
};

exports.addAddrGroup = function(addrGroups){
  while(addrGroups.length > 0){
    var tmp = addrGroups.length > 50? addrGroups.splice(0, 50) : addrGroups.splice(0, addrGroups.length);
    client.post('/api/addrGroup',  tmp, function(err, req, res, obj) {
      if (res)logger.info('%d -> %j', res.statusCode, res.headers);
      logger.info('%j', obj);
    });
  }
};

exports.addAddrGroupMember = function(addrGroupMembers, serverId){
  while(addrGroupMembers.length > 0){
    var tmp = addrGroupMembers.length > 50? addrGroupMembers.splice(0, 50) : addrGroupMembers.splice(0, addrGroupMembers.length);
    client.post('/api/addrGroupMember/' + serverId,  tmp, function(err, req, res, obj) {
      if (res)logger.info('%d -> %j', res.statusCode, res.headers);
      logger.info('%j', obj);
    });
  }
};