module-federation-dev-server.impl.ts

import { ExecutorContext, logger, runExecutor } from '@nrwl/devkit';
import devServerExecutor, {
  WebDevServerOptions,
} from '@nrwl/web/src/executors/dev-server/dev-server.impl';
import { join } from 'path';
import {
  combineAsyncIterators,
  tapAsyncIterator,
} from '../../utils/async-iterator';

type ModuleFederationDevServerOptions = WebDevServerOptions & {
  devRemotes?: string | string[];
};

export default async function* moduleFederationDevServer(
  options: ModuleFederationDevServerOptions,
  context: ExecutorContext
) {
  let iter = devServerExecutor(options, context);
  const p = context.workspace.projects[context.projectName];

  const moduleFederationConfigPath = join(
    context.root,
    p.root,
    'module-federation.config.js'
  );

  let moduleFederationConfig: any;
  try {
    moduleFederationConfig = require(moduleFederationConfigPath);
  } catch {
    // TODO(jack): Add a link to guide
    throw new Error(
      `Could not load ${moduleFederationConfigPath}. Was this project generated with "@nrwl/react:host"?`
    );
  }

  const knownRemotes = moduleFederationConfig.remotes ?? [];

  const devServeApps = !options.devRemotes
    ? []
    : Array.isArray(options.devRemotes)
    ? options.devRemotes
    : [options.devRemotes];

  for (const app of knownRemotes) {
    const isDev = devServeApps.includes(app);
    iter = combineAsyncIterators(
      iter,
      await runExecutor(
        {
          project: app,
          target: isDev ? 'serve' : 'serve-static',
          configuration: context.configurationName,
        },
        {
          watch: isDev,
        },
        context
      )
    );
  }

  let numAwaiting = knownRemotes.length + 1; // remotes + host
  return yield* tapAsyncIterator(iter, (x) => {
    numAwaiting--;
    if (numAwaiting === 0) {
      logger.info(
        `Host is ready: ${options.host ?? 'localhost'}:${options.port ?? 4200}`
      );
    }
  });
}