feat: revert AutomationTaskSyncHandler changes and add task deleted signal dispatching

- Reverted changes in AutomationTaskSyncHandler because cross-platform sync is not used and
was deemed unnecessary for now.
- Added signal dispatching when a task is deleted.

Author: vestefano

packages/core/src/lib/tasks/commands/handlers/automation-task.sync.handler.ts

@@ -26,7 +26,6 @@ import { Task } from './../../task.entity';
 import { TypeOrmIntegrationMapRepository } from '../../../integration-map/repository/type-orm-integration-map.repository';
 import { TypeOrmTaskStatusRepository } from '../../statuses/repository/type-orm-task-status.repository';
 import { TypeOrmTaskRepository } from '../../repository/type-orm-task.repository';
-import { SocketService } from '../../../socket/socket.service';
 
 @CommandHandler(AutomationTaskSyncCommand)
 export class AutomationTaskSyncHandler implements ICommandHandler<AutomationTaskSyncCommand> {
@@ -38,8 +37,7 @@ export class AutomationTaskSyncHandler implements ICommandHandler<AutomationTask
 		private readonly _taskService: TaskService,
 		private readonly activityLogService: ActivityLogService,
 		private readonly _employeeService: EmployeeService,
-		private readonly _entitySubscriptionService: EntitySubscriptionService,
-		private readonly _socketService: SocketService
+		private readonly _entitySubscriptionService: EntitySubscriptionService
 	) {}
 
 	/**
@@ -189,15 +187,6 @@ export class AutomationTaskSyncHandler implements ICommandHandler<AutomationTask
 							)
 						)
 					);
-
-					// Emit tasks:changed event to all members to update their task list in the timer
-					try {
-						employees.forEach((employee: IEmployee) => {
-							this._socketService.emitToClient(employee.id, 'tasks:changed', null);
-						});
-					} catch (error) {
-						console.error(`Error while sending tasks:changed event to members: ${error}`);
-					}
 				} catch (error) {
 					console.error('Error subscribing new members to the task:', error);
 				}
@@ -313,16 +302,6 @@ export class AutomationTaskSyncHandler implements ICommandHandler<AutomationTask
 				}
 			}
 
-			// Emit tasks:changed event to all existing members as well
-			try {
-				const allMemberIds = new Set([...existingMemberIds, ...memberIds]);
-				allMemberIds.forEach((memberId) => {
-					this._socketService.emitToClient(memberId, 'tasks:changed', null);
-				});
-			} catch (error) {
-				console.error(`Error while sending tasks:changed event to all members: ${error}`);
-			}
-
 			// Activity Log Task Update
 			this.activityLogService.logActivity<Task>(
 				BaseEntityEnum.Task,

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

@@ -1420,6 +1420,7 @@ export class TaskService extends TenantAwareCrudService<Task> {
 				// 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(employeeId);
+				this._socketService.emitToClient(employeeId, 'tasks:changed', null);
 			}
 
 			return result;