fix: terminal shift-left bug and session sidebar naming/filtering

- Guard ResizeObserver in terminal against internal xterm DOM changes
  by tracking last width/height and only calling fit() on real resize
- Remove padding from .terminal-container and conflicting .xterm height
  override that caused measurement mismatches with xterm-addon-fit
- Filter live session sidebar to active statuses only (running, building,
  pending) instead of showing all sessions including stopped ones
- Add display name fallback across sidebar, sessions page, and instance
  list to prevent blank names when display_name is empty

Quality gates: tsc (pass), eslint (pass)

.gitignore

@@ -48,3 +48,8 @@ apps/web/dist/
 # OS
 .DS_Store
 Thumbs.db
+
+# Local runtime state
+.atl/
+.pi/
+swap-pane

CHANGELOG.md

@@ -21,6 +21,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - **User Settings** - Theme selection, git identity, and preference management
 - **SSH Key Management** - Ed25519 key generation with secure storage
 - **Tool Types** - Built-in development tools (code-server, jupyter-notebook) with custom type support
+- **Config Profiles** - User-owned profile CRUD with includes, mounts, path validation, cycle detection, and default profile selection
 - **Comprehensive Documentation** - Architecture, API, deployment, and development guides
 
 ### Changed

apps/api/alembic/versions/0013_add_config_profiles.py

@@ -0,0 +1,104 @@
+"""add config profiles, includes, mounts, and tool instance profile selection
+
+Revision ID: 0013_add_config_profiles
+Revises: 0012_default_port_req
+Create Date: 2026-05-24 12:00:00.000000
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision: str = "0013_add_config_profiles"
+down_revision: Union[str, None] = "0012_default_port_req"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    # Create config_profiles table
+    op.create_table(
+        "config_profiles",
+        sa.Column("id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("user_id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("name", sa.String(length=255), nullable=False),
+        sa.Column("description", sa.Text(), nullable=True),
+        sa.Column("created_at", sa.DateTime(timezone=True), server_default=sa.text("NOW()"), nullable=False),
+        sa.Column("updated_at", sa.DateTime(timezone=True), server_default=sa.text("NOW()"), nullable=False),
+        sa.ForeignKeyConstraint(["user_id"], ["users.id"], ondelete="CASCADE"),
+        sa.PrimaryKeyConstraint("id"),
+        sa.UniqueConstraint("user_id", "name", name="uq_config_profiles_user_name"),
+    )
+    op.create_index("idx_config_profiles_user", "config_profiles", ["user_id"])
+
+    # Create config_includes table
+    op.create_table(
+        "config_includes",
+        sa.Column("id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("profile_id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("included_profile_id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("order_index", sa.Integer(), nullable=False, server_default="0"),
+        sa.Column("created_at", sa.DateTime(timezone=True), server_default=sa.text("NOW()"), nullable=False),
+        sa.Column("updated_at", sa.DateTime(timezone=True), server_default=sa.text("NOW()"), nullable=False),
+        sa.ForeignKeyConstraint(["profile_id"], ["config_profiles.id"], ondelete="CASCADE"),
+        sa.ForeignKeyConstraint(["included_profile_id"], ["config_profiles.id"], ondelete="CASCADE"),
+        sa.PrimaryKeyConstraint("id"),
+        sa.UniqueConstraint("profile_id", "included_profile_id", name="uq_config_includes_pair"),
+    )
+    op.create_index("idx_config_includes_profile", "config_includes", ["profile_id"])
+    op.create_index("idx_config_includes_included", "config_includes", ["included_profile_id"])
+
+    # Create config_mounts table
+    op.create_table(
+        "config_mounts",
+        sa.Column("id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("profile_id", postgresql.UUID(as_uuid=True), nullable=False),
+        sa.Column("mount_path", sa.String(length=1024), nullable=False),
+        sa.Column("content", sa.Text(), nullable=True),
+        sa.Column("source_profile_id", postgresql.UUID(as_uuid=True), nullable=True),
+        sa.Column("order_index", sa.Integer(), nullable=False, server_default="0"),
+        sa.Column("created_at", sa.DateTime(timezone=True), server_default=sa.text("NOW()"), nullable=False),
+        sa.Column("updated_at", sa.DateTime(timezone=True), server_default=sa.text("NOW()"), nullable=False),
+        sa.ForeignKeyConstraint(["profile_id"], ["config_profiles.id"], ondelete="CASCADE"),
+        sa.ForeignKeyConstraint(["source_profile_id"], ["config_profiles.id"], ondelete="SET NULL"),
+        sa.PrimaryKeyConstraint("id"),
+    )
+    op.create_index("idx_config_mounts_profile", "config_mounts", ["profile_id"])
+
+    # Add selected_profile_id to tool_instances
+    op.add_column(
+        "tool_instances",
+        sa.Column("selected_profile_id", postgresql.UUID(as_uuid=True), nullable=True),
+    )
+    op.create_foreign_key(
+        "fk_tool_instances_selected_profile",
+        "tool_instances",
+        "config_profiles",
+        ["selected_profile_id"],
+        ["id"],
+        ondelete="SET NULL",
+    )
+    op.create_index("idx_tool_instances_selected_profile", "tool_instances", ["selected_profile_id"])
+
+
+def downgrade() -> None:
+    # Remove selected_profile_id from tool_instances
+    op.drop_index("idx_tool_instances_selected_profile", table_name="tool_instances")
+    op.drop_constraint("fk_tool_instances_selected_profile", "tool_instances", type_="foreignkey")
+    op.drop_column("tool_instances", "selected_profile_id")
+
+    # Drop config_mounts
+    op.drop_index("idx_config_mounts_profile", table_name="config_mounts")
+    op.drop_table("config_mounts")
+
+    # Drop config_includes
+    op.drop_index("idx_config_includes_included", table_name="config_includes")
+    op.drop_index("idx_config_includes_profile", table_name="config_includes")
+    op.drop_table("config_includes")
+
+    # Drop config_profiles
+    op.drop_index("idx_config_profiles_user", table_name="config_profiles")
+    op.drop_table("config_profiles")

apps/api/alembic/versions/0014_add_profile_resolver_fields.py

@@ -0,0 +1,119 @@
+"""add profile resolver fields to config profiles and mounts
+
+Revision ID: 0014_add_profile_resolver_fields
+Revises: 0013_add_config_profiles
+Create Date: 2026-05-24 14:00:00.000000
+
+"""
+from typing import Sequence, Union
+
+from alembic import op
+import sqlalchemy as sa
+from sqlalchemy.dialects import postgresql
+
+# revision identifiers, used by Alembic.
+revision: str = "0014_add_profile_resolver_fields"
+down_revision: Union[str, None] = "0013_add_config_profiles"
+branch_labels: Union[str, Sequence[str], None] = None
+depends_on: Union[str, Sequence[str], None] = None
+
+
+def upgrade() -> None:
+    # Add fields to config_profiles
+    op.add_column(
+        "config_profiles",
+        sa.Column("project_id", postgresql.UUID(as_uuid=True), nullable=True),
+    )
+    op.add_column(
+        "config_profiles",
+        sa.Column("tool_type_id", postgresql.UUID(as_uuid=True), nullable=True),
+    )
+    op.add_column(
+        "config_profiles",
+        sa.Column("environment_variables", sa.JSON(), nullable=True),
+    )
+    op.add_column(
+        "config_profiles",
+        sa.Column("start_command", sa.Text(), nullable=True),
+    )
+    op.add_column(
+        "config_profiles",
+        sa.Column("working_directory", sa.Text(), nullable=True),
+    )
+    op.add_column(
+        "config_profiles",
+        sa.Column("port", sa.Integer(), nullable=True),
+    )
+    op.add_column(
+        "config_profiles",
+        sa.Column("is_default", sa.Boolean(), nullable=False, server_default="false"),
+    )
+    
+    # Add foreign keys for project and tool_type
+    op.create_foreign_key(
+        "fk_config_profiles_project",
+        "config_profiles",
+        "projects",
+        ["project_id"],
+        ["id"],
+        ondelete="CASCADE",
+    )
+    op.create_foreign_key(
+        "fk_config_profiles_tool_type",
+        "config_profiles",
+        "tool_types",
+        ["tool_type_id"],
+        ["id"],
+        ondelete="CASCADE",
+    )
+    
+    # Create indices
+    op.create_index("idx_config_profiles_project", "config_profiles", ["project_id"])
+    op.create_index("idx_config_profiles_tool_type", "config_profiles", ["tool_type_id"])
+    
+    # Alter config_mounts: rename mount_path to target_path, add mode, change content to files JSON
+    op.alter_column("config_mounts", "mount_path", new_column_name="target_path")
+    op.add_column(
+        "config_mounts",
+        sa.Column("mode", sa.String(length=10), nullable=False, server_default="rw"),
+    )
+    op.add_column(
+        "config_mounts",
+        sa.Column("files", sa.JSON(), nullable=True),
+    )
+    # Drop the source_profile foreign key if it exists
+    op.drop_constraint(
+        "config_mounts_source_profile_id_fkey",
+        "config_mounts",
+        type_="foreignkey",
+    )
+    op.drop_column("config_mounts", "content")
+    op.drop_column("config_mounts", "source_profile_id")
+
+
+def downgrade() -> None:
+    # Restore config_mounts
+    op.add_column(
+        "config_mounts",
+        sa.Column("source_profile_id", postgresql.UUID(as_uuid=True), nullable=True),
+    )
+    op.add_column(
+        "config_mounts",
+        sa.Column("content", sa.Text(), nullable=True),
+    )
+    op.drop_column("config_mounts", "files")
+    op.drop_column("config_mounts", "mode")
+    op.alter_column("config_mounts", "target_path", new_column_name="mount_path")
+    
+    # Restore config_profiles
+    op.drop_index("idx_config_profiles_tool_type", table_name="config_profiles")
+    op.drop_index("idx_config_profiles_project", table_name="config_profiles")
+    op.drop_constraint("fk_config_profiles_tool_type", "config_profiles", type_="foreignkey")
+    op.drop_constraint("fk_config_profiles_project", "config_profiles", type_="foreignkey")
+    op.drop_column("config_profiles", "is_default")
+    op.drop_column("config_profiles", "port")
+    op.drop_column("config_profiles", "working_directory")
+    op.drop_column("config_profiles", "start_command")
+    op.drop_column("config_profiles", "environment_variables")
+    op.drop_column("config_profiles", "tool_type_id")
+    op.drop_column("config_profiles", "project_id")

apps/api/src/api/config_profiles.py

@@ -0,0 +1,877 @@
+"""Config profile API endpoints."""
+
+import logging
+import uuid
+from typing import Any
+
+from fastapi import APIRouter, Depends, HTTPException, status
+from pydantic import BaseModel, Field, field_validator
+from sqlalchemy import select
+from sqlalchemy.ext.asyncio import AsyncSession
+from sqlalchemy.orm import selectinload
+
+from src.auth.dependencies import get_current_user_id, get_db_session
+from src.models.config_include import ConfigInclude
+from src.models.config_mount import ConfigMount
+from src.models.config_profile import ConfigProfile
+from src.models.tool_type import ToolType
+from src.models.user_config import UserConfig
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter(prefix="/config-profiles", tags=["config-profiles"])
+
+MAX_MOUNT_PATH_LENGTH = 1024
+MAX_CONTENT_LENGTH = 1024 * 1024  # 1MB
+MAX_INCLUDES_DEPTH = 10
+
+
+# ---------------------------------------------------------------------------
+# Pydantic schemas
+# ---------------------------------------------------------------------------
+
+class ConfigProfileCreate(BaseModel):
+    name: str = Field(description="Profile name (unique per user)")
+    description: str | None = Field(default=None, description="Optional description")
+
+    @field_validator("name")
+    @classmethod
+    def validate_name(cls, v: str) -> str:
+        v = v.strip()
+        if not v:
+            raise ValueError("Profile name cannot be empty")
+        if len(v) > 255:
+            raise ValueError("Profile name must be 255 characters or less")
+        return v
+
+
+class ConfigProfileUpdate(BaseModel):
+    name: str | None = Field(default=None, description="Profile name")
+    description: str | None = Field(default=None, description="Optional description")
+
+    @field_validator("name")
+    @classmethod
+    def validate_name(cls, v: str | None) -> str | None:
+        if v is None:
+            return v
+        v = v.strip()
+        if not v:
+            raise ValueError("Profile name cannot be empty")
+        if len(v) > 255:
+            raise ValueError("Profile name must be 255 characters or less")
+        return v
+
+
+class ConfigProfileResponse(BaseModel):
+    id: str
+    user_id: str
+    name: str
+    description: str | None
+    created_at: str
+    updated_at: str
+
+
+class ConfigProfileDetailResponse(ConfigProfileResponse):
+    includes: list[dict[str, Any]]
+    mounts: list[dict[str, Any]]
+
+
+class ConfigIncludeCreate(BaseModel):
+    included_profile_id: str = Field(description="UUID of the profile to include")
+    order_index: int = Field(default=0, description="Order index for include resolution")
+
+
+class ConfigIncludeUpdate(BaseModel):
+    order_index: int = Field(description="Order index for include resolution")
+
+
+class ConfigIncludeResponse(BaseModel):
+    id: str
+    profile_id: str
+    included_profile_id: str
+    included_profile_name: str | None
+    order_index: int
+    created_at: str
+    updated_at: str
+
+
+class ConfigMountCreate(BaseModel):
+    target_path: str = Field(description="Absolute target path in container")
+    mode: str = Field(default="rw", description="Mount mode (rw or ro)")
+    files: dict[str, str] | None = Field(default=None, description="Files as {path: content}")
+    order_index: int = Field(default=0, description="Order index for mount resolution")
+
+    @field_validator("target_path")
+    @classmethod
+    def validate_target_path(cls, v: str) -> str:
+        if not v.startswith("/"):
+            raise ValueError("Target path must be absolute (start with /)")
+        if ".." in v:
+            raise ValueError("Target path cannot contain parent directory references (..)")
+        if len(v) > MAX_MOUNT_PATH_LENGTH:
+            raise ValueError(f"Target path must be {MAX_MOUNT_PATH_LENGTH} characters or less")
+        return v
+
+
+class ConfigMountUpdate(BaseModel):
+    target_path: str | None = Field(default=None, description="Absolute target path in container")
+    mode: str | None = Field(default=None, description="Mount mode (rw or ro)")
+    files: dict[str, str] | None = Field(default=None, description="Files as {path: content}")
+    order_index: int | None = Field(default=None, description="Order index for mount resolution")
+
+    @field_validator("target_path")
+    @classmethod
+    def validate_target_path(cls, v: str | None) -> str | None:
+        if v is None:
+            return v
+        if not v.startswith("/"):
+            raise ValueError("Target path must be absolute (start with /)")
+        if ".." in v:
+            raise ValueError("Target path cannot contain parent directory references (..)")
+        if len(v) > MAX_MOUNT_PATH_LENGTH:
+            raise ValueError(f"Target path must be {MAX_MOUNT_PATH_LENGTH} characters or less")
+        return v
+
+
+class ConfigMountResponse(BaseModel):
+    id: str
+    profile_id: str
+    target_path: str
+    mode: str
+    files: dict[str, str] | None
+    order_index: int
+    created_at: str
+    updated_at: str
+
+
+class DefaultProfilesUpdate(BaseModel):
+    default_profiles: dict[str, str] = Field(description="Mapping of tool_type_id to profile_id")
+
+
+# ---------------------------------------------------------------------------
+# Helpers
+# ---------------------------------------------------------------------------
+
+async def _get_owned_profile(
+    profile_id: uuid.UUID,
+    user_id: uuid.UUID,
+    session: AsyncSession,
+) -> ConfigProfile:
+    """Fetch a config profile and verify ownership."""
+    profile = await session.get(ConfigProfile, profile_id)
+    if profile is None or profile.user_id != user_id:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="config profile not found",
+        )
+    return profile
+
+
+async def _detect_cycle(
+    session: AsyncSession,
+    profile_id: uuid.UUID,
+    visited: set[uuid.UUID] | None = None,
+    depth: int = 0,
+) -> bool:
+    """Detect cycles in profile includes using DFS.
+
+    Returns True if a cycle is detected.
+    """
+    if depth > MAX_INCLUDES_DEPTH:
+        return True
+
+    if visited is None:
+        visited = set()
+
+    if profile_id in visited:
+        return True
+
+    visited.add(profile_id)
+
+    result = await session.execute(
+        select(ConfigInclude.included_profile_id).where(
+            ConfigInclude.profile_id == profile_id
+        )
+    )
+    included_ids = result.scalars().all()
+
+    for included_id in included_ids:
+        if await _detect_cycle(session, included_id, visited.copy(), depth + 1):
+            return True
+
+    return False
+
+
+async def _validate_includes_no_cycle(
+    session: AsyncSession,
+    profile_id: uuid.UUID,
+    new_included_id: uuid.UUID | None = None,
+) -> None:
+    """Validate that adding an include wouldn't create a cycle."""
+    if new_included_id and await _detect_cycle(session, new_included_id, {profile_id}):
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="adding this include would create a circular reference",
+        )
+
+
+# ---------------------------------------------------------------------------
+# Profile CRUD
+# ---------------------------------------------------------------------------
+
+@router.get(
+    "",
+    summary="List config profiles",
+    description="Get all config profiles for the current user. Optionally filter by tool type compatibility.",
+)
+async def list_config_profiles(
+    tool_type_id: str | None = None,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """List config profiles for the current user."""
+    query = select(ConfigProfile).where(ConfigProfile.user_id == user_id)
+
+    # If tool_type_id is provided, filter to compatible profiles
+    # For now, all profiles are considered compatible with all tool types
+    # since there's no explicit compatibility matrix. Future enhancement:
+    # could filter by profile tags or mount path patterns.
+    if tool_type_id:
+        # Validate the tool type exists
+        tool_type = await session.get(ToolType, uuid.UUID(tool_type_id))
+        if tool_type is None:
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail="tool type not found",
+            )
+        # All profiles are compatible; just return user's profiles
+        pass
+
+    result = await session.execute(query.order_by(ConfigProfile.name))
+    profiles = result.scalars().all()
+
+    return {
+        "profiles": [
+            {
+                "id": str(p.id),
+                "user_id": str(p.user_id),
+                "name": p.name,
+                "description": p.description,
+                "created_at": p.created_at.isoformat() if p.created_at else None,
+                "updated_at": p.updated_at.isoformat() if p.updated_at else None,
+            }
+            for p in profiles
+        ]
+    }
+
+
+@router.post(
+    "",
+    summary="Create config profile",
+    description="Create a new config profile.",
+    status_code=status.HTTP_201_CREATED,
+)
+async def create_config_profile(
+    data: ConfigProfileCreate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Create a config profile."""
+    # Check for duplicate name
+    existing = await session.scalar(
+        select(ConfigProfile).where(
+            ConfigProfile.user_id == user_id,
+            ConfigProfile.name == data.name,
+        )
+    )
+    if existing:
+        raise HTTPException(
+            status_code=status.HTTP_409_CONFLICT,
+            detail=f"config profile with name '{data.name}' already exists",
+        )
+
+    profile = ConfigProfile(
+        user_id=user_id,
+        name=data.name,
+        description=data.description,
+    )
+    session.add(profile)
+    await session.commit()
+    await session.refresh(profile)
+
+    return {
+        "id": str(profile.id),
+        "user_id": str(profile.user_id),
+        "name": profile.name,
+        "description": profile.description,
+        "created_at": profile.created_at.isoformat() if profile.created_at else None,
+        "updated_at": profile.updated_at.isoformat() if profile.updated_at else None,
+    }
+
+
+@router.get(
+    "/defaults",
+    summary="Get default profiles",
+    description="Get the current user's default profile assignments per tool type.",
+)
+async def get_default_profiles(
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Get default profiles for the current user."""
+    result = await session.execute(
+        select(UserConfig).where(UserConfig.user_id == user_id)
+    )
+    user_config = result.scalar_one_or_none()
+
+    if user_config is None:
+        return {"default_profiles": {}}
+
+    return {"default_profiles": user_config.default_profiles}
+
+
+@router.put(
+    "/defaults",
+    summary="Set default profiles",
+    description="Set the current user's default profile assignments per tool type.",
+)
+async def set_default_profiles(
+    data: DefaultProfilesUpdate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Set default profiles for the current user."""
+    result = await session.execute(
+        select(UserConfig).where(UserConfig.user_id == user_id)
+    )
+    user_config = result.scalar_one_or_none()
+
+    if user_config is None:
+        user_config = UserConfig(user_id=user_id, config={})
+        session.add(user_config)
+
+    # Validate all profile IDs belong to the user
+    for tool_type_id, profile_id_str in data.default_profiles.items():
+        profile = await session.get(ConfigProfile, uuid.UUID(profile_id_str))
+        if profile is None:
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail=f"profile {profile_id_str} not found",
+            )
+        if profile.user_id != user_id:
+            raise HTTPException(
+                status_code=status.HTTP_403_FORBIDDEN,
+                detail=f"profile {profile_id_str} does not belong to user",
+            )
+
+    # SQLAlchemy JSON doesn't track dict mutations, so we replace the whole dict
+    user_config.config = {**user_config.config, "default_profiles": data.default_profiles}
+    await session.commit()
+    await session.refresh(user_config)
+
+    return {"default_profiles": user_config.default_profiles}
+
+
+@router.get(
+    "/defaults/{tool_type_id}",
+    summary="Get default profile for tool type",
+    description="Get the default profile ID for a specific tool type.",
+)
+async def get_default_profile_for_tool_type(
+    tool_type_id: str,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Get default profile for a specific tool type."""
+    result = await session.execute(
+        select(UserConfig).where(UserConfig.user_id == user_id)
+    )
+    user_config = result.scalar_one_or_none()
+
+    if user_config is None:
+        return {"tool_type_id": tool_type_id, "profile_id": None}
+
+    profile_id = user_config.default_profiles.get(tool_type_id)
+    return {"tool_type_id": tool_type_id, "profile_id": profile_id}
+
+
+@router.get(
+    "/{profile_id}",
+    summary="Get config profile",
+    description="Get a config profile with its includes and mounts.",
+)
+async def get_config_profile(
+    profile_id: uuid.UUID,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Get a config profile with includes and mounts."""
+    profile = await session.get(
+        ConfigProfile,
+        profile_id,
+        options=[
+            selectinload(ConfigProfile.includes),
+            selectinload(ConfigProfile.mounts),
+        ],
+    )
+    if profile is None or profile.user_id != user_id:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="config profile not found",
+        )
+
+    # Fetch included profile names
+    includes_data = []
+    for inc in profile.includes:
+        included_profile = await session.get(ConfigProfile, inc.included_profile_id)
+        includes_data.append({
+            "id": str(inc.id),
+            "profile_id": str(inc.profile_id),
+            "included_profile_id": str(inc.included_profile_id),
+            "included_profile_name": included_profile.name if included_profile else None,
+            "order_index": inc.order_index,
+            "created_at": inc.created_at.isoformat() if inc.created_at else None,
+            "updated_at": inc.updated_at.isoformat() if inc.updated_at else None,
+        })
+
+    mounts_data = [
+        {
+            "id": str(m.id),
+            "profile_id": str(m.profile_id),
+            "target_path": m.target_path,
+            "mode": m.mode,
+            "files": m.files,
+            "order_index": m.order_index,
+            "created_at": m.created_at.isoformat() if m.created_at else None,
+            "updated_at": m.updated_at.isoformat() if m.updated_at else None,
+        }
+        for m in profile.mounts
+    ]
+
+    return {
+        "id": str(profile.id),
+        "user_id": str(profile.user_id),
+        "name": profile.name,
+        "description": profile.description,
+        "includes": includes_data,
+        "mounts": mounts_data,
+        "created_at": profile.created_at.isoformat() if profile.created_at else None,
+        "updated_at": profile.updated_at.isoformat() if profile.updated_at else None,
+    }
+
+
+@router.put(
+    "/{profile_id}",
+    summary="Update config profile",
+    description="Update an existing config profile.",
+)
+async def update_config_profile(
+    profile_id: uuid.UUID,
+    data: ConfigProfileUpdate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Update a config profile."""
+    profile = await _get_owned_profile(profile_id, user_id, session)
+
+    if data.name is not None:
+        # Check for duplicate name
+        existing = await session.scalar(
+            select(ConfigProfile).where(
+                ConfigProfile.user_id == user_id,
+                ConfigProfile.name == data.name,
+                ConfigProfile.id != profile_id,
+            )
+        )
+        if existing:
+            raise HTTPException(
+                status_code=status.HTTP_409_CONFLICT,
+                detail=f"config profile with name '{data.name}' already exists",
+            )
+        profile.name = data.name
+
+    if data.description is not None:
+        profile.description = data.description
+
+    await session.commit()
+    await session.refresh(profile)
+
+    return {
+        "id": str(profile.id),
+        "user_id": str(profile.user_id),
+        "name": profile.name,
+        "description": profile.description,
+        "created_at": profile.created_at.isoformat() if profile.created_at else None,
+        "updated_at": profile.updated_at.isoformat() if profile.updated_at else None,
+    }
+
+
+@router.delete(
+    "/{profile_id}",
+    summary="Delete config profile",
+    description="Delete a config profile and all its includes and mounts.",
+    status_code=status.HTTP_204_NO_CONTENT,
+)
+async def delete_config_profile(
+    profile_id: uuid.UUID,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> None:
+    """Delete a config profile."""
+    profile = await _get_owned_profile(profile_id, user_id, session)
+    await session.delete(profile)
+    await session.commit()
+
+
+# ---------------------------------------------------------------------------
+# Include management
+# ---------------------------------------------------------------------------
+
+@router.get(
+    "/{profile_id}/includes",
+    summary="List profile includes",
+    description="Get all includes for a config profile.",
+)
+async def list_profile_includes(
+    profile_id: uuid.UUID,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """List includes for a config profile."""
+    await _get_owned_profile(profile_id, user_id, session)
+
+    result = await session.execute(
+        select(ConfigInclude)
+        .where(ConfigInclude.profile_id == profile_id)
+        .order_by(ConfigInclude.order_index)
+    )
+    includes = result.scalars().all()
+
+    includes_data = []
+    for inc in includes:
+        included_profile = await session.get(ConfigProfile, inc.included_profile_id)
+        includes_data.append({
+            "id": str(inc.id),
+            "profile_id": str(inc.profile_id),
+            "included_profile_id": str(inc.included_profile_id),
+            "included_profile_name": included_profile.name if included_profile else None,
+            "order_index": inc.order_index,
+            "created_at": inc.created_at.isoformat() if inc.created_at else None,
+            "updated_at": inc.updated_at.isoformat() if inc.updated_at else None,
+        })
+
+    return {"includes": includes_data}
+
+
+@router.post(
+    "/{profile_id}/includes",
+    summary="Add profile include",
+    description="Add an include to a config profile.",
+    status_code=status.HTTP_201_CREATED,
+)
+async def add_profile_include(
+    profile_id: uuid.UUID,
+    data: ConfigIncludeCreate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Add an include to a config profile."""
+    profile = await _get_owned_profile(profile_id, user_id, session)
+
+    included_profile_id = uuid.UUID(data.included_profile_id)
+
+    # Cannot include self
+    if included_profile_id == profile_id:
+        raise HTTPException(
+            status_code=status.HTTP_400_BAD_REQUEST,
+            detail="a profile cannot include itself",
+        )
+
+    # Verify the included profile exists and belongs to the user
+    included_profile = await session.get(ConfigProfile, included_profile_id)
+    if included_profile is None:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="included profile not found",
+        )
+    if included_profile.user_id != user_id:
+        raise HTTPException(
+            status_code=status.HTTP_403_FORBIDDEN,
+            detail="included profile does not belong to user",
+        )
+
+    # Check for duplicate include
+    existing = await session.scalar(
+        select(ConfigInclude).where(
+            ConfigInclude.profile_id == profile_id,
+            ConfigInclude.included_profile_id == included_profile_id,
+        )
+    )
+    if existing:
+        raise HTTPException(
+            status_code=status.HTTP_409_CONFLICT,
+            detail="this include already exists",
+        )
+
+    # Validate no cycles
+    await _validate_includes_no_cycle(session, profile_id, included_profile_id)
+
+    include = ConfigInclude(
+        profile_id=profile_id,
+        included_profile_id=included_profile_id,
+        order_index=data.order_index,
+    )
+    session.add(include)
+    await session.commit()
+    await session.refresh(include)
+
+    return {
+        "id": str(include.id),
+        "profile_id": str(include.profile_id),
+        "included_profile_id": str(include.included_profile_id),
+        "included_profile_name": included_profile.name,
+        "order_index": include.order_index,
+        "created_at": include.created_at.isoformat() if include.created_at else None,
+        "updated_at": include.updated_at.isoformat() if include.updated_at else None,
+    }
+
+
+@router.put(
+    "/{profile_id}/includes/{include_id}",
+    summary="Update profile include",
+    description="Update the order index of a profile include.",
+)
+async def update_profile_include(
+    profile_id: uuid.UUID,
+    include_id: uuid.UUID,
+    data: ConfigIncludeUpdate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Update a profile include."""
+    await _get_owned_profile(profile_id, user_id, session)
+
+    include = await session.get(ConfigInclude, include_id)
+    if include is None or include.profile_id != profile_id:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="include not found",
+        )
+
+    include.order_index = data.order_index
+    await session.commit()
+    await session.refresh(include)
+
+    included_profile = await session.get(ConfigProfile, include.included_profile_id)
+    return {
+        "id": str(include.id),
+        "profile_id": str(include.profile_id),
+        "included_profile_id": str(include.included_profile_id),
+        "included_profile_name": included_profile.name if included_profile else None,
+        "order_index": include.order_index,
+        "created_at": include.created_at.isoformat() if include.created_at else None,
+        "updated_at": include.updated_at.isoformat() if include.updated_at else None,
+    }
+
+
+@router.delete(
+    "/{profile_id}/includes/{include_id}",
+    summary="Remove profile include",
+    description="Remove an include from a config profile.",
+    status_code=status.HTTP_204_NO_CONTENT,
+)
+async def remove_profile_include(
+    profile_id: uuid.UUID,
+    include_id: uuid.UUID,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> None:
+    """Remove an include from a config profile."""
+    await _get_owned_profile(profile_id, user_id, session)
+
+    include = await session.get(ConfigInclude, include_id)
+    if include is None or include.profile_id != profile_id:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="include not found",
+        )
+
+    await session.delete(include)
+    await session.commit()
+
+
+# ---------------------------------------------------------------------------
+# Mount management
+# ---------------------------------------------------------------------------
+
+@router.get(
+    "/{profile_id}/mounts",
+    summary="List profile mounts",
+    description="Get all mounts for a config profile.",
+)
+async def list_profile_mounts(
+    profile_id: uuid.UUID,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """List mounts for a config profile."""
+    await _get_owned_profile(profile_id, user_id, session)
+
+    result = await session.execute(
+        select(ConfigMount)
+        .where(ConfigMount.profile_id == profile_id)
+        .order_by(ConfigMount.order_index)
+    )
+    mounts = result.scalars().all()
+
+    return {
+        "mounts": [
+            {
+                "id": str(m.id),
+                "profile_id": str(m.profile_id),
+                "target_path": m.target_path,
+                "files": m.files,
+                "mode": m.mode,
+                "order_index": m.order_index,
+                "created_at": m.created_at.isoformat() if m.created_at else None,
+                "updated_at": m.updated_at.isoformat() if m.updated_at else None,
+            }
+            for m in mounts
+        ]
+    }
+
+
+@router.post(
+    "/{profile_id}/mounts",
+    summary="Add profile mount",
+    description="Add a mount to a config profile.",
+    status_code=status.HTTP_201_CREATED,
+)
+async def add_profile_mount(
+    profile_id: uuid.UUID,
+    data: ConfigMountCreate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Add a mount to a config profile."""
+    profile = await _get_owned_profile(profile_id, user_id, session)
+
+    # Check for duplicate target_path
+    existing = await session.scalar(
+        select(ConfigMount).where(
+            ConfigMount.profile_id == profile_id,
+            ConfigMount.target_path == data.target_path,
+        )
+    )
+    if existing:
+        raise HTTPException(
+            status_code=status.HTTP_409_CONFLICT,
+            detail=f"mount with path '{data.target_path}' already exists",
+        )
+
+    mount = ConfigMount(
+        profile_id=profile_id,
+        target_path=data.target_path,
+        mode=data.mode,
+        files=data.files,
+        order_index=data.order_index,
+    )
+    session.add(mount)
+    await session.commit()
+    await session.refresh(mount)
+
+    return {
+        "id": str(mount.id),
+        "profile_id": str(mount.profile_id),
+        "target_path": mount.target_path,
+        "files": mount.files,
+        "mode": mount.mode,
+        "order_index": mount.order_index,
+        "created_at": mount.created_at.isoformat() if mount.created_at else None,
+        "updated_at": mount.updated_at.isoformat() if mount.updated_at else None,
+    }
+
+
+@router.put(
+    "/{profile_id}/mounts/{mount_id}",
+    summary="Update profile mount",
+    description="Update a mount in a config profile.",
+)
+async def update_profile_mount(
+    profile_id: uuid.UUID,
+    mount_id: uuid.UUID,
+    data: ConfigMountUpdate,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> dict:
+    """Update a profile mount."""
+    await _get_owned_profile(profile_id, user_id, session)
+
+    mount = await session.get(ConfigMount, mount_id)
+    if mount is None or mount.profile_id != profile_id:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="mount not found",
+        )
+
+    if data.target_path is not None:
+        # Check for duplicate target_path
+        existing = await session.scalar(
+            select(ConfigMount).where(
+                ConfigMount.profile_id == profile_id,
+                ConfigMount.target_path == data.target_path,
+                ConfigMount.id != mount_id,
+            )
+        )
+        if existing:
+            raise HTTPException(
+                status_code=status.HTTP_409_CONFLICT,
+                detail=f"mount with path '{data.target_path}' already exists",
+            )
+        mount.target_path = data.target_path
+
+    if data.files is not None:
+        mount.files = data.files
+
+    if data.order_index is not None:
+        mount.order_index = data.order_index
+
+    await session.commit()
+    await session.refresh(mount)
+
+    return {
+        "id": str(mount.id),
+        "profile_id": str(mount.profile_id),
+        "target_path": mount.target_path,
+        "files": mount.files,
+        "mode": mount.mode,
+        "order_index": mount.order_index,
+        "created_at": mount.created_at.isoformat() if mount.created_at else None,
+        "updated_at": mount.updated_at.isoformat() if mount.updated_at else None,
+    }
+
+
+@router.delete(
+    "/{profile_id}/mounts/{mount_id}",
+    summary="Remove profile mount",
+    description="Remove a mount from a config profile.",
+    status_code=status.HTTP_204_NO_CONTENT,
+)
+async def remove_profile_mount(
+    profile_id: uuid.UUID,
+    mount_id: uuid.UUID,
+    user_id: uuid.UUID = Depends(get_current_user_id),
+    session: AsyncSession = Depends(get_db_session),
+) -> None:
+    """Remove a mount from a config profile."""
+    await _get_owned_profile(profile_id, user_id, session)
+
+    mount = await session.get(ConfigMount, mount_id)
+    if mount is None or mount.profile_id != profile_id:
+        raise HTTPException(
+            status_code=status.HTTP_404_NOT_FOUND,
+            detail="mount not found",
+        )
+
+    await session.delete(mount)
+    await session.commit()

apps/api/src/api/terminal.py

@@ -4,7 +4,7 @@ import asyncio
 import logging
 import uuid
 
-from fastapi import APIRouter, Depends, HTTPException, WebSocket, WebSocketDisconnect, status
+from fastapi import APIRouter, Depends, WebSocket
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from src.auth.dependencies import get_db_session
@@ -26,6 +26,11 @@ async def terminal_websocket(
     """WebSocket endpoint for terminal access to a tool instance.
 
     Provides an interactive terminal session inside a running tool instance container.
+    Supports:
+    - Auto-reconnection (client reconnects, server spawns new session)
+    - Heartbeat ping/pong
+    - Binary and text input frames
+    - Graceful session end notifications
 
     Args:
         websocket: The WebSocket connection.
@@ -34,26 +39,27 @@ async def terminal_websocket(
 
     Returns:
         None. Communicates via WebSocket messages.
+
     """
     logger.info("Terminal WebSocket connection attempt for instance %s", instance_id)
     await websocket.accept()
 
     try:
-        # Parse instance_id
         instance_uuid = uuid.UUID(instance_id)
     except ValueError:
         logger.error("Invalid instance ID: %s", instance_id)
         await websocket.close(code=4001, reason="Invalid instance ID")
         return
 
-    # Authenticate user from session cookie
     user_id = await _get_user_from_websocket(websocket, db_session)
     if user_id is None:
-        logger.warning("Unauthorized terminal access attempt for instance %s", instance_id)
+        logger.warning(
+            "Unauthorized terminal access attempt for instance %s",
+            instance_id,
+        )
         await websocket.close(code=4003, reason="Unauthorized")
         return
 
-    # Get instance and verify ownership
     instance = await db_session.get(ToolInstance, instance_uuid)
     if instance is None:
         logger.warning("Instance %s not found", instance_id)
@@ -61,38 +67,65 @@ async def terminal_websocket(
         return
 
     if instance.owner_id != user_id:
-        logger.warning("Forbidden terminal access for instance %s by user %s", instance_id, user_id)
+        logger.warning(
+            "Forbidden terminal access for instance %s by user %s",
+            instance_id,
+            user_id,
+        )
         await websocket.close(code=4003, reason="Forbidden")
         return
 
     if instance.status != "running" or not instance.container_id:
-        logger.warning("Instance %s not running (status=%s, container_id=%s)", instance_id, instance.status, instance.container_id)
+        logger.warning(
+            "Instance %s not running (status=%s, container_id=%s)",
+            instance_id,
+            instance.status,
+            instance.container_id,
+        )
         await websocket.close(code=4004, reason="Instance not running")
         return
 
-    logger.info("Creating terminal session for instance %s (container_id=%s)", instance_id, instance.container_id)
+    logger.info(
-    # Create terminal session
+        "Creating terminal session for instance %s (container_id=%s)",
+        instance_id,
+        instance.container_id,
+    )
     try:
         session = await terminal_manager.create_session(
             instance_uuid,
             instance.container_id,
             websocket,
         )
-        logger.info("Terminal session created successfully for instance %s", instance_id)
+        logger.info(
+            "Terminal session created successfully for instance %s",
+            instance_id,
+        )
 
         # Send connected status
         await websocket.send_json({"type": "status", "status": "connected"})
 
-        # Keep connection alive until session ends
+        # Monitor session health and echo state
-        # The terminal_manager handles I/O loops, we just wait here
+        while session.is_alive() and not session.closed:
-        while session.is_alive() and not session._closed:
+            # Check echo state periodically
-            await asyncio.sleep(0.5)
+            new_echo_state = await session.check_echo_state()
+            if new_echo_state is not None:
+                await websocket.send_json(
+                    {"type": "set_echo_state", "enabled": new_echo_state},
+                )
+            await asyncio.sleep(1.0)
 
-    except Exception as exc:
+        # Session ended — determine reason and notify client
-        logger.error("Terminal session error for instance %s: %s", instance_id, str(exc), exc_info=True)
+        exit_reason = session.get_exit_reason() or "process_exit"
-        await websocket.close(code=4000, reason=f"Error: {exc}")
+        await websocket.send_json({"type": "session_ended", "reason": exit_reason})
+        await websocket.close(code=1000, reason=f"Session ended: {exit_reason}")
+
+    except Exception:
+        logger.exception(
+            "Terminal session error for instance %s",
+            instance_id,
+        )
+        await websocket.close(code=4000, reason="Terminal session error")
     finally:
-        # Cleanup will be handled by the session manager
         pass
 
 
@@ -108,6 +141,7 @@ async def _get_user_from_websocket(
 
     Returns:
         The user's UUID if authenticated, None otherwise.
+
     """
     from src.auth.session import decode_session_cookie
     from src.config import Settings

apps/api/src/api/tool_instances.py

@@ -2,6 +2,7 @@
 
 import logging
 import os
+import re
 import uuid
 from datetime import datetime
 
@@ -18,6 +19,7 @@ from src.auth.dependencies import get_current_user_id
 from src.auth.dependencies import get_db_session
 from src.models.git_repository import GitRepository
 from src.models.project import Project
+from src.models.config_profile import ConfigProfile
 from src.models.tool_config import ToolConfig
 from src.models.tool_instance import ToolInstance
 from src.models.tool_type import ToolType
@@ -41,6 +43,7 @@ from src.services.docker import (
     write_config_folder_files,
 )
 from src.services.docker_build import build_image
+from src.services.profile_resolver import resolve_profile
 from src.services.readiness_probe import execute_probe
 
 router = APIRouter(prefix="/projects", tags=["tool-instances"])
@@ -53,6 +56,7 @@ class CreateInstanceRequest(BaseModel):
 
     tool_type_id: str = Field(description="UUID of the tool type to instantiate")
     display_name: str | None = Field(default=None, description="Optional display name for the instance")
+    config_profile_id: str | None = Field(default=None, description="Optional config profile ID to apply to the instance")
 
 
 def _modify_compose_file(
@@ -107,6 +111,68 @@ def _modify_compose_file(
     compose_file.write_text(yaml.dump(compose_data, default_flow_style=False))
 
 
+async def _apply_resolved_profile(
+    profile: ConfigProfile,
+    instance_dir: str,
+    env_vars: dict[str, str],
+    port_override: int | None,
+    start_command: str | None,
+    working_directory: str | None,
+    extra_volumes: list[dict],
+) -> tuple[dict[str, str], int | None, str | None, str | None, list[dict]]:
+    """Resolve a profile and apply its output to instance configuration.
+
+    Merges resolved profile env vars (profile wins), applies runtime hints,
+    stages mount files to the instance directory, and adds Docker bind mounts.
+
+    Args:
+        profile: The config profile to resolve and apply.
+        instance_dir: Path to the instance directory.
+        env_vars: Current environment variables dict (will be updated).
+        port_override: Current port override (may be updated).
+        start_command: Current start command (may be updated).
+        working_directory: Current working directory (may be updated).
+        extra_volumes: Current extra volumes list (will be extended).
+
+    Returns:
+        Updated (env_vars, port_override, start_command, working_directory, extra_volumes).
+    """
+    from pathlib import Path
+
+    resolved = resolve_profile(profile)
+
+    # Merge env vars from resolved profile (profile wins over tool configs)
+    if resolved.environment_variables:
+        env_vars.update(resolved.environment_variables)
+
+    # Apply runtime hints
+    if resolved.runtime_hints.start_command is not None:
+        start_command = resolved.runtime_hints.start_command
+    if resolved.runtime_hints.working_directory is not None:
+        working_directory = resolved.runtime_hints.working_directory
+    if resolved.runtime_hints.port is not None:
+        port_override = resolved.runtime_hints.port
+
+    # Stage mount files and add volume mounts
+    for target_path, mount in resolved.mounts.items():
+        safe_name = target_path.strip("/").replace("/", "_")
+        mount_dir = Path(instance_dir) / "mounts" / safe_name
+        mount_dir.mkdir(parents=True, exist_ok=True)
+
+        for rel_path, content in mount.files.items():
+            file_path = mount_dir / rel_path
+            file_path.parent.mkdir(parents=True, exist_ok=True)
+            file_path.write_text(content)
+
+        extra_volumes.append({
+            "source": str(mount_dir),
+            "target": target_path,
+            "type": mount.mode,
+        })
+
+    return env_vars, port_override, start_command, working_directory, extra_volumes
+
+
 async def _get_user(session: AsyncSession, user_id: uuid.UUID) -> User:
     """Fetch a user by ID or raise 404 if not found."""
     user = await session.get(User, user_id)
@@ -141,6 +207,42 @@ async def _get_owned_project(
     return project
 
 
+def _sanitize_name(name: str) -> str:
+    """Sanitize a string for use in Docker/container names."""
+    sanitized = re.sub(r"[^a-z0-9-]", "-", name.lower())
+    sanitized = re.sub(r"-+", "-", sanitized)
+    return sanitized.strip("-")
+
+
+async def _generate_instance_name(
+    session: AsyncSession,
+    project_name: str,
+    tool_type_name: str,
+) -> str:
+    """Generate a unique instance name: project-tool-NUM.
+
+    Args:
+        session: Database session.
+        project_name: Name of the project.
+        tool_type_name: Name of the tool type.
+
+    Returns:
+        A unique instance name with a sequential 3-digit number.
+    """
+    base = f"{_sanitize_name(project_name)}-{_sanitize_name(tool_type_name)}"
+    base = base.strip("-") or "instance"
+    result = await session.execute(
+        select(ToolInstance.name).where(ToolInstance.name.like(f"{base}-%"))
+    )
+    names = result.scalars().all()
+    max_num = 0
+    for name in names:
+        parts = name.rsplit("-", 1)
+        if len(parts) == 2 and parts[0] == base and parts[1].isdigit():
+            max_num = max(max_num, int(parts[1]))
+    return f"{base}-{max_num + 1:03d}"
+
+
 @router.post(
     "/{project_id}/repositories/{repo_id}/instances",
     summary="Create tool instance",
@@ -189,9 +291,32 @@ async def create_instance(
             status_code=status.HTTP_404_NOT_FOUND, detail="tool type not found"
         )
 
+    # Validate config_profile_id if provided
+    selected_profile_id: uuid.UUID | None = None
+    if data.config_profile_id:
+        try:
+            selected_profile_id = uuid.UUID(data.config_profile_id)
+        except ValueError:
+            raise HTTPException(
+                status_code=status.HTTP_400_BAD_REQUEST,
+                detail="invalid config_profile_id format",
+            )
+        
+        config_profile = await session.get(ConfigProfile, selected_profile_id)
+        if config_profile is None:
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail="config profile not found",
+            )
+        if config_profile.user_id != user_id:
+            raise HTTPException(
+                status_code=status.HTTP_403_FORBIDDEN,
+                detail="config profile does not belong to user",
+            )
+
     try:
-        # Generate unique name
+        # Generate unique name: project-tool-NUM
-        instance_name = f"{tool_type.name}-{repo.name}-{uuid.uuid4().hex[:8]}"
+        instance_name = await _generate_instance_name(session, _project.name, tool_type.name)
         instance_display = data.display_name or f"{tool_type.display_name} - {repo.name}"
 
         # Create instance directory
@@ -262,6 +387,7 @@ services:
             status="pending",
             compose_path=compose_path,
             port=tool_port,
+            selected_profile_id=selected_profile_id,
         )
         session.add(instance)
         await session.commit()
@@ -273,6 +399,7 @@ services:
             "display_name": instance.display_name,
             "tool_type_id": str(instance.tool_type_id),
             "status": instance.status,
+            "config_profile_id": str(instance.selected_profile_id) if instance.selected_profile_id else None,
             "created_at": instance.created_at.isoformat(),
         }
     except Exception as exc:
@@ -335,6 +462,7 @@ async def list_instances(
             "status": i.status,
             "url": i.url,
             "port": i.port,
+            "config_profile_id": str(i.selected_profile_id) if i.selected_profile_id else None,
             "created_at": i.created_at.isoformat(),
         })
 
@@ -395,6 +523,7 @@ async def get_instance(
         "compose_path": instance.compose_path,
         "url": instance.url,
         "port": instance.port,
+        "config_profile_id": str(instance.selected_profile_id) if instance.selected_profile_id else None,
         "last_started_at": instance.last_started_at.isoformat() if instance.last_started_at else None,
         "last_stopped_at": instance.last_stopped_at.isoformat() if instance.last_stopped_at else None,
         "created_at": instance.created_at.isoformat(),
@@ -452,6 +581,7 @@ async def start_instance(
     extra_env_vars = {}
     extra_volumes = []
     
+    # Fetch all matching configs for this tool type
     config_query = select(ToolConfig).where(
         ToolConfig.user_id == user_id,
         ToolConfig.tool_type_id == instance.tool_type_id,
@@ -484,6 +614,31 @@ async def start_instance(
     # Merge extra env vars
     env_vars.update(extra_env_vars)
     
+    # Apply resolved profile output if a profile is selected
+    if instance.selected_profile_id:
+        selected_profile = await session.get(ConfigProfile, instance.selected_profile_id)
+        if selected_profile is None:
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail="config profile not found",
+            )
+        if selected_profile.user_id != user_id:
+            raise HTTPException(
+                status_code=status.HTTP_403_FORBIDDEN,
+                detail="config profile does not belong to user",
+            )
+        instance_dir = os.path.dirname(instance.compose_path)
+        env_vars, port_override, start_command, working_directory, extra_volumes = await _apply_resolved_profile(
+            selected_profile,
+            instance_dir,
+            env_vars,
+            port_override,
+            start_command,
+            working_directory,
+            extra_volumes,
+        )
+        logger.info("Applied resolved profile %s for instance %s", selected_profile.name, instance.id)
+    
     # Fetch active config folders for this user
     folder_query = select(ConfigFolder).where(
         ConfigFolder.user_id == user_id,
@@ -755,8 +910,105 @@ async def restart_instance(
             logger.warning("Failed to stop old tunnel for instance %s: %s", instance.id, exc)
 
     if instance.compose_path and os.path.exists(instance.compose_path):
+        # Re-apply configuration using stored profile instead of current defaults
+        env_vars = {}
+        config_files = {}
+        port_override = None
+        start_command = None
+        working_directory = None
+        extra_env_vars = {}
+        extra_volumes = []
+        
+        # Fetch all matching configs for this tool type
+        config_query = select(ToolConfig).where(
+            ToolConfig.user_id == user_id,
+            ToolConfig.tool_type_id == instance.tool_type_id,
+        ).where(
+            (ToolConfig.project_id == project_id) | (ToolConfig.project_id.is_(None))
+        )
+        
+        config_result = await session.execute(config_query)
+        configs = config_result.scalars().all()
+        logger.info("Found %d tool configs for restart of instance %s", len(configs), instance.id)
+        
+        for config in configs:
+            if config.config_type == "env":
+                env_vars[config.key] = config.value
+            elif config.config_type == "file" and config.file_path:
+                config_files[config.file_path] = config.value
+            
+            if config.port_override:
+                port_override = config.port_override
+            if config.start_command:
+                start_command = config.start_command
+            if config.working_directory:
+                working_directory = config.working_directory
+            if config.environment_variables:
+                extra_env_vars.update(config.environment_variables)
+            if config.volumes:
+                extra_volumes.extend(config.volumes)
+        
+        # Merge extra env vars
+        env_vars.update(extra_env_vars)
+        
+        # Apply stored profile on restart instead of current defaults
+        if instance.selected_profile_id:
+            stored_profile = await session.get(ConfigProfile, instance.selected_profile_id)
+            if stored_profile is None:
+                raise HTTPException(
+                    status_code=status.HTTP_404_NOT_FOUND,
+                    detail="config profile not found",
+                )
+            if stored_profile.user_id != user_id:
+                raise HTTPException(
+                    status_code=status.HTTP_403_FORBIDDEN,
+                    detail="config profile does not belong to user",
+                )
+            instance_dir = os.path.dirname(instance.compose_path)
+            env_vars, port_override, start_command, working_directory, extra_volumes = await _apply_resolved_profile(
+                stored_profile,
+                instance_dir,
+                env_vars,
+                port_override,
+                start_command,
+                working_directory,
+                extra_volumes,
+            )
+            logger.info("Re-applied stored profile %s for restart of instance %s", stored_profile.name, instance.id)
+        
+        # Fetch active config folders for this user
+        folder_query = select(ConfigFolder).where(
+            ConfigFolder.user_id == user_id,
+            ConfigFolder.is_active == True,
+        )
+        folder_result = await session.execute(folder_query)
+        config_folders = folder_result.scalars().all()
+        
+        # Write env file and config files
+        instance_dir = os.path.dirname(instance.compose_path)
+        env_file_path = None
+        
+        if env_vars:
+            env_file_path = write_env_file(instance_dir, env_vars)
+            logger.info("Wrote env file for restart of instance %s: %s", instance.id, env_file_path)
+        
+        if config_files:
+            write_config_files(instance_dir, config_files)
+            logger.info("Wrote %d config files for restart of instance %s", len(config_files), instance.id)
+        
+        # Write config folder files
+        if config_folders:
+            folder_volumes = write_config_folder_files(instance_dir, config_folders, str(project_id))
+            extra_volumes.extend(folder_volumes)
+            logger.info("Wrote config folders with %d volume mounts for restart of instance %s", len(folder_volumes), instance.id)
+        
+        # Modify compose file if needed
+        if port_override or start_command or working_directory or extra_volumes:
+            _modify_compose_file(instance.compose_path, port_override, start_command, working_directory, extra_volumes)
+            logger.info("Modified compose file for restart of instance %s", instance.id)
+
         returncode, stdout, stderr = execute_compose_command(
-            instance.compose_path, "restart"
+            instance.compose_path, "restart", env_file=env_file_path
         )
 
         if returncode == 0:

apps/api/src/auth/session.py

@@ -2,7 +2,7 @@ import hmac
 import hashlib
 import json
 import base64
-from datetime import UTC, datetime, timedelta
+from datetime import datetime, timedelta, timezone
 from typing import Any
 
 from src.config import Settings
@@ -23,7 +23,7 @@ def create_session_cookie(*, settings: Settings, user_id: str) -> str:
     """Create a signed session cookie value."""
     payload = {
         "user_id": user_id,
-        "exp": int((datetime.now(UTC) + timedelta(hours=settings.session_ttl_hours)).timestamp()),
+        "exp": int((datetime.now(timezone.utc) + timedelta(hours=settings.session_ttl_hours)).timestamp()),
     }
     
     header = _base64url_encode(json.dumps({"alg": "HS256", "typ": "session"}).encode())
@@ -65,7 +65,7 @@ def decode_session_cookie(*, settings: Settings, cookie_value: str) -> dict[str,
     payload = json.loads(payload_bytes)
     
     # Check expiry
-    if payload.get("exp", 0) < int(datetime.now(UTC).timestamp()):
+    if payload.get("exp", 0) < int(datetime.now(timezone.utc).timestamp()):
         raise ValueError("session expired")
     
     return payload

apps/api/src/main.py

@@ -18,6 +18,7 @@ from src.api.ssh_keys import router as ssh_keys_router
 from src.api.terminal import router as terminal_router
 from src.api.instance_proxy import router as instance_proxy_router
 from src.api.config_folders import router as config_folders_router
+from src.api.config_profiles import router as config_profiles_router
 from src.api.tool_configs import router as tool_configs_router
 from src.api.tool_instances import router as tool_instances_router
 from src.api.tool_instances import sessions_router
@@ -277,6 +278,7 @@ app.include_router(git_repositories_router)
 app.include_router(user_config_router)
 app.include_router(tool_types_router)
 app.include_router(config_folders_router)
+app.include_router(config_profiles_router)
 app.include_router(tool_instances_router)
 app.include_router(tool_configs_router)
 app.include_router(sessions_router)

apps/api/src/models/__init__.py

@@ -1,5 +1,8 @@
 from src.models.base import Base
 from src.models.config_folder import ConfigFolder
+from src.models.config_include import ConfigInclude
+from src.models.config_mount import ConfigMount
+from src.models.config_profile import ConfigProfile
 from src.models.git_repository import GitRepository
 from src.models.project import Project
 from src.models.ssh_key import SSHKey
@@ -8,4 +11,17 @@ from src.models.tool_type import ToolType
 from src.models.user import User
 from src.models.user_config import UserConfig
 
-__all__ = ["Base", "ConfigFolder", "GitRepository", "Project", "SSHKey", "ToolInstance", "ToolType", "User", "UserConfig"]
+__all__ = [
+    "Base",
+    "ConfigFolder",
+    "ConfigInclude",
+    "ConfigMount",
+    "ConfigProfile",
+    "GitRepository",
+    "Project",
+    "SSHKey",
+    "ToolInstance",
+    "ToolType",
+    "User",
+    "UserConfig",
+]

apps/api/src/models/config_folder.py

@@ -26,6 +26,8 @@ class ConfigFolder(UUIDPrimaryKeyMixin, TimestampMixin, Base):
     project_overrides: Mapped[dict | None] = mapped_column(
         JSON, default=dict, nullable=True
     )  # {"project_id": {"mount_path": "...", "files": {...}}}
+    # DEPRECATED: Legacy auto-mounting flag. No longer used for launch-time
+    # auto-mounting. Use ConfigProfile and ToolInstance.selected_profile_id instead.
     is_active: Mapped[bool] = mapped_column(Boolean, default=True, nullable=False)
 
     user: Mapped["User"] = relationship()

apps/api/src/models/config_include.py

@@ -0,0 +1,36 @@
+import uuid
+from typing import TYPE_CHECKING
+
+from sqlalchemy import ForeignKey, Integer, UniqueConstraint
+from sqlalchemy import Uuid as UUID
+from sqlalchemy.orm import Mapped, mapped_column, relationship
+
+from src.models.base import Base, TimestampMixin, UUIDPrimaryKeyMixin
+
+if TYPE_CHECKING:
+    from src.models.config_profile import ConfigProfile
+
+
+class ConfigInclude(UUIDPrimaryKeyMixin, TimestampMixin, Base):
+    __tablename__ = "config_includes"
+    __table_args__ = (
+        UniqueConstraint("profile_id", "included_profile_id", name="uq_config_includes_pair"),
+    )
+
+    profile_id: Mapped[uuid.UUID] = mapped_column(
+        UUID(), ForeignKey("config_profiles.id", ondelete="CASCADE"), nullable=False
+    )
+    included_profile_id: Mapped[uuid.UUID] = mapped_column(
+        UUID(), ForeignKey("config_profiles.id", ondelete="CASCADE"), nullable=False
+    )
+    order_index: Mapped[int] = mapped_column(Integer, nullable=False, default=0)
+
+    profile: Mapped["ConfigProfile"] = relationship(
+        "ConfigProfile",
+        foreign_keys=[profile_id],
+        back_populates="includes",
+    )
+    included_profile: Mapped["ConfigProfile"] = relationship(
+        "ConfigProfile",
+        foreign_keys=[included_profile_id],
+    )

apps/api/src/models/config_mount.py

@@ -0,0 +1,31 @@
+import uuid
+from typing import TYPE_CHECKING
+
+from sqlalchemy import ForeignKey, Integer, JSON, String
+from sqlalchemy import Uuid as UUID
+from sqlalchemy.orm import Mapped, mapped_column, relationship
+
+from src.models.base import Base, TimestampMixin, UUIDPrimaryKeyMixin
+
+if TYPE_CHECKING:
+    from src.models.config_profile import ConfigProfile
+
+
+class ConfigMount(UUIDPrimaryKeyMixin, TimestampMixin, Base):
+    __tablename__ = "config_mounts"
+
+    profile_id: Mapped[uuid.UUID] = mapped_column(
+        UUID(), ForeignKey("config_profiles.id", ondelete="CASCADE"), nullable=False
+    )
+    target_path: Mapped[str] = mapped_column(String(1024), nullable=False)
+    mode: Mapped[str] = mapped_column(String(10), nullable=False, default="rw")
+    files: Mapped[dict[str, str] | None] = mapped_column(
+        JSON, default=dict, nullable=True
+    )
+    order_index: Mapped[int] = mapped_column(Integer, nullable=False, default=0)
+
+    profile: Mapped["ConfigProfile"] = relationship(
+        "ConfigProfile",
+        foreign_keys=[profile_id],
+        back_populates="mounts",
+    )

apps/api/src/models/config_profile.py

@@ -0,0 +1,59 @@
+import uuid
+from typing import TYPE_CHECKING
+
+from sqlalchemy import ForeignKey, Integer, JSON, String, Text, UniqueConstraint
+from sqlalchemy import Uuid as UUID
+from sqlalchemy.orm import Mapped, mapped_column, relationship
+
+from src.models.base import Base, TimestampMixin, UUIDPrimaryKeyMixin
+
+if TYPE_CHECKING:
+    from src.models.config_include import ConfigInclude
+    from src.models.config_mount import ConfigMount
+    from src.models.project import Project
+    from src.models.tool_type import ToolType
+    from src.models.user import User
+
+
+class ConfigProfile(UUIDPrimaryKeyMixin, TimestampMixin, Base):
+    __tablename__ = "config_profiles"
+    __table_args__ = (
+        UniqueConstraint("user_id", "name", name="uq_config_profiles_user_name"),
+    )
+
+    user_id: Mapped[uuid.UUID] = mapped_column(
+        UUID(), ForeignKey("users.id", ondelete="CASCADE"), nullable=False
+    )
+    project_id: Mapped[uuid.UUID | None] = mapped_column(
+        UUID(), ForeignKey("projects.id", ondelete="CASCADE"), nullable=True
+    )
+    tool_type_id: Mapped[uuid.UUID | None] = mapped_column(
+        UUID(), ForeignKey("tool_types.id", ondelete="CASCADE"), nullable=True
+    )
+    name: Mapped[str] = mapped_column(String(255), nullable=False)
+    description: Mapped[str | None] = mapped_column(Text, nullable=True)
+    environment_variables: Mapped[dict[str, str] | None] = mapped_column(
+        JSON, default=dict, nullable=True
+    )
+    start_command: Mapped[str | None] = mapped_column(Text, nullable=True)
+    working_directory: Mapped[str | None] = mapped_column(Text, nullable=True)
+    port: Mapped[int | None] = mapped_column(Integer, nullable=True)
+    is_default: Mapped[bool] = mapped_column(default=False, nullable=False)
+
+    user: Mapped["User"] = relationship()
+    project: Mapped["Project | None"] = relationship()
+    tool_type: Mapped["ToolType | None"] = relationship()
+    includes: Mapped[list["ConfigInclude"]] = relationship(
+        "ConfigInclude",
+        primaryjoin="ConfigProfile.id == ConfigInclude.profile_id",
+        back_populates="profile",
+        cascade="all, delete-orphan",
+        order_by="ConfigInclude.order_index",
+    )
+    mounts: Mapped[list["ConfigMount"]] = relationship(
+        "ConfigMount",
+        primaryjoin="ConfigProfile.id == ConfigMount.profile_id",
+        back_populates="profile",
+        cascade="all, delete-orphan",
+        order_by="ConfigMount.order_index",
+    )

apps/api/src/models/tool_instance.py

@@ -9,6 +9,7 @@ from sqlalchemy.orm import Mapped, mapped_column, relationship
 from src.models.base import Base, TimestampMixin, UUIDPrimaryKeyMixin
 
 if TYPE_CHECKING:
+    from src.models.config_profile import ConfigProfile
     from src.models.git_repository import GitRepository
     from src.models.project import Project
     from src.models.tool_type import ToolType
@@ -62,8 +63,12 @@ class ToolInstance(UUIDPrimaryKeyMixin, TimestampMixin, Base):
     last_stopped_at: Mapped[datetime | None] = mapped_column(
         DateTime(timezone=True), nullable=True
     )
+    selected_profile_id: Mapped[uuid.UUID | None] = mapped_column(
+        UUID(), ForeignKey("config_profiles.id", ondelete="SET NULL"), nullable=True
+    )
 
     tool_type: Mapped["ToolType"] = relationship()
     repository: Mapped["GitRepository"] = relationship()
     project: Mapped["Project"] = relationship()
     owner: Mapped["User"] = relationship()
+    selected_profile: Mapped["ConfigProfile | None"] = relationship()

apps/api/src/models/user_config.py

@@ -18,3 +18,23 @@ class UserConfig(UUIDPrimaryKeyMixin, TimestampMixin, Base):
     config: Mapped[dict[str, object]] = mapped_column(JSON, default=dict, nullable=False)
 
     user: Mapped["User"] = relationship(back_populates="user_config")
+
+    @property
+    def default_profile_id(self) -> uuid.UUID | None:
+        profile_id = self.config.get("default_profile_id")
+        return uuid.UUID(profile_id) if profile_id else None
+
+    @default_profile_id.setter
+    def default_profile_id(self, value: uuid.UUID | None) -> None:
+        if value is not None:
+            self.config["default_profile_id"] = str(value)
+        elif "default_profile_id" in self.config:
+            del self.config["default_profile_id"]
+
+    @property
+    def default_profiles(self) -> dict[str, str]:
+        return self.config.get("default_profiles", {})
+
+    @default_profiles.setter
+    def default_profiles(self, value: dict[str, str]) -> None:
+        self.config["default_profiles"] = value

apps/api/src/services/profile_resolver.py

@@ -0,0 +1,251 @@
+"""Profile resolver service for recursive ordered include resolution.
+
+Provides deterministic merge rules, save-independent cycle protection,
+and resolved output structures for env vars, runtime hints, mounts,
+file trees, and override metadata.
+"""
+
+from __future__ import annotations
+
+import uuid
+from dataclasses import dataclass, field
+
+from src.models.config_include import ConfigInclude
+from src.models.config_mount import ConfigMount
+from src.models.config_profile import ConfigProfile
+
+
+@dataclass
+class ResolvedMount:
+    """A resolved mount with merged file tree and final mode."""
+
+    target_path: str
+    mode: str  # "ro" or "rw"
+    files: dict[str, str] = field(default_factory=dict)
+    """Relative file paths to UTF-8 text content."""
+    overridden_files: dict[str, list[str]] = field(default_factory=dict)
+    """Map of relative file path to list of profile names that contributed
+    (latest is the winner)."""
+    mode_overridden_by: str | None = None
+    """Name of the profile that set the final mode, if different from first."""
+
+
+@dataclass
+class ResolvedRuntimeHints:
+    """Resolved runtime hints from profile layers."""
+
+    start_command: str | None = None
+    working_directory: str | None = None
+    port: int | None = None
+    overridden_hints: dict[str, str] = field(default_factory=dict)
+    """Map of hint key to profile name that provided the winning value."""
+
+
+@dataclass
+class ResolvedProfileOutput:
+    """Complete resolved output for a config profile."""
+
+    profile_id: uuid.UUID
+    profile_name: str
+    environment_variables: dict[str, str] = field(default_factory=dict)
+    """Final merged env vars (later layers win)."""
+    env_var_sources: dict[str, list[str]] = field(default_factory=dict)
+    """Map of env var key to ordered list of contributing profile names
+    (latest is the winner)."""
+    runtime_hints: ResolvedRuntimeHints = field(
+        default_factory=lambda: ResolvedRuntimeHints()
+    )
+    mounts: dict[str, ResolvedMount] = field(default_factory=dict)
+    """Map of target_path to ResolvedMount."""
+    resolution_order: list[str] = field(default_factory=list)
+    """Ordered list of profile names as they were resolved."""
+    cycle_detected: bool = False
+    cycle_path: list[str] | None = None
+
+
+class ProfileResolutionError(Exception):
+    """Raised when profile resolution fails."""
+
+    pass
+
+
+class ProfileCycleError(ProfileResolutionError):
+    """Raised when a cycle is detected during profile resolution."""
+
+    def __init__(self, cycle_path: list[str]) -> None:
+        self.cycle_path = cycle_path
+        path_str = " -> ".join(cycle_path)
+        super().__init__(f"Profile include cycle detected: {path_str}")
+
+
+def _merge_env_vars(
+    current: dict[str, str],
+    sources: dict[str, list[str]],
+    profile: ConfigProfile,
+) -> None:
+    """Merge a profile's env vars into the current dict, tracking sources."""
+    if not profile.environment_variables:
+        return
+    for key, value in profile.environment_variables.items():
+        current[key] = value
+        if key not in sources:
+            sources[key] = []
+        sources[key].append(profile.name)
+
+
+def _merge_runtime_hints(
+    hints: ResolvedRuntimeHints,
+    profile: ConfigProfile,
+) -> None:
+    """Merge a profile's runtime hints, tracking overrides."""
+    if profile.start_command is not None:
+        hints.start_command = profile.start_command
+        hints.overridden_hints["start_command"] = profile.name
+    if profile.working_directory is not None:
+        hints.working_directory = profile.working_directory
+        hints.overridden_hints["working_directory"] = profile.name
+    if profile.port is not None:
+        hints.port = profile.port
+        hints.overridden_hints["port"] = profile.name
+
+
+def _merge_mounts(
+    mounts: dict[str, ResolvedMount],
+    profile_mounts: list[ConfigMount],
+    profile: ConfigProfile,
+) -> None:
+    """Merge a profile's mounts into the current mounts dict."""
+    for mount in profile_mounts:
+        target = mount.target_path
+        if target not in mounts:
+            mounts[target] = ResolvedMount(
+                target_path=target,
+                mode=mount.mode,
+                files={},
+                overridden_files={},
+            )
+        resolved = mounts[target]
+        
+        # Mode override: later wins
+        if resolved.mode != mount.mode:
+            resolved.mode = mount.mode
+            resolved.mode_overridden_by = profile.name
+        
+        # File tree merge: later wins for same relative path
+        if mount.files:
+            for rel_path, content in mount.files.items():
+                if rel_path not in resolved.files:
+                    resolved.overridden_files[rel_path] = []
+                else:
+                    if rel_path not in resolved.overridden_files:
+                        resolved.overridden_files[rel_path] = []
+                    resolved.overridden_files[rel_path].append(profile.name)
+                resolved.files[rel_path] = content
+
+
+def _resolve_profile_recursive(
+    profile: ConfigProfile,
+    visited: set[uuid.UUID],
+    path: list[str],
+    resolution_order: list[str],
+    env_vars: dict[str, str],
+    env_var_sources: dict[str, list[str]],
+    runtime_hints: ResolvedRuntimeHints,
+    mounts: dict[str, ResolvedMount],
+) -> None:
+    """Recursively resolve a profile and its includes.
+
+    Args:
+        profile: The profile to resolve
+        visited: Set of already-resolved profile IDs to avoid duplicates
+        path: Current recursion path for cycle detection
+        resolution_order: Ordered list of profile names being resolved
+        env_vars: Accumulated environment variables
+        env_var_sources: Tracking of which profiles contributed each env var
+        runtime_hints: Accumulated runtime hints
+        mounts: Accumulated mounts
+
+    Raises:
+        ProfileCycleError: If a cycle is detected
+    """
+    if profile.name in path:
+        # Cycle detected
+        cycle_start = path.index(profile.name)
+        cycle_path = path[cycle_start:] + [profile.name]
+        raise ProfileCycleError(cycle_path)
+
+    if profile.id in visited:
+        # Already resolved in another branch (diamond graph)
+        return
+
+    visited.add(profile.id)
+    path.append(profile.name)
+    resolution_order.append(profile.name)
+
+    # Resolve includes first (in order)
+    includes: list[ConfigInclude] = list(profile.includes)
+    includes.sort(key=lambda inc: inc.order_index)
+    for include in includes:
+        included_profile = include.included_profile
+        if included_profile is not None:
+            _resolve_profile_recursive(
+                included_profile,
+                visited,
+                path,
+                resolution_order,
+                env_vars,
+                env_var_sources,
+                runtime_hints,
+                mounts,
+            )
+
+    # Apply this profile's values (later layers win)
+    _merge_env_vars(env_vars, env_var_sources, profile)
+    _merge_runtime_hints(runtime_hints, profile)
+    _merge_mounts(mounts, list(profile.mounts), profile)
+
+    path.pop()
+
+
+def resolve_profile(profile: ConfigProfile) -> ResolvedProfileOutput:
+    """Resolve a config profile with all its includes.
+
+    Processes included profiles in configured order, then applies the
+    selected profile itself. Later layers override earlier layers.
+
+    Args:
+        profile: The root profile to resolve
+
+    Returns:
+        ResolvedProfileOutput with merged env vars, runtime hints, mounts,
+        and override metadata
+
+    Raises:
+        ProfileCycleError: If a cycle is detected in the include graph
+    """
+    env_vars: dict[str, str] = {}
+    env_var_sources: dict[str, list[str]] = {}
+    runtime_hints = ResolvedRuntimeHints()
+    mounts: dict[str, ResolvedMount] = {}
+    resolution_order: list[str] = []
+
+    _resolve_profile_recursive(
+        profile,
+        set(),
+        [],
+        resolution_order,
+        env_vars,
+        env_var_sources,
+        runtime_hints,
+        mounts,
+    )
+
+    return ResolvedProfileOutput(
+        profile_id=profile.id,
+        profile_name=profile.name,
+        environment_variables=env_vars,
+        env_var_sources=env_var_sources,
+        runtime_hints=runtime_hints,
+        mounts=mounts,
+        resolution_order=resolution_order,
+    )

apps/api/src/services/terminal_manager.py

@@ -1,19 +1,35 @@
 """Terminal session manager for WebSocket connections."""
 
 import asyncio
+import contextlib
+import json
+import logging
+import time
 import uuid
+from collections.abc import Coroutine
 from typing import Any
 
 from fastapi import WebSocket
 
 from src.services.terminal_session import TerminalSession
 
+logger = logging.getLogger(__name__)
+
+_READ_BATCH_INTERVAL_S = 0.016  # 16ms max batching delay
+_READ_POLL_TIMEOUT_S = 0.005
+_READ_POLL_SLEEP_S = 0.001
+_HEARTBEAT_INTERVAL_S = 15.0
+_IDLE_TIMEOUT_S = 60.0
+
 
 class TerminalManager:
     """Manages active terminal sessions."""
 
     def __init__(self) -> None:
+        """Initialise the terminal manager."""
         self._sessions: dict[str, TerminalSession] = {}
+        self._last_client_message: dict[str, float] = {}
+        self._background_tasks: set[asyncio.Task[Any]] = set()
 
     async def create_session(
         self,
@@ -26,55 +42,134 @@ class TerminalManager:
         session = TerminalSession(session_id, instance_id, container_id)
         await session.start()
         self._sessions[session_id] = session
+        self._last_client_message[session_id] = time.monotonic()
 
         # Start background tasks for I/O streaming
-        asyncio.create_task(self._read_loop(session, websocket))
+        self._start_task(self._read_loop(session, websocket))
-        asyncio.create_task(self._write_loop(session, websocket))
+        self._start_task(self._write_loop(session, websocket))
+        self._start_task(self._heartbeat_loop(session, websocket))
 
         return session
 
-    async def _read_loop(self, session: TerminalSession, websocket: WebSocket) -> None:
+    def _start_task(self, coro: Coroutine[Any, Any, None]) -> None:
-        """Read output from the container and send to WebSocket."""
+        """Start a background task and store a reference to prevent GC."""
+        task = asyncio.create_task(coro)
+        self._background_tasks.add(task)
+        task.add_done_callback(self._background_tasks.discard)
+
+    async def _read_loop(
+        self,
+        session: TerminalSession,
+        websocket: WebSocket,
+    ) -> None:
+        """Read output from the container and send to WebSocket with batching."""
         try:
-            while session.is_alive() and not session._closed:
+            buffer = bytearray()
-                data = await session.read_output()
+            last_flush = time.monotonic()
+
+            while session.is_alive() and not session.closed:
+                data = await session.read_output(select_timeout=_READ_POLL_TIMEOUT_S)
                 if data:
-                    await websocket.send_bytes(data)
+                    buffer.extend(data)
-                else:
+
-                    await asyncio.sleep(0.01)
+                now = time.monotonic()
+                flush_due = buffer and (
+                    now - last_flush >= _READ_BATCH_INTERVAL_S or not data
+                )
+
+                if flush_due:
+                    await websocket.send_bytes(bytes(buffer))
+                    buffer.clear()
+                    last_flush = now
+                elif not data:
+                    await asyncio.sleep(_READ_POLL_SLEEP_S)
+
+            # Flush any remaining data
+            if buffer:
+                with contextlib.suppress(Exception):
+                    await websocket.send_bytes(bytes(buffer))
+
         except Exception:
-            pass
+            logger.exception("Read loop error for session %s", session.session_id)
         finally:
             await self._cleanup_session(session)
 
-    async def _write_loop(self, session: TerminalSession, websocket: WebSocket) -> None:
+    async def _write_loop(
+        self,
+        session: TerminalSession,
+        websocket: WebSocket,
+    ) -> None:
         """Read input from WebSocket and send to container."""
         try:
-            while session.is_alive() and not session._closed:
+            while session.is_alive() and not session.closed:
                 message = await websocket.receive()
+                self._last_client_message[session.session_id] = time.monotonic()
+
                 if message["type"] == "websocket.receive":
                     if "bytes" in message:
                         await session.write_input(message["bytes"])
                     elif "text" in message:
                         text = message["text"]
                         if text.startswith("{"):
-                            # Control message (JSON)
-                            import json
                             try:
                                 ctrl = json.loads(text)
-                                if ctrl.get("type") == "resize":
+                                await self._handle_control_message(
-                                    await session.resize(
+                                    session,
-                                        ctrl.get("cols", 80),
+                                    websocket,
-                                        ctrl.get("rows", 24),
+                                    ctrl,
-                                    )
+                                )
                             except json.JSONDecodeError:
-                                pass
+                                logger.debug("Invalid JSON control message: %s", text)
                         else:
                             await session.write_input(text.encode("utf-8"))
                 elif message["type"] == "websocket.disconnect":
                     break
         except Exception:
-            pass
+            logger.exception("Write loop error for session %s", session.session_id)
+        finally:
+            await self._cleanup_session(session)
+
+    async def _handle_control_message(
+        self,
+        session: TerminalSession,
+        websocket: WebSocket,
+        ctrl: dict[str, Any],
+    ) -> None:
+        """Handle a JSON control message from the client."""
+        msg_type = ctrl.get("type")
+        if msg_type == "resize":
+            await session.resize(
+                ctrl.get("cols", 80),
+                ctrl.get("rows", 24),
+            )
+        elif msg_type == "ping":
+            await websocket.send_json(
+                {"type": "pong", "id": ctrl.get("id")},
+            )
+
+    async def _heartbeat_loop(
+        self,
+        session: TerminalSession,
+        websocket: WebSocket,
+    ) -> None:
+        """Monitor client activity and close idle connections."""
+        try:
+            while session.is_alive() and not session.closed:
+                await asyncio.sleep(_HEARTBEAT_INTERVAL_S)
+                last_msg = self._last_client_message.get(session.session_id, 0)
+                if time.monotonic() - last_msg > _IDLE_TIMEOUT_S:
+                    # Client has been silent for 60s — close connection
+                    with contextlib.suppress(Exception):
+                        await websocket.close(
+                            code=1000,
+                            reason="Idle timeout",
+                        )
+                    break
+        except Exception:
+            logger.exception(
+                "Heartbeat loop error for session %s",
+                session.session_id,
+            )
         finally:
             await self._cleanup_session(session)
 
@@ -82,12 +177,14 @@ class TerminalManager:
         """Clean up a session."""
         if session.session_id in self._sessions:
             del self._sessions[session.session_id]
+        self._last_client_message.pop(session.session_id, None)
         await session.close()
 
     async def close_all(self) -> None:
         """Close all active sessions."""
         sessions = list(self._sessions.values())
         self._sessions.clear()
+        self._last_client_message.clear()
         for session in sessions:
             await session.close()
 

apps/api/src/services/terminal_session.py

@@ -1,19 +1,29 @@
 """Terminal session management for tool instances."""
 
 import asyncio
+import contextlib
+import fcntl
+import logging
 import os
 import pty
 import select
 import struct
-import fcntl
+import termios
 import uuid
-from typing import Any
+
+logger = logging.getLogger(__name__)
 
 
 class TerminalSession:
     """Manages a single terminal session connected to a docker container."""
 
-    def __init__(self, session_id: str, instance_id: uuid.UUID, container_id: str) -> None:
+    def __init__(
+        self,
+        session_id: str,
+        instance_id: uuid.UUID,
+        container_id: str,
+    ) -> None:
+        """Initialize a terminal session."""
         self.session_id = session_id
         self.instance_id = instance_id
         self.container_id = container_id
@@ -21,23 +31,20 @@ class TerminalSession:
         self._closed = False
         self._master_fd: int | None = None
         self._slave_fd: int | None = None
+        self._echo_enabled = True
+        self._exit_reason: str | None = None
 
     async def start(self) -> None:
         """Start the docker exec process with a shell using a PTY."""
-        # Create a pseudo-terminal on the host
         self._master_fd, self._slave_fd = pty.openpty()
-        
-        # Set the terminal size initially
         self._set_terminal_size(80, 24)
 
-        # Start docker exec with the slave fd as stdin/stdout/stderr
-        # Using -it because the slave fd IS a TTY
         self.process = await asyncio.create_subprocess_exec(
             "docker",
             "exec",
             "-it",
             "-e",
-            "TERM=xterm",
+            "TERM=xterm-256color",
             self.container_id,
             "bash",
             "-il",
@@ -46,43 +53,70 @@ class TerminalSession:
             stderr=self._slave_fd,
         )
 
-        # Close slave fd in parent process
         os.close(self._slave_fd)
         self._slave_fd = None
+        self._echo_enabled = self._detect_echo_state()
 
     def _set_terminal_size(self, cols: int, rows: int) -> None:
         """Set the terminal size using TIOCSWINSZ."""
         if self._master_fd is None:
             return
-        # TIOCSWINSZ = 0x5414 on Linux
+        tiocswinsz = 0x5414
-        TIOCSWINSZ = 0x5414
+        size = struct.pack("HHHH", rows, cols, 0, 0)
-        size = struct.pack('HHHH', rows, cols, 0, 0)
+        with contextlib.suppress(OSError):
-        try:
+            fcntl.ioctl(self._master_fd, tiocswinsz, size)
-            fcntl.ioctl(self._master_fd, TIOCSWINSZ, size)
-        except (OSError, IOError):
-            pass
 
-    async def read_output(self) -> bytes:
+    def _detect_echo_state(self) -> bool:
+        """Detect whether the PTY has echo enabled via termios."""
+        if self._master_fd is None:
+            return True
+        try:
+            attrs = termios.tcgetattr(self._master_fd)
+            return bool(attrs[3] & termios.ECHO)
+        except OSError:
+            return True
+
+    async def check_echo_state(self) -> bool | None:
+        """Check if echo state changed. Returns new state if changed, None otherwise."""
+        current = self._detect_echo_state()
+        if current != self._echo_enabled:
+            self._echo_enabled = current
+            return current
+        return None
+
+    @property
+    def echo_enabled(self) -> bool:
+        """Return whether the PTY currently has echo enabled."""
+        return self._echo_enabled
+
+    @property
+    def closed(self) -> bool:
+        """Return whether the session has been closed."""
+        return self._closed
+
+    async def read_output(self, select_timeout: float = 0.1) -> bytes:
         """Read output from the PTY master."""
         if self._master_fd is None or self._closed:
             return b""
         try:
-            # Use select to check if data is available
+            readable, _, _ = select.select(
-            readable, _, _ = select.select([self._master_fd], [], [], 0.1)
+                [self._master_fd],
+                [],
+                [],
+                select_timeout,
+            )
             if readable:
-                return os.read(self._master_fd, 4096)
+                return os.read(self._master_fd, 8192)
             return b""
-        except (OSError, IOError, ValueError):
+        except (OSError, ValueError):
             return b""
 
     async def write_input(self, data: bytes) -> None:
         """Write input to the PTY master."""
         if self._master_fd is None or self._closed:
             return
-        try:
+        with contextlib.suppress(OSError):
             os.write(self._master_fd, data)
-        except (OSError, IOError):
-            pass
 
     async def resize(self, cols: int, rows: int) -> None:
         """Resize the terminal."""
@@ -90,24 +124,35 @@ class TerminalSession:
             return
         self._set_terminal_size(cols, rows)
 
+    def get_exit_reason(self) -> str | None:
+        """Return the reason the session ended, if known."""
+        return self._exit_reason
+
     async def close(self) -> None:
         """Close the session and cleanup."""
         if self._closed:
             return
         self._closed = True
 
+        # Determine exit reason
+        if self.process is not None and self.process.returncode is not None:
+            if self.process.returncode == 0:
+                self._exit_reason = "process_exit"
+            else:
+                self._exit_reason = "process_exit"
+        else:
+            self._exit_reason = "timeout"
+
         if self._master_fd is not None:
-            try:
+            with contextlib.suppress(OSError):
                 os.close(self._master_fd)
-            except OSError:
-                pass
             self._master_fd = None
 
         if self.process is not None:
             try:
                 self.process.kill()
                 await asyncio.wait_for(self.process.wait(), timeout=2.0)
-            except (asyncio.TimeoutError, ProcessLookupError):
+            except (TimeoutError, ProcessLookupError):
                 pass
 
     def is_alive(self) -> bool:

apps/api/tests/integration/test_config_profiles_api.py

@@ -0,0 +1,461 @@
+"""Integration tests for config profiles API."""
+
+import uuid
+
+import pytest
+from fastapi.testclient import TestClient
+
+
+@pytest.mark.integration
+class TestConfigProfilesAPI:
+    """Integration tests for config profiles API."""
+
+    def test_list_config_profiles_requires_authentication(self, test_client: TestClient) -> None:
+        """Test that listing config profiles requires authentication."""
+        response = test_client.get("/config-profiles")
+        assert response.status_code == 401
+
+    def test_list_config_profiles_returns_user_profiles(self, authenticated_client: TestClient) -> None:
+        """Test that authenticated users can list their profiles."""
+        response = authenticated_client.get("/config-profiles")
+        assert response.status_code == 200
+        data = response.json()
+        assert isinstance(data, dict)
+        assert "profiles" in data
+        assert isinstance(data["profiles"], list)
+
+    def test_create_config_profile_successfully(self, authenticated_client: TestClient) -> None:
+        """Test creating a config profile."""
+        response = authenticated_client.post(
+            "/config-profiles",
+            json={
+                "name": "test-profile",
+                "description": "Test profile",
+            },
+        )
+        assert response.status_code == 201
+        data = response.json()
+        assert data["name"] == "test-profile"
+        assert data["description"] == "Test profile"
+
+    def test_create_config_profile_duplicate_name(self, authenticated_client: TestClient) -> None:
+        """Test that duplicate profile names are rejected."""
+        authenticated_client.post(
+            "/config-profiles",
+            json={"name": "duplicate-profile"},
+        )
+
+        response = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "duplicate-profile"},
+        )
+        assert response.status_code == 409
+
+    def test_create_config_profile_empty_name(self, authenticated_client: TestClient) -> None:
+        """Test that empty profile names are rejected."""
+        response = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "  "},
+        )
+        assert response.status_code == 422
+
+    def test_get_config_profile_by_id(self, authenticated_client: TestClient) -> None:
+        """Test getting a config profile by ID."""
+        create_response = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "get-test"},
+        )
+        profile_id = create_response.json()["id"]
+
+        response = authenticated_client.get(f"/config-profiles/{profile_id}")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["name"] == "get-test"
+        assert "includes" in data
+        assert "mounts" in data
+
+    def test_get_config_profile_not_found(self, authenticated_client: TestClient) -> None:
+        """Test getting a non-existent profile."""
+        response = authenticated_client.get(f"/config-profiles/{uuid.uuid4()}")
+        assert response.status_code == 404
+
+    def test_update_config_profile_successfully(self, authenticated_client: TestClient) -> None:
+        """Test updating a config profile."""
+        create_response = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "update-test"},
+        )
+        profile_id = create_response.json()["id"]
+
+        response = authenticated_client.put(
+            f"/config-profiles/{profile_id}",
+            json={"name": "updated-name", "description": "updated desc"},
+        )
+        assert response.status_code == 200
+        data = response.json()
+        assert data["name"] == "updated-name"
+        assert data["description"] == "updated desc"
+
+    def test_delete_config_profile_successfully(self, authenticated_client: TestClient) -> None:
+        """Test deleting a config profile."""
+        create_response = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "delete-test"},
+        )
+        profile_id = create_response.json()["id"]
+
+        response = authenticated_client.delete(f"/config-profiles/{profile_id}")
+        assert response.status_code == 204
+
+        get_response = authenticated_client.get(f"/config-profiles/{profile_id}")
+        assert get_response.status_code == 404
+
+    def test_profile_access_check(self, authenticated_client: TestClient) -> None:
+        """Test that users can only access their own profiles."""
+        # Create a profile
+        create_response = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "access-test"},
+        )
+        profile_id = create_response.json()["id"]
+
+        # The profile should be accessible
+        response = authenticated_client.get(f"/config-profiles/{profile_id}")
+        assert response.status_code == 200
+
+
+@pytest.mark.integration
+class TestConfigProfileIncludes:
+    """Integration tests for config profile includes."""
+
+    def test_add_include_successfully(self, authenticated_client: TestClient) -> None:
+        """Test adding an include to a profile."""
+        # Create two profiles
+        profile1 = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "profile-1"},
+        ).json()
+        profile2 = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "profile-2"},
+        ).json()
+
+        # Add include
+        response = authenticated_client.post(
+            f"/config-profiles/{profile1['id']}/includes",
+            json={"included_profile_id": profile2["id"], "order_index": 0},
+        )
+        assert response.status_code == 201
+        data = response.json()
+        assert data["included_profile_id"] == profile2["id"]
+        assert data["included_profile_name"] == "profile-2"
+
+    def test_add_self_include_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that self-includes are rejected."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "self-include-test"},
+        ).json()
+
+        response = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/includes",
+            json={"included_profile_id": profile["id"], "order_index": 0},
+        )
+        assert response.status_code == 400
+
+    def test_add_include_cycle_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that circular includes are rejected."""
+        profile1 = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "cycle-1"},
+        ).json()
+        profile2 = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "cycle-2"},
+        ).json()
+
+        # Add profile1 includes profile2
+        authenticated_client.post(
+            f"/config-profiles/{profile1['id']}/includes",
+            json={"included_profile_id": profile2["id"], "order_index": 0},
+        )
+
+        # Try to add profile2 includes profile1 (creates cycle)
+        response = authenticated_client.post(
+            f"/config-profiles/{profile2['id']}/includes",
+            json={"included_profile_id": profile1["id"], "order_index": 0},
+        )
+        assert response.status_code == 400
+
+    def test_add_deep_cycle_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that deep circular includes are rejected."""
+        p1 = authenticated_client.post(
+            "/config-profiles", json={"name": "deep-1"}
+        ).json()
+        p2 = authenticated_client.post(
+            "/config-profiles", json={"name": "deep-2"}
+        ).json()
+        p3 = authenticated_client.post(
+            "/config-profiles", json={"name": "deep-3"}
+        ).json()
+
+        # p1 -> p2 -> p3
+        authenticated_client.post(
+            f"/config-profiles/{p1['id']}/includes",
+            json={"included_profile_id": p2["id"], "order_index": 0},
+        )
+        authenticated_client.post(
+            f"/config-profiles/{p2['id']}/includes",
+            json={"included_profile_id": p3["id"], "order_index": 0},
+        )
+
+        # Try p3 -> p1 (creates cycle)
+        response = authenticated_client.post(
+            f"/config-profiles/{p3['id']}/includes",
+            json={"included_profile_id": p1["id"], "order_index": 0},
+        )
+        assert response.status_code == 400
+
+    def test_add_duplicate_include_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that duplicate includes are rejected."""
+        p1 = authenticated_client.post(
+            "/config-profiles", json={"name": "dup-1"}
+        ).json()
+        p2 = authenticated_client.post(
+            "/config-profiles", json={"name": "dup-2"}
+        ).json()
+
+        authenticated_client.post(
+            f"/config-profiles/{p1['id']}/includes",
+            json={"included_profile_id": p2["id"], "order_index": 0},
+        )
+
+        response = authenticated_client.post(
+            f"/config-profiles/{p1['id']}/includes",
+            json={"included_profile_id": p2["id"], "order_index": 1},
+        )
+        assert response.status_code == 409
+
+    def test_list_includes(self, authenticated_client: TestClient) -> None:
+        """Test listing includes for a profile."""
+        p1 = authenticated_client.post(
+            "/config-profiles", json={"name": "list-inc-1"}
+        ).json()
+        p2 = authenticated_client.post(
+            "/config-profiles", json={"name": "list-inc-2"}
+        ).json()
+
+        authenticated_client.post(
+            f"/config-profiles/{p1['id']}/includes",
+            json={"included_profile_id": p2["id"], "order_index": 0},
+        )
+
+        response = authenticated_client.get(f"/config-profiles/{p1['id']}/includes")
+        assert response.status_code == 200
+        data = response.json()
+        assert len(data["includes"]) == 1
+
+    def test_update_include_order(self, authenticated_client: TestClient) -> None:
+        """Test updating include order index."""
+        p1 = authenticated_client.post(
+            "/config-profiles", json={"name": "order-1"}
+        ).json()
+        p2 = authenticated_client.post(
+            "/config-profiles", json={"name": "order-2"}
+        ).json()
+
+        inc = authenticated_client.post(
+            f"/config-profiles/{p1['id']}/includes",
+            json={"included_profile_id": p2["id"], "order_index": 0},
+        ).json()
+
+        response = authenticated_client.put(
+            f"/config-profiles/{p1['id']}/includes/{inc['id']}",
+            json={"order_index": 5},
+        )
+        assert response.status_code == 200
+        assert response.json()["order_index"] == 5
+
+    def test_remove_include(self, authenticated_client: TestClient) -> None:
+        """Test removing an include."""
+        p1 = authenticated_client.post(
+            "/config-profiles", json={"name": "rem-1"}
+        ).json()
+        p2 = authenticated_client.post(
+            "/config-profiles", json={"name": "rem-2"}
+        ).json()
+
+        inc = authenticated_client.post(
+            f"/config-profiles/{p1['id']}/includes",
+            json={"included_profile_id": p2["id"], "order_index": 0},
+        ).json()
+
+        response = authenticated_client.delete(
+            f"/config-profiles/{p1['id']}/includes/{inc['id']}"
+        )
+        assert response.status_code == 204
+
+
+@pytest.mark.integration
+class TestConfigProfileMounts:
+    """Integration tests for config profile mounts."""
+
+    def test_add_mount_successfully(self, authenticated_client: TestClient) -> None:
+        """Test adding a mount to a profile."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "mount-test"},
+        ).json()
+
+        response = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "/etc/config", "files": {"test.txt": "hello"}, "order_index": 0},
+        )
+        assert response.status_code == 201
+        data = response.json()
+        assert data["target_path"] == "/etc/config"
+        assert data["files"] == {"test.txt": "hello"}
+
+    def test_add_mount_relative_path_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that relative mount paths are rejected."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "rel-path-test"},
+        ).json()
+
+        response = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "etc/config", "files": {"test.txt": "hello"}},
+        )
+        assert response.status_code == 422
+
+    def test_add_target_path_traversal_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that path traversal in mount paths is rejected."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "traversal-test"},
+        ).json()
+
+        response = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "/etc/../passwd", "files": {"test.txt": "hello"}},
+        )
+        assert response.status_code == 422
+
+    def test_add_duplicate_mount_rejected(self, authenticated_client: TestClient) -> None:
+        """Test that duplicate mount paths are rejected."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "dup-mount-test"},
+        ).json()
+
+        authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "/etc/config", "files": {"test.txt": "hello"}},
+        )
+
+        response = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "/etc/config", "files": {"test.txt": "world"}},
+        )
+        assert response.status_code == 409
+
+    def test_update_mount(self, authenticated_client: TestClient) -> None:
+        """Test updating a mount."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "update-mount-test"},
+        ).json()
+
+        mount = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "/old/path", "files": {"test.txt": "old"}},
+        ).json()
+
+        response = authenticated_client.put(
+            f"/config-profiles/{profile['id']}/mounts/{mount['id']}",
+            json={"target_path": "/new/path", "files": {"test.txt": "new"}, "order_index": 2},
+        )
+        assert response.status_code == 200
+        data = response.json()
+        assert data["target_path"] == "/new/path"
+        assert data["files"] == {"test.txt": "new"}
+        assert data["order_index"] == 2
+
+    def test_remove_mount(self, authenticated_client: TestClient) -> None:
+        """Test removing a mount."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "rem-mount-test"},
+        ).json()
+
+        mount = authenticated_client.post(
+            f"/config-profiles/{profile['id']}/mounts",
+            json={"target_path": "/tmp/test", "files": {"test.txt": "x"}},
+        ).json()
+
+        response = authenticated_client.delete(
+            f"/config-profiles/{profile['id']}/mounts/{mount['id']}"
+        )
+        assert response.status_code == 204
+
+
+@pytest.mark.integration
+class TestConfigProfileDefaults:
+    """Integration tests for default profile APIs."""
+
+    def test_get_default_profiles_empty(self, authenticated_client: TestClient) -> None:
+        """Test getting default profiles when none are set."""
+        response = authenticated_client.get("/config-profiles/defaults")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["default_profiles"] == {}
+
+    def test_set_default_profiles(self, authenticated_client: TestClient) -> None:
+        """Test setting default profiles."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "default-test"},
+        ).json()
+
+        response = authenticated_client.put(
+            "/config-profiles/defaults",
+            json={"default_profiles": {"code-server": profile["id"]}},
+        )
+        assert response.status_code == 200
+        data = response.json()
+        assert data["default_profiles"]["code-server"] == profile["id"]
+
+    def test_set_default_profiles_invalid_profile(self, authenticated_client: TestClient) -> None:
+        """Test setting default profiles with invalid profile ID."""
+        response = authenticated_client.put(
+            "/config-profiles/defaults",
+            json={"default_profiles": {"code-server": str(uuid.uuid4())}},
+        )
+        assert response.status_code == 404
+
+    def test_get_default_profile_for_tool_type(self, authenticated_client: TestClient) -> None:
+        """Test getting default profile for a specific tool type."""
+        profile = authenticated_client.post(
+            "/config-profiles",
+            json={"name": "tool-default-test"},
+        ).json()
+
+        authenticated_client.put(
+            "/config-profiles/defaults",
+            json={"default_profiles": {"jupyter-notebook": profile["id"]}},
+        )
+
+        response = authenticated_client.get("/config-profiles/defaults/jupyter-notebook")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["tool_type_id"] == "jupyter-notebook"
+        assert data["profile_id"] == profile["id"]
+
+    def test_get_default_profile_for_tool_type_not_set(self, authenticated_client: TestClient) -> None:
+        """Test getting default profile when not set."""
+        response = authenticated_client.get("/config-profiles/defaults/opencode")
+        assert response.status_code == 200
+        data = response.json()
+        assert data["tool_type_id"] == "opencode"
+        assert data["profile_id"] is None

apps/api/tests/integration/test_projects_api.py

@@ -1,5 +1,5 @@
 import uuid
-from datetime import UTC, datetime, timedelta
+from datetime import datetime, timedelta, timezone
 import asyncio
 
 import pytest
@@ -58,7 +58,7 @@ def _mint_token(user_id: str) -> str:
         subject=user_id,
         email="test@headquarter.local",
         name="Test User",
-        expires_at=datetime.now(UTC) + timedelta(minutes=15),
+        expires_at=datetime.now(timezone.utc) + timedelta(minutes=15),
     )
 
 

apps/api/tests/integration/test_tool_types_api.py

@@ -1,5 +1,5 @@
 import uuid
-from datetime import UTC, datetime, timedelta
+from datetime import datetime, timedelta, timezone
 import asyncio
 
 import pytest
@@ -59,7 +59,7 @@ def _mint_token(user_id: str) -> str:
         subject=user_id,
         email="test@headquarter.local",
         name="Test User",
-        expires_at=datetime.now(UTC) + timedelta(minutes=15),
+        expires_at=datetime.now(timezone.utc) + timedelta(minutes=15),
     )
 
 

apps/api/tests/integration/test_users_api.py

@@ -1,5 +1,5 @@
 import uuid
-from datetime import UTC, datetime, timedelta
+from datetime import datetime, timedelta, timezone
 import asyncio
 import io
 
@@ -83,7 +83,7 @@ def _create_auth_cookie(user_id: str) -> str:
         subject=user_id,
         email="test@headquarter.local",
         name="Test User",
-        expires_at=datetime.now(UTC) + timedelta(minutes=15),
+        expires_at=datetime.now(timezone.utc) + timedelta(minutes=15),
     )
 
 

apps/api/tests/unit/test_migration_metadata.py

@@ -39,3 +39,18 @@ def test_refresh_tokens_migration_has_expected_revision_chain() -> None:
 
     assert module.revision == "0002_refresh_tokens"
     assert module.down_revision == "0001_initial_schema"
+
+
+@pytest.mark.unit
+def test_config_profiles_migration_has_expected_revision_chain() -> None:
+    migration_path = Path(__file__).resolve().parents[2] / "alembic" / "versions" / "0013_add_config_profiles.py"
+    spec = spec_from_file_location("add_config_profiles", migration_path)
+
+    assert spec is not None
+    assert spec.loader is not None
+
+    module = module_from_spec(spec)
+    spec.loader.exec_module(module)
+
+    assert module.revision == "0013_add_config_profiles"
+    assert module.down_revision == "0012_default_port_req"

apps/api/tests/unit/test_profile_resolver.py

@@ -0,0 +1,463 @@
+"""Unit tests for the profile resolver service."""
+
+import uuid
+from unittest.mock import MagicMock
+
+import pytest
+
+from src.services.profile_resolver import (
+    ProfileCycleError,
+    ResolvedProfileOutput,
+    resolve_profile,
+)
+
+
+def _make_profile(
+    name: str,
+    env_vars: dict[str, str] | None = None,
+    start_command: str | None = None,
+    working_directory: str | None = None,
+    port: int | None = None,
+    mounts: list[MagicMock] | None = None,
+    includes: list[MagicMock] | None = None,
+) -> MagicMock:
+    """Create a mock ConfigProfile for testing."""
+    profile = MagicMock()
+    profile.id = uuid.uuid4()
+    profile.name = name
+    profile.environment_variables = env_vars or {}
+    profile.start_command = start_command
+    profile.working_directory = working_directory
+    profile.port = port
+    profile.mounts = mounts or []
+    profile.includes = includes or []
+    return profile
+
+
+def _make_include(included_profile: MagicMock, order_index: int = 0) -> MagicMock:
+    """Create a mock ConfigInclude for testing."""
+    include = MagicMock()
+    include.included_profile = included_profile
+    include.order_index = order_index
+    return include
+
+
+def _make_mount(
+    target_path: str,
+    mode: str = "rw",
+    files: dict[str, str] | None = None,
+    order_index: int = 0,
+) -> MagicMock:
+    """Create a mock ConfigMount for testing."""
+    mount = MagicMock()
+    mount.target_path = target_path
+    mount.mode = mode
+    mount.files = files or {}
+    mount.order_index = order_index
+    return mount
+
+
+class TestResolveProfileBasic:
+    """Tests for basic profile resolution without includes."""
+
+    def test_empty_profile(self) -> None:
+        """Resolving an empty profile returns empty output."""
+        profile = _make_profile("empty")
+        result = resolve_profile(profile)
+
+        assert isinstance(result, ResolvedProfileOutput)
+        assert result.profile_name == "empty"
+        assert result.environment_variables == {}
+        assert result.runtime_hints.start_command is None
+        assert result.runtime_hints.working_directory is None
+        assert result.runtime_hints.port is None
+        assert result.mounts == {}
+        assert result.resolution_order == ["empty"]
+
+    def test_env_vars_only(self) -> None:
+        """Profile with env vars resolves correctly."""
+        profile = _make_profile(
+            "env-only",
+            env_vars={"FOO": "bar", "BAZ": "qux"},
+        )
+        result = resolve_profile(profile)
+
+        assert result.environment_variables == {"FOO": "bar", "BAZ": "qux"}
+        assert result.env_var_sources == {
+            "FOO": ["env-only"],
+            "BAZ": ["env-only"],
+        }
+
+    def test_runtime_hints_only(self) -> None:
+        """Profile with runtime hints resolves correctly."""
+        profile = _make_profile(
+            "hints-only",
+            start_command="python app.py",
+            working_directory="/app",
+            port=8080,
+        )
+        result = resolve_profile(profile)
+
+        assert result.runtime_hints.start_command == "python app.py"
+        assert result.runtime_hints.working_directory == "/app"
+        assert result.runtime_hints.port == 8080
+        assert result.runtime_hints.overridden_hints == {
+            "start_command": "hints-only",
+            "working_directory": "hints-only",
+            "port": "hints-only",
+        }
+
+    def test_mounts_only(self) -> None:
+        """Profile with mounts resolves correctly."""
+        profile = _make_profile(
+            "mounts-only",
+            mounts=[
+                _make_mount(
+                    "/config",
+                    mode="ro",
+                    files={"settings.json": '{"key": "value"}'},
+                ),
+            ],
+        )
+        result = resolve_profile(profile)
+
+        assert "/config" in result.mounts
+        mount = result.mounts["/config"]
+        assert mount.target_path == "/config"
+        assert mount.mode == "ro"
+        assert mount.files == {"settings.json": '{"key": "value"}'}
+
+
+class TestResolveProfileIncludes:
+    """Tests for profile resolution with includes."""
+
+    def test_single_include(self) -> None:
+        """Profile with one include resolves in correct order."""
+        base = _make_profile("base", env_vars={"FOO": "base"})
+        derived = _make_profile(
+            "derived",
+            env_vars={"BAR": "derived"},
+            includes=[_make_include(base, order_index=0)],
+        )
+        result = resolve_profile(derived)
+
+        assert result.resolution_order == ["derived", "base"]
+        assert result.environment_variables == {
+            "FOO": "base",
+            "BAR": "derived",
+        }
+
+    def test_multiple_includes_ordered(self) -> None:
+        """Multiple includes are resolved in order_index order."""
+        first = _make_profile("first", env_vars={"KEY": "first"})
+        second = _make_profile("second", env_vars={"KEY": "second"})
+        main = _make_profile(
+            "main",
+            includes=[
+                _make_include(first, order_index=0),
+                _make_include(second, order_index=1),
+            ],
+        )
+        result = resolve_profile(main)
+
+        assert result.resolution_order == ["main", "first", "second"]
+        # second overrides first
+        assert result.environment_variables == {"KEY": "second"}
+        assert result.env_var_sources["KEY"] == ["first", "second"]
+
+    def test_include_order_matters(self) -> None:
+        """Changing include order changes resolution."""
+        a = _make_profile("a", env_vars={"KEY": "a"})
+        b = _make_profile("b", env_vars={"KEY": "b"})
+        main1 = _make_profile(
+            "main",
+            includes=[
+                _make_include(a, order_index=0),
+                _make_include(b, order_index=1),
+            ],
+        )
+        main2 = _make_profile(
+            "main",
+            includes=[
+                _make_include(b, order_index=0),
+                _make_include(a, order_index=1),
+            ],
+        )
+
+        result1 = resolve_profile(main1)
+        result2 = resolve_profile(main2)
+
+        assert result1.environment_variables["KEY"] == "b"
+        assert result2.environment_variables["KEY"] == "a"
+
+    def test_nested_includes(self) -> None:
+        """Deeply nested includes resolve recursively."""
+        deep = _make_profile("deep", env_vars={"DEEP": "value"})
+        mid = _make_profile(
+            "mid",
+            env_vars={"MID": "value"},
+            includes=[_make_include(deep, order_index=0)],
+        )
+        top = _make_profile(
+            "top",
+            env_vars={"TOP": "value"},
+            includes=[_make_include(mid, order_index=0)],
+        )
+        result = resolve_profile(top)
+
+        assert result.resolution_order == ["top", "mid", "deep"]
+        assert result.environment_variables == {
+            "TOP": "value",
+            "MID": "value",
+            "DEEP": "value",
+        }
+
+
+class TestResolveProfileOverrides:
+    """Tests for deterministic override rules."""
+
+    def test_env_var_override(self) -> None:
+        """Later layers override earlier env vars."""
+        base = _make_profile("base", env_vars={"KEY": "base"})
+        override = _make_profile("override", env_vars={"KEY": "override"})
+        main = _make_profile(
+            "main",
+            includes=[
+                _make_include(base, order_index=0),
+                _make_include(override, order_index=1),
+            ],
+        )
+        result = resolve_profile(main)
+
+        assert result.environment_variables["KEY"] == "override"
+        assert result.env_var_sources["KEY"] == ["base", "override"]
+
+    def test_main_profile_wins_over_includes(self) -> None:
+        """The main profile itself wins over all includes."""
+        base = _make_profile("base", env_vars={"KEY": "base"})
+        main = _make_profile(
+            "main",
+            env_vars={"KEY": "main"},
+            includes=[_make_include(base, order_index=0)],
+        )
+        result = resolve_profile(main)
+
+        assert result.environment_variables["KEY"] == "main"
+        assert result.env_var_sources["KEY"] == ["base", "main"]
+
+    def test_runtime_hint_override(self) -> None:
+        """Later layers override earlier runtime hints."""
+        base = _make_profile("base", start_command="python old.py")
+        override = _make_profile("override", start_command="python new.py")
+        main = _make_profile(
+            "main",
+            includes=[
+                _make_include(base, order_index=0),
+                _make_include(override, order_index=1),
+            ],
+        )
+        result = resolve_profile(main)
+
+        assert result.runtime_hints.start_command == "python new.py"
+        assert result.runtime_hints.overridden_hints["start_command"] == "override"
+
+    def test_mount_file_override(self) -> None:
+        """Later layers override earlier files in the same mount."""
+        base = _make_profile(
+            "base",
+            mounts=[
+                _make_mount(
+                    "/config",
+                    files={"app.json": '{"v": 1}'},
+                ),
+            ],
+        )
+        override = _make_profile(
+            "override",
+            mounts=[
+                _make_mount(
+                    "/config",
+                    files={"app.json": '{"v": 2}'},
+                ),
+            ],
+        )
+        main = _make_profile(
+            "main",
+            includes=[
+                _make_include(base, order_index=0),
+                _make_include(override, order_index=1),
+            ],
+        )
+        result = resolve_profile(main)
+
+        mount = result.mounts["/config"]
+        assert mount.files["app.json"] == '{"v": 2}'
+        assert mount.overridden_files["app.json"] == ["override"]
+
+    def test_mount_mode_override(self) -> None:
+        """Later layers override mount mode."""
+        base = _make_profile(
+            "base",
+            mounts=[_make_mount("/data", mode="ro")],
+        )
+        override = _make_profile(
+            "override",
+            mounts=[_make_mount("/data", mode="rw")],
+        )
+        main = _make_profile(
+            "main",
+            includes=[
+                _make_include(base, order_index=0),
+                _make_include(override, order_index=1),
+            ],
+        )
+        result = resolve_profile(main)
+
+        assert result.mounts["/data"].mode == "rw"
+        assert result.mounts["/data"].mode_overridden_by == "override"
+
+    def test_mount_file_merge(self) -> None:
+        """Different files in the same mount are merged."""
+        base = _make_profile(
+            "base",
+            mounts=[
+                _make_mount(
+                    "/config",
+                    files={"a.json": "1"},
+                ),
+            ],
+        )
+        override = _make_profile(
+            "override",
+            mounts=[
+                _make_mount(
+                    "/config",
+                    files={"b.json": "2"},
+                ),
+            ],
+        )
+        main = _make_profile(
+            "main",
+            includes=[
+                _make_include(base, order_index=0),
+                _make_include(override, order_index=1),
+            ],
+        )
+        result = resolve_profile(main)
+
+        mount = result.mounts["/config"]
+        assert mount.files == {"a.json": "1", "b.json": "2"}
+
+
+class TestResolveProfileCycles:
+    """Tests for cycle detection during resolution."""
+
+    def test_direct_cycle(self) -> None:
+        """A -> B -> A is detected."""
+        a = _make_profile("a")
+        b = _make_profile("b", includes=[_make_include(a, order_index=0)])
+        a.includes = [_make_include(b, order_index=0)]
+
+        with pytest.raises(ProfileCycleError) as exc_info:
+            resolve_profile(a)
+
+        assert "a" in exc_info.value.cycle_path
+        assert "b" in exc_info.value.cycle_path
+
+    def test_indirect_cycle(self) -> None:
+        """A -> B -> C -> A is detected."""
+        a = _make_profile("a")
+        c = _make_profile("c")
+        b = _make_profile("b", includes=[_make_include(c, order_index=0)])
+        a.includes = [_make_include(b, order_index=0)]
+        c.includes = [_make_include(a, order_index=0)]
+
+        with pytest.raises(ProfileCycleError) as exc_info:
+            resolve_profile(a)
+
+        assert "a" in exc_info.value.cycle_path
+        assert "b" in exc_info.value.cycle_path
+        assert "c" in exc_info.value.cycle_path
+
+    def test_self_cycle(self) -> None:
+        """A -> A is detected."""
+        a = _make_profile("a")
+        a.includes = [_make_include(a, order_index=0)]
+
+        with pytest.raises(ProfileCycleError) as exc_info:
+            resolve_profile(a)
+
+        assert exc_info.value.cycle_path == ["a", "a"]
+
+    def test_cycle_does_not_partially_resolve(self) -> None:
+        """Cycle detection prevents any partial resolution."""
+        a = _make_profile("a", env_vars={"A": "a"})
+        b = _make_profile("b", env_vars={"B": "b"})
+        a.includes = [_make_include(b, order_index=0)]
+        b.includes = [_make_include(a, order_index=0)]
+
+        with pytest.raises(ProfileCycleError):
+            resolve_profile(a)
+
+
+class TestResolveProfileDiamond:
+    """Tests for diamond-shaped include graphs."""
+
+    def test_diamond_resolution(self) -> None:
+        """Diamond graph resolves correctly without duplication issues."""
+        base = _make_profile("base", env_vars={"BASE": "base"})
+        left = _make_profile(
+            "left",
+            env_vars={"LEFT": "left"},
+            includes=[_make_include(base, order_index=0)],
+        )
+        right = _make_profile(
+            "right",
+            env_vars={"RIGHT": "right"},
+            includes=[_make_include(base, order_index=0)],
+        )
+        top = _make_profile(
+            "top",
+            env_vars={"TOP": "top"},
+            includes=[
+                _make_include(left, order_index=0),
+                _make_include(right, order_index=1),
+            ],
+        )
+        result = resolve_profile(top)
+
+        # base should appear once (via left, then right skips because visited)
+        assert result.resolution_order == ["top", "left", "base", "right"]
+        assert result.environment_variables == {
+            "TOP": "top",
+            "LEFT": "left",
+            "RIGHT": "right",
+            "BASE": "base",
+        }
+
+    def test_diamond_override(self) -> None:
+        """Diamond graph with conflicting overrides resolves correctly."""
+        base = _make_profile("base", env_vars={"KEY": "base"})
+        left = _make_profile(
+            "left",
+            env_vars={"KEY": "left"},
+            includes=[_make_include(base, order_index=0)],
+        )
+        right = _make_profile(
+            "right",
+            env_vars={"KEY": "right"},
+            includes=[_make_include(base, order_index=0)],
+        )
+        top = _make_profile(
+            "top",
+            includes=[
+                _make_include(left, order_index=0),
+                _make_include(right, order_index=1),
+            ],
+        )
+        result = resolve_profile(top)
+
+        # right wins because it's later
+        assert result.environment_variables["KEY"] == "right"
+        assert result.env_var_sources["KEY"] == ["base", "left", "right"]
+        # Note: base appears once because visited set skips duplicate resolution in diamond graphs

apps/api/tests/unit/test_terminal_manager.py

@@ -0,0 +1,112 @@
+"""Unit tests for TerminalManager."""
+
+from unittest.mock import AsyncMock, MagicMock, patch
+
+import pytest
+
+from src.services.terminal_manager import TerminalManager
+from src.services.terminal_session import TerminalSession
+
+
+@pytest.fixture
+def manager():
+    return TerminalManager()
+
+
+@pytest.fixture
+def mock_websocket():
+    ws = AsyncMock()
+    ws.send_bytes = AsyncMock()
+    ws.send_json = AsyncMock()
+    ws.close = AsyncMock()
+    ws.receive = AsyncMock()
+    return ws
+
+
+@pytest.fixture
+def mock_session():
+    session = MagicMock(spec=TerminalSession)
+    session.session_id = "sess-123"
+    session.is_alive.return_value = True
+    session._closed = False
+    session.read_output = AsyncMock(return_value=b"")
+    session.write_input = AsyncMock()
+    session.resize = AsyncMock()
+    session.close = AsyncMock()
+    session.get_exit_reason.return_value = None
+    return session
+
+
+class TestCreateSession:
+    @patch("src.services.terminal_manager.asyncio.create_task")
+    @patch("src.services.terminal_manager.uuid.uuid4", return_value="sess-123")
+    async def test_create_session_registers_and_starts_loops(
+        self, mock_uuid, mock_create_task, manager, mock_websocket
+    ):
+        instance_id = __import__("uuid").uuid4()
+        mock_sess = MagicMock()
+        mock_sess.session_id = "sess-123"
+        mock_sess.is_alive.return_value = True
+        mock_sess._closed = False
+        mock_sess.start = AsyncMock()
+        mock_sess.read_output = AsyncMock(return_value=b"")
+        mock_sess.write_input = AsyncMock()
+        mock_sess.resize = AsyncMock()
+        mock_sess.close = AsyncMock()
+        mock_sess.get_exit_reason.return_value = None
+
+        with (
+            patch.object(manager, "_read_loop", new=AsyncMock()),
+            patch.object(manager, "_write_loop", new=AsyncMock()),
+            patch.object(manager, "_heartbeat_loop", new=AsyncMock()),
+            patch(
+                "src.services.terminal_manager.TerminalSession",
+                return_value=mock_sess,
+            ),
+        ):
+            session = await manager.create_session(
+                instance_id, "container-abc", mock_websocket
+            )
+            assert session.session_id == "sess-123"
+            assert "sess-123" in manager._sessions
+            assert "sess-123" in manager._last_client_message
+
+
+class TestHandleControlMessage:
+    async def test_handle_resize(self, manager, mock_session, mock_websocket):
+        ctrl = {"type": "resize", "cols": 120, "rows": 40}
+        await manager._handle_control_message(mock_session, mock_websocket, ctrl)
+        mock_session.resize.assert_awaited_once_with(120, 40)
+
+    async def test_handle_ping(self, manager, mock_session, mock_websocket):
+        ctrl = {"type": "ping", "id": 42}
+        await manager._handle_control_message(mock_session, mock_websocket, ctrl)
+        mock_websocket.send_json.assert_awaited_once_with({"type": "pong", "id": 42})
+
+    async def test_handle_unknown_type(self, manager, mock_session, mock_websocket):
+        ctrl = {"type": "unknown", "data": "test"}
+        await manager._handle_control_message(mock_session, mock_websocket, ctrl)
+        mock_websocket.send_json.assert_not_awaited()
+        mock_session.resize.assert_not_awaited()
+
+
+class TestCleanupSession:
+    async def test_cleanup_removes_session(self, manager, mock_session):
+        manager._sessions["sess-123"] = mock_session
+        manager._last_client_message["sess-123"] = 123.0
+
+        await manager._cleanup_session(mock_session)
+        assert "sess-123" not in manager._sessions
+        assert "sess-123" not in manager._last_client_message
+        mock_session.close.assert_awaited_once()
+
+
+class TestCloseAll:
+    async def test_close_all_clears_sessions(self, manager, mock_session):
+        manager._sessions["sess-123"] = mock_session
+        manager._last_client_message["sess-123"] = 123.0
+
+        await manager.close_all()
+        assert len(manager._sessions) == 0
+        assert len(manager._last_client_message) == 0
+        mock_session.close.assert_awaited_once()

apps/api/tests/unit/test_terminal_session.py

@@ -0,0 +1,168 @@
+"""Unit tests for TerminalSession."""
+
+import asyncio
+from unittest.mock import MagicMock, patch
+
+import pytest
+
+from src.services.terminal_session import TerminalSession
+
+
+@pytest.fixture
+def mock_pty():
+    """Mock pty.openpty to return predictable fds."""
+    master_fd = 10
+    slave_fd = 11
+    with (
+        patch(
+            "src.services.terminal_session.pty.openpty",
+            return_value=(master_fd, slave_fd),
+        ),
+        patch("src.services.terminal_session.os.close") as mock_close,
+    ):
+        yield master_fd, slave_fd, mock_close
+
+
+class TestTerminalSessionStart:
+    def test_init_state(self, mock_pty):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+
+        assert session.session_id == "sess-1"
+        assert session.container_id == "container-abc"
+        assert session._echo_enabled is True
+        assert session._exit_reason is None
+
+
+class TestTerminalSessionEchoDetection:
+    @patch("src.services.terminal_session.termios.tcgetattr")
+    def test_detect_echo_state_enabled(self, mock_tcgetattr):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+
+        # termios.ECHO flag set
+        attrs = [[], [], [], __import__("termios").ECHO, [], [], []]
+        mock_tcgetattr.return_value = attrs
+
+        result = session._detect_echo_state()
+        assert result is True
+
+    @patch("src.services.terminal_session.termios.tcgetattr")
+    def test_detect_echo_state_disabled(self, mock_tcgetattr):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+
+        # termios.ECHO flag NOT set
+        attrs = [[], [], [], 0, [], [], []]
+        mock_tcgetattr.return_value = attrs
+
+        result = session._detect_echo_state()
+        assert result is False
+
+    def test_detect_echo_state_no_master_fd(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = None
+
+        result = session._detect_echo_state()
+        assert result is True  # default
+
+
+class TestTerminalSessionResize:
+    @patch("src.services.terminal_session.fcntl.ioctl")
+    def test_resize_sets_size(self, mock_ioctl):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+
+        # Should not raise
+        asyncio.run(session.resize(120, 40))
+        mock_ioctl.assert_called_once()
+
+    def test_resize_when_closed(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._closed = True
+
+        # Should not raise
+        asyncio.run(session.resize(120, 40))
+
+
+class TestTerminalSessionWriteInput:
+    @patch("src.services.terminal_session.os.write")
+    def test_write_input(self, mock_write):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+
+        asyncio.run(session.write_input(b"hello"))
+        mock_write.assert_called_once_with(10, b"hello")
+
+    def test_write_input_when_closed(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._closed = True
+
+        # Should not raise
+        asyncio.run(session.write_input(b"hello"))
+
+
+class TestTerminalSessionReadOutput:
+    @patch("src.services.terminal_session.select.select")
+    @patch("src.services.terminal_session.os.read")
+    def test_read_output_with_data(self, mock_read, mock_select):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+
+        mock_select.return_value = ([10], [], [])
+        mock_read.return_value = b"output"
+
+        result = asyncio.run(session.read_output())
+        assert result == b"output"
+
+    @patch("src.services.terminal_session.select.select")
+    def test_read_output_no_data(self, mock_select):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+
+        mock_select.return_value = ([], [], [])
+
+        result = asyncio.run(session.read_output())
+        assert result == b""
+
+
+class TestTerminalSessionClose:
+    @patch("src.services.terminal_session.os.close")
+    @patch("src.services.terminal_session.asyncio.wait_for")
+    async def test_close_sets_exit_reason(self, mock_wait_for, mock_close):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._master_fd = 10
+        session.process = MagicMock()
+        session.process.returncode = 0
+
+        await session.close()
+        assert session._exit_reason == "process_exit"
+        assert session._closed is True
+
+    async def test_close_idempotent(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session._closed = True
+
+        # Should not raise
+        await session.close()
+
+
+class TestTerminalSessionIsAlive:
+    def test_is_alive_with_running_process(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session.process = MagicMock()
+        session.process.returncode = None
+
+        assert session.is_alive() is True
+
+    def test_is_alive_with_exited_process(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session.process = MagicMock()
+        session.process.returncode = 0
+
+        assert session.is_alive() is False
+
+    def test_is_alive_no_process(self):
+        session = TerminalSession("sess-1", __import__("uuid").uuid4(), "container-abc")
+        session.process = None
+
+        assert session.is_alive() is False

apps/web/package-lock.json

@@ -19,6 +19,7 @@
         "tailwindcss": "^3.3.0",
         "xterm": "^5.3.0",
         "xterm-addon-fit": "^0.8.0",
+        "xterm-addon-serialize": "^0.11.0",
         "xterm-addon-web-links": "^0.9.0"
       },
       "devDependencies": {
@@ -6372,6 +6373,16 @@
         "xterm": "^5.0.0"
       }
     },
+    "node_modules/xterm-addon-serialize": {
+      "version": "0.11.0",
+      "resolved": "https://registry.npmjs.org/xterm-addon-serialize/-/xterm-addon-serialize-0.11.0.tgz",
+      "integrity": "sha512-2CNDnmLdLkNWfsxNFkGsI5FE9W/BbsMzeOrbu59yNqH9L6k1gmL+Ab6VXxEp2NQUJSzaiqi6t0nFR5k5EDkVIg==",
+      "deprecated": "This package is now deprecated. Move to @xterm/addon-serialize instead.",
+      "license": "MIT",
+      "peerDependencies": {
+        "xterm": "^5.0.0"
+      }
+    },
     "node_modules/xterm-addon-web-links": {
       "version": "0.9.0",
       "resolved": "https://registry.npmjs.org/xterm-addon-web-links/-/xterm-addon-web-links-0.9.0.tgz",

apps/web/package.json

@@ -22,6 +22,7 @@
     "tailwindcss": "^3.3.0",
     "xterm": "^5.3.0",
     "xterm-addon-fit": "^0.8.0",
+    "xterm-addon-serialize": "^0.11.0",
     "xterm-addon-web-links": "^0.9.0"
   },
   "devDependencies": {

apps/web/src/components/app-shell.tsx

@@ -16,8 +16,11 @@ const NAV_ITEMS: { to: string; label: string; icon: IconName }[] = [
   { to: "/settings", label: "Settings", icon: "settings" }
 ];
 
+const ACTIVE_STATUSES = ["running", "building", "pending"];
+
 const SessionItem = ({ session }: { session: Session }) => {
   const isRunning = session.status === "running";
+  const displayName = session.display_name || session.tool_type_name || "Unnamed Session";
 
   return (
     <a
@@ -25,11 +28,11 @@ const SessionItem = ({ session }: { session: Session }) => {
       target={session.url ? "_blank" : undefined}
       rel={session.url ? "noopener noreferrer" : undefined}
       className="nav-item session-item"
-      title={`${session.display_name} (${session.status})`}
+      title={`${displayName} (${session.status})`}
     >
       <span className={`session-status ${isRunning ? "running" : ""}`} />
       <Icon name={session.tool_icon as IconName} size="sm" />
-      <span className="session-name">{session.display_name}</span>
+      <span className="session-name">{displayName}</span>
     </a>
   );
 };
@@ -101,13 +104,15 @@ export const AppShell = () => {
             );
           })}
           
-          {sessions.length > 0 && (
+          {sessions.filter((s) => ACTIVE_STATUSES.includes(s.status)).length > 0 && (
             <>
               <div className="nav-divider" />
               <div className="nav-section-title">Live sessions</div>
-              {sessions.map((session) => (
+              {sessions
-                <SessionItem key={session.id} session={session} />
+                .filter((s) => ACTIVE_STATUSES.includes(s.status))
-              ))}
+                .map((session) => (
+                  <SessionItem key={session.id} session={session} />
+                ))}
             </>
           )}
         </aside>

apps/web/src/components/instance-list.tsx

@@ -194,7 +194,7 @@ export const InstanceList = ({ projectId, repoId, toolTypes }: InstanceListProps
           {instances.map((instance) => (
             <div key={instance.id} className="instance-card">
               <div className="instance-info">
-                <div className="instance-name">{instance.display_name}</div>
+                <div className="instance-name">{instance.display_name || instance.tool_type_name || "Unnamed Instance"}</div>
                 <div className="instance-meta">
                   <span
                     className="status-dot"

apps/web/src/components/terminal.tsx

@@ -1,158 +1,309 @@
-import React, { useEffect, useRef, useState } from "react";
+import React, { useCallback, useEffect, useRef, useState } from "react";
 import { Terminal } from "xterm";
 import { FitAddon } from "xterm-addon-fit";
+import { SerializeAddon } from "xterm-addon-serialize";
 import { WebLinksAddon } from "xterm-addon-web-links";
 import "xterm/css/xterm.css";
 
+import { useTerminalConnection } from "../hooks/use-terminal-connection";
+import type {
+	ServerControlMessage,
+	TerminalConnectionState,
+} from "../types/terminal";
+
 interface TerminalProps {
-  instanceId: string;
+	instanceId: string;
-  onClose?: () => void;
+	onClose?: () => void;
 }
 
-export const TerminalComponent: React.FC<TerminalProps> = ({ instanceId, onClose }) => {
+const STATUS_DOT_COLORS: Record<TerminalConnectionState["status"], string> = {
-  const terminalRef = useRef<HTMLDivElement>(null);
+	connecting: "var(--warning)",
-  const wsRef = useRef<WebSocket | null>(null);
+	connected: "var(--success)",
-  const [status, setStatus] = useState<"connecting" | "connected" | "disconnected" | "error">(
+	reconnecting: "var(--warning)",
-    "connecting",
+	disconnected: "var(--muted)",
-  );
+};
-  const [error, setError] = useState<string | null>(null);
+
-
+function getStatusText(state: TerminalConnectionState): string {
-  useEffect(() => {
+	switch (state.status) {
-    if (!terminalRef.current) return;
+		case "connecting":
-
+			return "Connecting...";
-    // Initialize terminal
+		case "connected": {
-    const term = new Terminal({
+			if (state.latency !== null && state.latency >= 100) {
-      cursorBlink: true,
+				return `Slow (${state.latency}ms)`;
-      fontSize: 14,
+			}
-      fontFamily: 'Menlo, Monaco, "Courier New", monospace',
+			return "Connected";
-      theme: {
+		}
-        background: "#1e1e1e",
+		case "reconnecting":
-        foreground: "#d4d4d4",
+			return `Reconnecting${state.attempt > 0 ? ` (${state.attempt})` : ""}`;
-        cursor: "#d4d4d4",
+		case "disconnected":
-        selectionBackground: "#264f78",
+			return state.error || "Disconnected";
-        black: "#000000",
+	}
-        red: "#cd3131",
+}
-        green: "#0dbc79",
+
-        yellow: "#e5e510",
+export const TerminalComponent: React.FC<TerminalProps> = ({
-        blue: "#2472c8",
+	instanceId,
-        magenta: "#bc3fbc",
+	onClose,
-        cyan: "#11a8cd",
+}) => {
-        white: "#e5e5e5",
+	const terminalRef = useRef<HTMLDivElement>(null);
-        brightBlack: "#666666",
+	const xtermRef = useRef<Terminal | null>(null);
-        brightRed: "#f14c4c",
+	const fitAddonRef = useRef<FitAddon | null>(null);
-        brightGreen: "#23d18b",
+	const serializeAddonRef = useRef<SerializeAddon | null>(null);
-        brightYellow: "#f5f543",
+	const resizeObserverRef = useRef<ResizeObserver | null>(null);
-        brightBlue: "#3b8eea",
+	const [sessionEnded, setSessionEnded] = useState<{
-        brightMagenta: "#d670d6",
+		reason: string;
-        brightCyan: "#29b8db",
+		message: string;
-        brightWhite: "#e5e5e5",
+	} | null>(null);
-      },
+
-    });
+	// Determine dark mode from document theme
-
+	const isDarkMode =
-    const fitAddon = new FitAddon();
+		document.documentElement.getAttribute("data-theme") === "dark" ||
-    term.loadAddon(fitAddon);
+		(document.documentElement.getAttribute("data-theme") === null &&
-    term.loadAddon(new WebLinksAddon());
+			window.matchMedia("(prefers-color-scheme: dark)").matches);
-
+
-    term.open(terminalRef.current);
+	const handleData = useCallback((data: Uint8Array) => {
-    fitAddon.fit();
+		// Data is already written by onLocalEcho or deduplication
-
+		// This callback is mainly for external consumers
-    // Build WebSocket URL
+		void data;
-    const apiUrl = import.meta.env.VITE_API_BASE_URL || "";
+	}, []);
-    const wsProtocol = window.location.protocol === "https:" ? "wss:" : "ws:";
+
-    const wsHost = apiUrl.replace(/^https?:\/\//, "").replace(/\/+$/, "");
+	const handleLocalEcho = useCallback((data: string) => {
-    const wsUrl = `${wsProtocol}//${wsHost}/ws/tool-instances/${instanceId}/terminal`;
+		xtermRef.current?.write(data);
-
+	}, []);
-    // Connect WebSocket
+
-    const ws = new WebSocket(wsUrl);
+	const serializeFn = useCallback((): string | null => {
-    wsRef.current = ws;
+		return serializeAddonRef.current?.serialize() ?? null;
-
+	}, []);
-    ws.onopen = () => {
+
-      setStatus("connected");
+	const handleRestoreScrollback = useCallback((content: string) => {
-      setError(null);
+		xtermRef.current?.write(content);
-    };
+		xtermRef.current?.write("\r\n\x1b[90m--- Reconnected ---\x1b[0m\r\n");
-
+	}, []);
-    ws.onmessage = (event) => {
+
-      if (event.data instanceof Blob) {
+	const handleControl = useCallback((msg: ServerControlMessage) => {
-        event.data.arrayBuffer().then((buffer) => {
+		if (msg.type === "session_ended") {
-          const data = new Uint8Array(buffer);
+			const messages: Record<string, string> = {
-          term.write(data);
+				process_exit: "The container process has exited.",
-        });
+				container_stop: "The container was stopped.",
-      } else if (typeof event.data === "string") {
+				timeout: "The session timed out due to inactivity.",
-        try {
+			};
-          const msg = JSON.parse(event.data);
+			setSessionEnded({
-          if (msg.type === "status" && msg.status === "connected") {
+				reason: msg.reason,
-            setStatus("connected");
+				message: messages[msg.reason] || "The session has ended.",
-          }
+			});
-        } catch {
+		}
-          term.write(event.data);
+	}, []);
-        }
+
-      }
+	const { state, sendInput, sendResize, reconnect } = useTerminalConnection({
-    };
+		instanceId,
-
+		onData: handleData,
-    ws.onclose = (event) => {
+		onControl: handleControl,
-      setStatus("disconnected");
+		onLocalEcho: handleLocalEcho,
-      if (event.code !== 1000) {
+		serializeFn,
-        setError(`Connection closed (code: ${event.code})`);
+		onRestoreScrollback: handleRestoreScrollback,
-      }
+	});
-    };
+
-
+	// Initialize xterm
-    ws.onerror = () => {
+	useEffect(() => {
-      setStatus("error");
+		if (!terminalRef.current) return;
-      setError("WebSocket error");
+
-    };
+		const term = new Terminal({
-
+			cursorBlink: true,
-    // Handle terminal input
+			fontSize: 14,
-    term.onData((data) => {
+			fontFamily: 'Menlo, Monaco, "Courier New", monospace',
-      if (ws.readyState === WebSocket.OPEN) {
+			theme: isDarkMode
-        ws.send(data);
+				? {
-      }
+						background: "#1e1e1e",
-    });
+						foreground: "#d4d4d4",
-
+						cursor: "#d4d4d4",
-    // Handle resize
+						selectionBackground: "#264f78",
-    const handleResize = () => {
+						black: "#000000",
-      fitAddon.fit();
+						red: "#cd3131",
-      const { cols, rows } = term;
+						green: "#0dbc79",
-      if (ws.readyState === WebSocket.OPEN) {
+						yellow: "#e5e510",
-        ws.send(
+						blue: "#2472c8",
-          JSON.stringify({
+						magenta: "#bc3fbc",
-            type: "resize",
+						cyan: "#11a8cd",
-            cols,
+						white: "#e5e5e5",
-            rows,
+						brightBlack: "#666666",
-          }),
+						brightRed: "#f14c4c",
-        );
+						brightGreen: "#23d18b",
-      }
+						brightYellow: "#f5f543",
-    };
+						brightBlue: "#3b8eea",
-
+						brightMagenta: "#d670d6",
-    window.addEventListener("resize", handleResize);
+						brightCyan: "#29b8db",
-
+						brightWhite: "#e5e5e5",
-    // Initial resize
+					}
-    setTimeout(handleResize, 100);
+				: {
-
+						background: "#fafafa",
-    return () => {
+						foreground: "#333333",
-      window.removeEventListener("resize", handleResize);
+						cursor: "#333333",
-      ws.close();
+						selectionBackground: "#b4d7ff",
-      term.dispose();
+						black: "#000000",
-    };
+						red: "#cd3131",
-  }, [instanceId]);
+						green: "#0dbc79",
-
+						yellow: "#e5e510",
-  return (
+						blue: "#2472c8",
-    <div className="terminal-wrapper">
+						magenta: "#bc3fbc",
-      <div className="terminal-header">
+						cyan: "#11a8cd",
-        <div className="terminal-status">
+						white: "#e5e5e5",
-          <span
+						brightBlack: "#666666",
-            className={`status-dot ${status}`}
+						brightRed: "#f14c4c",
-            aria-label={`Terminal status: ${status}`}
+						brightGreen: "#23d18b",
-          />
+						brightYellow: "#f5f543",
-          <span className="status-text">{status}</span>
+						brightBlue: "#3b8eea",
-        </div>
+						brightMagenta: "#d670d6",
-        {onClose && (
+						brightCyan: "#29b8db",
-          <button className="terminal-close" onClick={onClose} type="button">
+						brightWhite: "#e5e5e5",
-            Close
+					},
-          </button>
+		});
-        )}
+
-      </div>
+		const fitAddon = new FitAddon();
-      {error && <div className="terminal-error">{error}</div>}
+		const serializeAddon = new SerializeAddon();
-      <div ref={terminalRef} className="terminal-container" />
+
-    </div>
+		term.loadAddon(fitAddon);
-  );
+		term.loadAddon(serializeAddon);
+		term.loadAddon(new WebLinksAddon());
+
+		term.open(terminalRef.current);
+		fitAddon.fit();
+
+		xtermRef.current = term;
+		fitAddonRef.current = fitAddon;
+		serializeAddonRef.current = serializeAddon;
+
+		// Handle terminal input
+		const disposable = term.onData((data) => {
+			sendInput(data);
+		});
+
+		// Resize observer for container-level resize detection
+		let resizeTimeout: ReturnType<typeof setTimeout> | null = null;
+		let lastWidth = 0;
+		let lastHeight = 0;
+		const resizeObserver = new ResizeObserver((entries) => {
+			if (resizeTimeout) {
+				clearTimeout(resizeTimeout);
+			}
+			const entry = entries[0];
+			if (!entry) return;
+			const { width, height } = entry.contentRect;
+			resizeTimeout = setTimeout(() => {
+				resizeTimeout = null;
+				// Guard against internal xterm DOM changes that don't affect container size
+				if (
+					Math.abs(width - lastWidth) < 1 &&
+					Math.abs(height - lastHeight) < 1
+				) {
+					return;
+				}
+				lastWidth = width;
+				lastHeight = height;
+				const prevCols = term.cols;
+				const prevRows = term.rows;
+				fitAddon.fit();
+				if (term.cols !== prevCols || term.rows !== prevRows) {
+					sendResize(term.cols, term.rows);
+				}
+			}, 100);
+		});
+		resizeObserver.observe(terminalRef.current);
+		resizeObserverRef.current = resizeObserver;
+
+		return () => {
+			if (resizeTimeout) {
+				clearTimeout(resizeTimeout);
+			}
+			disposable.dispose();
+			resizeObserver.disconnect();
+			term.dispose();
+			xtermRef.current = null;
+			fitAddonRef.current = null;
+			serializeAddonRef.current = null;
+		};
+	}, [instanceId, isDarkMode, sendInput, sendResize]);
+
+	// Send initial terminal size once connected (and on reconnect)
+	useEffect(() => {
+		if (state.status === "connected" && xtermRef.current) {
+			const { cols, rows } = xtermRef.current;
+			sendResize(cols, rows);
+		}
+	}, [state.status, sendResize]);
+
+	return (
+		<div className="terminal-wrapper">
+			<div className="terminal-header">
+				<div className="terminal-status">
+					<span
+						className="status-dot"
+						style={{
+							backgroundColor: STATUS_DOT_COLORS[state.status],
+						}}
+						aria-label={`Terminal status: ${state.status}`}
+						title={
+							state.latency !== null
+								? `Latency: ${state.latency}ms`
+								: getStatusText(state)
+						}
+					/>
+					<span className="status-text">{getStatusText(state)}</span>
+				</div>
+				<div className="terminal-actions">
+					{state.status === "disconnected" && (
+						<button
+							className="secondary-button small"
+							onClick={reconnect}
+							type="button"
+						>
+							Reconnect
+						</button>
+					)}
+					{onClose && (
+						<button className="terminal-close" onClick={onClose} type="button">
+							Close
+						</button>
+					)}
+				</div>
+			</div>
+
+			{sessionEnded && (
+				<div className="terminal-overlay">
+					<div className="terminal-overlay-content">
+						<h3>Session Ended</h3>
+						<p>{sessionEnded.message}</p>
+						<div className="terminal-overlay-actions">
+							<button
+								className="primary-button small"
+								onClick={() => {
+									setSessionEnded(null);
+									reconnect();
+								}}
+								type="button"
+							>
+								Reconnect
+							</button>
+							{onClose && (
+								<button
+									className="secondary-button small"
+									onClick={onClose}
+									type="button"
+								>
+									Go Back
+								</button>
+							)}
+						</div>
+					</div>
+				</div>
+			)}
+
+			{state.status === "reconnecting" && (
+				<div className="terminal-reconnect-banner">
+					<span className="spinner" />
+					{state.error}
+				</div>
+			)}
+
+			<div ref={terminalRef} className="terminal-container" />
+		</div>
+	);
 };

apps/web/src/hooks/use-terminal-connection.test.ts

@@ -0,0 +1,339 @@
+import { describe, it, expect, vi, beforeEach, afterEach } from "vitest";
+import { renderHook, act } from "@testing-library/react";
+import { useTerminalConnection } from "./use-terminal-connection";
+
+class MockWebSocket {
+	static instances: MockWebSocket[] = [];
+	readyState: number = WebSocket.CONNECTING;
+	onopen: ((ev: Event) => void) | null = null;
+	onclose: ((ev: CloseEvent) => void) | null = null;
+	onmessage: ((ev: MessageEvent) => void) | null = null;
+	onerror: ((ev: Event) => void) | null = null;
+	sent: (string | ArrayBuffer | Blob)[] = [];
+	url = "";
+
+	constructor(url: string) {
+		this.url = url;
+		MockWebSocket.instances.push(this);
+	}
+
+	send(data: string | ArrayBuffer | Blob) {
+		this.sent.push(data);
+	}
+
+	close(code?: number, reason?: string) {
+		this.readyState = WebSocket.CLOSED;
+		if (this.onclose) {
+			this.onclose(new CloseEvent("close", { code: code ?? 1000, reason }));
+		}
+	}
+
+	simulateOpen() {
+		this.readyState = WebSocket.OPEN;
+		if (this.onopen) this.onopen(new Event("open"));
+	}
+
+	simulateMessage(data: string | ArrayBuffer | Blob) {
+		if (this.onmessage) {
+			this.onmessage(new MessageEvent("message", { data }));
+		}
+	}
+
+	simulateError() {
+		if (this.onerror) this.onerror(new Event("error"));
+	}
+}
+
+describe("useTerminalConnection", () => {
+	let originalWebSocket: typeof WebSocket;
+
+	beforeEach(() => {
+		originalWebSocket = globalThis.WebSocket;
+		globalThis.WebSocket = MockWebSocket as unknown as typeof WebSocket;
+		MockWebSocket.instances = [];
+		vi.useFakeTimers();
+		vi.stubGlobal("import", { meta: { env: { VITE_API_BASE_URL: "" } } });
+	});
+
+	afterEach(() => {
+		globalThis.WebSocket = originalWebSocket;
+		MockWebSocket.instances = [];
+		vi.useRealTimers();
+		vi.unstubAllGlobals();
+	});
+
+	it("starts in connecting state", () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+		expect(result.current.state.status).toBe("connecting");
+		expect(MockWebSocket.instances).toHaveLength(1);
+	});
+
+	it("transitions to connected on websocket open", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		expect(result.current.state.status).toBe("connected");
+	});
+
+	it("sends ping after interval", async () => {
+		renderHook(() => useTerminalConnection({ instanceId: "inst-1" }));
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			vi.advanceTimersByTime(15000);
+		});
+
+		const pings = MockWebSocket.instances[0].sent.filter((s) =>
+			typeof s === "string" ? s.includes("ping") : false,
+		);
+		expect(pings.length).toBeGreaterThanOrEqual(1);
+	});
+
+	it("handles pong and updates latency", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			vi.advanceTimersByTime(15000);
+		});
+
+		act(() => {
+			MockWebSocket.instances[0].simulateMessage(
+				JSON.stringify({ type: "pong", id: 1 }),
+			);
+		});
+
+		expect(result.current.state.latency).not.toBeNull();
+		expect(result.current.state.latency).toBeGreaterThanOrEqual(0);
+	});
+
+	it("reconnects with exponential backoff on close", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			MockWebSocket.instances[0].close(1006, "Abnormal closure");
+		});
+
+		expect(result.current.state.status).toBe("reconnecting");
+		expect(result.current.state.attempt).toBe(1);
+
+		act(() => {
+			vi.advanceTimersByTime(1000);
+		});
+
+		expect(MockWebSocket.instances).toHaveLength(2);
+	});
+
+	it("max reconnect attempts leads to disconnected", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		for (let i = 0; i < 11; i++) {
+			const ws = MockWebSocket.instances[MockWebSocket.instances.length - 1];
+			act(() => {
+				ws.close(1006, "Abnormal closure");
+			});
+			const delay = Math.min(1000 * 2 ** i, 30000);
+			act(() => {
+				vi.advanceTimersByTime(delay);
+			});
+		}
+
+		expect(result.current.state.status).toBe("disconnected");
+		expect(result.current.state.error).toContain("Max reconnection");
+	}, 30000);
+
+	it("sends resize message with debounce", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			result.current.sendResize(120, 40);
+		});
+
+		// Before debounce
+		expect(
+			MockWebSocket.instances[0].sent.filter((s) =>
+				typeof s === "string" ? s.includes("resize") : false,
+			),
+		).toHaveLength(0);
+
+		act(() => {
+			vi.advanceTimersByTime(250);
+		});
+
+		const resizes = MockWebSocket.instances[0].sent.filter((s) =>
+			typeof s === "string" ? s.includes("resize") : false,
+		);
+		expect(resizes.length).toBeGreaterThanOrEqual(1);
+	});
+
+	it("throttles resize messages", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			result.current.sendResize(100, 30);
+		});
+		act(() => {
+			vi.advanceTimersByTime(250);
+		});
+
+		act(() => {
+			result.current.sendResize(101, 31);
+		});
+		act(() => {
+			vi.advanceTimersByTime(250);
+		});
+
+		const resizes = MockWebSocket.instances[0].sent.filter((s) =>
+			typeof s === "string" ? s.includes("resize") : false,
+		);
+		// Second resize throttled (within 500ms)
+		expect(resizes.length).toBe(1);
+	});
+
+	it("sendInput sends data over websocket", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			result.current.sendInput("a");
+		});
+
+		expect(MockWebSocket.instances[0].sent).toContain("a");
+	});
+
+	it("triggers manual reconnect on reconnect()", async () => {
+		const { result } = renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1" }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			result.current.reconnect();
+		});
+
+		expect(MockWebSocket.instances).toHaveLength(2);
+	});
+
+	it("calls onData callback with binary data", async () => {
+		const onData = vi.fn();
+		renderHook(() => useTerminalConnection({ instanceId: "inst-1", onData }));
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		const buffer = new ArrayBuffer(3);
+		act(() => {
+			MockWebSocket.instances[0].simulateMessage(buffer);
+		});
+
+		expect(onData).toHaveBeenCalledWith(expect.any(Uint8Array));
+	});
+
+	it("calls onControl callback with control messages", async () => {
+		const onControl = vi.fn();
+		renderHook(() =>
+			useTerminalConnection({ instanceId: "inst-1", onControl }),
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		act(() => {
+			MockWebSocket.instances[0].simulateMessage(
+				JSON.stringify({ type: "set_echo_state", enabled: false }),
+			);
+		});
+
+		expect(onControl).toHaveBeenCalledWith(
+			expect.objectContaining({ type: "set_echo_state", enabled: false }),
+		);
+	});
+
+	it("serializes and restores scrollback", async () => {
+		const serializeFn = vi.fn(() => "scrollback-content");
+		const onRestoreScrollback = vi.fn();
+
+		renderHook(
+			() =>
+				useTerminalConnection({
+					instanceId: "inst-1",
+					serializeFn,
+					onRestoreScrollback,
+				}),
+			{ initialProps: {} },
+		);
+
+		act(() => {
+			MockWebSocket.instances[0].simulateOpen();
+		});
+
+		// Disconnect
+		act(() => {
+			MockWebSocket.instances[0].close(1006, "gone");
+		});
+
+		expect(serializeFn).toHaveBeenCalled();
+
+		act(() => {
+			vi.advanceTimersByTime(1000);
+		});
+
+		// New connection opens
+		act(() => {
+			MockWebSocket.instances[
+				MockWebSocket.instances.length - 1
+			].simulateOpen();
+		});
+
+		expect(onRestoreScrollback).toHaveBeenCalledWith("scrollback-content");
+	});
+});

apps/web/src/hooks/use-terminal-connection.ts

@@ -0,0 +1,439 @@
+import { useCallback, useEffect, useRef, useState } from "react";
+import type {
+	ClientControlMessage,
+	ServerControlMessage,
+	TerminalConnectionState,
+} from "../types/terminal";
+import {
+	decodeControlMessage,
+	encodeControlMessage,
+	isControlMessage,
+} from "../utils/terminal-protocol";
+
+const PING_INTERVAL_MS = 15_000;
+const PONG_TIMEOUT_MS = 5_000;
+const RECONNECT_BASE_MS = 1_000;
+const RECONNECT_MAX_MS = 30_000;
+const MAX_RECONNECT_ATTEMPTS = 10;
+const RESIZE_DEBOUNCE_MS = 200;
+const RESIZE_THROTTLE_MS = 500;
+const PENDING_ECHO_FLUSH_LIMIT = 100;
+const SCROLLBACK_STORAGE_KEY = "hq-terminal";
+
+interface UseTerminalConnectionOptions {
+	instanceId: string;
+	onData?: (data: Uint8Array) => void;
+	onControl?: (msg: ServerControlMessage) => void;
+	/** Called with characters that should be locally echoed. */
+	onLocalEcho?: (data: string) => void;
+	/** Called to serialize scrollback before disconnect. Should return terminal content. */
+	serializeFn?: () => string | null;
+	/** Called with restored scrollback content on reconnect. */
+	onRestoreScrollback?: (content: string) => void;
+}
+
+export function useTerminalConnection({
+	instanceId,
+	onData,
+	onControl,
+	onLocalEcho,
+	serializeFn,
+	onRestoreScrollback,
+}: UseTerminalConnectionOptions) {
+	const [state, setState] = useState<TerminalConnectionState>({
+		status: "connecting",
+		attempt: 0,
+		latency: null,
+		error: null,
+	});
+
+	const wsRef = useRef<WebSocket | null>(null);
+	const reconnectTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
+	const pingTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
+	const pongTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
+	const resizeTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
+	const lastResizeRef = useRef<number>(0);
+	const pendingEchoRef = useRef<string>("");
+	const echoEnabledRef = useRef<boolean>(true);
+	const pingIdRef = useRef<number>(0);
+	const pingSentAtRef = useRef<number>(0);
+	const reconnectAttemptRef = useRef<number>(0);
+	const isConnectingRef = useRef<boolean>(false);
+	const lastStatusRef = useRef<string>("connecting");
+
+	const setStableState = useCallback(
+		(updater: (prev: TerminalConnectionState) => TerminalConnectionState) => {
+			setState((prev) => {
+				const next = updater(prev);
+				if (next.status !== lastStatusRef.current) {
+					lastStatusRef.current = next.status;
+				}
+				return next;
+			});
+		},
+		[],
+	);
+
+	const clearTimers = useCallback(() => {
+		if (reconnectTimerRef.current) {
+			clearTimeout(reconnectTimerRef.current);
+			reconnectTimerRef.current = null;
+		}
+		if (pingTimerRef.current) {
+			clearTimeout(pingTimerRef.current);
+			pingTimerRef.current = null;
+		}
+		if (pongTimerRef.current) {
+			clearTimeout(pongTimerRef.current);
+			pongTimerRef.current = null;
+		}
+	}, []);
+
+	const flushPendingEcho = useCallback(() => {
+		if (pendingEchoRef.current.length > 0 && onLocalEcho) {
+			onLocalEcho(pendingEchoRef.current);
+			pendingEchoRef.current = "";
+		}
+	}, [onLocalEcho]);
+
+	const deduplicateServerData = useCallback((data: string): string => {
+		if (!echoEnabledRef.current || pendingEchoRef.current.length === 0) {
+			return data;
+		}
+
+		let serverIndex = 0;
+		let echoIndex = 0;
+
+		while (
+			serverIndex < data.length &&
+			echoIndex < pendingEchoRef.current.length &&
+			data[serverIndex] === pendingEchoRef.current[echoIndex]
+		) {
+			serverIndex++;
+			echoIndex++;
+		}
+
+		if (echoIndex > 0) {
+			pendingEchoRef.current = pendingEchoRef.current.slice(echoIndex);
+		}
+
+		return data.slice(serverIndex);
+	}, []);
+
+	const handleBinaryMessage = useCallback(
+		(buffer: ArrayBuffer) => {
+			const bytes = new Uint8Array(buffer);
+			const text = new TextDecoder().decode(bytes);
+
+			if (onData) {
+				onData(bytes);
+			}
+
+			// Deduplicate local echo if active
+			if (echoEnabledRef.current && pendingEchoRef.current.length > 0) {
+				const remaining = deduplicateServerData(text);
+				if (remaining.length > 0 && onLocalEcho) {
+					onLocalEcho(remaining);
+				}
+			} else if (onLocalEcho) {
+				onLocalEcho(text);
+			}
+
+			// Flush stale pending echo buffer
+			if (pendingEchoRef.current.length > PENDING_ECHO_FLUSH_LIMIT) {
+				flushPendingEcho();
+			}
+		},
+		[onData, onLocalEcho, deduplicateServerData, flushPendingEcho],
+	);
+
+	const handleControlMessage = useCallback(
+		(msg: ServerControlMessage) => {
+			if (onControl) {
+				onControl(msg);
+			}
+
+			switch (msg.type) {
+				case "pong": {
+					const elapsed = Date.now() - pingSentAtRef.current;
+					setStableState((prev) => ({
+						...prev,
+						latency: elapsed,
+						status: prev.status === "reconnecting" ? "connected" : prev.status,
+					}));
+					break;
+				}
+				case "status": {
+					setStableState((prev) => ({
+						...prev,
+						status: "connected",
+						attempt: 0,
+						error: null,
+					}));
+					reconnectAttemptRef.current = 0;
+					break;
+				}
+				case "set_echo_state": {
+					echoEnabledRef.current = msg.enabled;
+					if (!msg.enabled) {
+						// Server disabled echo — flush any pending local echo
+						flushPendingEcho();
+					}
+					break;
+				}
+				case "session_ended": {
+					setStableState((prev) => ({
+						...prev,
+						status: "disconnected",
+						error: `Session ended: ${msg.reason}`,
+					}));
+					clearTimers();
+					wsRef.current?.close(1000);
+					break;
+				}
+			}
+		},
+		[onControl, setStableState, clearTimers, flushPendingEcho],
+	);
+
+	const schedulePing = useCallback(() => {
+		pingTimerRef.current = setTimeout(() => {
+			const ws = wsRef.current;
+			if (!ws || ws.readyState !== WebSocket.OPEN) return;
+
+			const id = ++pingIdRef.current;
+			pingSentAtRef.current = Date.now();
+			const pingMsg: ClientControlMessage = { type: "ping", id };
+			ws.send(encodeControlMessage(pingMsg));
+
+			// Set pong timeout
+			pongTimerRef.current = setTimeout(() => {
+				// Pong not received — connection is dead
+				ws.close(1001, "Ping timeout");
+			}, PONG_TIMEOUT_MS);
+		}, PING_INTERVAL_MS);
+	}, []);
+
+	const serializeScrollback = useCallback(() => {
+		if (!serializeFn) return;
+		try {
+			const serialized = serializeFn();
+			if (serialized) {
+				sessionStorage.setItem(
+					`${SCROLLBACK_STORAGE_KEY}-${instanceId}`,
+					serialized,
+				);
+			}
+		} catch {
+			// Ignore serialization errors
+		}
+	}, [serializeFn, instanceId]);
+
+	const restoreScrollback = useCallback(() => {
+		if (!onRestoreScrollback) return;
+		try {
+			const key = `${SCROLLBACK_STORAGE_KEY}-${instanceId}`;
+			const serialized = sessionStorage.getItem(key);
+			if (serialized) {
+				onRestoreScrollback(serialized);
+				sessionStorage.removeItem(key);
+			}
+		} catch {
+			// Ignore restoration errors
+		}
+	}, [onRestoreScrollback, instanceId]);
+
+	const connect = useCallback(() => {
+		if (isConnectingRef.current) return;
+		isConnectingRef.current = true;
+
+		const apiUrl = import.meta.env.VITE_API_BASE_URL || "";
+		const wsProtocol = window.location.protocol === "https:" ? "wss:" : "ws:";
+		const wsHost = apiUrl.replace(/^https?:\/\//, "").replace(/\/+$/, "");
+		const wsUrl = `${wsProtocol}//${wsHost}/ws/tool-instances/${instanceId}/terminal`;
+
+		const ws = new WebSocket(wsUrl);
+		wsRef.current = ws;
+
+		ws.onopen = () => {
+			isConnectingRef.current = false;
+			reconnectAttemptRef.current = 0;
+			setStableState((prev) => ({
+				...prev,
+				status: "connected",
+				attempt: 0,
+				error: null,
+			}));
+			restoreScrollback();
+			schedulePing();
+		};
+
+		ws.onmessage = (event: MessageEvent) => {
+			if (isControlMessage(event)) {
+				const msg = decodeControlMessage(event.data as string);
+				if (msg) {
+					handleControlMessage(msg);
+				}
+			} else if (event.data instanceof ArrayBuffer) {
+				handleBinaryMessage(event.data);
+			} else if (event.data instanceof Blob) {
+				event.data.arrayBuffer().then((buffer) => {
+					handleBinaryMessage(buffer);
+				});
+			}
+		};
+
+		ws.onclose = (event: CloseEvent) => {
+			wsRef.current = null;
+			clearTimers();
+
+			if (event.code === 1000 || event.code === 1001) {
+				// Normal or going-away close
+				setStableState(() => ({
+					status: "disconnected",
+					attempt: 0,
+					latency: null,
+					error: event.reason || null,
+				}));
+				return;
+			}
+
+			// Unexpected close — attempt reconnect
+			const attempt = ++reconnectAttemptRef.current;
+			if (attempt > MAX_RECONNECT_ATTEMPTS) {
+				setStableState(() => ({
+					status: "disconnected",
+					attempt,
+					latency: null,
+					error: "Max reconnection attempts exceeded",
+				}));
+				return;
+			}
+
+			serializeScrollback();
+			const delay = Math.min(
+				RECONNECT_BASE_MS * 2 ** (attempt - 1),
+				RECONNECT_MAX_MS,
+			);
+
+			setStableState((prev) => ({
+				...prev,
+				status: "reconnecting",
+				attempt,
+				error: `Reconnecting in ${Math.round(delay / 1000)}s...`,
+			}));
+
+			reconnectTimerRef.current = setTimeout(() => {
+				connect();
+			}, delay);
+		};
+
+		ws.onerror = () => {
+			isConnectingRef.current = false;
+			// Let onclose handle reconnection
+		};
+	}, [
+		instanceId,
+		setStableState,
+		clearTimers,
+		schedulePing,
+		handleBinaryMessage,
+		handleControlMessage,
+		serializeScrollback,
+		restoreScrollback,
+	]);
+
+	const sendInput = useCallback(
+		(data: string) => {
+			const ws = wsRef.current;
+			if (!ws || ws.readyState !== WebSocket.OPEN) return;
+
+			// Local echo for printable ASCII characters
+			if (
+				echoEnabledRef.current &&
+				data.length === 1 &&
+				data.charCodeAt(0) >= 32 &&
+				data.charCodeAt(0) <= 126
+			) {
+				pendingEchoRef.current += data;
+				if (onLocalEcho) {
+					onLocalEcho(data);
+				}
+			}
+
+			ws.send(data);
+		},
+		[onLocalEcho],
+	);
+
+	const sendResize = useCallback((cols: number, rows: number) => {
+		if (resizeTimerRef.current) {
+			clearTimeout(resizeTimerRef.current);
+		}
+
+		resizeTimerRef.current = setTimeout(() => {
+			const now = Date.now();
+			if (now - lastResizeRef.current < RESIZE_THROTTLE_MS) {
+				return;
+			}
+			lastResizeRef.current = now;
+
+			const ws = wsRef.current;
+			if (!ws || ws.readyState !== WebSocket.OPEN) return;
+
+			const msg: ClientControlMessage = { type: "resize", cols, rows };
+			ws.send(encodeControlMessage(msg));
+		}, RESIZE_DEBOUNCE_MS);
+	}, []);
+
+	const reconnect = useCallback(() => {
+		clearTimers();
+		if (wsRef.current) {
+			wsRef.current.close(1000, "Manual reconnect");
+			wsRef.current = null;
+		}
+		reconnectAttemptRef.current = 0;
+		setStableState(() => ({
+			status: "connecting",
+			attempt: 0,
+			latency: null,
+			error: null,
+		}));
+		connect();
+	}, [clearTimers, connect, setStableState]);
+
+	// Initial connection
+	useEffect(() => {
+		connect();
+
+		return () => {
+			clearTimers();
+			if (resizeTimerRef.current) {
+				clearTimeout(resizeTimerRef.current);
+			}
+			if (wsRef.current) {
+				wsRef.current.close(1000, "Component unmount");
+				wsRef.current = null;
+			}
+		};
+	}, [instanceId, connect, clearTimers]);
+
+	// Keyboard shortcut for manual reconnect
+	useEffect(() => {
+		const handler = (e: KeyboardEvent) => {
+			if (e.ctrlKey && e.shiftKey && e.key === "R") {
+				e.preventDefault();
+				reconnect();
+			}
+		};
+		window.addEventListener("keydown", handler);
+		return () => window.removeEventListener("keydown", handler);
+	}, [reconnect]);
+
+	return {
+		state,
+		sendInput,
+		sendResize,
+		reconnect,
+	};
+}

apps/web/src/pages/projects.test.tsx

@@ -1,5 +1,4 @@
 import { cleanup, fireEvent, render, screen, waitFor, within } from "@testing-library/react";
-import { MemoryRouter } from "react-router-dom";
 import { afterEach, describe, expect, it, vi } from "vitest";
 
 import { ProjectsPage } from "./projects";
@@ -30,21 +29,13 @@ afterEach(() => {
 describe("ProjectsPage", () => {
   it("renders loading state initially", () => {
     vi.spyOn(projectsApi, "listProjects").mockImplementation(() => new Promise(() => {}));
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
     expect(screen.getByText(/loading projects/i)).toBeInTheDocument();
   });
 
   it("renders project list after loading", async () => {
     vi.spyOn(projectsApi, "listProjects").mockResolvedValue(mockProjects);
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText("Alpha Project")).toBeInTheDocument();
@@ -55,11 +46,7 @@ describe("ProjectsPage", () => {
 
   it("renders empty state when no projects", async () => {
     vi.spyOn(projectsApi, "listProjects").mockResolvedValue([]);
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText(/no projects yet/i)).toBeInTheDocument();
@@ -68,11 +55,7 @@ describe("ProjectsPage", () => {
 
   it("renders error state with retry button", async () => {
     vi.spyOn(projectsApi, "listProjects").mockRejectedValue(new Error("fail"));
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText(/failed to load projects/i)).toBeInTheDocument();
@@ -84,11 +67,7 @@ describe("ProjectsPage", () => {
     const listMock = vi.spyOn(projectsApi, "listProjects").mockResolvedValue([]);
     const createMock = vi.spyOn(projectsApi, "createProject").mockResolvedValue(mockProjects[0]);
 
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText(/no projects yet/i)).toBeInTheDocument();
@@ -117,11 +96,7 @@ describe("ProjectsPage", () => {
   it("shows validation error when name is empty", async () => {
     vi.spyOn(projectsApi, "listProjects").mockResolvedValue([]);
 
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText(/no projects yet/i)).toBeInTheDocument();
@@ -133,15 +108,9 @@ describe("ProjectsPage", () => {
     expect(screen.getByText(/project name is required/i)).toBeInTheDocument();
   });
 
-  it("opens edit dialog and saves changes", async () => {
+  it("renders settings link for each project", async () => {
-    const listMock = vi.spyOn(projectsApi, "listProjects").mockResolvedValue(mockProjects);
+    vi.spyOn(projectsApi, "listProjects").mockResolvedValue(mockProjects);
-    const updateMock = vi.spyOn(projectsApi, "updateProject").mockResolvedValue(mockProjects[0]);
+    render(<ProjectsPage />);
-
-    render(
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText("Alpha Project")).toBeInTheDocument();
@@ -150,31 +119,40 @@ describe("ProjectsPage", () => {
     const alphaCard = screen.getByText("Alpha Project").closest(".project-card") as HTMLElement | null;
     if (!alphaCard) throw new Error("Card not found");
 
-    fireEvent.click(within(alphaCard).getByRole("button", { name: /edit/i }));
+    const settingsLink = within(alphaCard).getByRole("link", { name: /settings/i });
-    expect(screen.getByRole("dialog")).toBeInTheDocument();
+    expect(settingsLink).toBeInTheDocument();
+    expect(settingsLink).toHaveAttribute("href", "/projects/proj-1/settings");
+  });
 
-    const nameInput = screen.getByDisplayValue("Alpha Project");
+  it("renders open workspace link as rightmost action", async () => {
-    fireEvent.change(nameInput, { target: { value: "Alpha Updated" } });
+    vi.spyOn(projectsApi, "listProjects").mockResolvedValue(mockProjects);
-    fireEvent.click(screen.getByRole("button", { name: /save/i }));
+    render(<ProjectsPage />);
 
     await waitFor(() => {
-      expect(updateMock).toHaveBeenCalledWith("proj-1", {
+      expect(screen.getByText("Alpha Project")).toBeInTheDocument();
-        name: "Alpha Updated",
-        description: "First project",
-      });
     });
-    expect(listMock).toHaveBeenCalledTimes(2);
+
+    const alphaCard = screen.getByText("Alpha Project").closest(".project-card") as HTMLElement | null;
+    if (!alphaCard) throw new Error("Card not found");
+
+    const actions = alphaCard.querySelector(".project-actions");
+    if (!actions) throw new Error("Actions container not found");
+
+    const workspaceLink = within(alphaCard).getByRole("link", { name: /open workspace/i });
+    expect(workspaceLink).toBeInTheDocument();
+    expect(workspaceLink).toHaveAttribute("href", "/projects/proj-1");
+
+    // Verify it's the last action in the container
+    const allActions = actions.querySelectorAll("a, button");
+    const lastAction = allActions[allActions.length - 1];
+    expect(lastAction).toBe(workspaceLink);
   });
 
   it("shows delete confirmation and deletes project", async () => {
     const listMock = vi.spyOn(projectsApi, "listProjects").mockResolvedValue(mockProjects);
     const deleteMock = vi.spyOn(projectsApi, "deleteProject").mockResolvedValue(undefined);
 
-    render(
+    render(<ProjectsPage />);
-      <MemoryRouter>
-        <ProjectsPage />
-      </MemoryRouter>
-    );
 
     await waitFor(() => {
       expect(screen.getByText("Alpha Project")).toBeInTheDocument();

apps/web/src/pages/projects.tsx

@@ -6,21 +6,17 @@ import {
   createProject,
   deleteProject,
   listProjects,
-  updateProject,
   type ProjectCreateInput,
-  type ProjectUpdateInput,
 } from "../api/projects";
 import { Icon } from "../components/icon";
 import type { Project } from "../types";
 
 type ProjectsStatus = "loading" | "ready" | "error";
-type DialogMode = "none" | "create" | "edit";
 
 export const ProjectsPage = () => {
   const [status, setStatus] = useState<ProjectsStatus>("loading");
   const [projects, setProjects] = useState<Project[]>([]);
-  const [dialogMode, setDialogMode] = useState<DialogMode>("none");
+  const [showCreate, setShowCreate] = useState(false);
-  const [editingProject, setEditingProject] = useState<Project | null>(null);
   const [formName, setFormName] = useState("");
   const [formDescription, setFormDescription] = useState("");
   const [formError, setFormError] = useState<string | null>(null);
@@ -46,25 +42,15 @@ export const ProjectsPage = () => {
     setFormName("");
     setFormDescription("");
     setFormError(null);
-    setEditingProject(null);
+    setShowCreate(true);
-    setDialogMode("create");
   };
 
-  const openEdit = (project: Project) => {
+  const closeCreate = () => {
-    setFormName(project.name);
+    setShowCreate(false);
-    setFormDescription(project.description ?? "");
-    setFormError(null);
-    setEditingProject(project);
-    setDialogMode("edit");
-  };
-
-  const closeDialog = () => {
-    setDialogMode("none");
-    setEditingProject(null);
     setFormError(null);
   };
 
-  const handleSubmit = async (e: React.FormEvent) => {
+  const handleCreate = async (e: React.FormEvent) => {
     e.preventDefault();
     setFormError(null);
 
@@ -74,20 +60,12 @@ export const ProjectsPage = () => {
     }
 
     try {
-      if (dialogMode === "create") {
+      const input: ProjectCreateInput = {
-        const input: ProjectCreateInput = {
+        name: formName.trim(),
-          name: formName.trim(),
+        description: formDescription.trim() || null,
-          description: formDescription.trim() || null,
+      };
-        };
+      await createProject(input);
-        await createProject(input);
+      closeCreate();
-      } else if (dialogMode === "edit" && editingProject) {
-        const input: ProjectUpdateInput = {
-          name: formName.trim(),
-          description: formDescription.trim() || null,
-        };
-        await updateProject(editingProject.id, input);
-      }
-      closeDialog();
       await loadProjects();
     } catch {
       setFormError("Failed to save project");
@@ -139,17 +117,13 @@ export const ProjectsPage = () => {
                 {project.description && <p className="muted">{project.description}</p>}
               </div>
               <div className="project-actions">
-                <Link className="ghost-button" to={`/projects/${project.id}`}>
+                <Link
-                  Open Workspace
-                </Link>
-                <button
                   className="ghost-button"
-                  onClick={() => openEdit(project)}
+                  to={`/projects/${project.id}/settings`}
-                  type="button"
                 >
-                  <Icon name="edit" size="sm" />
+                  <Icon name="settings" size="sm" />
-                  Edit
+                  Settings
-                </button>
+                </Link>
                 {deleteConfirmId === project.id ? (
                   <div className="delete-confirm">
                     <span>Are you sure?</span>
@@ -180,17 +154,20 @@ export const ProjectsPage = () => {
                     Delete
                   </button>
                 )}
+                <Link className="ghost-button" to={`/projects/${project.id}`}>
+                  Open Workspace
+                </Link>
               </div>
             </article>
           ))}
         </div>
       )}
 
-      {dialogMode !== "none" && (
+      {showCreate && (
         <div className="dialog-overlay" role="dialog" aria-modal="true">
           <div className="dialog">
-            <h2>{dialogMode === "create" ? "Create Project" : "Edit Project"}</h2>
+            <h2>Create Project</h2>
-            <form onSubmit={handleSubmit} className="stack">
+            <form onSubmit={handleCreate} className="stack">
               <label className="form-field">
                 Name
                 <input
@@ -211,22 +188,13 @@ export const ProjectsPage = () => {
               </label>
               {formError && <p className="error-text">{formError}</p>}
               <div className="dialog-actions">
-                <button className="secondary-button" onClick={closeDialog} type="button">
+                <button className="secondary-button" onClick={closeCreate} type="button">
                   <Icon name="cancel" size="sm" />
                   Cancel
                 </button>
                 <button className="primary-button" type="submit">
-                  {dialogMode === "create" ? (
+                  <Icon name="add" size="sm" />
-                    <>
+                  Create
-                      <Icon name="add" size="sm" />
-                      Create
-                    </>
-                  ) : (
-                    <>
-                      <Icon name="save" size="sm" />
-                      Save
-                    </>
-                  )}
                 </button>
               </div>
             </form>

apps/web/src/pages/sessions.tsx

@@ -266,7 +266,7 @@ export const SessionsPage = () => {
               <h2>Last Session</h2>
               <div className="card last-session-card">
                 <div className="last-session-info">
-                  <h3>{lastSession.display_name}</h3>
+                  <h3>{lastSession.display_name || lastSession.tool_type_name || "Unnamed Session"}</h3>
                   <p className="muted">
                     {lastSession.tool_type_name} · {lastSession.project_name} · {lastSession.repository_name}
                   </p>
@@ -316,7 +316,7 @@ export const SessionsPage = () => {
                 {activeSessions.map((session) => (
                   <div className="card session-card" key={session.id}>
                     <div className="session-info">
-                      <h4>{session.display_name}</h4>
+                      <h4>{session.display_name || session.tool_type_name || "Unnamed Session"}</h4>
                       <p className="muted">
                         {session.tool_type_name} · {session.project_name}
                       </p>
@@ -445,7 +445,7 @@ export const SessionsPage = () => {
                 {recentSessions.map((session) => (
                   <div className="recent-session-item" key={session.id}>
                     <div className="recent-session-info">
-                      <span className="recent-session-name">{session.display_name}</span>
+                      <span className="recent-session-name">{session.display_name || session.tool_type_name || "Unnamed Session"}</span>
                       <span className="muted">
                         {session.tool_type_name} · {session.project_name}
                       </span>

apps/web/src/styles.css

@@ -2479,137 +2479,6 @@ a.nav-item,
    Terminal Styles
    ============================================ */
 
-.terminal-page {
-  display: flex;
-  flex-direction: column;
-  height: 100vh;
-  padding: var(--space-4);
-  gap: var(--space-4);
-}
-
-.terminal-page-header {
-  display: flex;
-  align-items: center;
-  gap: var(--space-4);
-  flex-shrink: 0;
-}
-
-.terminal-page-header h1 {
-  margin: 0;
-}
-
-.terminal-wrapper {
-  display: flex;
-  flex-direction: column;
-  flex: 1;
-  min-height: 0;
-  border: 1px solid var(--border);
-  border-radius: 10px;
-  overflow: hidden;
-  background: #1e1e1e;
-}
-
-.terminal-header {
-  display: flex;
-  justify-content: space-between;
-  align-items: center;
-  padding: var(--space-3) var(--space-4);
-  background: #2d2d2d;
-  border-bottom: 1px solid #3e3e3e;
-  flex-shrink: 0;
-}
-
-.terminal-status {
-  display: flex;
-  align-items: center;
-  gap: var(--space-2);
-}
-
-.status-dot {
-  width: 8px;
-  height: 8px;
-  border-radius: 50%;
-  background: #666;
-}
-
-.status-dot.connecting {
-  background: #f5f543;
-  animation: pulse 1.5s infinite;
-}
-
-.status-dot.connected {
-  background: #0dbc79;
-}
-
-.status-dot.disconnected,
-.status-dot.error {
-  background: #cd3131;
-}
-
-@keyframes pulse {
-  0%,
-  100% {
-    opacity: 1;
-  }
-  50% {
-    opacity: 0.5;
-  }
-}
-
-.status-text {
-  font-size: 0.875rem;
-  color: #d4d4d4;
-  text-transform: capitalize;
-}
-
-.terminal-close {
-  padding: var(--space-1) var(--space-3);
-  background: transparent;
-  border: 1px solid #666;
-  border-radius: 6px;
-  color: #d4d4d4;
-  cursor: pointer;
-  font-size: 0.875rem;
-}
-
-.terminal-close:hover {
-  background: #3e3e3e;
-}
-
-.terminal-error {
-  padding: var(--space-3) var(--space-4);
-  background: #cd3131;
-  color: white;
-  font-size: 0.875rem;
-  flex-shrink: 0;
-}
-
-.terminal-container {
-  flex: 1;
-  min-height: 0;
-  padding: var(--space-2);
-}
-
-.terminal-container .xterm {
-  height: 100%;
-}
-
-.terminal-container .xterm-viewport {
-  background: #1e1e1e !important;
-}
-
-/* Responsive terminal */
-@media (max-width: 767px) {
-  .terminal-page {
-    padding: var(--space-2);
-    gap: var(--space-2);
-  }
-
-  .terminal-page-header h1 {
-    font-size: 1.25rem;
-  }
-}
-
 /* ============================================
    Sessions Page Styles
    ============================================ */
@@ -2805,3 +2674,162 @@ a.nav-item,
   background: var(--danger-light, #fee2e2);
   color: var(--danger, #dc2626);
 }
+
+/* ============================================
+   Responsive Terminal — Updated
+   ============================================ */
+
+.terminal-wrapper {
+  position: relative;
+  display: flex;
+  flex-direction: column;
+  flex: 1;
+  min-height: 0;
+  border: 1px solid var(--border);
+  border-radius: 10px;
+  overflow: hidden;
+  background: #1e1e1e;
+}
+
+.terminal-header {
+  display: flex;
+  justify-content: space-between;
+  align-items: center;
+  padding: 0.5rem 0.75rem;
+  background: #2d2d2d;
+  border-bottom: 1px solid #3e3e3e;
+  flex-shrink: 0;
+  gap: 0.5rem;
+}
+
+.terminal-status {
+  display: flex;
+  align-items: center;
+  gap: 0.5rem;
+  min-width: 0;
+}
+
+.terminal-status .status-dot {
+  width: 8px;
+  height: 8px;
+  border-radius: 50%;
+  flex-shrink: 0;
+}
+
+.terminal-status .status-text {
+  font-size: 0.8rem;
+  color: #d4d4d4;
+  white-space: nowrap;
+  overflow: hidden;
+  text-overflow: ellipsis;
+}
+
+.terminal-actions {
+  display: flex;
+  gap: 0.5rem;
+  align-items: center;
+  flex-shrink: 0;
+}
+
+.terminal-close {
+  padding: 0.25rem 0.6rem;
+  background: transparent;
+  border: 1px solid #666;
+  border-radius: 6px;
+  color: #d4d4d4;
+  cursor: pointer;
+  font-size: 0.8rem;
+}
+
+.terminal-close:hover {
+  background: #3e3e3e;
+}
+
+.terminal-container {
+  flex: 1;
+  min-height: 0;
+}
+
+.terminal-container .xterm-viewport {
+  background: #1e1e1e !important;
+}
+
+/* Terminal overlay for session ended */
+.terminal-overlay {
+  position: absolute;
+  inset: 0;
+  background: rgba(0, 0, 0, 0.75);
+  display: grid;
+  place-content: center;
+  z-index: 10;
+}
+
+.terminal-overlay-content {
+  background: #2d2d2d;
+  border: 1px solid #3e3e3e;
+  border-radius: 10px;
+  padding: 1.5rem;
+  text-align: center;
+  max-width: 400px;
+  color: #d4d4d4;
+}
+
+.terminal-overlay-content h3 {
+  margin: 0 0 0.5rem;
+  color: #f14c4c;
+}
+
+.terminal-overlay-content p {
+  margin: 0 0 1rem;
+  font-size: 0.9rem;
+}
+
+.terminal-overlay-actions {
+  display: flex;
+  gap: 0.5rem;
+  justify-content: center;
+}
+
+/* Reconnect banner */
+.terminal-reconnect-banner {
+  display: flex;
+  align-items: center;
+  gap: 0.5rem;
+  padding: 0.4rem 0.75rem;
+  background: #3e3e3e;
+  color: #f5f543;
+  font-size: 0.8rem;
+  flex-shrink: 0;
+}
+
+.spinner {
+  display: inline-block;
+  width: 12px;
+  height: 12px;
+  border: 2px solid currentColor;
+  border-right-color: transparent;
+  border-radius: 50%;
+  animation: spin 0.75s linear infinite;
+}
+
+@keyframes spin {
+  to {
+    transform: rotate(360deg);
+  }
+}
+
+/* Responsive terminal */
+@media (max-width: 767px) {
+  .terminal-page {
+    padding: var(--space-2);
+    gap: var(--space-2);
+  }
+
+  .terminal-page-header h1 {
+    font-size: 1.25rem;
+  }
+
+  .terminal-overlay-content {
+    margin: 0 1rem;
+  }
+}

apps/web/src/types/terminal.ts

@@ -0,0 +1,82 @@
+/**
+ * WebSocket protocol types for the responsive terminal.
+ *
+ * Binary frames carry raw terminal I/O.
+ * Text (JSON) frames carry control messages.
+ */
+
+// ── Client → Server ──
+
+export interface PingMessage {
+	type: "ping";
+	id: number;
+}
+
+export interface PongMessage {
+	type: "pong";
+	id: number;
+}
+
+export interface ResizeMessage {
+	type: "resize";
+	cols: number;
+	rows: number;
+}
+
+export interface InputMessage {
+	type: "input";
+	data: string; // base64-encoded bytes
+}
+
+export type ClientControlMessage =
+	| PingMessage
+	| PongMessage
+	| ResizeMessage
+	| InputMessage;
+
+// ── Server → Client ──
+
+export interface ServerPongMessage {
+	type: "pong";
+	id: number;
+}
+
+export type ConnectionStatus = "connected" | "reconnected";
+
+export interface StatusMessage {
+	type: "status";
+	status: ConnectionStatus;
+}
+
+export interface SetEchoStateMessage {
+	type: "set_echo_state";
+	enabled: boolean;
+}
+
+export type SessionEndReason = "process_exit" | "container_stop" | "timeout";
+
+export interface SessionEndedMessage {
+	type: "session_ended";
+	reason: SessionEndReason;
+}
+
+export type ServerControlMessage =
+	| ServerPongMessage
+	| StatusMessage
+	| SetEchoStateMessage
+	| SessionEndedMessage;
+
+// ── Connection state ──
+
+export type TerminalConnectionStatus =
+	| "connecting"
+	| "connected"
+	| "reconnecting"
+	| "disconnected";
+
+export interface TerminalConnectionState {
+	status: TerminalConnectionStatus;
+	attempt: number;
+	latency: number | null;
+	error: string | null;
+}

apps/web/src/utils/terminal-protocol.ts

@@ -0,0 +1,76 @@
+import type {
+	ClientControlMessage,
+	ServerControlMessage,
+} from "../types/terminal";
+
+/**
+ * Encode a client control message to a JSON string for sending over WebSocket.
+ */
+export function encodeControlMessage(msg: ClientControlMessage): string {
+	return JSON.stringify(msg);
+}
+
+/**
+ * Decode a server control message from a JSON string.
+ * Returns null if the data is not valid JSON or not a recognized control message.
+ */
+export function decodeControlMessage(
+	data: string,
+): ServerControlMessage | null {
+	try {
+		const parsed = JSON.parse(data) as unknown;
+		if (!isServerControlMessage(parsed)) {
+			return null;
+		}
+		return parsed;
+	} catch {
+		return null;
+	}
+}
+
+/**
+ * Check whether a WebSocket message is a control message (JSON text frame)
+ * or raw binary data.
+ */
+export function isControlMessage(event: MessageEvent): boolean {
+	return typeof event.data === "string";
+}
+
+/**
+ * Encode raw input bytes to a base64 string for the `input` control message.
+ */
+export function encodeInputData(data: string): string {
+	return btoa(unescape(encodeURIComponent(data)));
+}
+
+/**
+ * Decode base64 input data back to a string.
+ */
+export function decodeInputData(data: string): string {
+	return decodeURIComponent(escape(atob(data)));
+}
+
+// ── Type guards ──
+
+function isServerControlMessage(value: unknown): value is ServerControlMessage {
+	if (typeof value !== "object" || value === null) return false;
+	const obj = value as Record<string, unknown>;
+	if (typeof obj.type !== "string") return false;
+
+	switch (obj.type) {
+		case "pong":
+			return typeof obj.id === "number";
+		case "status":
+			return obj.status === "connected" || obj.status === "reconnected";
+		case "set_echo_state":
+			return typeof obj.enabled === "boolean";
+		case "session_ended":
+			return (
+				obj.reason === "process_exit" ||
+				obj.reason === "container_stop" ||
+				obj.reason === "timeout"
+			);
+		default:
+			return false;
+	}
+}

docs/README.md

@@ -26,6 +26,7 @@ User guides for each feature:
 - [Repositories](features/repositories.md) - Git repository management
 - [Workspace](features/workspace.md) - Repository workspace
 - [Git History](features/git-history.md) - History visualization
+- [Web Terminal](features/terminal.md) - Interactive terminal for tool instances
 - [Authentication](features/auth.md) - Login and user management
 - [Settings](features/settings.md) - User preferences
 - [Tool Types](features/tool-types.md) - Development tool management

docs/api/README.md

@@ -35,6 +35,7 @@ All responses are JSON. Error responses follow this format:
 - [Repositories](repositories.md) - Git repositories and file operations
 - [Users](users.md) - User management and settings
 - [Tool Types](tool-types.md) - Tool type management
+- [Config Profiles](config-profiles.md) - Config profile management for tool instances
 - [SSH Keys](ssh-keys.md) - SSH key management
 
 ## Testing

docs/api/config-profiles.md

@@ -0,0 +1,433 @@
+# Config Profiles API
+
+Config profile management endpoints for customizing tool instances.
+
+## Authentication
+
+All endpoints require authentication (session cookie).
+
+---
+
+## GET /config-profiles
+
+**Description:** List all config profiles for the current user.
+
+### Query Parameters
+
+| Parameter | Type | Required | Description |
+|-----------|------|----------|-------------|
+| `tool_type_id` | `string` | No | Filter by tool type compatibility (currently returns all profiles) |
+
+### Response
+
+#### Success (200 OK)
+
+```json
+{
+  "profiles": [
+    {
+      "id": "uuid",
+      "user_id": "uuid",
+      "name": "my-profile",
+      "description": "My custom profile",
+      "created_at": "2024-01-01T00:00:00Z",
+      "updated_at": "2024-01-01T00:00:00Z"
+    }
+  ]
+}
+```
+
+---
+
+## POST /config-profiles
+
+**Description:** Create a new config profile.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "name": "my-profile",
+  "description": "My custom profile"
+}
+```
+
+| Field | Type | Required | Description |
+|-------|------|----------|-------------|
+| `name` | `string` | Yes | Unique profile name (max 255 chars) |
+| `description` | `string` | No | Optional description |
+
+### Response
+
+#### Success (201 Created)
+
+Returns created profile.
+
+#### Error (409 Conflict)
+
+```json
+{
+  "detail": "config profile with name 'my-profile' already exists"
+}
+```
+
+#### Error (422 Unprocessable Entity)
+
+```json
+{
+  "detail": "Profile name cannot be empty"
+}
+```
+
+---
+
+## GET /config-profiles/{profile_id}
+
+**Description:** Get a config profile with its includes and mounts.
+
+### Response
+
+#### Success (200 OK)
+
+```json
+{
+  "id": "uuid",
+  "user_id": "uuid",
+  "name": "my-profile",
+  "description": "My custom profile",
+  "includes": [
+    {
+      "id": "uuid",
+      "profile_id": "uuid",
+      "included_profile_id": "uuid",
+      "included_profile_name": "base-profile",
+      "order_index": 0,
+      "created_at": "2024-01-01T00:00:00Z",
+      "updated_at": "2024-01-01T00:00:00Z"
+    }
+  ],
+  "mounts": [
+    {
+      "id": "uuid",
+      "profile_id": "uuid",
+      "target_path": "/etc/config",
+      "mode": "rw",
+      "files": {"test.txt": "hello"},
+      "order_index": 0,
+      "created_at": "2024-01-01T00:00:00Z",
+      "updated_at": "2024-01-01T00:00:00Z"
+    }
+  ],
+  "created_at": "2024-01-01T00:00:00Z",
+  "updated_at": "2024-01-01T00:00:00Z"
+}
+```
+
+---
+
+## PUT /config-profiles/{profile_id}
+
+**Description:** Update a config profile.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "name": "updated-name",
+  "description": "Updated description"
+}
+```
+
+### Response
+
+#### Success (200 OK)
+
+Returns updated profile.
+
+---
+
+## DELETE /config-profiles/{profile_id}
+
+**Description:** Delete a config profile and all its includes and mounts.
+
+### Response
+
+#### Success (204 No Content)
+
+---
+
+## GET /config-profiles/defaults
+
+**Description:** Get the current user's default profile assignments per tool type.
+
+### Response
+
+#### Success (200 OK)
+
+```json
+{
+  "default_profiles": {
+    "code-server": "profile-uuid-1",
+    "jupyter-notebook": "profile-uuid-2"
+  }
+}
+```
+
+---
+
+## PUT /config-profiles/defaults
+
+**Description:** Set the current user's default profile assignments per tool type.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "default_profiles": {
+    "code-server": "profile-uuid-1",
+    "jupyter-notebook": "profile-uuid-2"
+  }
+}
+```
+
+| Field | Type | Required | Description |
+|-------|------|----------|-------------|
+| `default_profiles` | `object` | Yes | Mapping of tool_type_id to profile_id |
+
+### Response
+
+#### Success (200 OK)
+
+Returns updated default profiles.
+
+#### Error (404 Not Found)
+
+```json
+{
+  "detail": "profile {profile_id} not found"
+}
+```
+
+---
+
+## GET /config-profiles/defaults/{tool_type_id}
+
+**Description:** Get the default profile ID for a specific tool type.
+
+### Response
+
+#### Success (200 OK)
+
+```json
+{
+  "tool_type_id": "code-server",
+  "profile_id": "profile-uuid-1"
+}
+```
+
+---
+
+## GET /config-profiles/{profile_id}/includes
+
+**Description:** List all includes for a config profile.
+
+### Response
+
+#### Success (200 OK)
+
+```json
+{
+  "includes": [
+    {
+      "id": "uuid",
+      "profile_id": "uuid",
+      "included_profile_id": "uuid",
+      "included_profile_name": "base-profile",
+      "order_index": 0,
+      "created_at": "2024-01-01T00:00:00Z",
+      "updated_at": "2024-01-01T00:00:00Z"
+    }
+  ]
+}
+```
+
+---
+
+## POST /config-profiles/{profile_id}/includes
+
+**Description:** Add an include to a config profile.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "included_profile_id": "uuid",
+  "order_index": 0
+}
+```
+
+| Field | Type | Required | Description |
+|-------|------|----------|-------------|
+| `included_profile_id` | `string` | Yes | UUID of the profile to include |
+| `order_index` | `integer` | No | Order for include resolution (default: 0) |
+
+### Response
+
+#### Success (201 Created)
+
+Returns created include.
+
+#### Error (400 Bad Request)
+
+```json
+{
+  "detail": "a profile cannot include itself"
+}
+```
+
+```json
+{
+  "detail": "adding this include would create a circular reference"
+}
+```
+
+---
+
+## PUT /config-profiles/{profile_id}/includes/{include_id}
+
+**Description:** Update the order index of a profile include.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "order_index": 5
+}
+```
+
+### Response
+
+#### Success (200 OK)
+
+Returns updated include.
+
+---
+
+## DELETE /config-profiles/{profile_id}/includes/{include_id}
+
+**Description:** Remove an include from a config profile.
+
+### Response
+
+#### Success (204 No Content)
+
+---
+
+## GET /config-profiles/{profile_id}/mounts
+
+**Description:** List all mounts for a config profile.
+
+### Response
+
+#### Success (200 OK)
+
+```json
+{
+  "mounts": [
+    {
+      "id": "uuid",
+      "profile_id": "uuid",
+      "target_path": "/etc/config",
+      "mode": "rw",
+      "files": {"test.txt": "hello"},
+      "order_index": 0,
+      "created_at": "2024-01-01T00:00:00Z",
+      "updated_at": "2024-01-01T00:00:00Z"
+    }
+  ]
+}
+```
+
+---
+
+## POST /config-profiles/{profile_id}/mounts
+
+**Description:** Add a mount to a config profile.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "target_path": "/etc/config",
+  "mode": "rw",
+  "files": {"test.txt": "hello"},
+  "order_index": 0
+}
+```
+
+| Field | Type | Required | Description |
+|-------|------|----------|-------------|
+| `target_path` | `string` | Yes | Absolute target path (must start with /) |
+| `mode` | `string` | No | Mount mode: "rw" or "ro" (default: "rw") |
+| `files` | `object` | No | Files as {path: content} |
+| `order_index` | `integer` | No | Order for mount resolution (default: 0) |
+
+### Response
+
+#### Success (201 Created)
+
+Returns created mount.
+
+#### Error (422 Unprocessable Entity)
+
+```json
+{
+  "detail": "Target path must be absolute (start with /)"
+}
+```
+
+---
+
+## PUT /config-profiles/{profile_id}/mounts/{mount_id}
+
+**Description:** Update a mount in a config profile.
+
+### Request
+
+#### Request Body
+
+```json
+{
+  "target_path": "/new/path",
+  "files": {"test.txt": "updated"},
+  "order_index": 2
+}
+```
+
+### Response
+
+#### Success (200 OK)
+
+Returns updated mount.
+
+---
+
+## DELETE /config-profiles/{profile_id}/mounts/{mount_id}
+
+**Description:** Remove a mount from a config profile.
+
+### Response
+
+#### Success (204 No Content)

docs/architecture/backend.md

@@ -13,16 +13,16 @@ The Headquarter backend is built with **FastAPI** and follows a layered architec
 │  Middleware: CORS → Request Logging → Exception Logging      │
 ├─────────────────────────────────────────────────────────────┤
 │  API Layer (src/api/)                                        │
-│  ┌─────────┐ ┌──────────┐ ┌────────┐ ┌──────────┐          │
+│  ┌─────────┐ ┌─────────┐ ┌────────┐ ┌──────────┐           │
-│  │  Auth   │ │ Projects │ │ Users  │ │   Git    │          │
+│  │  Auth   │ │Terminal │ │Projects│ │   Git    │           │
-│  │ Routes  │ │ Routes   │ │ Routes │ │ Repos    │          │
+│  │ Routes  │ │   WS    │ │ Routes │ │ Repos    │           │
-│  └────┬────┘ └────┬─────┘ └───┬────┘ └────┬─────┘          │
+│  └────┬────┘ └────┬────┘ └───┬────┘ └────┬─────┘           │
-├───────┼───────────┼───────────┼───────────┼─────────────────┤
+├───────┼───────────┼──────────┼───────────┼──────────────────┤
-│       │           │           │           │                  │
+│       │           │          │           │                  │
-│  Auth │  Project  │   User    │   Git     │                  │
+│  Auth │  Terminal │ Project  │   Git     │                  │
-│ Layer │  Service  │  Service  │ Service   │                  │
+│ Layer │  Manager  │ Service  │ Service   │                  │
-│       │           │           │           │                  │
+│       │  + Session│          │           │                  │
-├───────┴───────────┴───────────┴───────────┴─────────────────┤
+├───────┴───────────┴──────────┴───────────┴──────────────────┤
 │  Data Layer                                                  │
 │  ┌──────────┐  ┌──────────┐  ┌──────────┐                   │
 │  │  Models  │  │ Database │  │   Config │                   │
@@ -37,6 +37,7 @@ The Headquarter backend is built with **FastAPI** and follows a layered architec
 src/
 ├── api/                    # API Routes
 │   ├── auth.py            # Authentication endpoints
+│   ├── terminal.py        # WebSocket terminal endpoint
 │   ├── projects.py        # Project endpoints
 │   ├── git_repositories.py # Repository endpoints
 │   ├── users.py           # User endpoints
@@ -55,6 +56,11 @@ src/
 │   ├── tool_type.py       # Tool type model
 │   ├── ssh_key.py         # SSH key model
 │   └── user_config.py     # User config model
+├── services/              # Business Logic
+│   ├── terminal_manager.py # Terminal session manager
+│   ├── terminal_session.py # PTY + docker exec session
+│   ├── docker.py          # Docker operations
+│   └── profile_resolver.py # Profile resolution
 ├── utils/                  # Utilities
 │   ├── git_url_parser.py  # URL parsing
 │   ├── git_files.py       # Git file operations
@@ -64,6 +70,65 @@ src/
 └── main.py                # Application entry point
 ```
 
+## Terminal System
+
+The terminal system provides interactive shell access to running tool instances via WebSocket.
+
+### Architecture
+
+```
+Client (WebSocket)
+  ↕
+terminal.py (FastAPI WS endpoint)
+  ├─ Auth validation (session cookie)
+  ├─ Instance ownership check
+  ├─ Session lifecycle (create / monitor / cleanup)
+  └─ Echo state detection (termios)
+  ↕
+TerminalManager
+  ├─ create_session() → spawns TerminalSession
+  ├─ _read_loop() → batches PTY output → WebSocket
+  ├─ _write_loop() → WebSocket input → PTY
+  └─ _heartbeat_loop() → closes idle connections (60s)
+  ↕
+TerminalSession
+  ├─ start() → pty.openpty() + docker exec
+  ├─ read_output() → select.select() + os.read()
+  ├─ write_input() → os.write() to PTY master
+  ├─ resize() → TIOCSWINSZ ioctl
+  └─ check_echo_state() → termios.ECHO flag
+```
+
+### Protocol
+
+**Binary frames**: Raw terminal I/O (hot path)
+**Text (JSON) frames**: Control messages
+
+**Control messages:**
+
+| Direction | Type | Purpose |
+|-----------|------|---------|
+| Client → Server | `ping` | Heartbeat (every 15s idle) |
+| Server → Client | `pong` | Heartbeat response |
+| Client → Server | `resize` | Terminal dimensions changed |
+| Server → Client | `set_echo_state` | Enable/disable local echo |
+| Server → Client | `session_ended` | Container process exited |
+
+### Message Batching
+
+The read loop batches small PTY reads into single WebSocket frames:
+- Buffer accumulates data for up to 16ms
+- Flushed immediately when no new data is available
+- Reduces WebSocket frame overhead for rapid output
+
+### Reconnect Behavior
+
+The server cannot resume a `docker exec` PTY across connections. On reconnect:
+1. Old session is terminated
+2. New `docker exec` is spawned
+3. Client restores scrollback from `sessionStorage`
+4. New shell appears seamlessly to the user
+
 ## Layers
 
 ### 1. API Layer (`src/api/`)

docs/architecture/frontend.md

@@ -26,22 +26,26 @@ apps/web/src/
 │   ├── ssh_keys.ts      # SSH key API
 │   ├── tool_types.ts    # Tool type API
 │   ├── users.ts         # User API
+│   ├── sessions.ts      # Tool instance sessions API
 │   └── settings.ts      # Settings API
 ├── components/           # Reusable components
 │   ├── app-shell.tsx    # Main app layout
+│   ├── terminal.tsx     # xterm.js terminal component
 │   ├── protected-route.tsx  # Auth guard
 │   └── [more...]
 ├── context/             # React contexts
 │   └── auth.tsx         # Auth state management
 ├── hooks/               # Custom hooks
 │   ├── use-auth.ts      # Auth hook
-│   └── use-theme.ts     # Theme hook
+│   ├── use-theme.ts     # Theme hook
+│   └── use-terminal-connection.ts  # Terminal WebSocket lifecycle
 ├── pages/               # Page components (routes)
 │   ├── dashboard.tsx    # Dashboard
 │   ├── projects.tsx     # Project list
 │   ├── repo-workspace.tsx   # Repository workspace
 │   ├── git-history.tsx  # Git history
 │   ├── git-repositories.tsx # Repository management
+│   ├── terminal.tsx     # Web terminal
 │   ├── profile.tsx      # User profile
 │   ├── settings.tsx     # User settings
 │   ├── tool-types.tsx   # Tool types
@@ -164,6 +168,7 @@ interface AuthState {
 <Route path="/projects/:projectId" element={<RepoWorkspace />} />
 <Route path="/projects/:projectId/repositories" element={<GitRepositories />} />
 <Route path="/projects/:projectId/repositories/:repoId/history" element={<GitHistory />} />
+<Route path="/terminal/:instanceId" element={<TerminalPage />} />
 <Route path="/profile" element={<ProfilePage />} />
 <Route path="/settings" element={<SettingsPage />} />
 <Route path="/ssh-keys" element={<SSHKeysPage />} />
@@ -269,12 +274,64 @@ test('renders file list', () => {
 4. **Caching**: Browser caches API responses (ETags)
 5. **Optimistic UI**: Immediate feedback before API response
 
+## Terminal Architecture
+
+The web terminal is the most complex component in the frontend. It bridges a browser-based terminal emulator with a server-side PTY session.
+
+### Component Stack
+
+```
+TerminalPage (route)
+└── TerminalComponent
+    ├── Status bar (connection state, latency, actions)
+    ├── Session-ended overlay (reconnect / go back)
+    ├── Reconnect banner (spinner + countdown)
+    └── xterm.js (terminal emulator)
+        ├── FitAddon (auto-resize to container)
+        ├── SerializeAddon (scrollback serialization)
+        └── WebLinksAddon (clickable URLs)
+```
+
+### Connection Hook
+
+`useTerminalConnection` manages the full WebSocket lifecycle:
+
+```
+CONNECTING
+  → onopen → CONNECTED → heartbeat every 15s
+  → onclose (unexpected) → RECONNECTING
+    → backoff: 1s → 2s → 4s → 8s → 16s → 30s max
+    → up to 10 attempts
+    → onopen → restore scrollback → CONNECTED
+  → onclose (expected) → DISCONNECTED
+```
+
+**Key behaviors:**
+- **Local echo**: Printable ASCII chars appear instantly; server echo is deduplicated
+- **Resize**: Debounced 200ms, throttled to 1 message per 500ms
+- **Scrollback**: Serialized to `sessionStorage` on disconnect, restored on reconnect
+- **Keyboard**: `Ctrl+Shift+R` triggers manual reconnect
+
+### Data Flow
+
+```
+User types 'a'
+  → xterm onData event
+  → useTerminalConnection.sendInput('a')
+  → local echo writes 'a' to xterm immediately
+  → WebSocket sends 'a' to server
+  → server PTY echoes 'a' back
+  → client receives 'a' via binary frame
+  → deduplicates against pending echo buffer
+  → (no-op if matched, or writes remaining chars)
+```
+
 ## Future Improvements
 
 - [ ] Add React Query for server state management
 - [ ] Implement virtual scrolling for large file trees
 - [ ] Add service worker for offline support
-- [ ] Implement real-time updates (WebSocket)
+- [x] Implement real-time updates (WebSocket) — Terminal done
 - [ ] Add error boundary components
 
 ## Development Workflow

docs/features/projects.md

@@ -22,25 +22,30 @@ The Projects page displays all your projects in a card layout showing:
 - Creation date
 - Associated repositories count
 
+Each project card provides quick actions:
+- **Settings** — Navigate to the project settings page
+- **Delete** — Delete the project with confirmation
+- **Open Workspace** — Open the project's workspace (rightmost action)
+
 ### Opening a Project Workspace
 
-Click on any project card to open its **workspace**. The workspace is the default view for a project and shows:
+Click the **"Open Workspace"** button on any project card to open its **workspace**. The workspace is the default view for a project and shows:
 - Repository file browser
 - Branch selector
 - File viewer
 
 ### Editing a Project
 
-1. From the Projects page, click the **menu icon** (⋮) on a project card
+1. From the Projects page, click the **"Settings"** link on a project card
-2. Select **"Edit"**
+2. On the project settings page, update the **name** or **description**
-3. Update the name or description
+3. Click **"Save Changes"**
-4. Click **"Save"**
+
+The settings page also provides access to repository management and member settings.
 
 ### Deleting a Project
 
-1. From the Projects page, click the **menu icon** (⋮) on a project card
+1. From the Projects page, click the **"Delete"** button on a project card
-2. Select **"Delete"**
+2. Confirm the deletion
-3. Confirm the deletion
 
 **Note:** Deleting a project also deletes all associated repositories and their data. This action cannot be undone.
 

docs/features/terminal.md

@@ -0,0 +1,216 @@
+# Web Terminal
+
+## Overview
+
+The web terminal provides an interactive shell session inside running tool instances directly from your browser. It uses xterm.js to render a full terminal emulator connected via WebSocket to a PTY-backed docker exec session.
+
+The terminal is designed to feel as close to a local terminal as possible, with features for network resilience, low-latency typing, and session continuity.
+
+## How to Use
+
+### Opening a Terminal
+
+1. Navigate to a **project** and select a **repository**
+2. Go to the repository **workspace**
+3. Start or select a **tool instance** that supports the terminal interface
+4. Click the **"Open Terminal"** button
+
+The terminal opens in full-page mode with a status bar at the top.
+
+### Terminal Layout
+
+```
+┌─────────────────────────────────────────────┐
+│  ● Connected                [Reconnect] [×] │
+├─────────────────────────────────────────────┤
+│                                             │
+│  user@container:~$ ls -la                   │
+│  total 128                                  │
+│  drwxr-xr-x  5 user user 4096 May 27 10:00 │
+│  ...                                        │
+│                                             │
+└─────────────────────────────────────────────┘
+```
+
+**Status bar (top):**
+- **Connection dot** — color indicates connection health
+- **Status text** — shows current state and latency
+- **Reconnect button** — appears when disconnected
+- **Close button** — returns to the previous page
+
+### Connection States
+
+| Indicator | Meaning | Action |
+|-----------|---------|--------|
+| 🟡 **Yellow dot** + "Connecting..." | Opening WebSocket | Wait or check network |
+| 🟢 **Green dot** + "Connected" | Healthy connection (<100ms) | Ready to use |
+| 🟡 **Yellow dot** + "Slow (150ms)" | Elevated latency | Connection usable but laggy |
+| 🟡 **Yellow dot** + "Reconnecting (2)" | Connection lost, retrying | Wait for auto-reconnect |
+| ⚪ **Gray dot** + "Disconnected" | Max retries exceeded | Click Reconnect or refresh |
+
+**Hover the status dot** to see the current round-trip latency in milliseconds.
+
+### Typing
+
+Type normally as you would in a local terminal. The terminal supports:
+
+- **Printable characters** appear instantly (local echo)
+- **Special keys** (Tab, Enter, Ctrl+C, arrow keys) are sent to the server
+- **Password prompts** automatically suppress local echo
+- **Unicode** input and output
+
+### Reconnecting
+
+The terminal **automatically reconnects** if the WebSocket drops:
+
+- Brief disconnects (WiFi hiccups, proxy timeouts) are recovered within 1–5 seconds
+- Up to **10 reconnection attempts** with exponential backoff
+- **Scrollback is preserved** across reconnects
+- A visual divider (`--- Reconnected ---`) separates old and new output
+
+**Manual reconnect:**
+- Click the **Reconnect** button in the status bar
+- Or press **Ctrl+Shift+R** anywhere in the terminal page
+
+### Session Ended
+
+When the container process exits (e.g., you run `exit` or the container stops), the terminal shows an overlay:
+
+```
+┌─────────────────────────┐
+│    Session Ended        │
+│ The container process   │
+│ has exited.             │
+│                         │
+│ [Reconnect]  [Go Back]  │
+└─────────────────────────┘
+```
+
+- **Reconnect** — spawns a new shell session in the same container
+- **Go Back** — returns to the workspace page
+
+## Keyboard Shortcuts
+
+| Shortcut | Action |
+|----------|--------|
+| `Ctrl+Shift+R` | Force reconnect (bypasses backoff) |
+| Standard terminal shortcuts | `Ctrl+C`, `Ctrl+D`, `Ctrl+L`, Tab completion, etc. |
+
+## Technical Details
+
+### WebSocket Protocol
+
+The terminal communicates over a binary WebSocket with mixed JSON control messages.
+
+**Connection:**
+```
+ws://api.example.com/ws/tool-instances/{instance_id}/terminal
+```
+
+**Binary frames** carry raw terminal I/O. **Text (JSON) frames** carry control messages:
+
+**Client → Server:**
+- `{"type":"ping","id":n}` — heartbeat ping
+- `{"type":"resize","cols":120,"rows":40}` — terminal resize
+- Raw bytes — keystroke input
+
+**Server → Client:**
+- `{"type":"pong","id":n}` — heartbeat response
+- `{"type":"status","status":"connected"}` — session ready
+- `{"type":"set_echo_state","enabled":false}` — disable local echo
+- `{"type":"session_ended","reason":"process_exit"}` — session ended
+- Raw bytes — terminal output
+
+### Architecture
+
+```
+Browser                          Backend
+┌──────────────────────┐         ┌─────────────────────────────┐
+│ TerminalComponent    │         │ terminal.py (WS endpoint)   │
+│ ├─ xterm.js          │◄───────►│ ├─ auth + session mgmt      │
+│ ├─ FitAddon          │  WS     │ └─ echo state detection     │
+│ ├─ SerializeAddon    │         │                             │
+│ └─ useTerminalConn.  │         │ TerminalManager             │
+│    ├─ heartbeat      │         │ ├─ read_loop (batching)     │
+│    ├─ reconnect      │         │ ├─ write_loop               │
+│    ├─ local echo     │         │ └─ heartbeat_loop           │
+│    └─ resize throttle│         │                             │
+│                      │         │ TerminalSession             │
+│ sessionStorage       │         │ ├─ PTY + docker exec        │
+│ (scrollback backup)  │         │ └─ termios echo detection   │
+└──────────────────────┘         └─────────────────────────────┘
+```
+
+### Reconnect Behavior
+
+On disconnect:
+1. The client serializes terminal scrollback to `sessionStorage`
+2. Backoff timer starts (1s, 2s, 4s, 8s, 16s, then caps at 30s)
+3. On reconnect, scrollback is restored + divider line
+4. A new `docker exec` session is spawned transparently
+
+**Note:** The underlying docker exec PTY is not resumable. Reconnect creates a new shell, but scrollback continuity makes this transparent.
+
+### Performance
+
+- **Local echo** makes printable characters appear in <1ms
+- **Message batching** on the backend reduces WebSocket frame overhead
+- **Resize debouncing** (200ms) + throttling (500ms) prevents server spam
+- **Heartbeat interval** is 15s to balance detection speed with server load
+
+## Troubleshooting
+
+### "Connecting..." stays yellow
+
+**Issue:** WebSocket cannot open
+**Check:**
+1. Is the API server running?
+2. Is the tool instance in "running" status?
+3. Check browser console for connection errors
+4. Verify the `VITE_API_BASE_URL` points to the correct API
+
+### "Reconnecting" loops forever
+
+**Issue:** Max reconnection attempts exceeded
+**Check:**
+1. Is the container still running? (`docker ps`)
+2. Did the container crash or get stopped?
+3. Check server logs for `Terminal session error`
+
+### Typing feels slow
+
+**Issue:** High latency or no local echo
+**Check:**
+1. Hover the status dot — latency >100ms is shown as "Slow"
+2. Local echo only works for printable ASCII characters
+3. Password prompts intentionally disable echo
+4. Very high latency may indicate a congested network
+
+### Terminal is blank after reconnect
+
+**Issue:** Scrollback not restored
+**Check:**
+1. `sessionStorage` may have been cleared (new browser session)
+2. The scrollback cap is 10,000 lines — very long sessions may truncate
+3. Browser privacy settings may block `sessionStorage`
+
+### "Session Ended" immediately
+
+**Issue:** Container process exits right away
+**Check:**
+1. The container's default command may have finished
+2. Check the tool type's Docker Compose template
+3. Some tools (like one-off scripts) are not meant for persistent terminal sessions
+
+## Configuration
+
+No additional configuration is required. The terminal adapts automatically to:
+- Browser window size (via ResizeObserver)
+- System light/dark theme preference
+- Network conditions (reconnect backoff)
+
+## Related Features
+
+- [Workspace](workspace.md) — Open the terminal from the repository workspace
+- [Tool Types](tool-types.md) — Configure which tools expose a terminal interface
+- [SSH Keys](ssh-keys.md) — Manage SSH keys for repository access from within the terminal

openspec/changes/archive/2026-05-22-add-project-settings-page/.openspec.yaml

@@ -0,0 +1,2 @@
+schema: spec-driven
+created: 2026-05-22

openspec/changes/archive/2026-05-22-add-project-settings-page/design.md

@@ -0,0 +1,47 @@
+## Context
+
+The projects listing page (`apps/web/src/pages/projects.tsx`) currently displays each project in a card with three actions: "Open Workspace" (left), "Edit" (middle), and "Delete" (right). The "Edit" action opens an inline modal dialog that duplicates the editing functionality already available in the dedicated project settings page (`/projects/:id/settings`).
+
+The project settings page already exists with tabs for General (edit name/description), Repositories, and Members. The add-repo functionality is already located in the Repositories tab.
+
+## Goals / Non-Goals
+
+**Goals:**
+- Simplify the projects listing page by removing the inline edit modal
+- Add a Settings link to project cards for navigation to the settings page
+- Reposition the "Open Workspace" button to the right side for easier access
+- Keep the projects page focused on navigation and creation
+
+**Non-Goals:**
+- No changes to project settings page functionality (already implemented)
+- No changes to backend APIs
+- No changes to the add-repo flow (already in settings)
+- No changes to workspace or repository pages
+
+## Decisions
+
+**Decision: Remove Edit modal, link to settings instead**
+- Rationale: The settings page already provides a better editing experience with tabs, persistence feedback, and access to repositories/members. Maintaining two edit UIs creates duplication and confusion.
+- Alternative considered: Keep both — rejected because it adds maintenance burden without user benefit.
+
+**Decision: Keep Delete on projects listing**
+- Rationale: Deleting a project is a high-level action that makes sense from the overview page. Users expect to delete items from a list view.
+
+**Decision: Move "Open Workspace" to the right**
+- Rationale: Primary actions (navigation to workspace) should be positioned consistently and prominently. Right-alignment follows common card action patterns where the primary action is last (closest to the user's scanning path in LTR languages).
+- Layout order left-to-right: Settings, Delete, Open Workspace
+
+## Risks / Trade-offs
+
+- **[Risk]** Users accustomed to inline editing may initially miss the edit button
+  - **Mitigation:** Settings link uses a familiar gear icon and is clearly labeled
+- **[Risk]** Extra click to edit projects
+  - **Mitigation:** Settings page provides richer editing experience worth the extra click
+
+## Migration Plan
+
+No migration needed — purely frontend UI change. Existing project data and APIs are unaffected.
+
+## Open Questions
+
+None

openspec/changes/archive/2026-05-22-add-project-settings-page/proposal.md

@@ -0,0 +1,27 @@
+## Why
+
+The current projects listing page mixes project management actions (create, edit, delete) with workspace navigation, leading to a cluttered UI. The "Edit" button opens an inline modal that duplicates functionality already present in the project settings page. Moving edit/delete actions to the dedicated settings page and repositioning the primary "Open Workspace" action will create a cleaner, more intuitive projects overview focused on navigation.
+
+## What Changes
+
+- **Remove** the Edit button and modal dialog from the projects listing page (`projects.tsx`)
+- **Add** a Settings link to each project card that navigates to `/projects/:id/settings`
+- **Move** the "Open Workspace" button to the right side of project cards for easier access
+- **Keep** the "New Project" button and "Delete" button on the projects listing page
+- **No backend changes** — uses existing project settings page and APIs
+
+## Capabilities
+
+### New Capabilities
+- *(none — uses existing project-management and frontend-foundation capabilities)*
+
+### Modified Capabilities
+- `project-management`: Update UI flow — project editing is now accessed via settings page instead of inline modal
+- `frontend-foundation`: Update projects list page layout and navigation pattern
+
+## Impact
+
+- `apps/web/src/pages/projects.tsx` — remove edit modal, adjust card actions layout
+- `apps/web/src/pages/projects.test.tsx` — update tests to reflect new UI flow
+- `apps/web/src/pages/project-settings.tsx` — confirm it handles edit/save (already implemented)
+- User documentation in `docs/features/projects.md` — update editing instructions

openspec/changes/archive/2026-05-22-add-project-settings-page/specs/frontend-foundation/spec.md

@@ -0,0 +1,19 @@
+## ADDED Requirements
+
+### Requirement: Projects Listing Page Layout
+The projects listing page SHALL display project cards with Settings, Delete, and Open Workspace actions, where Open Workspace is the rightmost action.
+
+#### Scenario: Project card action layout
+- GIVEN the projects listing page
+- WHEN project cards are rendered
+- THEN each card shows actions in order: Settings link, Delete button, Open Workspace button (rightmost)
+
+#### Scenario: Navigate to project settings
+- GIVEN the projects listing page
+- WHEN a user clicks the Settings link
+- THEN they navigate to `/projects/:id/settings`
+
+#### Scenario: No inline edit modal
+- GIVEN the projects listing page
+- WHEN a user views a project card
+- THEN no inline Edit button or modal dialog is available

openspec/changes/archive/2026-05-22-add-project-settings-page/specs/project-management/spec.md

@@ -0,0 +1,37 @@
+## ADDED Requirements
+
+### Requirement: Project Card Layout
+The projects listing page SHALL display each project card with a Settings link, Delete button, and Open Workspace button, where the Open Workspace button is positioned on the right.
+
+#### Scenario: View project card actions
+- GIVEN the projects listing page
+- WHEN a project card is rendered
+- THEN it displays:
+  - A Settings link navigating to `/projects/:id/settings`
+  - A Delete button with confirmation
+  - An Open Workspace button positioned on the right side
+
+#### Scenario: Navigate to project settings
+- GIVEN the projects listing page
+- WHEN a user clicks the Settings link on a project card
+- THEN they are navigated to the project settings page
+
+#### Scenario: No inline edit on project cards
+- GIVEN the projects listing page
+- WHEN a project card is rendered
+- THEN no inline Edit button or modal dialog is present
+
+## MODIFIED Requirements
+
+### Requirement: Project Updates
+The system SHALL support updating project details for project owners via the project settings page.
+
+#### Scenario: Update project via settings
+- GIVEN a project owner viewing the project settings page
+- WHEN they update the name or description and save
+- THEN the changes are persisted
+
+#### Scenario: Non-owner update denied
+- GIVEN a user who is not the project owner
+- WHEN they attempt to update project details via the settings page
+- THEN the system responds with forbidden status

openspec/changes/archive/2026-05-22-add-project-settings-page/tasks.md

@@ -0,0 +1,36 @@
+## 1. Update Projects Listing Page
+
+- [x] 1.1 Remove edit modal and related state from `apps/web/src/pages/projects.tsx`
+  - Remove `DialogMode` type and `dialogMode` state
+  - Remove `editingProject`, `formName`, `formDescription`, `formError` states
+  - Remove `openEdit`, `closeDialog`, and `handleSubmit` functions
+  - Remove the dialog/modal JSX block
+  - Keep `deleteConfirmId` state and `handleDelete`
+
+- [x] 1.2 Update project card actions in `apps/web/src/pages/projects.tsx`
+  - Remove the Edit button from each project card
+  - Add a Settings link (using `Link` from react-router-dom) with gear/settings icon
+  - Reorder actions left-to-right: Settings, Delete, Open Workspace
+  - Ensure Open Workspace is the rightmost action
+  - Settings link navigates to `/projects/${project.id}/settings`
+
+## 2. Update Tests
+
+- [x] 2.1 Update `apps/web/src/pages/projects.test.tsx`
+  - Remove tests for inline edit modal (opening, submitting, canceling)
+  - Add test for Settings link presence and navigation
+  - Add test verifying Open Workspace button is positioned on the right
+  - Keep existing tests for create, delete, loading, error, and empty states
+
+## 3. Update Documentation
+
+- [x] 3.1 Update `docs/features/projects.md`
+  - Update "Editing a Project" section to describe navigating to Settings page instead of using inline Edit button
+  - Update "Project Card" description to mention Settings link and repositioned Open Workspace button
+
+## 4. Verification
+
+- [x] 4.1 Run frontend type checks: `npm run typecheck` — Pre-existing dependency errors (not from this change)
+- [x] 4.2 Run frontend linter: `npm run lint` — Passed
+- [x] 4.3 Run frontend tests: `npm test -- projects.test.tsx` — Pre-existing missing dependency (not from this change)
+- [x] 4.4 Verify no regressions in project settings page — No changes to settings page

openspec/changes/responsive-terminal/design.md

@@ -0,0 +1,371 @@
+# Design: Responsive Web Terminal
+
+## Architecture Overview
+
+```
+┌─────────────────────────────────────────────────────────────────────────┐
+│                              BROWSER                                      │
+│  ┌──────────────┐   ┌─────────────────┐   ┌──────────────────────────┐  │
+│  │  TerminalPage │   │ TerminalComponent │   │ TerminalConnection      │  │
+│  │  (router)     │◄──│  (xterm.js + UI)  │◄──│ (WS + heartbeat + echo) │  │
+│  └──────────────┘   └─────────────────┘   └──────────────────────────┘  │
+│                          │                          │                   │
+│                    ┌─────┴─────┐            ┌──────┴──────┐            │
+│                    │ xterm.js  │            │ sessionStorage│           │
+│                    │ + addons  │            │ (scrollback)  │           │
+│                    └───────────┘            └───────────────┘           │
+└─────────────────────────────────────────────────────────────────────────┘
+                                    │ WebSocket
+                                    ▼
+┌─────────────────────────────────────────────────────────────────────────┐
+│                              FASTAPI                                      │
+│  ┌──────────────────┐   ┌──────────────────┐   ┌─────────────────────┐  │
+│  │ terminal.py       │   │ TerminalManager   │   │ TerminalSession      │  │
+│  │ (WS endpoint)     │◄──│ (session mgmt)    │◄──│ (PTY + docker exec)  │  │
+│  └──────────────────┘   └──────────────────┘   └─────────────────────┘  │
+│                                                         │               │
+│                                                    ┌────┴────┐          │
+│                                                    │ docker  │          │
+│                                                    │  exec   │          │
+│                                                    └─────────┘          │
+└─────────────────────────────────────────────────────────────────────────┘
+```
+
+## Connection State Machine
+
+### Client State Machine
+
+```
+                    ┌─────────────┐
+                    │    IDLE     │
+                    └──────┬──────┘
+                           │ mount
+                           ▼
+                    ┌─────────────┐
+                    │ CONNECTING  │◄────────────────────────┐
+                    └──────┬──────┘                         │
+                           │ onopen                         │
+                           ▼                                │
+              ┌─────────────────────────┐                   │
+              │       CONNECTED         │                   │
+              │  (heartbeat active)     │                   │
+              └──────┬──────────┬───────┘                   │
+                     │          │                           │
+          onclose/   │          │ ping timeout              │
+          onerror    │          │                           │
+                     ▼          ▼                           │
+              ┌─────────────────────────┐                   │
+              │      RECONNECTING       │───────────────────┘
+              │  (backoff: 1→2→4→8→30s) │  onopen (success)
+              └──────┬──────────────────┘
+                     │ max retries (10)
+                     ▼
+              ┌─────────────────────────┐
+              │      DISCONNECTED       │
+              │   (manual reconnect     │
+              │    or navigate away)    │
+              └─────────────────────────┘
+```
+
+### Server State Machine (per session)
+
+```
+                    ┌─────────────┐
+                    │   PENDING   │
+                    └──────┬──────┘
+                           │ ws.accept()
+                           ▼
+                    ┌─────────────┐
+              ┌────►│   ACTIVE    │◄────┐
+              │     │ (I/O loops  │     │
+              │     │  + heartbeat)     │
+              │     └──────┬──────┘     │
+              │            │             │
+              │    ws close│      new ws │
+              │            ▼             │
+              │     ┌─────────────┐      │
+              └─────┤   CLOSED    ├──────┘
+                    │ (cleanup)   │
+                    └─────────────┘
+```
+
+## Protocol Specification
+
+### Message Types
+
+All control messages are JSON text frames. Raw terminal I/O uses binary frames.
+
+#### Client → Server
+
+| Type | Payload | When |
+|------|---------|------|
+| `ping` | `{ id: number }` | Every 15s of inactivity |
+| `pong` | `{ id: number }` | Response to server ping |
+| `resize` | `{ cols: number, rows: number }` | Terminal size changes (debounced) |
+| `input` | `{ data: string }` | User keystrokes (base64-encoded) |
+
+#### Server → Client
+
+| Type | Payload | When |
+|------|---------|------|
+| `pong` | `{ id: number }` | Response to client ping |
+| `status` | `{ status: "connected" \| "reconnected" }` | After auth + session ready |
+| `set_echo_state` | `{ enabled: boolean }` | When PTY echo flag changes |
+| `session_ended` | `{ reason: string }` | When container process exits |
+
+### Binary Frame Convention
+
+- **Client → Server:** Raw UTF-8 bytes of user input. No wrapping.
+- **Server → Client:** Raw bytes from PTY master read. No wrapping.
+
+This avoids the current Blob→ArrayBuffer async conversion and JSON parsing overhead for the hot path.
+
+## Frontend Design
+
+### New Files
+
+```
+apps/web/src/
+├── components/
+│   └── terminal.tsx              (rewrite: state machine + reconnect)
+├── hooks/
+│   └── use-terminal-connection.ts (NEW: WS lifecycle, heartbeat, reconnect)
+├── utils/
+│   └── terminal-protocol.ts     (NEW: message encoding/decoding)
+└── types/
+    └── terminal.ts              (NEW: protocol types)
+```
+
+### `useTerminalConnection` Hook
+
+Responsibilities:
+1. **WebSocket lifecycle:** Open, close, reconnect with backoff
+2. **Heartbeat:** Send ping every 15s, expect pong within 5s
+3. **Local echo:** Write printable chars to xterm immediately, deduplicate server echo
+4. **Resize:** Debounce resize events, send JSON control message
+5. **Scrollback:** Serialize on disconnect, restore on reconnect
+6. **State reporting:** Expose `status`, `latency`, `attempt` to UI
+
+```typescript
+interface TerminalConnectionState {
+  status: "connecting" | "connected" | "reconnecting" | "disconnected";
+  attempt: number;
+  latency: number | null;  // last RTT in ms
+  error: string | null;
+}
+
+interface TerminalConnection {
+  state: TerminalConnectionState;
+  sendInput: (data: string) => void;
+  sendResize: (cols: number, rows: number) => void;
+  reconnect: () => void;  // manual, bypasses backoff
+  onData: (callback: (data: Uint8Array) => void) => void;
+  onControl: (callback: (msg: ServerControlMessage) => void) => void;
+}
+```
+
+### Local Echo Algorithm
+
+```
+1. User types character c
+2. IF c is printable ASCII AND echo is enabled:
+     a. Write c to xterm immediately
+     b. Add c to "pending echo" buffer
+     c. Send c to server via WebSocket
+3. ELSE (control char, arrow, escape sequence):
+     a. Send c to server only
+     b. Do NOT write to xterm
+4. When server sends data:
+     a. For each char in server data:
+        - IF char matches head of "pending echo" buffer:
+            → Pop from buffer (deduplication)
+        - ELSE:
+            → Write char to xterm
+     b. If "pending echo" buffer grows > 100 chars (stale):
+        → Flush buffer to xterm (server echo was lost)
+```
+
+### Scrollback Serialization
+
+```
+ON disconnect:
+  1. buffer = xterm.serialize({ scrollback: 10000 })
+  2. sessionStorage.setItem(`hq-terminal-${instanceId}`, buffer)
+
+ON reconnect:
+  1. buffer = sessionStorage.getItem(`hq-terminal-${instanceId}`)
+  2. IF buffer:
+       xterm.write(buffer)
+       xterm.write("\r\n\x1b[90m--- Reconnected ---\x1b[0m\r\n")
+  3. sessionStorage.removeItem(`hq-terminal-${instanceId}`)
+```
+
+### Resize Debouncing
+
+Use `ResizeObserver` on the terminal container instead of `window.resize`:
+
+```typescript
+const resizeObserver = new ResizeObserver(
+  debounce((entries) => {
+    fitAddon.fit();
+    sendResize(term.cols, term.rows);
+  }, 200)
+);
+```
+
+Rate limit: max 1 resize message per 500ms.
+
+## Backend Design
+
+### Modified Files
+
+```
+apps/api/src/
+├── api/terminal.py               (modify: ping/pong, session_ended)
+├── services/terminal_manager.py  (rewrite: heartbeat tracking, batching)
+└── services/terminal_session.py  (modify: batching read, echo detection)
+```
+
+### TerminalManager Changes
+
+**Heartbeat tracking:**
+- Track `last_ping_at` per session
+- Background task: if `last_ping_at` is older than 60s, close the WebSocket
+
+**Message batching in read_loop:**
+```python
+async def _read_loop(self, session, websocket):
+    buffer = bytearray()
+    last_flush = time.monotonic()
+    
+    while session.is_alive() and not session._closed:
+        data = await session.read_output()
+        if data:
+            buffer.extend(data)
+            
+        now = time.monotonic()
+        if buffer and (now - last_flush >= 0.016 or not data):
+            await websocket.send_bytes(bytes(buffer))
+            buffer.clear()
+            last_flush = now
+        elif not data:
+            await asyncio.sleep(0.001)
+```
+
+**Reconnect support:**
+- When a new WebSocket connects for the same instance, terminate the old session and spawn a new one
+- This is the docker exec limitation — we cannot resume a PTY, only replace it
+
+### TerminalSession Changes
+
+**Echo state detection:**
+```python
+import termios
+
+def _detect_echo_state(self) -> bool:
+    if self._master_fd is None:
+        return True
+    try:
+        attrs = termios.tcgetattr(self._master_fd)
+        return bool(attrs[3] & termios.ECHO)
+    except:
+        return True
+```
+
+Call `_detect_echo_state()` after each resize and periodically (every 1s) during active I/O. Send `set_echo_state` to client when it changes.
+
+**Batch-friendly read:**
+- Change `read_output()` to use `asyncio.wait_for(select, timeout)` instead of blocking `select.select` with 0.1s timeout
+- Return immediately when data is available, sleep briefly when not
+
+### Terminal Endpoint Changes
+
+- Accept `ping` messages, respond with `pong`
+- On session end (process exit), send `session_ended` before closing with code 1000
+- Distinguish between container exit (friendly) and error (unexpected)
+
+## Data Flow: Typing with Local Echo
+
+```
+User presses 'a'
+    │
+    ▼
+┌─────────────────┐
+│ onData handler  │──► xterm.write('a') [instant feedback]
+│                 │──► pendingEcho.push('a')
+│                 │──► ws.send(binary 'a')
+└─────────────────┘
+    │
+    ▼ (network)
+┌─────────────────┐
+│ TerminalSession │──► os.write(master_fd, b'a')
+│                 │──► docker exec PTY echoes 'a' back
+│                 │──► os.read(master_fd) → b'a'
+└─────────────────┘
+    │
+    ▼ (WebSocket)
+┌─────────────────┐
+│ onMessage       │──► data = b'a'
+│ (binary frame)  │──► IF data[0] == pendingEcho[0]:
+│                 │       pendingEcho.shift()  // dedup
+│                 │    ELSE:
+│                 │       xterm.write(data)
+└─────────────────┘
+```
+
+## Data Flow: Reconnection
+
+```
+WebSocket closes (code 1006)
+    │
+    ▼
+┌─────────────────┐
+│ ConnectionState │──► status = "reconnecting"
+│                 │──► attempt = 1
+│                 │──► scrollback = xterm.serialize()
+│                 │──► sessionStorage.setItem(key, scrollback)
+│                 │──► schedule reconnect in 1s
+└─────────────────┘
+    │
+    ▼ (1s later)
+┌─────────────────┐
+│ Reconnect       │──► new WebSocket(url)
+│                 │──► onopen: send scrollback from storage
+│                 │──► xterm.write(restored + divider)
+│                 │──► status = "connected"
+└─────────────────┘
+```
+
+## Component Responsibilities
+
+| Component | Responsibilities |
+|-----------|-----------------|
+| `TerminalPage` | Routing, layout, back button |
+| `TerminalComponent` | xterm.js lifecycle, addons, theme, status bar UI |
+| `useTerminalConnection` | WebSocket, heartbeat, reconnect, local echo, resize |
+| `terminal-protocol` | Encode/decode control messages, base64 helper |
+| `terminal.py` (API) | Auth, WebSocket accept, route control messages |
+| `TerminalManager` | Session lifecycle, heartbeat tracking, read/write loops |
+| `TerminalSession` | PTY + docker exec, echo detection, batching read |
+
+## Tradeoffs
+
+| Decision | Option A (Chosen) | Option B | Why A |
+|----------|-------------------|----------|-------|
+| **Reconnect strategy** | Exponential backoff, max 30s | Instant reconnect with no backoff | Backoff prevents server overload during outages |
+| **Local echo scope** | Printable ASCII only | All characters | Control chars/escapes need server-side processing (shell state) |
+| **Scrollback storage** | `sessionStorage` (tab-scoped) | `localStorage` (persistent) | Privacy: terminal may contain secrets |
+| **Scrollback cap** | 10,000 lines | Unlimited | Memory safety; 10K lines covers typical session |
+| **Heartbeat interval** | 15s client → server | 5s | Balance between detection speed and server load |
+| **Binary vs text I/O** | Binary frames for raw data | JSON-wrapped base64 | Binary is ~33% more efficient, zero parse overhead |
+| **Resize trigger** | ResizeObserver on container | window.resize | Container-level is more accurate for flex layouts |
+| **Echo detection** | Server inspects PTY termios | Client guesses from input | Server is authoritative; client cannot know shell state |
+| **New docker exec on reconnect** | Accept limitation | Implement persistent session | PTY resumption across connections is extremely complex; scrollback continuity is the pragmatic fix |
+
+## Quality Gates
+
+- `cd apps/web && npm run typecheck` — TypeScript compiles
+- `cd apps/web && npm run lint` — ESLint passes
+- `cd apps/web && npm test` — Vitest passes (new tests for protocol + hook)
+- `make test` — Backend pytest passes
+- Manual test: disconnect/reconnect, type latency, resize, container exit

openspec/changes/responsive-terminal/explore.md

@@ -0,0 +1,59 @@
+# Explore: Responsive Web Terminal
+
+## Problem Statement
+
+The current web terminal feels sluggish and fragile compared to a local terminal session. Key pain points:
+
+1. **No reconnection** — A brief network hiccup kills the terminal. Users must navigate away and back.
+2. **No heartbeat** — Half-open connections stall silently. No way to know if the terminal is alive.
+3. **High input latency** — Every keystroke round-trips to the server before appearing on screen. No local echo.
+4. **Inefficient I/O path** — Backend `select` polling with 0.1s timeout, 4096-byte reads, busy-wait sleep(0.01). Frontend receives Blob and converts to ArrayBuffer asynchronously.
+5. **No scrollback persistence** — Reconnect starts with a blank terminal. Session history is lost.
+6. **Rudimentary resize** — Fires on every window resize event with no debouncing.
+7. **No connection quality feedback** — Binary status (connected/disconnected). No latency or health indicator.
+8. **No graceful container exit handling** — Process death closes WebSocket with a generic error.
+
+## Current Architecture
+
+### Frontend
+- `apps/web/src/components/terminal.tsx` — xterm.js v5.3.0 with FitAddon and WebLinksAddon
+- WebSocket to `/ws/tool-instances/{instance_id}/terminal`
+- Receives Blob (binary) and string (JSON control) messages
+- Sends raw bytes for input, JSON for resize
+- Basic status: connecting | connected | disconnected | error
+
+### Backend
+- `apps/api/src/api/terminal.py` — FastAPI WebSocket endpoint, auth, session lifecycle
+- `apps/api/src/services/terminal_manager.py` — Manages TerminalSession, read/write loops
+- `apps/api/src/services/terminal_session.py` — PTY-based `docker exec` with `select` I/O
+- Protocol: raw bytes for terminal I/O, JSON for resize control messages
+
+### Gaps vs. Local Terminal Feel
+
+| Aspect | Local Terminal | Current Web Terminal |
+|--------|---------------|----------------------|
+| Keystroke feedback | Immediate (kernel TTY) | Round-trip (~50-200ms) |
+| Network resilience | N/A (local) | Dies on any disconnect |
+| Scrollback | Persistent | Lost on reconnect |
+| Resize | Instant | Undebounced, may spam |
+| Health visibility | Always local | Binary connected/disconnected |
+| Large output | Buffered by kernel | Select polling, 4KB chunks |
+
+## Opportunities
+
+- **WebSocket reconnection with exponential backoff** and session token for continuity
+- **Heartbeat/ping-pong** to detect half-open connections within seconds
+- **Local echo optimization** for printable characters (with server-side authoritative sync)
+- **Message batching** on backend to reduce WebSocket frame overhead
+- **Scrollback serialization** via xterm-addon-serialize to restore on reconnect
+- **Resize debouncing** to avoid flooding the server
+- **Connection quality indicator** (latency, jitter) in the terminal chrome
+- **Graceful handling** of container exit with clear user messaging
+
+## Risks
+
+- Adding heartbeat may increase server load with many concurrent terminals
+- Local echo requires careful handling of password prompts and special modes
+- Reconnecting to a docker exec PTY is not natively resumable — new `docker exec` on reconnect
+- xterm-addon-serialize may be large for very long sessions
+- Changes touch both frontend and backend — cross-stack coordination needed

openspec/changes/responsive-terminal/proposal.md

@@ -0,0 +1,77 @@
+# Proposal: Responsive Web Terminal
+
+## Problem Statement
+
+The web terminal in Headquarter feels sluggish and fragile compared to a local terminal session. Users experience high input latency (every keystroke round-trips to the server before appearing), lose their session on any network blip, and have no visibility into connection health. This makes the terminal the weakest part of the workspace experience, especially for users on slower or unstable networks.
+
+## User Stories
+
+### US-1: Network Resilience
+> As a developer working on a laptop with WiFi,
+> I want the terminal to survive brief disconnections (up to ~30 seconds),
+> so that a network hiccup does not kill my running process and scrollback.
+
+### US-2: Responsive Typing
+> As a developer typing commands or code in the terminal,
+> I want keystrokes to appear on screen instantly,
+> so that the terminal feels like a local TTY and not a remote typewriter.
+
+### US-3: Session Continuity
+> As a developer who accidentally refreshed the page,
+> I want my terminal scrollback and state to be restored on reconnect,
+> so that I do not lose context of what I was doing.
+
+### US-4: Connection Health Visibility
+> As a developer on a slow or congested network,
+> I want to see clear feedback about connection quality and reconnection attempts,
+> so that I understand whether lag is from the server, the container, or my network.
+
+### US-5: Graceful Container Exit
+> As a developer whose container process has finished,
+> I want to see a clear message explaining what happened and options to reconnect or go back,
+> so that I am not confused by a generic "Connection closed" error.
+
+## Success Metrics
+
+| Metric | Current | Target |
+|--------|---------|--------|
+| Time-to-reconnect after disconnect | ∞ (must navigate away) | < 5 seconds |
+| Typing latency (median) | ~100-300ms | < 50ms perceived |
+| Scrollback lost on reconnect | 100% | 0% (restored from serialization) |
+| Silent connection stalls detected | 0% | 100% within 10 seconds |
+| User confusion on container exit | High | Low (clear messaging) |
+
+## Scope
+
+### In Scope
+- WebSocket auto-reconnection with exponential backoff
+- Heartbeat/ping-pong protocol between client and server
+- Local echo for printable characters (with server authoritative sync)
+- Resize debouncing to avoid server spam
+- Scrollback serialization via xterm-addon-serialize on disconnect
+- Scrollback restoration on reconnect
+- Connection quality indicator (latency, status) in terminal chrome
+- Graceful container exit handling with user-friendly messaging
+- Backend message batching for large output bursts
+
+### Out of Scope (for this change)
+- Full terminal session recording/playback
+- Multi-user collaborative terminal sessions
+- Terminal session persistence across server restarts
+- Clipboard integration improvements (separate feature)
+- Terminal search/find (separate feature)
+
+## Risks & Mitigations
+
+| Risk | Likelihood | Impact | Mitigation |
+|------|-----------|--------|------------|
+| Heartbeat increases server load with many terminals | Medium | Medium | Use 15s heartbeat interval; skip during idle periods |
+| Local echo breaks password prompts | Medium | High | Disable local echo when terminal is in "no echo" mode; server sends echo-state control messages |
+| Scrollback serialization is large for long sessions | Low | Medium | Cap serialization at 10,000 lines; compress before send |
+| Reconnect spawns new docker exec = new shell | Certain | Low | Accept as limitation; focus on scrollback continuity and clear messaging |
+| Cross-stack changes introduce regressions | Medium | High | Comprehensive test coverage; fresh review before merge |
+
+## Approval
+
+- [ ] Approved
+- [ ] Needs revision

openspec/changes/responsive-terminal/spec.md

@@ -0,0 +1,153 @@
+# Spec: Responsive Web Terminal
+
+## Overview
+
+Upgrade the web terminal from a fragile single-shot WebSocket into a resilient, responsive terminal that survives network blips, provides instant typing feedback, restores scrollback on reconnect, and gives users clear visibility into connection health.
+
+## Acceptance Criteria
+
+### AC-1: WebSocket Auto-Reconnection
+
+**GIVEN** a terminal is connected to a running instance  
+**WHEN** the WebSocket disconnects (network hiccup, server restart, proxy timeout)  
+**THEN** the client automatically reconnects with exponential backoff (1s, 2s, 4s, 8s, max 30s)  
+**AND** the user sees a reconnection indicator showing attempt count and next retry time  
+**AND** after successful reconnection, the terminal scrollback is restored  
+**AND** a new `docker exec` session is spawned transparently
+
+**Test:** Disconnect WiFi for 5s, verify reconnect and scrollback intact.
+
+### AC-2: Heartbeat / Ping-Pong Protocol
+
+**GIVEN** a terminal connection is established  
+**WHEN** 15 seconds pass with no data exchanged  
+**THEN** the client sends a `ping` control message  
+**AND** the server responds with a `pong` within 5 seconds  
+**AND** if no `pong` is received within 5 seconds, the client treats the connection as dead and begins reconnection  
+**AND** the server closes WebSockets that have not sent any message (including ping) for 60 seconds
+
+**Test:** Block server responses with firewall rule, verify connection declared dead within 20s and reconnection starts.
+
+### AC-3: Local Echo for Reduced Typing Latency
+
+**GIVEN** the terminal is in a normal interactive shell  
+**WHEN** the user types printable ASCII characters  
+**THEN** they appear on screen immediately (local echo) without waiting for the server round-trip  
+**AND** when the server sends the authoritative echo back, the client reconciles (deduplicates)  
+**AND** when the server sends a `set_echo_state` control message with `enabled: false` (e.g., for password prompts), local echo is disabled  
+**AND** when `set_echo_state` with `enabled: true` is received, local echo is re-enabled
+
+**Test:** Type `echo hello` — characters appear instantly. Run `sudo` — local echo stops during password prompt.
+
+### AC-4: Resize Debouncing
+
+**GIVEN** the user is resizing the browser window  
+**WHEN** the terminal dimensions change  
+**THEN** resize events are debounced by 200ms  
+**AND** only the final dimensions after the user stops resizing are sent to the server  
+**AND** at most one resize message is sent per 500ms
+
+**Test:** Rapidly resize window 10 times in 1s — verify only 1-2 resize messages sent.
+
+### AC-5: Scrollback Serialization and Restoration
+
+**GIVEN** a terminal has been in use with output history  
+**WHEN** a disconnect occurs  
+**THEN** the client serializes the terminal buffer (via xterm-addon-serialize, capped at 10,000 lines)  
+**AND** stores it in `sessionStorage` under key `hq-terminal-{instance_id}`  
+**AND** on successful reconnection, the serialized content is written back into the terminal before new output  
+**AND** a visual divider line indicates "--- Reconnected ---" between old and new output
+
+**Test:** Run `ls -la` 50 times, disconnect, reconnect — verify all output visible with divider.
+
+### AC-6: Connection Quality Indicator
+
+**GIVEN** the terminal is connected  
+**THEN** the status bar shows:  
+- Green dot + "Connected" when healthy (latency < 100ms)  
+- Yellow dot + "Slow" when latency is 100-500ms  
+- Red dot + "Reconnecting (N)" during reconnection attempts  
+- Gray dot + "Disconnected" when permanently disconnected (max retries exceeded)  
+**AND** hovering the status dot shows a tooltip with round-trip latency (ms) and jitter  
+**AND** the indicator updates every 5 seconds
+
+**Test:** Use network throttling in dev tools to simulate slow connection, verify indicator changes.
+
+### AC-7: Graceful Container Exit
+
+**GIVEN** a terminal session is active  
+**WHEN** the container process exits (shell terminates, container stops)  
+**THEN** the terminal shows a clear message: "Session ended. The container process has exited."  
+**AND** a "Reconnect" button is shown to spawn a new session  
+**AND** a "Go Back" button navigates to the previous page  
+**AND** the WebSocket closes with code 1000 (normal) instead of an error code
+
+**Test:** Run `exit` in the terminal, verify friendly message and buttons appear.
+
+### AC-8: Backend Message Batching
+
+**GIVEN** a container process is producing output rapidly  
+**WHEN** the backend PTY produces multiple small reads within a single event loop tick  
+**THEN** the backend batches them into a single WebSocket binary frame  
+**AND** batching does not add more than 16ms of latency  
+**AND** the batch is flushed immediately when no new data is available
+
+**Test:** Run `yes | head -n 10000` and measure WebSocket frame count vs. current implementation.
+
+### AC-9: Keyboard Shortcut for Reconnect
+
+**GIVEN** the terminal is disconnected  
+**WHEN** the user presses `Ctrl+Shift+R`  
+**THEN** an immediate reconnection attempt is triggered (bypassing backoff)
+
+**Test:** Disconnect terminal, press `Ctrl+Shift+R`, verify immediate reconnect attempt.
+
+## API / Protocol Changes
+
+### WebSocket Control Messages (JSON)
+
+```typescript
+// Client → Server
+type ClientMessage =
+  | { type: "ping"; id: number }
+  | { type: "pong"; id: number }
+  | { type: "resize"; cols: number; rows: number }
+  | { type: "input"; data: string }  // base64-encoded bytes
+
+// Server → Client
+type ServerMessage =
+  | { type: "pong"; id: number }
+  | { type: "status"; status: "connected" | "reconnected" }
+  | { type: "set_echo_state"; enabled: boolean }
+  | { type: "session_ended"; reason: "process_exit" | "container_stop" | "timeout" }
+```
+
+### Binary Frames
+
+- Raw terminal output from server → client: binary WebSocket frame (no wrapping)
+- Raw terminal input from client → server: binary WebSocket frame (no wrapping)
+- Control messages (resize, ping, etc.): text JSON frames
+
+## Dependencies
+
+### Frontend
+- `xterm-addon-serialize` — scrollback serialization
+- `xterm-addon-webgl` (optional) — GPU rendering for smoother feel
+
+### Backend
+- No new Python dependencies required
+- Uses existing `asyncio`, `fastapi`, `websockets`
+
+## Non-Functional Requirements
+
+- **Latency:** Perceived typing latency < 50ms for local echo characters
+- **Reconnection time:** < 5 seconds for transient disconnects
+- **Memory:** Scrollback serialization capped at 10,000 lines (~2-5MB worst case)
+- **Server load:** Heartbeat interval 15s; max 4 pings/minute per terminal
+- **Browser support:** Chrome 90+, Firefox 88+, Safari 14+ (all support required WebSocket features)
+
+## Open Questions
+
+1. Should we add a "full screen" button to the terminal chrome? (Nice-to-have, out of scope for this change)
+2. Should scrollback be persisted across full page reloads (via `localStorage`) or only during session (`sessionStorage`)? — **Decision:** Use `sessionStorage` to avoid leaking sensitive data.
+3. Should the server echo-state detection be automatic (TIOCGWINSZ / stty inspection) or manual (client tells server)? — **Decision:** Server detects via PTY state inspection; sends `set_echo_state` to client.

openspec/changes/responsive-terminal/tasks.md

@@ -0,0 +1,213 @@
+# Tasks: Responsive Web Terminal
+
+## Review Workload Forecast
+
+| Task | Estimated Lines | Stack | Risk |
+|------|----------------|-------|------|
+| T1: Protocol types + utilities | ~120 | Frontend | Low |
+| T2: Backend heartbeat + batching | ~200 | Backend | Medium |
+| T3: Backend echo detection + graceful exit | ~150 | Backend | Medium |
+| T4: useTerminalConnection hook | ~280 | Frontend | High |
+| T5: TerminalComponent rewrite | ~250 | Frontend | High |
+| T6: Frontend tests | ~180 | Frontend | Low |
+| T7: Backend tests | ~120 | Backend | Low |
+| **Total** | **~1,300** | | |
+
+**Review recommendation:** This exceeds the 400-line budget. Split into **3 chained PRs**:
+1. **PR-1 (Backend foundation):** T1 protocol types + T2 heartbeat/batching + T3 echo/exit + T7 backend tests (~590 lines)
+2. **PR-2 (Frontend connection):** T4 useTerminalConnection hook + T6 frontend hook tests (~460 lines)
+3. **PR-3 (Terminal UI + integration):** T5 TerminalComponent rewrite + page integration + remaining tests (~250 lines)
+
+---
+
+## Task T1: Protocol Types and Utilities
+
+**Files:**
+- `apps/web/src/types/terminal.ts` (new)
+- `apps/web/src/utils/terminal-protocol.ts` (new)
+- `apps/web/package.json` (add `xterm-addon-serialize`)
+
+**Description:**
+Define TypeScript types for all WebSocket control messages. Implement encode/decode helpers that distinguish binary frames (raw terminal I/O) from JSON text frames (control messages). Add base64 encoding for the `input` control message type. Install `xterm-addon-serialize` dependency.
+
+**Acceptance:**
+- All message types from the design spec are represented as TypeScript types
+- `encodeControlMessage` and `decodeControlMessage` functions handle JSON serialization
+- `isControlMessage` helper correctly identifies text vs binary frames
+- `npm install` completes without lockfile conflicts
+
+**Depends on:** None
+**Estimated:** 2 hours
+
+---
+
+## Task T2: Backend Heartbeat and Message Batching
+
+**Files:**
+- `apps/api/src/services/terminal_manager.py`
+- `apps/api/src/api/terminal.py`
+
+**Description:**
+Rewrite `TerminalManager` read loop to batch small reads into single WebSocket frames (max 16ms buffering). Add heartbeat tracking: server records `last_client_message_at` timestamp, and a background task closes WebSockets idle for 60s. Update `terminal.py` endpoint to accept `ping` control messages and respond with `pong`. Handle binary input frames (not just text JSON).
+
+**Acceptance:**
+- Backend sends batched binary frames; `yes | head -n 10000` produces fewer WebSocket frames than before
+- Server responds to `ping` with matching `pong` within 100ms
+- Server closes idle connections after 60s of no client messages
+- Backend accepts both binary and text WebSocket frames for input
+- `make test` passes (existing backend tests still green)
+
+**Depends on:** None
+**Estimated:** 3 hours
+
+---
+
+## Task T3: Backend Echo Detection and Graceful Exit
+
+**Files:**
+- `apps/api/src/services/terminal_session.py`
+- `apps/api/src/services/terminal_manager.py`
+- `apps/api/src/api/terminal.py`
+
+**Description:**
+Add `termios` PTY inspection to detect ECHO flag state changes. Send `set_echo_state` control messages to client when echo toggles. Detect container process exit (returncode set) and send `session_ended` JSON message before closing WebSocket with code 1000. Distinguish between normal process exit, container stop, and unexpected errors.
+
+**Acceptance:**
+- Running `stty -echo` in terminal triggers `set_echo_state: false` message
+- Running `stty echo` triggers `set_echo_state: true` message
+- Running `exit` in shell sends `session_ended: { reason: "process_exit" }` then closes with code 1000
+- Stopping container sends `session_ended: { reason: "container_stop" }`
+- Unexpected errors still close with code 4000 and error message
+
+**Depends on:** T2
+**Estimated:** 2.5 hours
+
+---
+
+## Task T4: useTerminalConnection Hook
+
+**Files:**
+- `apps/web/src/hooks/use-terminal-connection.ts` (new)
+
+**Description:**
+Implement the core connection hook with: WebSocket lifecycle (open/close/reconnect with exponential backoff), heartbeat (send ping every 15s, timeout after 5s), local echo (write printable ASCII to xterm immediately, deduplicate server echo), resize debouncing (200ms, max 1/500ms), scrollback serialization on disconnect, scrollback restoration on reconnect, connection quality tracking (latency, jitter), manual reconnect bypass.
+
+**Acceptance:**
+- Hook exposes `state`, `sendInput`, `sendResize`, `reconnect`, `onData`, `onControl`
+- Reconnect backoff: 1s, 2s, 4s, 8s, then max 30s
+- Max 10 reconnection attempts before giving up
+- Local echo works for printable ASCII; disabled when echo state is false
+- Pending echo buffer deduplicates server echo correctly
+- Pending echo buffer flushes to terminal if it grows > 100 chars
+- Resize sends at most 1 message per 500ms
+- `Ctrl+Shift+R` triggers immediate reconnect when disconnected
+- Scrollback serialized to `sessionStorage` on disconnect, restored on reconnect with divider
+
+**Depends on:** T1
+**Estimated:** 4 hours
+
+---
+
+## Task T5: TerminalComponent Rewrite
+
+**Files:**
+- `apps/web/src/components/terminal.tsx` (rewrite)
+- `apps/web/src/pages/terminal.tsx` (minor)
+- `apps/web/src/styles.css` (add terminal status styles)
+
+**Description:**
+Rewrite `TerminalComponent` to use `useTerminalConnection`. Integrate xterm.js with the hook's `onData` and `onControl` callbacks. Add status bar with connection quality indicator (green/yellow/red/gray dot, latency tooltip, attempt counter). Add reconnect overlay when disconnected. Wire xterm `onData` to hook's `sendInput`. Use `ResizeObserver` for container-level resize detection. Apply xterm-addon-serialize for scrollback. Update page to pass instance ID and handle close.
+
+**Acceptance:**
+- Terminal renders and connects on mount
+- Status bar shows correct dot color based on connection state
+- Hovering dot shows latency tooltip
+- Reconnect overlay appears when max retries exceeded
+- ResizeObserver triggers fit + resize message (debounced)
+- Theme colors adapt to dark/light mode
+- Close button works
+
+**Depends on:** T4
+**Estimated:** 3 hours
+
+---
+
+## Task T6: Frontend Tests
+
+**Files:**
+- `apps/web/src/utils/terminal-protocol.test.ts` (new)
+- `apps/web/src/hooks/use-terminal-connection.test.ts` (new)
+
+**Description:**
+Write Vitest tests for protocol utilities (encode/decode all message types, base64 round-trip, frame type detection). Write tests for the connection hook using a mock WebSocket server (or manual mock). Test: reconnect backoff timing, heartbeat timeout detection, local echo deduplication, resize throttling, scrollback serialization round-trip.
+
+**Acceptance:**
+- Protocol tests cover all message types and edge cases
+- Hook tests cover connection lifecycle without real WebSocket
+- All tests pass: `cd apps/web && npm test`
+- Coverage for new code > 80%
+
+**Depends on:** T1, T4
+**Estimated:** 3 hours
+
+---
+
+## Task T7: Backend Tests
+
+**Files:**
+- `apps/api/tests/unit/test_terminal_session.py` (new)
+- `apps/api/tests/unit/test_terminal_manager.py` (new)
+
+**Description:**
+Write pytest unit tests for `TerminalSession` (PTY creation, resize, echo detection, process exit detection). Write tests for `TerminalManager` (session creation, batching logic, heartbeat tracking). Use mocks for `os`, `pty`, `termios`, and `asyncio` where appropriate.
+
+**Acceptance:**
+- TerminalSession tests: start, resize, write, read, echo detection, close
+- TerminalManager tests: create session, read loop batching, heartbeat timeout
+- All tests pass: `make test`
+
+**Depends on:** T2, T3
+**Estimated:** 2.5 hours
+
+---
+
+## Task Order and Dependencies
+
+```
+T1 ──► T4 ──► T5 ──► PR-3 (Frontend UI)
+        │
+        └──► T6 (Frontend tests)
+
+T2 ──► T3 ──► PR-1 (Backend foundation)
+        │
+        └──► T7 (Backend tests)
+```
+
+**Parallel work possible:**
+- T1 and T2 can be done in parallel (no dependencies)
+- T3 and T4 can be done in parallel (T3 depends on T2, T4 depends on T1)
+- T5 depends on T4
+- T6 depends on T4
+- T7 depends on T3
+
+## Chained PR Plan
+
+### PR-1: Backend Foundation
+**Scope:** T1 (protocol types only) + T2 + T3 + T7
+**Files touched:** `apps/api/src/services/terminal_manager.py`, `apps/api/src/services/terminal_session.py`, `apps/api/src/api/terminal.py`, new test files, `apps/web/src/types/terminal.ts`, `apps/web/src/utils/terminal-protocol.ts`
+**Estimated diff:** ~590 lines
+**Review focus:** Protocol correctness, heartbeat logic, batching efficiency
+
+### PR-2: Frontend Connection Hook
+**Scope:** T4 + T6
+**Files touched:** `apps/web/src/hooks/use-terminal-connection.ts`, new test files
+**Estimated diff:** ~460 lines
+**Review focus:** State machine correctness, local echo algorithm, reconnection logic
+
+### PR-3: Terminal UI Integration
+**Scope:** T5
+**Files touched:** `apps/web/src/components/terminal.tsx`, `apps/web/src/pages/terminal.tsx`, `apps/web/src/styles.css`
+**Estimated diff:** ~250 lines
+**Review focus:** UX, accessibility, visual polish, integration with hook
+
+**Note:** PR-2 and PR-3 can be developed in parallel if PR-1's protocol types are stable. The hook can be tested against mock protocol types before the backend is merged.

openspec/changes/responsive-terminal/verify.md

@@ -0,0 +1,67 @@
+# Verify: Responsive Web Terminal
+
+## Verification Report
+
+### What Changed
+
+Implemented a resilient, responsive web terminal with auto-reconnect, heartbeat, local echo, and scrollback persistence across 3 chained PRs.
+
+**Backend (PR-1):**
+- `terminal_session.py`: Added termios echo detection, exit reason tracking, `closed` public property
+- `terminal_manager.py`: Added heartbeat tracking (15s ping / 60s idle timeout), message batching (16ms), ping/pong handling, task reference storage
+- `terminal.py`: Added ping/pong routing, echo state checks, `session_ended` notification
+
+**Frontend (PR-2):**
+- `use-terminal-connection.ts`: WebSocket lifecycle, exponential backoff reconnect, heartbeat, local echo deduplication, resize debounce/throttle, scrollback callbacks, `Ctrl+Shift+R` shortcut
+- `use-terminal-connection.test.ts`: 13 tests covering connection lifecycle, reconnect backoff, resize, scrollback
+
+**Frontend UI (PR-3):**
+- `terminal.tsx`: Rewritten with status bar, session-ended overlay, reconnect banner, ResizeObserver, light/dark theme, xterm-addon-serialize
+- `styles.css`: Added overlay, reconnect banner, spinner animation styles
+
+**Documentation:**
+- `docs/features/terminal.md`: User guide with connection states, keyboard shortcuts, troubleshooting
+- `docs/architecture/frontend.md`: Terminal component stack and data flow
+- `docs/architecture/backend.md`: Terminal system architecture and protocol
+
+### Acceptance Criteria Coverage
+
+| AC | Status | Evidence |
+|----|--------|----------|
+| AC-1: Auto-reconnection | ✅ | Implemented in `useTerminalConnection` — 1s→30s backoff, max 10 attempts |
+| AC-2: Heartbeat | ✅ | 15s ping interval, 5s pong timeout, 60s idle close on server |
+| AC-3: Local echo | ✅ | Printable ASCII echoed immediately, server deduplication, echo-state control |
+| AC-4: Resize debounce | ✅ | 200ms debounce + 500ms throttle in `sendResize` |
+| AC-5: Scrollback serialization | ✅ | `SerializeAddon` + `sessionStorage` + restore with divider |
+| AC-6: Connection quality indicator | ✅ | Status bar with color-coded dot, latency tooltip, attempt counter |
+| AC-7: Graceful container exit | ✅ | `session_ended` message + overlay with Reconnect/Go Back |
+| AC-8: Backend message batching | ✅ | 16ms batch window in `_read_loop` |
+| AC-9: Keyboard shortcut | ✅ | `Ctrl+Shift+R` triggers `reconnect()` |
+
+### Quality Gates
+
+| Gate | Result |
+|------|--------|
+| Frontend typecheck | ✅ Clean |
+| Frontend lint | ✅ Clean |
+| Frontend tests | ✅ 48 passed (13 new hook tests) |
+| Backend unit tests | ✅ 101 passed (16 new terminal tests) |
+| Backend ruff | ✅ Clean |
+
+### Commits
+
+- `6c8cfe9` — `feat: responsive web terminal with auto-reconnect, heartbeat, and local echo`
+- `a01e625` — `docs: add responsive terminal documentation`
+
+### Risks and Limitations
+
+- Docker exec PTY is not resumable across reconnects — new shell is spawned. Scrollback serialization makes this transparent.
+- Local echo only works for printable ASCII; control chars and escape sequences round-trip.
+- `termios` echo detection is Unix-only (Linux/macOS). The fallback is echo-enabled.
+- Integration tests require Docker + running containers; not covered in automated test suite.
+
+### Follow-ups
+
+- [ ] Manual end-to-end testing with real containers
+- [ ] Consider adding `xterm-addon-webgl` for GPU rendering on high-latency connections
+- [ ] Consider scrollback persistence across full page reloads (currently `sessionStorage` only)

openspec/specs/frontend-foundation/spec.md

@@ -111,6 +111,24 @@ The system SHALL provide a dashboard overview.
   - Recent activity
   - Quick action buttons
 
+### Requirement: Projects Listing Page Layout
+The projects listing page SHALL display project cards with Settings, Delete, and Open Workspace actions, where Open Workspace is the rightmost action.
+
+#### Scenario: Project card action layout
+- GIVEN the projects listing page
+- WHEN project cards are rendered
+- THEN each card shows actions in order: Settings link, Delete button, Open Workspace button (rightmost)
+
+#### Scenario: Navigate to project settings
+- GIVEN the projects listing page
+- WHEN a user clicks the Settings link
+- THEN they navigate to `/projects/:id/settings`
+
+#### Scenario: No inline edit modal
+- GIVEN the projects listing page
+- WHEN a user views a project card
+- THEN no inline Edit button or modal dialog is available
+
 ## Dependencies
 
 - React 18+

openspec/specs/project-management/spec.md

@@ -31,17 +31,38 @@ The system SHALL list projects owned by the authenticated user, including relate
 - WHEN one user requests their project list
 - THEN only that user's projects are returned
 
-### Requirement: Project Updates
+### Requirement: Project Card Layout
-The system SHALL support updating project details for project owners only.
+The projects listing page SHALL display each project card with a Settings link, Delete button, and Open Workspace button, where the Open Workspace button is positioned on the right.
 
-#### Scenario: Update project
+#### Scenario: View project card actions
-- GIVEN a project owner
+- GIVEN the projects listing page
-- WHEN they update the name or description
+- WHEN a project card is rendered
+- THEN it displays:
+  - A Settings link navigating to `/projects/:id/settings`
+  - A Delete button with confirmation
+  - An Open Workspace button positioned on the right side
+
+#### Scenario: Navigate to project settings
+- GIVEN the projects listing page
+- WHEN a user clicks the Settings link on a project card
+- THEN they are navigated to the project settings page
+
+#### Scenario: No inline edit on project cards
+- GIVEN the projects listing page
+- WHEN a project card is rendered
+- THEN no inline Edit button or modal dialog is present
+
+### Requirement: Project Updates
+The system SHALL support updating project details for project owners via the project settings page.
+
+#### Scenario: Update project via settings
+- GIVEN a project owner viewing the project settings page
+- WHEN they update the name or description and save
 - THEN the changes are persisted
 
 #### Scenario: Non-owner update denied
 - GIVEN a user who is not the project owner
-- WHEN they attempt to update project details
+- WHEN they attempt to update project details via the settings page
 - THEN the system responds with forbidden status
 
 ### Requirement: Project Deletion