File: //usr/local/lib/node_modules/firebase-tools/lib/command.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.validateProjectId = exports.Command = void 0;
const clc = require("colorette");
const lodash_1 = require("lodash");
const error_1 = require("./error");
const utils_1 = require("./utils");
const rc_1 = require("./rc");
const config_1 = require("./config");
const configstore_1 = require("./configstore");
const detectProjectRoot_1 = require("./detectProjectRoot");
const track_1 = require("./track");
const auth_1 = require("./auth");
const projects_1 = require("./management/projects");
const requireAuth_1 = require("./requireAuth");
class Command {
constructor(cmd) {
this.cmd = cmd;
this.name = "";
this.descriptionText = "";
this.options = [];
this.aliases = [];
this.actionFn = () => {
};
this.befores = [];
this.helpText = "";
this.positionalArgs = [];
this.name = (0, lodash_1.first)(cmd.split(" ")) || "";
}
description(t) {
this.descriptionText = t;
return this;
}
alias(alias) {
this.aliases.push(alias);
return this;
}
option(...args) {
this.options.push(args);
return this;
}
withForce(message) {
this.options.push(["-f, --force", message || "automatically accept all interactive prompts"]);
return this;
}
before(fn, ...args) {
this.befores.push({ fn: fn, args: args });
return this;
}
help(t) {
this.helpText = t;
return this;
}
action(fn) {
this.actionFn = fn;
return this;
}
register(client) {
this.client = client;
const program = client.cli;
const cmd = program.command(this.cmd);
if (this.descriptionText) {
cmd.description(this.descriptionText);
}
if (this.aliases) {
cmd.aliases(this.aliases);
}
this.options.forEach((args) => {
const flags = args.shift();
cmd.option(flags, ...args);
});
if (this.helpText) {
cmd.on("--help", () => {
console.log();
console.log(this.helpText);
});
}
this.positionalArgs = cmd._args;
cmd.action((...args) => {
const runner = this.runner();
const start = process.uptime();
const options = (0, lodash_1.last)(args);
if (args.length - 1 > cmd._args.length) {
client.errorOut(new error_1.FirebaseError(`Too many arguments. Run ${clc.bold("firebase help " + this.name)} for usage instructions`, { exit: 1 }));
return;
}
const isEmulator = this.name.includes("emulator") || this.name === "serve";
if (isEmulator) {
void (0, track_1.trackEmulator)("command_start", { command_name: this.name });
}
runner(...args)
.then(async (result) => {
if ((0, utils_1.getInheritedOption)(options, "json")) {
await new Promise((resolve) => {
process.stdout.write(JSON.stringify({
status: "success",
result: result,
}, null, 2), resolve);
});
}
const duration = Math.floor((process.uptime() - start) * 1000);
const trackSuccess = (0, track_1.trackGA4)("command_execution", {
command_name: this.name,
result: "success",
duration,
interactive: (0, utils_1.getInheritedOption)(options, "nonInteractive") ? "false" : "true",
});
if (!isEmulator) {
await (0, utils_1.withTimeout)(5000, trackSuccess);
}
else {
await (0, utils_1.withTimeout)(5000, Promise.all([
trackSuccess,
(0, track_1.trackEmulator)("command_success", {
command_name: this.name,
duration,
}),
]));
}
process.exit();
})
.catch(async (err) => {
if ((0, utils_1.getInheritedOption)(options, "json")) {
await new Promise((resolve) => {
process.stdout.write(JSON.stringify({
status: "error",
error: err.message,
}, null, 2), resolve);
});
}
const duration = Math.floor((process.uptime() - start) * 1000);
await (0, utils_1.withTimeout)(5000, Promise.all([
(0, track_1.trackGA4)("command_execution", {
command_name: this.name,
result: "error",
interactive: (0, utils_1.getInheritedOption)(options, "nonInteractive") ? "false" : "true",
}, duration),
isEmulator
? (0, track_1.trackEmulator)("command_error", {
command_name: this.name,
duration,
error_type: err.exit === 1 ? "user" : "unexpected",
})
: Promise.resolve(),
]));
client.errorOut(err);
});
});
}
async prepare(options) {
options = options || {};
options.project = (0, utils_1.getInheritedOption)(options, "project");
if (!process.stdin.isTTY || (0, utils_1.getInheritedOption)(options, "nonInteractive")) {
options.nonInteractive = true;
}
if ((0, utils_1.getInheritedOption)(options, "interactive")) {
options.interactive = true;
options.nonInteractive = false;
}
if ((0, utils_1.getInheritedOption)(options, "debug")) {
options.debug = true;
}
if ((0, utils_1.getInheritedOption)(options, "json")) {
options.nonInteractive = true;
}
else {
(0, utils_1.setupLoggers)();
}
if ((0, utils_1.getInheritedOption)(options, "config")) {
options.configPath = (0, utils_1.getInheritedOption)(options, "config");
}
try {
options.config = config_1.Config.load(options);
}
catch (e) {
options.configError = e;
}
const account = (0, utils_1.getInheritedOption)(options, "account");
options.account = account;
options.projectRoot = (0, detectProjectRoot_1.detectProjectRoot)(options);
const projectRoot = options.projectRoot;
const activeAccount = (0, auth_1.selectAccount)(account, projectRoot);
if (activeAccount) {
(0, auth_1.setActiveAccount)(options, activeAccount);
}
this.applyRC(options);
if (options.project) {
await this.resolveProjectIdentifiers(options);
validateProjectId(options.projectId);
}
}
applyRC(options) {
var _a, _b;
const rc = (0, rc_1.loadRC)(options);
options.rc = rc;
const activeProject = options.projectRoot
? ((_a = configstore_1.configstore.get("activeProjects")) !== null && _a !== void 0 ? _a : {})[options.projectRoot]
: undefined;
options.project = (_b = options.project) !== null && _b !== void 0 ? _b : activeProject;
if (options.config && !options.project) {
options.project = options.config.defaults.project;
}
const aliases = rc.projects;
const rcProject = options.project ? aliases[options.project] : undefined;
if (rcProject) {
options.projectAlias = options.project;
options.project = rcProject;
}
else if (!options.project && (0, lodash_1.size)(aliases) === 1) {
options.projectAlias = (0, lodash_1.head)((0, lodash_1.keys)(aliases));
options.project = (0, lodash_1.head)((0, lodash_1.values)(aliases));
}
else if (!options.project && aliases["default"]) {
options.projectAlias = "default";
options.project = aliases["default"];
}
}
async resolveProjectIdentifiers(options) {
var _a;
if ((_a = options.project) === null || _a === void 0 ? void 0 : _a.match(/^\d+$/)) {
await (0, requireAuth_1.requireAuth)(options);
const { projectId, projectNumber } = await (0, projects_1.getProject)(options.project);
options.projectId = projectId;
options.projectNumber = projectNumber;
}
else {
options.projectId = options.project;
}
}
runner() {
return async (...args) => {
if (typeof (0, lodash_1.last)(args) !== "object" || (0, lodash_1.last)(args) === null) {
args.push({});
}
while (args.length < this.positionalArgs.length + 1) {
args.splice(args.length - 1, 0, "");
}
const options = (0, lodash_1.last)(args);
await this.prepare(options);
for (const before of this.befores) {
await before.fn(options, ...before.args);
}
return this.actionFn(...args);
};
}
}
exports.Command = Command;
const PROJECT_ID_REGEX = /^(?:[^:]+:)?[a-z0-9-]+$/;
function validateProjectId(project) {
if (PROJECT_ID_REGEX.test(project)) {
return;
}
(0, track_1.trackGA4)("error", {
error_type: "Error (User)",
details: "Invalid project ID",
});
const invalidMessage = "Invalid project id: " + clc.bold(project) + ".";
if (project.toLowerCase() !== project) {
throw new error_1.FirebaseError(invalidMessage + "\nNote: Project id must be all lowercase.");
}
else {
throw new error_1.FirebaseError(invalidMessage);
}
}
exports.validateProjectId = validateProjectId;