File size: 1,791 Bytes
1f21206 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 | import { create } from 'zustand'
import { tasksApi } from '../api/tasks'
import type { CronTask, CreateTaskInput, TaskRun } from '../types/task'
type TaskStore = {
tasks: CronTask[]
recentRuns: TaskRun[]
isLoading: boolean
error: string | null
fetchTasks: () => Promise<void>
createTask: (input: CreateTaskInput) => Promise<void>
updateTask: (id: string, updates: Partial<CronTask>) => Promise<void>
deleteTask: (id: string) => Promise<void>
runTask: (taskId: string) => Promise<void>
fetchRecentRuns: () => Promise<void>
fetchTaskRuns: (taskId: string) => Promise<TaskRun[]>
}
export const useTaskStore = create<TaskStore>((set) => ({
tasks: [],
recentRuns: [],
isLoading: false,
error: null,
fetchTasks: async () => {
set({ isLoading: true, error: null })
try {
const { tasks } = await tasksApi.list()
set({ tasks, isLoading: false })
} catch (err) {
set({ error: (err as Error).message, isLoading: false })
}
},
createTask: async (input) => {
const { task } = await tasksApi.create(input)
set((s) => ({ tasks: [...s.tasks, task] }))
},
updateTask: async (id, updates) => {
const { task } = await tasksApi.update(id, updates)
set((s) => ({ tasks: s.tasks.map((t) => (t.id === id ? task : t)) }))
},
deleteTask: async (id) => {
await tasksApi.delete(id)
set((s) => ({ tasks: s.tasks.filter((t) => t.id !== id) }))
},
runTask: async (taskId) => {
await tasksApi.runTask(taskId)
},
fetchRecentRuns: async () => {
try {
const { runs } = await tasksApi.getRecentRuns()
set({ recentRuns: runs })
} catch {
// ignore
}
},
fetchTaskRuns: async (taskId) => {
const { runs } = await tasksApi.getTaskRuns(taskId)
return runs
},
}))
|