Chamar Pedido para Coleta

// ListStandby.tsx
function onRemove(id: number, acceptepUserId?: number) {
  socket?.emit('call', { id, acceptepUserId }, (data: responseWs) => {
    if (data.status === 'receive') {
      // Remove da lista de standby
      socket?.emit('remove.standby', orders.find((o) => o.id === id));
    }
    if (data.status === 'refused') {
      // Mostra notificação de erro
      addNotification({
        title: 'Atenção!!!',
        message: data.message,
        bg: 'danger',
        className: 'text-white',
        autohide: true,
      });
    }
  });
}

@SubscribeMessage('call')
async handleMessage(
  @ConnectedSocket() client: Socket,
  @MessageBody() data: UpdateOrderDto,
) {
  try {
    const payload = client.data.payload as PayloadTokenDto;
    
    // Valida se o usuário já está coletando outro paciente
    const exists = await this.ordersService.existsOrder(
      OrdersStatusEnum.IN_PROGRESS,
      data.acceptepUserId ?? payload.sub, // Usa acceptepUserId se fornecido, senão usa usuário logado
      payload,
    );
    
    if (exists) {
      return {
        status: 'refused',
        message: 'O usuário já está coletando outro paciente',
        timestamp: new Date().toISOString(),
      };
    }
    // ... continua no próximo passo
  } catch (e) {
    // ... tratamento de erro
  }
}

// Continuação do handleMessage
// Atualiza o pedido (muda status de STANDBY para IN_PROGRESS)
const order = await this.ordersService.updateOrder(data, payload);

// Busca dados completos do pedido atualizado
const orderComplete = await this.ordersService.findById(order.id, payload);

// Notifica todos os clientes da mesma conta via broadcast
this.notifyOnEvent(
  'progress',
  orderComplete,
  client.data.payload,
);

// Retorna sucesso
return {
  status: 'receive',
  timestamp: new Date().toISOString(),
};

async notifyOnEvent(
  event: string,
  data: any,
  payload: PayloadTokenDto,
): Promise<any> {
  if (this._events.includes(event)) {
    // Envia para todos os clientes da mesma conta
    this.server
      .to(`${this.room}${payload.accountId}`)
      .emit(event, data);
  }
}

// this.room = 'orders.account.'
// Todos os clientes conectados da mesma accountId recebem o evento 'progress'

// ListStandby.tsx - Callback do socket.emit
if (data.status === 'receive') {
  // Remove da lista de standby localmente
  socket?.emit('remove.standby', orders.find((o) => o.id === id));
}

if (data.status === 'refused') {
  // Exibe notificação de erro
  addNotification({
    title: 'Atenção!!!',
    message: data.message,
    bg: 'danger',
    className: 'text-white',
    autohide: true,
  });
  // Não remove da lista (pedido continua em standby)
}

// ListInProgress.tsx
socket.on('progress', (newData: Order) => {
  setOrders((prev) => {
    // Previne duplicatas
    if (prev.find((d) => d.id === newData.id)) return prev;
    // Adiciona no início da lista (pedidos mais recentes primeiro)
    return [newData, ...prev];
  });
});