{ "edges": [ { "to": "81532dcb-26f5-4b6a-abe5-3a0719956a2b", "from": "3d7f517f-b1a2-453b-a52a-6b628f78b01d", "toPort": "0", "fromPort": "0" }, { "to": "e895bafe-82b3-49d6-9345-6f96892fc0dd", "from": "44c2c592-6541-4263-a3cf-69197987323e", "toPort": "0", "fromPort": "0" }, { "to": "cb3da9a8-f39c-4931-89b1-35cc9c8a32e6", "from": "0ef01345-c99a-4fa8-bbba-6f2135016305", "toPort": "0", "fromPort": "0" }, { "to": "44c2c592-6541-4263-a3cf-69197987323e", "from": "8cfb215d-975c-4f69-8869-902c134bc4b6", "toPort": "0", "fromPort": "0" }, { "to": "0ef01345-c99a-4fa8-bbba-6f2135016305", "from": "4a4d3e65-b267-45ea-b919-ec191a45b5ca", "toPort": "0", "fromPort": "0" }, { "to": "8cfb215d-975c-4f69-8869-902c134bc4b6", "from": "dfc6b969-e588-403c-afdc-13259c754669", "toPort": "0", "fromPort": "ai_languageModel" }, { "to": "3d7f517f-b1a2-453b-a52a-6b628f78b01d", "from": "e895bafe-82b3-49d6-9345-6f96892fc0dd", "toPort": "0", "fromPort": "0" }, { "to": "8cfb215d-975c-4f69-8869-902c134bc4b6", "from": "cb3da9a8-f39c-4931-89b1-35cc9c8a32e6", "toPort": "0", "fromPort": "0" }, { "to": "44c2c592-6541-4263-a3cf-69197987323e", "from": "cb3da9a8-f39c-4931-89b1-35cc9c8a32e6", "toPort": "1", "fromPort": "0" }, { "to": "0ef01345-c99a-4fa8-bbba-6f2135016305", "from": "01fb9a7a-bca2-417a-ba7c-8305afce9e87", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "01fb9a7a-bca2-417a-ba7c-8305afce9e87", "name": "When clicking ‘Execute workflow’", "type": "manualTrigger", "params": {}, "position": [ 48, 268 ] }, { "id": "8cfb215d-975c-4f69-8869-902c134bc4b6", "name": "AI Agent", "type": "llm", "params": { "text": "=HTML:{{ $json.compact_text }}\nNOW_ISO: {{$now}}\n", "prompt": "=HTML:{{ $json.compact_text }}\nNOW_ISO: {{$now}}\n", "options": { "systemMessage": "You are an enrichment model.\n\nYou will receive a compact, pre-extracted list of eBay deals (NOT raw HTML). Each line contains:\nID, TITLE, PRICE, CURRENCY, ORIGINAL_PRICE, URL, IMG.\n\nTask:\nFor each item, return JSON with ONLY these fields:\n{\n \"listing_id\": string,\n \"category_ai\": \"tech\"|\"home\"|\"fashion\"|\"other\",\n \"deal_score\": number, // 0..10\n \"score_reason\": string // max 120 chars, no emojis\n}\n\nRules:\n- Return an array of objects.\n- listing_id must match the ID from input.\n- category_ai must be EXACTLY one of: tech, home, fashion, other.\n- deal_score:\n - If title is missing or too generic -> score <= 4.\n - If price looks unusually low for the product type -> +2.\n - If title contains clear brand/model -> +1.\n - If original_price exists and discount seems strong -> +1.\n - Clamp 0..10.\n- score_reason: 1 short sentence explaining the score.\n- Output must be pure JSON only (no markdown, no extra text).\n" }, "provider": "openai", "promptType": "define", "approximated": true, "systemMessage": "You are an enrichment model.\n\nYou will receive a compact, pre-extracted list of eBay deals (NOT raw HTML). Each line contains:\nID, TITLE, PRICE, CURRENCY, ORIGINAL_PRICE, URL, IMG.\n\nTask:\nFor each item, return JSON with ONLY these fields:\n{\n \"listing_id\": string,\n \"category_ai\": \"tech\"|\"home\"|\"fashion\"|\"other\",\n \"deal_score\": number, // 0..10\n \"score_reason\": string // max 120 chars, no emojis\n}\n\nRules:\n- Return an array of objects.\n- listing_id must match the ID from input.\n- category_ai must be EXACTLY one of: tech, home, fashion, other.\n- deal_score:\n - If title is missing or too generic -> score <= 4.\n - If price looks unusually low for the product type -> +2.\n - If title contains clear brand/model -> +1.\n - If original_price exists and discount seems strong -> +1.\n - Clamp 0..10.\n- score_reason: 1 short sentence explaining the score.\n- Output must be pure JSON only (no markdown, no extra text).\n" }, "position": [ 784, 304 ] }, { "id": "e895bafe-82b3-49d6-9345-6f96892fc0dd", "name": "Code in JavaScript", "type": "code", "params": { "jsCode": "/**\n * POST-LMM JOIN (NO FILTERING)\n * Expects (after MERGE):\n * - $json.pre_extracted : array base items\n * - $json.output : string with JSON array from LLM\n *\n * Returns: ALL items (one n8n item per product) with enrichment fields.\n */\n\nfunction stripCodeFences(s) {\n if (typeof s !== \"string\") return s;\n const t = s.trim();\n if (!t.startsWith(\"```\")) return t;\n let body = t.replace(/^```(?:json)?\\s*/i, \"\");\n if (body.endsWith(\"```\")) body = body.slice(0, -3);\n return body.trim();\n}\n\nfunction tryParseJSON(text) {\n if (Array.isArray(text)) return text;\n if (typeof text !== \"string\") return null;\n try { return JSON.parse(text); } catch {}\n const m = text.match(/(\\[[\\s\\S]*\\]|\\{[\\s\\S]*\\})/);\n if (m) {\n try { return JSON.parse(m[1]); } catch {}\n }\n return null;\n}\n\nfunction clamp(n, min, max) {\n return Math.max(min, Math.min(max, n));\n}\n\nfunction toNumberOrNull(v) {\n if (v === null || v === undefined) return null;\n if (typeof v === \"number\") return Number.isFinite(v) ? v : null;\n const s = String(v);\n const m = s.match(/(\\d{1,6}(?:[.,]\\d{1,2})?)/);\n if (!m) return null;\n const f = parseFloat(m[1].replace(\",\", \".\"));\n return Number.isFinite(f) ? f : null;\n}\n\n// thresholds (4 categorías)\nconst thresholdsByCategory = { tech: 30, home: 20, fashion: 15, other: 20 };\n\n// base items (from pre-extract)\nconst base = Array.isArray($json.pre_extracted) ? $json.pre_extracted : [];\n\n// LLM output (string) -> array\nconst llmStr = $json.output || \"\";\nconst enrichedArr = tryParseJSON(stripCodeFences(llmStr)) || [];\nconst enrichedList = Array.isArray(enrichedArr) ? enrichedArr : [enrichedArr];\n\n// index enriched by listing_id\nconst enrichedById = new Map();\nfor (const e of enrichedList) {\n const id = (e?.listing_id ?? \"\").toString().trim();\n if (!id) continue;\n\n let category_ai = (e?.category_ai ?? \"other\").toString().trim().toLowerCase();\n if (![\"tech\", \"home\", \"fashion\", \"other\"].includes(category_ai)) category_ai = \"other\";\n\n let deal_score = toNumberOrNull(e?.deal_score);\n deal_score = deal_score === null ? 5 : clamp(deal_score, 0, 10);\n\n const score_reason = (e?.score_reason ?? \"\")\n .toString()\n .trim()\n .replace(/\\s+/g, \" \")\n .slice(0, 120) || \"No reason provided.\";\n\n enrichedById.set(id, { category_ai, deal_score, score_reason });\n}\n\nconst nowISO = new Date().toISOString();\n\nconst out = [];\nconst seen = new Set();\n\nfor (const it of base) {\n const listing_id = (it?.listing_id ?? \"\").toString().trim();\n if (!listing_id || seen.has(listing_id)) continue;\n seen.add(listing_id);\n\n const title = (it?.title ?? null)?.toString()?.trim() || null;\n const price = toNumberOrNull(it?.price);\n const currency = (it?.currency ?? null)?.toString()?.trim()?.toUpperCase() || null;\n const original_price = toNumberOrNull(it?.original_price);\n const url = (it?.url ?? null)?.toString()?.trim() || null;\n const image_url = (it?.image_url ?? null)?.toString()?.trim() || null;\n\n const enrich = enrichedById.get(listing_id) || {\n category_ai: \"other\",\n deal_score: 5,\n score_reason: \"No LLM enrichment (fallback).\"\n };\n\n const effective_threshold = thresholdsByCategory[enrich.category_ai] ?? 20;\n const price_below_threshold = Boolean(currency === \"EUR\" && price !== null && price < effective_threshold);\n\n // discount %\n let discount_pct = null;\n if (price !== null && original_price !== null && original_price > 0 && original_price > price) {\n discount_pct = clamp(((original_price - price) / original_price) * 100, 0, 99.9);\n discount_pct = Math.round(discount_pct * 10) / 10;\n }\n\n out.push({\n listing_id,\n title,\n price,\n currency,\n original_price,\n discount_pct,\n url,\n image_url,\n\n category_ai: enrich.category_ai,\n deal_score: enrich.deal_score,\n score_reason: enrich.score_reason,\n\n effective_threshold,\n price_below_threshold,\n\n scraped_at: nowISO\n });\n}\n\n// ✅ DEVOLVEMOS TODOS, SIN FILTRAR\nreturn out.map(x => ({ json: x }));\n" }, "position": [ 1248, 320 ] }, { "id": "81532dcb-26f5-4b6a-abe5-3a0719956a2b", "name": "Send a text message", "type": "integration", "params": { "text": "=🔥 eBay Deal Alert (AI Filtered)\n\n🛒 {{ $json.title || 'Product' }}\n💶 Price: €{{ $json.price }} ({{ $json.currency }})\n🏷️ Category (AI): {{ $json.category_ai }}\n🎯 Threshold: €{{ $json.effective_threshold }}\n\n{{ $json.discount_pct ? ('💸 Discount: ' + $json.discount_pct + '% (was €' + $json.original_price + ')') : '' }}\n\n⭐ Deal Score: {{ $json.deal_score }}/10\n🧠 Why: {{ $json.score_reason }}\n\n🔗 {{ $json.url }}\n🕒 Scraped: {{ $json.scraped_at }}\n", "chatId": "123456789", "service": "telegram", "operation": "read", "additionalFields": {} }, "position": [ 1744, 364 ] }, { "id": "3d7f517f-b1a2-453b-a52a-6b628f78b01d", "name": "If", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "72e30794-f836-4252-9373-5b9e003a21dd", "operator": { "type": "number", "operation": "lt" }, "leftValue": "={{ $json.price }}", "rightValue": 100 }, { "id": "e498c8fb-af42-496e-99e5-4557bd337184", "operator": { "type": "number", "operation": "gt" }, "leftValue": "={{ $json.deal_score }}", "rightValue": 7 } ] } }, "position": [ 1424, 352 ] }, { "id": "4a4d3e65-b267-45ea-b919-ec191a45b5ca", "name": "Schedule Trigger", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "hours", "hoursInterval": 3 } ] } }, "position": [ 48, 464 ] }, { "id": "dfc6b969-e588-403c-afdc-13259c754669", "name": "OpenAI Chat Model", "type": "llm", "params": { "model": "gpt-4.1-nano", "options": {}, "provider": "openai", "builtInTools": {} }, "position": [ 640, 560 ] }, { "id": "cb3da9a8-f39c-4931-89b1-35cc9c8a32e6", "name": "Code in JavaScript1", "type": "code", "params": { "jsCode": "/**\n * PRE-EXTRACT for eBay Deals (dne-itemtile blocks)\n * Input: $json.results[0].content (HTML)\n * Output: compact_text + pre_extracted + stats\n */\n\nfunction decodeHtml(s) {\n if (!s || typeof s !== \"string\") return s;\n return s\n .replace(/&/g, \"&\")\n .replace(/"/g, '\"')\n .replace(/'/g, \"'\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/&#(\\d+);/g, (_, code) => String.fromCharCode(Number(code)));\n}\n\nfunction cleanText(s, maxLen = 200) {\n if (!s) return null;\n return decodeHtml(String(s))\n .replace(/<[^>]*>/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim()\n .slice(0, maxLen) || null;\n}\n\nfunction parsePriceNumber(priceStr) {\n if (!priceStr) return null;\n // \"245,25 EUR\" -> 245.25 | \"19,99 €\" -> 19.99\n const raw = String(priceStr).trim();\n const m = raw.match(/(\\d{1,4}(?:[.,]\\d{1,2})?)/);\n if (!m) return null;\n const n = m[1].replace(\",\", \".\");\n const f = parseFloat(n);\n return Number.isFinite(f) ? f : null;\n}\n\nfunction normalizeCurrency(curStr, fallbackChunk = \"\") {\n if (curStr) {\n const u = String(curStr).trim().toUpperCase();\n if (u.includes(\"EUR\")) return \"EUR\";\n if (u.includes(\"USD\")) return \"USD\";\n return u;\n }\n if (fallbackChunk.includes(\"€\") || /\\bEUR\\b/i.test(fallbackChunk)) return \"EUR\";\n if (fallbackChunk.includes(\"$\") || /\\bUSD\\b/i.test(fallbackChunk)) return \"USD\";\n return null;\n}\n\nfunction normalizeUrl(url) {\n if (!url) return null;\n if (url.startsWith(\"http\")) return url;\n if (url.startsWith(\"//\")) return \"https:\" + url;\n if (url.startsWith(\"/\")) return \"https://www.ebay.es\" + url;\n return \"https://www.ebay.es/\" + url.replace(/^\\s+/, \"\");\n}\n\nconst html = $json?.results?.[0]?.content;\nif (!html || typeof html !== \"string\") {\n return [{ json: { compact_text: \"NO_HTML_INPUT\", pre_extracted: [], stats: { html_len: 0, items: 0 } } }];\n}\n\nconst htmlLen = html.length;\n\n// Capturamos bloques que tengan data-listing-id y la clase dne-itemtile\n// Nota: el HTML es grande; hacemos un match “contenedor” razonable alrededor del listing.\nconst blockRegex = /data-listing-id=(\\d{9,15})[\\s\\S]{0,6000}?class=\"[^\"]*dne-itemtile[^\"]*\"|class=\"[^\"]*dne-itemtile[^\"]*\"[\\s\\S]{0,6000}?data-listing-id=(\\d{9,15})/g;\n\nconst items = [];\nconst seen = new Set();\n\nlet match;\nwhile ((match = blockRegex.exec(html)) !== null) {\n const listing_id = match[1] || match[2];\n if (!listing_id || seen.has(listing_id)) continue;\n seen.add(listing_id);\n\n // Cogemos una “ventana” alrededor del match para parsear detalles del tile\n const idx = match.index;\n const start = Math.max(0, idx - 1500);\n const end = Math.min(html.length, idx + 6000);\n const chunk = html.slice(start, end);\n\n // URL del item\n let url = null;\n // suele venir: href=https://www.ebay.es/itm/336061318758?... (a veces sin comillas)\n const urlMatch =\n chunk.match(new RegExp(`href=([^\\\\s>]{0,300}/itm/${listing_id}[^\\\\s>]*)`, \"i\")) ||\n chunk.match(new RegExp(`href=\"([^\"]{0,300}/itm/${listing_id}[^\"]*)\"`, \"i\"));\n if (urlMatch) url = normalizeUrl(urlMatch[1]);\n if (!url) url = `https://www.ebay.es/itm/${listing_id}`;\n\n // Title: suele venir en h3 title=\"...\"\n let title = null;\n const titleMatch = chunk.match(/dne-itemtile-title[\\s\\S]{0,400}?title=\"([^\"]{3,220})\"/i);\n if (titleMatch) title = cleanText(titleMatch[1], 220);\n\n // Currency: meta itemprop=priceCurrency content=EUR\n let currency = null;\n const curMatch = chunk.match(/itemprop=priceCurrency\\s+content=([A-Z]{3})/i);\n if (curMatch) currency = normalizeCurrency(curMatch[1], chunk);\n\n // Price: 245,25 EUR\n let price_text = null;\n const priceMatch = chunk.match(/itemprop=price[^>]*>\\s*([^<]{1,40})327,00 EUR\n let original_price_text = null;\n const origMatch = chunk.match(/itemtile-price-strikethrough[^>]*>\\s*([^<]{1,40})\n let image_url = null;\n const imgMatch =\n chunk.match(/]*src=([^\\s>]+ebayimg\\.com[^\\s>]+)\\s/i) ||\n chunk.match(/]*src=\"([^\"]+ebayimg\\.com[^\"]+)\"/i);\n if (imgMatch) image_url = normalizeUrl(imgMatch[1]);\n\n items.push({\n listing_id,\n title,\n price,\n currency,\n price_text,\n original_price,\n original_price_text,\n url,\n image_url,\n });\n\n if (items.length >= 60) break;\n}\n\n// compact payload para el LLM (barato en tokens)\nconst lines = [];\nlines.push(\"SOURCE: eBay Deals (pre-extracted from dne-itemtile)\");\nlines.push(`ITEMS: ${items.length}`);\nlines.push(\"---\");\nfor (const it of items) {\n lines.push(\n [\n `ID=${it.listing_id}`,\n `TITLE=${it.title ?? \"null\"}`,\n `PRICE=${it.price ?? \"null\"}`,\n `CURRENCY=${it.currency ?? \"null\"}`,\n `ORIGINAL_PRICE=${it.original_price ?? \"null\"}`,\n `URL=${it.url ?? \"null\"}`,\n `IMG=${it.image_url ?? \"null\"}`,\n ].join(\" | \")\n );\n}\n\nreturn [\n {\n json: {\n compact_text: lines.join(\"\\n\"),\n pre_extracted: items,\n stats: { html_len: htmlLen, items: items.length, unique_ids: seen.size },\n },\n },\n];\n" }, "position": [ 496, 364 ] }, { "id": "0ef01345-c99a-4fa8-bbba-6f2135016305", "name": "Decodo", "type": "integration", "params": { "geo": "en", "url": "https://www.ebay.es/deals", "service": "decodo", "headless": false, "operation": "run", "__originalType": "@decodo/n8n-nodes-decodo.decodo" }, "position": [ 272, 364 ] }, { "id": "44c2c592-6541-4263-a3cf-69197987323e", "name": "Merge", "type": "merge", "params": { "mode": "combine", "options": {}, "combineBy": "combineByPosition" }, "position": [ 1136, 416 ] } ] }

Monitor eBay deals with GPT-4 scoring,Decodo & Telegram notifications