var __create = Object.create; var __defProp = Object.defineProperty; var __defProps = Object.defineProperties; var __getOwnPropDesc = Object.getOwnPropertyDescriptor; var __getOwnPropDescs = Object.getOwnPropertyDescriptors; var __getOwnPropNames = Object.getOwnPropertyNames; var __getOwnPropSymbols = Object.getOwnPropertySymbols; var __getProtoOf = Object.getPrototypeOf; var __hasOwnProp = Object.prototype.hasOwnProperty; var __propIsEnum = Object.prototype.propertyIsEnumerable; var __defNormalProp = (obj, key, value) => key in obj ? __defProp(obj, key, { enumerable: true, configurable: true, writable: true, value }) : obj[key] = value; var __spreadValues = (a, b) => { for (var prop in b || (b = {})) if (__hasOwnProp.call(b, prop)) __defNormalProp(a, prop, b[prop]); if (__getOwnPropSymbols) for (var prop of __getOwnPropSymbols(b)) { if (__propIsEnum.call(b, prop)) __defNormalProp(a, prop, b[prop]); } return a; }; var __spreadProps = (a, b) => __defProps(a, __getOwnPropDescs(b)); var __markAsModule = (target) => __defProp(target, "__esModule", { value: true }); var __export = (target, all) => { for (var name in all) __defProp(target, name, { get: all[name], enumerable: true }); }; var __reExport = (target, module2, copyDefault, desc) => { if (module2 && typeof module2 === "object" || typeof module2 === "function") { for (let key of __getOwnPropNames(module2)) if (!__hasOwnProp.call(target, key) && (copyDefault || key !== "default")) __defProp(target, key, { get: () => module2[key], enumerable: !(desc = __getOwnPropDesc(module2, key)) || desc.enumerable }); } return target; }; var __toESM = (module2, isNodeMode) => { return __reExport(__markAsModule(__defProp(module2 != null ? __create(__getProtoOf(module2)) : {}, "default", !isNodeMode && module2 && module2.__esModule ? { get: () => module2.default, enumerable: true } : { value: module2, enumerable: true })), module2); }; var __toCommonJS = /* @__PURE__ */ ((cache) => { return (module2, temp) => { return cache && cache.get(module2) || (temp = __reExport(__markAsModule({}), module2, 1), cache && cache.set(module2, temp), temp); }; })(typeof WeakMap !== "undefined" ? /* @__PURE__ */ new WeakMap() : 0); // src/index.ts var src_exports = {}; __export(src_exports, { Listr: () => Listr, ListrError: () => ListrError, ListrErrorTypes: () => ListrErrorTypes, ListrEventType: () => ListrEventType, ListrTaskState: () => ListrTaskState, LogLevels: () => LogLevels, Logger: () => Logger, Manager: () => Manager, PromptError: () => PromptError, createPrompt: () => createPrompt, destroyPrompt: () => destroyPrompt, figures: () => figures }); // src/listr.ts var import_p_map = __toESM(require("p-map"), 1); var import_rxjs2 = require("rxjs"); // src/constants/state.constants.ts var ListrTaskState = /* @__PURE__ */ ((ListrTaskState2) => { ListrTaskState2["PENDING"] = "PENDING"; ListrTaskState2["COMPLETED"] = "COMPLETED"; ListrTaskState2["FAILED"] = "FAILED"; ListrTaskState2["SKIPPED"] = "SKIPPED"; ListrTaskState2["ROLLING_BACK"] = "ROLLING_BACK"; ListrTaskState2["ROLLED_BACK"] = "ROLLED_BACK"; ListrTaskState2["RETRY"] = "RETRY"; return ListrTaskState2; })(ListrTaskState || {}); // src/lib/task.ts var import_rxjs = require("rxjs"); var import_stream = require("stream"); // src/constants/event.constants.ts var ListrEventType = /* @__PURE__ */ ((ListrEventType2) => { ListrEventType2["TITLE"] = "TITLE"; ListrEventType2["STATE"] = "STATE"; ListrEventType2["ENABLED"] = "ENABLED"; ListrEventType2["SUBTASK"] = "SUBTASK"; ListrEventType2["DATA"] = "DATA"; ListrEventType2["MESSAGE"] = "MESSAGE"; return ListrEventType2; })(ListrEventType || {}); // src/utils/general.ts var import_rfdc = __toESM(require("rfdc"), 1); var clone = (0, import_rfdc.default)({ circles: true }); function cloneObject(obj) { return clone(obj); } // src/interfaces/listr-error.interface.ts var ListrError = class extends Error { constructor(error, type, task) { super(error.message); this.error = error; this.type = type; this.task = task; var _a2; this.name = "ListrError"; this.path = [...(_a2 = task.listr.path) != null ? _a2 : [], task.title].join(" > "); if ((task == null ? void 0 : task.options.collectErrors) === "full") { this.task = cloneObject(task); this.ctx = cloneObject(task.listr.ctx); } this.stack = error == null ? void 0 : error.stack; } }; var ListrErrorTypes = /* @__PURE__ */ ((ListrErrorTypes2) => { ListrErrorTypes2["WILL_RETRY"] = "WILL_RETRY"; ListrErrorTypes2["WILL_ROLLBACK"] = "WILL_ROLLBACK"; ListrErrorTypes2["HAS_FAILED_TO_ROLLBACK"] = "HAS_FAILED_TO_ROLLBACK"; ListrErrorTypes2["HAS_FAILED"] = "HAS_FAILED"; ListrErrorTypes2["HAS_FAILED_WITHOUT_ERROR"] = "HAS_FAILED_WITHOUT_ERROR"; return ListrErrorTypes2; })(ListrErrorTypes || {}); var PromptError = class extends Error { constructor(message) { super(message); this.name = "PromptError"; } }; // src/utils/assert.ts function assertFunctionOrSelf(functionOrSelf, ...args) { if (typeof functionOrSelf === "function") { return functionOrSelf(...args); } else { return functionOrSelf; } } // src/renderer/default.renderer.ts var import_cli_truncate = __toESM(require("cli-truncate"), 1); var import_log_update = __toESM(require("log-update"), 1); var import_os = require("os"); var import_wrap_ansi = __toESM(require("wrap-ansi"), 1); // src/utils/colorette.ts var import_colorette = require("colorette"); var _a; var colorette_default = (0, import_colorette.createColors)({ useColor: ((_a = process.env) == null ? void 0 : _a.LISTR_DISABLE_COLOR) !== "1" }); // src/utils/is-unicode-supported.ts function isUnicodeSupported() { if (process.platform !== "win32") { return true; } return Boolean(process.env.CI) || Boolean(process.env.WT_SESSION) || process.env.TERM_PROGRAM === "vscode" || process.env.TERM === "xterm-256color" || process.env.TERM === "alacritty"; } // src/utils/figures.ts var FIGURES_MAIN = { warning: "\u26A0", cross: "\u2716", arrowDown: "\u2193", tick: "\u2714", arrowRight: "\u2192", pointer: "\u276F", checkboxOn: "\u2612", arrowLeft: "\u2190", squareSmallFilled: "\u25FC", pointerSmall: "\u203A" }; var FIGURES_FALLBACK = __spreadProps(__spreadValues({}, FIGURES_MAIN), { warning: "\u203C", cross: "\xD7", tick: "\u221A", pointer: ">", checkboxOn: "[\xD7]", squareSmallFilled: "\u25A0" }); var figures = isUnicodeSupported() ? FIGURES_MAIN : FIGURES_FALLBACK; // src/utils/indent-string.ts function indentString(string, count) { return string.replace(/^(?!\s*$)/gm, " ".repeat(count)); } // src/utils/parse-time.ts function parseTaskTime(duration) { const seconds = Math.floor(duration / 1e3); const minutes = Math.floor(seconds / 60); let parsedTime; if (seconds === 0 && minutes === 0) { parsedTime = `0.${Math.floor(duration / 100)}s`; } if (seconds > 0) { parsedTime = `${seconds % 60}s`; } if (minutes > 0) { parsedTime = `${minutes}m${parsedTime}`; } return parsedTime; } // src/renderer/default.renderer.ts var _DefaultRenderer = class { constructor(tasks, options, renderHook$) { this.tasks = tasks; this.options = options; this.renderHook$ = renderHook$; this.bottomBar = {}; this.spinner = !isUnicodeSupported() ? ["-", "\\", "|", "/"] : ["\u280B", "\u2819", "\u2839", "\u2838", "\u283C", "\u2834", "\u2826", "\u2827", "\u2807", "\u280F"]; this.spinnerPosition = 0; this.options = __spreadValues(__spreadValues({}, _DefaultRenderer.rendererOptions), this.options); } getTaskOptions(task) { return __spreadValues(__spreadValues({}, _DefaultRenderer.rendererTaskOptions), task.rendererTaskOptions); } isBottomBar(task) { const bottomBar = this.getTaskOptions(task).bottomBar; return typeof bottomBar === "number" && bottomBar !== 0 || typeof bottomBar === "boolean" && bottomBar !== false; } hasPersistentOutput(task) { return this.getTaskOptions(task).persistentOutput === true; } hasTimer(task) { return this.getTaskOptions(task).showTimer === true; } getSelfOrParentOption(task, key) { var _a2, _b, _c; return (_c = (_a2 = task == null ? void 0 : task.rendererOptions) == null ? void 0 : _a2[key]) != null ? _c : (_b = this.options) == null ? void 0 : _b[key]; } getTaskTime(task) { return colorette_default.dim(`[${parseTaskTime(task.message.duration)}]`); } createRender(options) { options = __spreadValues(__spreadValues({}, { tasks: true, bottomBar: true, prompt: true }), options); const render = []; const renderTasks = this.multiLineRenderer(this.tasks); const renderBottomBar = this.renderBottomBar(); const renderPrompt = this.renderPrompt(); if (options.tasks && (renderTasks == null ? void 0 : renderTasks.trim().length) > 0) { render.push(renderTasks); } if (options.bottomBar && (renderBottomBar == null ? void 0 : renderBottomBar.trim().length) > 0) { render.push((render.length > 0 ? import_os.EOL : "") + renderBottomBar); } if (options.prompt && (renderPrompt == null ? void 0 : renderPrompt.trim().length) > 0) { render.push((render.length > 0 ? import_os.EOL : "") + renderPrompt); } return render.length > 0 ? render.join(import_os.EOL) : ""; } render() { var _a2; if (this.id) { return; } const updateRender = () => (0, import_log_update.default)(this.createRender()); if (!((_a2 = this.options) == null ? void 0 : _a2.lazy)) { this.id = setInterval(() => { this.spinnerPosition = ++this.spinnerPosition % this.spinner.length; updateRender(); }, 100); } this.renderHook$.subscribe(() => { updateRender(); }); } end() { clearInterval(this.id); if (this.id) { this.id = void 0; } import_log_update.default.clear(); import_log_update.default.done(); if (!this.options.clearOutput) { process.stdout.write(this.createRender({ prompt: false }) + import_os.EOL); } } multiLineRenderer(tasks, level = 0) { var _a2, _b; let output = []; for (const task of tasks) { if (task.isEnabled()) { if (task.hasTitle()) { if (!(tasks.some((task2) => task2.hasFailed()) && !task.hasFailed() && task.options.exitOnError !== false && !(task.isCompleted() || task.isSkipped()))) { if (task.hasFailed() && this.getSelfOrParentOption(task, "collapseErrors")) { output = [ ...output, this.formatString(!task.hasSubtasks() && task.message.error && this.getSelfOrParentOption(task, "showErrorMessage") ? task.message.error : task.title, this.getSymbol(task), level) ]; } else if (task.isSkipped() && this.getSelfOrParentOption(task, "collapseSkips")) { output = [ ...output, this.formatString(this.addSuffixToMessage(task.message.skip && this.getSelfOrParentOption(task, "showSkipMessage") ? task.message.skip : task.title, "SKIPPED", this.getSelfOrParentOption(task, "suffixSkips")), this.getSymbol(task), level) ]; } else if (task.isRetrying() && this.getSelfOrParentOption(task, "suffixRetries")) { output = [...output, this.formatString(this.addSuffixToMessage(task.title, `RETRYING-${task.message.retry.count}`), this.getSymbol(task), level)]; } else if (task.isCompleted() && task.hasTitle() && (this.getSelfOrParentOption(task, "showTimer") || this.hasTimer(task))) { output = [...output, this.formatString(`${task == null ? void 0 : task.title} ${this.getTaskTime(task)}`, this.getSymbol(task), level)]; } else { output = [...output, this.formatString(task.title, this.getSymbol(task), level)]; } } else { output = [...output, this.formatString(task.title, colorette_default.red(figures.squareSmallFilled), level)]; } } if (!task.hasSubtasks() || !this.getSelfOrParentOption(task, "showSubtasks")) { if (task.hasFailed() && this.getSelfOrParentOption(task, "collapseErrors") === false && (this.getSelfOrParentOption(task, "showErrorMessage") || !this.getSelfOrParentOption(task, "showSubtasks"))) { output = [...output, this.dumpData(task, level, "error")]; } else if (task.isSkipped() && this.getSelfOrParentOption(task, "collapseSkips") === false && (this.getSelfOrParentOption(task, "showSkipMessage") || !this.getSelfOrParentOption(task, "showSubtasks"))) { output = [...output, this.dumpData(task, level, "skip")]; } } if (task == null ? void 0 : task.output) { if ((task.isPending() || task.isRetrying() || task.isRollingBack()) && task.isPrompt()) { this.promptBar = task.output; } else if (this.isBottomBar(task) || !task.hasTitle()) { const data = [this.dumpData(task, -1)]; if (!this.bottomBar[task.id]) { this.bottomBar[task.id] = {}; this.bottomBar[task.id].data = []; const bottomBar = this.getTaskOptions(task).bottomBar; if (typeof bottomBar === "boolean") { this.bottomBar[task.id].items = 1; } else { this.bottomBar[task.id].items = bottomBar; } } if (!((_b = (_a2 = this.bottomBar[task.id]) == null ? void 0 : _a2.data) == null ? void 0 : _b.some((element) => data.includes(element))) && !task.isSkipped()) { this.bottomBar[task.id].data = [...this.bottomBar[task.id].data, ...data]; } } else if (task.isPending() || task.isRetrying() || task.isRollingBack() || this.hasPersistentOutput(task)) { output = [...output, this.dumpData(task, level)]; } } if (this.getSelfOrParentOption(task, "showSubtasks") !== false && task.hasSubtasks() && (task.isPending() || task.hasFailed() || task.isCompleted() && !task.hasTitle() || task.isCompleted() && this.getSelfOrParentOption(task, "collapse") === false && !task.subtasks.some((subtask) => subtask.rendererOptions.collapse === true) || task.subtasks.some((subtask) => subtask.rendererOptions.collapse === false) || task.subtasks.some((subtask) => subtask.hasFailed()) || task.subtasks.some((subtask) => subtask.hasRolledBack()))) { const subtaskLevel = !task.hasTitle() ? level : level + 1; const subtaskRender = this.multiLineRenderer(task.subtasks, subtaskLevel); if ((subtaskRender == null ? void 0 : subtaskRender.trim()) !== "" && !task.subtasks.every((subtask) => !subtask.hasTitle())) { output = [...output, subtaskRender]; } } if (task.isCompleted() || task.hasFailed() || task.isSkipped() || task.hasRolledBack()) { this.promptBar = null; if (!this.hasPersistentOutput(task)) { delete this.bottomBar[task.id]; } } } } output = output.filter(Boolean); if (output.length > 0) { return output.join(import_os.EOL); } else { return; } } renderBottomBar() { if (Object.keys(this.bottomBar).length > 0) { this.bottomBar = Object.keys(this.bottomBar).reduce((o, key) => { if (!(o == null ? void 0 : o[key])) { o[key] = {}; } o[key] = this.bottomBar[key]; this.bottomBar[key].data = this.bottomBar[key].data.slice(-this.bottomBar[key].items); o[key].data = this.bottomBar[key].data; return o; }, {}); return Object.values(this.bottomBar).reduce((o, value) => o = [...o, ...value.data], []).filter(Boolean).join(import_os.EOL); } } renderPrompt() { if (this.promptBar) { return this.promptBar; } } dumpData(task, level, source = "output") { let data; switch (source) { case "output": data = task.output; break; case "skip": data = task.message.skip; break; case "error": data = task.message.error; break; } if (task.hasTitle() && source === "error" && data === task.title) { return; } if (typeof data === "string") { return this.formatString(data, this.getSymbol(task, true), level + 1); } } formatString(str, icon, level) { if (str.trim() === "") { return; } str = `${icon} ${str}`; let parsedStr; let columns = process.stdout.columns ? process.stdout.columns : 80; columns = columns - level * this.options.indentation - 2; switch (this.options.formatOutput) { case "truncate": parsedStr = str.split(import_os.EOL).map((s, i) => { return (0, import_cli_truncate.default)(this.indentMultilineOutput(s, i), columns); }); break; case "wrap": parsedStr = (0, import_wrap_ansi.default)(str, columns, { hard: true }).split(import_os.EOL).map((s, i) => this.indentMultilineOutput(s, i)); break; default: throw new Error("Format option for the renderer is wrong."); } if (this.options.removeEmptyLines) { parsedStr = parsedStr.filter(Boolean); } return indentString(parsedStr.join(import_os.EOL), level * this.options.indentation); } indentMultilineOutput(str, i) { return i > 0 ? indentString(str.trim(), 2) : str.trim(); } getSymbol(task, data = false) { var _a2, _b, _c; if (task.isPending() && !data) { return ((_a2 = this.options) == null ? void 0 : _a2.lazy) || this.getSelfOrParentOption(task, "showSubtasks") !== false && task.hasSubtasks() && !task.subtasks.every((subtask) => !subtask.hasTitle()) ? colorette_default.yellow(figures.pointer) : colorette_default.yellowBright(this.spinner[this.spinnerPosition]); } else if (task.isCompleted() && !data) { return task.hasSubtasks() && task.subtasks.some((subtask) => subtask.hasFailed()) ? colorette_default.yellow(figures.warning) : colorette_default.green(figures.tick); } else if (task.isRetrying() && !data) { return ((_b = this.options) == null ? void 0 : _b.lazy) ? colorette_default.yellow(figures.warning) : colorette_default.yellow(this.spinner[this.spinnerPosition]); } else if (task.isRollingBack() && !data) { return ((_c = this.options) == null ? void 0 : _c.lazy) ? colorette_default.red(figures.warning) : colorette_default.red(this.spinner[this.spinnerPosition]); } else if (task.hasRolledBack() && !data) { return colorette_default.red(figures.arrowLeft); } else if (task.hasFailed() && !data) { return task.hasSubtasks() ? colorette_default.red(figures.pointer) : colorette_default.red(figures.cross); } else if (task.isSkipped() && !data && this.getSelfOrParentOption(task, "collapseSkips") === false) { return colorette_default.yellow(figures.warning); } else if (task.isSkipped() && (data || this.getSelfOrParentOption(task, "collapseSkips"))) { return colorette_default.yellow(figures.arrowDown); } return !data ? colorette_default.dim(figures.squareSmallFilled) : figures.pointerSmall; } addSuffixToMessage(message, suffix, condition) { return (condition != null ? condition : true) ? message + colorette_default.dim(` [${suffix}]`) : message; } }; var DefaultRenderer = _DefaultRenderer; DefaultRenderer.nonTTY = false; DefaultRenderer.rendererOptions = { indentation: 2, clearOutput: false, showSubtasks: true, collapse: true, collapseSkips: true, showSkipMessage: true, suffixSkips: true, collapseErrors: true, showErrorMessage: true, suffixRetries: true, lazy: false, showTimer: false, removeEmptyLines: true, formatOutput: "truncate" }; // src/renderer/silent.renderer.ts var SilentRenderer = class { constructor(tasks, options) { this.tasks = tasks; this.options = options; } render() { } end() { } }; SilentRenderer.nonTTY = true; // src/renderer/simple.renderer.ts var import_log_update2 = require("log-update"); var import_os2 = require("os"); var _SimpleRenderer = class { constructor(tasks, options) { this.tasks = tasks; this.options = options; this.eventTypeRendererMap = { ["SUBTASK" /* SUBTASK */]: (task) => { if (task.hasTitle()) { this.log(`${colorette_default.blue(figures.pointer)} ${task.title}`); } if (task.hasSubtasks()) { this.render(task.subtasks); } }, ["STATE" /* STATE */]: (task) => { if (task.isCompleted() && task.hasTitle()) { this.log(`${colorette_default.green(figures.tick)} ${task.title}`); } }, ["DATA" /* DATA */]: (task, event) => { if (task.isPrompt() && !String(event.data).match(/^\n$/)) { (0, import_log_update2.stderr)(`${event.data}`); } else { this.log(`${figures.pointerSmall} ${event.data}`); } }, ["MESSAGE" /* MESSAGE */]: (task, event) => { if (event.data.error) { const title = _SimpleRenderer.formatTitle(task); this.log(`${colorette_default.red(figures.cross)}${title}: ${event.data.error}`); } else if (event.data.skip) { const title = _SimpleRenderer.formatTitle(task); const skip = task.title !== event.data.skip ? `: ${event.data.skip}` : ""; this.log(`${colorette_default.yellow(figures.arrowDown)}${title} [${colorette_default.yellow(`skipped${skip}`)}]`); } else if (event.data.rollback) { const title = _SimpleRenderer.formatTitle(task); this.log(`${colorette_default.red(figures.arrowLeft)}${title}: ${event.data.rollback}`); } else if (event.data.retry) { const title = _SimpleRenderer.formatTitle(task); this.log(`[${colorette_default.yellow(`${event.data.retry.count}`)}]${title}`); } } }; this.options = __spreadValues(__spreadValues({}, _SimpleRenderer.rendererOptions), options); } static now() { return new Date(); } static formatTitle(task) { return (task == null ? void 0 : task.title) ? ` ${task.title}` : ""; } log(output) { const logOut = (msg) => { process[this.options.output].write(msg.endsWith(import_os2.EOL) ? msg : `${msg}${import_os2.EOL}`); }; if (!this.options.prefixWithTimestamp) { logOut(`${output}`); return; } const now = _SimpleRenderer.now(); const timestamp = String(now.getHours()).padStart(2, "0") + ":" + String(now.getMinutes()).padStart(2, "0") + ":" + String(now.getSeconds()).padStart(2, "0"); logOut(`${colorette_default.dim(`[${timestamp}]`)} ${output}`); } end() { } render(tasks) { if (tasks == null ? void 0 : tasks.length) { tasks.forEach((task) => { task.subscribe((event) => { var _a2, _b; (_b = (_a2 = this.eventTypeRendererMap)[event.type]) == null ? void 0 : _b.call(_a2, task, event); }, this.log); }); } else { this.render(this.tasks); } } }; var SimpleRenderer = _SimpleRenderer; SimpleRenderer.nonTTY = true; SimpleRenderer.rendererOptions = { prefixWithTimestamp: false, output: "stdout" }; // src/utils/logger.constants.ts var LogLevels = /* @__PURE__ */ ((LogLevels2) => { LogLevels2["SILENT"] = "SILENT"; LogLevels2["FAILED"] = "FAILED"; LogLevels2["SKIPPED"] = "SKIPPED"; LogLevels2["SUCCESS"] = "SUCCESS"; LogLevels2["DATA"] = "DATA"; LogLevels2["STARTED"] = "STARTED"; LogLevels2["TITLE"] = "TITLE"; LogLevels2["RETRY"] = "RETRY"; LogLevels2["ROLLBACK"] = "ROLLBACK"; return LogLevels2; })(LogLevels || {}); // src/utils/logger.ts var Logger = class { constructor(options) { this.options = options; } fail(message) { message = this.parseMessage("FAILED" /* FAILED */, message); console.error(message); } skip(message) { message = this.parseMessage("SKIPPED" /* SKIPPED */, message); console.info(message); } success(message) { message = this.parseMessage("SUCCESS" /* SUCCESS */, message); console.log(message); } data(message) { message = this.parseMessage("DATA" /* DATA */, message); console.info(message); } start(message) { message = this.parseMessage("STARTED" /* STARTED */, message); console.log(message); } title(message) { message = this.parseMessage("TITLE" /* TITLE */, message); console.info(message); } retry(message) { message = this.parseMessage("RETRY" /* RETRY */, message); console.warn(message); } rollback(message) { message = this.parseMessage("ROLLBACK" /* ROLLBACK */, message); console.warn(message); } parseMessage(level, message) { let multiLineMessage; try { multiLineMessage = message.split("\n"); } catch { multiLineMessage = [message]; } multiLineMessage = multiLineMessage.map((msg) => { return this.logColoring({ level, message: msg }); }); message = multiLineMessage.join("\n"); return message; } logColoring({ level, message }) { var _a2, _b, _c, _d, _e, _f, _g, _h; let icon; let coloring = (input) => { return input; }; switch (level) { case "FAILED" /* FAILED */: if ((_a2 = this.options) == null ? void 0 : _a2.useIcons) { coloring = colorette_default.red; icon = figures.cross; } else { icon = this.wrapInBrackets(level); } break; case "SKIPPED" /* SKIPPED */: if ((_b = this.options) == null ? void 0 : _b.useIcons) { coloring = colorette_default.yellow; icon = figures.arrowDown; } else { icon = this.wrapInBrackets(level); } break; case "SUCCESS" /* SUCCESS */: if ((_c = this.options) == null ? void 0 : _c.useIcons) { coloring = colorette_default.green; icon = figures.tick; } else { icon = this.wrapInBrackets(level); } break; case "DATA" /* DATA */: if ((_d = this.options) == null ? void 0 : _d.useIcons) { icon = figures.arrowRight; } else { icon = this.wrapInBrackets(level); } break; case "STARTED" /* STARTED */: if ((_e = this.options) == null ? void 0 : _e.useIcons) { icon = figures.pointer; } else { icon = this.wrapInBrackets(level); } break; case "TITLE" /* TITLE */: if ((_f = this.options) == null ? void 0 : _f.useIcons) { icon = figures.checkboxOn; } else { icon = this.wrapInBrackets(level); } break; case "RETRY" /* RETRY */: if ((_g = this.options) == null ? void 0 : _g.useIcons) { coloring = colorette_default.yellow; icon = figures.pointer; } else { icon = this.wrapInBrackets(level); } break; case "ROLLBACK" /* ROLLBACK */: if ((_h = this.options) == null ? void 0 : _h.useIcons) { coloring = colorette_default.red; icon = figures.arrowLeft; } else { icon = this.wrapInBrackets(level); } break; } return coloring(`${icon} ${message}`); } wrapInBrackets(level) { return `[${level}]`; } }; // src/renderer/verbose.renderer.ts var _VerboseRenderer = class { constructor(tasks, options) { this.tasks = tasks; this.options = options; var _a2, _b, _c, _d; if (((_a2 = this.options) == null ? void 0 : _a2.logger) && ((_b = this.options) == null ? void 0 : _b.options)) { this.logger = new this.options.logger(this.options.options); } else if ((_c = this.options) == null ? void 0 : _c.logger) { this.logger = new this.options.logger(); } else { this.logger = new Logger({ useIcons: (_d = this.options) == null ? void 0 : _d.useIcons }); } this.options = __spreadValues(__spreadValues({}, _VerboseRenderer.rendererOptions), this.options); } render() { this.verboseRenderer(this.tasks); } end() { } verboseRenderer(tasks) { return tasks == null ? void 0 : tasks.forEach((task) => { task.subscribe((event) => { var _a2, _b, _c, _d, _e, _f, _g, _h; if (task.isEnabled()) { const taskTitle = task.hasTitle() ? task.title : "Task without title."; if (event.type === "SUBTASK" /* SUBTASK */ && task.hasSubtasks()) { this.verboseRenderer(task.subtasks); } else if (event.type === "STATE" /* STATE */) { if (((_a2 = this.options) == null ? void 0 : _a2.logEmptyTitle) !== false || task.hasTitle()) { if (task.isPending()) { this.logger.start(taskTitle); } else if (task.isCompleted()) { this.logger.success(taskTitle + (((_b = this.options) == null ? void 0 : _b.showTimer) && ((_c = task.message) == null ? void 0 : _c.duration) ? ` [${parseTaskTime(task.message.duration)}]` : "")); } } } else if (event.type === "DATA" /* DATA */ && !!event.data) { this.logger.data(String(event.data)); } else if (event.type === "TITLE" /* TITLE */) { if (((_d = this.options) == null ? void 0 : _d.logTitleChange) !== false) { this.logger.title(String(event.data)); } } else if (event.type === "MESSAGE" /* MESSAGE */) { if ((_e = event.data) == null ? void 0 : _e.error) { this.logger.fail(String(event.data.error)); } else if ((_f = event.data) == null ? void 0 : _f.skip) { this.logger.skip(String(event.data.skip)); } else if ((_g = event.data) == null ? void 0 : _g.rollback) { this.logger.rollback(String(event.data.rollback)); } else if ((_h = event.data) == null ? void 0 : _h.retry) { this.logger.retry(`[${event.data.retry.count}] ` + String(taskTitle)); } } } }, (err) => { this.logger.fail(err); }); }); } }; var VerboseRenderer = _VerboseRenderer; VerboseRenderer.nonTTY = true; VerboseRenderer.rendererOptions = { useIcons: false, logEmptyTitle: true, logTitleChange: true }; // src/utils/renderer.ts var renderers = { default: DefaultRenderer, simple: SimpleRenderer, verbose: VerboseRenderer, silent: SilentRenderer }; function isRendererSupported(renderer) { return process.stdout.isTTY === true || renderer.nonTTY === true; } function getRendererClass(renderer) { if (typeof renderer === "string") { return renderers[renderer] || renderers.default; } return typeof renderer === "function" ? renderer : renderers.default; } function getRenderer(renderer, fallbackRenderer, fallbackCondition, silentCondition) { let returnValue; let ret = getRendererClass(renderer); returnValue = { renderer: ret, nonTTY: false }; const evaluateSilent = assertFunctionOrSelf(silentCondition); const evaluateFallback = assertFunctionOrSelf(fallbackCondition); if (evaluateSilent) { ret = getRendererClass("silent"); returnValue = { renderer: ret, nonTTY: true }; } else if (!isRendererSupported(ret) || evaluateFallback) { ret = getRendererClass(fallbackRenderer); returnValue = { renderer: ret, nonTTY: true }; } return returnValue; } // src/utils/uuid.ts function generateUUID() { return "xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx".replace(/[xy]/g, (c) => { const r = Math.random() * 16 || 0; const v = c === "x" ? r : r && 3 || 8; return v.toString(16); }); } // src/lib/task.ts var Task = class extends import_rxjs.Subject { constructor(listr, tasks, options, rendererOptions) { super(); this.listr = listr; this.tasks = tasks; this.options = options; this.rendererOptions = rendererOptions; this.message = {}; var _a2, _b, _c, _d, _e, _f; this.id = generateUUID(); this.title = (_a2 = this.tasks) == null ? void 0 : _a2.title; this.initialTitle = (_b = this.tasks) == null ? void 0 : _b.title; this.task = this.tasks.task; this.skip = (_d = (_c = this.tasks) == null ? void 0 : _c.skip) != null ? _d : false; this.enabledFn = (_f = (_e = this.tasks) == null ? void 0 : _e.enabled) != null ? _f : true; this.rendererTaskOptions = this.tasks.options; this.renderHook$ = this.listr.renderHook$; this.subscribe(() => { this.renderHook$.next(); }); } set state$(state) { this.state = state; this.next({ type: "STATE" /* STATE */, data: state }); if (this.hasSubtasks() && this.hasFailed()) { for (const subtask of this.subtasks) { if (subtask.state === "PENDING" /* PENDING */) { subtask.state$ = "FAILED" /* FAILED */; } } } } set output$(data) { this.output = data; this.next({ type: "DATA" /* DATA */, data }); } set message$(data) { this.message = __spreadValues(__spreadValues({}, this.message), data); this.next({ type: "MESSAGE" /* MESSAGE */, data }); } set title$(title) { this.title = title; this.next({ type: "TITLE" /* TITLE */, data: title }); } async check(ctx) { if (this.state === void 0) { this.enabled = await assertFunctionOrSelf(this.enabledFn, ctx); this.next({ type: "ENABLED" /* ENABLED */, data: this.enabled }); } } hasSubtasks() { var _a2; return ((_a2 = this.subtasks) == null ? void 0 : _a2.length) > 0; } isPending() { return this.state === "PENDING" /* PENDING */; } isSkipped() { return this.state === "SKIPPED" /* SKIPPED */; } isCompleted() { return this.state === "COMPLETED" /* COMPLETED */; } hasFailed() { return this.state === "FAILED" /* FAILED */; } isRollingBack() { return this.state === "ROLLING_BACK" /* ROLLING_BACK */; } hasRolledBack() { return this.state === "ROLLED_BACK" /* ROLLED_BACK */; } isRetrying() { return this.state === "RETRY" /* RETRY */; } isEnabled() { return this.enabled; } hasTitle() { return typeof (this == null ? void 0 : this.title) === "string"; } isPrompt() { return !!this.prompt; } async run(context, wrapper) { var _a2, _b, _c, _d, _e; const handleResult = (result) => { if (result instanceof Listr) { result.options = __spreadValues(__spreadValues({}, this.options), result.options); result.rendererClass = getRenderer("silent").renderer; result.renderHook$.subscribe(() => { this.renderHook$.next(); }); this.subtasks = result.tasks; result.err = this.listr.err; this.next({ type: "SUBTASK" /* SUBTASK */ }); result = result.run(context); } else if (this.isPrompt()) { } else if (result instanceof Promise) { result = result.then(handleResult); } else if (result instanceof import_stream.Readable) { result = new Promise((resolve, reject) => { result.on("data", (data) => { this.output$ = data.toString(); }); result.on("error", (error) => reject(error)); result.on("end", () => resolve(null)); }); } else if (result instanceof import_rxjs.Observable) { result = new Promise((resolve, reject) => { result.subscribe({ next: (data) => { this.output$ = data; }, error: reject, complete: resolve }); }); } return result; }; const startTime = Date.now(); this.state$ = "PENDING" /* PENDING */; const skipped = await assertFunctionOrSelf(this.skip, context); if (skipped) { if (typeof skipped === "string") { this.message$ = { skip: skipped }; } else if (this.hasTitle()) { this.message$ = { skip: this.title }; } else { this.message$ = { skip: "Skipped task without a title." }; } this.state$ = "SKIPPED" /* SKIPPED */; return; } try { const retryCount = ((_a2 = this.tasks) == null ? void 0 : _a2.retry) && ((_b = this.tasks) == null ? void 0 : _b.retry) > 0 ? this.tasks.retry + 1 : 1; for (let retries = 1; retries <= retryCount; retries++) { try { await handleResult(this.task(context, wrapper)); break; } catch (err) { if (retries !== retryCount) { this.retry = { count: retries, withError: err }; this.message$ = { retry: this.retry }; this.title$ = this.initialTitle; this.output = void 0; wrapper.report(err, "WILL_RETRY" /* WILL_RETRY */); this.state$ = "RETRY" /* RETRY */; } else { throw err; } } } if (this.isPending() || this.isRetrying()) { this.message$ = { duration: Date.now() - startTime }; this.state$ = "COMPLETED" /* COMPLETED */; } } catch (error) { if (this.prompt instanceof PromptError) { error = new Error(this.prompt.message); } if ((_c = this.tasks) == null ? void 0 : _c.rollback) { wrapper.report(error, "WILL_ROLLBACK" /* WILL_ROLLBACK */); try { this.state$ = "ROLLING_BACK" /* ROLLING_BACK */; await this.tasks.rollback(context, wrapper); this.state$ = "ROLLED_BACK" /* ROLLED_BACK */; this.message$ = { rollback: this.title }; } catch (err) { this.state$ = "FAILED" /* FAILED */; wrapper.report(err, "HAS_FAILED_TO_ROLLBACK" /* HAS_FAILED_TO_ROLLBACK */); throw err; } if (((_d = this.listr.options) == null ? void 0 : _d.exitAfterRollback) !== false) { throw new Error(this.title); } } else { this.state$ = "FAILED" /* FAILED */; if (this.listr.options.exitOnError !== false && await assertFunctionOrSelf((_e = this.tasks) == null ? void 0 : _e.exitOnError, context) !== false) { wrapper.report(error, "HAS_FAILED" /* HAS_FAILED */); throw error; } else if (!this.hasSubtasks()) { wrapper.report(error, "HAS_FAILED_WITHOUT_ERROR" /* HAS_FAILED_WITHOUT_ERROR */); } } } finally { this.complete(); } } }; // src/lib/task-wrapper.ts var import_through = __toESM(require("through"), 1); // src/constants/clearline-regex.constants.ts var CLEAR_LINE_REGEX = "(?:\\u001b|\\u009b)\\[[\\=><~/#&.:=?%@~_-]*[0-9]*[\\a-ln-tqyz=><~/#&.:=?%@~_-]+"; var BELL_REGEX = /\u0007/; // src/utils/prompt.ts function defaultCancelCallback(settings) { const errorMsg = "Cancelled prompt."; if (this instanceof TaskWrapper) { this.task.prompt = new PromptError(errorMsg); } else if ((settings == null ? void 0 : settings.error) !== false) { throw new Error(errorMsg); } else { return errorMsg; } } async function createPrompt(options, settings) { let cancelCallback; if (settings == null ? void 0 : settings.cancelCallback) { cancelCallback = settings.cancelCallback; } else { cancelCallback = defaultCancelCallback; } if (!Array.isArray(options)) { options = [__spreadProps(__spreadValues({}, options), { name: "default" })]; } else if (options.length === 1) { options = options.reduce((o, option) => { return [...o, Object.assign(option, { name: "default" })]; }, []); } options = options.reduce((o, option) => { var _a2; return [ ...o, Object.assign(option, { stdout: this instanceof TaskWrapper ? (_a2 = settings == null ? void 0 : settings.stdout) != null ? _a2 : this.stdout() : process.stdout, onCancel: cancelCallback.bind(this, settings) }) ]; }, []); let enquirer; if (settings == null ? void 0 : settings.enquirer) { enquirer = settings.enquirer; } else { try { enquirer = new (await Promise.resolve().then(() => __toESM(require("enquirer"), 1))).default(); } catch (e) { this.task.prompt = new PromptError("Enquirer is a peer dependency that must be installed separately."); throw new Error(e); } } if (this instanceof TaskWrapper) { enquirer.on("prompt", (prompt) => this.task.prompt = prompt); enquirer.on("submit", () => this.task.prompt = void 0); this.task.subscribe((event) => { if (event.type === "STATE" /* STATE */ && event.data === "SKIPPED" /* SKIPPED */) { if (this.task.prompt && !(this.task.prompt instanceof PromptError)) { this.task.prompt.submit(); } } }); } const response = await enquirer.prompt(options); if (options.length === 1) { return response.default; } else { return response; } } function destroyPrompt(throwError = false) { if (!this.task.prompt || this.task.prompt instanceof PromptError) { return; } if (throwError) { this.task.prompt.cancel(); } else { this.task.prompt.submit(); } } // src/lib/task-wrapper.ts var TaskWrapper = class { constructor(task, errors, options) { this.task = task; this.errors = errors; this.options = options; } get title() { return this.task.title; } set title(data) { this.task.title$ = data; } get output() { return this.task.output; } set output(data) { this.task.output$ = data; } newListr(task, options) { let tasks; if (typeof task === "function") { tasks = task(this); } else { tasks = task; } return new Listr(tasks, options, this.task); } report(error, type) { var _a2, _b, _c; if (this.task.options.collectErrors !== false) { this.errors.push(new ListrError(error, type, this.task)); } this.task.message$ = { error: (_c = (_b = error.message) != null ? _b : (_a2 = this.task) == null ? void 0 : _a2.title) != null ? _c : "Task with no title." }; } skip(message) { var _a2, _b; this.task.state$ = "SKIPPED" /* SKIPPED */; if (message) { this.task.message$ = { skip: (_b = message != null ? message : (_a2 = this.task) == null ? void 0 : _a2.title) != null ? _b : "Task with no title." }; } } isRetrying() { return this.task.isRetrying() ? this.task.retry : { count: 0 }; } async prompt(options) { var _a2; return createPrompt.bind(this)(options, __spreadValues({}, (_a2 = this.options) == null ? void 0 : _a2.injectWrapper)); } cancelPrompt(throwError = false) { return destroyPrompt.bind(this)(throwError); } stdout() { return (0, import_through.default)((chunk) => { chunk = chunk.toString(); chunk = chunk.replace(new RegExp(CLEAR_LINE_REGEX, "gmi"), ""); chunk = chunk.replace(new RegExp(BELL_REGEX, "gmi"), ""); if (chunk !== "") { this.output = chunk; } }); } run(ctx) { return this.task.run(ctx, this); } }; // src/listr.ts var Listr = class { constructor(task, options, parentTask) { this.task = task; this.options = options; this.parentTask = parentTask; this.tasks = []; this.err = []; this.renderHook$ = new import_rxjs2.Subject(); this.path = []; var _a2, _b, _c; this.options = __spreadValues(__spreadValues({}, { concurrent: false, renderer: "default", nonTTYRenderer: "verbose", exitOnError: true, exitAfterRollback: true, collectErrors: "minimal", registerSignalListeners: true }), options); if (this.options.concurrent === true) { this.concurrency = Infinity; } else if (typeof this.options.concurrent === "number") { this.concurrency = this.options.concurrent; } else { this.concurrency = 1; } const renderer = getRenderer(this.options.renderer, this.options.nonTTYRenderer, (_a2 = this.options) == null ? void 0 : _a2.rendererFallback, (_b = this.options) == null ? void 0 : _b.rendererSilent); this.rendererClass = renderer.renderer; if (!renderer.nonTTY) { this.rendererClassOptions = this.options.rendererOptions; } else { this.rendererClassOptions = this.options.nonTTYRendererOptions; } this.add(task != null ? task : []); if (parentTask) { this.path = [...parentTask.listr.path, parentTask.title]; } if (this.options.registerSignalListeners) { process.once("SIGINT", () => { this.tasks.forEach(async (task2) => { if (task2.isPending()) { task2.state$ = "FAILED" /* FAILED */; } }); this.renderer.end(new Error("Interrupted.")); process.exit(127); }).setMaxListeners(0); } if ((_c = this.options) == null ? void 0 : _c.disableColor) { process.env.LISTR_DISABLE_COLOR = "1"; } } add(task) { const tasks = Array.isArray(task) ? task : [task]; tasks.forEach((task2) => { this.tasks.push(new Task(this, task2, this.options, __spreadValues(__spreadValues({}, this.rendererClassOptions), task2.options))); }); } async run(context) { var _a2, _b, _c; if (!this.renderer) { this.renderer = new this.rendererClass(this.tasks, this.rendererClassOptions, this.renderHook$); } this.renderer.render(); this.ctx = (_c = (_b = (_a2 = this.options) == null ? void 0 : _a2.ctx) != null ? _b : context) != null ? _c : {}; await this.checkAll(this.ctx); try { await (0, import_p_map.default)(this.tasks, async (task) => { await task.check(this.ctx); return this.runTask(task, this.ctx, this.err); }, { concurrency: this.concurrency }); this.renderer.end(); } catch (err) { if (this.options.exitOnError !== false) { this.renderer.end(err); throw err; } } return this.ctx; } checkAll(context) { return Promise.all(this.tasks.map((task) => task.check(context))); } runTask(task, context, errors) { if (!task.isEnabled()) { return Promise.resolve(); } return new TaskWrapper(task, errors, this.options).run(context); } }; // src/manager.ts var Manager = class { constructor(options) { this.options = options; this.err = []; this.tasks = []; } set ctx(ctx) { this.options.ctx = ctx; } add(tasks, options) { options = __spreadValues(__spreadValues({}, this.options), options); this.tasks = [...this.tasks, this.indent(tasks, options)]; } async runAll(options) { options = __spreadValues(__spreadValues({}, this.options), options); const ctx = await this.run(this.tasks, options); this.tasks = []; return ctx; } newListr(tasks, options) { return new Listr(tasks, options); } indent(tasks, options, taskOptions) { options = __spreadValues(__spreadValues({}, this.options), options); let newTask; if (typeof tasks === "function") { newTask = __spreadProps(__spreadValues({}, taskOptions), { task: (ctx) => this.newListr(tasks(ctx), options) }); } else { newTask = __spreadProps(__spreadValues({}, taskOptions), { task: () => this.newListr(tasks, options) }); } return newTask; } async run(tasks, options) { options = __spreadValues(__spreadValues({}, this.options), options); const task = this.newListr(tasks, options); const ctx = await task.run(); this.err = task.err; return ctx; } getRuntime(pipetime) { return `${Math.round(Date.now() - pipetime) / 1e3}s`; } }; module.exports = __toCommonJS(src_exports); // Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = { Listr, ListrError, ListrErrorTypes, ListrEventType, ListrTaskState, LogLevels, Logger, Manager, PromptError, createPrompt, destroyPrompt, figures });