{ "edges": [ { "to": "3341bc66-95c5-4b39-99f5-d570f57ed9ae", "from": "9f9ea823-ff65-4038-b2f2-210c56dbe458", "toPort": "0", "fromPort": "0" }, { "to": "4c5000ed-1a4f-4d84-b110-8ef575768b8b", "from": "3254ebf7-a419-4a02-b77e-f71d8d24d597", "toPort": "0", "fromPort": "0" }, { "to": "9f9ea823-ff65-4038-b2f2-210c56dbe458", "from": "b4c864af-128c-4434-bf0c-a4dcd76f5794", "toPort": "0", "fromPort": "0" }, { "to": "b4c864af-128c-4434-bf0c-a4dcd76f5794", "from": "4c5000ed-1a4f-4d84-b110-8ef575768b8b", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "4c5000ed-1a4f-4d84-b110-8ef575768b8b", "name": "Fetch Natural Gas Page1", "type": "http", "params": { "url": "https://oilprice.com/futures/natural-gas/", "options": {} }, "position": [ 624, 208 ] }, { "id": "3254ebf7-a419-4a02-b77e-f71d8d24d597", "name": "Market Hours Trigger1", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 10 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 12 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 14 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 16 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 18, "triggerAtMinute": 19 }, { "field": "weeks", "triggerAtDay": [ 1, 2, 3, 4, 5 ], "triggerAtHour": 19, "triggerAtMinute": 20 } ] } }, "position": [ 400, 208 ] }, { "id": "b4c864af-128c-4434-bf0c-a4dcd76f5794", "name": "Extract Spot & Futures1", "type": "code", "params": { "jsCode": "// n8n Code Node to Extract Henry Hub Natural Gas Futures Prices + CURRENT SPOT PRICE\n// This function extracts all available contract data AND the current real-time price\n\nconst items = $input.all();\nconst extractedData = [];\n\nfor (const item of items) {\n const htmlContent = item.json.data;\n \n // ========================================\n // EXTRACT CURRENT SPOT PRICE (Real-time)\n // ========================================\n let currentSpotPrice = null;\n let currentChange = null;\n let currentChangePercent = null;\n let currentChangeDirection = null;\n \n // Look for the current Natural Gas spot price in the header section\n const spotPricePattern = /]*>(.*?)<\\/tr>/s;\n const spotMatch = htmlContent.match(spotPricePattern);\n \n if (spotMatch) {\n const spotRow = spotMatch[1];\n \n // Extract current price\n const priceMatch = spotRow.match(/\\s*([\\d.]+)\\s*\\s*([+\\-][\\d.]+)/);\n if (changeMatch) {\n currentChange = parseFloat(changeMatch[1]);\n }\n \n // Extract change percentage\n const percentMatch = spotRow.match(/\\s*([+\\-][\\d.]+)%/);\n if (percentMatch) {\n currentChangePercent = parseFloat(percentMatch[1]);\n }\n \n // Extract direction (up/down)\n const directionMatch = spotRow.match(/class=\"(change_up|change_down)/);\n if (directionMatch) {\n currentChangeDirection = directionMatch[1].replace('change_', '');\n }\n }\n \n // ========================================\n // EXTRACT FUTURES CONTRACTS DATA\n // ========================================\n const rowPattern = /
]*>((?:(?!
/gs;\n \n const contracts_list = [];\n let match;\n \n while ((match = rowPattern.exec(htmlContent)) !== null) {\n const symbol = match[1];\n const days5Price = match[2] ? parseFloat(match[2]) : null;\n const days30Price = match[3] ? parseFloat(match[3]) : null;\n const days90Price = match[4] ? parseFloat(match[4]) : null;\n const yearPrice = match[5] ? parseFloat(match[5]) : null;\n const ytdPrice = match[6] ? parseFloat(match[6]) : null;\n const innerHtml = match[7];\n \n // Extract contract details\n const nameMatch = innerHtml.match(/data-name=\"([^\"]+)\"/);\n const lastPriceMatch = innerHtml.match(/
\\s*([\\d.]+)/);\n const changeMatch = innerHtml.match(/
\\s*([+\\-][\\d.]+)/);\n const openMatch = innerHtml.match(/
\\s*([\\d.]+)/);\n const highMatch = innerHtml.match(/
\\s*([\\d.]+)/);\n const lowMatch = innerHtml.match(/
\\s*([\\d.]+)/);\n const dateMatch = innerHtml.match(/
\\s*([^<\\n]+)/);\n \n const lastPrice = lastPriceMatch ? parseFloat(lastPriceMatch[1]) : null;\n const changeDirection = changeMatch ? changeMatch[1] : null;\n const changeValue = changeMatch ? parseFloat(changeMatch[2]) : null;\n \n const contractData = {\n symbol: symbol,\n contract_name: nameMatch ? nameMatch[1] : '',\n last_price: lastPrice,\n change_direction: changeDirection,\n change_value: changeValue,\n change_percent: lastPrice && changeValue ? parseFloat(((changeValue / lastPrice) * 100).toFixed(2)) : null,\n open: openMatch ? parseFloat(openMatch[1]) : null,\n high: highMatch ? parseFloat(highMatch[1]) : null,\n low: lowMatch ? parseFloat(lowMatch[1]) : null,\n date_time: dateMatch ? dateMatch[1].trim() : '',\n price_5_days_ago: days5Price,\n price_30_days_ago: days30Price,\n price_90_days_ago: days90Price,\n price_1_year_ago: yearPrice,\n price_ytd: ytdPrice\n };\n \n // Calculate percentage changes\n if (lastPrice) {\n if (days5Price) contractData.change_5_days_percent = parseFloat((((lastPrice - days5Price) / days5Price) * 100).toFixed(2));\n if (days30Price) contractData.change_30_days_percent = parseFloat((((lastPrice - days30Price) / days30Price) * 100).toFixed(2));\n if (days90Price) contractData.change_90_days_percent = parseFloat((((lastPrice - days90Price) / days90Price) * 100).toFixed(2));\n if (yearPrice) contractData.change_1_year_percent = parseFloat((((lastPrice - yearPrice) / yearPrice) * 100).toFixed(2));\n if (ytdPrice) contractData.change_ytd_percent = parseFloat((((lastPrice - ytdPrice) / ytdPrice) * 100).toFixed(2));\n }\n \n contractData.scraped_at = new Date().toISOString();\n contracts_list.push(contractData);\n }\n \n // ========================================\n // COMBINE SPOT PRICE + CONTRACTS\n // ========================================\n // Add spot price data as a special entry at the beginning\n if (currentSpotPrice) {\n extractedData.push({\n type: 'spot_price',\n spot_price: currentSpotPrice,\n spot_change: currentChange,\n spot_change_percent: currentChangePercent,\n spot_direction: currentChangeDirection,\n timestamp: new Date().toISOString(),\n timestamp_ist: new Date().toLocaleString('en-IN', { \n timeZone: 'Asia/Kolkata',\n year: 'numeric',\n month: 'short',\n day: 'numeric',\n hour: '2-digit',\n minute: '2-digit',\n second: '2-digit',\n hour12: true\n })\n });\n }\n \n // Add all contract data\n contracts_list.forEach(contract => {\n extractedData.push({\n type: 'futures_contract',\n ...contract\n });\n });\n}\n\nreturn extractedData.map(data => ({ json: data }));\n" }, "position": [ 848, 208 ] }, { "id": "9f9ea823-ff65-4038-b2f2-210c56dbe458", "name": "Build HTML Table1", "type": "code", "params": { "jsCode": "// Get all input data\nconst items = $input.all();\n\n// Separate spot price and futures contracts\nlet spotData = null;\nconst futuresContracts = [];\n\nitems.forEach(item => {\n if (item.json.type === 'spot_price') {\n spotData = item.json;\n } else if (item.json.type === 'futures_contract') {\n futuresContracts.push(item.json);\n }\n});\n\n// Build the message\nlet message = `📊 HENRY HUB NATURAL GAS FUTURES\\n`;\nmessage += `📅 ${spotData.timestamp_ist}\\n`;\nmessage += `━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\\n\\n`;\n\n// Spot Price Section - TABLE FORMAT (same as futures)\nconst isPositive = spotData.spot_change > 0;\nconst indicator = isPositive ? '🟢' : '🔴';\n\nmessage += `💰 SPOT PRICE\\n\\n`;\nmessage += `
`;\nmessage += `Contract Period Price Change\\n`;\nmessage += `━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\\n`;\n\n// Format spot price row\nconst spotSymbol = `${indicator} SPOT `.padEnd(10);\nconst today = new Date();\nconst todayStr = today.toLocaleDateString('en-GB', { day: 'numeric', month: 'short', year: '2-digit' }).replace(/ /g, ' ');\nconst spotPeriod = `Today`.padEnd(10);\nconst spotPrice = `$${spotData.spot_price.toFixed(2)}`.padStart(7);\nconst spotChange = `${isPositive ? '$+' : '$'}${Math.abs(spotData.spot_change).toFixed(2)}`.padStart(8);\n\nmessage += `${spotSymbol} ${spotPeriod} ${spotPrice} ${spotChange}\\n`;\nmessage += `
\\n\\n`;\n\nmessage += `━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\\n`;\nmessage += `📈 NEXT 12 MONTHS\\n\\n`;\n\n// Futures contracts table\nmessage += `
`;\nmessage += `Contract Period Price Change\\n`;\nmessage += `━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\\n`;\n\nconst monthlyContracts = futuresContracts.slice(0, 12);\n\nmonthlyContracts.forEach(contract => {\n // Extract month and year from contract name\n const nameParts = contract.contract_name.replace('Natural Gas ', '').split(' ');\n const month = nameParts[0].substring(0, 3); // First 3 letters of month\n const year = `'${nameParts[1].substring(2)}`; // Last 2 digits of year\n \n // Use 30-day price as current (since last_price is null)\n const currentPrice = contract.price_30_days_ago;\n \n // Calculate change from 1 year ago\n const changeValue = contract.price_1_year_ago ? currentPrice - contract.price_1_year_ago : 0;\n \n // Format the row with proper spacing\n const symbol = `🔴 ${contract.symbol.padEnd(6)}`;\n const period = `${month} ${year}`.padEnd(10);\n const price = `$${currentPrice.toFixed(2)}`.padStart(7);\n const change = `${changeValue > 0 ? '$+' : '$'}${changeValue.toFixed(2)}`.padStart(8);\n \n message += `${symbol} ${period} ${price} ${change}\\n`;\n});\n\nmessage += `
\\n\\n`;\n\n// Summary stats\nconst monthlyPrices = monthlyContracts.map(c => c.price_30_days_ago);\nconst lowestPrice = Math.min(...monthlyPrices);\nconst highestPrice = Math.max(...monthlyPrices);\nconst avgPrice = monthlyPrices.reduce((a, b) => a + b, 0) / monthlyPrices.length;\n\nmessage += `📊 Range: $${lowestPrice.toFixed(2)} - $${highestPrice.toFixed(2)}\\n`;\nmessage += `📈 Avg: $${avgPrice.toFixed(2)}\\n\\n`;\n\nmessage += `━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\\n`;\nmessage += `🔔 Source: Henry Hub Futures Data`;\n\n// Return the formatted message\nreturn {\n json: {\n telegram_message: message\n }\n};" }, "position": [ 1072, 208 ] }, { "id": "3341bc66-95c5-4b39-99f5-d570f57ed9ae", "name": "Send Telegram Update1", "type": "integration", "params": { "text": "={{ $json.telegram_message }}", "chatId": "YOUR_TELEGRAM_CHAT_ID", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML", "appendAttribution": false } }, "position": [ 1312, 208 ] } ] }

Send Henry Hub natural gas forward curve updates to Telegram with zero API cost