/**
 * Reviewer Lane Invocation Module (ADR-2782 Phase 5b, #2799 — closes #2718).
 *
 * Turns a DECLARED lane (`review-lane-descriptor.cts`) plus resolved configuration into a concrete,
 * inspectable INVOCATION PLAN. Phase 1's module declares; this one resolves; `review-lane-runner`
 * executes. The split exists so the interesting half is pure: a plan is a value, so the twelve
 * shipped lanes can be asserted against a golden table without spawning anything.
 *
 * WHY A GOLDEN TABLE AND NOT A FRESH DESIGN (Gall's Law). The 640 lines of hand-authored bash this
 * replaces is the simple system that worked, and every leg encodes a hard-won fix — #2494 and #2605
 * (empty output), #1698 (Codex stdout teardown noise), #1936 (OpenCode zero-output turns), #2073
 * (Antigravity's three modes), #2176 (repo-root anchoring), #2589 (no jq on stock Windows), #2794
 * (Qwen's missing sidecar). A resolver designed from the descriptor TYPES would throw that away and
 * rebuild the bugs. So each lane's plan was derived from its leg, and `tests/review-lane-invocation`
 * asserts all twelve against a frozen table. Old and new cannot literally run in parallel, so that
 * table is the strangler-fig substitute — it is what makes this cutover safe rather than hopeful.
 *
 * PURE. No filesystem, no network, no subprocess, no clock. Configuration arrives through the
 * `configGet` seam so a test drives it with a plain object and production wires it to the real
 * resolved config. Every function here is total: a malformed lane yields an `unavailable` result,
 * never a throw — a resolver that throws on bad input cannot report on it, and this runs against
 * third-party overlay manifests (ADR-2782 D4).
 */

import type {
  EmptyOutputPolicy,
  LaneHandler,
  LaneProbe,
  ReviewerLane,
} from './review-lane-descriptor.cjs';
import { LANE_SLUG_RE } from './review-lane-descriptor.cjs';

/* ------------------------------------------------------------------ *
 * Unavailability — a frozen enum, because the reason is the product
 * ------------------------------------------------------------------ */

/**
 * Why a lane will not run.
 *
 * Frozen and exhaustive because the bash it replaces had exactly one outcome for every failure —
 * an empty file — and that ambiguity IS the defect class this epic exists to close (#2494/#2605: a
 * failed lane was indistinguishable from a reviewer that ran cleanly with nothing to report). The
 * caller renders these; tests assert on them. Never assert on the rendered prose.
 *
 * Adding a member is three coordinated changes: this enum, the emitting site, and the test locking
 * `Object.keys(...).sort()`.
 */
export const LANE_UNAVAILABLE = Object.freeze({
  MALFORMED_LANE: 'malformed_lane',
  UNKNOWN_HANDLER: 'unknown_handler',
  UNKNOWN_TRANSPORT: 'unknown_transport',
  MISSING_BINARY: 'missing_binary',
  MISSING_REQUIRED_BINARY: 'missing_required_binary',
  PROBE_FAILED: 'probe_failed',
  PROBE_TIMEOUT: 'probe_timeout',
  HOST_UNREACHABLE: 'host_unreachable',
  EGRESS_HOST_CHANGED: 'egress_host_changed',
  BUDGET_TOO_SMALL: 'budget_too_small',
  BUDGET_TOOL_FAILED: 'budget_tool_failed',
} as const);

export type LaneUnavailableReason =
  (typeof LANE_UNAVAILABLE)[keyof typeof LANE_UNAVAILABLE];

/* ------------------------------------------------------------------ *
 * The plan
 * ------------------------------------------------------------------ */

/** Where a spawned lane's review actually lands. */
export type OutputTarget =
  | { kind: 'stdout' }
  /** Codex: the tool writes the review itself and stdout is discarded (#1698). */
  | { kind: 'file'; path: string };

export interface SpawnPlan {
  transport: 'spawn';
  slug: string;
  binary: string;
  /** Fully resolved argv — model, effort and prompt already folded in, in leg order. */
  argv: string[];
  /** Prompt delivered on stdin, or `null` for `argv`/`argv-file-ref`/`none` lanes. */
  stdin: string | null;
  /**
   * The assembled prompt file, regardless of how (or whether) this lane consumes it. Carried even
   * for `promptChannel: 'none'` so a handler never has to re-derive the path from another field.
   */
  promptPath: string;
  outputTarget: OutputTarget;
  /** Canonical review path: `<runDir>/gsd-review-<slug>.md`. */
  reviewPath: string;
  /** stderr sidecar — never `/dev/null` (#2494). */
  errPath: string;
  timeoutMs: number;
  emptyOutput: EmptyOutputPolicy;
  handler: LaneHandler;
  requiresBinaries: readonly string[];
  probe: LaneProbe;
}

export interface HttpPlan {
  transport: 'openai-http';
  slug: string;
  /** Resolved base URL, normalized (no trailing slash). */
  host: string;
  hostConfigKey: string;
  /** `host` + the declared path. */
  url: string;
  /** Models endpoint for discovery, when `modelDiscovery` asks for it. */
  modelsUrl: string | null;
  /** Configured model, or `null` when discovery should run. */
  model: string | null;
  fallbackModel: string;
  promptPath: string;
  reviewPath: string;
  errPath: string;
  timeoutMs: number;
  emptyOutput: EmptyOutputPolicy;
  handler: LaneHandler;
  requiresBinaries: readonly string[];
  probe: LaneProbe;
}

export type LanePlan = SpawnPlan | HttpPlan;

export type ResolveResult =
  | { ok: true; plan: LanePlan; warnings: string[] }
  | { ok: false; reason: LaneUnavailableReason; detail: string; warnings: string[] };

/** Every handler name the runner can dispatch. Mirrors `LaneHandler` (D6's closed enum). */
const KNOWN_HANDLERS: ReadonlySet<string> = new Set(['antigravity', 'openai-compatible', 'opencode']);

export interface ResolveInput {
  lane: ReviewerLane;
  /** Resolved config lookup. Returns `undefined` for an absent key. */
  configGet: (key: string) => unknown;
  /** The run-scoped temp dir (`{run_dir}` in the workflow). */
  runDir: string;
  /** Absolute repo root, for `argv-file-ref` anchoring (#2176). */
  repoRoot: string;
  /** Effort argv for lanes whose `effortChannel` is `argv`; empty when the host declares none. */
  effortArgs?: readonly string[];
}

/* ------------------------------------------------------------------ *
 * Value normalization — the stringly-typed edges the bash lived with
 * ------------------------------------------------------------------ */

/**
 * A configured string value, or `null` when effectively unset.
 *
 * Four shapes all mean "not configured", and the bash had to handle three of them by hand:
 *   - absent / `null` / `undefined`;
 *   - `""` — the declared default of every federated `review.models.*` key;
 *   - `"null"` — the LITERAL four characters `config-get --raw` prints for a missing key, which
 *     every leg tested for (`[ "$X" != "null" ]`). Reading config in-process removes the source of
 *     this, but a `.planning/config.json` written by an older workflow can still contain it;
 *   - whitespace-only — never a meaningful model name or host.
 *
 * A non-string (number, bool, object, array) is NOT coerced. `String(0)` would put `"0"` into argv
 * as a model name; a wrong model silently reviewed is worse than no model override.
 */
function configString(raw: unknown): string | null {
  if (typeof raw !== 'string') return null;
  const trimmed = raw.trim();
  if (trimmed === '' || trimmed === 'null' || trimmed === 'undefined') return null;
  return trimmed;
}

/**
 * Normalize a base URL for storage and for the D5 consent comparison.
 *
 * Trailing slash, case in the scheme/host, and an explicit default port are all the same
 * destination. Without normalizing, a cosmetic `.planning/config.json` edit — adding a trailing
 * slash — would read as "the egress destination changed" and block the lane, training the user to
 * dismiss the one warning that matters.
 *
 * Returns the input trimmed when it is not parseable as a URL: an unparseable host is compared
 * verbatim rather than silently rewritten.
 */
export function normalizeHost(raw: string): string {
  const trimmed = String(raw ?? '').trim();
  if (!trimmed) return '';
  let u: URL;
  try {
    u = new URL(trimmed);
  } catch {
    return trimmed.replace(/\/+$/, '');
  }
  // `new URL('localhost:11434')` PARSES — protocol `localhost:`, empty hostname — so a plausible
  // but scheme-less config value would otherwise be rewritten to `localhost://11434` and compared
  // (and requested) as though it were a real destination. No hostname means this is not a URL;
  // return it verbatim so it fails visibly rather than silently becoming something else.
  if (!u.hostname) return trimmed.replace(/\/+$/, '');
  const scheme = u.protocol.toLowerCase();
  const isDefaultPort =
    (scheme === 'http:' && u.port === '80') || (scheme === 'https:' && u.port === '443');
  const port = isDefaultPort ? '' : u.port;
  const host = u.hostname.toLowerCase();
  const pathPart = u.pathname.replace(/\/+$/, '');
  return `${scheme}//${host}${port ? `:${port}` : ''}${pathPart}`;
}

/**
 * Classify a lane's output as a review or as empty.
 *
 * WHITESPACE-ONLY COUNTS AS EMPTY, for every lane. The bash tested `[ ! -s file ]`, which counts
 * BYTES — so a reply of three spaces passed as a successful review. Two legs (LM Studio,
 * llama.cpp) closed this locally with a case-glob; gemini, claude, codex, qwen and cursor did not.
 * Making it uniform is a deliberate, disclosed behavior change (a bug fix that breaks a workaround)
 * and is why this phase ships a changeset note.
 *
 * The `-n` / `-e` / `-E` hazard the two printf-using legs guarded against cannot occur here at all:
 * nothing in this path goes through `echo`.
 */
export function isEmptyReview(text: unknown): boolean {
  if (typeof text !== 'string') return true;
  return text.trim().length === 0;
}

/**
 * The standard `argv-file-ref` prompt (#2176).
 *
 * Two lanes take the prompt as an ARGUMENT rather than on stdin, and a full plan set inline would
 * approach the 32,767-character Windows `execFileSync` ceiling — so the argument is a short
 * instruction naming the prompt file. It must also carry the ABSOLUTE repo root: an argv-fed CLI
 * does not reliably inherit the review's working directory, and without the anchor the reviewer
 * reviews the plan text in isolation, which is exactly what the Review Instructions forbid.
 *
 * `antigravity` deliberately does NOT use this text — its handler owns a variant that additionally
 * demands a `REVIEWED-WITHOUT-REPO-ACCESS` self-report.
 */
export function fileRefPrompt(promptPath: string, repoRoot: string): string {
  return (
    `Read the file at ${promptPath} in full and carry out the review request it contains. ` +
    `The repository under review is at ${repoRoot} — resolve every relative file path in the ` +
    `review request against that absolute root. Output only the resulting markdown review. ` +
    `Do not edit any files.`
  );
}

/** Run-dir artifact paths. POSIX-joined: these are workflow-visible strings, not OS paths. */
function artifactPaths(runDir: string, slug: string): {
  promptPath: string;
  reviewPath: string;
  errPath: string;
} {
  const base = String(runDir ?? '').replace(/\/+$/, '');
  return {
    promptPath: `${base}/gsd-review-prompt.md`,
    reviewPath: `${base}/gsd-review-${slug}.md`,
    errPath: `${base}/gsd-review-${slug}.err`,
  };
}

/* ------------------------------------------------------------------ *
 * Resolution
 * ------------------------------------------------------------------ */

/**
 * Resolve one declared lane into an executable plan.
 *
 * TOTAL: never throws. Every rejection is a typed `LaneUnavailableReason`, because the caller has to
 * tell three different unavailabilities apart — a lane that is absent, a lane whose probe failed,
 * and a lane blocked on a changed egress destination are not the same event to a user.
 *
 * NOT resolved here: probe execution, prompt-budget trimming, and the D5 egress-host comparison.
 * Those need I/O and live in the runner. This function decides SHAPE.
 */
export function resolveLanePlan(input: ResolveInput): ResolveResult {
  const warnings: string[] = [];
  const fail = (reason: LaneUnavailableReason, detail: string): ResolveResult => ({
    ok: false,
    reason,
    detail,
    warnings,
  });

  // Trust boundary: the declared type says ReviewerLane, but overlay manifests arrive here.
  const raw = input?.lane as unknown;
  if (raw === null || typeof raw !== 'object' || Array.isArray(raw)) {
    return fail(LANE_UNAVAILABLE.MALFORMED_LANE, `lane is not an object: ${String(raw)}`);
  }
  const lane = raw as ReviewerLane;
  const slug = typeof lane.slug === 'string' ? lane.slug.trim() : '';
  if (!slug) {
    return fail(LANE_UNAVAILABLE.MALFORMED_LANE, 'lane declares no slug');
  }
  // The slug is CONCATENATED into artifact paths below, so the grammar is enforced here rather
  // than trusted from upstream. `checkReviewerLaneParity` and the capability validator both check
  // it too, but neither runs on this path — and this module's whole premise is that it is the
  // trust boundary for third-party overlay manifests. A slug of `../../../tmp/evil` would
  // otherwise produce a reviewPath outside the run dir that `writeReviewOrStub` happily writes to.
  if (!LANE_SLUG_RE.test(slug)) {
    return fail(
      LANE_UNAVAILABLE.MALFORMED_LANE,
      `lane slug '${slug}' is outside the declared grammar ${String(LANE_SLUG_RE)}`,
    );
  }

  // D4 rule 4: an unknown handler FAILS CLOSED. A lane naming imperative code this GSD version does
  // not have cannot be run "mostly" — the handler is precisely the part data could not express.
  const handler: LaneHandler = lane.handler ?? null;
  if (handler !== null && !KNOWN_HANDLERS.has(handler)) {
    return fail(
      LANE_UNAVAILABLE.UNKNOWN_HANDLER,
      `lane '${slug}' names handler '${String(handler)}', which this GSD version does not provide`,
    );
  }

  const { promptPath, reviewPath, errPath } = artifactPaths(input.runDir, slug);
  const timeoutMs =
    typeof lane.timeoutFloorMs === 'number' && Number.isFinite(lane.timeoutFloorMs) && lane.timeoutFloorMs > 0
      ? lane.timeoutFloorMs
      : 900_000;
  const emptyOutput: EmptyOutputPolicy = lane.emptyOutput === 'handler-owned' ? 'handler-owned' : 'stub-with-stderr';
  const requiresBinaries = Array.isArray(lane.requiresBinaries)
    ? lane.requiresBinaries.filter((b): b is string => typeof b === 'string')
    : [];

  const model = configString(
    typeof lane.modelConfigKey === 'string' ? input.configGet(lane.modelConfigKey) : undefined,
  );

  if (lane.transport === 'openai-http') {
    const rawInvoke: unknown = lane.invoke;
    // The spawn branch below guards with `inv?.binary`; this one must too. Without it a lane
    // declaring `transport: 'openai-http'` and no `invoke` THROWS, which breaks this module's
    // documented totality — and a throw here is worse than it looks: the CLI seam resolves every
    // selected lane in one `.map`, so one malformed overlay manifest would abort the whole review
    // rather than dropping its own lane.
    if (rawInvoke === null || typeof rawInvoke !== 'object' || Array.isArray(rawInvoke)) {
      return fail(
        LANE_UNAVAILABLE.MALFORMED_LANE,
        `openai-http lane '${slug}' declares no invoke object`,
      );
    }
    const inv = rawInvoke as {
      hostConfigKey?: unknown;
      defaultHost?: unknown;
      path?: unknown;
      fallbackModel?: unknown;
      modelDiscovery?: unknown;
    };
    const hostConfigKey = typeof inv.hostConfigKey === 'string' ? inv.hostConfigKey : '';
    const configured = hostConfigKey ? configString(input.configGet(hostConfigKey)) : null;
    // Only a STRING declares a host. Coercing an object would produce the literal
    // '[object Object]' and normalize THAT as the lane's egress destination.
    const declaredDefault = typeof inv.defaultHost === 'string' ? inv.defaultHost : '';
    const host = normalizeHost(configured ?? declaredDefault);
    if (!host) {
      return fail(
        LANE_UNAVAILABLE.MALFORMED_LANE,
        `lane '${slug}' resolves no host: '${hostConfigKey}' is unset and it declares no defaultHost`,
      );
    }
    const apiPath = typeof inv.path === 'string' && inv.path ? inv.path : '/v1/chat/completions';
    const discovers = inv.modelDiscovery === 'first-from-models-endpoint';
    return {
      ok: true,
      warnings,
      plan: {
        transport: 'openai-http',
        slug,
        host,
        hostConfigKey,
        url: `${host}${apiPath}`,
        modelsUrl: discovers ? `${host}/v1/models` : null,
        model,
        fallbackModel: typeof inv.fallbackModel === 'string' ? inv.fallbackModel : 'local-model',
        promptPath,
        reviewPath,
        errPath,
        timeoutMs,
        emptyOutput,
        handler,
        requiresBinaries,
        probe: lane.probe,
      },
    };
  }

  if (lane.transport !== 'spawn') {
    return fail(
      LANE_UNAVAILABLE.UNKNOWN_TRANSPORT,
      `lane '${slug}' declares transport '${String((lane as { transport?: unknown }).transport)}'`,
    );
  }

  const inv = lane.invoke;
  const binary = typeof inv?.binary === 'string' ? inv.binary.trim() : '';
  if (!binary) {
    return fail(LANE_UNAVAILABLE.MALFORMED_LANE, `spawn lane '${slug}' declares no binary`);
  }

  // Output target first: `{{output}}` needs to know the path, and the target is also what tells the
  // runner whether to capture stdout or read a file the tool wrote itself (#1698).
  let outputTarget: OutputTarget = { kind: 'stdout' };
  let outputExpansion: string[] = [];
  if (inv.outputChannel === 'file-arg') {
    const outputArg = typeof inv.outputArg === 'string' ? inv.outputArg : '';
    if (!outputArg) {
      return fail(
        LANE_UNAVAILABLE.MALFORMED_LANE,
        `lane '${slug}' declares outputChannel 'file-arg' with no outputArg naming the argument`,
      );
    }
    outputExpansion = [outputArg, reviewPath];
    outputTarget = { kind: 'file', path: reviewPath };
  }

  let stdin: string | null = null;
  let promptExpansion: string[] = [];
  switch (inv.promptChannel) {
    case 'stdin':
      stdin = promptPath; // the runner streams this file; the plan names it.
      break;
    case 'argv-file-ref':
      promptExpansion = [fileRefPrompt(promptPath, input.repoRoot)];
      break;
    case 'argv':
      promptExpansion = [promptPath];
      break;
    case 'none':
      break; // CodeRabbit reviews the working tree and is fed nothing (review.md:367).
    default:
      return fail(
        LANE_UNAVAILABLE.MALFORMED_LANE,
        `lane '${slug}' declares promptChannel '${String(inv.promptChannel)}'`,
      );
  }

  const modelExpansion =
    model && typeof inv.modelArg === 'string' && inv.modelArg ? [inv.modelArg, model] : [];
  const effortExpansion =
    inv.effortChannel === 'argv'
      ? (input.effortArgs ?? []).filter((a): a is string => typeof a === 'string' && a !== '')
      : [];

  // Expand the argv template in declared order. A placeholder with nothing to contribute expands to
  // ZERO elements and disappears — that is what lets one template serve both the configured and the
  // unconfigured case without a conditional in the data.
  const expansions: Record<string, string[]> = {
    '{{model}}': modelExpansion,
    '{{effort}}': effortExpansion,
    '{{output}}': outputExpansion,
    '{{prompt}}': promptExpansion,
  };
  const template = Array.isArray(inv.args)
    ? inv.args.filter((a): a is string => typeof a === 'string')
    : [];
  const argv: string[] = [];
  for (const token of template) {
    // Own-property lookup: a lane could declare a literal `constructor` argument, and prototype
    // members must never resolve as expansions.
    if (Object.prototype.hasOwnProperty.call(expansions, token)) {
      argv.push(...expansions[token]);
    } else {
      argv.push(token);
    }
  }

  return {
    ok: true,
    warnings,
    plan: {
      transport: 'spawn',
      slug,
      binary,
      argv,
      stdin,
      promptPath,
      outputTarget,
      reviewPath,
      errPath,
      timeoutMs,
      emptyOutput,
      handler,
      requiresBinaries,
      probe: lane.probe,
    },
  };
}