Agendamento Em Atendimento

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

  try {
    // Processa atualizações em transação atômica
    // ... continua no próximo passo
  } catch (error) {
    // Trata erros
  }
}

// in-service-appointment.ts - Continuação
try {
  await this.prisma.$transaction(async (tx) => {
    // Marca médico como ocupado
    const doctor = await tx.doctors.update({
      where: {
        id: event.doctorId ?? event.appointment.doctorId,
      },
      data: { isBusy: true },
    });

    // Garante vínculo do appointment com o médico
    await tx.appointments.update({
      where: {
        id: event.appointment.id,
      },
      data: {
        doctorId: doctor.id,
      },
    });
  });

  // Emite evento interno para propagação via WebSocket
  this.eventEmitter.emit('appointments.serving', {
    appointment: event.appointment,
    payload: event.payload,
    doctorId: event.doctorId ?? event.appointment.doctorId,
  });
} catch (error) {
  // Trata erros
}

// appointments.listener.ts
@OnEvent('appointments.serving')
async handleAppointmentServing(data: {
  appointment: AppointmentResponseDto;
  payload: PayloadTokenDto;
  doctorId: number;
}) {
  try {
    // Propaga via WebSocket para todos os clientes da conta
    await this.gateway.notifyOnEvent(
      'appointments.serving',
      data.appointment,
      data.payload,
    );
    
    this.logger.debug(
      `Agendamento ${data.appointment.id} propagado via WebSocket para o medico atribuido ${data.doctorId}`,
    );
  } catch (error) {
    this.logger.error(
      `Erro ao propagar evento appointments.serving:`,
      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.serving'

// List.tsx
socket.on('appointments.serving', (appointment: Appointment) => {
  // Remove o agendamento da fila de espera
  setListAppointments((prev) =>
    prev.filter((apt) => apt.id !== appointment.id)
  );
});

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