Onboarding & Offboarding — Integration

interface HrOnboardingStartedPayload {
  event_type: 'hr_onboarding_started';
  employee_id: uuid;
  onboarding_instance_id: uuid;
  template_id: uuid;
  start_date: date;
  is_clinical: boolean;
  organization_id: uuid;
  timestamp: timestamptz;
}

interface HrOnboardingTaskCreatedPayload {
  event_type: 'hr_onboarding_task_created';
  task_instance_id: uuid;
  onboarding_instance_id: uuid;
  employee_id: uuid;
  category: 'it_setup';
  title: string;
  due_date: date;
  organization_id: uuid;
  timestamp: timestamptz;
}

interface HrOffboardingStartedPayload {
  event_type: 'hr_offboarding_started';
  employee_id: uuid;
  offboarding_instance_id: uuid;
  termination_date: date;
  termination_type: 'voluntary' | 'involuntary' | 'retirement' | 'end_contract';
  organization_id: uuid;
  timestamp: timestamptz;
}

interface HrOffboardingTaskCreatedPayload {
  event_type: 'hr_offboarding_task_created';
  checklist_item_id: uuid;
  offboarding_instance_id: uuid;
  employee_id: uuid;
  category: 'access_revocation';
  title: string;
  organization_id: uuid;
  timestamp: timestamptz;
}

CREATE OR REPLACE FUNCTION hr_publish_onboarding_started()
RETURNS TRIGGER AS $$
DECLARE
  v_organization_id uuid;
BEGIN
  -- Resolve and validate organization_id before publishing
  SELECT organization_id INTO v_organization_id
  FROM hr_employees
  WHERE id = NEW.employee_id;
  
  IF v_organization_id IS NULL THEN
    RAISE EXCEPTION 'Employee % not found or has no organization_id', NEW.employee_id;
  END IF;
  
  PERFORM pg_notify('domain_events', json_build_object(
    'event_type', 'hr_onboarding_started',
    'employee_id', NEW.employee_id,
    'onboarding_instance_id', NEW.id,
    'template_id', NEW.template_id,
    'start_date', NEW.start_date,
    'is_clinical', COALESCE((SELECT is_clinical FROM hr_onboarding_templates WHERE id = NEW.template_id), false),
    'organization_id', v_organization_id,
    'timestamp', now()
  )::text);
  RETURN NEW;
END;
$$ LANGUAGE plpgsql SECURITY DEFINER SET search_path = public;

CREATE TRIGGER trigger_hr_onboarding_started
AFTER INSERT ON hr_onboarding_instances
FOR EACH ROW
EXECUTE FUNCTION hr_publish_onboarding_started();

CREATE OR REPLACE FUNCTION hr_publish_offboarding_started()
RETURNS TRIGGER AS $$
BEGIN
  PERFORM pg_notify('domain_events', json_build_object(
    'event_type', 'hr_offboarding_started',
    'employee_id', NEW.employee_id,
    'offboarding_instance_id', NEW.id,
    'termination_date', NEW.termination_date,
    'termination_type', NEW.termination_type,
    'organization_id', (SELECT organization_id FROM hr_employees WHERE id = NEW.employee_id),
    'timestamp', now()
  )::text);
  RETURN NEW;
END;
$$ LANGUAGE plpgsql SECURITY DEFINER SET search_path = public;

CREATE TRIGGER trigger_hr_offboarding_started
AFTER INSERT ON hr_offboarding_instances
FOR EACH ROW
EXECUTE FUNCTION hr_publish_offboarding_started();