feat: add docker dev environment, fix agent execution, and improve thread UI

- Add docker-compose.dev.yml with Dramatiq worker for background task processing
- Add backend Dockerfile.dev for development with hot reload
- Fix agent status propagation to LayoutContext for auto-opening preview panel
- Fix tool call buttons to display on single line with proper flexbox properties
- Add message grouping and streaming content components for better thread rendering
- Update billing components and settings pages
- Various UI/UX improvements across thread, sidebar, and settings components

Author: iamjr15

backend/Dockerfile.dev

@@ -0,0 +1,19 @@
+FROM ghcr.io/astral-sh/uv:python3.11-alpine
+
+ENV ENV_MODE=development
+WORKDIR /app
+
+RUN apk add --no-cache curl git build-base linux-headers rust cargo
+
+COPY pyproject.toml ./
+ENV UV_LINK_MODE=copy
+RUN --mount=type=cache,target=/root/.cache/uv uv lock
+RUN --mount=type=cache,target=/root/.cache/uv uv sync --locked --quiet
+
+COPY . .
+
+ENV PYTHONPATH=/app
+ENV PYTHONUNBUFFERED=1
+EXPOSE 8000
+
+CMD ["uv", "run", "uvicorn", "main:app", "--host", "0.0.0.0", "--port", "8000", "--reload"]

backend/agent/api.py

@@ -169,7 +169,10 @@ async def cleanup():
 
 
 async def get_agent_run_with_access_check(client, agent_run_id: str, user_id: str):
-    agent_run = await client.table('agent_runs').select('*').eq('run_id', agent_run_id).execute()
+    # Only select columns needed for access check and response
+    agent_run = await client.table('agent_runs').select(
+        'run_id, thread_id, status, started_at, completed_at, error, metadata, created_at, updated_at'
+    ).eq('run_id', agent_run_id).execute()
     if not agent_run.data:
         raise HTTPException(status_code=404, detail="Agent run not found")
 
@@ -225,7 +228,9 @@ async def start_agent(
             ).eq('user_id', account_id).eq('is_active', True).eq('is_default_for_dashboard', True).execute()
         ) if project_id else None
         project_task = asyncio.create_task(
-            client.table('projects').select('*').eq('project_id', project_id).execute()
+            client.table('projects').select(
+                'project_id, name, user_id, sandbox, app_type, model_name'
+            ).eq('project_id', project_id).execute()
         ) if project_id else None
 
         # Await token status first (needed for quota check)
@@ -349,7 +354,9 @@ async def start_agent(
 
     try:
         # Use pre-fetched project data from parallel query above
-        project_result = await project_task if project_task else await client.table('projects').select('*').eq('project_id', project_id).execute()
+        project_result = await project_task if project_task else await client.table('projects').select(
+            'project_id, name, user_id, sandbox, app_type, model_name'
+        ).eq('project_id', project_id).execute()
         if not project_result.data:
             raise HTTPException(status_code=404, detail="Project not found")
 

backend/projects_threads_api.py

@@ -58,8 +58,9 @@ async def get_projects(
             return []
 
         # Query projects for this account with pagination and ordering
+        # Only select columns needed for the API response to reduce data transfer
         result = await client.table('projects')\
-            .select('*')\
+            .select('project_id, name, description, user_id, created_at, updated_at, sandbox, is_public, app_type')\
             .eq('user_id', account_id)\
             .order('created_at', desc=True)\
             .range(offset, offset + limit - 1)\
@@ -106,8 +107,10 @@ async def get_project(
     try:
         client = await db.client
 
-        # Fetch the project row
-        result = await client.table('projects').select('*').eq('project_id', project_id).execute()
+        # Fetch the project row - only select needed columns
+        result = await client.table('projects').select(
+            'project_id, name, description, user_id, created_at, updated_at, sandbox, is_public, app_type'
+        ).eq('project_id', project_id).execute()
 
         if not result.data:
             raise HTTPException(status_code=404, detail="Project not found")
@@ -167,8 +170,10 @@ async def get_threads(
             return []
 
         # Build query with server-side filtering for agent builder threads
-        # and pagination for performance
-        query = client.table('threads').select('*').eq('user_id', account_id)
+        # and pagination for performance - only select needed columns
+        query = client.table('threads').select(
+            'thread_id, user_id, project_id, is_public, created_at, updated_at, metadata'
+        ).eq('user_id', account_id)
 
         if project_id:
             query = query.eq('project_id', project_id)

backend/services/billing.py

@@ -150,11 +150,9 @@ async def get_billing_status(
             free_tokens = free_plan['token_quota']
             free_credits = free_plan['display_credits']
 
-            # Get deployment count
-            from deployments.api import _count_deployed_projects_for_account
+            # Get deployment count with caching
             from utils.constants import get_plan_deployment_limit
-            async with db.get_async_client() as client:
-                deployments_used = await _count_deployed_projects_for_account(client, account_id)
+            deployments_used = await get_deployment_count_cached(account_id)
             deployments_total = get_plan_deployment_limit('free')
 
             return SubscriptionStatusResponse(
@@ -177,12 +175,9 @@ async def get_billing_status(
         if not plan_config:
             raise HTTPException(status_code=500, detail="Invalid plan configuration")
 
-        # Get deployment count
-        from deployments.api import _count_deployed_projects_for_account
+        # Get deployment count with caching
         from utils.constants import get_plan_deployment_limit
-        db = DBConnection()
-        async with db.get_async_client() as client:
-            deployments_used = await _count_deployed_projects_for_account(client, subscription['account_id'])
+        deployments_used = await get_deployment_count_cached(subscription['account_id'])
         deployments_total = get_plan_deployment_limit(subscription['plan'])
 
         return SubscriptionStatusResponse(
@@ -462,6 +457,44 @@ async def get_quota_status(
 # Billing status cache TTL in seconds (30 seconds for quick updates while reducing DB load)
 BILLING_STATUS_CACHE_TTL = 30
 
+# Deployment count cache TTL (60 seconds - deployments change less frequently)
+DEPLOYMENT_COUNT_CACHE_TTL = 60
+
+
+async def get_deployment_count_cached(account_id: str) -> int:
+    """Get deployment count with Redis caching to avoid redundant queries.
+
+    Caches the result for 60 seconds since deployments change infrequently.
+    """
+    import json
+    from services import redis as redis_service
+    from deployments.api import _count_deployed_projects_for_account
+
+    cache_key = f"deployment_count:{account_id}"
+
+    # Try cache first
+    try:
+        cached_count = await redis_service.get_value(cache_key)
+        if cached_count is not None:
+            logger.debug(f"Cache HIT for deployment count: {account_id}")
+            return int(cached_count)
+    except Exception as e:
+        logger.debug(f"Cache miss for deployment count {account_id}: {e}")
+
+    # Cache miss - query database
+    db = DBConnection()
+    async with db.get_async_client() as client:
+        count = await _count_deployed_projects_for_account(client, account_id)
+
+    # Cache the result
+    try:
+        await redis_service.set_value(cache_key, str(count), ttl=DEPLOYMENT_COUNT_CACHE_TTL)
+        logger.debug(f"Cached deployment count for {account_id}: {count}")
+    except Exception as e:
+        logger.warning(f"Failed to cache deployment count: {e}")
+
+    return count
+
 async def can_use_model(client: Client, user_id: str, model_name: str):
     """Check if user can use a specific model based on their subscription.
 

docker-compose.dev.yml

@@ -0,0 +1,97 @@
+services:
+  # Backend API with hot reload
+  backend:
+    build:
+      context: ./backend
+      dockerfile: Dockerfile.dev
+    ports:
+      - "8000:8000"
+    env_file:
+      - ./backend/.env
+    volumes:
+      - ./backend:/app
+      - /app/.venv
+    environment:
+      - ENV_MODE=development
+      - REDIS_URL=redis://redis:6379
+      - PYTHONUNBUFFERED=1
+    depends_on:
+      redis:
+        condition: service_healthy
+    networks:
+      - dev-network
+    dns:
+      - 8.8.8.8
+      - 8.8.4.4
+
+  # Dramatiq worker for background tasks
+  worker:
+    build:
+      context: ./backend
+      dockerfile: Dockerfile.dev
+    command: uv run dramatiq --skip-logging --processes 1 --threads 2 run_agent_background
+    env_file:
+      - ./backend/.env
+    volumes:
+      - ./backend:/app
+      - /app/.venv
+    environment:
+      - ENV_MODE=development
+      - REDIS_URL=redis://redis:6379
+      - PYTHONUNBUFFERED=1
+    depends_on:
+      redis:
+        condition: service_healthy
+    networks:
+      - dev-network
+    dns:
+      - 8.8.8.8
+      - 8.8.4.4
+    restart: unless-stopped
+
+  # Frontend with hot reload
+  frontend:
+    build:
+      context: ./frontend
+      dockerfile: Dockerfile
+      target: development
+    ports:
+      - "3000:3000"
+    env_file:
+      - ./frontend/.env
+    volumes:
+      - ./frontend:/app
+      - /app/node_modules
+      - /app/.next
+    environment:
+      - NODE_ENV=development
+      - WATCHPACK_POLLING=true
+    networks:
+      - dev-network
+    dns:
+      - 8.8.8.8
+      - 8.8.4.4
+
+  # Redis
+  redis:
+    image: redis:8-alpine
+    ports:
+      - "127.0.0.1:6380:6379"
+    volumes:
+      - redis_data:/data
+    networks:
+      - dev-network
+    command: redis-server --appendonly yes --bind 0.0.0.0 --protected-mode no
+    healthcheck:
+      test: ["CMD", "redis-cli", "ping"]
+      interval: 10s
+      timeout: 5s
+      retries: 5
+      start_period: 5s
+
+networks:
+  dev-network:
+    driver: bridge
+
+volumes:
+  redis_data:

frontend/eslint.config.mjs

@@ -13,13 +13,14 @@ const eslintConfig = [
   ...compat.extends('next/core-web-vitals', 'next/typescript'),
   {
     rules: {
-      '@typescript-eslint/no-unused-vars': 'off',
-      '@typescript-eslint/no-explicit-any': 'off',
+      '@typescript-eslint/no-unused-vars': 'error',
+      '@typescript-eslint/no-explicit-any': 'error',
       'react/no-unescaped-entities': 'off',
-      'react-hooks/exhaustive-deps': 'warn',
-      '@next/next/no-img-element': 'warn',
+      'react-hooks/exhaustive-deps': 'error',
+      '@next/next/no-img-element': 'error',
       '@typescript-eslint/no-empty-object-type': 'off',
-      'prefer-const': 'warn',
+      'prefer-const': 'error',
+      'no-console': 'error',
     },
   },
 ];