"""Pulumi processor: pulumi up, preview, destroy, refresh."""

import re

from .base import Processor

_PULUMI_CMD_RE = re.compile(r"\bpulumi\s+(up|update|preview|destroy|refresh)\b")
# Resource operation lines start with a +/-/~ marker (create/delete/update).
_RESOURCE_OP_RE = re.compile(r"^\s*[+\-~]\s+\S")
_KEEP_RE = re.compile(
    r"^(Updating|Previewing|Destroying|Refreshing|Resources:|Outputs:|Duration:|Diagnostics:)",
)
_ERROR_RE = re.compile(r"\b(error|Error|warning|Warning|failed|Failed|panic)\b")


class PulumiProcessor(Processor):
    priority = 46
    hook_patterns = [
        r"^pulumi\s+(up|update|preview|destroy|refresh)\b",
    ]

    @property
    def name(self) -> str:
        return "pulumi"

    def can_handle(self, command: str) -> bool:
        return bool(_PULUMI_CMD_RE.search(command))

    def process(self, command: str, output: str) -> str:
        if not output or not output.strip():
            return output

        lines = output.splitlines()
        if len(lines) <= 20:
            return output

        result: list[str] = []
        in_summary = False
        skipped = 0

        for line in lines:
            stripped = line.strip()

            if _KEEP_RE.match(stripped):
                # Resources:/Outputs:/Diagnostics: open a block we keep verbatim.
                in_summary = stripped.startswith(("Resources:", "Outputs:", "Diagnostics:"))
                result.append(line)
                continue

            # Inside a summary block, keep indented detail lines.
            if in_summary and (line.startswith((" ", "\t")) and stripped):
                result.append(line)
                continue
            if in_summary and not stripped:
                in_summary = False

            if _RESOURCE_OP_RE.match(line) or _ERROR_RE.search(stripped):
                result.append(line)
                continue

            if stripped:
                skipped += 1

        if skipped:
            result.append(f"[{skipped} unchanged/progress lines hidden]")

        return "\n".join(result) if result else output