import type { Block, KnownBlock, WebClient } from "@slack/web-api";
import { logVerbose } from "openclaw/plugin-sdk/runtime-env";
import { editSlackMessage } from "../../actions.js";
import { buildSlackBlocksFallbackText } from "../../blocks-fallback.js";
import { normalizeSlackOutboundText } from "../../format.js";

type SlackReadbackMessage = {
  ts?: string;
  text?: string;
  blocks?: unknown[];
};

function buildExpectedSlackEditText(params: {
  text: string;
  blocks?: (Block | KnownBlock)[];
}): string {
  const trimmed = normalizeSlackOutboundText(params.text.trim());
  if (trimmed) {
    return trimmed;
  }
  if (params.blocks?.length) {
    return buildSlackBlocksFallbackText(params.blocks);
  }
  return " ";
}

function blocksMatch(expected?: (Block | KnownBlock)[], actual?: unknown[]): boolean {
  if (!expected?.length) {
    return !actual?.length;
  }
  if (!actual?.length) {
    return false;
  }
  return JSON.stringify(expected) === JSON.stringify(actual);
}

async function readSlackMessageAfterEditError(params: {
  client: WebClient;
  token: string;
  channelId: string;
  messageId: string;
  threadTs?: string;
}): Promise<SlackReadbackMessage | null> {
  if (params.threadTs) {
    const replyResult = await params.client.conversations.replies({
      token: params.token,
      channel: params.channelId,
      ts: params.threadTs,
      latest: params.messageId,
      inclusive: true,
      limit: 100,
    });
    const reply = (replyResult.messages ?? []).find(
      (message) => (message as SlackReadbackMessage | undefined)?.ts === params.messageId,
    ) as SlackReadbackMessage | undefined;
    return reply ?? null;
  }

  const historyResult = await params.client.conversations.history({
    token: params.token,
    channel: params.channelId,
    latest: params.messageId,
    oldest: params.messageId,
    inclusive: true,
    limit: 1,
  });
  const message = historyResult.messages?.[0] as SlackReadbackMessage | undefined;
  if (!message?.ts || message.ts !== params.messageId) {
    return null;
  }
  return message;
}

async function didSlackPreviewEditApplyAfterError(params: {
  client: WebClient;
  token: string;
  channelId: string;
  messageId: string;
  text: string;
  blocks?: (Block | KnownBlock)[];
  threadTs?: string;
}): Promise<boolean> {
  const readback = await readSlackMessageAfterEditError(params);
  if (!readback) {
    return false;
  }
  const expectedText = buildExpectedSlackEditText({
    text: params.text,
    blocks: params.blocks,
  });
  const actualText = normalizeSlackOutboundText((readback.text ?? "").trim());
  if (params.blocks?.length) {
    return actualText === expectedText && blocksMatch(params.blocks, readback.blocks);
  }
  return actualText === expectedText;
}

export async function finalizeSlackPreviewEdit(params: {
  client: WebClient;
  token: string;
  accountId?: string;
  channelId: string;
  messageId: string;
  text: string;
  blocks?: (Block | KnownBlock)[];
  threadTs?: string;
}): Promise<void> {
  try {
    await editSlackMessage(params.channelId, params.messageId, params.text, {
      token: params.token,
      accountId: params.accountId,
      client: params.client,
      ...(params.blocks?.length ? { blocks: params.blocks } : {}),
    });
    return;
  } catch (err) {
    try {
      const applied = await didSlackPreviewEditApplyAfterError({
        client: params.client,
        token: params.token,
        channelId: params.channelId,
        messageId: params.messageId,
        text: params.text,
        blocks: params.blocks,
        threadTs: params.threadTs,
      });
      if (applied) {
        logVerbose(
          `slack: preview final edit response failed but readback matched message ${params.channelId}/${params.messageId}; suppressing duplicate fallback send`,
        );
        return;
      }
    } catch (readbackErr) {
      logVerbose(`slack: preview final edit readback failed (${String(readbackErr)})`);
    }
    throw err;
  }
}

export const __testing = {
  buildExpectedSlackEditText,
  blocksMatch,
  didSlackPreviewEditApplyAfterError,
  readSlackMessageAfterEditError,
};