This workflow follows the Emailsend → 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 →
{
"nodes": [
{
"name": "HTML Extract",
"type": "n8n-nodes-base.htmlExtract",
"position": [
-220,
-390
],
"parameters": {
"options": {},
"extractionValues": {
"values": [
{
"key": "price",
"cssSelector": "={{$node[\"initItem\"].json[\"selector\"]}}"
}
]
}
},
"typeVersion": 1
},
{
"name": "Cron",
"type": "n8n-nodes-base.cron",
"position": [
-1290,
-390
],
"parameters": {
"triggerTimes": {
"item": [
{
"mode": "everyX",
"unit": "minutes",
"value": 15
}
]
}
},
"typeVersion": 1
},
{
"name": "getActualPrice",
"type": "n8n-nodes-base.functionItem",
"position": [
-20,
-390
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\n\nvar price = String(item.price).replace(\",\", \".\");\nprice = parseFloat(price);\n//price = price.replace(/\\D/g, '');\n//item.price = String(item.price).replace(\",\", \".\");\n//item.price = parseFloat(item.price);\n\nitem.priceExists = (price > 0 ? true : false)\nitem.price = price;\n\n// Update its data\nglobalData.actualPrice = item;\n\nreturn item;"
},
"typeVersion": 1
},
{
"name": "fetchWeb",
"type": "n8n-nodes-base.httpRequest",
"position": [
-410,
-390
],
"parameters": {
"url": "={{$node[\"initItem\"].json[\"link\"]}}",
"options": {},
"responseFormat": "string"
},
"typeVersion": 1
},
{
"name": "FunctionItem",
"type": "n8n-nodes-base.functionItem",
"position": [
1020,
-390
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\n\nglobalData.iteration = 0;\n//var thiselem = $node[\"initItem\"].json;\n\n//const s1 = {'slug': thiselem.slug, \"link\": thiselem.link, \"selector\": thiselem.selector, \"price\":$node[\"getActualPrice\"].json.price, \"currency\": thiselem.currency};\n//const s2 = {'slug': thiselem.slug+'2', \"link\": thiselem.link, \"selector\": thiselem.selector, \"price\":$node[\"getActualPrice\"].json.price, \"currency\": thiselem.currency};\n//const s3 = {'slug': thiselem.slug+'3', \"link\": thiselem.link, \"selector\": thiselem.selector, \"price\":$node[\"getActualPrice\"].json.price, \"currency\": thiselem.currency};\n\nreturn $node[\"changeME\"].json.myWatchers;\n"
},
"typeVersion": 1
},
{
"name": "Write Binary File1",
"type": "n8n-nodes-base.writeBinaryFile",
"position": [
1850,
-390
],
"parameters": {
"fileName": "/data/kopacky.json",
"dataPropertyName": "=price"
},
"typeVersion": 1
},
{
"name": "Move Binary Data1",
"type": "n8n-nodes-base.moveBinaryData",
"position": [
1420,
-390
],
"parameters": {
"mode": "jsonToBinary",
"options": {},
"destinationKey": "price"
},
"typeVersion": 1
},
{
"name": "IF1",
"type": "n8n-nodes-base.if",
"position": [
550,
-370
],
"parameters": {
"conditions": {
"string": [
{
"value1": "={{$node[\"checkifexists\"].json[\"stdout\"]}}",
"value2": "Exists",
"operation": "notEqual"
}
]
}
},
"typeVersion": 1
},
{
"name": "checkifexists",
"type": "n8n-nodes-base.executeCommand",
"position": [
410,
-370
],
"parameters": {
"command": "if [ -r /data/kopacky.json ]; then echo Exists; fi"
},
"typeVersion": 1
},
{
"name": "IF3",
"type": "n8n-nodes-base.if",
"position": [
680,
110
],
"parameters": {
"conditions": {
"string": [
{
"value1": "={{$node[\"checkifexists\"].json[\"stdout\"]}}",
"value2": "Exists"
}
]
}
},
"typeVersion": 1
},
{
"name": "SaveToFile",
"type": "n8n-nodes-base.writeBinaryFile",
"position": [
1650,
110
],
"parameters": {
"fileName": "/data/kopacky.json",
"dataPropertyName": "=price"
},
"typeVersion": 1
},
{
"name": "JsonToBinary",
"type": "n8n-nodes-base.moveBinaryData",
"position": [
1500,
110
],
"parameters": {
"mode": "jsonToBinary",
"options": {},
"destinationKey": "price"
},
"typeVersion": 1
},
{
"name": "changeME",
"type": "n8n-nodes-base.functionItem",
"color": "#3BDD33",
"position": [
-830,
-390
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\n\n//{'slug': 'kopacky', 'link': 'https://www.adsport.sk/kopacky-lisovky-adidas-x-19-3-ll-fg-ef0598/#1131861', 'currency': 'EUR'}[]\nvar myWatchers = [\n{'slug': 'kopacky', 'link': 'https://www.adsport.sk/kopacky-lisovky-adidas-x-19-3-ll-fg-ef0598/#1131861', 'selector':'.prices > strong:nth-child(1) > span:nth-child(1)', 'currency': 'EUR'},\n{'slug': 'kopacky2', 'link': 'https://www.adsport.sk/turfy-adidas-ace-tango-17-3-tf-by2203/', 'selector':'.col-xs-4 > strong:nth-child(1) > span:nth-child(1)', 'currency': 'EUR'},\n{'slug': 'mobilcek', 'link': 'https://mobil.bazos.sk/inzerat/112253662/predam-odolny-doogee-s60-52-4g-lte-nfc.php', 'selector':'.listadvlevo > table:nth-child(1) > tbody:nth-child(1) > tr:nth-child(5) > td:nth-child(2) > b:nth-child(2)', 'currency': 'EUR'},\n{'slug': 'ADIZERO RC 2', 'link': 'https://www.adsport.sk/panske-bezecke-topanky-adidas-adizero-rc-2-eg1187/', 'selector':'.col-xs-4 > strong:nth-child(1) > span:nth-child(1)', 'currency': 'EUR'}\n];\n\nitem.myWatchers = myWatchers;\nitem.watchersCount = myWatchers.length;\nglobalData.myWatchers = myWatchers;\n\nreturn item;"
},
"typeVersion": 1
},
{
"name": "initItem",
"type": "n8n-nodes-base.functionItem",
"position": [
-620,
-390
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\n\nvar counter = globalData.iteration;\n\nitem.myWatchers[counter].watchersCount = item.watchersCount;\nitem.myWatchers[counter].canContinue = (globalData.iteration < item.watchersCount-1 ? true : false);\n//item.myWatchers[counter].canContinue = false;\n\nglobalData.iteration = counter + 1;\n\nreturn item.myWatchers[counter];"
},
"typeVersion": 1
},
{
"name": "savedItems",
"type": "n8n-nodes-base.readBinaryFile",
"position": [
850,
-20
],
"parameters": {
"filePath": "/data/kopacky.json",
"dataPropertyName": "savedItems"
},
"typeVersion": 1,
"continueOnFail": true,
"alwaysOutputData": true
},
{
"name": "itemsToJSON",
"type": "n8n-nodes-base.moveBinaryData",
"position": [
1020,
-20
],
"parameters": {
"options": {},
"sourceKey": "savedItems"
},
"typeVersion": 1
},
{
"name": "IF",
"type": "n8n-nodes-base.if",
"position": [
2190,
-90
],
"parameters": {
"conditions": {
"string": [],
"boolean": [
{
"value1": "={{$node[\"initItem\"].json[\"canContinue\"]}}",
"value2": true
}
]
}
},
"typeVersion": 1
},
{
"name": "initItem1",
"type": "n8n-nodes-base.functionItem",
"position": [
-1060,
-390
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\n\nglobalData.iteration = 0;\n\nreturn item;"
},
"typeVersion": 1
},
{
"name": "IF2",
"type": "n8n-nodes-base.if",
"position": [
1850,
110
],
"parameters": {
"conditions": {
"number": [
{
"value1": "={{$node[\"getActualPrice\"].json[\"price\"]}}",
"value2": "={{$node[\"updateSavedItems1\"].json[\"oldPrice\"]}}"
}
],
"string": []
}
},
"typeVersion": 1
},
{
"name": "updateSavedItems",
"type": "n8n-nodes-base.functionItem",
"position": [
1350,
110
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\n\nvar myitems = [];\nvar i;\nfor (i = 0; i < item.items.length; i++) { \n if($node[\"initItem\"].json.slug == item.items[i].slug && $node[\"getActualPrice\"].json.price < item.items[i].price) {\n item.items[i].price = $node[\"getActualPrice\"].json.price;\n }\n myitems.push(item.items[i]);\n} \n\nreturn myitems;\n"
},
"typeVersion": 1
},
{
"name": "updateSavedItems1",
"type": "n8n-nodes-base.functionItem",
"position": [
1200,
-20
],
"parameters": {
"functionCode": "const globalData = getWorkflowStaticData('global');\nvar oldPrice = null;\nvar myitems = [];\nvar i;\nfor (i = 0; i < item.length; i++) {\n if($node[\"initItem\"].json.slug == item[i].slug) {\n\n item[i].link = $node[\"initItem\"].json.link;\n item[i].selector = $node[\"initItem\"].json.selector;\n item[i].currency = $node[\"initItem\"].json.currency;\n \n if(!item[i].price){\n item[i].price = $node[\"getActualPrice\"].json.price;\n }\n \n if($node[\"getActualPrice\"].json.price < item[i].price){\n oldPrice = item[i].price;\n item[i].price = $node[\"getActualPrice\"].json.price;\n }\n \n \n }\n \n myitems.push(item[i]);\n} \n\n//item.somar = $node[\"initItem\"].json;\n//return globalData.actualPrice;\n\nvar itemm = {};\nitemm.items = myitems;\nitemm.oldPrice = oldPrice;\nreturn itemm;\n"
},
"typeVersion": 1
},
{
"name": "cleanData",
"type": "n8n-nodes-base.executeCommand",
"notes": "This will remove all storaged data.",
"position": [
-1290,
-560
],
"parameters": {
"command": "file=\"/data/kopacky.json\"\n[ -f $file ] && rm $file"
},
"typeVersion": 1
},
{
"name": "IF4",
"type": "n8n-nodes-base.if",
"position": [
150,
-390
],
"parameters": {
"conditions": {
"string": [],
"boolean": [
{
"value1": "={{$node[\"getActualPrice\"].json[\"priceExists\"]}}"
}
]
}
},
"typeVersion": 1
},
{
"name": "NotifyBetterPrice",
"type": "n8n-nodes-base.emailSend",
"position": [
1850,
-90
],
"parameters": {
"html": "=<h2>Nov\u00e1 cena je: {{$node[\"getActualPrice\"].json[\"price\"]}} {{$node[\"initItem\"].json[\"currency\"]}}</h2><br>\nP\u00f4vodn\u00e1 cena bola: {{$node[\"updateSavedItems1\"].json[\"oldPrice\"]}} {{$node[\"initItem\"].json[\"currency\"]}}<br>\nURL: {{$node[\"initItem\"].json[\"link\"]}}",
"text": "=",
"options": {},
"subject": "=Nov\u00e1 cena - {{$node[\"initItem\"].json[\"slug\"]}} - {{$node[\"getActualPrice\"].json[\"price\"]}} {{$node[\"initItem\"].json[\"currency\"]}}",
"toEmail": "sthosstudio@gmail.com",
"fromEmail": "hostovecky@weyou.sk"
},
"credentials": {
"smtp": "<your credential>"
},
"typeVersion": 1
},
{
"name": "NotifyIncorrectPrice",
"type": "n8n-nodes-base.emailSend",
"position": [
270,
-690
],
"parameters": {
"html": "=Please check the link or selector for the item with slug <strong>{{$node[\"initItem\"].json[\"slug\"]}}</strong><br>\nURL: {{$node[\"initItem\"].json[\"link\"]}}",
"text": "=",
"options": {},
"subject": "={{$node[\"initItem\"].json[\"slug\"]}} - Getting price issue.",
"toEmail": "sthosstudio@gmail.com",
"fromEmail": "hostovecky@weyou.sk"
},
"credentials": {
"smtp": "<your credential>"
},
"typeVersion": 1
}
],
"connections": {
"IF": {
"main": [
[
{
"node": "changeME",
"type": "main",
"index": 0
}
]
]
},
"IF1": {
"main": [
[
{
"node": "FunctionItem",
"type": "main",
"index": 0
}
],
[
{
"node": "IF3",
"type": "main",
"index": 0
}
]
]
},
"IF2": {
"main": [
[
{
"node": "NotifyBetterPrice",
"type": "main",
"index": 0
}
],
[
{
"node": "IF",
"type": "main",
"index": 0
}
]
]
},
"IF3": {
"main": [
[
{
"node": "savedItems",
"type": "main",
"index": 0
}
]
]
},
"IF4": {
"main": [
[
{
"node": "NotifyIncorrectPrice",
"type": "main",
"index": 0
}
],
[
{
"node": "checkifexists",
"type": "main",
"index": 0
}
]
]
},
"Cron": {
"main": [
[
{
"node": "initItem1",
"type": "main",
"index": 0
}
]
]
},
"changeME": {
"main": [
[
{
"node": "initItem",
"type": "main",
"index": 0
}
]
]
},
"fetchWeb": {
"main": [
[
{
"node": "HTML Extract",
"type": "main",
"index": 0
}
]
]
},
"initItem": {
"main": [
[
{
"node": "fetchWeb",
"type": "main",
"index": 0
}
]
]
},
"initItem1": {
"main": [
[
{
"node": "changeME",
"type": "main",
"index": 0
}
]
]
},
"SaveToFile": {
"main": [
[
{
"node": "IF2",
"type": "main",
"index": 0
}
]
]
},
"savedItems": {
"main": [
[
{
"node": "itemsToJSON",
"type": "main",
"index": 0
}
]
]
},
"itemsToJSON": {
"main": [
[
{
"node": "updateSavedItems1",
"type": "main",
"index": 0
}
]
]
},
"FunctionItem": {
"main": [
[
{
"node": "Move Binary Data1",
"type": "main",
"index": 0
}
]
]
},
"HTML Extract": {
"main": [
[
{
"node": "getActualPrice",
"type": "main",
"index": 0
}
]
]
},
"JsonToBinary": {
"main": [
[
{
"node": "SaveToFile",
"type": "main",
"index": 0
}
]
]
},
"checkifexists": {
"main": [
[
{
"node": "IF1",
"type": "main",
"index": 0
}
]
]
},
"getActualPrice": {
"main": [
[
{
"node": "IF4",
"type": "main",
"index": 0
}
]
]
},
"updateSavedItems": {
"main": [
[
{
"node": "JsonToBinary",
"type": "main",
"index": 0
}
]
]
},
"Move Binary Data1": {
"main": [
[
{
"node": "Write Binary File1",
"type": "main",
"index": 0
}
]
]
},
"NotifyBetterPrice": {
"main": [
[
{
"node": "IF",
"type": "main",
"index": 0
}
]
]
},
"updateSavedItems1": {
"main": [
[
{
"node": "updateSavedItems",
"type": "main",
"index": 0
}
]
]
},
"Write Binary File1": {
"main": [
[
{
"node": "IF",
"type": "main",
"index": 0
}
]
]
},
"NotifyIncorrectPrice": {
"main": [
[
{
"node": "checkifexists",
"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.
smtp
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
How this works
This workflow enables businesses and e-commerce managers to monitor product price fluctuations on competitor websites, ensuring you stay informed of market shifts without manual checks. It fetches webpage data via HTTP requests, extracts prices using HTML Extract, and logs changes to binary files for easy review. Ideal for retailers or analysts tracking dynamic pricing, the key step involves comparing current prices against historical data in a function item to detect variations.
Use this workflow for periodic surveillance of specific product pages, such as daily cron-scheduled checks on high-volume items, to inform pricing strategies or inventory decisions. Avoid it for real-time monitoring needs, where API-based tools like those from Shopify or Google Sheets would suit better, or when dealing with sites heavy on JavaScript that block simple HTTP fetches. Common variations include emailing alerts on price drops or integrating with spreadsheet apps for trend analysis.
About this workflow
Track Changes Of Product Prices. Uses htmlExtract, functionItem, httpRequest, writeBinaryFile. Scheduled trigger; 25 nodes.
Source: https://github.com/Zie619/n8n-workflows — 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.
This workflow automatically tracks changes on specific websites, typically in e-commerce where you want to get information about price changes. Basic knowledge of HTML and JavaScript Execute Command n
Html Extract, Function Item, HTTP Request +5
extract_swifts. Uses manualTrigger, httpRequest, htmlExtract, splitInBatches. Event-driven trigger; 23 nodes.
HTTP Request, Html Extract, MongoDB +5
Scrape And Store Data From Multiple Website Pages. Uses manualTrigger, httpRequest, htmlExtract, splitInBatches. Event-driven trigger; 23 nodes.
HTTP Request, Html Extract, MongoDB +5
AI Product Video Generator (Windows). Uses httpRequest, writeBinaryFile, executeCommand, readBinaryFile. Webhook trigger; 16 nodes.
HTTP Request, Write Binary File, Execute Command +1
Testflow1. Uses httpRequest, readBinaryFiles, executeCommand, writeBinaryFile. Scheduled trigger; 11 nodes.
HTTP Request, Read Binary Files, Execute Command +1