import { z } from 'zod'; import { supabase } from '@/lib/supabaseClient'; import { handleNonCriticalError, getErrorMessage } from '@/lib/errorHandler'; import { logger } from '@/lib/logger'; // ============================================ // VALIDATION SCHEMAS - DOCUMENTATION ONLY // ============================================ // ⚠️ NOTE: These schemas are currently NOT used in the React application. // All business logic validation happens server-side in the edge function. // These schemas are kept for: // 1. Documentation of validation rules // 2. Potential future use for client-side UX validation (basic checks only) // 3. Reference when updating edge function validation logic // // DO NOT import these in production code for business logic validation. // ============================================ // ============================================ // CENTRALIZED VALIDATION SCHEMAS // ⚠️ CRITICAL: These schemas represent the validation rules // They should mirror the validation in process-selective-approval edge function // Client-side should NOT perform business logic validation // Client-side only does basic UX validation (non-empty, format checks) in forms // ============================================ const currentYear = new Date().getFullYear(); // ============================================ // SHARED IMAGE UPLOAD SCHEMA // ============================================ const imageAssignmentSchema = z.object({ uploaded: z.array(z.any()), banner_assignment: z.number().int().min(0).nullable().optional(), card_assignment: z.number().int().min(0).nullable().optional() }).optional().default({ uploaded: [], banner_assignment: null, card_assignment: null }); // ============================================ // PARK SCHEMA // ============================================ export const parkValidationSchema = z.object({ name: z.string().trim().min(1, 'Park name is required').max(200, 'Name must be less than 200 characters'), slug: z.string().trim().min(1, 'Slug is required').regex(/^[a-z0-9-]+$/, 'Slug must contain only lowercase letters, numbers, and hyphens'), description: z.string().trim().max(2000, 'Description must be less than 2000 characters').nullish().transform(val => val ?? undefined), park_type: z.string().min(1, 'Park type is required'), status: z.enum(['operating', 'closed_permanently', 'closed_temporarily', 'under_construction', 'planned', 'abandoned']), opening_date: z.string().nullish().transform(val => val ?? undefined).refine((val) => { if (!val) return true; const date = new Date(val); return date <= new Date(); }, 'Opening date cannot be in the future'), opening_date_precision: z.enum(['day', 'month', 'year']).nullable().optional(), closing_date: z.string().nullish().transform(val => val ?? undefined), closing_date_precision: z.enum(['day', 'month', 'year']).nullable().optional(), location_id: z.string().uuid().optional().nullable(), location: z.object({ name: z.string(), street_address: z.string().optional().nullable(), city: z.string().optional().nullable(), state_province: z.string().optional().nullable(), country: z.string(), postal_code: z.string().optional().nullable(), latitude: z.number(), longitude: z.number(), timezone: z.string().optional().nullable(), display_name: z.string(), }).optional(), website_url: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().url().safeParse(val).success; }, 'Invalid URL format'), phone: z.string().trim().max(50, 'Phone must be less than 50 characters').nullish().transform(val => val ?? undefined), email: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().email().safeParse(val).success; }, 'Invalid email format'), operator_id: z.string() .refine( val => !val || val === '' || val.startsWith('temp-') || /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(val), 'Must be a valid UUID or temporary placeholder' ) .nullish() .transform(val => val ?? undefined), property_owner_id: z.string() .refine( val => !val || val === '' || val.startsWith('temp-') || /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(val), 'Must be a valid UUID or temporary placeholder' ) .nullish() .transform(val => val ?? undefined), banner_image_id: z.string().nullish().transform(val => val ?? undefined), banner_image_url: z.string().nullish().transform(val => val ?? undefined), card_image_id: z.string().nullish().transform(val => val ?? undefined), card_image_url: z.string().nullish().transform(val => val ?? undefined), images: imageAssignmentSchema, source_url: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().url().safeParse(val).success; }, 'Invalid URL format. Must be a valid URL starting with http:// or https://'), submission_notes: z.string().trim() .max(1000, 'Submission notes must be less than 1000 characters') .nullish() .transform(val => val ?? undefined), }).refine((data) => { if (data.closing_date && data.opening_date) { return new Date(data.closing_date) >= new Date(data.opening_date); } return true; }, { message: 'Closing date must be after opening date', path: ['closing_date'], }).refine((data) => { // Either location object OR location_id must be provided return !!(data.location || data.location_id); }, { message: 'Location is required. Please search and select a location for the park.', path: ['location'] }); // ============================================ // RIDE SCHEMA // ============================================ export const rideValidationSchema = z.object({ name: z.string().trim().min(1, 'Ride name is required').max(200, 'Name must be less than 200 characters'), slug: z.string().trim().min(1, 'Slug is required').regex(/^[a-z0-9-]+$/, 'Slug must contain only lowercase letters, numbers, and hyphens'), description: z.string().trim().max(2000, 'Description must be less than 2000 characters').nullish().transform(val => val ?? undefined), category: z.string().min(1, 'Category is required'), ride_sub_type: z.string().trim().max(100, 'Sub type must be less than 100 characters').nullish().transform(val => val ?? undefined), status: z.enum(['operating', 'closed_permanently', 'closed_temporarily', 'under_construction', 'relocated', 'stored', 'demolished']), park_id: z.string().uuid().optional().nullable(), designer_id: z.string() .refine( val => !val || val === '' || val.startsWith('temp-') || /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(val), 'Must be a valid UUID or temporary placeholder' ) .optional() .nullable(), opening_date: z.string().nullish().transform(val => val ?? undefined), opening_date_precision: z.enum(['day', 'month', 'year']).nullable().optional(), closing_date: z.string().nullish().transform(val => val ?? undefined), closing_date_precision: z.enum(['day', 'month', 'year']).nullable().optional(), height_requirement: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Height requirement must be positive').max(300, 'Height requirement must be less than 300cm').optional() ), age_requirement: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Age requirement must be positive').max(100, 'Age requirement must be less than 100').optional() ), capacity_per_hour: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1, 'Capacity must be positive').max(99999, 'Capacity must be less than 100,000').optional() ), duration_seconds: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1, 'Duration must be positive').max(86400, 'Duration must be less than 24 hours').optional() ), max_speed_kmh: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Speed must be positive').max(500, 'Speed must be less than 500 km/h').optional() ), max_height_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Height must be positive').max(200, 'Height must be less than 200 meters').optional() ), length_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Length must be positive').max(10000, 'Length must be less than 10km').optional() ), inversions: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Inversions must be positive').max(20, 'Inversions must be less than 20').optional() ), drop_height_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Drop height must be positive').max(200, 'Drop height must be less than 200 meters').optional() ), max_g_force: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(-10, 'G-force must be greater than -10').max(10, 'G-force must be less than 10').optional() ), manufacturer_id: z.string() .refine( val => !val || val === '' || val.startsWith('temp-') || /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(val), 'Must be a valid UUID or temporary placeholder' ) .optional() .nullable(), ride_model_id: z.string() .refine( val => !val || val === '' || val.startsWith('temp-') || /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(val), 'Must be a valid UUID or temporary placeholder' ) .optional() .nullable(), coaster_type: z.string().nullable().optional(), seating_type: z.string().nullable().optional(), intensity_level: z.string().nullable().optional(), track_material: z.array(z.string()).optional().nullable(), support_material: z.array(z.string()).optional().nullable(), propulsion_method: z.array(z.string()).optional().nullable(), // Water ride specific fields water_depth_cm: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Water depth must be positive').max(1000, 'Water depth must be less than 1000cm').optional() ), splash_height_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Splash height must be positive').max(100, 'Splash height must be less than 100 meters').optional() ), wetness_level: z.enum(['dry', 'light', 'moderate', 'soaked']).nullable().optional(), flume_type: z.string().trim().max(100, 'Flume type must be less than 100 characters').nullish().transform(val => val ?? undefined), boat_capacity: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1, 'Boat capacity must be positive').max(100, 'Boat capacity must be less than 100').optional() ), // Dark ride specific fields theme_name: z.string().trim().max(200, 'Theme name must be less than 200 characters').nullish().transform(val => val ?? undefined), story_description: z.string().trim().max(2000, 'Story description must be less than 2000 characters').nullish().transform(val => val ?? undefined), show_duration_seconds: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Show duration must be positive').max(7200, 'Show duration must be less than 2 hours').optional() ), animatronics_count: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Animatronics count must be positive').max(1000, 'Animatronics count must be less than 1000').optional() ), projection_type: z.string().trim().max(100, 'Projection type must be less than 100 characters').nullish().transform(val => val ?? undefined), ride_system: z.string().trim().max(100, 'Ride system must be less than 100 characters').nullish().transform(val => val ?? undefined), scenes_count: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Scenes count must be positive').max(100, 'Scenes count must be less than 100').optional() ), // Flat ride specific fields rotation_type: z.enum(['horizontal', 'vertical', 'multi_axis', 'pendulum', 'none']).nullable().optional(), motion_pattern: z.string().trim().max(200, 'Motion pattern must be less than 200 characters').nullish().transform(val => val ?? undefined), platform_count: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1, 'Platform count must be positive').max(100, 'Platform count must be less than 100').optional() ), swing_angle_degrees: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Swing angle must be positive').max(360, 'Swing angle must be less than 360 degrees').optional() ), rotation_speed_rpm: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Rotation speed must be positive').max(200, 'Rotation speed must be less than 200 RPM').optional() ), arm_length_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Arm length must be positive').max(100, 'Arm length must be less than 100 meters').optional() ), max_height_reached_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Max height reached must be positive').max(200, 'Max height reached must be less than 200 meters').optional() ), // Kiddie ride specific fields min_age: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Min age must be positive').max(18, 'Min age must be less than 18').optional() ), max_age: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Max age must be positive').max(18, 'Max age must be less than 18').optional() ), educational_theme: z.string().trim().max(200, 'Educational theme must be less than 200 characters').nullish().transform(val => val ?? undefined), character_theme: z.string().trim().max(200, 'Character theme must be less than 200 characters').nullish().transform(val => val ?? undefined), // Transportation ride specific fields transport_type: z.enum(['train', 'monorail', 'skylift', 'ferry', 'peoplemover', 'cable_car']).nullable().optional(), route_length_meters: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().min(0, 'Route length must be positive').max(50000, 'Route length must be less than 50km').optional() ), stations_count: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(2, 'Stations count must be at least 2').max(50, 'Stations count must be less than 50').optional() ), vehicle_capacity: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1, 'Vehicle capacity must be positive').max(500, 'Vehicle capacity must be less than 500').optional() ), vehicles_count: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1, 'Vehicles count must be positive').max(100, 'Vehicles count must be less than 100').optional() ), round_trip_duration_seconds: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(0, 'Round trip duration must be positive').max(7200, 'Round trip duration must be less than 2 hours').optional() ), banner_image_id: z.string().nullish().transform(val => val ?? undefined), banner_image_url: z.string().nullish().transform(val => val ?? undefined), card_image_id: z.string().nullish().transform(val => val ?? undefined), card_image_url: z.string().nullish().transform(val => val ?? undefined), images: imageAssignmentSchema, source_url: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().url().safeParse(val).success; }, 'Invalid URL format. Must be a valid URL starting with http:// or https://'), submission_notes: z.string().trim() .max(1000, 'Submission notes must be less than 1000 characters') .nullish() .transform(val => val ?? undefined), }).refine((data) => { // park_id is required (either real UUID or temp- reference) return !!(data.park_id && data.park_id.trim().length > 0); }, { message: 'Park is required. Please select or create a park for this ride.', path: ['park_id'] }); // ============================================ // COMPANY SCHEMA (Manufacturer, Designer, Operator, Property Owner) // ============================================ export const companyValidationSchema = z.object({ name: z.string().trim().min(1, 'Company name is required').max(200, 'Name must be less than 200 characters'), slug: z.string().trim().min(1, 'Slug is required').regex(/^[a-z0-9-]+$/, 'Slug must contain only lowercase letters, numbers, and hyphens'), company_type: z.enum(['manufacturer', 'designer', 'operator', 'property_owner']), description: z.string().trim().max(2000, 'Description must be less than 2000 characters').nullish().transform(val => val ?? undefined), person_type: z.enum(['company', 'individual', 'firm', 'organization']), founded_date: z.string().nullish().transform(val => val ?? undefined), founded_date_precision: z.enum(['day', 'month', 'year']).nullable().optional(), founded_year: z.preprocess( (val) => val === '' || val === null || val === undefined ? undefined : Number(val), z.number().int().min(1800, 'Founded year must be after 1800').max(currentYear, `Founded year cannot be after ${currentYear}`).optional() ), headquarters_location: z.string().trim().max(200, 'Location must be less than 200 characters').nullish().transform(val => val ?? undefined), website_url: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().url().safeParse(val).success; }, 'Invalid URL format'), banner_image_id: z.string().nullish().transform(val => val ?? undefined), banner_image_url: z.string().nullish().transform(val => val ?? undefined), card_image_id: z.string().nullish().transform(val => val ?? undefined), card_image_url: z.string().nullish().transform(val => val ?? undefined), images: imageAssignmentSchema, source_url: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().url().safeParse(val).success; }, 'Invalid URL format. Must be a valid URL starting with http:// or https://'), submission_notes: z.string().trim() .max(1000, 'Submission notes must be less than 1000 characters') .nullish() .transform(val => val ?? undefined), }); // ============================================ // RIDE MODEL SCHEMA // ============================================ export const rideModelValidationSchema = z.object({ name: z.string().trim().min(1, 'Model name is required').max(200, 'Name must be less than 200 characters'), slug: z.string().trim().min(1, 'Slug is required').regex(/^[a-z0-9-]+$/, 'Slug must contain only lowercase letters, numbers, and hyphens'), category: z.string().min(1, 'Category is required'), ride_type: z.string().trim().min(1, 'Ride type is required').max(100, 'Ride type must be less than 100 characters'), description: z.string().trim().max(2000, 'Description must be less than 2000 characters').nullish().transform(val => val ?? undefined), manufacturer_id: z.string() .refine( val => !val || val === '' || val.startsWith('temp-') || /^[0-9a-f]{8}-[0-9a-f]{4}-[1-5][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(val), 'Must be a valid UUID or temporary placeholder' ) .optional(), source_url: z.string().trim().nullish().transform(val => val ?? undefined).refine((val) => { if (!val || val === '') return true; return z.string().url().safeParse(val).success; }, 'Invalid URL format. Must be a valid URL starting with http:// or https://'), submission_notes: z.string().trim() .max(1000, 'Submission notes must be less than 1000 characters') .nullish() .transform(val => val ?? undefined), }); // ============================================ // PHOTO SCHEMA // ============================================ export const photoValidationSchema = z.object({ cloudflare_image_id: z.string().min(1, 'Image ID is required'), cloudflare_image_url: z.string().url('Invalid image URL'), entity_type: z.string().min(1, 'Entity type is required'), entity_id: z.string().uuid('Invalid entity ID'), caption: z.string().trim().max(500, 'Caption must be less than 500 characters').optional().or(z.literal('')), photographer_credit: z.string().trim().max(200, 'Credit must be less than 200 characters').optional().or(z.literal('')), }); // ============================================ // MILESTONE/TIMELINE EVENT SCHEMA // ============================================ export const milestoneValidationSchema = z.object({ title: z.string().trim().min(1, 'Event title is required').max(200, 'Title must be less than 200 characters'), description: z.string().trim().max(2000, 'Description must be less than 2000 characters').optional().or(z.literal('')), event_type: z.string().min(1, 'Event type is required'), event_date: z.string().min(1, 'Event date is required').refine((val) => { if (!val) return true; const date = new Date(val); const fiveYearsFromNow = new Date(); fiveYearsFromNow.setFullYear(fiveYearsFromNow.getFullYear() + 5); return date <= fiveYearsFromNow; }, 'Event date cannot be more than 5 years in the future'), event_date_precision: z.enum(['day', 'month', 'year']).optional().default('day'), entity_type: z.string().min(1, 'Entity type is required'), entity_id: z.string().uuid('Invalid entity ID'), is_public: z.boolean().optional(), display_order: z.number().optional(), from_value: z.string().trim().max(200).optional().or(z.literal('')), to_value: z.string().trim().max(200).optional().or(z.literal('')), from_entity_id: z.string().uuid().optional().nullable(), to_entity_id: z.string().uuid().optional().nullable(), from_location_id: z.string().uuid().optional().nullable(), to_location_id: z.string().uuid().optional().nullable(), }).refine((data) => { // For change events, require from_value or to_value const changeEvents = ['name_change', 'operator_change', 'owner_change', 'location_change', 'status_change']; if (changeEvents.includes(data.event_type)) { return data.from_value || data.to_value || data.from_entity_id || data.to_entity_id || data.from_location_id || data.to_location_id; } return true; }, { message: 'Change events must specify what changed (from/to values or entity IDs)', path: ['from_value'], }); // ============================================ // PHOTO OPERATION SCHEMAS // ============================================ export const photoEditValidationSchema = z.object({ photo_id: z.string().uuid('Invalid photo ID'), cloudflare_image_url: z.string().url('Invalid image URL'), caption: z.string().trim().max(500, 'Caption must be less than 500 characters').optional().or(z.literal('')), title: z.string().trim().max(200, 'Title must be less than 200 characters').optional().or(z.literal('')), entity_type: z.string().min(1, 'Entity type is required'), entity_id: z.string().uuid('Invalid entity ID'), }); export const photoDeleteValidationSchema = z.object({ photo_id: z.string().uuid('Invalid photo ID'), cloudflare_image_id: z.string().min(1, 'Image ID is required'), cloudflare_image_url: z.string().url('Invalid image URL').optional(), entity_type: z.string().min(1, 'Entity type is required'), entity_id: z.string().uuid('Invalid entity ID'), }); // ============================================ // SCHEMA REGISTRY // ============================================ export const entitySchemas = { park: parkValidationSchema, ride: rideValidationSchema, manufacturer: companyValidationSchema, designer: companyValidationSchema, operator: companyValidationSchema, property_owner: companyValidationSchema, ride_model: rideModelValidationSchema, photo: photoValidationSchema, photo_edit: photoEditValidationSchema, photo_delete: photoDeleteValidationSchema, milestone: milestoneValidationSchema, timeline_event: milestoneValidationSchema, // Alias for milestone }; // ============================================ // VALIDATION RESULT TYPES // ============================================ export interface ValidationError { field: string; message: string; severity: 'blocking' | 'warning' | 'suggestion'; } export interface ValidationResult { isValid: boolean; blockingErrors: ValidationError[]; warnings: ValidationError[]; suggestions: ValidationError[]; allErrors: ValidationError[]; } // ============================================ // VALIDATION HELPERS // ============================================ /** * Validate entity data against its schema * Returns detailed validation result with errors categorized by severity */ export async function validateEntityData( entityType: keyof typeof entitySchemas, data: unknown ): Promise { try { // Debug logging for operator entity if (entityType === 'operator') { logger.log('Validating operator entity', { dataKeys: data ? Object.keys(data as object) : [], dataTypes: data ? Object.entries(data as object).reduce((acc, [key, val]) => { acc[key] = typeof val; return acc; }, {} as Record) : {}, rawData: JSON.stringify(data).substring(0, 500) }); } const schema = entitySchemas[entityType]; if (!schema) { const error = { field: 'entity_type', message: `Unknown entity type: ${entityType}`, severity: 'blocking' as const }; handleNonCriticalError(new Error(`Unknown entity type: ${entityType}`), { action: 'Entity Validation', metadata: { entityType, providedData: data } }); return { isValid: false, blockingErrors: [error], warnings: [], suggestions: [], allErrors: [error], }; } const result = schema.safeParse(data); const blockingErrors: ValidationError[] = []; const warnings: ValidationError[] = []; const suggestions: ValidationError[] = []; // Process Zod errors if (!result.success) { const zodError = result.error as z.ZodError; // Log detailed validation failure handleNonCriticalError(zodError, { action: 'Zod Validation Failed', metadata: { entityType, issues: zodError.issues, providedData: JSON.stringify(data).substring(0, 500), issueCount: zodError.issues.length } }); zodError.issues.forEach((issue) => { const field = issue.path.join('.') || entityType; blockingErrors.push({ field, message: `${issue.message} (code: ${issue.code})`, severity: 'blocking', }); }); } // Add warnings for optional but recommended fields const validData = data as Record; if (validData.description && typeof validData.description === 'string' && validData.description.length < 50) { warnings.push({ field: 'description', message: 'Description is short. Recommended: 50+ characters', severity: 'warning', }); } if (entityType === 'park' || entityType === 'ride') { if (!validData.description || (typeof validData.description === 'string' && validData.description.trim() === '')) { warnings.push({ field: 'description', message: 'No description provided. Adding a description improves content quality', severity: 'warning', }); } } // Check slug uniqueness (async) - only if slug has changed if (validData.slug && typeof validData.slug === 'string') { // Extract the correct ID field based on entity type let entityId: string | undefined; switch (entityType) { case 'park': entityId = typeof validData.park_id === 'string' ? validData.park_id : undefined; break; case 'ride': entityId = typeof validData.ride_id === 'string' ? validData.ride_id : undefined; break; case 'manufacturer': case 'designer': case 'operator': case 'property_owner': entityId = typeof validData.company_id === 'string' ? validData.company_id : (typeof validData.id === 'string' ? validData.id : undefined); break; case 'ride_model': entityId = typeof validData.ride_model_id === 'string' ? validData.ride_model_id : (typeof validData.id === 'string' ? validData.id : undefined); break; default: entityId = typeof validData.id === 'string' ? validData.id : undefined; } // If we have an entity ID, check if slug has actually changed let shouldCheckUniqueness = true; if (entityId) { const tableName = getTableNameFromEntityType(entityType); // Use switch to avoid TypeScript type instantiation issues let originalSlug: string | null = null; try { switch (tableName) { case 'parks': { const { data, error } = await supabase.from('parks').select('slug').eq('id', entityId).maybeSingle(); if (error || !data) { originalSlug = null; break; } originalSlug = data.slug || null; break; } case 'rides': { const { data, error } = await supabase.from('rides').select('slug').eq('id', entityId).maybeSingle(); if (error || !data) { originalSlug = null; break; } originalSlug = data.slug || null; break; } case 'companies': { const { data, error } = await supabase.from('companies').select('slug').eq('id', entityId).maybeSingle(); if (error || !data) { originalSlug = null; break; } originalSlug = data.slug || null; break; } case 'ride_models': { const { data, error } = await supabase.from('ride_models').select('slug').eq('id', entityId).maybeSingle(); if (error || !data) { originalSlug = null; break; } originalSlug = data.slug || null; break; } } // If slug hasn't changed, skip uniqueness check if (originalSlug && originalSlug === validData.slug) { shouldCheckUniqueness = false; } } catch (error) { // Entity doesn't exist yet (CREATE action) - proceed with uniqueness check // This is expected for new submissions where entityId is a submission_id console.log('Entity not found in live table (likely a new submission)', { entityType, entityId, tableName }); } } // Only check uniqueness if this is a new entity or slug has changed if (shouldCheckUniqueness) { const isSlugUnique = await checkSlugUniqueness( entityType, validData.slug, entityId ); if (!isSlugUnique) { blockingErrors.push({ field: 'slug', message: 'This slug is already in use. Manually check if this entity already exists, and reject if so. Otherwise, escalate to an admin for manual editing of the slug.', severity: 'blocking', }); } } } const allErrors = [...blockingErrors, ...warnings, ...suggestions]; const isValid = blockingErrors.length === 0; return { isValid, blockingErrors, warnings, suggestions, allErrors, }; } catch (error) { // Catch any unexpected errors during validation const errorId = handleNonCriticalError(error, { action: 'Entity Validation Unexpected Error', metadata: { entityType, dataType: typeof data, hasData: !!data } }); return { isValid: false, blockingErrors: [{ field: entityType, message: `Validation error: ${getErrorMessage(error)} (ref: ${errorId.slice(0, 8)})`, severity: 'blocking' }], warnings: [], suggestions: [], allErrors: [{ field: entityType, message: `Validation error: ${getErrorMessage(error)} (ref: ${errorId.slice(0, 8)})`, severity: 'blocking' }], }; } } /** * Check if slug is unique for the entity type */ async function checkSlugUniqueness( entityType: keyof typeof entitySchemas, slug: string, excludeId?: string ): Promise { const tableName = getTableNameFromEntityType(entityType); try { // Query with explicit table name - use simple approach to avoid type instantiation issues let result; switch (tableName) { case 'parks': result = await supabase.from('parks').select('id').eq('slug', slug).limit(1); break; case 'rides': result = await supabase.from('rides').select('id').eq('slug', slug).limit(1); break; case 'companies': result = await supabase.from('companies').select('id').eq('slug', slug).limit(1); break; case 'ride_models': result = await supabase.from('ride_models').select('id').eq('slug', slug).limit(1); break; default: return true; // Assume unique on invalid table } const { data, error } = result; if (error) { return true; // Assume unique on error to avoid blocking } // If no data, slug is unique if (!data || data.length === 0) { return true; } // If excludeId provided and matches, it's the same entity (editing) if (excludeId && data[0] && data[0].id === excludeId) { return true; } // Slug is in use by a different entity return false; } catch (error) { return true; // Assume unique on error to avoid false positives } } /** * Get database table name from entity type */ function getTableNameFromEntityType(entityType: keyof typeof entitySchemas): string { switch (entityType) { case 'park': return 'parks'; case 'ride': return 'rides'; case 'manufacturer': case 'designer': case 'operator': case 'property_owner': return 'companies'; case 'ride_model': return 'ride_models'; case 'photo': return 'photos'; default: return entityType + 's'; } } /** * Batch validate multiple items */ export async function validateMultipleItems( items: Array<{ item_type: string; item_data: unknown; id?: string }> ): Promise> { const results = new Map(); await Promise.all( items.map(async (item) => { const result = await validateEntityData( item.item_type as keyof typeof entitySchemas, { ...(item.item_data as object), id: item.id } ); const validData = item.item_data as Record; results.set( item.id || (typeof validData.slug === 'string' ? validData.slug : ''), result ); }) ); return results; } /** * Validate required fields before submission * Returns user-friendly error messages */ export function validateRequiredFields( entityType: keyof typeof entitySchemas, data: any ): { valid: boolean; errors: string[] } { const errors: string[] = []; if (entityType === 'park') { if (!data.location && !data.location_id) { errors.push('Location is required. Please search and select a location for the park.'); } } if (entityType === 'ride') { if (!data.park_id || data.park_id.trim().length === 0) { errors.push('Park is required. Please select or create a park for this ride.'); } } return { valid: errors.length === 0, errors }; }