Agendamento Check-in

// check-in-appointment.ts
@OnEvent('appointments.status.change')
async handleAppointmentsStatusChange(event: AppointmentStatusChangeEvent) {
  // Só processa se action === CHECKIN
  if (event.action !== AppointmentStatusEnum.CHECKIN) return;

  try {
    // Emite evento interno para propagação via WebSocket
    this.eventEmitter.emit('appointments.checkin', {
      appointment: event.appointment,
      payload: event.payload,
    });
  } catch (e) {
    const error = e as Error;
    this.logger.error(error.message, error.stack);
  }
}

// appointments.listener.ts
@OnEvent('appointments.checkin')
async handlePatientCheckin(data: {
  appointment: AppointmentResponseDto;
  payload: PayloadTokenDto;
}) {
  try {
    // Propaga via WebSocket para todos os clientes da conta
    await this.gateway.notifyOnEvent(
      'appointments.checkin',
      data.appointment,
      data.payload,
    );
    
    this.logger.debug(
      `Agendamento ${data.appointment.id} propagado via WebSocket para a fila de espera ${data.payload.accountId}`,
    );
  } catch (error) {
    this.logger.error(
      `Erro ao propagar evento appointments.checkin:`,
      error,
    );
  }
}

// accounts.gateways.ts
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 'appointments.checkin'

// List.tsx
socket.on('appointments.checkin', (appointment: Appointment) => {
  setListAppointments((prev) => {
    // Verifica se o agendamento já existe na lista
    const exists = prev.some((apt) => apt.id === appointment.id);
    
    // Valida se não existe e se o status é 'Check-in'
    if (!exists && appointment.status?.name === 'Check-in') {
      // Adiciona à lista
      return [...prev, appointment];
    }
    
    // Se já existe ou status não é 'Check-in', mantém lista original
    return prev;
  });
});

// Remove listener ao desmontar componente
useEffect(() => {
  return () => {
    socket.off('doctors.busy');
    socket.off('appointments.checkin');
    socket.off('appointments.serving');
    socket.off('appointmnents.finished');
  };
}, []);