Function ChainFind

lib/ChainFind.js:10–292

(Model, opts)

module.exports = ChainFind;

function ChainFind(Model, opts) {
  var promiseFunctionPostfix = Model.settings.get('promiseFunctionPostfix');

  var prepareConditions = function () {
    return Utilities.transformPropertyNames(
      opts.conditions, opts.properties
    );
  };

  var prepareOrder = function () {
    return Utilities.transformOrderPropertyNames(
      opts.order, opts.properties
    );
  };

  var chainRun = function (done) {
    var order, conditions;

    conditions = Utilities.transformPropertyNames(
      opts.conditions, opts.properties
    );
    order = Utilities.transformOrderPropertyNames(
      opts.order, opts.properties
    );

    opts.driver.find(opts.only, opts.table, conditions, {
      limit  : opts.limit,
      order  : order,
      merge  : opts.merge,
      offset : opts.offset,
      exists : opts.exists
    }, function (err, dataItems) {
      if (err) {
        return done(err);
      }
      if (dataItems.length === 0) {
        return done(null, []);
      }

      var eagerLoad = function (err, items) {
        var idMap = {};

        var keys = _.map(items, function (item, index) {
          var key = item[opts.keys[0]];
          // Create the association arrays
          for (var i = 0, association; association = opts.__eager[i]; i++) {
            item[association.name] = [];
          }
          idMap[key] = index;

          return key;
        });

        async.eachSeries(opts.__eager,
          function (association, cb) {
            opts.driver.eagerQuery(association, opts, keys, function (err, instances) {
              if (err) return cb(err)