Case Routing Rule Set

[Input] → [Assignment Area Table] → [Worker Selection Table] → [Output]

{
  "name": "georgia-case-routing",
  "version": "v1.0",
  "description": "Georgia DFCS case routing decision per Policy Chapter 4. Determines assignment area and routing method based on geography, allegation type, priority, and caseload. Uses two-stage decision: geographic/functional area assignment, then worker selection method.",
  "nodes": [
    {
      "id": "input",
      "name": "Input",
      "type": "inputNode"
    },
    {
      "id": "assignment-area",
      "name": "Assignment Area Determination",
      "type": "decisionTableNode",
      "content": {
        "hitPolicy": "first",
        "inputs": [
          { "id": "i_admin", "name": "Administrative Unit", "field": "admin_unit" },
          { "id": "i_allege", "name": "Allegation Type", "field": "allegation_type" },
          { "id": "i_icwa", "name": "ICWA Flag", "field": "icwa_flag" },
          { "id": "i_special", "name": "Special Unit Needed", "field": "special_unit_needed" }
        ],
        "outputs": [
          { "id": "o_area", "name": "Assignment Area", "field": "assignment_area" }
        ],
        "rules": [...]
      }
    },
    {
      "id": "worker-selection",
      "name": "Worker Selection Method",
      "type": "decisionTableNode",
      "content": {
        "hitPolicy": "first",
        "inputs": [
          { "id": "i_area", "name": "Assignment Area", "field": "assignment_area" },
          { "id": "i_priority", "name": "Priority", "field": "priority" },
          { "id": "i_caseload", "name": "Caseload Tier", "field": "caseload_tier" }
        ],
        "outputs": [
          { "id": "o_decision", "name": "Routing Decision", "field": "routing_decision" },
          { "id": "o_method", "name": "Assignment Method", "field": "assignment_method" },
          { "id": "o_hours", "name": "Max Response Hours", "field": "max_response_hours" },
          { "id": "o_notes", "name": "Routing Notes", "field": "routing_notes" }
        ],
        "rules": [...]
      }
    },
    {
      "id": "output",
      "name": "Output",
      "type": "outputNode"
    }
  ],
  "edges": [
    { "id": "e1", "sourceId": "input", "targetId": "assignment-area", "type": "edge" },
    { "id": "e2", "sourceId": "assignment-area", "targetId": "worker-selection", "type": "edge" },
    { "id": "e3", "sourceId": "worker-selection", "targetId": "output", "type": "edge" }
  ]
}

// In handle_domain_event match:
"case.referral_created" => {
    // Existing: evaluates {jurisdiction}-intake-screening
    // Add: also evaluate {jurisdiction}-case-routing with the referral data
    let routing_input = json!({
        "admin_unit": payload["admin_unit"],
        "allegation_type": payload["concern_type"],
        "priority": screening_result["priority"],  // from intake-screening output
        "caseload_tier": "medium",  // placeholder — real caseload data requires worker registry
        "icwa_flag": payload.get("icwa_flag").and_then(|v| v.as_bool()).unwrap_or(false),
        "special_unit_needed": "none",
    });
    evaluate_and_publish(&engine, &publisher, &format!("{jurisdiction}-case-routing"), routing_input).await;
}

curl -X POST http://localhost:8001/v1/rules/evaluate \
  -H "Authorization: Bearer $TOKEN" \
  -d '{"rule_set": "georgia-case-routing", "input": {"admin_unit": "Fulton", ...}}'

// Test 1: georgia_case_routing_sexual_abuse_routes_to_special_investigations
// Input: admin_unit="Fulton", allegation_type="sexual_abuse", priority="STANDARD",
//        caseload_tier="low", icwa_flag=false, special_unit_needed="none"
// Expected: assignment_area="special_investigations", routing_decision="specialty_unit",
//           assignment_method="round_robin"

// Test 2: georgia_case_routing_immediate_high_caseload_goes_to_supervisor
// Input: admin_unit="Fulton", allegation_type="neglect", priority="IMMEDIATE",
//        caseload_tier="high", icwa_flag=false, special_unit_needed="none"
// Expected: routing_decision="supervisor_queue", assignment_method="manual"

// Test 3: georgia_case_routing_standard_low_caseload_auto_assigns
// Input: admin_unit="Chatham", allegation_type="neglect", priority="STANDARD",
//        caseload_tier="low", icwa_flag=false, special_unit_needed="none"
// Expected: assignment_area="coastal", routing_decision="auto_assign",
//           assignment_method="round_robin"

// Test 4: georgia_case_routing_icwa_flag_routes_to_icwa_specialist
// Input: admin_unit="Fulton", allegation_type="neglect", priority="STANDARD",
//        caseload_tier="low", icwa_flag=true, special_unit_needed="none"
// Expected: assignment_area="icwa_specialist"

// Test 5: texas_case_routing_p1_auto_assigns_lowest_caseload
// Input: admin_unit="Harris", allegation_type="physical_abuse", priority="P1",
//        caseload_tier="medium", icwa_flag=false, special_unit_needed="none"
// Expected: routing_decision="auto_assign", assignment_method="lowest_caseload",
//           max_response_hours=24

// Test 6: texas_case_routing_institutional_abuse_routes_to_special_unit
// Input: admin_unit="Dallas", allegation_type="physical_abuse", priority="P2",
//        caseload_tier="low", icwa_flag=false, special_unit_needed="institutional_abuse_unit"
// Expected: routing_decision="specialty_unit"

let harness = TestHarness::new().await.unwrap();
let client = harness.admin_rules_client().await.unwrap();
let resp = client
    .post("/v1/rules/evaluate")
    .json(&json!({
        "rule_set": "georgia-case-routing",
        "input": { ... }
    }))
    .send()
    .await
    .unwrap();
assert_eq!(resp.status(), 200);
let body: Value = resp.json().await.unwrap();
assert_eq!(body["result"]["assignment_area"], "special_investigations");