Function createProgressiveStrategy

src/framework/piral-base/src/strategies.ts:51–110

(async: boolean)

 * @param async Uses the asynchronous mode.
 */
export function createProgressiveStrategy(async: boolean): PiletLoadingStrategy {
  return (options, cb) => {
    const {
      fetchPilets,
      dependencies = {},
      createApi,
      config,
      pilets = [],
      loadPilet = getDefaultLoader(config),
      loaders,
      hooks,
    } = options;
    const loadingAll = loadMetadata(fetchPilets);
    const loadSingle = extendLoader(loadPilet, loaders);

    return registerDependencies(dependencies).then(() => {
      if (!checkCreateApi(createApi)) {
        cb(undefined, []);
        return Promise.resolve();
      }

      return runPilets(createApi, pilets, hooks).then((integratedPilets) => {
        if (async && integratedPilets.length > 0) {
          cb(undefined, [...integratedPilets]);
        }

        const followUp = loadingAll.then((metadata) => {
          const promises = metadata.map((m) =>
            loadSingle(m).then((app) => {
              const available = pilets.filter((m) => m.name === app.name).length === 0;

              if (available) {
                return runPilet(createApi, app, hooks).then((additionalPilet) => {
                  integratedPilets.push(additionalPilet);

                  if (async) {
                    cb(undefined, [...integratedPilets]);
                  }
                });
              }
            }),
          );

          return Promise.all(promises).then(() => {
            if (!async) {
              cb(undefined, integratedPilets);
            }
          });
        });

        if (async) {
          followUp.catch(() => {});
          return loadingAll.then();
        } else {
          return followUp.then();
        }
      });
    });