/**
 * Configuration for the jobs extension.
 *
 * The `job` section of the shared `bytefly.json` (global then project, project
 * wins). Missing or malformed
 * documents are ignored, and every value is clamped to a safe range.
 */

import { clampInteger, cleanString, loadConfigSection } from "../../lib/config.ts";

export interface JobsConfig {
	/** Track jobs at all. Default: true. */
	enabled: boolean;
	/** Show the status chips while jobs run or a failure is unreported. */
	showStatus: boolean;
	/** Wake the agent with one triggered turn when any job finishes. */
	wakeOnFinish: boolean;
	/** Leave jobs running when the session ends unless a job opts out. */
	detachedByDefault: boolean;
	/** Finished jobs kept in the registry before the oldest are pruned. */
	maxJobs: number;
	/** Log lines returned to the model by the `logs` action. */
	maxLogLines: number;
	/** Bytes a log segment may reach before it rotates; 0 keeps logs unbounded. */
	maxLogBytes: number;
	/** Grace period before a SIGTERM escalates to SIGKILL. */
	killGraceMs: number;
	/** Status-chip refresh interval while jobs run. */
	repaintMs: number;
	/** How long a session heartbeat is trusted before its jobs are reaped. */
	sessionTtlMs: number;
	/** Override for the registry directory; defaults under the agent dir. */
	registryDir: string | undefined;
}

export const DEFAULT_CONFIG: JobsConfig = {
	enabled: true,
	showStatus: true,
	wakeOnFinish: false,
	detachedByDefault: false,
	maxJobs: 20,
	maxLogLines: 100,
	maxLogBytes: 8 * 1024 * 1024,
	killGraceMs: 5000,
	repaintMs: 1000,
	sessionTtlMs: 60_000,
	registryDir: undefined,
};

/** Normalize one merged config object over the running base. */
export function normalizeConfig(raw: Record<string, unknown> | undefined, base: JobsConfig): JobsConfig {
	if (!raw) return base;
	const registryDir = cleanString(raw.registryDir, "");
	return {
		enabled: typeof raw.enabled === "boolean" ? raw.enabled : base.enabled,
		showStatus: typeof raw.showStatus === "boolean" ? raw.showStatus : base.showStatus,
		wakeOnFinish: typeof raw.wakeOnFinish === "boolean" ? raw.wakeOnFinish : base.wakeOnFinish,
		detachedByDefault: typeof raw.detachedByDefault === "boolean" ? raw.detachedByDefault : base.detachedByDefault,
		maxJobs: clampInteger(raw.maxJobs, base.maxJobs, 1, 500),
		maxLogLines: clampInteger(raw.maxLogLines, base.maxLogLines, 1, 5000),
		maxLogBytes: clampInteger(raw.maxLogBytes, base.maxLogBytes, 0, 1024 * 1024 * 1024),
		killGraceMs: clampInteger(raw.killGraceMs, base.killGraceMs, 0, 60_000),
		repaintMs: clampInteger(raw.repaintMs, base.repaintMs, 100, 10_000),
		sessionTtlMs: clampInteger(raw.sessionTtlMs, base.sessionTtlMs, 5_000, 600_000),
		registryDir: registryDir || undefined,
	};
}

/** Load the effective config for a working directory. */
export function loadConfig(cwd: string): JobsConfig {
	return loadConfigSection(cwd, "job", DEFAULT_CONFIG, normalizeConfig);
}