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) => {
  const results = [];

  switch (strapi.db.dialect.client) {
    case 'mysql': {
      mapAsync(array, async (elm) => {
        results.push(await func(elm));
      });
      break;
    }
    default:
      results.push(...(await Promise.all(array.map(func))));
      break;
  }

  return results;
};

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