|
1 | 1 | import { Component, OnInit } from '@angular/core'; |
2 | 2 | import { TaskService } from '../../../../../tasks/services/task/task.service'; |
3 | | -import { map, Observable, switchMap, forkJoin, of, EMPTY } from 'rxjs'; |
| 3 | +import { Observable, forkJoin, EMPTY, map } from 'rxjs'; |
4 | 4 | import { MemberService } from '../../../../services/member/member.service'; |
5 | 5 | import { ProjectMember } from '../../../../interfaces/project-member.interface'; |
6 | 6 | import { Status } from '../../../../../tasks/interfaces/status.interface'; |
7 | 7 | import { Task } from '@tasks/interfaces/task.interface'; |
8 | 8 | import { ProjectService } from '../../../../services/project/project.service'; |
9 | 9 | import { StatusService } from '../../../../../tasks/services/status/status.service'; |
10 | 10 | import { Project } from '../../../../interfaces/project.interface'; |
11 | | -import { TaskFilters } from '../../../../../tasks/filters/task.filters'; |
12 | 11 | import { UserService } from '../../../../../auth/services/user/user.service'; |
13 | 12 | import { Loader } from '../../../../../_main/classes/loader/loader.class'; |
14 | 13 | import { withLoader } from '../../../../../_main/operators/loader.operator'; |
@@ -45,24 +44,27 @@ export class WidgetTasksComponent implements OnInit { |
45 | 44 | } |
46 | 45 |
|
47 | 46 | private loadProjects() { |
48 | | - return this.projectService.list().pipe( |
49 | | - switchMap((projects) => { |
50 | | - return forkJoin(projects.map((project) => this.loadProject(project))); |
| 47 | + return forkJoin({ |
| 48 | + projects: this.projectService.list(), |
| 49 | + tasks: this.taskService.listTasksAssignedToMe(), |
| 50 | + }).pipe( |
| 51 | + map(({ projects, tasks }) => { |
| 52 | + return projects.map((project) => |
| 53 | + this.loadProject( |
| 54 | + project, |
| 55 | + tasks.filter((task) => task.projectId === project.id), |
| 56 | + ), |
| 57 | + ); |
51 | 58 | }), |
52 | | - map((projects) => projects.filter((project) => project.tasks.length > 0)), |
53 | 59 | ); |
54 | 60 | } |
55 | 61 |
|
56 | | - private loadProject(project: Project) { |
57 | | - return this.userService.getMyself().pipe( |
58 | | - switchMap((user) => { |
59 | | - return forkJoin({ |
60 | | - project: of(project), |
61 | | - members: this.memberService.map(project.id), |
62 | | - statuses: this.statusService.list(project.id), |
63 | | - tasks: this.taskService.list(project.id, TaskFilters.ASSIGNEE_ID(user.id)), |
64 | | - }); |
65 | | - }), |
66 | | - ); |
| 62 | + private loadProject(project: Project, tasks: Task[]) { |
| 63 | + return { |
| 64 | + project: project, |
| 65 | + members: new Map(), |
| 66 | + statuses: project.statuses, |
| 67 | + tasks: tasks, |
| 68 | + }; |
67 | 69 | } |
68 | 70 | } |
0 commit comments