{ "edges": [ { "to": "fcae28cd-d96f-436f-849a-c37bd5fbc992", "from": "c5def029-6c26-4e86-95d1-c450028478ea", "toPort": "0", "fromPort": "0" }, { "to": "d056425b-4ac9-472c-b719-43a48f620c00", "from": "c5def029-6c26-4e86-95d1-c450028478ea", "toPort": "0", "fromPort": "1" }, { "to": "eb9876b9-9d8e-4b33-970a-44f4127c5ccc", "from": "fcae28cd-d96f-436f-849a-c37bd5fbc992", "toPort": "0", "fromPort": "0" }, { "to": "0732a5a9-3f99-45f8-be98-98a153e49537", "from": "46f49aa4-9f06-4f05-9124-dbc59982bd32", "toPort": "0", "fromPort": "ai_languageModel" }, { "to": "28c6a089-8fa9-4f07-9fc8-ddff34d2464d", "from": "6cfe2bca-abc4-487b-afa4-a703a4872c51", "toPort": "0", "fromPort": "0" }, { "to": "ff913bf0-34d6-421f-a56b-154d50a1a2f4", "from": "28c6a089-8fa9-4f07-9fc8-ddff34d2464d", "toPort": "0", "fromPort": "0" }, { "to": "d056425b-4ac9-472c-b719-43a48f620c00", "from": "eb9876b9-9d8e-4b33-970a-44f4127c5ccc", "toPort": "0", "fromPort": "0" }, { "to": "c5def029-6c26-4e86-95d1-c450028478ea", "from": "0732a5a9-3f99-45f8-be98-98a153e49537", "toPort": "0", "fromPort": "0" }, { "to": "0732a5a9-3f99-45f8-be98-98a153e49537", "from": "4a9e9a7d-cde5-459d-945c-fb7715e3996d", "toPort": "0", "fromPort": "ai_outputParser" }, { "to": "0732a5a9-3f99-45f8-be98-98a153e49537", "from": "574222db-ff63-48e2-b976-5671565b6084", "toPort": "0", "fromPort": "0" }, { "to": "b25edce2-2aa5-42a0-9d37-bcc68978cba2", "from": "d6d79de4-0bec-4773-913e-56e0729d0b9d", "toPort": "0", "fromPort": "ai_languageModel" }, { "to": "b25edce2-2aa5-42a0-9d37-bcc68978cba2", "from": "ead44960-92f3-469c-96fb-37fbff3ed761", "toPort": "0", "fromPort": "ai_outputParser" }, { "to": "574222db-ff63-48e2-b976-5671565b6084", "from": "ff913bf0-34d6-421f-a56b-154d50a1a2f4", "toPort": "0", "fromPort": "0" }, { "to": "6cfe2bca-abc4-487b-afa4-a703a4872c51", "from": "b25edce2-2aa5-42a0-9d37-bcc68978cba2", "toPort": "0", "fromPort": "0" }, { "to": "b25edce2-2aa5-42a0-9d37-bcc68978cba2", "from": "6327f8eb-6f67-4d01-ab54-46a95fc9110d", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "6327f8eb-6f67-4d01-ab54-46a95fc9110d", "name": "Gmail — Invoice Inbox", "type": "trigger", "params": { "kind": "n8n-nodes-base.gmailTrigger", "filters": { "includeSpamTrash": false }, "pollTimes": { "item": [ { "mode": "everyMinute" } ] } }, "position": [ 26448, 8016 ] }, { "id": "b25edce2-2aa5-42a0-9d37-bcc68978cba2", "name": "Extract Invoice Data", "type": "llm", "params": { "text": "=Extract all invoice data from this email.\n\nFrom: {{ $json.from }}\nSubject: {{ $json.subject }}\nBody: {{ $json.text || $json.snippet }}\n\nExtract the invoice number, vendor/supplier name, total amount (as a number), currency, invoice date, due date, and a list of line items if visible. If any field is not present, use null.", "prompt": "=Extract all invoice data from this email.\n\nFrom: {{ $json.from }}\nSubject: {{ $json.subject }}\nBody: {{ $json.text || $json.snippet }}\n\nExtract the invoice number, vendor/supplier name, total amount (as a number), currency, invoice date, due date, and a list of line items if visible. If any field is not present, use null.", "options": { "systemMessage": "You are an accounts payable assistant. Extract structured invoice data precisely from email content. Invoice numbers typically follow patterns like INV-12345, 2024-001, or similar. Amounts should be numeric only (no currency symbols). Dates should be ISO 8601 format (YYYY-MM-DD). If the email does not appear to be an invoice, set is_invoice to false.", "returnIntermediateSteps": false }, "provider": "openai", "promptType": "define", "approximated": true, "systemMessage": "You are an accounts payable assistant. Extract structured invoice data precisely from email content. Invoice numbers typically follow patterns like INV-12345, 2024-001, or similar. Amounts should be numeric only (no currency symbols). Dates should be ISO 8601 format (YYYY-MM-DD). If the email does not appear to be an invoice, set is_invoice to false.", "hasOutputParser": true }, "position": [ 26704, 8016 ] }, { "id": "d6d79de4-0bec-4773-913e-56e0729d0b9d", "name": "OpenAI — Extract", "type": "llm", "params": { "model": "gpt-4o", "options": { "temperature": 0 }, "provider": "openai", "temperature": 0 }, "position": [ 26592, 8208 ] }, { "id": "ead44960-92f3-469c-96fb-37fbff3ed761", "name": "Invoice Data Schema", "type": "passthrough", "params": { "mode": "noOp", "schemaType": "manual", "inputSchema": "{\"type\":\"object\",\"properties\":{\"invoice_number\":{\"type\":\"string\"},\"vendor_name\":{\"type\":\"string\"},\"amount\":{\"type\":\"number\"},\"currency\":{\"type\":\"string\"},\"invoice_date\":{\"type\":\"string\"},\"due_date\":{\"type\":\"string\"},\"line_items\":{\"type\":\"array\",\"items\":{\"type\":\"object\"}},\"is_invoice\":{\"type\":\"boolean\"}},\"required\":[\"invoice_number\",\"vendor_name\",\"amount\",\"currency\",\"is_invoice\"]}" }, "position": [ 26896, 8208 ] }, { "id": "6cfe2bca-abc4-487b-afa4-a703a4872c51", "name": "Check Duplicates", "type": "integration", "params": { "filters": { "conditions": [ { "keyName": "invoice_number", "keyValue": "={{ $json.output.invoice_number }}", "condition": "eq" } ] }, "service": "supabase", "tableId": "invoices", "operation": "getAll", "returnAll": true }, "position": [ 27024, 8016 ] }, { "id": "28c6a089-8fa9-4f07-9fc8-ddff34d2464d", "name": "Count Duplicates", "type": "code", "params": { "jsCode": "const dupRows = $input.all();\nconst invoice = $('Extract Invoice Data').first().json.output || {};\nreturn [{ json: {\n ...invoice,\n duplicate_count: dupRows.filter(r => !r.json.error).length\n}}];" }, "position": [ 27264, 8000 ] }, { "id": "ff913bf0-34d6-421f-a56b-154d50a1a2f4", "name": "Check Vendor History", "type": "integration", "params": { "filters": { "conditions": [ { "keyName": "vendor_name", "keyValue": "={{ $json.vendor_name }}", "condition": "eq" } ] }, "service": "supabase", "tableId": "vendors", "operation": "getAll", "returnAll": true }, "position": [ 27488, 8000 ] }, { "id": "574222db-ff63-48e2-b976-5671565b6084", "name": "Merge All Context", "type": "code", "params": { "jsCode": "const vendorRows = $input.all();\nconst invoiceCtx = $('Count Duplicates').first().json;\nconst vendors = vendorRows.filter(r => !r.json.error).map(r => r.json);\nconst vendor = vendors[0] || null;\nreturn [{ json: {\n ...invoiceCtx,\n vendor_known: !!vendor,\n vendor_avg_amount: vendor ? vendor.avg_amount : null,\n vendor_flagged: vendor ? (vendor.flagged || false) : false,\n vendor_total_invoices: vendor ? vendor.total_invoices : 0,\n vendor_last_invoice_date: vendor ? vendor.last_invoice_date : null,\n amount_deviation_pct: vendor && vendor.avg_amount > 0\n ? Math.round(((invoiceCtx.amount - vendor.avg_amount) / vendor.avg_amount) * 100)\n : null\n}}];" }, "position": [ 27808, 7984 ] }, { "id": "0732a5a9-3f99-45f8-be98-98a153e49537", "name": "Assess Fraud Risk", "type": "llm", "params": { "text": "=Assess the fraud risk for this invoice.\n\nInvoice Number: {{ $json.invoice_number }}\nVendor: {{ $json.vendor_name }}\nAmount: {{ $json.amount }} {{ $json.currency }}\nInvoice Date: {{ $json.invoice_date }}\nDue Date: {{ $json.due_date }}\n\nDuplicate Invoice Count (same number already in system): {{ $json.duplicate_count }}\nVendor Known in System: {{ $json.vendor_known }}\nVendor Previously Flagged: {{ $json.vendor_flagged }}\nVendor Average Invoice Amount: {{ $json.vendor_avg_amount }}\nAmount Deviation from Vendor Average: {{ $json.amount_deviation_pct }}%\nVendor Total Historical Invoices: {{ $json.vendor_total_invoices }}\n\nEvaluate the risk of fraud or payment error and provide a risk score and recommended action.", "prompt": "=Assess the fraud risk for this invoice.\n\nInvoice Number: {{ $json.invoice_number }}\nVendor: {{ $json.vendor_name }}\nAmount: {{ $json.amount }} {{ $json.currency }}\nInvoice Date: {{ $json.invoice_date }}\nDue Date: {{ $json.due_date }}\n\nDuplicate Invoice Count (same number already in system): {{ $json.duplicate_count }}\nVendor Known in System: {{ $json.vendor_known }}\nVendor Previously Flagged: {{ $json.vendor_flagged }}\nVendor Average Invoice Amount: {{ $json.vendor_avg_amount }}\nAmount Deviation from Vendor Average: {{ $json.amount_deviation_pct }}%\nVendor Total Historical Invoices: {{ $json.vendor_total_invoices }}\n\nEvaluate the risk of fraud or payment error and provide a risk score and recommended action.", "options": { "systemMessage": "You are an accounts payable fraud detection specialist. Evaluate invoices for: duplicate submissions, amounts significantly above vendor average (>50% deviation = high risk, >100% = critical), unknown vendors, previously flagged vendors, or suspicious timing patterns. Risk levels: low = approve automatically, medium = flag for review, high = hold pending approval, critical = block and escalate immediately. Always provide clear reasoning.", "returnIntermediateSteps": false }, "provider": "openai", "promptType": "define", "approximated": true, "systemMessage": "You are an accounts payable fraud detection specialist. Evaluate invoices for: duplicate submissions, amounts significantly above vendor average (>50% deviation = high risk, >100% = critical), unknown vendors, previously flagged vendors, or suspicious timing patterns. Risk levels: low = approve automatically, medium = flag for review, high = hold pending approval, critical = block and escalate immediately. Always provide clear reasoning.", "hasOutputParser": true }, "position": [ 28000, 7984 ] }, { "id": "46f49aa4-9f06-4f05-9124-dbc59982bd32", "name": "OpenAI — Risk", "type": "llm", "params": { "model": "gpt-4o", "options": { "temperature": 0 }, "provider": "openai", "temperature": 0 }, "position": [ 27776, 8224 ] }, { "id": "4a9e9a7d-cde5-459d-945c-fb7715e3996d", "name": "Fraud Risk Schema", "type": "passthrough", "params": { "mode": "noOp", "schemaType": "manual", "inputSchema": "{\"type\":\"object\",\"properties\":{\"risk_level\":{\"type\":\"string\",\"enum\":[\"low\",\"medium\",\"high\",\"critical\"]},\"risk_score\":{\"type\":\"integer\",\"minimum\":0,\"maximum\":100},\"fraud_indicators\":{\"type\":\"array\",\"items\":{\"type\":\"string\"}},\"reasoning\":{\"type\":\"string\"},\"recommended_action\":{\"type\":\"string\"},\"requires_hold\":{\"type\":\"boolean\"}},\"required\":[\"risk_level\",\"risk_score\",\"fraud_indicators\",\"reasoning\",\"recommended_action\",\"requires_hold\"]}" }, "position": [ 28240, 8256 ] }, { "id": "c5def029-6c26-4e86-95d1-c450028478ea", "name": "High Risk?", "type": "if", "params": { "options": {}, "conditions": { "options": { "typeValidation": "loose" }, "combinator": "and", "conditions": [ { "id": "cond-risk", "operator": { "type": "boolean", "operation": "equal" }, "leftValue": "={{ $json.output.requires_hold }}", "rightValue": true } ] } }, "position": [ 28336, 7984 ] }, { "id": "fcae28cd-d96f-436f-849a-c37bd5fbc992", "name": "Alert Slack", "type": "integration", "params": { "text": "=*FRAUD ALERT — {{ $('Merge All Context').first().json.risk_level.toUpperCase() }} RISK*\n\n*Invoice:* {{ $('Merge All Context').first().json.invoice_number }}\n*Vendor:* {{ $('Merge All Context').first().json.vendor_name }}\n*Amount:* {{ $('Merge All Context').first().json.amount }} {{ $('Merge All Context').first().json.currency }}\n*Risk Score:* {{ $json.output.risk_score }}/100\n\n*Fraud Indicators:*\n{{ $json.output.fraud_indicators.join('\\n') }}\n\n*Reasoning:* {{ $json.output.reasoning }}\n\n*Recommended Action:* {{ $json.output.recommended_action }}", "service": "slack", "operation": "read", "otherOptions": {} }, "position": [ 28592, 7936 ] }, { "id": "eb9876b9-9d8e-4b33-970a-44f4127c5ccc", "name": "Send Hold Notice", "type": "integration", "params": { "sendTo": "user@example.com", "message": "=

Invoice Flagged for Review

The following invoice has been placed on hold pending your approval.

Invoice Number	{{ $('Merge All Context').first().json.invoice_number }}
Vendor	{{ $('Merge All Context').first().json.vendor_name }}
Amount	{{ $('Merge All Context').first().json.amount }} {{ $('Merge All Context').first().json.currency }}
Risk Level	{{ $('Assess Fraud Risk').first().json.output.risk_level.toUpperCase() }}
Risk Score	{{ $('Assess Fraud Risk').first().json.output.risk_score }}/100

Fraud Indicators:
{{ $('Assess Fraud Risk').first().json.output.fraud_indicators.join('
') }}

Reasoning: {{ $('Assess Fraud Risk').first().json.output.reasoning }}

Recommended Action: {{ $('Assess Fraud Risk').first().json.output.recommended_action }}

", "options": {}, "service": "gmail", "subject": "=Invoice Hold — {{ $('Merge All Context').first().json.invoice_number }} from {{ $('Merge All Context').first().json.vendor_name }} ({{ $('Merge All Context').first().json.risk_level.toUpperCase() }} RISK)", "operation": "read" }, "position": [ 28832, 7856 ] }, { "id": "d056425b-4ac9-472c-b719-43a48f620c00", "name": "Log Invoice to Supabase", "type": "integration", "params": { "service": "supabase", "operation": "insert" }, "position": [ 29120, 8112 ] } ] }

Flag duplicate and risky AP invoices with Gmail, OpenAI and Supabase