{ "edges": [ { "to": "1cda8f9a-f994-4715-a85f-8536080a000d", "from": "1bf9ac9b-b5a7-4242-ae6f-b06327314b74", "toPort": "0", "fromPort": "0" }, { "to": "0a154269-8c8f-432b-a7b5-35f868301a70", "from": "7f3bf805-965b-436c-8983-ad02a26ad5f2", "toPort": "0", "fromPort": "0" }, { "to": "812d5980-a3d9-4e0a-aefc-ea85d4ee3503", "from": "632bc0b3-da1c-411a-8114-edc4137bfbcc", "toPort": "0", "fromPort": "0" }, { "to": "90647890-ea8e-4de0-abca-23a2a2c09d4a", "from": "632bc0b3-da1c-411a-8114-edc4137bfbcc", "toPort": "0", "fromPort": "1" }, { "to": "b8bdb28d-b48f-4b33-bd84-8c14d96469ae", "from": "42920d01-c232-4e46-9cf1-7d3de4d79755", "toPort": "0", "fromPort": "0" }, { "to": "1bf9ac9b-b5a7-4242-ae6f-b06327314b74", "from": "42920d01-c232-4e46-9cf1-7d3de4d79755", "toPort": "0", "fromPort": "1" }, { "to": "976316b0-f216-4e1b-b51f-5c07e97c3a17", "from": "1cda8f9a-f994-4715-a85f-8536080a000d", "toPort": "0", "fromPort": "0" }, { "to": "4b05f0a7-8473-45df-ab5b-04c6b6c8ce77", "from": "812d5980-a3d9-4e0a-aefc-ea85d4ee3503", "toPort": "0", "fromPort": "0" }, { "to": "4b05f0a7-8473-45df-ab5b-04c6b6c8ce77", "from": "90647890-ea8e-4de0-abca-23a2a2c09d4a", "toPort": "0", "fromPort": "0" }, { "to": "1bf9ac9b-b5a7-4242-ae6f-b06327314b74", "from": "b8bdb28d-b48f-4b33-bd84-8c14d96469ae", "toPort": "0", "fromPort": "0" }, { "to": "632bc0b3-da1c-411a-8114-edc4137bfbcc", "from": "0a154269-8c8f-432b-a7b5-35f868301a70", "toPort": "0", "fromPort": "0" }, { "to": "42920d01-c232-4e46-9cf1-7d3de4d79755", "from": "4b05f0a7-8473-45df-ab5b-04c6b6c8ce77", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "0a154269-8c8f-432b-a7b5-35f868301a70", "name": "Parse & Enrich Payment Data", "type": "code", "params": { "jsCode": "// ─── Parse & Enrich Stripe Failed Payment Event ───────────────────────────\nconst body = $input.item.json.body ?? $input.item.json;\n\n// Validate event type\nconst ALLOWED = [\n 'payment_intent.payment_failed',\n 'invoice.payment_failed',\n 'charge.failed'\n];\nif (!ALLOWED.includes(body.type)) {\n throw new Error('[StripeRecovery] Unexpected event: ' + body.type);\n}\n\nconst o = body.data?.object ?? {};\n\n// Normalise across event types (payment_intent vs invoice)\nconst amountCents = o.amount ?? o.amount_due ?? 0;\nconst amountDollars = (amountCents / 100).toFixed(2);\nconst currency = (o.currency ?? 'usd').toUpperCase();\nconst customerId = o.customer ?? '';\nconst customerEmail = o.receipt_email ?? o.customer_email ?? o.metadata?.customer_email ?? '';\nconst customerName = o.metadata?.customer_name ?? o.customer_name ?? 'Unknown Customer';\nconst plan = o.metadata?.plan ?? o.metadata?.product_name ?? 'N/A';\nconst paymentId = o.id ?? '';\nconst invoiceId = o.invoice ?? o.id ?? '';\nconst subscriptionId = o.subscription ?? o.metadata?.subscription_id ?? null;\nconst attemptCount = Number(\n o.attempt_count ?? // real field on invoice events\n o.metadata?.attempt_count ?? // your custom metadata override\n 1\n);\nconst failureCode = o.last_payment_error?.code ?? o.failure_code ?? 'unknown';\nconst failureMessage = o.last_payment_error?.message ?? o.failure_message ?? 'Payment failed';\nconst failureType = o.last_payment_error?.type ?? 'unknown';\nconst declineCode = o.last_payment_error?.decline_code ?? null;\nconst nextRetryAt = o.next_payment_attempt\n ? new Date(o.next_payment_attempt * 1000).toUTCString()\n : 'None scheduled';\nconst createdAt = new Date((o.created ?? Date.now() / 1000) * 1000).toISOString();\nconst processedAt = new Date().toISOString();\n\n// Severity tiers\nlet severity = 'LOW';\nif (amountCents >= 100000) severity = 'CRITICAL'; // >= $1,000\nelse if (amountCents >= 10000) severity = 'HIGH'; // >= $100\nelse if (amountCents >= 1000) severity = 'MEDIUM'; // >= $10\n\n// ClickUp priority: 1=urgent 2=high 3=normal 4=low\nconst priorityMap = { CRITICAL: 1, HIGH: 2, MEDIUM: 3, LOW: 4 };\nconst clickupPriority = priorityMap[severity];\n\n// Due date: 24h critical, 48h otherwise\nconst dueDateMs = severity === 'CRITICAL'\n ? Date.now() + 24 * 3600 * 1000\n : Date.now() + 48 * 3600 * 1000;\n\nreturn [{ json: {\n // Identifiers\n stripeEventId: body.id,\n eventType: body.type,\n paymentId,\n invoiceId,\n subscriptionId,\n customerId,\n // Customer\n customerEmail,\n customerName,\n plan,\n // Payment\n amountCents,\n amountDollars,\n currency,\n // Failure\n attemptCount,\n failureCode,\n failureMessage,\n failureType,\n declineCode,\n // Routing\n severity,\n clickupPriority,\n dueDateMs,\n isHighValue: amountCents >= 100000,\n isRepeatedFailure: attemptCount > 2,\n // Timing\n nextRetryAt,\n createdAt,\n processedAt,\n // Deep links\n stripePaymentUrl: 'https://dashboard.stripe.com/payments/' + paymentId,\n stripeCustomerUrl: 'https://dashboard.stripe.com/customers/' + customerId\n}}];" }, "position": [ 960, 416 ] }, { "id": "632bc0b3-da1c-411a-8114-edc4137bfbcc", "name": "High Value Check", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 1, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "cond-highvalue", "operator": { "type": "boolean", "operation": "equals" }, "leftValue": "={{ $json.isHighValue }}", "rightValue": true } ] } }, "position": [ 1392, 416 ] }, { "id": "812d5980-a3d9-4e0a-aefc-ea85d4ee3503", "name": "Slack — Critical Alert", "type": "integration", "params": { "text": "=:rotating_light: *CRITICAL PAYMENT FAILURE* :rotating_light:\n\n*Customer:* {{ $('Parse & Enrich Payment Data').item.json.customerName }}\n*Email:* {{ $('Parse & Enrich Payment Data').item.json.customerEmail }}\n*Plan:* {{ $('Parse & Enrich Payment Data').item.json.plan }}\n*Amount:* {{ $('Parse & Enrich Payment Data').item.json.amountDollars }} {{ $('Parse & Enrich Payment Data').item.json.currency }}\n*Severity:* `{{ $('Parse & Enrich Payment Data').item.json.severity }}`\n*Failure Code:* `{{ $('Parse & Enrich Payment Data').item.json.failureCode }}`\n*Failure Message:* {{ $('Parse & Enrich Payment Data').item.json.failureMessage }}\n*Attempt #:* {{ $('Parse & Enrich Payment Data').item.json.attemptCount }}\n*Next Retry:* {{ $('Parse & Enrich Payment Data').item.json.nextRetryAt }}\n\n:link: <{{ $('Parse & Enrich Payment Data').item.json.stripePaymentUrl }}|View Payment> | <{{ $('Parse & Enrich Payment Data').item.json.stripeCustomerUrl }}|View Customer>\n\n_Event: `{{ $('Parse & Enrich Payment Data').item.json.stripeEventId }}` — {{ $('Parse & Enrich Payment Data').item.json.processedAt }}_", "service": "slack", "operation": "read", "otherOptions": { "mrkdwn": true }, "authentication": "oAuth2" }, "position": [ 1760, 256 ] }, { "id": "90647890-ea8e-4de0-abca-23a2a2c09d4a", "name": "Slack — Standard Alert", "type": "integration", "params": { "text": "=:credit_card: *Payment Failed*\n\n*Customer:* {{ $json.customerName }}\n*Email:* {{ $json.customerEmail }}\n*Plan:* {{ $json.plan }}\n*Amount:* ${{ $json.amountDollars }} {{ $json.currency }}\n*Severity:* `{{ $json.severity }}`\n*Failure:* {{ $json.failureMessage }} (`{{ $json.failureCode }}`)\n*Attempt #:* {{ $json.attemptCount }}\n*Next Retry:* {{ $json.nextRetryAt }}\n\n:link: <{{ $json.stripePaymentUrl }}|View Payment> | <{{ $json.stripeCustomerUrl }}|View Customer>\n\n_Event: `{{ $json.stripeEventId }}` — {{ $json.processedAt }}_", "service": "slack", "operation": "read", "otherOptions": { "mrkdwn": true }, "authentication": "oAuth2" }, "position": [ 1760, 528 ] }, { "id": "4b05f0a7-8473-45df-ab5b-04c6b6c8ce77", "name": "ClickUp — Create Recovery Task", "type": "integration", "params": { "name": "=💳 Payment Recovery: {{ $('High Value Check').item.json.customerName }}— {{ $('High Value Check').item.json.amountDollars }} {{ $('High Value Check').item.json.currency }}", "service": "clickup", "operation": "read", "folderless": true, "additionalFields": { "dueDate": "={{ $('Parse & Enrich Payment Data').item.json.dueDateMs }}", "priority": "={{ $('Parse & Enrich Payment Data').item.json.clickupPriority }}" } }, "position": [ 2112, 416 ] }, { "id": "42920d01-c232-4e46-9cf1-7d3de4d79755", "name": "Retry Count Check", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 1, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "cond-retry", "operator": { "type": "boolean", "operation": "equals" }, "leftValue": "={{ $('High Value Check').item.json.isRepeatedFailure }}", "rightValue": true } ] } }, "position": [ 2416, 416 ] }, { "id": "b8bdb28d-b48f-4b33-bd84-8c14d96469ae", "name": "Slack — Escalation Alert", "type": "integration", "params": { "text": "=:sos: *ESCALATION — Repeated Payment Failure (Attempt #{{ $('High Value Check').item.json.attemptCount }}*\n\nA customer has now failed payment *{{ $('High Value Check').item.json.attemptCount }} times*. Manual intervention required.\n\n*Customer:* {{ $('High Value Check').item.json.customerName }} ({{ $('High Value Check').item.json.customerEmail }})\n*Plan:* {{ $('High Value Check').item.json.plan }}\n*Amount:* {{ $('High Value Check').item.json.amountDollars }} {{ $('High Value Check').item.json.currency }}\n*Last Failure:* {{ $('High Value Check').item.json.failureMessage }} (`{{ $('High Value Check').item.json.failureCode }}`)\n*Subscription ID:* {{ $('High Value Check').item.json.subscriptionId || 'N/A' }}\n\n:link: <{{ $('High Value Check').item.json.stripeCustomerUrl }}|View Customer in Stripe>\n\n{{ $vars.SLACK_ESCALATION_MENTION || '@billing-manager' }} — please review and take action.\n\n_Event: `{{ $('High Value Check').item.json.stripeEventId }}` | Severity: {{ $('High Value Check').item.json.severity }}_", "service": "slack", "operation": "read", "otherOptions": { "mrkdwn": true }, "authentication": "oAuth2" }, "position": [ 2768, 288 ] }, { "id": "1cda8f9a-f994-4715-a85f-8536080a000d", "name": "Log to Google Sheets", "type": "integration", "params": { "service": "googleSheets", "operation": "append", "sheetName": { "__rl": true, "mode": "", "value": "", "cachedResultUrl": "", "cachedResultName": "" }, "documentId": { "__rl": true, "mode": "", "value": "", "cachedResultUrl": "", "cachedResultName": "" } }, "position": [ 3344, 432 ] }, { "id": "1bf9ac9b-b5a7-4242-ae6f-b06327314b74", "name": "Send a message", "type": "integration", "params": { "message": "=

Dear {{ $('High Value Check').item.json.customerName }},

We were unable to process your payment of {{ $('High Value Check').item.json.amountDollars }} {{ $('High Value Check').item.json.currency }} for your {{ $('High Value Check').item.json.plan }} subscription.

Reason: {{ $('High Value Check').item.json.failureMessage }}
Failure Code: {{ $('High Value Check').item.json.failureCode }}
Attempt #: {{ $('High Value Check').item.json.attemptCount }}

If you need help, reply to this email.

Best regards,
The Billing Team

Next retry scheduled: {{ $('High Value Check').item.json.nextRetryAt }}

", "options": {}, "service": "gmail", "subject": "=Action Required: Payment of ${{ $('High Value Check').item.json.amountDollars }} Failed — {{ $('High Value Check').item.json.plan }} Plan", "operation": "read" }, "position": [ 3136, 432 ] }, { "id": "7f3bf805-965b-436c-8983-ad02a26ad5f2", "name": "Stripe Trigger", "type": "integration", "params": { "events": [ "charge.failed", "invoice.payment_failed", "payment_intent.payment_failed" ], "service": "stripetrigger", "operation": "run", "__originalType": "n8n-nodes-base.stripeTrigger" }, "position": [ 544, 416 ] }, { "id": "976316b0-f216-4e1b-b51f-5c07e97c3a17", "name": "Create or update a contact", "type": "integration", "params": { "options": {}, "service": "hubspot", "operation": "read", "authentication": "appToken", "additionalFields": { "lastName": "={{ $('High Value Check').item.json.customerName.split(' ')[1] ?? '' }}", "firstName": "={{ $('High Value Check').item.json.customerName.split(' ')[0] }}", "companyName": "={{ $('High Value Check').item.json.plan }}" } }, "position": [ 3536, 432 ] } ] }

Handle failed Stripe payments with Slack, ClickUp, Gmail and Google Sheets