{ "edges": [ { "to": "1fb11c47-0ebd-42a6-9f3d-edda675f6005", "from": "d7c9c504-8ee8-42f4-a907-cd34eeacb8c2", "toPort": "0", "fromPort": "0" }, { "to": "9d056cdc-1924-47b1-8968-b37d671bd1ff", "from": "761e94e5-a17e-4c63-8392-2438f7b749c8", "toPort": "0", "fromPort": "0" }, { "to": "761e94e5-a17e-4c63-8392-2438f7b749c8", "from": "a22c09b0-7b98-40bf-bcb0-b5af2e17109d", "toPort": "0", "fromPort": "0" }, { "to": "d7c9c504-8ee8-42f4-a907-cd34eeacb8c2", "from": "9d056cdc-1924-47b1-8968-b37d671bd1ff", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "9d056cdc-1924-47b1-8968-b37d671bd1ff", "name": "Extract WTI Futures Data", "type": "code", "params": { "jsCode": "// Extracts WTI Crude Oil Futures data dynamically\nconst htmlContent = $input.item.json.data || \"\";\n\nif (!htmlContent || typeof htmlContent !== 'string') {\n return [{ json: { error: \"No HTML content found from the HTTP Request.\" } }];\n}\n\nconst now = new Date();\nconst scrapeDate = now.toISOString().split('T')[0];\nconst scrapeTime = now.toTimeString().split(' ')[0];\n\nconst results = [];\nconst foundSymbols = new Set();\n\n// WTI contracts use the \"CL\" prefix followed by a month code and 2-digit year (e.g., CLN26)\nconst symbolRegex = /CL([FGHJKMNQUVXZ])([0-9]{2})/g;\nlet match;\n\nconst monthMap = {\n 'F': 'Jan', 'G': 'Feb', 'H': 'Mar', 'J': 'Apr', 'K': 'May', 'M': 'Jun',\n 'N': 'Jul', 'Q': 'Aug', 'U': 'Sep', 'V': 'Oct', 'X': 'Nov', 'Z': 'Dec'\n};\n\nwhile ((match = symbolRegex.exec(htmlContent)) !== null) {\n const symbol = match[0];\n \n // Prevent duplicates if the symbol appears multiple times on the page\n if (foundSymbols.has(symbol)) continue;\n foundSymbols.add(symbol);\n\n const monthCode = match[1];\n const yearSuffix = match[2];\n const month = monthMap[monthCode];\n const year = \"20\" + yearSuffix;\n\n const idx = match.index;\n // Get context AFTER the symbol to extract its row data\n const ctx = htmlContent.substring(idx, Math.min(htmlContent.length, idx + 400));\n\n // Extract price: Match the first valid decimal price (e.g., 91.74) following the symbol\n const priceRegex = new RegExp(`${symbol}[\\\\s\\\\S]{0,150}?(?:]*>|]*>|\\\\s)([0-9]{2,3}\\\\.[0-9]{2})(?:<|\\\\s)`);\n const priceMatch = ctx.match(priceRegex) || ctx.match(/([0-9]{2,3}\\.[0-9]{2})/);\n\n // Extract change: Match the first number with an explicit + or - sign\n const changeMatch = ctx.match(/([+\\-][0-9]+\\.[0-9]{2})/);\n\n // Extract time or date (e.g., 18:05 or 22/05)\n const timeMatch = ctx.match(/([0-2][0-9]:[0-5][0-9]|[0-3][0-9]\\/[0-1][0-9])/);\n\n if (priceMatch) {\n results.push({\n json: {\n symbol: symbol,\n month: month,\n year: year,\n contract: `${month} ${year}`,\n price_usd: parseFloat(priceMatch[1]),\n change: changeMatch ? parseFloat(changeMatch[1]) : 0,\n website_update_time: timeMatch ? timeMatch[1] : \"\",\n scrape_date: scrapeDate,\n scrape_time: scrapeTime,\n source: \"https://oilprice.com/futures/wti/\",\n commodity: \"WTI Crude Oil\"\n }\n });\n }\n}\n\n// Sort chronologically by year, then month\nconst monthOrder = { 'Jan':1, 'Feb':2, 'Mar':3, 'Apr':4, 'May':5, 'Jun':6, 'Jul':7, 'Aug':8, 'Sep':9, 'Oct':10, 'Nov':11, 'Dec':12 };\nresults.sort((a, b) => {\n if (a.json.year !== b.json.year) return parseInt(a.json.year) - parseInt(b.json.year);\n return monthOrder[a.json.month] - monthOrder[b.json.month];\n});\n\n// Limit to the next 15 contracts to ensure the Telegram message fits well on mobile screens\nconst finalResults = results.slice(0, 15);\n\nif (finalResults.length === 0) {\n return [{ json: { error: \"No contracts extracted\", scrape_date: scrapeDate } }];\n}\n\nreturn finalResults;" }, "position": [ 1024, 128 ] }, { "id": "d7c9c504-8ee8-42f4-a907-cd34eeacb8c2", "name": "Aggregate Crude Data", "type": "passthrough", "params": { "mode": "aggregate", "options": {}, "aggregate": "aggregateAllItemData" }, "position": [ 1232, 128 ] }, { "id": "a22c09b0-7b98-40bf-bcb0-b5af2e17109d", "name": "When Market Hour Starts", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 9 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 11, "triggerAtMinute": 11 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 13, "triggerAtMinute": 30 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 16 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 19, "triggerAtMinute": 15 } ] } }, "position": [ 608, 128 ] }, { "id": "1fb11c47-0ebd-42a6-9f3d-edda675f6005", "name": "Send Telegram Alert", "type": "integration", "params": { "text": "==🇺🇸 WTI Crude Oil Futures\n📅 {{ $json.data[0].scrape_date }} • {{ $json.data[0].scrape_time }}\n\n{{ $json.data.every(item => item.change >= 0) ? '✅ ALL UP' : $json.data.every(item => item.change < 0) ? '⚠️ ALL DOWN' : '📊 MIXED MARKET' }}\n━━━━━━━━━━━━━━━━━━━━━━\n

\nSymb   Period  Price     Change\n───────────────────────────────\n{{ $json.data.map(item => {\n  const emoji = item.change > 0 ? '🟢' : item.change < 0 ? '🔴' : '⚪';\n  const symbol = item.symbol.padEnd(6);\n  const period = `${item.month}${String(item.year).slice(-2)}`.padEnd(7);\n  const price = `$${item.price_usd.toFixed(2)}`.padEnd(9);\n  const change = `${item.change >= 0 ? '+' : ''}${item.change.toFixed(2)}`;\n  return `${emoji} ${symbol} ${period} ${price} ${change}`;\n}).join('\\n') }}\n

\n\n📊 Range: ${{ Math.min(...$json.data.map(d => d.price_usd)).toFixed(2) }} - ${{ Math.max(...$json.data.map(d => d.price_usd)).toFixed(2) }}\n📈 Avg Change: {{ ($json.data.reduce((sum, d) => sum + d.change, 0) / $json.data.length).toFixed(2) >= 0 ? '+' : '' }}${{ ($json.data.reduce((sum, d) => sum + d.change, 0) / $json.data.length).toFixed(2) }}\n\n🔗 Live WTI Source", "chatId": "123456789", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML", "appendAttribution": false } }, "position": [ 1456, 128 ] }, { "id": "761e94e5-a17e-4c63-8392-2438f7b749c8", "name": "Fetch WTI Crude Prices", "type": "http", "params": { "url": "https://oilprice.com/futures/wti/", "options": {} }, "position": [ 800, 128 ] } ] }

Track WTI crude futures from Oilprice.com and send Telegram alerts