import type { TaskDeliveryState, TaskRecord } from "./task-registry.types.js";

/** Process-local indexes backing task lookup, owner access, and pending delivery scans. */

export type TaskRegistryProcessState = {

type TaskRegistryProcessState = {

tasks: Map<string, TaskRecord>;

taskDeliveryStates: Map<string, TaskDeliveryState>;

taskIdsByRunId: Map<string, Set<string>>;

// Shares SQLite row mapping helpers between task registry persistence modules.

import { chmodSync, existsSync, mkdirSync } from "node:fs";

import { isRecord } from "../utils.js";

import { normalizeDeliveryContext } from "../utils/delivery-context.shared.js";

import type { DeliveryContext } from "../utils/delivery-context.types.js";

export const SQLITE_SIDECAR_SUFFIXES = ["", "-shm", "-wal"] as const;

export function normalizeSqliteNumber(value: number | bigint | null): number | undefined {

if (typeof value === "bigint") {

return Number(value);

}

return typeof value === "number" ? value : undefined;

}

// oxlint-disable-next-line typescript/no-unnecessary-type-parameters -- Persisted JSON columns are typed by the receiving field.

export function parseSqliteJsonValue<T>(raw: string | null): T | undefined {

function parseSqliteJsonValue<T>(raw: string | null): T | undefined {

if (!raw?.trim()) {

return undefined;

}

: undefined,

});

}

export function ensureSqliteStorePermissions(params: {

dir: string;

pathname: string;

dirMode: number;

fileMode: number;

}) {

mkdirSync(params.dir, { recursive: true, mode: params.dirMode });

chmodSync(params.dir, params.dirMode);

for (const suffix of SQLITE_SIDECAR_SUFFIXES) {

const candidate = `${params.pathname}${suffix}`;

if (!existsSync(candidate)) {

continue;

}

chmodSync(candidate, params.fileMode);

}

}

previous: TaskRecord;

};

export type TaskRegistryObservers = {

type TaskRegistryObservers = {

// Observers are incremental/best-effort only. Snapshot persistence belongs to TaskRegistryStore.

onEvent?: (event: TaskRegistryObserverEvent) => void;

};

const ACTIVE_TASK_STATUSES = new Set(["queued", "running"]);

const FAILURE_TASK_STATUSES = new Set(["failed", "timed_out", "lost"]);

/** Window for showing recently completed tasks in compact status output. */

export const TASK_STATUS_RECENT_WINDOW_MS = 5 * 60_000;

export const TASK_STATUS_TITLE_MAX_CHARS = 80;

const TASK_STATUS_RECENT_WINDOW_MS = 5 * 60_000;

const TASK_STATUS_TITLE_MAX_CHARS = 80;

export const TASK_STATUS_DETAIL_MAX_CHARS = 120;

function isActiveTask(task: TaskRecord): boolean {

);

}

export type TaskStatusSnapshot = {

type TaskStatusSnapshot = {

latest?: TaskRecord;

focus?: TaskRecord;

visible: TaskRecord[];