import { listTransactions as consoleListTransactions } from "@olenbetong/appframe-updater";
import chalk from "chalk";
import { Option } from "commander";
import { rollups } from "d3";
import inquirer from "inquirer";

import { Command } from "./lib/Command.js";
import { getServerFromOptions } from "./lib/getServerFromOptions.js";
import { importJson } from "./lib/importJson.js";
import { Server } from "./lib/Server.js";

const appPkg = await importJson("../package.json");
const isInteractive = process.stdin.isTTY;

async function getType(options: { type?: "apply" | "deploy" }) {
	if (options.type) return options.type;

	if (isInteractive) {
		let result = await inquirer.prompt({
			type: "select",
			name: "type",
			message: "Which type of transactions do you want to list?",
			choices: [
				{ name: "Transactions that will be applied", value: "apply" },
				{
					name: "Transactions that will be deployed",
					value: "deploy",
				},
			],
		});

		options.type = result.type;
	}
}

async function listTransactions(
	namespaceArg: string,
	options: { server: string; type: "apply" | "deploy"; group: boolean },
) {
	await getServerFromOptions(options);
	await getType(options);
	let server = new Server(options.server);

	let namespace = await server.getNamespaceArgument(namespaceArg, options);
	let transactions = await server.getTransactions(options.type, namespace);

	if (transactions.length === 0) {
		console.log(chalk.yellow("No transactions found."));
	} else if (options.group) {
		let byNamespace = rollups(
			transactions,
			(t: any) => t.length,
			(t: any) => t.Namespace,
		)
			.map((t: any) => ({ Namespace: t[0], "Transaction count": t[1] }))
			.sort((a: any, z: any) => z["Transaction count"] - a["Transaction count"]);

		console.table(byNamespace);
	} else {
		consoleListTransactions(transactions);
	}
}

let typeOption = new Option("-t, --type <type>", "Type of transactions to list");

if (!isInteractive) {
	typeOption.default("apply");
}

let program = new Command();
program
	.version(appPkg.version)
	.addNamespaceArgument()
	.addServerOption()
	.addOption(typeOption)
	.option("-g, --group", "List only number of transactions per namespace")
	.action(listTransactions);

await program.parseAsync(process.argv);