feat: Add retry functionality for history tasks.

Author: ChanningHe

app.go

@@ -309,6 +309,7 @@ func (a *App) startHTTPServer() error {
 		apiGroup.PUT("/tasks/:id/pause", tasksHandler.PauseTask)
 		apiGroup.PUT("/tasks/:id/resume", tasksHandler.ResumeTask)
 		apiGroup.PUT("/tasks/:id/cancel", tasksHandler.CancelTask)
+		apiGroup.POST("/tasks/:id/retry", tasksHandler.RetryTask)
 		apiGroup.DELETE("/tasks/:id", tasksHandler.DeleteTask)
 
 		// Presets

cmd/server/main.go

@@ -90,6 +90,7 @@ func main() {
 		apiGroup.PUT("/tasks/:id/pause", tasksHandler.PauseTask)
 		apiGroup.PUT("/tasks/:id/resume", tasksHandler.ResumeTask)
 		apiGroup.PUT("/tasks/:id/cancel", tasksHandler.CancelTask)
+		apiGroup.POST("/tasks/:id/retry", tasksHandler.RetryTask)
 		apiGroup.DELETE("/tasks/:id", tasksHandler.DeleteTask)
 
 		// Presets

frontend/src/i18n/translations.ts

@@ -222,6 +222,12 @@ export const translations = {
       sourceFileSize: 'Source Size',
       outputFileSize: 'Output Size',
       compressionRatio: 'Compression Ratio',
+      retry: 'Retry',
+      retryTask: 'Retry Task',
+      retrySuccess: 'Task retry submitted successfully',
+      retryFailed: 'Failed to retry task',
+      retrySelected: 'Retry Selected',
+      retryMultipleSuccess: 'Selected tasks retry submitted successfully',
     },
     // Settings page
     settings: {
@@ -541,6 +547,12 @@ export const translations = {
       sourceFileSize: '源文件大小',
       outputFileSize: '输出文件大小',
       compressionRatio: '压缩比',
+      retry: '重试',
+      retryTask: '重试任务',
+      retrySuccess: '任务重试已提交',
+      retryFailed: '重试任务失败',
+      retrySelected: '重试选中',
+      retryMultipleSuccess: '选中任务重试已提交',
     },
     // 设置页面
     settings: {

frontend/src/lib/api.ts

@@ -66,6 +66,14 @@ class APIClient {
     if (!response.ok) throw new Error('Failed to cancel task')
   }
 
+  async retryTask(id: string): Promise<Task> {
+    const response = await fetch(`${getAPIBaseURL()}/tasks/${id}/retry`, {
+      method: 'POST',
+    })
+    if (!response.ok) throw new Error('Failed to retry task')
+    return response.json()
+  }
+
   // Presets
   async getPresets(): Promise<Preset[]> {
     const response = await fetch(`${getAPIBaseURL()}/presets`)

frontend/src/lib/mockApi.ts

@@ -139,6 +139,28 @@ class MockAPIClient {
         )
     }
 
+    async retryTask(id: string): Promise<Task> {
+        await delay(200)
+        const originalTask = tasks.find(t => t.id === id)
+        if (!originalTask) throw new Error('Task not found')
+
+        const newTask: Task = {
+            id: `task-mock-${++taskIdCounter}`,
+            sourceFile: originalTask.sourceFile,
+            outputFile: '',
+            status: 'pending' as const,
+            progress: 0,
+            speed: 0,
+            eta: 0,
+            createdAt: new Date().toISOString(),
+            sourceFileSize: originalTask.sourceFileSize,
+            config: originalTask.config,
+        }
+
+        tasks = [...tasks, newTask]
+        return newTask
+    }
+
     // Presets
     async getPresets(): Promise<Preset[]> {
         await delay()

frontend/src/pages/HistoryPage.tsx

@@ -1,6 +1,6 @@
 import { useState } from 'react'
 import { useQuery, useMutation, useQueryClient } from '@tanstack/react-query'
-import { Trash2, CheckCircle2, XCircle, CheckSquare, Square, Terminal } from 'lucide-react'
+import { Trash2, CheckCircle2, XCircle, CheckSquare, Square, Terminal, RotateCcw } from 'lucide-react'
 import { api } from '@/lib/api'
 import { useApp } from '@/contexts/AppContext'
 import { Button } from '@/components/ui/button'
@@ -76,6 +76,31 @@ export default function HistoryPage() {
     },
   })
 
+  const retryMutation = useMutation({
+    mutationFn: (id: string) => api.retryTask(id),
+    onSuccess: () => {
+      queryClient.invalidateQueries({ queryKey: ['tasks'] })
+      showToast(t.history.retrySuccess, 'success')
+    },
+    onError: () => {
+      showToast(t.history.retryFailed, 'error')
+    },
+  })
+
+  const retryMultipleMutation = useMutation({
+    mutationFn: async (ids: string[]) => {
+      await Promise.all(ids.map(id => api.retryTask(id)))
+    },
+    onSuccess: () => {
+      queryClient.invalidateQueries({ queryKey: ['tasks'] })
+      showToast(t.history.retryMultipleSuccess, 'success')
+      setSelectedTasks([])
+    },
+    onError: () => {
+      showToast(t.history.retryFailed, 'error')
+    },
+  })
+
   const handleDelete = (id: string) => {
     setTaskToDelete(id)
     setDeleteConfirmOpen(true)
@@ -152,14 +177,25 @@ export default function HistoryPage() {
         </div>
         <div className="flex gap-2">
           {selectedTasks.length > 0 && (
-            <Button
-              variant="destructive"
-              size="sm"
-              onClick={handleDeleteSelected}
-            >
-              <Trash2 className="h-4 w-4 mr-1" />
-              {t.history.deleteSelected} ({selectedTasks.length})
-            </Button>
+            <>
+              <Button
+                variant="default"
+                size="sm"
+                onClick={() => retryMultipleMutation.mutate(selectedTasks)}
+                disabled={retryMultipleMutation.isPending}
+              >
+                <RotateCcw className={cn("h-4 w-4 mr-1", retryMultipleMutation.isPending && "animate-spin")} />
+                {t.history.retrySelected} ({selectedTasks.length})
+              </Button>
+              <Button
+                variant="destructive"
+                size="sm"
+                onClick={handleDeleteSelected}
+              >
+                <Trash2 className="h-4 w-4 mr-1" />
+                {t.history.deleteSelected} ({selectedTasks.length})
+              </Button>
+            </>
           )}
           {completedTasks.length > 0 && (
             <Button
@@ -474,6 +510,16 @@ export default function HistoryPage() {
 
                 {/* Actions */}
                 <div className="pt-3 border-t space-y-2">
+                  <Button
+                    variant="default"
+                    size="sm"
+                    onClick={() => retryMutation.mutate(selectedTask.id)}
+                    disabled={retryMutation.isPending}
+                    className="w-full"
+                  >
+                    <RotateCcw className={cn("h-4 w-4 mr-1", retryMutation.isPending && "animate-spin")} />
+                    {t.history.retryTask}
+                  </Button>
                   <Button
                     variant="outline"
                     size="sm"

internal/api/tasks.go

@@ -219,3 +219,48 @@ func (h *TasksHandler) CancelTask(c *gin.Context) {
 
 	c.JSON(http.StatusOK, gin.H{"message": "task cancelled"})
 }
+
+// RetryTask handles POST /api/tasks/:id/retry
+// Creates a new task based on an existing failed, cancelled, or completed task
+func (h *TasksHandler) RetryTask(c *gin.Context) {
+	id := c.Param("id")
+
+	// Get original task
+	originalTask, err := h.db.GetTask(id)
+	if err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "task not found"})
+		return
+	}
+
+	// Can only retry completed, failed, or cancelled tasks
+	if originalTask.Status != model.TaskStatusCompleted &&
+		originalTask.Status != model.TaskStatusFailed &&
+		originalTask.Status != model.TaskStatusCancelled {
+		c.JSON(http.StatusBadRequest, gin.H{"error": "can only retry completed, failed, or cancelled tasks"})
+		return
+	}
+
+	// Create a new task with the same source file and config
+	newTask := &model.Task{
+		ID:         uuid.New().String(),
+		SourceFile: originalTask.SourceFile,
+		OutputFile: "", // Will be set by worker
+		Status:     model.TaskStatusPending,
+		Progress:   0,
+		Speed:      0,
+		ETA:        0,
+		CreatedAt:  time.Now(),
+		Preset:     originalTask.Preset,
+		Config:     originalTask.Config,
+	}
+
+	if err := h.db.CreateTask(newTask); err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": "failed to create task"})
+		return
+	}
+
+	// Submit task to worker pool
+	h.pool.SubmitTask(newTask.ID)
+
+	c.JSON(http.StatusOK, newTask)
+}