CL-PM Event Wiring Integration Contract

interface ProgressNoteSignedEvent {
  event: 'progress_note_signed';
  publisher: 'CL';
  subscriber: ['PM', 'PF', 'FW'];
  payload: {
    entity_id: string;          // cl_progress_notes.id (UUID)
    entity_type: 'progress_note';
    chart_id: string;           // cl_patient_charts.id
    encounter_id: string;       // pm_encounters.id (FK per ADR-002)
    rendering_provider_id: string; // pf_profiles.id of signing clinician
    service_date: string;       // ISO date (YYYY-MM-DD)
    billing_codes: string[];    // CPT codes derived from note type (e.g., ['90837', '90785'])
    modifiers?: string[];       // Modifier codes (e.g., ['GT'] for telehealth)
    duration_minutes: number;   // Actual session duration
    note_type: string;          // 'individual' | 'group' | 'family' | 'crisis'
    requires_cosignature: boolean;
    cosigned: boolean;
  };
  metadata: {
    organization_id: string;
    site_id?: string;
    user_id: string;            // Signing clinician
    timestamp: string;
    correlation_id: string;
    event_id: string;
  };
}

interface ReferralAcceptedEvent {
  event: 'pm_referral_accepted';
  publisher: 'PM';
  subscriber: ['CL', 'PF'];
  payload: {
    entity_id: string;           // pm_referrals.id (UUID)
    entity_type: 'referral';
    patient_id: string;          // pm_patients.id
    chart_id?: string;           // cl_patient_charts.id (if chart already exists)
    referring_provider_id: string;
    accepting_provider_id: string;
    referral_type: string;       // 'inbound' | 'outbound' | 'internal'
    service_type: string;        // e.g., 'behavioral_health', 'substance_use', 'psychiatric'
    priority: string;            // 'routine' | 'urgent' | 'emergent'
    authorization_number?: string;
  };
  metadata: {
    organization_id: string;
    site_id?: string;
    user_id: string;
    timestamp: string;
    correlation_id: string;
    event_id: string;
  };
}

interface ProgramCostAllocatedEvent {
  event: 'fa_program_cost_allocated';
  publisher: 'FA';
  subscriber: ['CL'];
  payload: {
    entity_id: string;            // fa_cost_allocations.id
    entity_type: 'cost_allocation';
    program_id: string;           // Program UUID
    program_name: string;         // e.g., 'IOP', 'PHP', 'Residential'
    period_start: string;         // ISO date
    period_end: string;
    total_cost: number;           // In cents (integer) to avoid floating point
    cost_per_patient_day?: number;
    patient_count: number;
    allocation_method: string;    // 'direct' | 'step_down' | 'activity_based'
  };
  metadata: {
    organization_id: string;
    user_id: string;
    timestamp: string;
    correlation_id: string;
    event_id: string;
  };
}

interface CrisisEpisodeResolvedEvent {
  event: 'cl_crisis_episode_resolved';
  publisher: 'CL';
  subscriber: ['PM'];
  payload: {
    entity_id: string;              // cl_crisis_episodes.id
    entity_type: 'crisis_episode';
    chart_id: string;
    crisis_type: string;
    service_date: string;           // ISO date YYYY-MM-DD
    billing_code: string;           // e.g. S9484, S9485, H2011, 90839, 90840
    duration_minutes?: number;
    rendering_provider_id: string;
    encounter_id?: string;           // pm_encounters.id when linked
  };
  metadata: {
    organization_id: string;
    site_id?: string;
    user_id: string;
    timestamp: string;
    correlation_id: string;
    event_id: string;               // Idempotency key for PM consumer
  };
}

async function handleEvent(event: DomainEvent): Promise<void> {
  // 1. Check for duplicate event_id — maybeSingle() so 0 rows returns null (first-time OK)
  const { data: existing } = await supabase
    .from('fw_domain_events')
    .select('id')
    .eq('event_id', event.metadata.event_id)
    .maybeSingle();

  if (existing) {
    logger.info(`Duplicate event ${event.metadata.event_id} — skipping`);
    return;
  }

  // 2. Process event
  await processEvent(event);

  // 3. Record processed event (store full payload for audit / replay)
  await supabase.from('fw_domain_events').insert({
    event_id: event.metadata.event_id,
    event_name: event.event,
    correlation_id: event.metadata.correlation_id,
    status: 'processed',
    processed_at: new Date().toISOString(),
    event_payload: event as unknown as Record<string, unknown>,
  });
}