Method StartTask

internal/services/task_service.go:49–77

StartTask attempts to start a new task. It returns an error if a task is already running.

(taskType, groupName string, total int)

// StartTask attempts to start a new task. It returns an error if a task is already running.
func (s *TaskService) StartTask(taskType, groupName string, total int) (*TaskStatus, error) {
	currentStatus, err := s.GetTaskStatus()
	if err != nil {
		return nil, fmt.Errorf("failed to check current task status before starting a new one: %w", err)
	}

	if currentStatus.IsRunning {
		return nil, errors.New("a task is already running, please wait")
	}

	status := &TaskStatus{
		TaskType:  taskType,
		IsRunning: true,
		GroupName: groupName,
		Total:     total,
		Processed: 0,
		StartedAt: time.Now(),
	}
	statusBytes, err := json.Marshal(status)
	if err != nil {
		return nil, fmt.Errorf("failed to serialize new task status: %w", err)
	}

	if err := s.store.Set(globalTaskKey, statusBytes, ResultTTL); err != nil {
		return nil, fmt.Errorf("failed to set initial task status: %w", err)
	}

	return status, nil
}

// GetTaskStatus returns the current status of the task.
func (s *TaskService) GetTaskStatus() (*TaskStatus, error) {