{ "edges": [ { "to": "e899ff7e-84cf-43e8-93dc-03f035134f1c", "from": "c863240d-717b-4557-9aa9-cdbe7944c45c", "toPort": "0", "fromPort": "ai_languageModel" }, { "to": "dd39e9a7-5491-487a-a4d2-9bfb636f645b", "from": "ca82c8e1-bd5e-4432-84d9-8bf30b45b098", "toPort": "0", "fromPort": "0" }, { "to": "28e8d953-d8f5-4946-b2d5-a09a156cc63e", "from": "ca82c8e1-bd5e-4432-84d9-8bf30b45b098", "toPort": "0", "fromPort": "1" }, { "to": "08182aff-c250-4133-8dea-45dba46d1c68", "from": "28e8d953-d8f5-4946-b2d5-a09a156cc63e", "toPort": "0", "fromPort": "0" }, { "to": "91e84561-d41a-464c-90eb-13174e459871", "from": "b345f524-39b0-494d-aab3-cda1f8a886b4", "toPort": "0", "fromPort": "0" }, { "to": "57f34ec5-1b04-4c7d-aa33-9d3c398f2bec", "from": "91e84561-d41a-464c-90eb-13174e459871", "toPort": "0", "fromPort": "0" }, { "to": "d373cd04-5d7b-42fb-bb8e-bff1e13bf9e8", "from": "719695c2-8b79-49bb-9637-43abece23440", "toPort": "0", "fromPort": "0" }, { "to": "b88b3738-780f-4d91-8071-06739ede596f", "from": "719695c2-8b79-49bb-9637-43abece23440", "toPort": "0", "fromPort": "1" }, { "to": "a3b4c774-7d06-4188-9503-8735319cbae8", "from": "d8c9cb70-d67b-401c-8191-474efc31eaac", "toPort": "0", "fromPort": "0" }, { "to": "886ec5de-c344-490f-a8aa-70909b6b60d4", "from": "b88b3738-780f-4d91-8071-06739ede596f", "toPort": "0", "fromPort": "0" }, { "to": "e899ff7e-84cf-43e8-93dc-03f035134f1c", "from": "a3b4c774-7d06-4188-9503-8735319cbae8", "toPort": "0", "fromPort": "0" }, { "to": "b345f524-39b0-494d-aab3-cda1f8a886b4", "from": "6d1b1c0b-fdc6-4d34-b364-4bffca5ec4c3", "toPort": "0", "fromPort": "0" }, { "to": "d8c9cb70-d67b-401c-8191-474efc31eaac", "from": "dd39e9a7-5491-487a-a4d2-9bfb636f645b", "toPort": "1", "fromPort": "0" }, { "to": "95becc17-a85a-42b3-8c7f-41707045543d", "from": "08182aff-c250-4133-8dea-45dba46d1c68", "toPort": "0", "fromPort": "0" }, { "to": "d8c9cb70-d67b-401c-8191-474efc31eaac", "from": "d373cd04-5d7b-42fb-bb8e-bff1e13bf9e8", "toPort": "0", "fromPort": "0" }, { "to": "fb221ed8-fa1c-4483-b9d2-38289e5a21df", "from": "e899ff7e-84cf-43e8-93dc-03f035134f1c", "toPort": "0", "fromPort": "0" }, { "to": "502a928b-2091-4b63-9716-651337efa735", "from": "886ec5de-c344-490f-a8aa-70909b6b60d4", "toPort": "0", "fromPort": "0" }, { "to": "ca82c8e1-bd5e-4432-84d9-8bf30b45b098", "from": "95becc17-a85a-42b3-8c7f-41707045543d", "toPort": "0", "fromPort": "0" }, { "to": "719695c2-8b79-49bb-9637-43abece23440", "from": "502a928b-2091-4b63-9716-651337efa735", "toPort": "0", "fromPort": "0" }, { "to": "98f99c7f-c4a1-4599-8d55-43ff58dff4f0", "from": "57f34ec5-1b04-4c7d-aa33-9d3c398f2bec", "toPort": "0", "fromPort": "0" }, { "to": "719695c2-8b79-49bb-9637-43abece23440", "from": "98f99c7f-c4a1-4599-8d55-43ff58dff4f0", "toPort": "0", "fromPort": "0" }, { "to": "ca82c8e1-bd5e-4432-84d9-8bf30b45b098", "from": "98f99c7f-c4a1-4599-8d55-43ff58dff4f0", "toPort": "0", "fromPort": "1" } ], "nodes": [ { "id": "6d1b1c0b-fdc6-4d34-b364-4bffca5ec4c3", "name": "Telegram Trigger", "type": "trigger", "params": { "kind": "n8n-nodes-base.telegramTrigger", "updates": [ "message" ], "additionalFields": {} }, "position": [ -2112, 1344 ] }, { "id": "b345f524-39b0-494d-aab3-cda1f8a886b4", "name": "Build Queries", "type": "code", "params": { "jsCode": "const product = $json.message.text?.trim();\nif (!product) return [];\n\nconst stores = [\n { store: \"amazon\", site: \"amazon.eg\" },\n { store: \"jumia\", site: \"jumia.com.eg\" },\n];\n\nreturn stores.map(s => ({\n json: {\n store: s.store,\n product,\n query: `${product} site:${s.site}`\n }\n}));\n" }, "position": [ -1904, 1344 ] }, { "id": "e899ff7e-84cf-43e8-93dc-03f035134f1c", "name": "AI Extraction Agent", "type": "llm", "params": { "text": "=User search intent:\n{{ $('Telegram Trigger').first().json.message.text }}\n\nScraped data (multiple sources):\n{{ $json.text }}\n", "prompt": "=User search intent:\n{{ $('Telegram Trigger').first().json.message.text }}\n\nScraped data (multiple sources):\n{{ $json.text }}\n", "options": { "systemMessage": "You are a product comparison extraction agent.\n\nYou will receive scraped and cleaned HTML text from multiple e-commerce pages\n(Amazon, Jumia, or others), along with their URLs and relevance scores.\n\nYour job is to:\n\n1. Identify the SAME product across different platforms.\n2. For EACH platform extract:\n - Product name (clean, human readable)\n - Price (number + currency if present)\n - Platform name (Amazon, Jumia, etc.)\n - URL\n3. Compare the platforms.\n4. Prepare a final user-friendly message suitable for Telegram.\n\nSTRICT RULES:\n- Do NOT invent prices or product names.\n- If price is missing, write \"Price not found\".\n- If multiple prices exist on the same page, choose the most prominent product price.\n- Ignore ads, bundles, delivery fees, unrelated products.\n- Use ONLY the provided text.\n- Be concise and clear.\n- Use emojis moderately (Telegram friendly).\n\nOUTPUT FORMAT:\nReturn ONLY a single formatted message string.\nNo JSON.\nNo explanations.\nNo markdown blocks.\n" }, "provider": "openai", "promptType": "define", "approximated": true, "systemMessage": "You are a product comparison extraction agent.\n\nYou will receive scraped and cleaned HTML text from multiple e-commerce pages\n(Amazon, Jumia, or others), along with their URLs and relevance scores.\n\nYour job is to:\n\n1. Identify the SAME product across different platforms.\n2. For EACH platform extract:\n - Product name (clean, human readable)\n - Price (number + currency if present)\n - Platform name (Amazon, Jumia, etc.)\n - URL\n3. Compare the platforms.\n4. Prepare a final user-friendly message suitable for Telegram.\n\nSTRICT RULES:\n- Do NOT invent prices or product names.\n- If price is missing, write \"Price not found\".\n- If multiple prices exist on the same page, choose the most prominent product price.\n- Ignore ads, bundles, delivery fees, unrelated products.\n- Use ONLY the provided text.\n- Be concise and clear.\n- Use emojis moderately (Telegram friendly).\n\nOUTPUT FORMAT:\nReturn ONLY a single formatted message string.\nNo JSON.\nNo explanations.\nNo markdown blocks.\n" }, "position": [ -640, 1344 ] }, { "id": "91e84561-d41a-464c-90eb-13174e459871", "name": "Google Search", "type": "integration", "params": { "query": "={{ $json.query }}", "service": "decodo", "headless": false, "operation": "google_search", "results_limit": 1, "__originalType": "@decodo/n8n-nodes-decodo.decodo" }, "position": [ -1728, 1344 ] }, { "id": "57f34ec5-1b04-4c7d-aa33-9d3c398f2bec", "name": "Extract & Filter URLs", "type": "code", "params": { "jsCode": "// Collect URLs from Decodo Google Search output\nconst allItems = $input.all();\n\nconst urls = [];\n\nfunction collectUrls(obj) {\n if (!obj || typeof obj !== 'object') return;\n\n // Collect URL fields\n if (typeof obj.url === 'string' && obj.url.startsWith('http')) {\n urls.push(obj.url);\n }\n\n // Recurse into arrays\n if (Array.isArray(obj)) {\n for (const item of obj) {\n collectUrls(item);\n }\n }\n // Recurse into objects\n else {\n for (const key of Object.keys(obj)) {\n collectUrls(obj[key]);\n }\n }\n}\n\n// Walk through every Decodo item\nfor (const item of allItems) {\n collectUrls(item.json);\n}\n\n// Deduplicate + remove Google search URLs\nconst uniqueUrls = [...new Set(urls)]\n .filter(url => !url.includes('google.com/search'))\n .slice(0, 20); // ✅ LIMIT TO 20 ONLY\n\n// Return one item per URL\nreturn uniqueUrls.map(url => ({\n json: { url }\n}));\n" }, "position": [ -1520, 1344 ] }, { "id": "98f99c7f-c4a1-4599-8d55-43ff58dff4f0", "name": "Router (Amazon vs. Other)", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 3, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "c783147f-8282-43f6-9b12-8e2526f35be9", "operator": { "type": "string", "operation": "contains" }, "leftValue": "={{ $json.url }}", "rightValue": "amazon" } ] } }, "position": [ -1344, 1344 ] }, { "id": "b88b3738-780f-4d91-8071-06739ede596f", "name": "Scrape Amazon", "type": "integration", "params": { "url": "={{ $('Extract & Filter URLs').item.json.url }}", "parse": false, "service": "decodo", "operation": "amazon", "__originalType": "@decodo/n8n-nodes-decodo.decodo" }, "position": [ -1072, 1008 ] }, { "id": "719695c2-8b79-49bb-9637-43abece23440", "name": "Loop (Amazon)", "type": "passthrough", "params": { "mode": "noOp", "options": {} }, "position": [ -1232, 992 ] }, { "id": "886ec5de-c344-490f-a8aa-70909b6b60d4", "name": "Clean HTML (Amazon)", "type": "code", "params": { "mode": "runOnceForEachItem", "jsCode": "const item = $input.item.json;\n\nlet html = \"\";\n\ntry {\n html = item.results[0].content || \"\";\n} catch (e) {\n html = \"\";\n}\n\nlet cleaned = html\n .replace(/]*>[\\s\\S]*?<\\/script>/gi, \"\")\n .replace(/]*>[\\s\\S]*?<\\/style>/gi, \"\")\n .replace(/]*>[\\s\\S]*?<\\/noscript>/gi, \"\")\n .replace(/<\\/?[^>]+>/g, \" \")\n .replace(/ /gi, \" \")\n .replace(/&/gi, \"&\")\n .replace(/"/gi, '\"')\n .replace(/'/gi, \"'\")\n .replace(/</gi, \"<\")\n .replace(/>/gi, \">\")\n .replace(/\\s+/g, \" \")\n .trim();\n\nreturn {\n json: {\n text_clean: cleaned,\n url: $('Loop (Amazon)').first().json.url\n }\n};\n" }, "position": [ -912, 1008 ] }, { "id": "28e8d953-d8f5-4946-b2d5-a09a156cc63e", "name": "Scrape Other", "type": "integration", "params": { "url": "={{ $json.url }}", "service": "decodo", "operation": "run", "__originalType": "@decodo/n8n-nodes-decodo.decodo" }, "position": [ -1072, 1728 ] }, { "id": "ca82c8e1-bd5e-4432-84d9-8bf30b45b098", "name": "Loop (Other)", "type": "passthrough", "params": { "mode": "noOp", "options": {} }, "position": [ -1232, 1712 ] }, { "id": "08182aff-c250-4133-8dea-45dba46d1c68", "name": "Clean HTML (Other)", "type": "code", "params": { "mode": "runOnceForEachItem", "jsCode": "const item = $input.item.json;\n\nlet html = \"\";\n\ntry {\n html = item.results[0].content || \"\";\n} catch (e) {\n html = \"\";\n}\n\nlet cleaned = html\n .replace(/]*>[\\s\\S]*?<\\/script>/gi, \"\")\n .replace(/]*>[\\s\\S]*?<\\/style>/gi, \"\")\n .replace(/]*>[\\s\\S]*?<\\/noscript>/gi, \"\")\n .replace(/<\\/?[^>]+>/g, \" \")\n .replace(/ /gi, \" \")\n .replace(/&/gi, \"&\")\n .replace(/"/gi, '\"')\n .replace(/'/gi, \"'\")\n .replace(/</gi, \"<\")\n .replace(/>/gi, \">\")\n .replace(/\\s+/g, \" \")\n .trim();\n\nreturn {\n json: {\n text_clean: cleaned,\n url: $('Loop (Other)').first().json.url\n }\n};\n" }, "position": [ -896, 1728 ] }, { "id": "95becc17-a85a-42b3-8c7f-41707045543d", "name": "Score Match (Other)", "type": "code", "params": { "jsCode": "// 1️⃣ User message (dynamic, from Telegram)\nconst userMessage =\n $('Telegram Trigger').first().json.message.text\n .toLowerCase()\n .replace(/[^\\w\\s\\u0600-\\u06FF]/g, ' ');\n\n// 2️⃣ Tokenize user message dynamically\nconst userTokens = userMessage\n .split(/\\s+/)\n .filter(w => w.length >= 3);\n\n// 3️⃣ Cleaned page text\nconst pageText = ($json.text_clean || '')\n .toLowerCase()\n .replace(/[^\\w\\s\\u0600-\\u06FF]/g, ' ');\n\n// 4️⃣ URL (pass-through from earlier nodes)\nconst url = $json.url || null;\n\n// Guards\nif (!pageText || userTokens.length === 0) {\n return [{\n json: {\n match: false,\n score: 0,\n url\n }\n }];\n}\n\n// 5️⃣ Dynamic scoring\nlet score = 0;\nlet matchedTokens = [];\n\nfor (const token of userTokens) {\n const occurrences = pageText.split(token).length - 1;\n if (occurrences > 0) {\n score += Math.min(occurrences * 3, 15); // density-aware\n matchedTokens.push(token);\n }\n}\n\n// 6️⃣ Structural bonuses (language-agnostic)\nif (pageText.length > 1500) score += 5; // real product page\nif (pageText.length < 400) score -= 10; // weak page\nif (\n pageText.includes('add to cart') ||\n pageText.includes('اضف') ||\n pageText.includes('أضف')\n) score += 5;\n\n// 7️⃣ Dynamic threshold (based on user input length)\nconst threshold = Math.max(12, userTokens.length * 4);\nconst isMatch = score >= threshold;\n\n// 8️⃣ Output EVERYTHING needed downstream\nreturn [{\n json: {\n match: isMatch,\n score,\n threshold,\n url,\n matched_tokens: matchedTokens,\n text_clean: pageText\n }\n}];\n" }, "position": [ -736, 1728 ] }, { "id": "502a928b-2091-4b63-9716-651337efa735", "name": "Score Match (Amazon)", "type": "code", "params": { "jsCode": "// 1️⃣ User message (dynamic, from Telegram)\nconst userMessage =\n $('Telegram Trigger').first().json.message.text\n .toLowerCase()\n .replace(/[^\\w\\s\\u0600-\\u06FF]/g, ' ');\n\n// 2️⃣ Tokenize user message dynamically\nconst userTokens = userMessage\n .split(/\\s+/)\n .filter(w => w.length >= 3);\n\n// 3️⃣ Cleaned page text\nconst pageText = ($json.text_clean || '')\n .toLowerCase()\n .replace(/[^\\w\\s\\u0600-\\u06FF]/g, ' ');\n\n// 4️⃣ URL (pass-through from earlier nodes)\nconst url = $json.url || null;\n\n// Guards\nif (!pageText || userTokens.length === 0) {\n return [{\n json: {\n match: false,\n score: 0,\n url\n }\n }];\n}\n\n// 5️⃣ Dynamic scoring\nlet score = 0;\nlet matchedTokens = [];\n\nfor (const token of userTokens) {\n const occurrences = pageText.split(token).length - 1;\n if (occurrences > 0) {\n score += Math.min(occurrences * 3, 15); // density-aware\n matchedTokens.push(token);\n }\n}\n\n// 6️⃣ Structural bonuses (language-agnostic)\nif (pageText.length > 1500) score += 5; // real product page\nif (pageText.length < 400) score -= 10; // weak page\nif (\n pageText.includes('add to cart') ||\n pageText.includes('اضف') ||\n pageText.includes('أضف')\n) score += 5;\n\n// 7️⃣ Dynamic threshold (based on user input length)\nconst threshold = Math.max(12, userTokens.length * 4);\nconst isMatch = score >= threshold;\n\n// 8️⃣ Output EVERYTHING needed downstream\nreturn [{\n json: {\n match: isMatch,\n score,\n threshold,\n url,\n matched_tokens: matchedTokens,\n text_clean: pageText\n }\n}];\n" }, "position": [ -736, 1008 ] }, { "id": "d373cd04-5d7b-42fb-bb8e-bff1e13bf9e8", "name": "Pick Best (Amazon)", "type": "code", "params": { "jsCode": "const items = $input.all().map(i => i.json);\n\n// Keep only valid matches\nconst valid = items.filter(i => i.match === true);\n\n// If none matched, return nothing\nif (!valid.length) return [];\n\n// Pick highest score\nvalid.sort((a, b) => b.score - a.score);\n\nreturn [{\n json: valid[0]\n}];\n" }, "position": [ -1120, 1280 ] }, { "id": "dd39e9a7-5491-487a-a4d2-9bfb636f645b", "name": "Pick Best (Other)", "type": "code", "params": { "jsCode": "const items = $input.all().map(i => i.json);\n\n// Keep only valid matches\nconst valid = items.filter(i => i.match === true);\n\n// If none matched, return nothing\nif (!valid.length) return [];\n\n// Pick highest score\nvalid.sort((a, b) => b.score - a.score);\n\nreturn [{\n json: valid[0]\n}];\n" }, "position": [ -1120, 1424 ] }, { "id": "d8c9cb70-d67b-401c-8191-474efc31eaac", "name": "Merge Results", "type": "merge", "params": {}, "position": [ -944, 1344 ] }, { "id": "c863240d-717b-4557-9aa9-cdbe7944c45c", "name": "GPT Model", "type": "llm", "params": { "model": "gpt-4o-mini", "options": {}, "provider": "openai" }, "position": [ -640, 1504 ] }, { "id": "a3b4c774-7d06-4188-9503-8735319cbae8", "name": "Format Context", "type": "code", "params": { "jsCode": "const items = $input.all().map(i => i.json);\n\nconst combinedText = items.map(item => `\nSOURCE URL:\n${item.url}\n\nRELEVANCE SCORE:\n${item.score}\n\nCONTENT:\n${item.text_clean.slice(0, 5000)}\n`).join('\\n\\n====================\\n\\n');\n\nreturn [{\n json: {\n text: combinedText // 🔴 THIS NAME IS CRITICAL\n }\n}];\n" }, "position": [ -800, 1344 ] }, { "id": "fb221ed8-fa1c-4483-b9d2-38289e5a21df", "name": "Send Reply", "type": "integration", "params": { "text": "={{ $json.output }}", "chatId": "={{ $('Telegram Trigger').item.json.message.chat.id }}", "service": "telegram", "operation": "read", "additionalFields": { "appendAttribution": false } }, "position": [ -336, 1344 ] } ] }

Compare product prices on Amazon and Jumia with Decodo, OpenAI and Telegram