/**
 * Refresh-token issuance + rotation (v1.4 G4).
 *
 * One-time-use semantics: every successful refresh marks the consumed
 * row's `usedAt`, sets `replacedById` to the new row, and sunsets the
 * paired access token — its expiry is pulled in to a few seconds so
 * requests already on the wire finish, without the token outliving its
 * sibling. Reuse of an already-consumed token is treated as a
 * stolen-token signal and revokes the entire token family instantly
 * (caller must log in again).
 */
import { randomBytes } from "node:crypto";
import { prisma } from "@/lib/db";
import { hashToken } from "@/lib/auth/hmac";
import { issueApiToken } from "@/lib/auth/issue-token";
import type { TokenPolicyDecision } from "@/lib/auth/native-client";

export interface IssuedRefreshBundle {
  accessToken: string;
  accessTokenExpiresAt: Date;
  refreshToken: string;
  refreshTokenExpiresAt: Date;
}

export interface IssueRefreshOpts {
  userId: string;
  policy: TokenPolicyDecision;
  deviceId?: string | null;
  userAgent?: string | null;
  ipAddress?: string | null;
  /** Token name suffix for the underlying ApiToken row. */
  source: string;
}

/**
 * How long an access token stays usable after the refresh token it was paired
 * with has been rotated away.
 *
 * A native client fires several requests at once and rotates in the middle of
 * them: a request that left the device a few hundred milliseconds before the
 * rotation committed still carries the outgoing access token and lands after
 * it. Killing that token at the instant of the commit answered those requests
 * with 401 `revoked`, which a client reads as "re-authenticate" — it then
 * rotates again with the refresh token it just consumed, trips reuse
 * detection, and loses the whole family. Being busy was enough to be signed
 * out.
 *
 * 15 seconds is picked from both ends. Long enough that a request already on
 * the wire over a slow mobile link finishes on the old credential, including a
 * retry; short enough that a leaked access token gains nothing worth having —
 * it was already valid for the seconds before the rotation, and this only
 * carries that same validity a few seconds further, against an access token
 * that lives a day.
 */
export const ACCESS_TOKEN_SUNSET_MS = 15_000;

function generateRefreshTokenSecret(): string {
  return `hlr_${randomBytes(32).toString("hex")}`;
}

/**
 * Issue a fresh access token + refresh token pair. Used by:
 *   - login (password + passkey verify) for native callers
 *   - the /api/auth/refresh rotation endpoint
 */
export async function issueAccessAndRefresh(
  opts: IssueRefreshOpts,
): Promise<IssuedRefreshBundle> {
  if (opts.policy.refreshTokenDays === null) {
    throw new Error(
      "issueAccessAndRefresh called for web policy (no refresh token)",
    );
  }

  const access = await issueApiToken({
    userId: opts.userId,
    name: `${opts.policy.tokenLabel} ${opts.source} ${new Date().toISOString()}`,
    permissions: ["*"],
    expiresInDays: opts.policy.accessTokenDays,
  });

  const refresh = generateRefreshTokenSecret();
  const refreshHash = hashToken(refresh);
  const accessTokenHash = hashToken(access.token);
  const expiresAt = new Date(
    Date.now() + opts.policy.refreshTokenDays * 24 * 60 * 60 * 1000,
  );

  await prisma.refreshToken.create({
    data: {
      userId: opts.userId,
      tokenHash: refreshHash,
      accessTokenHash,
      deviceId: opts.deviceId ?? null,
      expiresAt,
      userAgent: opts.userAgent ?? null,
      ipAddress: opts.ipAddress ?? null,
    },
  });

  return {
    accessToken: access.token,
    accessTokenExpiresAt: access.expiresAt,
    refreshToken: refresh,
    refreshTokenExpiresAt: expiresAt,
  };
}

export type RotationFailureReason =
  "not_found" | "expired" | "already_used" | "revoked" | "device_mismatch";

export type RotationResult =
  | { ok: true; bundle: IssuedRefreshBundle }
  | { ok: false; reason: RotationFailureReason };

/**
 * Atomically rotate a refresh token: validate, mark consumed, issue a new
 * pair, sunset the previously-paired access token (see
 * `ACCESS_TOKEN_SUNSET_MS`). Reuse of a consumed token revokes the whole
 * family immediately (defence against stolen refresh tokens).
 */
export async function rotateRefreshToken(input: {
  refreshToken: string;
  policy: TokenPolicyDecision;
  deviceId?: string | null;
  userAgent?: string | null;
  ipAddress?: string | null;
}): Promise<RotationResult> {
  const hash = hashToken(input.refreshToken);
  const row = await prisma.refreshToken.findUnique({
    where: { tokenHash: hash },
  });

  if (!row) return { ok: false, reason: "not_found" };
  if (row.revokedAt) return { ok: false, reason: "revoked" };
  if (row.expiresAt.getTime() <= Date.now())
    return { ok: false, reason: "expired" };

  if (row.usedAt) {
    // Reuse-detection: a previously-consumed refresh token shouldn't be
    // presented again. v1.4.23 scopes the blast radius to the originating
    // device so the legitimate two-device case keeps working — an iPhone
    // dropping into airplane mode shouldn't sign the user out of their
    // iPad. Tokens issued before v1.4.23 (deviceId === null) still
    // revoke-user-wide because we can't isolate them safely.
    //
    // Defence-in-depth note: the iOS client always sends X-Device-Id on
    // refresh, so the legitimate path always carries a deviceId. A
    // missing deviceId on a replay is itself a suspicious signal, hence
    // the fall-through to the wider revoke.
    //
    // M-4 hardening: a legitimate device never changes its id mid-family.
    // If the *presented* deviceId is present but differs from the stored
    // row's deviceId, the device-scoped key is client-asserted and would
    // confine the revoke to the attacker's own fabricated id, leaving the
    // victim's family live. Escalate to the user-wide revoke in that case
    // so a stolen token replayed under a spoofed id can't dodge
    // containment.
    const presentedDeviceId = input.deviceId ?? null;
    const storedDeviceId = row.deviceId ?? null;
    const deviceMismatch =
      presentedDeviceId !== null &&
      storedDeviceId !== null &&
      presentedDeviceId !== storedDeviceId;
    const where: { userId: string; revokedAt: null; deviceId?: string } =
      storedDeviceId !== null && !deviceMismatch
        ? { userId: row.userId, revokedAt: null, deviceId: storedDeviceId }
        : { userId: row.userId, revokedAt: null };
    const compromised = await prisma.refreshToken.findMany({ where });
    await prisma.refreshToken.updateMany({
      where,
      data: { revokedAt: new Date() },
    });
    const accessHashes = compromised
      .map((c) => c.accessTokenHash)
      .filter((v): v is string => Boolean(v));
    if (accessHashes.length > 0) {
      await prisma.apiToken.updateMany({
        where: { tokenHash: { in: accessHashes } },
        data: { revoked: true },
      });
    }
    return { ok: false, reason: "already_used" };
  }

  // A live token belongs to the device it was issued to. The M-4 escalation
  // above already treats a mismatched deviceId on a REPLAY as a spoofing
  // signal; the same mismatch on a still-live token is refused outright
  // rather than silently rotated. Without this the reuse-detection scope is
  // only as honest as the caller: a thief could rotate a stolen token under
  // their own fabricated device id, and the resulting family — keyed on the
  // attacker's id, because `issueAccessAndRefresh` below inherits
  // `row.deviceId ?? input.deviceId` — would sit outside the victim device's
  // containment blast radius.
  //
  // A stored null means the row predates per-device issuance, or the client
  // sent no `X-Device-Id` when it signed in: nothing to compare, so it
  // rotates. A stored id must be matched exactly, and an absent header does
  // not match it. It used to: leaving the header out skipped the check, so a
  // thief holding a stolen token rotated it simply by not naming a device. A
  // client that sent its id at sign-in sends it on every refresh, so this
  // locks out nobody who signed in honestly.
  const presentedId = input.deviceId ?? null;
  const storedId = row.deviceId ?? null;
  if (storedId !== null && presentedId !== storedId) {
    return { ok: false, reason: "device_mismatch" };
  }

  // Issue the new pair first, THEN mark old consumed in a transaction.
  // (Race: if two concurrent refreshes hit the same row, both will try to
  // mark `usedAt`. We use updateMany with a `usedAt: null` guard so only
  // one wins; the loser's new token row is orphaned but harmless because
  // the loser's access token will be revoked alongside it.)
  const bundle = await issueAccessAndRefresh({
    userId: row.userId,
    policy: input.policy,
    deviceId: row.deviceId ?? input.deviceId ?? null,
    userAgent: input.userAgent ?? row.userAgent,
    ipAddress: input.ipAddress ?? row.ipAddress,
    source: "refresh",
  });

  // Find the row we just created so we can store its id as replacedById.
  const newHash = hashToken(bundle.refreshToken);
  const newRow = await prisma.refreshToken.findUnique({
    where: { tokenHash: newHash },
    select: { id: true },
  });

  // `revokedAt: null` is part of the guard, not only `usedAt: null`. The row
  // was read as live at the top of this function; a revocation landing between
  // that read and this write — "sign out everywhere", a credential rotation,
  // reuse detection tripped by a sibling — would otherwise be overtaken, and
  // the pair minted a moment ago would be the one live login left on a family
  // the user had just ended.
  const updated = await prisma.refreshToken.updateMany({
    where: { id: row.id, usedAt: null, revokedAt: null },
    data: {
      usedAt: new Date(),
      replacedById: newRow?.id ?? null,
    },
  });

  if (updated.count === 0) {
    // Lost the race: another concurrent refresh consumed this row, or a
    // revocation landed underneath it. Either way, retire what was just minted
    // so no extra valid pair leaks, then say which it was — a revoked family
    // must read as `revoked`, which the client answers with a fresh sign-in,
    // not as `already_used`, which it would retry.
    await prisma.refreshToken.updateMany({
      where: { tokenHash: newHash },
      data: { revokedAt: new Date() },
    });
    await prisma.apiToken.updateMany({
      where: { tokenHash: hashToken(bundle.accessToken) },
      data: { revoked: true },
    });
    const now = await prisma.refreshToken.findUnique({
      where: { id: row.id },
      select: { revokedAt: true },
    });
    return { ok: false, reason: now?.revokedAt ? "revoked" : "already_used" };
  }

  // Best-effort: sunset the access token paired with the consumed refresh, so
  // a leaked access token can't meaningfully outlive its refresh-token
  // sibling. It is a SHORTENED EXPIRY, not a revoke: a request that left the
  // device before this rotation committed must still be served, and
  // `expiresAt <= now` is the verdict a client already knows how to handle
  // (`bearer.ts` answers it with reason `expired`), whereas `revoked` reads as
  // "re-authenticate" and drives the client into a second rotation with the
  // refresh token it just consumed.
  //
  // This grace applies to the ORDINARY rotation only. The reuse-detection path
  // above — a replayed refresh token, a spoofed device id — is the
  // stolen-token defence and keeps revoking the family and its access tokens
  // instantly, with no window. So does `revokeBearerAccessToken` at logout.
  //
  // The write can only ever SHORTEN. `LEAST(expires_at, $1)` takes the minimum
  // inside the single UPDATE, so a token already inside its last seconds is
  // not handed extra life by the very call that retires it, and there is no
  // read-then-write window for a concurrent update to fall into. Postgres
  // `LEAST` skips NULLs, which is the semantics we want for a token carrying
  // no fixed expiry: it gets the window and nothing longer.
  //
  // Raw because Prisma's `updateMany` cannot express a column-referencing
  // expression in `data`. Both values ride as tagged-template parameters.
  if (row.accessTokenHash) {
    const sunsetAt = new Date(Date.now() + ACCESS_TOKEN_SUNSET_MS);
    // The bound value is an ISO-8601 UTC string cast in SQL, not a JS `Date`:
    // a Date parameter is serialised in the process's local zone, and
    // `expires_at` is a zone-less UTC column, so the comparison would shift by
    // the host's offset. `::timestamptz AT TIME ZONE 'UTC'` pins the instant
    // whatever TZ the app process runs under.
    await prisma.$executeRaw`
      UPDATE api_tokens
         SET expires_at = LEAST(
               expires_at,
               ${sunsetAt.toISOString()}::timestamptz AT TIME ZONE 'UTC'
             )
       WHERE token_hash = ${row.accessTokenHash}
         AND revoked = false
    `;
  }

  return { ok: true, bundle };
}

/**
 * Revoke a bearer access token presented at logout (M-2 hardening).
 *
 * `destroySession()` only clears the cookie; for a native/bearer transport
 * that does not round-trip the refresh endpoint, `/api/auth/logout` would
 * otherwise leave the access token valid until expiry. This hashes the raw
 * `hlk_<…>` token, flips the matching `ApiToken.revoked = true`, and
 * revokes its paired `RefreshToken` sibling (matched by `accessTokenHash`)
 * so the whole credential pair dies with the logout.
 *
 * A logout is instant and stays instant: no sunset window applies here. The
 * rotation-time grace exists for requests the client did not choose to
 * abandon; a person signing out chose, and must not keep a live token for a
 * further few seconds.
 *
 * Returns true when a matching live ApiToken row was revoked.
 */
export async function revokeBearerAccessToken(
  rawAccessToken: string,
): Promise<boolean> {
  const accessHash = hashToken(rawAccessToken);

  const apiResult = await prisma.apiToken.updateMany({
    where: { tokenHash: accessHash, revoked: false },
    data: { revoked: true },
  });

  // Revoke the paired refresh sibling so a native logout kills both halves
  // of the pair in one call.
  await prisma.refreshToken.updateMany({
    where: { accessTokenHash: accessHash, revokedAt: null },
    data: { revokedAt: new Date() },
  });

  return apiResult.count > 0;
}

/**
 * Revoke a refresh token identified by its stored hash (not the raw secret).
 *
 * Replay-containment reach-back for the native OIDC handoff: the handoff row
 * records only `hashToken(refreshToken)` of the pair it issued, never the raw
 * token, so a replay must revoke by hash. Same effect as `revokeRefreshToken`
 * — flip the refresh row and its paired access token — keyed by the hash the
 * caller already holds.
 *
 * Returns true when a live refresh row was revoked.
 */
export async function revokeRefreshTokenByHash(
  refreshTokenHash: string,
): Promise<boolean> {
  const row = await prisma.refreshToken.findUnique({
    where: { tokenHash: refreshTokenHash },
    select: { accessTokenHash: true, revokedAt: true },
  });
  if (!row || row.revokedAt) return false;

  const result = await prisma.refreshToken.updateMany({
    where: { tokenHash: refreshTokenHash, revokedAt: null },
    data: { revokedAt: new Date() },
  });
  if (result.count === 0) return false;

  if (row.accessTokenHash) {
    await prisma.apiToken.updateMany({
      where: { tokenHash: row.accessTokenHash, revoked: false },
      data: { revoked: true },
    });
  }
  return true;
}

/** Revoke a specific refresh token (logout-on-device).
 *  Also revokes the paired access token so a leaked access token cannot
 *  outlive the refresh-token sibling that the user just killed. */
export async function revokeRefreshToken(
  refreshToken: string,
): Promise<boolean> {
  const hash = hashToken(refreshToken);
  const row = await prisma.refreshToken.findUnique({
    where: { tokenHash: hash },
    select: { accessTokenHash: true, revokedAt: true },
  });
  if (!row || row.revokedAt) return false;

  const result = await prisma.refreshToken.updateMany({
    where: { tokenHash: hash, revokedAt: null },
    data: { revokedAt: new Date() },
  });
  if (result.count === 0) return false;

  if (row.accessTokenHash) {
    await prisma.apiToken.updateMany({
      where: { tokenHash: row.accessTokenHash, revoked: false },
      data: { revoked: true },
    });
  }
  return true;
}