Method createTask

pkg/tools/builtin/tasks/tasks.go:278–327

Tool handlers

(_ context.Context, params CreateTaskArgs)

// Tool handlers

func (t *ToolSet) createTask(_ context.Context, params CreateTaskArgs) (*tools.ToolCallResult, error) {
	desc, err := t.resolveDescription(params.Description, params.Path)
	if err != nil {
		return tools.ResultError(err.Error()), nil
	}

	priority := TaskPriority(params.Priority)
	if params.Priority == "" {
		priority = PriorityMedium
	} else if !validPriority(params.Priority) {
		return tools.ResultError("invalid priority: " + params.Priority), nil
	}

	t.mu.Lock()
	defer t.mu.Unlock()

	store := t.load()
	id := uuid.New().String()

	deps := params.Dependencies
	if deps == nil {
		deps = []string{}
	}
	for _, depID := range deps {
		if _, ok := store.Tasks[depID]; !ok {
			return tools.ResultError("dependency task not found: " + depID), nil
		}
	}
	if hasCycle(store.Tasks, id, deps) {
		return tools.ResultError("adding these dependencies would create a cycle"), nil
	}

	task := Task{
		ID:           id,
		Title:        params.Title,
		Description:  desc,
		Priority:     priority,
		Status:       StatusPending,
		Dependencies: deps,
		CreatedAt:    now(),
		UpdatedAt:    now(),
	}

	store.Tasks[id] = task
	if err := t.save(store); err != nil {
		return tools.ResultError(err.Error()), nil
	}

	return taskResult(task), nil
}

func (t *ToolSet) getTask(_ context.Context, params GetTaskArgs) (*tools.ToolCallResult, error) {
	t.mu.Lock()