/**
 * Pure decision helpers for Fleet Dashboard destructive actions and live views.
 * Kept free of pi imports so black-box tests can exercise operator outcomes
 * without booting the full agent-hub extension.
 */
import type { FleetKind } from "./fleet-read-model.ts";
import type { createPanelResources } from "./fleet-panel.ts";

export type KillHandles = {
	proc?: unknown;
	comsAbort?: (() => void) | null;
};

export type KillOutcome =
	| { action: "kill-research"; message: string }
	| { action: "kill-proc"; message: string }
	| { action: "coms-abort"; message: string }
	| { action: "unsupported"; level: "warning"; message: string };

export type RestartOutcome =
	| { action: "restart-research"; message: string }
	| { action: "restart-specialist"; message: string }
	| { action: "unsupported"; level: "warning"; message: string };

/** Resolve a confirmed `x` kill for the highlighted row kind. */
export function resolveFleetKill(
	selected: { key: string; kind: FleetKind; name: string; status: "idle" | "running" | "done" | "error" | "pending" | "stale" },
	lookup: {
		researchExists: (key: string) => boolean;
		agentHandles: (key: string) => KillHandles | undefined;
	},
): KillOutcome {
	if (selected.kind === "research") {
		if (!lookup.researchExists(selected.key)) {
			return { action: "unsupported", level: "warning", message: `Research ${selected.name} is no longer available.` };
		}
		return { action: "kill-research", message: `Killed research ${selected.name}.` };
	}
	const agent = lookup.agentHandles(selected.key);
	if (agent?.proc) {
		return { action: "kill-proc", message: `Killing ${selected.name}...` };
	}
	if (agent?.comsAbort) {
		return { action: "coms-abort", message: `Abandoning ${selected.name}'s coms dispatch (the peer pane keeps running)...` };
	}
	if (selected.kind === "specialist" && selected.status !== "running") {
		return {
			action: "unsupported",
			level: "warning",
			message: `${selected.name} is ${selected.status === "done" ? "already finished" : `not running (${selected.status})`}; no live process or abort handle is available.`,
		};
	}
	return {
		action: "unsupported",
		level: "warning",
		message: `Kill is unsupported for ${selected.kind} rows; no owned process or abort handle is available.`,
	};
}

/** Resolve a confirmed `r` restart for the highlighted row kind. */
export function resolveFleetRestart(
	selected: { key: string; kind: FleetKind; name: string },
	lookup: {
		researchRestartable: (key: string) => boolean;
		specialistRestartable: (key: string) => boolean;
	},
): RestartOutcome {
	if (selected.kind === "peer" || selected.kind === "delegate") {
		return {
			action: "unsupported",
			level: "warning",
			message: `Restart is unsupported for ${selected.kind} rows; restart it from its owning session.`,
		};
	}
	if (selected.kind === "research") {
		if (!lookup.researchRestartable(selected.key)) {
			return {
				action: "unsupported",
				level: "warning",
				message: `Research ${selected.name} cannot be restarted while running or without a previous task.`,
			};
		}
		return { action: "restart-research", message: `Restarting research ${selected.name} (fresh)...` };
	}
	if (!lookup.specialistRestartable(selected.key)) {
		return {
			action: "unsupported",
			level: "warning",
			message: `${selected.name} has no previous task to restart.`,
		};
	}
	return { action: "restart-specialist", message: `Restarting ${selected.name} (fresh)...` };
}

/**
 * Always read the live timeline array from the target. Capturing the array at
 * open time freezes the detail view across re-dispatch (`state.timeline = []`).
 */
export function liveTimeline<T>(target: { timeline?: readonly T[] } | null | undefined): readonly T[] {
	return target?.timeline ?? [];
}

/** Compact below-editor / research-card widgets render only in compact mode. */
export function compactWidgetsEnabled(viewMode: "compact" | "off"): boolean {
	return viewMode === "compact";
}

type PanelResources = ReturnType<typeof createPanelResources>;

/** Register the 1s elapsed/status ticker and return a disposer that tears it down. */
export function attachFleetDashboardTicker(
	resources: PanelResources,
	requestRender: () => void,
	intervalMs = 1000,
): () => void {
	resources.every(intervalMs, requestRender);
	return () => resources.dispose();
}