strapi/packages/core/utils/lib/async.js

'use strict';

const pMap = require('p-map');
const { curry } = require('lodash/fp');

function pipeAsync(...methods) {
  return async (data) => {
    let res = data;

    for (const method of methods) {
      res = await method(res);
    }

    return res;
  };
}

/**
 * @type { import('./async').MapAsync }
 */
const mapAsync = curry(pMap);

/**
 * Because of how mysql works, making parallel requests can cause deadlocks.
 * This function will run the requests sequentially if mysql is used. Else,
 * it will encapsulate them in a Promise.all.
 *
 * @type { import('./async').MapAsync }
 */
const mapAsyncDialects = async (array, func, options = {}) => {
  switch (strapi.db.dialect.client) {
    case 'mysql':
      return mapAsync(array, func, { concurrency: 1 });
    default:
      return mapAsync(array, func, options);
  }
};

module.exports = {
  mapAsync,
  mapAsyncDialects,
  pipeAsync,
};