{ "edges": [ { "to": "759fa1da-ac35-41b4-8ab9-759079bc259f", "from": "9fc0ce09-8f88-499b-a322-09d761b374b6", "toPort": "0", "fromPort": "0" }, { "to": "677c3ae3-52d0-4fcb-97d8-5671a176d1b2", "from": "80e87ac8-1be3-4eef-8e7c-e13f09868bd3", "toPort": "0", "fromPort": "0" }, { "to": "665cad5b-6397-4427-90ab-4aae1789d93e", "from": "80e87ac8-1be3-4eef-8e7c-e13f09868bd3", "toPort": "0", "fromPort": "1" }, { "to": "acfc302f-9350-4114-ae25-97b7c34e5078", "from": "5b467790-afcc-46e8-a7f8-1ce628a48837", "toPort": "0", "fromPort": "0" }, { "to": "3010b968-8de8-49ec-8c14-9f545c0d4452", "from": "e253c9d4-98ef-4455-b238-389ff96ce2be", "toPort": "0", "fromPort": "0" }, { "to": "6c2ed912-8ba1-4e4a-884d-73382595da90", "from": "acfc302f-9350-4114-ae25-97b7c34e5078", "toPort": "0", "fromPort": "1" }, { "to": "ad0d7c05-0efd-44e6-943c-35bae37f1546", "from": "c152c0d6-8822-4521-828d-b36bb8d6c5c3", "toPort": "0", "fromPort": "0" }, { "to": "80e87ac8-1be3-4eef-8e7c-e13f09868bd3", "from": "8f078b55-0694-4edc-8a4b-faddd0ee9f83", "toPort": "0", "fromPort": "0" }, { "to": "5b467790-afcc-46e8-a7f8-1ce628a48837", "from": "a2c0086c-f856-46c2-818e-d4f1c2b00bd9", "toPort": "0", "fromPort": "0" }, { "to": "c152c0d6-8822-4521-828d-b36bb8d6c5c3", "from": "43183e68-bb8c-490c-ad6b-d51e3e31cf69", "toPort": "0", "fromPort": "0" }, { "to": "9fc0ce09-8f88-499b-a322-09d761b374b6", "from": "ad0d7c05-0efd-44e6-943c-35bae37f1546", "toPort": "0", "fromPort": "0" }, { "to": "665cad5b-6397-4427-90ab-4aae1789d93e", "from": "677c3ae3-52d0-4fcb-97d8-5671a176d1b2", "toPort": "0", "fromPort": "0" }, { "to": "43183e68-bb8c-490c-ad6b-d51e3e31cf69", "from": "3010b968-8de8-49ec-8c14-9f545c0d4452", "toPort": "0", "fromPort": "0" }, { "to": "9fc0ce09-8f88-499b-a322-09d761b374b6", "from": "080b40f3-e02a-4f2e-8f15-03bd8c146e72", "toPort": "0", "fromPort": "ai_languageModel" }, { "to": "8f078b55-0694-4edc-8a4b-faddd0ee9f83", "from": "759fa1da-ac35-41b4-8ab9-759079bc259f", "toPort": "0", "fromPort": "0" }, { "to": "e253c9d4-98ef-4455-b238-389ff96ce2be", "from": "6c2ed912-8ba1-4e4a-884d-73382595da90", "toPort": "0", "fromPort": "0" }, { "to": "acfc302f-9350-4114-ae25-97b7c34e5078", "from": "665cad5b-6397-4427-90ab-4aae1789d93e", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "a2c0086c-f856-46c2-818e-d4f1c2b00bd9", "name": "Manual Trigger", "type": "manualTrigger", "params": {}, "position": [ -2864, -128 ] }, { "id": "5b467790-afcc-46e8-a7f8-1ce628a48837", "name": "Get Products", "type": "integration", "params": { "options": {}, "service": "googleSheets", "operation": "read", "sheetName": { "__rl": true, "mode": "list", "value": 807909088, "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit#gid=807909088", "cachedResultName": "Products_Sheet_Template" }, "documentId": { "__rl": true, "mode": "list", "value": "YOUR_GOOGLE_SHEETS_DOCUMENT_ID", "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit?usp=drivesdk", "cachedResultName": "Products_Sheet_Template" } }, "position": [ -2592, -128 ] }, { "id": "acfc302f-9350-4114-ae25-97b7c34e5078", "name": "Loop Products", "type": "passthrough", "params": { "mode": "noOp", "options": { "reset": false } }, "position": [ -2256, -128 ] }, { "id": "6c2ed912-8ba1-4e4a-884d-73382595da90", "name": "Fetch Product Page", "type": "http", "params": { "url": "={{ $json.URL_Product }}", "options": { "timeout": 30000 }, "sendHeaders": true, "headerParameters": { "parameters": [ { "name": "User-Agent", "value": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36" } ] } }, "position": [ -2032, -112 ] }, { "id": "3010b968-8de8-49ec-8c14-9f545c0d4452", "name": "Get Price History", "type": "integration", "params": { "options": {}, "service": "googleSheets", "filtersUI": { "values": [ { "lookupValue": "={{ $('Loop Products').item.json.URL_Product }}", "lookupColumn": "URL_Product" } ] }, "operation": "read", "sheetName": { "__rl": true, "mode": "list", "value": 877762684, "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit#gid=877762684", "cachedResultName": "Price_History_Sheet_Template" }, "documentId": { "__rl": true, "mode": "list", "value": "YOUR_GOOGLE_SHEETS_DOCUMENT_ID", "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit?usp=drivesdk", "cachedResultName": "Price_History_Sheet_Template" } }, "position": [ -1488, -112 ] }, { "id": "43183e68-bb8c-490c-ad6b-d51e3e31cf69", "name": "Check Duplicate", "type": "code", "params": { "jsCode": "// Get current data\nconst productUrl = $('Get Products').first().json.URL_Product;\nconst currentPrice = parseFloat($('Extract Price').first().json.price.replace(/[$,]/g, ''));\nconst today = $now.toFormat('yyyy-MM-dd');\nconst timestamp = $now.toISO();\n\n// Get existing history for this product today\nconst historyItems = $('Get Price History').all();\n\n// Check if there's already a record for this product today\nconst existingTodayRecord = historyItems.find(item => \n item.json.URL_Product === productUrl && \n item.json.Date === today\n);\n\n// Prepare the data to return (will be used by next node to update sheet)\nreturn {\n url_product: productUrl,\n price: currentPrice,\n date: today,\n timestamp: timestamp,\n should_update: !!existingTodayRecord,\n row_number: existingTodayRecord ? existingTodayRecord.json.row_number : null\n};" }, "position": [ -1264, -112 ] }, { "id": "c152c0d6-8822-4521-828d-b36bb8d6c5c3", "name": "Add to History", "type": "integration", "params": { "columns": { "value": { "Date": "={{ $now }}", "Price": "={{ $('Extract Price').first().json.price }}", "Timestamp": "={{ $now }}", "URL_Product": "={{ $('Loop Products').first().json.URL_Product }}" }, "schema": [ { "id": "URL_Product", "type": "string", "display": true, "required": false, "displayName": "URL_Product", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Price", "type": "string", "display": true, "required": false, "displayName": "Price", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Date", "type": "string", "display": true, "required": false, "displayName": "Date", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Timestamp", "type": "string", "display": true, "required": false, "displayName": "Timestamp", "defaultMatch": false, "canBeUsedToMatch": true } ], "mappingMode": "defineBelow", "matchingColumns": [], "attemptToConvertTypes": false, "convertFieldsToString": false }, "options": {}, "service": "googleSheets", "operation": "append", "sheetName": { "__rl": true, "mode": "list", "value": 877762684, "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit#gid=877762684", "cachedResultName": "Price_History_Sheet_Template" }, "documentId": { "__rl": true, "mode": "list", "value": "YOUR_GOOGLE_SHEETS_DOCUMENT_ID", "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit?usp=drivesdk", "cachedResultName": "Price_History_Sheet_Template" } }, "position": [ -1040, -112 ] }, { "id": "ad0d7c05-0efd-44e6-943c-35bae37f1546", "name": "Prepare AI Data", "type": "code", "params": { "jsCode": "// Get current price\nconst currentPriceText = $('Extract Price').first().json.price;\nconst currentPrice = parseFloat(currentPriceText.replace(/[$,]/g, ''));\n\n// Get price history (last 60 days)\nconst historyItems = $('Get Price History').all();\n\n// Sort by date descending and get last 60 entries\nconst priceHistory = historyItems\n .map(item => ({\n date: item.json.Date,\n price: parseFloat(item.json.Price)\n }))\n .sort((a, b) => new Date(b.date) - new Date(a.date))\n .slice(0, 60);\n\n// Calculate statistics\nconst prices = priceHistory.map(h => h.price);\nconst avgPrice = prices.length > 0 ? prices.reduce((a, b) => a + b, 0) / prices.length : currentPrice;\nconst minPrice = prices.length > 0 ? Math.min(...prices) : currentPrice;\nconst maxPrice = prices.length > 0 ? Math.max(...prices) : currentPrice;\n\n// Prepare data for AI\nconst last30Days = priceHistory.slice(0, 30);\nconst priceData = last30Days.map(h => `${h.date}: $${h.price.toFixed(2)}`).join('\\n');\n\nconst targetPrice = $('Get Products').first().json.Target_Price;\n\nreturn {\n current_price: currentPrice,\n target_price: targetPrice,\n avg_price_60d: avgPrice.toFixed(2),\n min_price_60d: minPrice.toFixed(2),\n max_price_60d: maxPrice.toFixed(2),\n history_length: priceHistory.length,\n price_data_text: priceData,\n full_history: priceHistory\n};" }, "position": [ -752, -112 ] }, { "id": "9fc0ce09-8f88-499b-a322-09d761b374b6", "name": "AI Agent", "type": "llm", "params": { "text": "=Analyze this product price history and tell me if I should buy now or wait.\n\nCurrent Price: {{ $json.current_price }} \nTarget Price: {{ $json.target_price }} \nAverage (60 days): {{ $json.avg_price_60d }}\nMin (60 days): {{ $json.min_price_60d }} \nMax (60 days): {{ $json.max_price_60d }}\nPrice History (last 30 days):\n{{ $json.price_data_text }}\n\nProvide your analysis in JSON format with: recommendation, confidence, reason, urgency_score, predicted_trend.", "prompt": "=Analyze this product price history and tell me if I should buy now or wait.\n\nCurrent Price: {{ $json.current_price }} \nTarget Price: {{ $json.target_price }} \nAverage (60 days): {{ $json.avg_price_60d }}\nMin (60 days): {{ $json.min_price_60d }} \nMax (60 days): {{ $json.max_price_60d }}\nPrice History (last 30 days):\n{{ $json.price_data_text }}\n\nProvide your analysis in JSON format with: recommendation, confidence, reason, urgency_score, predicted_trend.", "options": { "systemMessage": "You are a price prediction expert. Analyze price history and provide buying recommendations. Always respond in valid JSON format with these exact fields: recommendation (BUY/WAIT), confidence (0-100), reason (brief explanation), urgency_score (0-100), predicted_trend (RISING/FALLING/STABLE)." }, "provider": "openai", "promptType": "define", "approximated": true, "systemMessage": "You are a price prediction expert. Analyze price history and provide buying recommendations. Always respond in valid JSON format with these exact fields: recommendation (BUY/WAIT), confidence (0-100), reason (brief explanation), urgency_score (0-100), predicted_trend (RISING/FALLING/STABLE)." }, "position": [ -544, -112 ] }, { "id": "080b40f3-e02a-4f2e-8f15-03bd8c146e72", "name": "OpenAI Chat Model", "type": "llm", "params": { "model": "gpt-4o-mini", "options": {}, "provider": "openai" }, "position": [ -544, 96 ] }, { "id": "759fa1da-ac35-41b4-8ab9-759079bc259f", "name": "Parse AI Response", "type": "code", "params": { "jsCode": "// Parse AI response\nlet aiResponse;\ntry {\n const content = $input.first().json.output || $input.first().json.text || '';\n // Try to extract JSON if wrapped in markdown\n const jsonMatch = content.match(/```json\\s*([\\s\\S]*?)```/) || content.match(/({[\\s\\S]*})/);\n const jsonStr = jsonMatch ? jsonMatch[1] : content;\n aiResponse = JSON.parse(jsonStr.trim());\n} catch (error) {\n // Fallback if parsing fails\n aiResponse = {\n recommendation: 'WAIT',\n confidence: 50,\n reason: 'Unable to parse AI response',\n urgency_score: 50,\n predicted_trend: 'STABLE'\n };\n}\n\n// Get data from Loop context\nconst loopItem = $('Loop Products').first().json;\nconst productUrl = loopItem.URL_Product;\nconst productName = loopItem.Product_Name || 'Product';\nconst userEmail = loopItem.User_Email;\nconst targetPrice = loopItem.Target_Price;\n\n// Get analysis data\nconst analysisData = $('Prepare AI Data').item.json;\nconst currentPrice = analysisData.current_price;\nconst avgPrice = analysisData.avg_price_60d;\nconst minPrice = analysisData.min_price_60d;\nconst maxPrice = analysisData.max_price_60d;\nconst priceHistory = analysisData.full_history;\n\n// Determine if should buy\nconst shouldBuy = aiResponse.recommendation === 'BUY' && currentPrice <= targetPrice;\n\n// Prepare chart data\nconst chartData = priceHistory.slice(0, 30).reverse();\nconst chartLabels = chartData.map(h => h.date);\nconst chartPrices = chartData.map(h => h.price);\n\nreturn {\n product_url: productUrl,\n product_name: productName,\n user_email: userEmail,\n current_price: currentPrice,\n target_price: targetPrice,\n avg_price: avgPrice,\n min_price: minPrice,\n max_price: maxPrice,\n ai_recommendation: aiResponse.recommendation,\n ai_confidence: aiResponse.confidence,\n ai_reason: aiResponse.reason,\n urgency_score: aiResponse.urgency_score,\n predicted_trend: aiResponse.predicted_trend,\n should_buy: shouldBuy,\n chart_labels: chartLabels,\n chart_prices: chartPrices\n};" }, "position": [ -256, -112 ] }, { "id": "8f078b55-0694-4edc-8a4b-faddd0ee9f83", "name": "Generate Chart", "type": "code", "params": { "jsCode": "// Generate QuickChart.io URL for price history chart\nconst labels = $json.chart_labels;\nconst prices = $json.chart_prices;\nconst currentPrice = $json.current_price;\nconst targetPrice = $json.target_price;\n\nconst chartConfig = {\n type: 'line',\n data: {\n labels: labels,\n datasets: [\n {\n label: 'Price History',\n data: prices,\n borderColor: 'rgb(75, 192, 192)',\n backgroundColor: 'rgba(75, 192, 192, 0.2)',\n tension: 0.1,\n fill: true\n },\n {\n label: 'Target Price',\n data: Array(labels.length).fill(targetPrice),\n borderColor: 'rgb(255, 99, 132)',\n borderDash: [5, 5],\n fill: false,\n pointRadius: 0\n }\n ]\n },\n options: {\n title: {\n display: true,\n text: 'Price History (Last 30 Days)'\n },\n scales: {\n yAxes: [{\n ticks: {\n callback: function(value) {\n return '$' + value.toFixed(2);\n }\n }\n }]\n }\n }\n};\n\nconst encodedConfig = encodeURIComponent(JSON.stringify(chartConfig));\nconst chartUrl = `https://quickchart.io/chart?c=${encodedConfig}&width=600&height=300`;\n\nreturn {\n ...($json),\n chart_url: chartUrl\n};" }, "position": [ -80, -112 ] }, { "id": "80e87ac8-1be3-4eef-8e7c-e13f09868bd3", "name": "Should Buy?", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "should-buy-condition", "operator": { "type": "boolean", "operation": "true", "singleValue": true }, "leftValue": "={{ $json.should_buy }}", "rightValue": true } ] } }, "position": [ 144, -112 ] }, { "id": "677c3ae3-52d0-4fcb-97d8-5671a176d1b2", "name": "Send Email Alert", "type": "integration", "params": { "sendTo": "={{ $json.user_email }}", "message": "=

Smart Price Monitor - AI Recommendation

\n\n

Product: {{ $json.product_name }}

\n\n

📊 Current Analysis

Current Price: ${{ $json.current_price }}
Your Target: ${{ $json.target_price }}
60-Day Average: ${{ $json.avg_price }}
60-Day Min: ${{ $json.min_price }}
60-Day Max: ${{ $json.max_price }}

\n\n

🤖 AI Recommendation

Action: {{ $json.ai_recommendation }}
Confidence: {{ $json.ai_confidence }}%
Urgency Score: {{ $json.urgency_score }}/100
Predicted Trend: {{ $json.predicted_trend }}
Reason: {{ $json.ai_reason }}

\n\n

📈 Price History Chart

$\"Price$

\n\n

This analysis is based on historical price data and AI prediction. Always verify current price before purchasing.

", "options": { "appendAttribution": false }, "service": "gmail", "subject": "=🎯 AI Recommends: {{ $json.ai_recommendation }} - {{ $json.product_name }}", "operation": "read" }, "position": [ 400, -208 ] }, { "id": "665cad5b-6397-4427-90ab-4aae1789d93e", "name": "Update Products Sheet", "type": "integration", "params": { "columns": { "value": { "Last_Check": "={{ $now.toISO() }}", "Last_Price": "={{ $('Parse AI Response').item.json.current_price }}", "Should_Buy": "={{ $('Parse AI Response').item.json.should_buy }}", "User_Email": "={{ $('Parse AI Response').item.json.user_email }}", "row_number": 0, "URL_Product": "={{ $('Parse AI Response').item.json.product_url }}", "Product_Name": "={{ $('Parse AI Response').item.json.product_name }}", "Target_Price": "={{ $('Parse AI Response').item.json.target_price }}", "AI_Confidence": "={{ $('Parse AI Response').item.json.ai_confidence }}", "Urgency_Score": "={{ $('Parse AI Response').item.json.urgency_score }}", "Predicted_Trend": "={{ $('Parse AI Response').item.json.predicted_trend }}", "AI_Recommendation": "={{ $('Parse AI Response').item.json.ai_recommendation }}" }, "schema": [ { "id": "URL_Product", "type": "string", "display": true, "required": false, "displayName": "URL_Product", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Product_Name", "type": "string", "display": true, "required": false, "displayName": "Product_Name", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Target_Price", "type": "string", "display": true, "required": false, "displayName": "Target_Price", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "User_Email", "type": "string", "display": true, "required": false, "displayName": "User_Email", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Last_Price", "type": "string", "display": true, "required": false, "displayName": "Last_Price", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Last_Check", "type": "string", "display": true, "required": false, "displayName": "Last_Check", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "AI_Recommendation", "type": "string", "display": true, "required": false, "displayName": "AI_Recommendation", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "AI_Confidence", "type": "string", "display": true, "required": false, "displayName": "AI_Confidence", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Urgency_Score", "type": "string", "display": true, "required": false, "displayName": "Urgency_Score", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Predicted_Trend", "type": "string", "display": true, "required": false, "displayName": "Predicted_Trend", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "Should_Buy", "type": "string", "display": true, "required": false, "displayName": "Should_Buy", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "row_number", "type": "number", "display": true, "readOnly": true, "required": false, "displayName": "row_number", "defaultMatch": false, "canBeUsedToMatch": true } ], "mappingMode": "defineBelow", "matchingColumns": [ "URL_Product" ], "attemptToConvertTypes": false, "convertFieldsToString": false }, "options": {}, "service": "googleSheets", "operation": "update", "sheetName": { "__rl": true, "mode": "list", "value": 807909088, "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit#gid=807909088", "cachedResultName": "Products_Sheet_Template" }, "documentId": { "__rl": true, "mode": "list", "value": "YOUR_GOOGLE_SHEETS_DOCUMENT_ID", "cachedResultUrl": "https://docs.google.com/spreadsheets/d/YOUR_GOOGLE_SHEETS_DOCUMENT_ID/edit?usp=drivesdk", "cachedResultName": "Products_Sheet_Template" } }, "position": [ 640, -96 ] }, { "id": "e253c9d4-98ef-4455-b238-389ff96ce2be", "name": "Extract Price", "type": "passthrough", "params": { "mode": "noOp", "options": {}, "operation": "extractHtmlContent", "extractionValues": { "values": [ { "key": "price", "cssSelector": ".a-price-whole" } ] } }, "position": [ -1792, -112 ] } ] }

Automated smart price monitor with AI prediction, Google Sheets and Gmail