This workflow follows the HTTP Request → Postgres 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 →
{
"nodes": [
{
"id": "2e37cecf-fcff-43f5-a547-7f15f385f3e5",
"name": "Webhook Admin",
"type": "n8n-nodes-base.webhook",
"typeVersion": 2.1,
"position": [
0,
300
],
"parameters": {
"httpMethod": "POST",
"path": "wm-admin-v3",
"responseMode": "lastNode",
"options": {}
}
},
{
"id": "785e284c-6f97-4d09-87ae-e041da3712c8",
"name": "Get Admin Token",
"type": "n8n-nodes-base.postgres",
"typeVersion": 2.5,
"position": [
220,
300
],
"parameters": {
"operation": "executeQuery",
"query": "SELECT value#>>'{}' AS token FROM wm_config WHERE key='secrets.admin_token' LIMIT 1;",
"options": {}
},
"credentials": {
"postgres": {
"name": "<your credential>"
}
}
},
{
"id": "81d08322-8a43-4041-b659-18242293d59e",
"name": "Auth + Parse",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
440,
300
],
"parameters": {
"mode": "runOnceForEachItem",
"jsCode": "const headers = $('Webhook Admin').item.json.headers || {};\nconst provided = String(headers['x-admin-token'] || headers['X-Admin-Token'] || '').trim();\nconst expected = String($json.token || '').trim();\nif (!expected || expected === 'CHANGE_ME_BEFORE_PROD') {\n return { json: { ok: false, status: 500, error: 'admin_token_not_configured' } };\n}\nif (provided !== expected) {\n return { json: { ok: false, status: 401, error: 'unauthorized' } };\n}\nconst body = $('Webhook Admin').item.json.body || {};\nconst action = String(body.action || '').toLowerCase();\nconst tel = String(body.tel || '').replace(/\\D/g, '');\nconst params = body.params || {};\nconst VALID = ['get_state','reset','pause_bot','resume_bot','list_leads'];\nif (!VALID.includes(action)) {\n return { json: { ok: false, status: 400, error: 'invalid_action', action } };\n}\nreturn { json: { ok: true, action, tel, params } };"
}
},
{
"id": "77857558-988b-4d33-8586-045e8af6cd2a",
"name": "IF Authorized",
"type": "n8n-nodes-base.if",
"typeVersion": 2.2,
"position": [
660,
300
],
"parameters": {
"conditions": {
"options": {
"caseSensitive": true,
"typeValidation": "strict",
"version": 2
},
"conditions": [
{
"id": "c_ok",
"leftValue": "={{ $json.ok }}",
"rightValue": true,
"operator": {
"type": "boolean",
"operation": "true",
"singleValue": true
}
}
],
"combinator": "and"
},
"options": {}
}
},
{
"id": "fdb25b5f-1440-4221-8ee0-393875de31d8",
"name": "Switch Action",
"type": "n8n-nodes-base.switch",
"typeVersion": 3.2,
"position": [
880,
200
],
"parameters": {
"rules": {
"values": [
{
"conditions": {
"options": {
"caseSensitive": true,
"typeValidation": "strict",
"version": 1
},
"conditions": [
{
"leftValue": "={{ $json.action }}",
"rightValue": "get_state",
"operator": {
"type": "string",
"operation": "equals"
},
"id": "c1"
}
],
"combinator": "and"
},
"renameOutput": true,
"outputKey": "get_state"
},
{
"conditions": {
"options": {
"caseSensitive": true,
"typeValidation": "strict",
"version": 1
},
"conditions": [
{
"leftValue": "={{ $json.action }}",
"rightValue": "reset",
"operator": {
"type": "string",
"operation": "equals"
},
"id": "c2"
}
],
"combinator": "and"
},
"renameOutput": true,
"outputKey": "reset"
},
{
"conditions": {
"options": {
"caseSensitive": true,
"typeValidation": "strict",
"version": 1
},
"conditions": [
{
"leftValue": "={{ $json.action }}",
"rightValue": "pause_bot",
"operator": {
"type": "string",
"operation": "equals"
},
"id": "c3"
}
],
"combinator": "and"
},
"renameOutput": true,
"outputKey": "pause_bot"
},
{
"conditions": {
"options": {
"caseSensitive": true,
"typeValidation": "strict",
"version": 1
},
"conditions": [
{
"leftValue": "={{ $json.action }}",
"rightValue": "resume_bot",
"operator": {
"type": "string",
"operation": "equals"
},
"id": "c4"
}
],
"combinator": "and"
},
"renameOutput": true,
"outputKey": "resume_bot"
},
{
"conditions": {
"options": {
"caseSensitive": true,
"typeValidation": "strict",
"version": 1
},
"conditions": [
{
"leftValue": "={{ $json.action }}",
"rightValue": "list_leads",
"operator": {
"type": "string",
"operation": "equals"
},
"id": "c5"
}
],
"combinator": "and"
},
"renameOutput": true,
"outputKey": "list_leads"
}
]
},
"options": {}
}
},
{
"id": "9011941b-f728-4598-a69a-30bd71b3ad5b",
"name": "Proxy Get State",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1100,
0
],
"parameters": {
"method": "POST",
"url": "https://ia-n8n.clalha.easypanel.host/webhook/wm-se-v3",
"sendBody": true,
"contentType": "raw",
"rawContentType": "application/json",
"body": "={{ JSON.stringify({ tel: $json.tel, action: 'get' }) }}",
"options": {
"timeout": 10000
}
}
},
{
"id": "4b531544-fc37-4751-b12b-3441824e541c",
"name": "Proxy Reset",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1100,
100
],
"parameters": {
"method": "POST",
"url": "https://ia-n8n.clalha.easypanel.host/webhook/wm-se-v3",
"sendBody": true,
"contentType": "raw",
"rawContentType": "application/json",
"body": "={{ JSON.stringify({ tel: $json.tel, action: 'clear', params: { scope: 'state_only' } }) }}",
"options": {
"timeout": 10000
}
}
},
{
"id": "b2690a40-0f55-4b47-9daa-a36d4553e111",
"name": "Proxy Pause Bot",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1100,
200
],
"parameters": {
"method": "POST",
"url": "https://ia-n8n.clalha.easypanel.host/webhook/wm-se-v3",
"sendBody": true,
"contentType": "raw",
"rawContentType": "application/json",
"body": "={{ JSON.stringify({ tel: $json.tel, action: 'pause_bot', params: { duration_ms: $json.params.duration_ms || 3600000, reason: $json.params.reason || 'admin_pause' } }) }}",
"options": {
"timeout": 10000
}
}
},
{
"id": "a300cb53-0f39-4cc4-a266-63ba32285da0",
"name": "Proxy Resume Bot",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.2,
"position": [
1100,
300
],
"parameters": {
"method": "POST",
"url": "https://ia-n8n.clalha.easypanel.host/webhook/wm-se-v3",
"sendBody": true,
"contentType": "raw",
"rawContentType": "application/json",
"body": "={{ JSON.stringify({ tel: $json.tel, action: 'resume_bot' }) }}",
"options": {
"timeout": 10000
}
}
},
{
"id": "7d486169-c3bf-4cb1-b6a5-382b71549495",
"name": "Redis KEYS",
"type": "n8n-nodes-base.redis",
"typeVersion": 1,
"position": [
1100,
400
],
"parameters": {
"operation": "keys",
"keyPattern": "lead:*:state",
"options": {}
},
"credentials": {
"redis": {
"name": "<your credential>"
}
}
},
{
"id": "1c8529b5-3f54-44b2-9f2a-ba726a287fb3",
"name": "Format Leads",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
1320,
400
],
"parameters": {
"mode": "runOnceForAllItems",
"jsCode": "const items = $input.all();\nconst phones = [];\nfor (const it of items) {\n const j = it.json || {};\n for (const key of Object.keys(j)) {\n const m = String(key).match(/^lead:(\\d+):state$/);\n if (m) phones.push(m[1]);\n }\n}\nreturn [{ json: { ok: true, count: phones.length, phones } }];"
}
},
{
"id": "1d177318-e60e-4eac-84c2-329b50e3243f",
"name": "Respond Unauthorized",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
880,
500
],
"parameters": {
"mode": "runOnceForEachItem",
"jsCode": "return { json: { ok: false, error: $json.error, status: $json.status || 401 } };"
}
}
],
"connections": {
"Webhook Admin": {
"main": [
[
{
"node": "Get Admin Token",
"type": "main",
"index": 0
}
]
]
},
"Get Admin Token": {
"main": [
[
{
"node": "Auth + Parse",
"type": "main",
"index": 0
}
]
]
},
"Auth + Parse": {
"main": [
[
{
"node": "IF Authorized",
"type": "main",
"index": 0
}
]
]
},
"IF Authorized": {
"main": [
[
{
"node": "Switch Action",
"type": "main",
"index": 0
}
],
[
{
"node": "Respond Unauthorized",
"type": "main",
"index": 0
}
]
]
},
"Switch Action": {
"main": [
[
{
"node": "Proxy Get State",
"type": "main",
"index": 0
}
],
[
{
"node": "Proxy Reset",
"type": "main",
"index": 0
}
],
[
{
"node": "Proxy Pause Bot",
"type": "main",
"index": 0
}
],
[
{
"node": "Proxy Resume Bot",
"type": "main",
"index": 0
}
],
[
{
"node": "Redis KEYS",
"type": "main",
"index": 0
}
]
]
},
"Redis KEYS": {
"main": [
[
{
"node": "Format Leads",
"type": "main",
"index": 0
}
]
]
}
}
}
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.
postgresredis
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
Wm-Admin.N8N-Import. Uses postgres, httpRequest, redis. Webhook trigger; 12 nodes.
Source: https://gist.github.com/bruunofco/f1a2437f3b4d23f4db304c61e62aecc4 — 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.
CMM. Uses httpRequest, postgres, redis. Webhook trigger; 90 nodes.
HTTP Request, Postgres, Redis
Reagendamiento_v2. Uses executeWorkflowTrigger, redis, httpRequest, n8n-nodes-evolution-api. Event-driven trigger; 89 nodes.
Execute Workflow Trigger, Redis, HTTP Request +3
This solution enables you to manage all your Notion and Todoist tasks from different workspaces as well as your calendar events in a single place. This is 2 way sync with partial support for recurring
Redis, Notion, Todoist +6
Scraping. Uses httpRequest, postgres, @apify/n8n-nodes-apify, respondToWebhook. Webhook trigger; 61 nodes.
HTTP Request, Postgres, @Apify/N8N Nodes Apify
Agendamiento_v2. Uses n8n-nodes-evolution-api, redis, httpRequest, executeWorkflowTrigger. Event-driven trigger; 59 nodes.
N8N Nodes Evolution Api, Redis, HTTP Request +3