| 1008 | } |
| 1009 | |
| 1010 | func CollectTasks(ctx context.Context, db database.Store) ([]Task, error) { |
| 1011 | dbTasks, err := db.ListTasks(ctx, database.ListTasksParams{ |
| 1012 | OwnerID: uuid.Nil, |
| 1013 | OrganizationID: uuid.Nil, |
| 1014 | Status: "", |
| 1015 | }) |
| 1016 | if err != nil { |
| 1017 | return nil, xerrors.Errorf("list tasks: %w", err) |
| 1018 | } |
| 1019 | if len(dbTasks) == 0 { |
| 1020 | return []Task{}, nil |
| 1021 | } |
| 1022 | |
| 1023 | tasks := make([]Task, 0, len(dbTasks)) |
| 1024 | for _, dbTask := range dbTasks { |
| 1025 | tasks = append(tasks, ConvertTask(dbTask)) |
| 1026 | } |
| 1027 | return tasks, nil |
| 1028 | } |
| 1029 | |
| 1030 | // buildTaskEvent constructs a TaskEvent from the combined query row. |
| 1031 | func buildTaskEvent( |