mirror of
https://github.com/leonvanzyl/autocoder.git
synced 2026-02-02 23:33:35 +00:00
Add `default_concurrency` column to the projects table in the registry
database, allowing each project to remember its preferred concurrency
setting (1-5 agents). The value persists across page refreshes and
app restarts.
Backend changes:
- Add `default_concurrency` column to Project model in registry.py
- Add database migration for existing databases (ALTER TABLE)
- Add get/set_project_concurrency() CRUD functions
- Add ProjectSettingsUpdate schema with validation
- Add PATCH /{name}/settings endpoint in projects router
- Include default_concurrency in ProjectSummary/ProjectDetail responses
Frontend changes:
- Add default_concurrency to ProjectSummary TypeScript interface
- Add ProjectSettingsUpdate type and updateProjectSettings API function
- Add useUpdateProjectSettings React Query mutation hook
- Update AgentControl to accept defaultConcurrency prop
- Sync local state when project changes via useEffect
- Debounce slider changes (500ms) before saving to backend
- Pass defaultConcurrency from selectedProjectData in App.tsx
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
184 lines
5.8 KiB
TypeScript
184 lines
5.8 KiB
TypeScript
import { useState, useEffect, useRef, useCallback } from 'react'
|
|
import { Play, Square, Loader2, GitBranch, Clock } from 'lucide-react'
|
|
import {
|
|
useStartAgent,
|
|
useStopAgent,
|
|
useSettings,
|
|
useUpdateProjectSettings,
|
|
} from '../hooks/useProjects'
|
|
import { useNextScheduledRun } from '../hooks/useSchedules'
|
|
import { formatNextRun, formatEndTime } from '../lib/timeUtils'
|
|
import { ScheduleModal } from './ScheduleModal'
|
|
import type { AgentStatus } from '../lib/types'
|
|
import { Button } from '@/components/ui/button'
|
|
import { Badge } from '@/components/ui/badge'
|
|
|
|
interface AgentControlProps {
|
|
projectName: string
|
|
status: AgentStatus
|
|
defaultConcurrency?: number
|
|
}
|
|
|
|
export function AgentControl({ projectName, status, defaultConcurrency = 3 }: AgentControlProps) {
|
|
const { data: settings } = useSettings()
|
|
const yoloMode = settings?.yolo_mode ?? false
|
|
|
|
// Concurrency: 1 = single agent, 2-5 = parallel
|
|
const [concurrency, setConcurrency] = useState(defaultConcurrency)
|
|
|
|
// Sync concurrency when project changes or defaultConcurrency updates
|
|
useEffect(() => {
|
|
setConcurrency(defaultConcurrency)
|
|
}, [defaultConcurrency])
|
|
|
|
// Debounced save for concurrency changes
|
|
const updateProjectSettings = useUpdateProjectSettings(projectName)
|
|
const saveTimeoutRef = useRef<ReturnType<typeof setTimeout> | null>(null)
|
|
|
|
const handleConcurrencyChange = useCallback((newConcurrency: number) => {
|
|
setConcurrency(newConcurrency)
|
|
|
|
// Clear previous timeout
|
|
if (saveTimeoutRef.current) {
|
|
clearTimeout(saveTimeoutRef.current)
|
|
}
|
|
|
|
// Debounce save (500ms)
|
|
saveTimeoutRef.current = setTimeout(() => {
|
|
updateProjectSettings.mutate({ default_concurrency: newConcurrency })
|
|
}, 500)
|
|
}, [updateProjectSettings])
|
|
|
|
// Cleanup timeout on unmount
|
|
useEffect(() => {
|
|
return () => {
|
|
if (saveTimeoutRef.current) {
|
|
clearTimeout(saveTimeoutRef.current)
|
|
}
|
|
}
|
|
}, [])
|
|
|
|
const startAgent = useStartAgent(projectName)
|
|
const stopAgent = useStopAgent(projectName)
|
|
const { data: nextRun } = useNextScheduledRun(projectName)
|
|
|
|
const [showScheduleModal, setShowScheduleModal] = useState(false)
|
|
|
|
const isLoading = startAgent.isPending || stopAgent.isPending
|
|
const isRunning = status === 'running' || status === 'paused'
|
|
const isLoadingStatus = status === 'loading'
|
|
const isParallel = concurrency > 1
|
|
|
|
const handleStart = () => startAgent.mutate({
|
|
yoloMode,
|
|
parallelMode: isParallel,
|
|
maxConcurrency: concurrency,
|
|
testingAgentRatio: settings?.testing_agent_ratio,
|
|
})
|
|
const handleStop = () => stopAgent.mutate()
|
|
|
|
const isStopped = status === 'stopped' || status === 'crashed'
|
|
|
|
return (
|
|
<>
|
|
<div className="flex items-center gap-4">
|
|
{/* Concurrency slider - visible when stopped */}
|
|
{isStopped && (
|
|
<div className="flex items-center gap-2">
|
|
<GitBranch size={16} className={isParallel ? 'text-primary' : 'text-muted-foreground'} />
|
|
<input
|
|
type="range"
|
|
min={1}
|
|
max={5}
|
|
value={concurrency}
|
|
onChange={(e) => handleConcurrencyChange(Number(e.target.value))}
|
|
disabled={isLoading}
|
|
className="w-16 h-2 accent-primary cursor-pointer"
|
|
title={`${concurrency} concurrent agent${concurrency > 1 ? 's' : ''}`}
|
|
aria-label="Set number of concurrent agents"
|
|
/>
|
|
<span className="text-xs font-semibold min-w-[1.5rem] text-center">
|
|
{concurrency}x
|
|
</span>
|
|
</div>
|
|
)}
|
|
|
|
{/* Show concurrency indicator when running with multiple agents */}
|
|
{isRunning && isParallel && (
|
|
<Badge variant="secondary" className="gap-1">
|
|
<GitBranch size={14} />
|
|
{concurrency}x
|
|
</Badge>
|
|
)}
|
|
|
|
{/* Schedule status display */}
|
|
{nextRun?.is_currently_running && nextRun.next_end && (
|
|
<Badge variant="default" className="gap-1">
|
|
<Clock size={14} />
|
|
Running until {formatEndTime(nextRun.next_end)}
|
|
</Badge>
|
|
)}
|
|
|
|
{!nextRun?.is_currently_running && nextRun?.next_start && (
|
|
<Badge variant="secondary" className="gap-1">
|
|
<Clock size={14} />
|
|
Next: {formatNextRun(nextRun.next_start)}
|
|
</Badge>
|
|
)}
|
|
|
|
{/* Start/Stop button */}
|
|
{isLoadingStatus ? (
|
|
<Button disabled variant="outline" size="sm">
|
|
<Loader2 size={18} className="animate-spin" />
|
|
</Button>
|
|
) : isStopped ? (
|
|
<Button
|
|
onClick={handleStart}
|
|
disabled={isLoading}
|
|
variant={yoloMode ? 'secondary' : 'default'}
|
|
size="sm"
|
|
title={yoloMode ? 'Start Agent (YOLO Mode)' : 'Start Agent'}
|
|
>
|
|
{isLoading ? (
|
|
<Loader2 size={18} className="animate-spin" />
|
|
) : (
|
|
<Play size={18} />
|
|
)}
|
|
</Button>
|
|
) : (
|
|
<Button
|
|
onClick={handleStop}
|
|
disabled={isLoading}
|
|
variant="destructive"
|
|
size="sm"
|
|
title={yoloMode ? 'Stop Agent (YOLO Mode)' : 'Stop Agent'}
|
|
>
|
|
{isLoading ? (
|
|
<Loader2 size={18} className="animate-spin" />
|
|
) : (
|
|
<Square size={18} />
|
|
)}
|
|
</Button>
|
|
)}
|
|
|
|
{/* Clock button to open schedule modal */}
|
|
<Button
|
|
variant="outline"
|
|
size="sm"
|
|
onClick={() => setShowScheduleModal(true)}
|
|
title="Manage schedules"
|
|
>
|
|
<Clock size={18} />
|
|
</Button>
|
|
</div>
|
|
|
|
{/* Schedule Modal */}
|
|
<ScheduleModal
|
|
projectName={projectName}
|
|
isOpen={showScheduleModal}
|
|
onClose={() => setShowScheduleModal(false)}
|
|
/>
|
|
</>
|
|
)
|
|
}
|