triqura-ecd/app/api/cortex/agenda/reschedule/route.ts

import { NextRequest, NextResponse } from 'next/server';
import { createClient } from '@/lib/auth/server';
import { rescheduleEncounter } from '@/app/epd/agenda/actions';
import { z } from 'zod';
import { addHours } from 'date-fns';

/**
 * Swift Reschedule Appointment API
 *
 * POST /api/swift/agenda/reschedule
 *
 * Reschedules an appointment to a new date/time.
 */

// Request body schema
const RescheduleAppointmentSchema = z.object({
  encounterId: z.string().uuid({ message: 'encounterId moet een geldige UUID zijn' }),
  newDatetime: z.object({
    date: z.string().refine((val) => !isNaN(Date.parse(val)), {
      message: 'newDatetime.date moet een geldige datum zijn',
    }),
    time: z
      .string()
      .regex(/^\d{2}:\d{2}$/, { message: 'newDatetime.time moet HH:mm formaat zijn' }),
  }),
});

export async function POST(request: NextRequest) {
  try {
    // Auth check
    const supabase = await createClient();
    const {
      data: { user },
      error: authError,
    } = await supabase.auth.getUser();

    if (authError || !user) {
      return NextResponse.json(
        { error: 'Niet geautoriseerd. Log opnieuw in.' },
        { status: 401 }
      );
    }

    // Parse and validate request body
    const body = await request.json();
    const validation = RescheduleAppointmentSchema.safeParse(body);

    if (!validation.success) {
      const errorMessage = validation.error.issues
        .map((e) => `${e.path.join('.')}: ${e.message}`)
        .join(', ');
      return NextResponse.json({ error: errorMessage }, { status: 400 });
    }

    const { encounterId, newDatetime } = validation.data;

    // Verify the encounter belongs to the current user (security check)
    const { data: encounter, error: fetchError } = await supabase
      .from('encounters')
      .select('id, practitioner_id, patient_id, period_start, period_end, status')
      .eq('id', encounterId)
      .single();

    if (fetchError || !encounter) {
      return NextResponse.json(
        { error: 'Afspraak niet gevonden' },
        { status: 404 }
      );
    }

    if (encounter.practitioner_id !== user.id) {
      return NextResponse.json(
        { error: 'Je hebt geen toegang tot deze afspraak' },
        { status: 403 }
      );
    }

    if (encounter.status === 'cancelled') {
      return NextResponse.json(
        { error: 'Kan een geannuleerde afspraak niet verzetten' },
        { status: 400 }
      );
    }

    // Combine new date and time into ISO datetime
    const [hours, minutes] = newDatetime.time.split(':').map(Number);
    const newStartDate = new Date(newDatetime.date);
    newStartDate.setHours(hours, minutes, 0, 0);

    // Validate new date is not in the past
    const now = new Date();
    if (newStartDate < now) {
      return NextResponse.json(
        { error: 'Kan geen afspraken in het verleden verzetten' },
        { status: 400 }
      );
    }

    // Calculate duration from original appointment
    let newEndDate: Date;
    if (encounter.period_end) {
      const originalStart = new Date(encounter.period_start);
      const originalEnd = new Date(encounter.period_end);
      const durationMs = originalEnd.getTime() - originalStart.getTime();
      newEndDate = new Date(newStartDate.getTime() + durationMs);
    } else {
      // Default: 1 hour
      newEndDate = addHours(newStartDate, 1);
    }

    // Reschedule the encounter
    const result = await rescheduleEncounter(
      encounterId,
      newStartDate.toISOString(),
      newEndDate.toISOString()
    );

    if (!result.success) {
      return NextResponse.json(
        { error: result.error || 'Fout bij het verzetten van de afspraak' },
        { status: 500 }
      );
    }

    return NextResponse.json(
      {
        success: true,
        encounterId,
        appointment: {
          id: encounterId,
          periodStart: newStartDate.toISOString(),
          periodEnd: newEndDate.toISOString(),
        },
        message: 'Afspraak succesvol verzet',
      },
      { status: 200 }
    );
  } catch (error) {
    console.error('Error in reschedule appointment API:', error);
    return NextResponse.json(
      {
        error:
          'Er ging iets mis bij het verzetten van de afspraak. Probeer het opnieuw.',
      },
      { status: 500 }
    );
  }
}