feat: Implement comprehensive entity submission architecture

src/lib/entitySubmissionHelpers.ts

@@ -0,0 +1,262 @@
+import { supabase } from '@/integrations/supabase/client';
+import { ImageAssignments } from '@/components/upload/EntityMultiImageUploader';
+import { uploadPendingImages } from './imageUploadHelper';
+
+export interface ParkFormData {
+  name: string;
+  slug: string;
+  description?: string;
+  park_type: string;
+  status: string;
+  opening_date?: string;
+  closing_date?: string;
+  website_url?: string;
+  phone?: string;
+  email?: string;
+  operator_id?: string;
+  property_owner_id?: string;
+  location_id?: string;
+  images?: ImageAssignments;
+  banner_image_url?: string;
+  banner_image_id?: string;
+  card_image_url?: string;
+  card_image_id?: string;
+}
+
+export interface RideFormData {
+  name: string;
+  slug: string;
+  description?: string;
+  category: string;
+  status: string;
+  park_id: string;
+  manufacturer_id?: string;
+  designer_id?: string;
+  ride_model_id?: string;
+  opening_date?: string;
+  closing_date?: string;
+  max_speed_kmh?: number;
+  max_height_meters?: number;
+  length_meters?: number;
+  duration_seconds?: number;
+  capacity_per_hour?: number;
+  height_requirement?: number;
+  age_requirement?: number;
+  inversions?: number;
+  drop_height_meters?: number;
+  max_g_force?: number;
+  intensity_level?: string;
+  coaster_type?: string;
+  seating_type?: string;
+  ride_sub_type?: string;
+  coaster_stats?: any;
+  technical_specs?: any;
+  former_names?: any;
+  images?: ImageAssignments;
+  banner_image_url?: string;
+  banner_image_id?: string;
+  card_image_url?: string;
+  card_image_id?: string;
+}
+
+export async function submitParkCreation(
+  data: ParkFormData,
+  userId: string
+) {
+  // Upload any pending local images first
+  let processedImages = data.images;
+  if (data.images?.uploaded && data.images.uploaded.length > 0) {
+    const uploadedImages = await uploadPendingImages(data.images.uploaded);
+    processedImages = {
+      ...data.images,
+      uploaded: uploadedImages
+    };
+  }
+
+  // Create the main submission record
+  const { data: submissionData, error: submissionError } = await supabase
+    .from('content_submissions')
+    .insert({
+      user_id: userId,
+      submission_type: 'park',
+      content: {
+        action: 'create'
+      },
+      status: 'pending'
+    })
+    .select()
+    .single();
+
+  if (submissionError) throw submissionError;
+
+  // Create the submission item with actual park data
+  const { error: itemError } = await supabase
+    .from('submission_items')
+    .insert({
+      submission_id: submissionData.id,
+      item_type: 'park',
+      item_data: {
+        ...data,
+        images: processedImages as any
+      },
+      status: 'pending',
+      order_index: 0
+    });
+
+  if (itemError) throw itemError;
+
+  return { submitted: true, submissionId: submissionData.id };
+}
+
+export async function submitParkUpdate(
+  parkId: string,
+  data: ParkFormData,
+  userId: string
+) {
+  // Upload any pending local images first
+  let processedImages = data.images;
+  if (data.images?.uploaded && data.images.uploaded.length > 0) {
+    const uploadedImages = await uploadPendingImages(data.images.uploaded);
+    processedImages = {
+      ...data.images,
+      uploaded: uploadedImages
+    };
+  }
+
+  // Create the main submission record
+  const { data: submissionData, error: submissionError } = await supabase
+    .from('content_submissions')
+    .insert({
+      user_id: userId,
+      submission_type: 'park',
+      content: {
+        action: 'edit',
+        park_id: parkId
+      },
+      status: 'pending'
+    })
+    .select()
+    .single();
+
+  if (submissionError) throw submissionError;
+
+  // Create the submission item with actual park data
+  const { error: itemError } = await supabase
+    .from('submission_items')
+    .insert({
+      submission_id: submissionData.id,
+      item_type: 'park',
+      item_data: {
+        ...data,
+        park_id: parkId,
+        images: processedImages as any
+      },
+      status: 'pending',
+      order_index: 0
+    });
+
+  if (itemError) throw itemError;
+
+  return { submitted: true, submissionId: submissionData.id };
+}
+
+export async function submitRideCreation(
+  data: RideFormData,
+  userId: string
+) {
+  // Upload any pending local images first
+  let processedImages = data.images;
+  if (data.images?.uploaded && data.images.uploaded.length > 0) {
+    const uploadedImages = await uploadPendingImages(data.images.uploaded);
+    processedImages = {
+      ...data.images,
+      uploaded: uploadedImages
+    };
+  }
+
+  // Create the main submission record
+  const { data: submissionData, error: submissionError } = await supabase
+    .from('content_submissions')
+    .insert({
+      user_id: userId,
+      submission_type: 'ride',
+      content: {
+        action: 'create'
+      },
+      status: 'pending'
+    })
+    .select()
+    .single();
+
+  if (submissionError) throw submissionError;
+
+  // Create the submission item with actual ride data
+  const { error: itemError } = await supabase
+    .from('submission_items')
+    .insert({
+      submission_id: submissionData.id,
+      item_type: 'ride',
+      item_data: {
+        ...data,
+        images: processedImages as any
+      },
+      status: 'pending',
+      order_index: 0
+    });
+
+  if (itemError) throw itemError;
+
+  return { submitted: true, submissionId: submissionData.id };
+}
+
+export async function submitRideUpdate(
+  rideId: string,
+  data: RideFormData,
+  userId: string
+) {
+  // Upload any pending local images first
+  let processedImages = data.images;
+  if (data.images?.uploaded && data.images.uploaded.length > 0) {
+    const uploadedImages = await uploadPendingImages(data.images.uploaded);
+    processedImages = {
+      ...data.images,
+      uploaded: uploadedImages
+    };
+  }
+
+  // Create the main submission record
+  const { data: submissionData, error: submissionError } = await supabase
+    .from('content_submissions')
+    .insert({
+      user_id: userId,
+      submission_type: 'ride',
+      content: {
+        action: 'edit',
+        ride_id: rideId
+      },
+      status: 'pending'
+    })
+    .select()
+    .single();
+
+  if (submissionError) throw submissionError;
+
+  // Create the submission item with actual ride data
+  const { error: itemError } = await supabase
+    .from('submission_items')
+    .insert({
+      submission_id: submissionData.id,
+      item_type: 'ride',
+      item_data: {
+        ...data,
+        ride_id: rideId,
+        images: processedImages as any
+      },
+      status: 'pending',
+      order_index: 0
+    });
+
+  if (itemError) throw itemError;
+
+  return { submitted: true, submissionId: submissionData.id };
+}