This workflow follows the Gmail → HTTP Request recipe pattern — see all workflows that pair these two integrations.
The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"name": "Addendo \u2014 Alert Router Central v1",
"nodes": [
{
"parameters": {
"httpMethod": "POST",
"path": "alert-router-v1",
"responseMode": "responseNode",
"options": {}
},
"id": "ar0-0000-0000-0000-000000000001",
"name": "Webhook Alert Router",
"type": "n8n-nodes-base.webhook",
"typeVersion": 2.1,
"position": [
0,
400
]
},
{
"parameters": {
"jsCode": "// Etapa 1+2: validar body, enmascarar credenciales, computar hash, determinar ceo_escalated preliminar.\n// Output un solo item con _route in {invalid, valid}.\nconst raw = $input.first().json;\nconst body = (raw && typeof raw === 'object' && raw.body && typeof raw.body === 'object') ? raw.body : raw;\n\nconst VALID_ALERT_TYPES = new Set([\n 'credential_exposed', 'infra_critical', 'cost_warning', 'cost_blocked',\n 'workflow_failed', 'analytics_anomaly', 'system_health'\n]);\nconst VALID_SEVERITIES = new Set(['P0', 'P1', 'P2', 'P3']);\n\nconst errors = [];\nif (!body || typeof body !== 'object') errors.push('body must be a JSON object');\nconst alert_type = body && body.alert_type;\nconst severity = body && body.severity;\nconst source_skill = body && body.source_skill;\nconst trace_id = body && body.trace_id;\nconst payload = body && body.payload;\nconst timestamp = (body && body.timestamp) || new Date().toISOString();\n\nif (!VALID_ALERT_TYPES.has(alert_type)) errors.push(\"alert_type invalid (one of \" + [...VALID_ALERT_TYPES].join(',') + \")\");\nif (!VALID_SEVERITIES.has(severity)) errors.push(\"severity must be P0|P1|P2|P3\");\nif (typeof trace_id !== 'string' || trace_id.trim() === '') errors.push('trace_id required (non-empty string)');\nif (!payload || typeof payload !== 'object') errors.push('payload required (object)');\nif (payload && (typeof payload.title !== 'string' || payload.title.trim() === '')) errors.push('payload.title required');\nif (payload && (typeof payload.description !== 'string' || payload.description.trim() === '')) errors.push('payload.description required');\n\nif (errors.length > 0) {\n return [{ json: { _route: 'invalid', _status: 400, error: 'validation_failed', details: errors, trace_id: trace_id || null } }];\n}\n\n// Enmascaramiento \u2014 patrones canonicos skill #40 L.4.\n// Orden: mas especificos primero, mas amplios despues.\nconst PATTERNS = [\n { name: 'aws_access_key', re: /AKIA[0-9A-Z]{16}/g, replacement: 'AKIA****REDACTED****' },\n { name: 'anthropic_api', re: /sk-ant-api03-[A-Za-z0-9_-]+/g, replacement: 'sk-ant-api03-****REDACTED****' },\n { name: 'openai_api', re: /sk-(proj-)?[A-Za-z0-9_-]{40,}/g, replacement: 'sk-****REDACTED****' },\n { name: 'github_classic', re: /gh[ps]_[A-Za-z0-9]{36,}/g, replacement: 'gh****REDACTED-GITHUB****' },\n { name: 'github_fine', re: /github_pat_[A-Za-z0-9_]{82}/g, replacement: 'github_pat_****REDACTED****' },\n { name: 'google_oauth', re: /1\\/\\/[A-Za-z0-9_-]{40,}/g, replacement: '1//****REDACTED-GOOGLE****' },\n { name: 'bearer_jwt', re: /Bearer\\s+eyJ[A-Za-z0-9_-]+\\.[A-Za-z0-9_-]+\\.[A-Za-z0-9_-]+/g, replacement: 'Bearer ****REDACTED-JWT****' },\n { name: 'credit_card', re: /\\b\\d{4}[\\s-]?\\d{4}[\\s-]?\\d{4}[\\s-]?(\\d{4})\\b/g, replacement: '****-****-****-$1' },\n { name: 'aws_secret_40', re: /[A-Za-z0-9\\/+=]{40}/g, replacement: '****REDACTED-AWS-SECRET****' },\n { name: 'token_generic_50', re: /[A-Za-z0-9_-]{50,}/g, replacement: '****REDACTED-TOKEN****', contextual: true }\n];\n\nlet masked_count = 0;\nconst masked_breakdown = {};\n\nfunction maskString(input, contextLabel) {\n if (typeof input !== 'string') return input;\n let out = input;\n for (const p of PATTERNS) {\n if (p.contextual) {\n const ctx = (contextLabel || '').toLowerCase();\n const inputLower = out.toLowerCase();\n const hasCtx = /\\b(token|key|secret|password|api[_-]?key|auth)/i.test(ctx) || /\\b(token|key|secret|password|api[_-]?key|auth)/i.test(inputLower);\n if (!hasCtx) continue;\n }\n let count = 0;\n out = out.replace(p.re, (match, ...rest) => {\n count++;\n if (typeof p.replacement === 'string' && p.replacement.includes('$1')) {\n return p.replacement.replace('$1', rest[0] || '');\n }\n return p.replacement;\n });\n if (count > 0) {\n masked_count += count;\n masked_breakdown[p.name] = (masked_breakdown[p.name] || 0) + count;\n }\n }\n return out;\n}\n\nfunction maskDeep(value, contextKey) {\n if (typeof value === 'string') return maskString(value, contextKey);\n if (Array.isArray(value)) return value.map((v, i) => maskDeep(v, contextKey + '[' + i + ']'));\n if (value && typeof value === 'object') {\n const out = {};\n for (const k of Object.keys(value)) out[k] = maskDeep(value[k], k);\n return out;\n }\n return value;\n}\n\nconst payload_masked = {\n title: maskString(payload.title, 'title'),\n description: maskString(payload.description, 'description'),\n context: maskDeep(payload.context || {}, 'context')\n};\n\n// Hash trace = FNV-1a 64-bit (n8n Code node bloquea 'crypto' module \u2014 dedup no requiere cripto-fuerza).\n// Misma propiedad: same input \u2192 same 16-hex output. Colision-resistente suficiente para dedup en ventana 30min.\nconst hashInput = String(alert_type) + '|' + String(source_skill || '') + '|' + String(payload.title) + '|' + String(payload.description);\nfunction fnv1a64Hex(str) {\n // FNV-1a 64-bit using BigInt\n const FNV_OFFSET = 0xcbf29ce484222325n;\n const FNV_PRIME = 0x100000001b3n;\n const MASK = 0xffffffffffffffffn;\n let h = FNV_OFFSET;\n for (let i = 0; i < str.length; i++) {\n h = h ^ BigInt(str.charCodeAt(i));\n h = (h * FNV_PRIME) & MASK;\n }\n return h.toString(16).padStart(16, '0');\n}\nconst hash_trace = fnv1a64Hex(hashInput);\n\n// Determinar ceo_escalated preliminar (Y.1 routing map).\nconst ctx = (payload && payload.context) || {};\nlet ceo_escalated = false;\nswitch (alert_type) {\n case 'credential_exposed':\n ceo_escalated = !!ctx.requires_ceo_escalation; break;\n case 'infra_critical':\n ceo_escalated = true; break; // re-evaluado tras self-heal placeholder (siempre falla hoy)\n case 'cost_warning':\n case 'cost_blocked':\n ceo_escalated = !!ctx.requires_ceo_escalation; break;\n case 'workflow_failed':\n ceo_escalated = (Number(ctx.client_affected_days) || 0) >= 1; break;\n case 'analytics_anomaly':\n ceo_escalated = !!ctx.severe_impact; break;\n case 'system_health':\n ceo_escalated = !!ctx.unresolvable_by_pm; break;\n}\n\n// Log estructurado pm2 si masked_count > 0.\nif (masked_count > 0) {\n console.log(\"COST_GUARD_ALERT level:WARN type:CREDENTIAL_DETECTED_IN_ALERT trace_id:\" + trace_id + \" masked_count:\" + masked_count + \" breakdown:\" + JSON.stringify(masked_breakdown));\n}\n\n// Inbox payload Redis (lo que el #4 PM consumira).\nconst now_iso = new Date().toISOString();\nconst inbox_payload = {\n trace_id: trace_id,\n alert_type: alert_type,\n severity: severity,\n source_skill: source_skill || null,\n timestamp: timestamp,\n received_at: now_iso,\n ceo_escalated: ceo_escalated, // re-actualizado despues si infra_critical\n deduplicated: false,\n masked_count: masked_count,\n masked_breakdown: masked_breakdown,\n payload: payload_masked,\n inbox_path_redis: 'agent:4:inbox:' + trace_id\n};\n\nreturn [{\n json: {\n _route: 'valid',\n trace_id: trace_id,\n alert_type: alert_type,\n severity: severity,\n source_skill: source_skill || null,\n timestamp: timestamp,\n hash_trace: hash_trace,\n cooldown_key: 'alert:cooldown:' + hash_trace,\n inbox_key: 'agent:4:inbox:' + trace_id,\n ceo_escalated: ceo_escalated,\n masked_count: masked_count,\n masked_breakdown: masked_breakdown,\n payload_masked: payload_masked,\n inbox_payload: inbox_payload,\n inbox_payload_json: JSON.stringify(inbox_payload)\n }\n}];"
},
"id": "ar0-0000-0000-0000-000000000002",
"name": "Validate Mask Hash",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
240,
400
]
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "loose"
},
"conditions": [
{
"id": "cond-0003",
"leftValue": "={{ $json._route }}",
"rightValue": "invalid",
"operator": {
"type": "string",
"operation": "equals"
}
}
],
"combinator": "and"
},
"options": {}
},
"id": "ar0-0000-0000-0000-000000000003",
"name": "IF invalid?",
"type": "n8n-nodes-base.if",
"typeVersion": 2.2,
"position": [
480,
400
]
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ { error: $json.error, details: $json.details, trace_id: $json.trace_id } }}",
"options": {
"responseCode": 400
}
},
"id": "ar0-0000-0000-0000-000000000004",
"name": "Respond 400",
"type": "n8n-nodes-base.respondToWebhook",
"typeVersion": 1.5,
"position": [
720,
200
]
},
{
"parameters": {
"operation": "get",
"key": "={{ $json.cooldown_key }}",
"options": {}
},
"id": "ar0-0000-0000-0000-000000000005",
"name": "Redis GET cooldown",
"type": "n8n-nodes-base.redis",
"typeVersion": 1,
"position": [
720,
600
],
"credentials": {
"redis": {
"name": "<your credential>"
}
},
"onError": "continueErrorOutput"
},
{
"parameters": {
"jsCode": "// Etapa 3 fail-closed: Redis GET fallo. Por invariante: NO escalar al CEO con flujo descontrolado.\n// Tratamos como deduplicado defensivo: log + respuesta 200 con fail_closed:true.\nconst meta = $('Validate Mask Hash').first().json;\nconst err = $input.first().json;\nconst errMsg = (err && (err.error || err.message)) ? (err.error || err.message) : JSON.stringify(err);\nconsole.log(\"ALERT_ROUTER_REDIS_FAIL_CLOSED trace_id:\" + meta.trace_id + \" error:\" + String(errMsg));\n\nreturn [{\n json: Object.assign({}, meta, {\n _route: 'fail_closed',\n _status: 200,\n response_body: {\n deduplicated: true,\n fail_closed: true,\n reason: 'redis_unreachable_failed_closed_per_invariant_2',\n trace_id: meta.trace_id,\n alert_type: meta.alert_type,\n ceo_escalated: false,\n credential_masked_count: meta.masked_count,\n pm_inbox_key: null,\n telegram_sent: false,\n email_sent: false\n }\n })\n}];"
},
"id": "ar0-0000-0000-0000-000000000006",
"name": "Code Fail-Closed",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
960,
800
]
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ $json.response_body }}",
"options": {
"responseCode": 200
}
},
"id": "ar0-0000-0000-0000-000000000007",
"name": "Respond 200 Fail-Closed",
"type": "n8n-nodes-base.respondToWebhook",
"typeVersion": 1.5,
"position": [
1200,
800
]
},
{
"parameters": {
"jsCode": "// Etapa 3: Inspeccionar output del Redis GET cooldown.\n// Si hay valor previo \u2192 _route = deduplicated. Si vacio \u2192 _route = fresh.\nconst meta = $('Validate Mask Hash').first().json;\nconst input = $input.first().json;\n\n// El nodo Redis GET retorna un objeto cuya propiedad coincide con la key (o un alias).\nlet rawValue = null;\nif (input && typeof input === 'object') {\n for (const k of Object.keys(input)) {\n if (input[k] !== undefined && input[k] !== null && input[k] !== '') {\n rawValue = input[k];\n break;\n }\n }\n}\n\nif (rawValue !== null && rawValue !== undefined && rawValue !== '') {\n console.log(\"ALERT_DEDUPED type:\" + meta.alert_type + \" trace_id:\" + meta.trace_id + \" original_trace_id:\" + String(rawValue));\n return [{\n json: Object.assign({}, meta, {\n _route: 'deduplicated',\n _status: 200,\n original_trace_id: String(rawValue),\n current_trace_id: meta.trace_id,\n response_body: {\n deduplicated: true,\n original_trace_id: String(rawValue),\n current_trace_id: meta.trace_id,\n alert_type: meta.alert_type,\n trace_id: meta.trace_id,\n ceo_escalated: false,\n credential_masked_count: meta.masked_count,\n pm_inbox_key: null,\n telegram_sent: false,\n email_sent: false\n }\n })\n }];\n}\n\nreturn [{ json: Object.assign({}, meta, { _route: 'fresh' }) }];"
},
"id": "ar0-0000-0000-0000-000000000008",
"name": "Code Check Dedup",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
960,
600
]
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "loose"
},
"conditions": [
{
"id": "cond-0009",
"leftValue": "={{ $json._route }}",
"rightValue": "deduplicated",
"operator": {
"type": "string",
"operation": "equals"
}
}
],
"combinator": "and"
},
"options": {}
},
"id": "ar0-0000-0000-0000-000000000009",
"name": "IF deduplicated?",
"type": "n8n-nodes-base.if",
"typeVersion": 2.2,
"position": [
1200,
600
]
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ $json.response_body }}",
"options": {
"responseCode": 200
}
},
"id": "ar0-0000-0000-0000-000000000010",
"name": "Respond 200 Dedup",
"type": "n8n-nodes-base.respondToWebhook",
"typeVersion": 1.5,
"position": [
1440,
400
]
},
{
"parameters": {
"operation": "set",
"key": "={{ $json.cooldown_key }}",
"options": {},
"value": "={{ $json.trace_id.toString() }}",
"keyType": "string",
"expire": true,
"ttl": 1800
},
"id": "ar0-0000-0000-0000-000000000011",
"name": "Redis SET cooldown",
"type": "n8n-nodes-base.redis",
"typeVersion": 1,
"position": [
1440,
800
],
"credentials": {
"redis": {
"name": "<your credential>"
}
}
},
{
"parameters": {
"jsCode": "// Etapa 4 case infra_critical: invocar Self-Heal Validator (placeholder Y.6.1).\n// TODO Y.6.1: construir workflow Self-Heal Validator con HTTP 200 check + smoke test workflow blog-don-jacinto.\n// Hoy: simular siempre {recovered: false} \u2192 escalar al CEO.\nconst meta = $input.first().json;\nif (meta.alert_type !== 'infra_critical') {\n // Pass-through para alert_types que no requieren self-heal.\n return [{ json: meta }];\n}\n\nconst self_heal_result = { recovered: false, placeholder: true, note: 'Self-Heal Validator workflow Y.6.1 pendiente \u2014 siempre escala hasta construirlo' };\nconsole.log(\"INFRA_SELF_HEAL_PLACEHOLDER trace_id:\" + meta.trace_id + \" result:false\");\n\n// Forzar ceo_escalated=true para infra_critical hasta que Y.6.1 exista.\nconst updated = Object.assign({}, meta, {\n ceo_escalated: true,\n self_heal_attempted: true,\n self_heal_recovered: false,\n inbox_payload: Object.assign({}, meta.inbox_payload, { ceo_escalated: true, self_heal_attempted: true, self_heal_recovered: false })\n});\nupdated.inbox_payload_json = JSON.stringify(updated.inbox_payload);\nreturn [{ json: updated }];"
},
"id": "ar0-0000-0000-0000-000000000012",
"name": "Code Self-Heal Placeholder",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
1680,
800
]
},
{
"parameters": {
"operation": "set",
"key": "={{ $json.inbox_key }}",
"options": {},
"value": "={{ $json.inbox_payload_json.toString() }}",
"keyType": "string",
"expire": true,
"ttl": 604800
},
"id": "ar0-0000-0000-0000-000000000013",
"name": "Redis SET inbox PM4",
"type": "n8n-nodes-base.redis",
"typeVersion": 1,
"position": [
1920,
800
],
"credentials": {
"redis": {
"name": "<your credential>"
}
}
},
{
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"leftValue": "",
"typeValidation": "loose"
},
"conditions": [
{
"id": "cond-0014",
"leftValue": "={{ $json.ceo_escalated.toString() }}",
"rightValue": "true",
"operator": {
"type": "string",
"operation": "equals"
}
}
],
"combinator": "and"
},
"options": {}
},
"id": "ar0-0000-0000-0000-000000000014",
"name": "IF ceo_escalated?",
"type": "n8n-nodes-base.if",
"typeVersion": 2.2,
"position": [
2160,
800
]
},
{
"parameters": {
"resource": "message",
"operation": "send",
"sendTo": "admin@addendo.io",
"subject": "=\ud83d\udea8 [ADDENDO] {{ $json.severity }} \u2014 {{ $json.alert_type }} \u2014 trace {{ $json.trace_id }}",
"emailType": "text",
"message": "=ALERTA ESCALADA AL CEO\nTrace ID: {{ $json.trace_id }}\nSeverity: {{ $json.severity }}\nTipo: {{ $json.alert_type }}\nSkill emisor: {{ $json.source_skill }}\nTimestamp UTC: {{ $json.timestamp }}\n\nTITULO:\n{{ $json.payload_masked.title }}\n\nDESCRIPCION (credenciales enmascaradas):\n{{ $json.payload_masked.description }}\n\nCONTEXTO:\n{{ JSON.stringify($json.payload_masked.context) }}\n\nMasked credentials count: {{ $json.masked_count }}\nMasked breakdown: {{ JSON.stringify($json.masked_breakdown) }}\n\nAccion requerida del CEO:\nLeer bandeja Redis #4 PM en clave: {{ $json.inbox_key }}\n(comando: redis-cli GET '{{ $json.inbox_key }}')\n\n\u2014 Addendo Agency OS Alert Router Central v1",
"options": {}
},
"id": "ar0-0000-0000-0000-000000000015",
"name": "Gmail Escalate CEO",
"type": "n8n-nodes-base.gmail",
"typeVersion": 2.1,
"position": [
2400,
600
],
"credentials": {
"gmailOAuth2": {
"name": "<your credential>"
}
},
"onError": "continueRegularOutput"
},
{
"parameters": {
"jsCode": "// Etapa final: construir respuesta HTTP 200 al skill emisor.\n// Refetch del meta del nodo Self-Heal Placeholder porque cuando Gmail dispara su output\n// reemplaza el contexto (Gmail devuelve message id, no el meta original).\nconst meta = $('Code Self-Heal Placeholder').first().json;\nreturn [{\n json: {\n _status: 200,\n response_body: {\n received: true,\n trace_id: meta.trace_id,\n alert_type: meta.alert_type,\n deduplicated: false,\n credential_masked_count: meta.masked_count,\n ceo_escalated: meta.ceo_escalated,\n pm_inbox_key: meta.inbox_key,\n telegram_sent: false,\n email_sent: !!meta.ceo_escalated\n }\n }\n}];"
},
"id": "ar0-0000-0000-0000-000000000016",
"name": "Code Build Response",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
2640,
800
]
},
{
"parameters": {
"respondWith": "json",
"responseBody": "={{ $json.response_body }}",
"options": {
"responseCode": 200
}
},
"id": "ar0-0000-0000-0000-000000000017",
"name": "Respond 200 Success",
"type": "n8n-nodes-base.respondToWebhook",
"typeVersion": 1.5,
"position": [
2880,
800
]
},
{
"parameters": {
"method": "POST",
"url": "=https://api.telegram.org/bot/sendMessage",
"sendBody": true,
"specifyBody": "json",
"jsonBody": "={ \"chat_id\": \"PENDIENTE_CHAT_ID\", \"text\": \"PLACEHOLDER\" }",
"options": {
"timeout": 10000
}
},
"id": "ar0-0000-0000-0000-000000000018",
"name": "Telegram CEO (DISABLED placeholder)",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
2400,
400
],
"disabled": true,
"notes": "TODO TELEGRAM BOT \u2014 pendiente crear en BotFather. Cuando exista, conectar desde IF ceo_escalated? rama true en paralelo a Gmail. Backlog inmediato declarado en CHANGELOG."
}
],
"connections": {
"Webhook Alert Router": {
"main": [
[
{
"node": "Validate Mask Hash",
"type": "main",
"index": 0
}
]
]
},
"Validate Mask Hash": {
"main": [
[
{
"node": "IF invalid?",
"type": "main",
"index": 0
}
]
]
},
"IF invalid?": {
"main": [
[
{
"node": "Respond 400",
"type": "main",
"index": 0
}
],
[
{
"node": "Redis GET cooldown",
"type": "main",
"index": 0
}
]
]
},
"Redis GET cooldown": {
"main": [
[
{
"node": "Code Check Dedup",
"type": "main",
"index": 0
}
],
[
{
"node": "Code Fail-Closed",
"type": "main",
"index": 0
}
]
]
},
"Code Fail-Closed": {
"main": [
[
{
"node": "Respond 200 Fail-Closed",
"type": "main",
"index": 0
}
]
]
},
"Code Check Dedup": {
"main": [
[
{
"node": "IF deduplicated?",
"type": "main",
"index": 0
}
]
]
},
"IF deduplicated?": {
"main": [
[
{
"node": "Respond 200 Dedup",
"type": "main",
"index": 0
}
],
[
{
"node": "Redis SET cooldown",
"type": "main",
"index": 0
}
]
]
},
"Redis SET cooldown": {
"main": [
[
{
"node": "Code Self-Heal Placeholder",
"type": "main",
"index": 0
}
]
]
},
"Code Self-Heal Placeholder": {
"main": [
[
{
"node": "Redis SET inbox PM4",
"type": "main",
"index": 0
}
]
]
},
"Redis SET inbox PM4": {
"main": [
[
{
"node": "IF ceo_escalated?",
"type": "main",
"index": 0
}
]
]
},
"IF ceo_escalated?": {
"main": [
[
{
"node": "Gmail Escalate CEO",
"type": "main",
"index": 0
}
],
[
{
"node": "Code Build Response",
"type": "main",
"index": 0
}
]
]
},
"Gmail Escalate CEO": {
"main": [
[
{
"node": "Code Build Response",
"type": "main",
"index": 0
}
]
]
},
"Code Build Response": {
"main": [
[
{
"node": "Respond 200 Success",
"type": "main",
"index": 0
}
]
]
}
},
"settings": {
"executionOrder": "v1",
"saveManualExecutions": true,
"callerPolicy": "workflowsFromSameOwner",
"saveExecutionProgress": true,
"saveDataErrorExecution": "all",
"saveDataSuccessExecution": "all",
"timezone": "America/New_York"
}
}
Credentials you'll need
Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.
gmailOAuth2redis
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
Addendo — Alert Router Central v1. Uses redis, gmail, httpRequest. Webhook trigger; 18 nodes.
Source: https://github.com/AddendoGrowthPartner/addendo-website/blob/main/workflows/produccion/Alert-Router-Central-v1.json — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
N8N-Amazon-Affiliate-Links.Workflow. Uses redis, httpRequest, gmail. Webhook trigger; 10 nodes.
Redis, HTTP Request, Gmail
Automate WhatsApp communication for recruitment agencies with an interactive, structured customer experience. This workflow handles pricing inquiries, request submissions, tracking, complaints, and hu
HTTP Request, Google Sheets, Gmail +1
This workflow automates HR onboarding by capturing new hires via a webhook, saving them to Google Sheets, emailing a Slack invite via Gmail, and notifying managers in Slack, then listening for Slack t
Google Sheets, Gmail, Slack +1
Fluxo Cadastro Original. Uses httpRequest, gmail. Webhook trigger; 67 nodes.
HTTP Request, Gmail
Advanced AI Powered Document Parsing & Text Extraction with Llama Parse. Uses gmail, gmailTrigger, httpRequest, googleSheets. Webhook trigger; 54 nodes.
Gmail, Gmail Trigger, HTTP Request +3