{ "edges": [ { "to": "8467a8ed-7938-46d7-b890-738ac6288fc0", "from": "2f39141f-73cf-4163-9295-6d7522ed30f5", "toPort": "0", "fromPort": "0" }, { "to": "8a60254d-4ad8-4fa3-8d90-cd4df1b68b94", "from": "9b4bd061-ca85-4279-9163-f165ad1ed7e5", "toPort": "0", "fromPort": "0" }, { "to": "2f39141f-73cf-4163-9295-6d7522ed30f5", "from": "8a60254d-4ad8-4fa3-8d90-cd4df1b68b94", "toPort": "0", "fromPort": "0" }, { "to": "9b4bd061-ca85-4279-9163-f165ad1ed7e5", "from": "8959692d-f633-40c8-b2f8-799570b5b165", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "8959692d-f633-40c8-b2f8-799570b5b165", "name": "Market Hours Trigger1", "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": [ 448, 144 ] }, { "id": "9b4bd061-ca85-4279-9163-f165ad1ed7e5", "name": "Fetch Brent Page1", "type": "http", "params": { "url": "https://oilprice.com/futures/brent/", "options": {} }, "position": [ 640, 144 ] }, { "id": "8a60254d-4ad8-4fa3-8d90-cd4df1b68b94", "name": "Parse 10 Contracts1", "type": "code", "params": { "jsCode": "// CORRECTED Code - Extracts correct \"Last\" price column\nconst htmlContent = $input.item.json.data || \"\";\n\nif (!htmlContent || typeof htmlContent !== 'string') {\n return [{ json: { error: \"No HTML content\" } }];\n}\n\nconst now = new Date();\nconst scrapeDate = now.toISOString().split('T')[0];\nconst scrapeTime = now.toTimeString().split(' ')[0];\n\nconst symbolsData = [\n { symbol: 'CBH26', month: 'Mar' },\n { symbol: 'CBJ26', month: 'Apr' },\n { symbol: 'CBK26', month: 'May' },\n { symbol: 'CBM26', month: 'Jun' },\n { symbol: 'CBN26', month: 'Jul' },\n { symbol: 'CBQ26', month: 'Aug' },\n { symbol: 'CBU26', month: 'Sep' },\n { symbol: 'CBV26', month: 'Oct' },\n { symbol: 'CBX26', month: 'Nov' },\n { symbol: 'CBZ26', month: 'Dec' }\n];\n\nconst results = [];\n\nfor (const { symbol, month } of symbolsData) {\n const idx = htmlContent.indexOf(symbol);\n \n if (idx > -1) {\n // Get context AFTER the symbol (not before)\n // This ensures we get data from the same row\n const ctx = htmlContent.substring(idx, Math.min(htmlContent.length, idx + 800));\n \n // Look for the \"Last\" column value specifically\n // Pattern: symbol, then month/year, then the FIRST number is Last price\n const priceMatch = ctx.match(/CBH26[\\s\\S]{0,200}?<\\/a>[\\s\\S]{0,200}?]*>\\s*([0-9]{2}\\.[0-9]{2})\\s*]*class=\"[^\"]*last[^\"]*\"[^>]*>\\s*([0-9]{2}\\.[0-9]{2})/i);\n \n // Try another pattern - look for first price after contract name\n const firstPriceMatch = ctx.match(/2026[^0-9]*([0-9]{2}\\.[0-9]{2})/);\n \n const price = lastPriceMatch ? lastPriceMatch[1] : \n (priceMatch ? priceMatch[1] : \n (firstPriceMatch ? firstPriceMatch[1] : null));\n \n if (price) {\n // Find change value\n const changeMatch = ctx.match(/([+\\-][0-9]\\.[0-9]{2})/);\n \n // Find time\n const timeMatch = ctx.match(/([0-9]{2}:[0-9]{2})/);\n \n results.push({\n json: {\n symbol: symbol,\n month: month,\n year: \"2026\",\n contract: `${month} 2026`,\n price_usd: parseFloat(price),\n change: changeMatch ? parseFloat(changeMatch[1]) : null,\n website_update_time: timeMatch ? timeMatch[1] : \"\",\n scrape_date: scrapeDate,\n scrape_time: scrapeTime,\n source: \"https://oilprice.com/futures/brent/\",\n commodity: \"Brent Crude Oil Futures\"\n }\n });\n }\n }\n}\n\nif (results.length === 0) {\n return [{\n json: {\n error: \"No contracts extracted\",\n scrape_date: scrapeDate\n }\n }];\n}\n\nreturn results;\n" }, "position": [ 896, 144 ] }, { "id": "2f39141f-73cf-4163-9295-6d7522ed30f5", "name": "Aggregate Items1", "type": "passthrough", "params": { "mode": "aggregate", "options": {}, "aggregate": "aggregateAllItemData" }, "position": [ 1088, 144 ] }, { "id": "8467a8ed-7938-46d7-b890-738ac6288fc0", "name": "Send Telegram Table1", "type": "integration", "params": { "text": "=🛢️ Brent 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' }}\n━━━━━━━━━━━━━━━━━━━━━━\n\n

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

\n\n📊 Range: ${{ Math.min(...$json.data.map(d => d.price_usd)) }} - ${{ Math.max(...$json.data.map(d => d.price_usd)) }}\n📈 Avg: {{ ($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🔗 Source", "chatId": "123456789", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML", "appendAttribution": false } }, "position": [ 1360, 144 ] } ] }

Send daily Brent crude oil futures prices to Telegram with 0 API cost