Plan: SNAP ABAWD Work Requirements

CREATE TABLE abawd_tracking (
    id UUID PRIMARY KEY,
    person_id UUID NOT NULL,
    household_id UUID NOT NULL,
    -- The 36-month tracking window. Reset when a new window starts after re-qualifying.
    window_start_date DATE NOT NULL,
    window_end_date DATE NOT NULL,  -- window_start_date + 36 months
    months_used INTEGER NOT NULL DEFAULT 0,  -- months of SNAP receipt without qualifying activity
    current_status TEXT NOT NULL DEFAULT 'tracking',
    -- 'exempt', 'tracking', 'time_limit_reached', 'regaining', 'waiver_area'
    exemption_type TEXT,
    -- 'pregnancy', 'disability_unfit', 'dependent_child_under_18',
    -- 'incapacitated_dependent', 'discretionary', 'waiver_area'
    exemption_expires DATE,
    discretionary_exemption_id UUID,  -- references abawd_discretionary_exemptions if applicable
    waiver_area_code TEXT,
    created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
    updated_at TIMESTAMPTZ NOT NULL DEFAULT now(),
    active BOOLEAN NOT NULL DEFAULT true
);

CREATE UNIQUE INDEX abawd_tracking_person_active ON abawd_tracking (person_id) WHERE active = true;

CREATE TABLE abawd_monthly_activity (
    id UUID PRIMARY KEY,
    person_id UUID NOT NULL,
    abawd_tracking_id UUID NOT NULL REFERENCES abawd_tracking(id),
    benefit_month DATE NOT NULL,  -- first day of month
    hours_worked SMALLINT NOT NULL DEFAULT 0,
    hours_job_search SMALLINT NOT NULL DEFAULT 0,
    hours_training SMALLINT NOT NULL DEFAULT 0,
    hours_community_service SMALLINT NOT NULL DEFAULT 0,
    hours_self_employment SMALLINT NOT NULL DEFAULT 0,
    total_hours SMALLINT GENERATED ALWAYS AS (
        hours_worked + hours_job_search + hours_training +
        hours_community_service + hours_self_employment
    ) STORED,
    -- NOTE: The 80-hour threshold is the federal default (7 CFR 273.24).
    -- Do NOT hardcode in SQL — qualifying_month must be computed in application
    -- code using the threshold from jurisdiction.toml [snap.abawd] qualifying_hours_per_month.
    -- The GENERATED ALWAYS AS columns below use 80 as a placeholder; in production,
    -- replace with a view or application-level computation that reads the config value.
    qualifying_month BOOLEAN GENERATED ALWAYS AS (
        hours_worked + hours_job_search + hours_training +
        hours_community_service + hours_self_employment >= 80
    ) STORED,
    counts_against_limit BOOLEAN GENERATED ALWAYS AS (
        hours_worked + hours_job_search + hours_training +
        hours_community_service + hours_self_employment < 80
    ) STORED,
    snap_received BOOLEAN NOT NULL DEFAULT true,  -- did this person receive SNAP this month?
    reported_by TEXT NOT NULL DEFAULT 'self_attestation',
    verified BOOLEAN NOT NULL DEFAULT false,
    created_at TIMESTAMPTZ NOT NULL DEFAULT now()
);

CREATE UNIQUE INDEX abawd_activity_month ON abawd_monthly_activity (person_id, benefit_month);

CREATE TABLE abawd_discretionary_exemptions (
    id UUID PRIMARY KEY,
    fiscal_year SMALLINT NOT NULL,  -- e.g., 2026
    quota_allocated INTEGER NOT NULL,  -- 12% of state ABAWD caseload
    quota_used INTEGER NOT NULL DEFAULT 0,
    quota_remaining INTEGER GENERATED ALWAYS AS (quota_allocated - quota_used) STORED,
    created_at TIMESTAMPTZ NOT NULL DEFAULT now()
);

CREATE TABLE abawd_discretionary_exemption_grants (
    id UUID PRIMARY KEY,
    exemption_pool_id UUID NOT NULL REFERENCES abawd_discretionary_exemptions(id),
    person_id UUID NOT NULL,
    fiscal_year SMALLINT NOT NULL,
    granted_at TIMESTAMPTZ NOT NULL DEFAULT now(),
    granted_by UUID NOT NULL,  -- worker person_id
    reason TEXT,
    active BOOLEAN NOT NULL DEFAULT true
);

CREATE TABLE abawd_waiver_areas (
    id UUID PRIMARY KEY,
    jurisdiction TEXT NOT NULL DEFAULT 'georgia',
    area_code TEXT NOT NULL,  -- FIPS county code or custom area identifier
    area_name TEXT NOT NULL,
    waiver_start_date DATE NOT NULL,
    waiver_end_date DATE,  -- null if ongoing
    fns_waiver_approval_number TEXT,
    created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
    active BOOLEAN NOT NULL DEFAULT true
);

{
  "person": {
    "age": 25,
    "is_pregnant": false,
    "disability_unfit_for_employment": false,
    "dependent_children_under_18": 0,
    "incapacitated_dependents": 0,
    "waiver_area_code": null
  }
}

{
  "is_abawd": true,
  "exemption_type": null
}

CREATE INDEX idx_abawd_tracking_household ON abawd_tracking (household_id);
CREATE INDEX idx_abawd_tracking_status ON abawd_tracking (current_status) WHERE active = true;
CREATE INDEX idx_abawd_activity_tracking ON abawd_monthly_activity (abawd_tracking_id);
CREATE INDEX idx_abawd_discretionary_grants_pool ON abawd_discretionary_exemption_grants (exemption_pool_id) WHERE active = true;
CREATE INDEX idx_abawd_waiver_areas_active ON abawd_waiver_areas (area_code) WHERE active = true;

// SPDX-License-Identifier: AGPL-3.0-or-later

use axum::{Router, routing::{get, post}, extract::{Path, Query, State}, Json};
use canopy_api::AppState;
use uuid::Uuid;

pub fn routes() -> Router<AppState> {
    Router::new()
        .route("/v1/abawd/:person_id", get(get_abawd_status))
        .route("/v1/abawd/:person_id/activity", post(record_monthly_activity))
        .route("/v1/abawd/:person_id/exemption", post(grant_discretionary_exemption))
        .route("/v1/abawd/exemptions/quota", get(get_quota_status))
        .route("/v1/abawd/waiver-areas", get(list_waiver_areas))
}

/// Run ABAWD evaluation for each household member aged 18-49.
/// Returns the list of person_ids that are ABAWD-excluded for this benefit month.
pub async fn evaluate_abawd_members(
    pool: &PgPool,
    abawd_tracker: &AbawdTracker,
    household_members: &[HouseholdMember],
    benefit_month: NaiveDate,
) -> Result<Vec<AbawdEvaluation>> {
    // For each member age 18-49:
    // 1. Call abawd_tracker.evaluate_abawd_status(person_id, household_id)
    // 2. If is_abawd && !exempt: call abawd_tracker.process_benefit_month(person_id, benefit_month)
    // 3. If time_limit_reached: mark person as ineligible for this month
    // 4. Return AbawdEvaluation { person_id, is_abawd, exempt, months_used, excluded }
}

use canopy_mq::publisher::EventPublisher;

pub async fn publish_abawd_warning(
    publisher: &EventPublisher,
    event_type: &str,  // "abawd.warning_month_1", "abawd.warning_month_2", "abawd.time_limit_reached"
    person_id: Uuid,
    household_id: Uuid,
    months_used: i32,
) -> Result<()> {
    // Publish to canopy.events topic exchange with routing key = event_type
    // Payload: { person_id, household_id, months_used, benefit_month }
    // Per ADR-004: no income, SSN, or IEVS data in events
}

// SPDX-License-Identifier: AGPL-3.0-or-later

use canopy_test_lib::{setup_test_db, mock_event_publisher};
use canopy_snap::abawd::AbawdTracker;

#[tokio::test]
async fn test_age_55_not_abawd() { /* age 55 -> evaluate_abawd_status returns is_abawd=false */ }

#[tokio::test]
async fn test_dependent_child_not_abawd() { /* age 35 + dependent child -> is_abawd=false, exemption_type="dependent_child_under_18" */ }

#[tokio::test]
async fn test_abawd_month_1_warning() { /* age 35, no activity, month 1 -> months_used=1, warning event published */ }

#[tokio::test]
async fn test_abawd_month_3_exhausted() { /* 3 consecutive months without qualifying activity -> status=time_limit_reached, determination=AbawdExceeded */ }

#[tokio::test]
async fn test_discretionary_exemption_granted() { /* grant exemption -> status=exempt, determination approved */ }

#[tokio::test]
async fn test_discretionary_exemption_quota_exhausted() { /* quota_remaining=0 -> grant returns 409 Conflict */ }

#[tokio::test]
async fn test_waiver_area_exempt() { /* FIPS code in abawd_waiver_areas -> exempt */ }

#[tokio::test]
async fn test_regaining_eligibility() { /* after time_limit_reached, 3 qualifying months -> status back to tracking, months_used reset */ }