Intelligent Patient Intake Document Processing

import { Mixpeek } from 'mixpeek';

const client = new Mixpeek({ apiKey: process.env.MIXPEEK_API_KEY });

// Process patient intake documents
async function processIntakeDocuments(documents: Array<{
  url: string;
  type: 'intake_form' | 'drivers_license' | 'insurance_card' | 'prior_records';
}>) {
  const results = await Promise.all(documents.map(doc =>
    client.healthcare.extractDocument({
      url: doc.url,
      document_type: doc.type,
      extractors: [
        'patient_demographics',
        'insurance_information',
        'medical_history',
        'medications',
        'allergies',
        'emergency_contacts'
      ],
      settings: {
        hipaa_compliant: true,
        validate_insurance: true,
        cross_reference_fields: true
      }
    })
  ));

  return mergeExtractedData(results);
}

// Validate extracted patient data
async function validateIntakeData(extracted: ExtractedPatientData) {
  const validation = await client.healthcare.validatePatientData({
    data: extracted,
    checks: [
      'date_format_consistency',
      'insurance_eligibility',
      'medication_interactions',
      'allergy_drug_conflicts',
      'address_verification',
      'phone_format'
    ]
  });

  return {
    validated_data: validation.corrected_data,
    confidence_scores: validation.field_confidence,
    issues_found: validation.issues,
    requires_review: validation.low_confidence_fields
  };
}

// Push to EHR system
async function pushToEHR(patientData: ValidatedPatientData, ehrSystem: string) {
  const integration = await client.healthcare.pushToEHR({
    data: patientData,
    ehr_system: ehrSystem, // 'epic', 'cerner', 'allscripts', etc.
    create_or_update: 'auto',
    conflict_resolution: 'prefer_document',
    audit_trail: true
  });

  return {
    ehr_patient_id: integration.patient_id,
    fields_created: integration.new_fields,
    fields_updated: integration.updated_fields,
    sync_status: integration.status
  };
}