import { useCallback, useEffect, useMemo, useState } from "react"; import { useNavigate } from "react-router-dom"; import { listProjects } from "../api/projects"; import type { Project } from "../types"; import { listRepositories, type GitRepository } from "../api/git_repositories"; import { getUserSessions, type Session, deleteInstance, stopInstance, checkInstanceHealth, recreateInstanceTunnel, } from "../api/sessions"; import { listToolTypes, type ToolType } from "../api/tool_types"; import { getUserConfig, updateUserConfig } from "../api/settings"; import { Icon } from "../components/icon"; import { CreateSessionForm } from "../components/create-session-form"; type SessionsStatus = "loading" | "ready" | "error"; export const SessionsPage = () => { const navigate = useNavigate(); const [status, setStatus] = useState("loading"); const [sessions, setSessions] = useState([]); const [lastSessionId, setLastSessionId] = useState(null); const [projects, setProjects] = useState([]); const [repositories, setRepositories] = useState([]); const [toolTypes, setToolTypes] = useState([]); const [selectedProject, setSelectedProject] = useState(""); const [dirtyDeleteSession, setDirtyDeleteSession] = useState(null); const [dirtyDeleteFiles, setDirtyDeleteFiles] = useState([]); const [deleteConfirmId, setDeleteConfirmId] = useState(null); const [stopConfirmId, setStopConfirmId] = useState(null); const [tunnelHealth, setTunnelHealth] = useState>({}); const [recreatingId, setRecreatingId] = useState(null); const [expandedProbeId, setExpandedProbeId] = useState(null); const [loadingSessionId, setLoadingSessionId] = useState(null); const [loadingAction, setLoadingAction] = useState(""); const loadSessions = useCallback(async () => { setStatus("loading"); try { const [sessionsData, config] = await Promise.all([ getUserSessions(), getUserConfig(), ]); setSessions(sessionsData); setLastSessionId(config.last_session_id ?? null); setStatus("ready"); } catch { setStatus("error"); } }, []); useEffect(() => { void loadSessions(); }, [loadSessions]); useEffect(() => { const loadProjects = async () => { try { const data = await listProjects(); setProjects(data); } catch { // ignore } }; void loadProjects(); }, []); useEffect(() => { const loadToolTypes = async () => { try { const data = await listToolTypes(); setToolTypes(data); } catch { // ignore } }; void loadToolTypes(); }, []); // Poll health every 30 seconds for active web-enabled instances useEffect(() => { const checkHealth = async () => { const activeSessions = sessions.filter( (s) => ["running", "starting", "unhealthy", "probing"].includes(s.status) && s.tool_type_interfaces?.includes("web") ); for (const session of activeSessions) { try { const health = await checkInstanceHealth( session.project_id, session.repository_id, session.id ); setTunnelHealth((prev) => ({ ...prev, [session.id]: health, })); } catch { setTunnelHealth((prev) => ({ ...prev, [session.id]: { healthy: false, container_status: "unknown", container_health: null, tunnel_status: "unreachable", tunnel_status_code: null, probe_status: "unknown", last_probe_output: null, error: "check failed", }, })); } } }; // Check immediately and then every 30 seconds void checkHealth(); const interval = setInterval(() => void checkHealth(), 30000); return () => clearInterval(interval); }, [sessions]); useEffect(() => { if (!selectedProject) { setRepositories([]); return; } const loadRepos = async () => { try { const data = await listRepositories(selectedProject); setRepositories(data); } catch { setRepositories([]); } }; void loadRepos(); }, [selectedProject]); const activeSessions = useMemo( () => sessions.filter((s) => ["running", "building", "pending", "starting", "probing", "unhealthy"].includes(s.status)), [sessions] ); const recentSessions = useMemo( () => sessions.filter((s) => ["stopped", "error"].includes(s.status)).slice(0, 5), [sessions] ); const lastSession = useMemo( () => sessions.find((s) => s.id === lastSessionId) ?? null, [sessions, lastSessionId] ); const handleCreateSuccess = async (instance: { id: string }) => { await updateUserConfig({ last_session_id: instance.id }); setSelectedProject(""); await loadSessions(); }; const handleStop = async (sessionId: string, projectId: string, repoId: string) => { setLoadingSessionId(sessionId); setLoadingAction("Stopping..."); try { await stopInstance(projectId, repoId, sessionId); setStopConfirmId(null); await loadSessions(); } catch { setStopConfirmId(null); } finally { setLoadingSessionId(null); setLoadingAction(""); } }; const handleDelete = async (sessionId: string, projectId: string, repoId: string, force = false) => { setLoadingSessionId(sessionId); setLoadingAction("Deleting..."); try { await deleteInstance(projectId, repoId, sessionId, force); setDeleteConfirmId(null); setDirtyDeleteSession(null); setDirtyDeleteFiles([]); // Remove from local state immediately setSessions((prev) => prev.filter((s) => s.id !== sessionId)); } catch (error) { const axiosError = error as { response?: { status?: number; data?: { detail?: { changed_files?: string[] } } } }; if (axiosError.response?.status === 409) { const detail = axiosError.response.data?.detail; if (detail?.changed_files) { setDirtyDeleteSession(sessions.find((s) => s.id === sessionId) ?? null); setDirtyDeleteFiles(detail.changed_files); setDeleteConfirmId(null); return; } } setDeleteConfirmId(null); } finally { setLoadingSessionId(null); setLoadingAction(""); } }; const handleRecreateTunnel = async (session: Session) => { setLoadingSessionId(session.id); setLoadingAction("Recreating tunnel..."); try { await recreateInstanceTunnel( session.project_id, session.repository_id, session.id ); // Refresh sessions to get new URL await loadSessions(); } catch { // ignore } finally { setLoadingSessionId(null); setLoadingAction(""); } }; const handleOpen = (session: Session) => { if (session.url) { window.open(session.url, '_blank', 'noopener,noreferrer'); } else if (session.tool_type_interfaces?.includes("terminal")) { navigate(`/instances/${session.id}/terminal`); } else { navigate(`/projects/${session.project_id}`); } }; const handleResumeLast = async () => { if (!lastSession) return; // Find the project and repo IDs const project = projects.find((p) => p.name === lastSession.project_name); if (project) { navigate(`/projects/${project.id}`); } }; return (

Sessions

{status === "loading" &&

Loading sessions...

} {status === "error" && (

Failed to load sessions

)} {status === "ready" && ( <> {/* Last Session */} {lastSession && (

Last Session

{lastSession.display_name}

{lastSession.tool_type_name} · {lastSession.project_name} · {lastSession.repository_name}

{lastSession.url && (

{lastSession.url}

)} {lastSession.status}
{lastSession.url ? ( Open ) : ( )}
)} {/* Active Sessions */}
{loadingSessionId && (

{loadingAction}

)}

Active Sessions {activeSessions.length > 0 && ( {activeSessions.length} )}

{activeSessions.length === 0 ? (

No active sessions

) : (
{activeSessions.map((session) => { const isTerminalOnly = session.tool_type_interfaces?.includes("terminal") && !session.tool_type_interfaces?.includes("web"); return (

{session.display_name}

{session.tool_type_name} · {session.project_name}

{session.created_at && (

Started: {new Date(session.created_at).toLocaleString()}

)} {session.clone_mode && (

Repo: {session.clone_mode === "clone" ? `clone (${session.branch || "main"})` : "mount"}

)} {session.url && (

{session.url}

)} {session.status} {session.status === "starting" && ( starting... )} {session.status === "probing" && ( checking... )} {!isTerminalOnly && tunnelHealth[session.id] && tunnelHealth[session.id].tunnel_status === "unreachable" && ( tunnel error )} {!isTerminalOnly && tunnelHealth[session.id] && tunnelHealth[session.id].tunnel_status === "error_response" && ( app error ({tunnelHealth[session.id].tunnel_status_code}) )} {!isTerminalOnly && tunnelHealth[session.id]?.probe_status && tunnelHealth[session.id]?.probe_status !== "not_applicable" && (
{expandedProbeId === session.id && tunnelHealth[session.id]?.last_probe_output && (
                              {tunnelHealth[session.id].last_probe_output}
                            
)}
)}
{session.url ? ( Open ) : ( )} {!isTerminalOnly && tunnelHealth[session.id] && tunnelHealth[session.id].tunnel_status === "unreachable" && ( )} {stopConfirmId === session.id ? (
Stop?
) : ( )} {deleteConfirmId === session.id ? (
) : ( )}
)})}
)}
{/* Recent Sessions */} {recentSessions.length > 0 && (

Recent Sessions

{recentSessions.map((session) => (
{session.display_name} {session.tool_type_name} · {session.project_name}
{session.url ? ( Open ) : ( )} {deleteConfirmId === session.id ? (
) : ( )}
))}
)} {/* Create Session */}

Create New Session

{ setSelectedProject(projectId); }} onSuccess={handleCreateSuccess} />
{/* Dirty Delete Confirmation Modal */} {dirtyDeleteSession && (
setDirtyDeleteSession(null)}>
e.stopPropagation()}>

Uncommitted Changes

The repository {dirtyDeleteSession.repository_name} has uncommitted changes. Deleting this session will permanently lose these changes.

Changed files:

    {dirtyDeleteFiles.map((file, idx) => (
  • {file}
  • ))}
)} )}
); };