n8n for AgriTech & Precision Agriculture SaaS: USDA NOP, EPA FIFRA, FDA FSMA §204 and CWA §404 Compliance (Free JSON)

{
  "name": "USDA NOP Organic Cert & EQIP Payment Deadline Tracker",
  "nodes": [
    {
      "name": "Every Weekday 7AM",
      "type": "n8n-nodes-base.scheduleTrigger",
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 7 * * 1-5"
            }
          ]
        }
      },
      "position": [
        200,
        300
      ]
    },
    {
      "name": "Load NOP & EQIP Deadlines",
      "type": "n8n-nodes-base.googleSheets",
      "parameters": {
        "operation": "readRows",
        "sheetId": "={{$vars.AGRI_COMPLIANCE_SHEET_ID}}",
        "range": "NOP_EQIP_Deadlines!A:H",
        "headerRow": true,
        "returnAllMatchingRows": true
      },
      "position": [
        400,
        300
      ]
    },
    {
      "name": "Evaluate Urgency",
      "type": "n8n-nodes-base.code",
      "parameters": {
        "language": "javascript",
        "jsCode": "const today = new Date();\nconst rows = $input.all().map(i => i.json);\nconst NOP_DEADLINE_TYPES = {\n  NOP_ANNUAL_UPDATE: { citation: '7 CFR \u00a7205.406(a)', description: 'NOP annual update \u2014 must file within 12 months of cert date', consequence: 'Certification lapse \u2014 organic claims prohibited' },\n  NOP_TRANSITION_YEAR1: { citation: '7 CFR \u00a7205.202(b)', description: 'Year 1 of 3-year organic transition \u2014 no prohibited substances for 12 months', consequence: 'Transition clock reset if violation' },\n  NOP_TRANSITION_YEAR2: { citation: '7 CFR \u00a7205.202(b)', description: 'Year 2 of transition', consequence: 'Full 3-year restart if prohibited input detected' },\n  NOP_TRANSITION_YEAR3: { citation: '7 CFR \u00a7205.202(b)', description: 'Year 3 \u2014 can certify after this year clears', consequence: 'Cannot certify until 36 months clean' },\n  NOP_OSP_ANNUAL_REVIEW: { citation: '7 CFR \u00a7205.406(a)', description: 'Organic System Plan annual review with certifier', consequence: 'Certification suspended pending review' },\n  NOP_INPUT_AUDIT: { citation: '7 CFR \u00a7205.103(b)', description: '5-year input record retention audit window', consequence: 'NOP inspector access required' },\n  EQIP_APPLICATION_WINDOW: { citation: 'Farm Bill \u00a71240B', description: 'EQIP practice application window \u2014 published quarterly by NRCS state office', consequence: 'No extensions \u2014 missed window = wait next cycle' },\n  CSP_RENEWAL: { citation: 'Farm Bill \u00a71240I', description: 'Conservation Stewardship Program 5-year renewal', consequence: 'Lapse in stewardship payment stream' },\n  NRCS_PRACTICE_REVIEW: { citation: '7 CFR Part 12', description: 'NRCS conservation practice annual compliance review', consequence: 'EQIP payment withheld if non-compliant' },\n  WATER_RIGHTS_ANNUAL_REPORT: { citation: 'State water code \u2014 prior appropriation states', description: 'Annual water use report to state engineer', consequence: 'Water right forfeiture in prior appropriation states' }\n};\nconst alerts = [];\nfor (const row of rows) {\n  const deadline = new Date(row.deadline_date);\n  const daysUntil = Math.floor((deadline - today) / 86400000);\n  const dtype = row.deadline_type;\n  const meta = NOP_DEADLINE_TYPES[dtype] || { citation: row.regulation, description: row.description, consequence: row.consequence };\n  let urgency;\n  if (daysUntil < 0) urgency = 'OVERDUE';\n  else if (daysUntil <= 7) urgency = 'CRITICAL';\n  else if (daysUntil <= 21) urgency = 'URGENT';\n  else if (daysUntil <= 45) urgency = 'WARNING';\n  else if (daysUntil <= 90) urgency = 'NOTICE';\n  else continue;\n  alerts.push({ ...row, ...meta, urgency, daysUntil, farmId: row.farm_id, farmName: row.farm_name, certifier: row.certifier_name, deadlineDisplay: deadline.toISOString().split('T')[0] });\n}\nreturn alerts.map(a => ({ json: a }));"
      },
      "position": [
        600,
        300
      ]
    },
    {
      "name": "Has Alerts?",
      "type": "n8n-nodes-base.if",
      "parameters": {
        "conditions": {
          "number": [
            {
              "value1": "={{$items().length}}",
              "operation": "larger",
              "value2": 0
            }
          ]
        }
      },
      "position": [
        800,
        300
      ]
    },
    {
      "name": "Notify Compliance Team",
      "type": "n8n-nodes-base.slack",
      "parameters": {
        "channel": "#agri-compliance-alerts",
        "text": "={{$json.urgency}} \u2014 {{$json.farmName}} \u2014 {{$json.deadline_type}} due {{$json.deadlineDisplay}} ({{$json.daysUntil}}d). {{$json.citation}}: {{$json.consequence}}"
      },
      "position": [
        1000,
        200
      ]
    },
    {
      "name": "Email Farm Account Manager",
      "type": "n8n-nodes-base.gmail",
      "parameters": {
        "to": "={{$json.account_manager_email}}",
        "subject": "={{$json.urgency}}: {{$json.farmName}} \u2014 {{$json.deadline_type}} due {{$json.deadlineDisplay}}",
        "message": "={{$json.description}} | {{$json.citation}} | Consequence if missed: {{$json.consequence}}"
      },
      "position": [
        1000,
        400
      ]
    }
  ],
  "connections": {
    "Every Weekday 7AM": {
      "main": [
        [
          {
            "node": "Load NOP & EQIP Deadlines",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Load NOP & EQIP Deadlines": {
      "main": [
        [
          {
            "node": "Evaluate Urgency",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Evaluate Urgency": {
      "main": [
        [
          {
            "node": "Has Alerts?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Has Alerts?": {
      "main": [
        [
          {
            "node": "Notify Compliance Team",
            "type": "main",
            "index": 0
          }
        ],
        []
      ]
    },
    "Notify Compliance Team": {
      "main": [
        [
          {
            "node": "Email Farm Account Manager",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}

{
  "name": "EPA FIFRA Pesticide Compliance & Misuse Monitor",
  "nodes": [
    {
      "name": "Webhook \u2014 Pesticide Application Event",
      "type": "n8n-nodes-base.webhook",
      "parameters": {
        "path": "fifra-pesticide-application",
        "httpMethod": "POST"
      },
      "position": [
        200,
        300
      ]
    },
    {
      "name": "Validate Application Against Label",
      "type": "n8n-nodes-base.code",
      "parameters": {
        "language": "javascript",
        "jsCode": "const event = $json;\nconst FIFRA_VIOLATION_TYPES = {\n  CANCELLED_REGISTRATION: { citation: 'EPA FIFRA \u00a7136d(a)', severity: 'CRITICAL', description: 'Pesticide registration cancelled or suspended \u2014 no legal use after effective date', consequence: '$10,000/day civil penalty or 1-year criminal for knowing violations' },\n  RUP_NO_CERTIFIED_APPLICATOR: { citation: 'EPA FIFRA \u00a7136i', severity: 'CRITICAL', description: 'Restricted Use Pesticide applied without certified applicator on record', consequence: 'EPA \u00a7136l civil penalty, state ag department enforcement' },\n  OFF_LABEL_RATE: { citation: 'EPA FIFRA \u00a7136j(a)(2)(G)', severity: 'HIGH', description: 'Application rate exceeds label maximum \u2014 off-label use prohibited', consequence: 'Civil penalty, nullifies crop insurance coverage for that field' },\n  OFF_LABEL_CROP: { citation: 'EPA FIFRA \u00a7136j(a)(2)(G)', severity: 'HIGH', description: 'Pesticide applied to crop not listed on label', consequence: 'EPA violation + state DOA violation in most states' },\n  PRE_HARVEST_INTERVAL_VIOLATION: { citation: 'FIFRA label PHI requirement', severity: 'HIGH', description: 'Application within pre-harvest interval \u2014 residues at harvest will exceed tolerance', consequence: 'FDA tolerance violation, potential recall, crop rejection' },\n  RESTRICTED_ENTRY_INTERVAL: { citation: 'EPA FIFRA Worker Protection Standard 40 CFR Part 170', severity: 'MEDIUM', description: 'Field worker entry during restricted entry interval after application', consequence: 'WPS violation, OSHA citation' },\n  LABEL_AMENDMENT_NOT_APPLIED: { citation: 'EPA FIFRA \u00a7136a(c)(9)(B)', severity: 'MEDIUM', description: 'Using superseded label \u2014 active label amendment not applied in platform', consequence: 'Off-label use for requirements in amendment' }\n};\nconst violations = [];\nif (event.epa_reg_status === 'CANCELLED' || event.epa_reg_status === 'SUSPENDED') {\n  violations.push({ ...FIFRA_VIOLATION_TYPES.CANCELLED_REGISTRATION, field: event.field_id, product: event.pesticide_name, epaRegNo: event.epa_reg_no });\n}\nif (event.rup_flag === true && !event.certified_applicator_id) {\n  violations.push({ ...FIFRA_VIOLATION_TYPES.RUP_NO_CERTIFIED_APPLICATOR, field: event.field_id, product: event.pesticide_name });\n}\nif (parseFloat(event.application_rate_ozac) > parseFloat(event.label_max_rate_ozac)) {\n  violations.push({ ...FIFRA_VIOLATION_TYPES.OFF_LABEL_RATE, field: event.field_id, appliedRate: event.application_rate_ozac, labelMaxRate: event.label_max_rate_ozac });\n}\nif (!event.label_registered_crops?.includes(event.target_crop)) {\n  violations.push({ ...FIFRA_VIOLATION_TYPES.OFF_LABEL_CROP, field: event.field_id, targetCrop: event.target_crop });\n}\nconst daysTilHarvest = event.days_til_harvest ? parseInt(event.days_til_harvest) : 999;\nif (daysTilHarvest < parseInt(event.label_phi_days || 0)) {\n  violations.push({ ...FIFRA_VIOLATION_TYPES.PRE_HARVEST_INTERVAL_VIOLATION, field: event.field_id, daysTilHarvest, phi: event.label_phi_days });\n}\nreturn violations.length > 0\n  ? violations.map(v => ({ json: { ...v, farmId: event.farm_id, farmName: event.farm_name, applicationTs: event.timestamp, applicationId: event.application_id } }))\n  : [{ json: { no_violations: true, applicationId: event.application_id } }];"
      },
      "position": [
        400,
        300
      ]
    },
    {
      "name": "Violation Detected?",
      "type": "n8n-nodes-base.if",
      "parameters": {
        "conditions": {
          "boolean": [
            {
              "value1": "={{!!$json.severity}}",
              "operation": "equal",
              "value2": true
            }
          ]
        }
      },
      "position": [
        600,
        300
      ]
    },
    {
      "name": "Alert CRITICAL to Slack",
      "type": "n8n-nodes-base.slack",
      "parameters": {
        "channel": "#fifra-compliance-critical",
        "text": "{{$json.severity}} FIFRA VIOLATION \u2014 Farm: {{$json.farmName}} | Field: {{$json.field}} | {{$json.citation}}: {{$json.description}} | Consequence: {{$json.consequence}}"
      },
      "position": [
        800,
        200
      ]
    },
    {
      "name": "Log to Postgres",
      "type": "n8n-nodes-base.postgres",
      "parameters": {
        "operation": "insert",
        "table": "fifra_compliance_log",
        "columns": "farm_id, field_id, application_id, violation_type, severity, citation, description, consequence, detected_at",
        "values": "={{$json.farmId}}, {{$json.field}}, {{$json.applicationId}}, '{{$json.severity}}', '{{$json.citation}}', '{{$json.description}}', '{{$json.consequence}}', NOW()"
      },
      "position": [
        800,
        400
      ]
    },
    {
      "name": "Respond 200",
      "type": "n8n-nodes-base.respondToWebhook",
      "parameters": {
        "responseCode": 200,
        "responseBody": "={\"received\":true,\"violations\":{{$items().length}}}"
      },
      "position": [
        1000,
        300
      ]
    }
  ],
  "connections": {
    "Webhook \u2014 Pesticide Application Event": {
      "main": [
        [
          {
            "node": "Validate Application Against Label",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Validate Application Against Label": {
      "main": [
        [
          {
            "node": "Violation Detected?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Violation Detected?": {
      "main": [
        [
          {
            "node": "Alert CRITICAL to Slack",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Respond 200",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Alert CRITICAL to Slack": {
      "main": [
        [
          {
            "node": "Log to Postgres",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Log to Postgres": {
      "main": [
        [
          {
            "node": "Respond 200",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}

{
  "name": "FDA FSMA \u00a7204 FTL KDE/CTE Compliance Pipeline",
  "nodes": [
    {
      "name": "Webhook \u2014 Lot Traceability Event",
      "type": "n8n-nodes-base.webhook",
      "parameters": {
        "path": "fsma-lot-traceability",
        "httpMethod": "POST"
      },
      "position": [
        200,
        300
      ]
    },
    {
      "name": "Validate KDEs by CTE Type",
      "type": "n8n-nodes-base.code",
      "parameters": {
        "language": "javascript",
        "jsCode": "const event = $json;\nconst FTL_CTE_REQUIREMENTS = {\n  GROWING_SITE: {\n    citation: '21 CFR \u00a71.1320(a) \u2014 Growing CTE',\n    required_kdes: ['traceability_lot_code', 'commodity_description', 'quantity_and_uom', 'unit_of_measure', 'location_description_growing_area', 'location_description_cool_or_pack', 'date_harvested'],\n    ftl_foods: ['leafy_greens', 'herbs', 'cucumbers', 'peppers', 'sprouts', 'tomatoes', 'melons']\n  },\n  HARVESTING: {\n    citation: '21 CFR \u00a71.1325(a) \u2014 Harvesting CTE',\n    required_kdes: ['traceability_lot_code', 'commodity_description', 'quantity_and_uom', 'location_description_harvesting', 'location_description_cool_or_pack', 'date_harvested', 'reference_document'],\n    ftl_foods: ['leafy_greens', 'herbs', 'cucumbers', 'peppers', 'sprouts', 'tomatoes', 'melons', 'fresh_cut']\n  },\n  COOLING: {\n    citation: '21 CFR \u00a71.1330(a) \u2014 Cooling CTE (before first receiver)',\n    required_kdes: ['traceability_lot_code', 'location_description_cooling', 'date_of_cooling', 'quantity_and_uom', 'reference_document'],\n    ftl_foods: ['leafy_greens', 'fresh_cut', 'finfish', 'crustaceans']\n  },\n  FIRST_RECEIVER: {\n    citation: '21 CFR \u00a71.1335(a) \u2014 First Receiver CTE',\n    required_kdes: ['traceability_lot_code', 'commodity_description', 'quantity_and_uom', 'location_description_first_receiver', 'date_received', 'location_description_immediate_subsequent_recipient', 'reference_document'],\n    ftl_foods: ['all_ftl']\n  },\n  SHIPPING: {\n    citation: '21 CFR \u00a71.1345(a) \u2014 Shipping CTE',\n    required_kdes: ['traceability_lot_code', 'quantity_and_uom', 'location_description_immediate_next', 'date_of_shipment', 'reference_document'],\n    ftl_foods: ['all_ftl']\n  }\n};\nconst cte = event.cte_type;\nconst requirements = FTL_CTE_REQUIREMENTS[cte];\nif (!requirements) {\n  return [{ json: { valid: true, unknown_cte: cte, lot_code: event.traceability_lot_code } }];\n}\nconst missingKDEs = requirements.required_kdes.filter(kde => !event[kde] || event[kde] === '' || event[kde] === null);\nconst lotCode = event.traceability_lot_code;\nif (missingKDEs.length > 0) {\n  return [{ json: {\n    violation: true, cte_type: cte, citation: requirements.citation,\n    lot_code: lotCode, commodity: event.commodity_description,\n    missing_kdes: missingKDEs, missing_count: missingKDEs.length,\n    farm_id: event.farm_id, farm_name: event.farm_name,\n    event_ts: event.event_timestamp,\n    consequence: 'FSMA \u00a7204 traceability failure \u2014 FDA 483 observation, Warning Letter, injunction risk. Must maintain complete KDE records 2 years from receipt (21 CFR \u00a71.1355(c)).'\n  }}];\n}\nreturn [{ json: { valid: true, cte_type: cte, lot_code: lotCode, kdes_validated: requirements.required_kdes.length } }];"
      },
      "position": [
        400,
        300
      ]
    },
    {
      "name": "KDE Violation?",
      "type": "n8n-nodes-base.if",
      "parameters": {
        "conditions": {
          "boolean": [
            {
              "value1": "={{$json.violation === true}}",
              "operation": "equal",
              "value2": true
            }
          ]
        }
      },
      "position": [
        600,
        300
      ]
    },
    {
      "name": "Slack #fsma-traceability-alerts",
      "type": "n8n-nodes-base.slack",
      "parameters": {
        "channel": "#fsma-traceability-alerts",
        "text": "FSMA \u00a7204 KDE VIOLATION \u2014 Lot: {{$json.lot_code}} | Farm: {{$json.farm_name}} | CTE: {{$json.cte_type}} | Missing {{$json.missing_count}} KDEs: {{$json.missing_kdes}} | {{$json.citation}}"
      },
      "position": [
        800,
        200
      ]
    },
    {
      "name": "Log Violation to Postgres",
      "type": "n8n-nodes-base.postgres",
      "parameters": {
        "operation": "insert",
        "table": "fsma_kde_violations",
        "columns": "lot_code, farm_id, cte_type, citation, missing_kdes, commodity, event_ts, detected_at",
        "values": "='{{$json.lot_code}}', '{{$json.farm_id}}', '{{$json.cte_type}}', '{{$json.citation}}', '{{$json.missing_kdes}}', '{{$json.commodity}}', '{{$json.event_ts}}', NOW()"
      },
      "position": [
        800,
        400
      ]
    },
    {
      "name": "Respond to Webhook",
      "type": "n8n-nodes-base.respondToWebhook",
      "parameters": {
        "responseCode": 200,
        "responseBody": "={\"received\":true,\"violation\":{{$json.violation === true}}}"
      },
      "position": [
        1000,
        300
      ]
    }
  ],
  "connections": {
    "Webhook \u2014 Lot Traceability Event": {
      "main": [
        [
          {
            "node": "Validate KDEs by CTE Type",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Validate KDEs by CTE Type": {
      "main": [
        [
          {
            "node": "KDE Violation?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "KDE Violation?": {
      "main": [
        [
          {
            "node": "Slack #fsma-traceability-alerts",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Respond to Webhook",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Slack #fsma-traceability-alerts": {
      "main": [
        [
          {
            "node": "Log Violation to Postgres",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Log Violation to Postgres": {
      "main": [
        [
          {
            "node": "Respond to Webhook",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}

{
  "name": "EPA CWA \u00a7404 Wetlands & USDA Conservation Deadline Monitor",
  "nodes": [
    {
      "name": "Daily 8AM",
      "type": "n8n-nodes-base.scheduleTrigger",
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 8 * * *"
            }
          ]
        }
      },
      "position": [
        200,
        300
      ]
    },
    {
      "name": "Load Conservation Permits",
      "type": "n8n-nodes-base.googleSheets",
      "parameters": {
        "operation": "readRows",
        "sheetId": "={{$vars.CONSERVATION_PERMITS_SHEET_ID}}",
        "range": "CWA_Conservation_Deadlines!A:I",
        "headerRow": true
      },
      "position": [
        400,
        300
      ]
    },
    {
      "name": "Evaluate Conservation Deadlines",
      "type": "n8n-nodes-base.code",
      "parameters": {
        "language": "javascript",
        "jsCode": "const today = new Date();\nconst rows = $input.all().map(i => i.json);\nconst CONSERVATION_DEADLINE_TYPES = {\n  CWA_404_PERMIT_EXPIRY: { citation: 'CWA \u00a7404, 33 CFR Part 323', description: 'Army Corps \u00a7404 individual permit expiration', consequence: 'Any drainage or fill activity becomes \u00a7301(a) violation \u2014 $66,712/day civil penalty (2024 adjusted)' },\n  CWA_404_MITIGATION_ANNUAL: { citation: 'CWA \u00a7404(b)(1) Guidelines, 40 CFR Part 230', description: 'Annual mitigation monitoring report to Army Corps and EPA', consequence: 'Permit condition violation \u2014 Army Corps may suspend or revoke \u00a7404 authorization' },\n  ESA_SEC7_CONSULTATION: { citation: 'ESA \u00a77(a)(2)', description: 'Section 7 informal consultation with USFWS \u2014 federal nexus via USDA program', consequence: 'Jeopardize listed species finding = injunction on ag operations in area' },\n  HEL_CONSERVATION_PLAN: { citation: '16 USC \u00a73811 (HELC)', description: 'Highly Erodible Land conservation plan annual compliance review for FSA benefits', consequence: 'USDA program benefit ineligibility \u2014 crop insurance, EQIP, loans all suspended' },\n  WETLAND_RESERVATION: { citation: '16 USC \u00a73831 (CRP Wetland Enrollment)', description: 'CRP wetland reserve easement annual inspection', consequence: 'CRP annual rental payment withheld; potential easement violation' },\n  SWANCC_ISOLATED_WETLANDS: { citation: 'SWANCC v. Army Corps 2001 + Sackett v. EPA 2023', description: 'Post-Sackett jurisdictional determination renewal \u2014 isolated wetlands may require state permit if \u00a7404 no longer applies', consequence: 'State wetland permit violation if operating under assumed federal jurisdiction after Sackett' },\n  STATE_WATER_RIGHTS_REPORT: { citation: 'Prior appropriation doctrine \u2014 CO, WY, MT, ID, NV, UT, AZ, NM, OR, WA, CA, ND, SD, NE, KS, OK, TX', description: 'Annual water use and diversion report to state engineer', consequence: 'Water right forfeiture for non-use (varies by state); priority call risk in drought year' }\n};\nconst alerts = [];\nfor (const row of rows) {\n  const deadline = new Date(row.deadline_date);\n  const daysUntil = Math.floor((deadline - today) / 86400000);\n  const meta = CONSERVATION_DEADLINE_TYPES[row.deadline_type] || { citation: row.regulation, description: row.description, consequence: row.consequence };\n  let urgency;\n  if (daysUntil < 0) urgency = 'OVERDUE';\n  else if (daysUntil <= 14) urgency = 'CRITICAL';\n  else if (daysUntil <= 30) urgency = 'URGENT';\n  else if (daysUntil <= 60) urgency = 'WARNING';\n  else if (daysUntil <= 90) urgency = 'NOTICE';\n  else continue;\n  alerts.push({ ...row, ...meta, urgency, daysUntil, deadlineDisplay: deadline.toISOString().split('T')[0] });\n}\nreturn alerts.map(a => ({ json: a }));"
      },
      "position": [
        600,
        300
      ]
    },
    {
      "name": "Alerts Found?",
      "type": "n8n-nodes-base.if",
      "parameters": {
        "conditions": {
          "number": [
            {
              "value1": "={{$items().length}}",
              "operation": "larger",
              "value2": 0
            }
          ]
        }
      },
      "position": [
        800,
        300
      ]
    },
    {
      "name": "Slack #cwa-conservation-alerts",
      "type": "n8n-nodes-base.slack",
      "parameters": {
        "channel": "#cwa-conservation-alerts",
        "text": "={{$json.urgency}} \u2014 {{$json.farm_name}} \u2014 {{$json.deadline_type}} due {{$json.deadlineDisplay}} ({{$json.daysUntil}}d) | {{$json.citation}}: {{$json.consequence}}"
      },
      "position": [
        1000,
        200
      ]
    },
    {
      "name": "Email Compliance Officer",
      "type": "n8n-nodes-base.gmail",
      "parameters": {
        "to": "={{$json.compliance_officer_email}}",
        "subject": "={{$json.urgency}}: {{$json.farm_name}} \u2014 {{$json.deadline_type}} due {{$json.deadlineDisplay}}",
        "message": "={{$json.description}} | {{$json.citation}} | Consequence: {{$json.consequence}}"
      },
      "position": [
        1000,
        400
      ]
    }
  ],
  "connections": {
    "Daily 8AM": {
      "main": [
        [
          {
            "node": "Load Conservation Permits",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Load Conservation Permits": {
      "main": [
        [
          {
            "node": "Evaluate Conservation Deadlines",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Evaluate Conservation Deadlines": {
      "main": [
        [
          {
            "node": "Alerts Found?",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Alerts Found?": {
      "main": [
        [
          {
            "node": "Slack #cwa-conservation-alerts",
            "type": "main",
            "index": 0
          }
        ],
        []
      ]
    },
    "Slack #cwa-conservation-alerts": {
      "main": [
        [
          {
            "node": "Email Compliance Officer",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}

{
  "name": "Weekly AgriTech Platform Compliance & KPI Dashboard",
  "nodes": [
    {
      "name": "Monday 7AM",
      "type": "n8n-nodes-base.scheduleTrigger",
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 7 * * 1"
            }
          ]
        }
      },
      "position": [
        200,
        300
      ]
    },
    {
      "name": "Query FIFRA & FSMA Violations",
      "type": "n8n-nodes-base.postgres",
      "parameters": {
        "operation": "executeQuery",
        "query": "SELECT COUNT(*) FILTER (WHERE severity='CRITICAL') as fifra_critical, COUNT(*) FILTER (WHERE severity='HIGH') as fifra_high, COUNT(*) FILTER (WHERE detected_at >= NOW() - INTERVAL '7 days') as fifra_new_7d FROM fifra_compliance_log WHERE detected_at >= NOW() - INTERVAL '7 days'"
      },
      "position": [
        400,
        200
      ]
    },
    {
      "name": "Query FSMA KDE Failures",
      "type": "n8n-nodes-base.postgres",
      "parameters": {
        "operation": "executeQuery",
        "query": "SELECT COUNT(*) as kde_violations_7d, COUNT(DISTINCT lot_code) as lots_affected, COUNT(DISTINCT farm_id) as farms_affected FROM fsma_kde_violations WHERE detected_at >= NOW() - INTERVAL '7 days'"
      },
      "position": [
        400,
        400
      ]
    },
    {
      "name": "Merge KPI Data",
      "type": "n8n-nodes-base.merge",
      "parameters": {
        "mode": "mergeByIndex"
      },
      "position": [
        600,
        300
      ]
    },
    {
      "name": "Build Dashboard Report",
      "type": "n8n-nodes-base.code",
      "parameters": {
        "language": "javascript",
        "jsCode": "const fifra = $input.first().json;\nconst fsma = $input.last().json;\nconst fifraCritical = parseInt(fifra.fifra_critical || 0);\nconst fifraHigh = parseInt(fifra.fifra_high || 0);\nconst kdeViolations = parseInt(fsma.kde_violations_7d || 0);\nconst lotsAffected = parseInt(fsma.lots_affected || 0);\nconst farmsAffected = parseInt(fsma.farms_affected || 0);\nlet ragStatus = 'GREEN';\nlet ragColor = '#16a766';\nif (fifraCritical > 0 || kdeViolations > 3) { ragStatus = 'RED'; ragColor = '#fb4c2f'; }\nelse if (fifraHigh > 0 || kdeViolations > 0) { ragStatus = 'AMBER'; ragColor = '#ffad47'; }\nconst html = '<div style=\"font-family:sans-serif;max-width:700px\">'\n  + '<h2 style=\"background:' + ragColor + ';color:white;padding:12px\">AgriTech Compliance Dashboard \u2014 Week of ' + new Date().toISOString().split('T')[0] + ' \u2014 ' + ragStatus + '</h2>'\n  + '<table style=\"width:100%;border-collapse:collapse\">'\n  + '<tr style=\"background:#f3f3f3\"><th>Metric</th><th>This Week</th><th>Regulation</th></tr>'\n  + '<tr><td>FIFRA Critical Violations</td><td style=\"color:' + (fifraCritical>0?'#fb4c2f':'#16a766') + '\">' + fifraCritical + '</td><td>EPA FIFRA \u00a7136j(a)(2)(G)</td></tr>'\n  + '<tr><td>FIFRA High Violations</td><td style=\"color:' + (fifraHigh>0?'#ffad47':'#16a766') + '\">' + fifraHigh + '</td><td>EPA FIFRA \u00a7136i (RUP), \u00a7136d</td></tr>'\n  + '<tr><td>FSMA \u00a7204 KDE Violations</td><td style=\"color:' + (kdeViolations>0?'#fb4c2f':'#16a766') + '\">' + kdeViolations + '</td><td>21 CFR Part 1 Subpart S \u2014 eff. Jan 20 2026</td></tr>'\n  + '<tr><td>Lots Affected (FSMA)</td><td>' + lotsAffected + '</td><td>FTL crops: leafy greens, shell eggs, nut butters</td></tr>'\n  + '<tr><td>Farms Affected (FSMA)</td><td>' + farmsAffected + '</td><td>USDA NOP \u00a7205.103(b) 5-yr record retention</td></tr>'\n  + '</table>'\n  + '<p style=\"font-size:11px;color:#666\">BCC: compliance-officer@company.com \u2014 intentional for USDA NOP \u00a7205.103(b) audit trail and EPA FIFRA \u00a78 2-year record retention requirement. Self-hosted n8n: all ag compliance data stays inside VPC. Pesticide application records routed through cloud iPaaS expand EPA inspection scope under FIFRA \u00a78 inspection authority.</p>'\n  + '</div>';\nreturn [{ json: { html, ragStatus, fifraCritical, fifraHigh, kdeViolations, lotsAffected, farmsAffected } }];"
      },
      "position": [
        800,
        300
      ]
    },
    {
      "name": "Email VP Operations + CCO",
      "type": "n8n-nodes-base.gmail",
      "parameters": {
        "to": "vp-operations@company.com",
        "cc": "cco@company.com",
        "bcc": "compliance-officer@company.com",
        "subject": "=[{{$json.ragStatus}}] AgriTech Weekly Compliance Dashboard \u2014 FIFRA: {{$json.fifraCritical}} critical | FSMA KDE: {{$json.kdeViolations}} violations",
        "message": "={{$json.html}}",
        "messageType": "html"
      },
      "position": [
        1000,
        300
      ]
    }
  ],
  "connections": {
    "Monday 7AM": {
      "main": [
        [
          {
            "node": "Query FIFRA & FSMA Violations",
            "type": "main",
            "index": 0
          },
          {
            "node": "Query FSMA KDE Failures",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Query FIFRA & FSMA Violations": {
      "main": [
        [
          {
            "node": "Merge KPI Data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Query FSMA KDE Failures": {
      "main": [
        [
          {
            "node": "Merge KPI Data",
            "type": "main",
            "index": 1
          }
        ]
      ]
    },
    "Merge KPI Data": {
      "main": [
        [
          {
            "node": "Build Dashboard Report",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Build Dashboard Report": {
      "main": [
        [
          {
            "node": "Email VP Operations + CCO",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}