import { useState, useCallback, useEffect, useRef } from "react"; import { useParams, useNavigate } from "react-router"; import { Masthead } from "../components/Masthead"; import { FileList } from "../components/files/FileList"; import { FileDetail } from "../components/files/FileDetail"; import { CliInput } from "../components/files/CliInput"; import { ConflictNotification } from "../components/files/ConflictNotification"; import { UpdateNotification } from "../components/files/UpdateNotification"; import { useFiles } from "../hooks/useFiles"; import { useFileSubscription, type FileUpdateEvent, } from "../hooks/useFileSubscription"; import type { FileDetail as FileDetailType, BodyElement } from "../lib/api"; export default function FilesPage() { const { id } = useParams<{ id: string }>(); const navigate = useNavigate(); const { files, loading, error, conflict, clearConflict, fetchFile, editFile, removeFile, saveFile } = useFiles(); const [fileDetail, setFileDetail] = useState(null); const [detailLoading, setDetailLoading] = useState(false); const [creating, setCreating] = useState(false); const [remoteUpdate, setRemoteUpdate] = useState(null); const [hasLocalChanges, setHasLocalChanges] = useState(false); const pendingUpdateRef = useRef(false); // Load file detail when URL has an id useEffect(() => { if (id) { setDetailLoading(true); setHasLocalChanges(false); fetchFile(id).then((detail) => { setFileDetail(detail); setDetailLoading(false); }); } else { setFileDetail(null); setHasLocalChanges(false); } }, [id, fetchFile]); // Handle file update events from WebSocket const handleFileUpdate = useCallback( async (event: FileUpdateEvent) => { // Ignore our own updates if (pendingUpdateRef.current) { pendingUpdateRef.current = false; return; } // If no local changes, auto-refresh if (!hasLocalChanges) { const detail = await fetchFile(event.fileId); setFileDetail(detail); } else { // Show notification about remote update setRemoteUpdate(event); } }, [hasLocalChanges, fetchFile] ); // Subscribe to file updates useFileSubscription({ fileId: id || null, onUpdate: handleFileUpdate, }); const handleSelectFile = useCallback( (fileId: string) => { navigate(`/files/${fileId}`); }, [navigate] ); const handleBack = useCallback(() => { navigate("/files"); }, [navigate]); const handleDelete = useCallback( async (fileId: string) => { if (confirm("Are you sure you want to delete this file?")) { const success = await removeFile(fileId); if (success && id === fileId) { navigate("/files"); } } }, [removeFile, id, navigate] ); const handleSave = useCallback( async (fileId: string, name: string, description: string) => { if (!fileDetail) return; pendingUpdateRef.current = true; const result = await editFile(fileId, { name, description, version: fileDetail.version }); if (result) { setFileDetail(result); setHasLocalChanges(false); } }, [editFile, fileDetail] ); const handleBodyUpdate = useCallback( (body: BodyElement[], summary: string | null) => { if (fileDetail) { setFileDetail({ ...fileDetail, body, summary, }); } }, [fileDetail] ); const handleBodyElementUpdate = useCallback( async (index: number, element: BodyElement) => { if (fileDetail && id) { // Create new body array with updated element const newBody = [...fileDetail.body]; newBody[index] = element; // Update local state immediately for responsiveness setFileDetail({ ...fileDetail, body: newBody, }); setHasLocalChanges(true); // Save to backend with version for optimistic locking pendingUpdateRef.current = true; const result = await editFile(id, { body: newBody, version: fileDetail.version }); if (result) { setFileDetail(result); setHasLocalChanges(false); } } }, [fileDetail, id, editFile] ); const handleBodyReorder = useCallback( async (fromIndex: number, toIndex: number) => { if (fileDetail && id) { // Create new body array with reordered elements const newBody = [...fileDetail.body]; const [movedElement] = newBody.splice(fromIndex, 1); newBody.splice(toIndex, 0, movedElement); // Update local state immediately for responsiveness setFileDetail({ ...fileDetail, body: newBody, }); setHasLocalChanges(true); // Save to backend with version for optimistic locking pendingUpdateRef.current = true; const result = await editFile(id, { body: newBody, version: fileDetail.version }); if (result) { setFileDetail(result); setHasLocalChanges(false); } } }, [fileDetail, id, editFile] ); const handleCreate = useCallback(async () => { if (creating) return; setCreating(true); try { const newFile = await saveFile({ name: `Untitled ${new Date().toLocaleDateString()}`, transcript: [], }); if (newFile) { navigate(`/files/${newFile.id}`); } } finally { setCreating(false); } }, [creating, saveFile, navigate]); // Conflict resolution handlers const handleConflictReload = useCallback(async () => { if (id) { clearConflict(); const detail = await fetchFile(id); setFileDetail(detail); setHasLocalChanges(false); } }, [id, clearConflict, fetchFile]); const handleConflictForceOverwrite = useCallback(async () => { if (id && fileDetail) { clearConflict(); // Fetch latest version first const latest = await fetchFile(id); if (latest) { // Retry with latest version pendingUpdateRef.current = true; const result = await editFile(id, { body: fileDetail.body, version: latest.version }); if (result) { setFileDetail(result); setHasLocalChanges(false); } } } }, [id, fileDetail, clearConflict, fetchFile, editFile]); // Remote update handlers const handleRemoteUpdateRefresh = useCallback(async () => { if (id) { const detail = await fetchFile(id); setFileDetail(detail); setRemoteUpdate(null); setHasLocalChanges(false); } }, [id, fetchFile]); const handleRemoteUpdateDismiss = useCallback(() => { setRemoteUpdate(null); }, []); return (
{error && (
{error}
)} {id && fileDetail ? (
) : id && detailLoading ? (
Loading...
) : ( )}
{/* Conflict notification */} {conflict?.hasConflict && ( )} {/* Remote update notification */} {remoteUpdate && ( )}
); }