Fix for when there are more than 25 resolvers for a type

Author: chadkouse

cli.js

@@ -69,13 +69,16 @@ program
  })
  }
 
- function _fetchResolvers(apiId, typeName) {
+ function _fetchResolvers(apiId, typeName, nextToken) {
  return new Promise(function(resolve, reject) {
  let params = {
  apiId: apiId,
  typeName: typeName,
  maxResults: 25
  };
+ if (nextToken) {
+ params.nextToken = nextToken;
+ }
  appsync.listResolvers(params, function(err, data) {
  if (err)
  return reject(err)
@@ -142,47 +145,59 @@ program
  }
  ],
  function(err, results) {
- if (err)
- return reject(err)
+ if (err) {
+ console.log("Error", err);
+ return reject(err)
+ }
  else
  return resolve(null)
  });
  })
  }
 
+ function processAllResolvers(type, nextToken, eachCallback) {
+ async.waterfall([
+ function fetchResolvers(cb) {
+ console.log("Fetching resolvers for", type.name, nextToken);
+ _fetchResolvers(API_ID, type.name, nextToken).then(function(data) {
+ cb(null, data);
+ }).catch(function(e) {
+ cb(e);
+ })
+ },
+ function writeResolvers(data, cb) {
+ if (data.resolvers.length > 0) {
+ async.each(data.resolvers, function(resolver, resolverCallback) {
+ _writeMappingTemplates(type.name, resolver).then(function() {
+ resolverCallback(null, data)
+ }).catch(function(err) {
+ console.log("Err", err);
+ resolverCallback(err, data)
+ })
+ }, function(err) {
+ cb(null, data)
+ })
+ } else {
+ console.log('No resolvers for ', type.name)
+ cb(null, 'NO_RESOLVER');
+ }
+ }
+ ], function(err, data) {
+ if (data != 'NO_RESOLVER' && data.nextToken != null && data.nextToken != undefined) {
+ processAllResolvers(type, data.nextToken, eachCallback);
+ } else
+ eachCallback(err, null)
+ });
+ }
+
  function ProcessAPI(params, callback) {
  _getDataTypes(params, function(err, data) {
  if (err)
  return callback(err)
  async.each(data.types, function(type, eachCallback) {
- async.waterfall([
- function fetchResolvers(cb) {
- _fetchResolvers(API_ID, type.name).then(function(data) {
- cb(null, data);
- }).catch(function(e) {
- cb(e);
- })
- },
- function writeResolvers(data, cb) {
- if (data.resolvers.length > 0) {
- async.each(data.resolvers, function(resolver, resolverCallback) {
- _writeMappingTemplates(type.name, resolver).then(function() {
- resolverCallback(null)
- }).catch(function(err) {
- resolverCallback(err)
- })
- }, function(err, done) {
- cb(null)
- })
- } else {
- console.log('No resolvers for ', type.name)
- cb(null, 'NO_RESOLVER');
- }
- }
- ], function(err, done) {
- eachCallback(err, done)
- });
- }, function(err, done) {
+ processAllResolvers(type, null, eachCallback);
+ }
+ , function(err, done) {
  if (data.nextToken != null || data.nextToken != undefined) {
  params.nextToken = data.nextToken;
  ProcessAPI(params, callback)