import { Download, Redo, Trash2 } from "lucide-react"; import { useRef, useState } from "react"; import { ProgressCard } from "@/components/common/progress-card"; import { useTranslation } from "@/contexts/i18n-context"; import { formatHeaders } from "@/lib/api"; import { format } from "@/lib/format"; import { generateId } from "@/lib/utils"; import { useFileStore } from "@/stores/file-store"; import type { EraserCanvasRef } from "./eraser-canvas"; const OUTPUT_FORMATS = [ "png", "jpg", "webp", "avif", "tiff", "gif", "heic", "heif", "jxl", ] as const; const LOSSY_FORMATS = ["jpg", "jpeg", "webp", "avif", "heic", "heif", "jxl"]; interface EraseObjectSettingsProps { eraserRef: React.RefObject; hasStrokes: boolean; brushSize: number; onBrushSizeChange: (size: number) => void; onMaskCenter?: (centerPct: number) => void; maskedFileCount: number; } export function EraseObjectSettings({ eraserRef, hasStrokes, brushSize, onBrushSizeChange: setBrushSize, onMaskCenter, maskedFileCount, }: EraseObjectSettingsProps) { const { t } = useTranslation(); const { files, entries, selectedIndex, processing, error, setProcessing, setError, currentEntry, } = useFileStore(); const [progressPhase, setProgressPhase] = useState<"idle" | "uploading" | "processing">("idle"); const [progressPercent, setProgressPercent] = useState(0); const [progressStage, setProgressStage] = useState(null); const [elapsed, setElapsed] = useState(0); const elapsedRef = useRef | null>(null); const [outputFormat, setOutputFormat] = useState("png"); const [quality, setQuality] = useState(95); const processOneFile = ( entryIndex: number, file: File, maskBlob: Blob, onProgress: (percent: number) => void, ): Promise => { return new Promise((resolve, reject) => { const clientJobId = generateId(); let asyncMode = false; const es = new EventSource(`/api/v1/jobs/${clientJobId}/progress`); es.onmessage = (event) => { try { const data = JSON.parse(event.data); if (data.type !== "single") return; if (data.phase === "complete" && data.result) { es.close(); const r = data.result; useFileStore.getState().updateEntry(entryIndex, { processedUrl: r.downloadUrl, processedPreviewUrl: r.previewUrl ?? null, processedFilename: null, status: "completed", originalSize: r.originalSize, processedSize: r.processedSize, }); resolve(); return; } if (data.phase === "failed" && asyncMode) { es.close(); reject(new Error(data.error || "Processing failed")); return; } if (typeof data.percent === "number") { onProgress(data.percent); } } catch {} }; es.onerror = () => { if (!asyncMode) es.close(); }; const maskFile = new File([maskBlob], "mask.png", { type: "image/png" }); const formData = new FormData(); formData.append("file", file); formData.append("mask", maskFile); formData.append("clientJobId", clientJobId); formData.append("format", outputFormat); formData.append("quality", String(quality)); const xhr = new XMLHttpRequest(); xhr.timeout = 600_000; xhr.onload = () => { if (xhr.status === 202) { asyncMode = true; return; } es.close(); if (xhr.status >= 200 && xhr.status < 300) { try { const data = JSON.parse(xhr.responseText); useFileStore.getState().updateEntry(entryIndex, { processedUrl: data.downloadUrl, processedPreviewUrl: data.previewUrl ?? null, processedFilename: null, status: "completed", originalSize: data.originalSize, processedSize: data.processedSize, }); resolve(); } catch { reject(new Error("Invalid response")); } } else { try { const body = JSON.parse(xhr.responseText); reject( new Error( typeof body.error === "string" ? body.error : typeof body.details === "string" ? body.details : `Failed: ${xhr.status}`, ), ); } catch { reject(new Error(`Processing failed: ${xhr.status}`)); } } }; xhr.onerror = () => { es.close(); reject(new Error("Network error")); }; xhr.ontimeout = () => { es.close(); reject(new Error("Request timed out")); }; xhr.open("POST", "/api/v1/tools/erase-object"); for (const [key, value] of formatHeaders()) { xhr.setRequestHeader(key, value); } xhr.send(formData); }); }; const handleProcess = async () => { if (files.length === 0 || !eraserRef.current) return; const capturedIndex = useFileStore.getState().selectedIndex; const maskBlob = await eraserRef.current.exportMask(); if (!maskBlob) return; // Record where the user painted so the comparison slider starts at that location const maskCenter = eraserRef.current.getMaskCenter(); if (maskCenter !== null && onMaskCenter) { onMaskCenter(maskCenter); } setError(null); setProcessing(true); setProgressPhase("uploading"); setProgressPercent(0); setElapsed(0); const startTime = Date.now(); elapsedRef.current = setInterval(() => { setElapsed(Math.floor((Date.now() - startTime) / 1000)); }, 1000); const clientJobId = generateId(); let asyncMode = false; const es = new EventSource(`/api/v1/jobs/${clientJobId}/progress`); es.onmessage = (event) => { try { const data = JSON.parse(event.data); if (data.type !== "single") return; if (data.phase === "complete" && data.result) { if (elapsedRef.current) clearInterval(elapsedRef.current); es.close(); const r = data.result; useFileStore.getState().updateEntry(capturedIndex, { processedUrl: r.downloadUrl, processedPreviewUrl: r.previewUrl ?? null, processedFilename: null, status: "completed", originalSize: r.originalSize, processedSize: r.processedSize, }); setProcessing(false); setProgressPhase("idle"); setProgressStage(null); return; } if (data.phase === "failed" && asyncMode) { if (elapsedRef.current) clearInterval(elapsedRef.current); es.close(); setError(data.error || "Processing failed"); setProcessing(false); setProgressPhase("idle"); return; } if (typeof data.percent === "number") { setProgressPhase("processing"); setProgressPercent(15 + (data.percent / 100) * 85); } } catch {} }; es.onerror = () => { if (!asyncMode) es.close(); }; const maskFile = new File([maskBlob], "mask.png", { type: "image/png" }); const formData = new FormData(); formData.append("file", entries[capturedIndex].file); formData.append("mask", maskFile); formData.append("clientJobId", clientJobId); formData.append("format", outputFormat); formData.append("quality", String(quality)); const xhr = new XMLHttpRequest(); xhr.timeout = 600_000; xhr.upload.onprogress = (e) => { if (e.lengthComputable) { setProgressPercent((e.loaded / e.total) * 15); } }; xhr.upload.onload = () => { setProgressPhase("processing"); setProgressPercent(15); }; xhr.onload = () => { if (xhr.status === 202) { asyncMode = true; return; } if (elapsedRef.current) clearInterval(elapsedRef.current); es.close(); if (xhr.status >= 200 && xhr.status < 300) { try { const data = JSON.parse(xhr.responseText); useFileStore.getState().updateEntry(capturedIndex, { processedUrl: data.downloadUrl, processedPreviewUrl: data.previewUrl ?? null, processedFilename: null, status: "completed", originalSize: data.originalSize, processedSize: data.processedSize, }); } catch { setError("Invalid response"); } } else { try { const body = JSON.parse(xhr.responseText); setError( typeof body.error === "string" ? body.error : typeof body.details === "string" ? body.details : `Failed: ${xhr.status}`, ); } catch { setError(`Processing failed: ${xhr.status}`); } } setProcessing(false); setProgressPhase("idle"); setProgressStage(null); }; xhr.onerror = () => { if (elapsedRef.current) clearInterval(elapsedRef.current); es.close(); setError("Network error"); setProcessing(false); setProgressPhase("idle"); }; xhr.ontimeout = () => { if (elapsedRef.current) clearInterval(elapsedRef.current); es.close(); setError("Request timed out - the server may be overloaded. Try again."); setProcessing(false); setProgressPhase("idle"); }; xhr.open("POST", "/api/v1/tools/erase-object"); formatHeaders().forEach((value, key) => { xhr.setRequestHeader(key, value); }); xhr.send(formData); }; const handleProcessAll = async () => { if (!eraserRef.current) return; const masks = await eraserRef.current.exportAllMasks(); if (masks.size === 0) return; const { entries: currentEntries } = useFileStore.getState(); // Map blobUrl -> entry index const blobToIndex = new Map(); for (let i = 0; i < currentEntries.length; i++) { blobToIndex.set(currentEntries[i].blobUrl, i); } const work: { index: number; file: File; maskBlob: Blob }[] = []; for (const [blobUrl, maskBlob] of masks) { const idx = blobToIndex.get(blobUrl); if (idx !== undefined) { work.push({ index: idx, file: currentEntries[idx].file, maskBlob }); } } if (work.length === 0) return; setError(null); setProcessing(true); setProgressPhase("uploading"); setProgressPercent(0); setElapsed(0); const startTime = Date.now(); elapsedRef.current = setInterval(() => { setElapsed(Math.floor((Date.now() - startTime) / 1000)); }, 1000); for (let wi = 0; wi < work.length; wi++) { const { index, file, maskBlob } = work[wi]; const basePercent = (wi / work.length) * 100; const sliceWeight = 100 / work.length; setProgressPhase("processing"); setProgressPercent(basePercent); setProgressStage(`Erasing ${wi + 1}/${work.length}`); useFileStore.getState().updateEntry(index, { status: "processing", error: null }); try { await processOneFile(index, file, maskBlob, (pct) => { setProgressPercent(basePercent + (pct / 100) * sliceWeight); }); } catch (err) { useFileStore.getState().updateEntry(index, { status: "failed", error: err instanceof Error ? err.message : "Processing failed", }); } } if (elapsedRef.current) clearInterval(elapsedRef.current); setProcessing(false); setProgressPhase("idle"); setProgressStage(null); }; const hasFile = files.length > 0; return (
{/* Brush size */}
{brushSize}px
setBrushSize(Number(e.target.value))} className="w-full mt-1" />
{t.toolSettings["erase-object"].fine} {t.toolSettings["erase-object"].wide}
{/* Clear / Undo */} {hasStrokes && (
)} {/* Output Format */}
{/* Quality (lossy formats only) */} {LOSSY_FORMATS.includes(outputFormat) && (
{quality}
setQuality(Number(e.target.value))} className="w-full mt-1" />
)} {/* Hint */} {hasFile && !hasStrokes && (

Paint over the objects you want to remove. Use Ctrl+Z to undo.

)} {/* Error */} {error &&

{error}

} {/* Size info */} {currentEntry?.originalSize != null && currentEntry?.processedSize != null && currentEntry?.status === "completed" && (

Original: {(currentEntry.originalSize / 1024).toFixed(1)} KB

Processed: {(currentEntry.processedSize / 1024).toFixed(1)} KB

)} {/* Process button */} {processing ? ( ) : ( )} {/* Download */} {currentEntry?.processedUrl && ( Download )}
); }