payment-supervisor.js

/**
 * A not-exactly-how-we-did-this-but-something-similar-implementation
 * Enqueues a payment-processor execution for 0 - (buckets - 1)
 * @param {Int} buckets: the number of Payment Processor executions to enqueue
 * @param {Object} queue: Amazon SQS queue
 * @returns {Promise(<Array>)} Array of queue receipts 
*/

import {range} from 'lodash';
import * as P from 'bluebird';

function enqueueParallelExecutions(buckets, queueService) {
  const enqueuedRequests = range(buckets).map((bucket) => {
    return queueService.enqueue('payment-processor', {bucket, buckets});
  });
  return P.all(enqueuedRequests);
}