Resiliency Dashboard

{ "edges": [ { "to": "674276f1-5a50-44ca-8806-038ef9ffefc6", "from": "68365082-a8dd-40b4-8f18-1af48964ac11", "toPort": "0", "fromPort": "0" }, { "to": "5bb16dd7-04ba-41df-bfc2-32073319d000", "from": "dd3be40c-a892-4397-9fcd-ec9f1e42cb40", "toPort": "0", "fromPort": "0" }, { "to": "d60eac82-4de8-4621-8af9-ae8c665a184b", "from": "84da998d-421b-4f28-842d-1a93eb6767c3", "toPort": "0", "fromPort": "0" }, { "to": "68365082-a8dd-40b4-8f18-1af48964ac11", "from": "5bb16dd7-04ba-41df-bfc2-32073319d000", "toPort": "0", "fromPort": "0" }, { "to": "84da998d-421b-4f28-842d-1a93eb6767c3", "from": "ee08f9c3-ce24-4f4c-a4ce-d50a616674a8", "toPort": "0", "fromPort": "0" }, { "to": "dd3be40c-a892-4397-9fcd-ec9f1e42cb40", "from": "4e6d2c87-39d5-4105-aa92-7b5d57529b65", "toPort": "1", "fromPort": "0" }, { "to": "dd3be40c-a892-4397-9fcd-ec9f1e42cb40", "from": "10ac5efd-4434-4f81-8448-9393ac45a36e", "toPort": "0", "fromPort": "0" }, { "to": "4e6d2c87-39d5-4105-aa92-7b5d57529b65", "from": "0f66b66b-a520-4378-b75d-5737632f35a8", "toPort": "0", "fromPort": "0" }, { "to": "10ac5efd-4434-4f81-8448-9393ac45a36e", "from": "0f66b66b-a520-4378-b75d-5737632f35a8", "toPort": "0", "fromPort": "0" }, { "to": "0f66b66b-a520-4378-b75d-5737632f35a8", "from": "d60eac82-4de8-4621-8af9-ae8c665a184b", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "dd3be40c-a892-4397-9fcd-ec9f1e42cb40", "name": "Merge", "type": "merge", "params": { "mode": "combine", "options": {}, "combineBy": "combineByPosition" }, "position": [ 1376, 320 ] }, { "id": "674276f1-5a50-44ca-8806-038ef9ffefc6", "name": "Respond to Webhook", "type": "passthrough", "params": { "mode": "noOp", "options": { "responseHeaders": { "entries": [ { "name": "Content-Type", "value": "text/html; charset=utf-8" } ] } }, "respondWith": "text", "responseBody": "={{ $json.html }}" }, "position": [ 2048, 320 ] }, { "id": "ee08f9c3-ce24-4f4c-a4ce-d50a616674a8", "name": "Webhook", "type": "trigger", "params": { "kind": "n8n-nodes-base.webhook", "path": "resiliency-dashboard", "options": {}, "responseMode": "responseNode" }, "position": [ 256, 320 ] }, { "id": "10ac5efd-4434-4f81-8448-9393ac45a36e", "name": "GET success", "type": "http", "params": { "url": "={{ $('Config').item.json.base_url }}/api/v1/executions?status=success&limit=50&workflowId={{ $json.id }}", "options": {}, "authentication": "predefinedCredentialType", "nodeCredentialType": "n8nApi" }, "position": [ 1152, 224 ] }, { "id": "4e6d2c87-39d5-4105-aa92-7b5d57529b65", "name": "GET error", "type": "http", "params": { "url": "={{ $('Config').item.json.base_url }}/api/v1/executions?status=error&limit=50&workflowId={{ $json.id }}", "options": {}, "authentication": "predefinedCredentialType", "nodeCredentialType": "n8nApi" }, "position": [ 1152, 416 ] }, { "id": "5bb16dd7-04ba-41df-bfc2-32073319d000", "name": "Compare", "type": "code", "params": { "jsCode": "const mergeItems = $input.all();\n\nconst erros = [];\nconst sucessos = [];\n\nmergeItems.forEach(item => {\n const data = item.json.data;\n if (!data) return;\n data.forEach(ex => {\n if (ex.status === 'error') erros.push(ex);\n else if (ex.status === 'success') sucessos.push(ex);\n });\n});\n\nconst workflows = $('Filter: [PROD] Tag').all().map(i => i.json);\n\nconst workflowStats = workflows.map(wf => {\n const wfErros = erros.filter(e => e.workflowId === wf.id);\n const wfSucessos = sucessos.filter(e => e.workflowId === wf.id);\n const total = wfErros.length + wfSucessos.length;\n const taxaSucesso = total > 0 ? Math.round((wfSucessos.length / total) * 100) : 100;\n const ultimoErro = wfErros.sort((a, b) => \n new Date(b.startedAt) - new Date(a.startedAt)\n )[0];\n\n return {\n id: wf.id,\n name: wf.name,\n totalErros: wfErros.length,\n totalSucessos: wfSucessos.length,\n taxaSucesso,\n saudavel: wfErros.length === 0,\n ultimoErro: ultimoErro ? ultimoErro.startedAt : null,\n };\n});\n\nconst totalMonitorados = workflows.length;\nconst totalSaudaveis = workflowStats.filter(w => w.saudavel).length;\nconst totalComErro = workflowStats.filter(w => !w.saudavel).length;\n\nconst hoje = new Date();\nconst diasLabels = [];\nconst diasErros = [];\n\nfor (let i = 6; i >= 0; i--) {\n const dia = new Date(hoje);\n dia.setDate(dia.getDate() - i);\n const label = dia.toLocaleDateString('en-US', { month: 'short', day: '2-digit' });\n const count = erros.filter(e => {\n const d = new Date(e.startedAt);\n return d.toDateString() === dia.toDateString();\n }).length;\n diasLabels.push(label);\n diasErros.push(count);\n}\n\nreturn [{\n json: {\n workflowStats,\n totalMonitorados,\n totalSaudaveis,\n totalComErro,\n diasLabels,\n diasErros\n }\n}];" }, "position": [ 1600, 320 ] }, { "id": "68365082-a8dd-40b4-8f18-1af48964ac11", "name": "HTML", "type": "code", "params": { "jsCode": "const data = $input.first().json;\n\nconst {\n workflowStats,\n totalMonitorados,\n totalSaudaveis,\n totalComErro,\n diasLabels,\n diasErros\n} = data;\n\nconst generatedAt = new Date().toLocaleString('en-US', { timeZone: 'UTC' });\n\nconst workflowRows = workflowStats.map(wf => {\n const statusPill = wf.saudavel\n ? 'Healthy'\n : 'Error';\n const lastError = wf.ultimoErro\n ? new Date(wf.ultimoErro).toLocaleString('en-US', { timeZone: 'UTC' })\n : '—';\n\n return `\n \n ${wf.name}\n ${statusPill}\n ${wf.taxaSucesso}%\n ${wf.totalErros}\n ${wf.totalSucessos}\n ${lastError}\n `;\n}).join('');\n\nconst html = `\n\n\n\n\n\nResiliency Dashboard\n\n\n\n\n\n

\n \n\n

Monitored

${totalMonitorados}

[PROD] Workflows

Healthy

${totalSaudaveis}

No recent errors

With errors

${totalComErro}

Need attention

\n\n

Errors per day — last 7 days

\n\n

Workflow status

\n \n \n \n \n \n \n \n \n \n \n \n ${workflowRows}\n

Workflow	Status	Success rate	Errors	Successes	Last error

\n\n\n\n`;\n\nreturn [{ json: { html } }];" }, "position": [ 1824, 320 ] }, { "id": "84da998d-421b-4f28-842d-1a93eb6767c3", "name": "Config", "type": "set", "params": { "options": {}, "assignments": { "assignments": [ { "id": "f505883e-8474-4d45-b9d0-474cb4f8ceac", "name": "base_url", "type": "string", "value": "https://YOUR-N8N-URL-HERE" } ] } }, "position": [ 480, 320 ] }, { "id": "d60eac82-4de8-4621-8af9-ae8c665a184b", "name": "API: List Workflows", "type": "http", "params": { "url": "={{ $('Config').item.json.base_url }}/api/v1/workflows ", "options": {}, "authentication": "predefinedCredentialType", "nodeCredentialType": "n8nApi" }, "position": [ 704, 320 ] }, { "id": "0f66b66b-a520-4378-b75d-5737632f35a8", "name": "Filter: [PROD] Tag", "type": "code", "params": { "jsCode": "const response = $input.first().json;\nconst workflows = response.data;\n\nconst prodWorkflows = workflows.filter(wf => \n wf.tags && wf.tags.some(tag => tag.name === \"[PROD]\")\n);\n\nreturn prodWorkflows.map(wf => ({\n json: {\n id: wf.id,\n name: wf.name,\n updatedAt: wf.updatedAt,\n versionId: wf.versionId,\n workflow: wf\n }\n}));" }, "position": [ 928, 320 ] } ] }

Monitor [PROD] workflows in real time with the n8n Public API dashboard