ENDING THE PAPERWORK CHASE FOR INDEPENDENT TRUCK CARRIERS.

export interface CarrierIntakePacket {
  legalBusinessName: string;
  mcNumber: `MC-${number}`;
  dotNumber: `DOT-${number}`;
  equipmentType: "53_dry_van" | "53_reefer" | "48_flatbed";
  preferredStates: string[];
  documents: {
    w9TaxFormUrl: string;
    mcAuthorityLetterUrl: string;
    certificateOfInsuranceUrl: string;
    noticeOfAssignmentUrl?: string;
  };
}

export function validateComplianceVault(docs: CarrierIntakePacket["documents"]) {
  const required = [
    ["W-9 Tax Form", docs.w9TaxFormUrl],
    ["MC Authority Letter", docs.mcAuthorityLetterUrl],
    ["Certificate of Insurance (COI)", docs.certificateOfInsuranceUrl],
  ] as const;

  const missing = required.filter(([, url]) => !url || !url.startsWith("https://"));
  if (missing.length > 0) {
    throw new Error(`Missing required documents: ${missing.map(([k]) => k).join(", ")}`);
  }
  return { verified: true, packetComplete: true };
}

export async function uploadCarrierDocument(
  mcNumber: string,
  docType: "w9" | "mc_authority" | "coi_insurance" | "noa",
  file: File
) {
  if (file.size > 15 * 1024 * 1024) {
    throw new Error("Document exceeds 15MB cab-upload limit.");
  }

  const cleanMc = mcNumber.replace(/[^0-9]/g, "");
  const storagePath = `carriers/MC-${cleanMc}/${docType}_${Date.now()}.pdf`;

  const { error } = await supabase.storage
    .from("carrier-compliance-vault")
    .upload(storagePath, file, { upsert: true });

  if (error) throw error;
  return supabase.storage.from("carrier-compliance-vault").getPublicUrl(storagePath).data.publicUrl;
}

export async function POST(req: Request) {
  const packet: CarrierIntakePacket = await req.json();
  validateComplianceVault(packet.documents);

  const { data: carrier, error } = await supabase
    .from("carrier_applications")
    .insert({
      legal_name: packet.legalBusinessName,
      mc_number: packet.mcNumber,
      dot_number: packet.dotNumber,
      equipment_type: packet.equipmentType,
      w9_url: packet.documents.w9TaxFormUrl,
      mc_letter_url: packet.documents.mcAuthorityLetterUrl,
      coi_url: packet.documents.certificateOfInsuranceUrl,
      review_status: "pending_review",
    })
    .select()
    .single();

  if (error) return Response.json({ error: error.message }, { status: 400 });

  await emailjs.send(SERVICE_ID, DISPATCH_TEMPLATE_ID, {
    carrier_name: carrier.legal_name,
    mc_number: carrier.mc_number,
    equipment: carrier.equipment_type,
  });

  return Response.json({ status: "submitted", carrierId: carrier.id });
}

export async function approveCarrierCompliance(
  applicationId: string,
  reviewerId: string
) {
  const { data, error } = await supabase
    .from("carrier_applications")
    .update({
      review_status: "cleared_to_haul",
      verified_by: reviewerId,
      verified_at: new Date().toISOString(),
    })
    .eq("id", applicationId)
    .select()
    .single();

  if (error) throw error;
  return data;
}