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, type FocusedElement } from "../components/files/FileDetail";
import { ConflictNotification } from "../components/files/ConflictNotification";
import { UpdateNotification } from "../components/files/UpdateNotification";
import { useFiles } from "../hooks/useFiles";
import { useVersionHistory } from "../hooks/useVersionHistory";
import {
useFileSubscription,
type FileUpdateEvent,
} from "../hooks/useFileSubscription";
import type { FileDetail as FileDetailType, BodyElement, Task, ContractSummary } from "../lib/api";
import { createTask, listContracts } from "../lib/api";
import { useAuth } from "../contexts/AuthContext";
export default function FilesPage() {
const { isAuthenticated, isAuthConfigured, isLoading: authLoading } = useAuth();
const navigate = useNavigate();
// Redirect to login if not authenticated (when auth is configured)
useEffect(() => {
if (!authLoading && isAuthConfigured && !isAuthenticated) {
navigate("/login");
}
}, [authLoading, isAuthConfigured, isAuthenticated, navigate]);
// Show loading while checking auth
if (authLoading) {
return (
Loading...
);
}
// Don't render if not authenticated (will redirect)
if (isAuthConfigured && !isAuthenticated) {
return null;
}
return ;
}
function FilesPageContent() {
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 [remoteFileData, setRemoteFileData] = useState(null);
const [focusedElement, setFocusedElement] = useState(null);
const [createdTask, setCreatedTask] = useState(null);
// Contract selection modal state for task creation
const [showContractModal, setShowContractModal] = useState(false);
const [contracts, setContracts] = useState([]);
const [contractsLoading, setContractsLoading] = useState(false);
const [pendingTaskData, setPendingTaskData] = useState<{ name: string; plan: string } | null>(null);
// Contract selection modal state for file creation
const [showFileContractModal, setShowFileContractModal] = useState(false);
const [pendingFileData, setPendingFileData] = useState<{ name: string; body?: BodyElement[] } | null>(null);
const pendingUpdateRef = useRef(false);
// Track the last version we sent to detect our own updates
const lastSentVersionRef = useRef(null);
// Track the version we just successfully saved (to ignore its WebSocket notification)
const lastSavedVersionRef = useRef(null);
// Use refs for values checked in WebSocket callback to avoid stale closures
const hasLocalChangesRef = useRef(false);
const isActivelyEditingRef = useRef(false);
const currentVersionRef = useRef(null);
// Helper functions to update refs (used only in callbacks, not for rendering)
const updateHasLocalChanges = useCallback((value: boolean) => {
hasLocalChangesRef.current = value;
}, []);
const updateIsActivelyEditing = useCallback((value: boolean) => {
isActivelyEditingRef.current = value;
}, []);
// Version history
const {
versions,
loading: versionsLoading,
selectedVersion,
loadingVersion,
restoring,
fetchVersion,
restoreToVersion,
clearSelectedVersion,
fetchVersions,
} = useVersionHistory({
fileId: id || null,
currentVersion: fileDetail?.version || 0,
});
// Handle version restore
const handleRestoreVersion = useCallback(
async (targetVersion: number) => {
const result = await restoreToVersion(targetVersion);
if (result) {
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
// Refresh version list after restore
fetchVersions();
}
},
[restoreToVersion, fetchVersions, updateHasLocalChanges]
);
// Load file detail when URL has an id
useEffect(() => {
if (id) {
setDetailLoading(true);
updateHasLocalChanges(false);
// Reset pending update tracking when switching files
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
lastSavedVersionRef.current = null;
currentVersionRef.current = null;
setRemoteUpdate(null);
setRemoteFileData(null);
setFocusedElement(null);
fetchFile(id).then((detail) => {
if (detail) {
currentVersionRef.current = detail.version;
}
setFileDetail(detail);
setDetailLoading(false);
});
} else {
setFileDetail(null);
currentVersionRef.current = null;
updateHasLocalChanges(false);
}
}, [id, fetchFile, updateHasLocalChanges]);
// Handle file update events from WebSocket
const handleFileUpdate = useCallback(
async (event: FileUpdateEvent) => {
// Check if this is a version we just saved - ignore it
// This handles the case where the WebSocket arrives after the HTTP response
if (lastSavedVersionRef.current !== null && event.version === lastSavedVersionRef.current) {
lastSavedVersionRef.current = null;
return;
}
// If we have a pending update, check if this is our own update
if (pendingUpdateRef.current) {
if (lastSentVersionRef.current !== null) {
const expectedNewVersion = lastSentVersionRef.current + 1;
if (event.version === expectedNewVersion) {
// This is our own update - ignore it
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
return;
}
}
// We sent an update but received a different version - could be a race condition
// Still ignore since we have an update in flight
return;
}
// Check if this version matches what we already have
// This catches cases where our save's WebSocket arrives late
if (currentVersionRef.current !== null && event.version === currentVersionRef.current) {
return;
}
// If no local changes and not actively editing, auto-refresh
// Use refs to get current values (avoid stale closure issues)
if (!hasLocalChangesRef.current && !isActivelyEditingRef.current) {
const detail = await fetchFile(event.fileId);
if (detail) {
currentVersionRef.current = detail.version;
}
setFileDetail(detail);
} else {
// Fetch remote version for diff display
const remoteData = await fetchFile(event.fileId);
setRemoteFileData(remoteData);
// Show notification about remote update
setRemoteUpdate(event);
}
},
[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;
lastSentVersionRef.current = fileDetail.version;
try {
const result = await editFile(fileId, { name, description, version: fileDetail.version });
if (result) {
// Track the saved version to ignore its WebSocket notification
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
},
[editFile, fileDetail, updateHasLocalChanges]
);
// handleBodyUpdate was the CliInput callback for AI-driven body
// rewrites. CliInput is gone with the LLM module.
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,
});
updateHasLocalChanges(true);
// Save to backend with version for optimistic locking
pendingUpdateRef.current = true;
lastSentVersionRef.current = fileDetail.version;
try {
const result = await editFile(id, { body: newBody, version: fileDetail.version });
if (result) {
// Track the saved version to ignore its WebSocket notification
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
}
},
[fileDetail, id, editFile, updateHasLocalChanges]
);
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,
});
updateHasLocalChanges(true);
// Save to backend with version for optimistic locking
pendingUpdateRef.current = true;
lastSentVersionRef.current = fileDetail.version;
try {
const result = await editFile(id, { body: newBody, version: fileDetail.version });
if (result) {
// Track the saved version to ignore its WebSocket notification
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
}
},
[fileDetail, id, editFile, updateHasLocalChanges]
);
// Element action handlers for context menu
const handleBodyElementDelete = useCallback(
async (index: number) => {
if (fileDetail && id) {
const newBody = fileDetail.body.filter((_, i) => i !== index);
// Update local state immediately
setFileDetail({
...fileDetail,
body: newBody,
});
updateHasLocalChanges(true);
// Clear focus if deleting focused element
if (focusedElement?.index === index) {
setFocusedElement(null);
} else if (focusedElement && focusedElement.index > index) {
// Adjust focus index if deleting an element before it
setFocusedElement({
...focusedElement,
index: focusedElement.index - 1,
});
}
// Save to backend
pendingUpdateRef.current = true;
lastSentVersionRef.current = fileDetail.version;
try {
const result = await editFile(id, { body: newBody, version: fileDetail.version });
if (result) {
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
}
},
[fileDetail, id, editFile, updateHasLocalChanges, focusedElement]
);
const handleBodyElementDuplicate = useCallback(
async (index: number) => {
if (fileDetail && id) {
const elementToDuplicate = fileDetail.body[index];
if (!elementToDuplicate) return;
const newBody = [...fileDetail.body];
// Insert duplicate after the original
newBody.splice(index + 1, 0, { ...elementToDuplicate });
// Update local state immediately
setFileDetail({
...fileDetail,
body: newBody,
});
updateHasLocalChanges(true);
// Adjust focus index if duplicating before focused element
if (focusedElement && focusedElement.index > index) {
setFocusedElement({
...focusedElement,
index: focusedElement.index + 1,
});
}
// Save to backend
pendingUpdateRef.current = true;
lastSentVersionRef.current = fileDetail.version;
try {
const result = await editFile(id, { body: newBody, version: fileDetail.version });
if (result) {
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
}
},
[fileDetail, id, editFile, updateHasLocalChanges, focusedElement]
);
const handleFocusElement = useCallback((element: FocusedElement | null) => {
setFocusedElement(element);
}, []);
// handleClearFocus was passed to CliInput; both gone now.
// Convert element to a different type
const handleConvertElement = useCallback(
async (index: number, toType: string) => {
if (!fileDetail || !id) return;
const element = fileDetail.body[index];
if (!element) return;
// Extract text content from current element
let textContent = "";
switch (element.type) {
case "heading":
case "paragraph":
textContent = element.text;
break;
case "code":
textContent = element.content;
break;
case "list":
textContent = element.items.join("\n");
break;
default:
return; // Can't convert charts/images
}
// Create new element based on target type
let newElement: BodyElement;
if (toType === "paragraph") {
newElement = { type: "paragraph", text: textContent };
} else if (toType === "list_unordered") {
const items = textContent.split("\n").filter(line => line.trim());
newElement = { type: "list", ordered: false, items };
} else if (toType === "list_ordered") {
const items = textContent.split("\n").filter(line => line.trim());
newElement = { type: "list", ordered: true, items };
} else if (toType === "code") {
newElement = { type: "code", content: textContent };
} else if (toType.startsWith("heading_")) {
const level = parseInt(toType.replace("heading_", ""), 10) as 1 | 2 | 3 | 4 | 5 | 6;
newElement = { type: "heading", level, text: textContent };
} else {
return; // Unknown type
}
const newBody = [...fileDetail.body];
newBody[index] = newElement;
// Update local state
setFileDetail({ ...fileDetail, body: newBody });
updateHasLocalChanges(true);
// Update focus if this element was focused
if (focusedElement?.index === index) {
setFocusedElement({
index,
type: newElement.type,
preview: textContent.slice(0, 50) + (textContent.length > 50 ? "..." : ""),
});
}
// Save to backend
pendingUpdateRef.current = true;
lastSentVersionRef.current = fileDetail.version;
try {
const result = await editFile(id, { body: newBody, version: fileDetail.version });
if (result) {
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
},
[fileDetail, id, editFile, updateHasLocalChanges, focusedElement]
);
// handleGenerateFromElement was an LLM elaborate/summarise/extract
// affordance that piped a suggested prompt into CliInput. Both
// CliInput and the LLM module are gone; the handler + its prop on
// FileDetail are removed.
// Create a mesh task from an element - shows contract selection modal
const handleCreateTaskFromElement = useCallback(
async (index: number, selectedText?: string) => {
if (!fileDetail || contractsLoading) return;
const element = fileDetail.body[index];
if (!element) return;
// Get the content to use as task plan
let content = selectedText || "";
if (!content) {
switch (element.type) {
case "heading":
case "paragraph":
content = element.text;
break;
case "code":
content = element.content;
break;
case "list":
content = element.items.join("\n");
break;
default:
content = "Task from file element";
}
}
// Create a task name from the content
const name = content.slice(0, 60) + (content.length > 60 ? "..." : "");
// Store pending task data and show contract selection modal
setPendingTaskData({ name, plan: content });
setContractsLoading(true);
try {
const response = await listContracts();
setContracts(response.contracts);
setShowContractModal(true);
} catch (e) {
console.error("Failed to load contracts:", e);
} finally {
setContractsLoading(false);
}
},
[fileDetail, contractsLoading]
);
// Create task with selected contract
const handleCreateTaskWithContract = useCallback(
async (contractId: string) => {
if (!pendingTaskData || !fileDetail) return;
setShowContractModal(false);
try {
const task = await createTask({
contractId,
name: pendingTaskData.name,
plan: pendingTaskData.plan,
description: `Created from ${fileDetail.name}`,
});
setCreatedTask(task);
setPendingTaskData(null);
} catch (err) {
console.error("Failed to create task:", err);
}
},
[pendingTaskData, fileDetail]
);
// Open contract selection modal for file creation
const handleCreate = useCallback(async () => {
if (creating || contractsLoading) return;
setContractsLoading(true);
try {
const response = await listContracts();
setContracts(response.contracts);
setPendingFileData({ name: `Untitled ${new Date().toLocaleDateString()}` });
setShowFileContractModal(true);
} catch (e) {
console.error("Failed to load contracts:", e);
} finally {
setContractsLoading(false);
}
}, [creating, contractsLoading]);
// Create file with selected contract
const handleCreateFileWithContract = useCallback(async (contractId: string) => {
if (creating || !pendingFileData) return;
setShowFileContractModal(false);
setCreating(true);
try {
const newFile = await saveFile({
contractId,
name: pendingFileData.name,
body: pendingFileData.body,
transcript: [],
});
if (newFile) {
// If there's body content, update it
if (pendingFileData.body && pendingFileData.body.length > 0) {
await editFile(newFile.id, { body: pendingFileData.body, version: newFile.version });
}
navigate(`/files/${newFile.id}`);
}
} finally {
setCreating(false);
setPendingFileData(null);
}
}, [creating, pendingFileData, saveFile, editFile, navigate]);
const handleUploadMarkdown = useCallback(async (name: string, body: BodyElement[]) => {
if (creating || contractsLoading) return;
setContractsLoading(true);
try {
const response = await listContracts();
setContracts(response.contracts);
setPendingFileData({ name, body });
setShowFileContractModal(true);
} catch (e) {
console.error("Failed to load contracts:", e);
} finally {
setContractsLoading(false);
}
}, [creating, contractsLoading]);
// Conflict resolution handlers
const handleConflictReload = useCallback(async () => {
if (id) {
clearConflict();
const detail = await fetchFile(id);
if (detail) {
currentVersionRef.current = detail.version;
}
setFileDetail(detail);
updateHasLocalChanges(false);
}
}, [id, clearConflict, fetchFile, updateHasLocalChanges]);
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;
lastSentVersionRef.current = latest.version;
try {
const result = await editFile(id, { body: fileDetail.body, version: latest.version });
if (result) {
// Track the saved version to ignore its WebSocket notification
lastSavedVersionRef.current = result.version;
currentVersionRef.current = result.version;
setFileDetail(result);
updateHasLocalChanges(false);
}
} finally {
pendingUpdateRef.current = false;
lastSentVersionRef.current = null;
}
}
}
}, [id, fileDetail, clearConflict, fetchFile, editFile, updateHasLocalChanges]);
// Remote update handlers
const handleRemoteUpdateRefresh = useCallback(async () => {
if (id) {
const detail = await fetchFile(id);
if (detail) {
currentVersionRef.current = detail.version;
}
setFileDetail(detail);
setRemoteUpdate(null);
setRemoteFileData(null);
updateHasLocalChanges(false);
}
}, [id, fetchFile, updateHasLocalChanges]);
const handleRemoteUpdateDismiss = useCallback(() => {
setRemoteUpdate(null);
setRemoteFileData(null);
}, []);
return (
{error && (
{error}
)}
{id && fileDetail ? (
{/* CliInput (file-level LLM chat) removed alongside the LLM
module. The file detail view is now a pure read/edit
surface; AI-driven file editing was the primary value of
this composer and went with the LLM removal. */}