Breathe Better — Mini Game

flowchart TD
  subgraph W1[1) AI Data Pipeline for Pollution Monitoring]
    A1[Cron: Hourly Trigger] --> A2[HTTP Request: EPA Crawl]
    A2 --> A3[HTTP Request: Weather API]
    A2 --> A4[LLM: Data Cleaner & Unit Normalizer]
    A3 --> A4
    A4 --> A5[Function: Merge + Impute]
    A5 --> A6[ML: Anomaly Detector]
    A6 -->|spike| A7[Telegram/LINE Notify]
    A5 --> A8[Postgres: upsert aqi_readings]
    A6 --> A9[Webhook: /api/aqi-feed]
  end

flowchart TD
  subgraph W2[2) Economic & Health Impact]
    B1[Cron: Daily] --> B2[DB: Fetch aqi_readings]
    B2 --> B3[Function: Dose-Response Calc]
    B3 --> B4[LLM: Risk Narratives per District]
    B3 --> B5[Function: Cost-Benefit Model]
    B4 --> B6[Webhook: /api/health-impact]
    B5 --> B7[Webhook: /api/cost-impact]
  end

flowchart TD
  subgraph W3[3) Policy & Market Intelligence]
    C1[Cron: Weekly] --> C2[HTTP: Policy Feeds (EU/CA/JP)]
    C1 --> C3[HTTP: EV Adoption & Charging APIs]
    C2 --> C4[LLM: Summarize & Benchmark vs Taiwan]
    C3 --> C5[LLM: Market Signals & Sentiment]
    C4 --> C6[Webhook: /api/policy]
    C5 --> C7[Webhook: /api/market]
  end

flowchart TD
  subgraph W4[4) Personal Advisor]
    D1[Webhook: /api/advisor-request] --> D2[DB: latest AQI by district]
    D2 --> D3[LLM: Personal Plan Generator]
    D3 --> D4[Return JSON with steps & timing]
  end

flowchart TD
  subgraph W5[5) Scenario Simulator / Predictor]
    E1[HTTP: User selection payload] --> E2[DB: Baseline AQI + Emissions]
    E2 --> E3[Function: Policy Mix Params]
    E3 --> E4[ML: Time-series Forecast (Prophet/XGBoost)]
    E4 --> E5[LLM: Outcome Narratives + KPIs]
    E4 --> E6[Webhook: /api/scenario]
  end