"use client" import type React from "react" import { useState, useEffect, useRef } from "react" import { Dialog, DialogContent, DialogTitle } from "@/components/ui/dialog" import { Button } from "@/components/ui/button" import { Input } from "@/components/ui/input" import { Label } from "@/components/ui/label" import { CheckCircle2, XCircle, Loader2, Activity, GripHorizontal } from "lucide-react" import { API_PORT } from "@/lib/api-config" import { useIsMobile } from "@/hooks/use-mobile" interface WebInteraction { type: "yesno" | "menu" | "msgbox" | "input" | "inputbox" id: string title: string message: string options?: Array<{ label: string; value: string }> default?: string } interface ScriptTerminalModalProps { open: boolean onClose: () => void scriptPath: string scriptName: string params?: Record title: string description: string } interface TerminalInstance { term: any | null ws: WebSocket | null fitAddon: any | null isConnected: boolean } export function ScriptTerminalModal({ open, onClose, scriptPath, scriptName, params = {}, title, description, }: ScriptTerminalModalProps) { const [terminal, setTerminal] = useState({ term: null, ws: null, fitAddon: null, isConnected: false, }) const sessionIdRef = useRef(Math.random().toString(36).substring(2, 8)) const [isComplete, setIsComplete] = useState(false) const [exitCode, setExitCode] = useState(null) const [currentInteraction, setCurrentInteraction] = useState(null) const [interactionInput, setInteractionInput] = useState("") const checkConnectionInterval = useRef(null) const isMobile = useIsMobile() const [isWaitingNextInteraction, setIsWaitingNextInteraction] = useState(false) const waitingTimeoutRef = useRef(null) const [modalHeight, setModalHeight] = useState(80) const [isResizing, setIsResizing] = useState(false) const startYRef = useRef(0) const startHeightRef = useRef(80) const terminalContainerRef = useRef(null) useEffect(() => { if (!open) { if (checkConnectionInterval.current) { clearInterval(checkConnectionInterval.current) } if (waitingTimeoutRef.current) { clearTimeout(waitingTimeoutRef.current) } if (terminal.ws) { terminal.ws.close() } if (terminal.term) { terminal.term.dispose() } setTerminal({ term: null, ws: null, fitAddon: null, isConnected: false }) sessionIdRef.current = Math.random().toString(36).substring(2, 8) setIsComplete(false) setExitCode(null) setInteractionInput("") setCurrentInteraction(null) setIsWaitingNextInteraction(false) } }, [open]) useEffect(() => { const container = terminalContainerRef.current if (!open || !container || terminal.term) { return } const initializeTerminal = async () => { const [TerminalClass, FitAddonClass] = await Promise.all([ import("xterm").then((mod) => mod.Terminal), import("xterm-addon-fit").then((mod) => mod.FitAddon), import("xterm/css/xterm.css"), ]) const fontSize = window.innerWidth < 768 ? 12 : 16 const term = new TerminalClass({ rendererType: "dom", fontFamily: '"Courier", "Courier New", "Liberation Mono", "DejaVu Sans Mono", monospace', fontSize: fontSize, lineHeight: 1, cursorBlink: true, scrollback: 2000, disableStdin: false, customGlyphs: true, fontWeight: "500", fontWeightBold: "700", theme: { background: "#000000", foreground: "#ffffff", cursor: "#ffffff", cursorAccent: "#000000", black: "#2e3436", red: "#cc0000", green: "#4e9a06", yellow: "#c4a000", blue: "#3465a4", magenta: "#75507b", cyan: "#06989a", white: "#d3d7cf", brightBlack: "#555753", brightRed: "#ef2929", brightGreen: "#8ae234", brightYellow: "#fce94f", brightBlue: "#729fcf", brightMagenta: "#ad7fa8", brightCyan: "#34e2e2", brightWhite: "#eeeeec", }, }) const fitAddon = new FitAddonClass() term.loadAddon(fitAddon) term.open(container) setTimeout(() => { try { fitAddon.fit() } catch (err) { // Ignore } }, 50) const wsUrl = getScriptWebSocketUrl(sessionIdRef.current) const ws = new WebSocket(wsUrl) ws.onopen = () => { setTerminal((prev) => ({ ...prev, isConnected: true, term, ws, fitAddon })) const initMessage = { script_path: scriptPath, params: { EXECUTION_MODE: "web", ...params, }, } ws.send(JSON.stringify(initMessage)) setTimeout(() => { try { fitAddon.fit() const cols = term.cols const rows = term.rows ws.send( JSON.stringify({ type: "resize", cols: cols, rows: rows, }), ) } catch (err) { // Ignore } }, 100) } ws.onmessage = (event) => { try { const msg = JSON.parse(event.data) if (msg.type === "web_interaction" && msg.interaction) { setIsWaitingNextInteraction(false) if (waitingTimeoutRef.current) { clearTimeout(waitingTimeoutRef.current) } setCurrentInteraction({ type: msg.interaction.type, id: msg.interaction.id, title: msg.interaction.title || "", message: msg.interaction.message || "", options: msg.interaction.options, default: msg.interaction.default, }) return // Don't write JSON to terminal } if (msg.type === "error") { terminal.term.writeln(`\x1b[31m${msg.message}\x1b[0m`) return } } catch { // Not JSON, it's regular terminal output } terminal.term.write(event.data) setIsWaitingNextInteraction(false) if (waitingTimeoutRef.current) { clearTimeout(waitingTimeoutRef.current) } } ws.onerror = (error) => { setTerminal((prev) => ({ ...prev, isConnected: false })) terminal.term.writeln("\x1b[31mWebSocket error occurred\x1b[0m") } ws.onclose = (event) => { setTerminal((prev) => ({ ...prev, isConnected: false })) terminal.term.writeln("\x1b[33mConnection closed\x1b[0m") if (!isComplete) { setIsComplete(true) setExitCode(event.code === 1000 ? 0 : 1) } } term.onData((data) => { if (ws.readyState === WebSocket.OPEN) { ws.send(data) } }) checkConnectionInterval.current = setInterval(() => { if (ws) { setTerminal((prev) => ({ ...prev, isConnected: ws.readyState === WebSocket.OPEN })) } }, 500) let resizeTimeout: NodeJS.Timeout | null = null const resizeObserver = new ResizeObserver(() => { if (resizeTimeout) clearTimeout(resizeTimeout) resizeTimeout = setTimeout(() => { if (fitAddon && term && ws?.readyState === WebSocket.OPEN) { try { fitAddon.fit() ws.send( JSON.stringify({ type: "resize", cols: term.cols, rows: term.rows, }), ) } catch (err) { // Ignore } } }, 100) }) resizeObserver.observe(container) } initializeTerminal() }, [open, terminal.term]) const getScriptWebSocketUrl = (sid: string): string => { if (typeof window === "undefined") { return `ws://localhost:${API_PORT}/ws/script/${sid}` } const { hostname, protocol } = window.location const wsProtocol = protocol === "https:" ? "wss:" : "ws:" return `${wsProtocol}//${hostname}:${API_PORT}/ws/script/${sid}` } const handleInteractionResponse = (value: string) => { if (!terminal.ws || !currentInteraction) { return } if (value === "cancel" || value === "") { setCurrentInteraction(null) setInteractionInput("") handleCloseModal() return } const response = JSON.stringify({ type: "interaction_response", id: currentInteraction.id, value: value, }) if (terminal.ws.readyState === WebSocket.OPEN) { terminal.ws.send(response) } setCurrentInteraction(null) setInteractionInput("") waitingTimeoutRef.current = setTimeout(() => { setIsWaitingNextInteraction(true) }, 300) } const handleCloseModal = () => { if (terminal.ws && terminal.ws.readyState === WebSocket.OPEN) { terminal.ws.close() } if (checkConnectionInterval.current) { clearInterval(checkConnectionInterval.current) } if (terminal.term) { terminal.term.dispose() } onClose() } const handleResizeStart = (e: React.MouseEvent | React.TouchEvent) => { setIsResizing(true) startYRef.current = "clientY" in e ? e.clientY : e.touches[0].clientY startHeightRef.current = modalHeight document.addEventListener("mousemove", handleResize as any) document.addEventListener("touchmove", handleResize as any) document.addEventListener("mouseup", handleResizeEnd) document.addEventListener("touchend", handleResizeEnd) } const handleResize = (e: MouseEvent | TouchEvent) => { if (!isResizing) return const currentY = e instanceof MouseEvent ? e.clientY : e.touches[0].clientY const deltaY = currentY - startYRef.current const newHeight = startHeightRef.current + (deltaY / window.innerHeight) * 100 setModalHeight(Math.max(50, Math.min(95, newHeight))) } const handleResizeEnd = () => { setIsResizing(false) document.removeEventListener("mousemove", handleResize as any) document.removeEventListener("touchmove", handleResize as any) document.removeEventListener("mouseup", handleResizeEnd) document.removeEventListener("touchend", handleResizeEnd) } return ( <> e.preventDefault()} onEscapeKeyDown={(e) => e.preventDefault()} > {title}
{isComplete && (exitCode === 0 ? ( ) : ( ))}

{title}

{description &&

{description}

}
{isWaitingNextInteraction && !currentInteraction && (

Processing...

)}
{!isMobile && (
)}
{terminal.isConnected ? "Online" : "Offline"}
{currentInteraction && ( e.preventDefault()} onEscapeKeyDown={(e) => e.preventDefault()} hideClose > {currentInteraction.title}

{currentInteraction.message}

{currentInteraction.type === "yesno" && (
)} {currentInteraction.type === "menu" && currentInteraction.options && (
{currentInteraction.options.map((option) => ( ))}
)} {(currentInteraction.type === "input" || currentInteraction.type === "inputbox") && (
setInteractionInput(e.target.value)} onKeyDown={(e) => { if (e.key === "Enter") { handleInteractionResponse(interactionInput) } }} placeholder={currentInteraction.default || ""} />
)} {currentInteraction.type === "msgbox" && (
)}
)} ) }