feat: refresh task selector based on real-time task updates

A new socket signal is emitted whenever a task is updated, allowing the UI to detect
changes immediately. This enables the task selector to refresh its list as soon as
a task is modified, ensuring that employees see updated assignments without having
to reload the page.

This behavior is especially important when an employee is added to or removed from
a task, as the selector now reflects these changes instantly. The logic to exclude
tasks with a "done" status remains unchanged.

Author: vestefano

packages/core/src/lib/tasks/task.service.ts

@@ -173,17 +173,7 @@ export class TaskService extends TenantAwareCrudService<Task> {
 			if (updatedTask.status === TaskStatusEnum.DONE && task.status !== TaskStatusEnum.DONE) {
 				try {
 					this.logger.debug(`Task ${updatedTask.id} changed status to DONE`);
-					const taskMembers = updatedTask.members?.length ? updatedTask.members : task.members;
-
-					if (taskMembers?.length) {
-						await Promise.all(
-							taskMembers.map(async (member) => {
-								// Send a real-time event to the specified user via socket.
-								// No error is thrown if the user is not currently connected.
-								this._socketService.sendTimerChanged(member?.id);
-							})
-						);
-					}
+					this._socketService.sendTimerChangedMany([...existingMemberIdSet])
 				} catch (error) {
 					this.logger.error(`Error emitting DONE status event for task ${updatedTask.id}: ${error}`);
 				}
@@ -250,6 +240,18 @@ export class TaskService extends TenantAwareCrudService<Task> {
 				}
 			}
 
+			try {
+				[
+					...existingMemberIdSet,
+					...newMembers.map((member) => member.id)
+				].forEach((memberId) => {
+					this._socketService.emitToClient(memberId, 'tasks:changed', null);
+				});
+
+			} catch (error) {
+				this.logger.error(`Error while sending tasks changed event: ${error}`);
+			}
+
 			// Generate the activity log
 			this._activityLogService.logActivity<Task>(
 				BaseEntityEnum.Task,

packages/ui-core/core/src/lib/services/tasks/index.ts

@@ -4,4 +4,5 @@ export * from './sizes.service';
 export * from './statuses.service';
 export * from './tasks-store.service';
 export * from './tasks.service';
-export * from './team-tasks-store.service';
+export * from './team-tasks-store.service';
+export * from './task-socket.service';

packages/ui-core/core/src/lib/services/tasks/task-socket.service.ts

@@ -0,0 +1,37 @@
+import { Injectable } from "@angular/core";
+import { UntilDestroy, untilDestroyed } from "@ngneat/until-destroy";
+import { SocketConnectionService } from "../socket-connection";
+import { BehaviorSubject, filter, fromEvent, switchMap, tap } from "rxjs";
+
+@UntilDestroy()
+@Injectable({
+    providedIn: 'root'
+})
+export class TaskSocketService {
+    public tasksChanged$ = new BehaviorSubject<boolean>(false);
+
+    constructor(private readonly socketConnection: SocketConnectionService) {
+        this.listenToTasksChanges();
+    }
+
+    /**
+     * Listen to tasks changes from the socket connection
+     */
+    private listenToTasksChanges() {
+        console.log(this.socketConnection?.socket);
+        this.socketConnection.connected$
+            .pipe(
+                filter((connected) => connected === true),
+                switchMap(() =>
+                   fromEvent(this.socketConnection.socket, 'tasks:changed').pipe(
+                    tap(() => {
+                        console.log('[Socket] tasks:changed event');
+                        this.tasksChanged$.next(true);
+                    })
+                   )
+                ),
+                untilDestroyed(this)
+            )
+            .subscribe();
+    }
+}

packages/ui-core/shared/src/lib/tasks/task-select/task/task.component.ts

@@ -6,6 +6,7 @@ import { UntilDestroy, untilDestroyed } from '@ngneat/until-destroy';
 import { IOrganization, ITask, PermissionsEnum, TaskStatusEnum } from '@gauzy/contracts';
 import { distinctUntilChange } from '@gauzy/ui-core/common';
 import { AuthService, Store, TasksService, ToastrService } from '@gauzy/ui-core/core';
+import { TaskSocketService } from '@gauzy/ui-core/core';
 
 @UntilDestroy({ checkProperties: true })
 @Component({
@@ -136,7 +137,8 @@ export class TaskSelectorComponent implements OnInit, ControlValueAccessor {
 		private readonly tasksService: TasksService,
 		private readonly toastrService: ToastrService,
 		private readonly store: Store,
-		private readonly authService: AuthService
+		private readonly authService: AuthService,
+		private readonly taskSocketService: TaskSocketService
 	) {}
 
 	onChange: any = () => {};
@@ -154,6 +156,13 @@ export class TaskSelectorComponent implements OnInit, ControlValueAccessor {
 				untilDestroyed(this)
 			)
 			.subscribe();
+		this.taskSocketService.tasksChanged$
+			.pipe(
+				filter((changed) => changed === true && !!this.organization),
+				tap(() => this.subject$.next(true)),
+				untilDestroyed(this)
+			)
+			.subscribe();
 		this.store.selectedOrganization$
 			.pipe(
 				distinctUntilChange(),