Function actionFunction

src/functionsShellCommandAction.ts:23–150

(options: Options)

const serveFunctions = new FunctionsServer();

export const actionFunction = async (options: Options) => {
  if (typeof options.port === "string") {
    options.port = parseInt(options.port, 10);
  }

  let debugPort = undefined;
  if (options.inspectFunctions) {
    debugPort = commandUtils.parseInspectionPort(options);
  }

  needProjectId(options);
  const hubClient = new EmulatorHubClient(options.project);

  let remoteEmulators: Record<string, EmulatorInfo> = {};
  if (hubClient.foundHub()) {
    remoteEmulators = await hubClient.getEmulators();
    logger.debug("Running emulators: ", remoteEmulators);
  }

  const runningEmulators = EMULATORS_SUPPORTED_BY_FUNCTIONS.filter(
    (e) => remoteEmulators[e] !== undefined,
  );
  const otherEmulators = EMULATORS_SUPPORTED_BY_FUNCTIONS.filter(
    (e) => remoteEmulators[e] === undefined,
  );

  let host = Constants.getDefaultHost();
  // If the port was not set by the --port flag or determined from 'firebase.json', just scan
  // up from 5000
  let port = 5000;
  if (typeof options.port === "number") {
    port = options.port;
  }

  const functionsInfo = remoteEmulators[Emulators.FUNCTIONS];
  if (functionsInfo) {
    utils.logLabeledWarning(
      "functions",
      `You are already running the Cloud Functions emulator on port ${functionsInfo.port}. Running the emulator and the Functions shell simultaenously can result in unexpected behavior.`,
    );
  } else if (!options.port) {
    // If the user did not pass in any port and the functions emulator is not already running, we can
    // use the port defined for the Functions emulator in their firebase.json
    port = options.config.src.emulators?.functions?.port ?? port;
    host = options.config.src.emulators?.functions?.host ?? host;
    options.host = host;
  }

  const listen = (
    await resolveHostAndAssignPorts({
      [Emulators.FUNCTIONS]: { host, port },
    })
  ).functions;
  // TODO: Listen on secondary addresses.
  options.host = listen[0].address;
  options.port = listen[0].port;

  return serveFunctions