playzer/apps/backend/src/modules/admin-booking/handlers/reschedule-admin-booking.handler.ts

import { db } from '@/lib/prisma';
import { sseManager } from '@/lib/sse';
import {
  AdminBookingServiceError,
  rescheduleAdminBooking,
} from '@/modules/admin-booking/services/admin-booking.service';
import { sendBookingRescheduled } from '@/services/booking-email.service';
import type { AppContext } from '@/types/hono';
import type { RescheduleAdminBookingInput } from '@repo/api-contract';

type BookingIdParams = { id: string };

export async function rescheduleAdminBookingHandler(c: AppContext) {
  const { id } = c.req.valid('param' as never) as BookingIdParams;
  const payload = c.req.valid('json' as never) as RescheduleAdminBookingInput;
  const user = c.get('user');

  const previous = await db.courtBooking.findUnique({
    where: { id },
    select: {
      court: { select: { name: true } },
      startTime: true,
      endTime: true,
      customerEmail: true,
    },
  });

  try {
    const booking = await rescheduleAdminBooking(user.id, id, payload);

    if (previous) {
      void sendBookingRescheduled({
        bookingCode: booking.bookingCode,
        complexName: booking.complexName,
        date: booking.date,
        startTime: booking.startTime,
        endTime: booking.endTime,
        courtName: booking.courtName,
        sportName: booking.sport.name,
        customerName: booking.customerName,
        customerEmail: previous.customerEmail,
        previousCourtName: previous.court.name,
        previousStartTime: previous.startTime,
        previousEndTime: previous.endTime,
      });
    }

    sseManager.emit(
      `complex:${booking.complexId}`,
      JSON.stringify({ type: 'reschedule', booking })
    );

    return c.json(booking);
  } catch (error) {
    if (error instanceof AdminBookingServiceError) {
      return c.json({ message: error.message }, error.status);
    }
    throw error;
  }
}