import {
  QueueMcpCancelInput,
  QueueMcpCancelResult,
  QueueMcpEditInput,
  QueueMcpEditResult,
  QueueMcpFailure,
  QueueMcpListInput,
  QueueMcpListResult,
  QueueMcpPromoteInput,
  QueueMcpPromoteResult,
  QueueMcpReadInput,
  QueueMcpReadResult,
  QueueMcpReorderInput,
  QueueMcpReorderResult,
} from "@t3tools/contracts";
import { Tool, Toolkit } from "effect/unstable/ai";

import * as McpInvocationContext from "../../McpInvocationContext.ts";
import { QueueMcpService } from "../../QueueMcpService.ts";

const dependencies = [McpInvocationContext.McpInvocationContext, QueueMcpService];

export const QueueListTool = Tool.make("t3_queue_list", {
  description:
    "List queued follow-up runs in delivery order for this thread, or another thread in the same project. Results and message text are bounded; continue with nextCursor.",
  parameters: QueueMcpListInput,
  success: QueueMcpListResult,
  failure: QueueMcpFailure,
  failureMode: "return",
  dependencies,
})
  .annotate(Tool.Title, "List queued work")
  .annotate(Tool.Readonly, true)
  .annotate(Tool.Destructive, false)
  .annotate(Tool.Idempotent, true);

export const QueueReadTool = Tool.make("t3_queue_read", {
  description:
    "Read one queued run and its durable message and attachment references. The run must still be queued in the selected same-project thread.",
  parameters: QueueMcpReadInput,
  success: QueueMcpReadResult,
  failure: QueueMcpFailure,
  failureMode: "return",
  dependencies,
})
  .annotate(Tool.Title, "Read queued work")
  .annotate(Tool.Readonly, true)
  .annotate(Tool.Destructive, false)
  .annotate(Tool.Idempotent, true);

export const QueueEditTool = Tool.make("t3_queue_edit", {
  description:
    "Edit a queued follow-up message. Omit attachmentIds to preserve attachments; pass [] to clear them; otherwise pass attachment IDs already owned by the target thread. Active and terminal runs are rejected.",
  parameters: QueueMcpEditInput,
  success: QueueMcpEditResult,
  failure: QueueMcpFailure,
  failureMode: "return",
  dependencies,
})
  .annotate(Tool.Title, "Edit queued work")
  .annotate(Tool.Destructive, true);

export const QueueReorderTool = Tool.make("t3_queue_reorder", {
  description:
    "Move a queued user message before another queued run, or pass beforeRunId=null to move it to the end. Automatic completion deliveries keep priority and cannot be moved. Check outcome: receipt_replayed means this retry did not apply the requested destination; list the queue for current order.",
  parameters: QueueMcpReorderInput,
  success: QueueMcpReorderResult,
  failure: QueueMcpFailure,
  failureMode: "return",
  dependencies,
})
  .annotate(Tool.Title, "Reorder queued work")
  .annotate(Tool.Destructive, true);

export const QueueCancelTool = Tool.make("t3_queue_cancel", {
  description:
    "Cancel a queued run without interrupting active work. Active and terminal runs are rejected by the serialized V2 queue command.",
  parameters: QueueMcpCancelInput,
  success: QueueMcpCancelResult,
  failure: QueueMcpFailure,
  failureMode: "return",
  dependencies,
})
  .annotate(Tool.Title, "Cancel queued work")
  .annotate(Tool.Destructive, true);

export const QueuePromoteTool = Tool.make("t3_queue_promote_to_steer", {
  description:
    "Promote a queued user message into a steerable active run. The selected provider must support its active steering path; unsupported, stale, and non-running targets are rejected without cancelling the queued run.",
  parameters: QueueMcpPromoteInput,
  success: QueueMcpPromoteResult,
  failure: QueueMcpFailure,
  failureMode: "return",
  dependencies,
})
  .annotate(Tool.Title, "Promote queued work to steering")
  .annotate(Tool.Destructive, true);

export const QueueToolkit = Toolkit.make(
  QueueListTool,
  QueueReadTool,
  QueueEditTool,
  QueueReorderTool,
  QueueCancelTool,
  QueuePromoteTool,
);