{ "edges": [ { "to": "pg-upsert", "from": "hash-content", "toPort": "0", "fromPort": "0" }, { "to": "format-list", "from": "if-has-changes", "toPort": "0", "fromPort": "0" }, { "to": "no-op", "from": "if-has-changes", "toPort": "0", "fromPort": "1" }, { "to": "if-has-changes", "from": "aggregate-changes", "toPort": "0", "fromPort": "0" }, { "to": "split-links", "from": "fc-map", "toPort": "0", "fromPort": "0" }, { "to": "fc-map", "from": "schedule", "toPort": "0", "fromPort": "0" }, { "to": "gemini-summarize", "from": "format-list", "toPort": "0", "fromPort": "0" }, { "to": "aggregate-changes", "from": "filter-changed", "toPort": "0", "fromPort": "0" }, { "to": "fc-scrape", "from": "split-links", "toPort": "0", "fromPort": "0" }, { "to": "hash-content", "from": "fc-scrape", "toPort": "0", "fromPort": "0" }, { "to": "filter-changed", "from": "pg-upsert", "toPort": "0", "fromPort": "0" }, { "to": "telegram-alert", "from": "gemini-summarize", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "schedule", "name": "Schedule Daily 9AM", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "cronExpression", "expression": "0 9 * * *" } ] } }, "position": [ -816, 208 ] }, { "id": "fc-map", "name": "Firecrawl Map Docs", "type": "integration", "params": { "mapUrl": "https://bot.zapps.me/docs", "service": "firecrawl", "operation": "map", "mapOptions": { "sitemap": "include", "includeSubdomains": false, "ignoreQueryParameters": true }, "__originalType": "n8n-nodes-firecrawl-v2.firecrawl" }, "position": [ -544, 208 ] }, { "id": "split-links", "name": "Split & Filter Links", "type": "code", "params": { "jsCode": "const items = $input.all();\nconst out = [];\nconst seen = new Set();\nfor (const item of items) {\n const links = item.json.links || item.json.data?.links || [];\n for (const l of links) {\n const url = typeof l === 'string' ? l : l.url;\n if (!url) continue;\n if (!url.startsWith('https://bot.zapps.me/docs')) continue;\n if (seen.has(url)) continue;\n seen.add(url);\n out.push({ json: { url } });\n }\n}\nreturn out;" }, "position": [ -256, 208 ] }, { "id": "fc-scrape", "name": "Firecrawl Scrape Page", "type": "integration", "params": { "url": "={{ $json.url }}", "service": "firecrawl", "operation": "run", "scrapeOptions": { "formats": [ "markdown" ], "waitFor": 5000, "onlyMainContent": true }, "__originalType": "n8n-nodes-firecrawl-v2.firecrawl" }, "position": [ 32, 208 ] }, { "id": "hash-content", "name": "Hash Content", "type": "code", "params": { "jsCode": "// Pure JS hash (no crypto module)\nfunction fnv1a64(str) {\n let h1 = 0x84222325, h2 = 0xcbf29ce4;\n for (let i = 0; i < str.length; i++) {\n const c = str.charCodeAt(i);\n h1 ^= c;\n const lo = h1 * 0x1b3 + (h2 * 0x1b3 << 0);\n const hi = h2 * 0x1b3 + (h1 << 8) + (h1 << 40 / 1);\n h1 = lo >>> 0;\n h2 = (hi + Math.floor(lo / 0x1+1234567890)) >>> 0;\n }\n return h2.toString(16).padStart(8, '0') + h1.toString(16).padStart(8, '0');\n}\n\n// Normalize markdown to remove volatile artifacts (JS render race conditions, whitespace noise)\nfunction normalize(md) {\n return (md || '')\n // Strip the server-side fallback placeholder that appears when JS hasn't rendered yet\n .replace(/Code demo fallback when rendering server side!?/gi, '')\n // Strip \"Last updated\" / \"Cập nhật lần cuối\" lines (relative dates can drift)\n .replace(/^.*[Cc]ập nhật lần cuối.*$/gm, '')\n .replace(/^.*[Ll]ast [Uu]pdated.*$/gm, '')\n // Collapse runs of whitespace\n .replace(/\\s+/g, ' ')\n .trim();\n}\n\nconst items = $input.all();\nreturn items.map(item => {\n const data = item.json.data || item.json;\n const url = data.metadata?.sourceURL || data.metadata?.url || data.url || item.json.url;\n const title = data.metadata?.title || (url || '').split('/').pop() || 'untitled';\n const markdown = data.markdown || '';\n const normalized = normalize(markdown);\n const lenTag = normalized.length.toString(16).padStart(8, '0');\n const fingerprint = fnv1a64(normalized);\n const contentHash = (lenTag + fingerprint).slice(0, 64);\n const preview = markdown.slice(0, 500);\n return {\n json: {\n source: 'zalo-bot',\n url,\n title,\n content_hash: contentHash,\n content_preview: preview,\n markdown_full: markdown,\n normalized_length: normalized.length,\n }\n };\n});" }, "position": [ 320, 208 ] }, { "id": "pg-upsert", "name": "Postgres Upsert & Diff", "type": "integration", "params": { "query": "WITH old AS (\n SELECT content_hash AS old_hash FROM docs_snapshots WHERE source = $1 AND url = $2\n),\nupsert AS (\n INSERT INTO docs_snapshots (source, url, title, content_hash, content_preview, last_seen, last_changed)\n VALUES ($1, $2, $3, $4, $5, NOW(), NOW())\n ON CONFLICT (source, url) DO UPDATE SET\n content_hash = EXCLUDED.content_hash,\n title = EXCLUDED.title,\n content_preview = EXCLUDED.content_preview,\n last_seen = NOW(),\n last_changed = CASE WHEN docs_snapshots.content_hash <> EXCLUDED.content_hash THEN NOW() ELSE docs_snapshots.last_changed END\n RETURNING url, title, content_hash AS new_hash, content_preview\n)\nSELECT\n upsert.url,\n upsert.title,\n upsert.new_hash,\n upsert.content_preview,\n COALESCE(old.old_hash, '') AS old_hash,\n CASE\n WHEN old.old_hash IS NULL THEN 'new'\n WHEN old.old_hash <> upsert.new_hash THEN 'changed'\n ELSE 'same'\n END AS status\nFROM upsert\nLEFT JOIN old ON true;", "options": { "queryReplacement": "={{ $json.source }},{{ $json.url }},{{ $json.title }},{{ $json.content_hash }},{{ $json.content_preview }}" }, "service": "postgres", "operation": "executeQuery" }, "position": [ 624, 208 ] }, { "id": "filter-changed", "name": "Filter Changed Pages", "type": "passthrough", "params": { "mode": "filter", "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": true, "typeValidation": "strict" }, "combinator": "and", "conditions": [ { "id": "not-same", "operator": { "type": "string", "operation": "notEquals" }, "leftValue": "={{ $json.status }}", "rightValue": "same" } ] } }, "position": [ 928, 208 ] }, { "id": "aggregate-changes", "name": "Aggregate Changes", "type": "passthrough", "params": { "mode": "aggregate", "options": {}, "aggregate": "aggregateAllItemData", "destinationFieldName": "changedPages" }, "position": [ 1232, 208 ] }, { "id": "if-has-changes", "name": "IF Has Changes", "type": "if", "params": { "options": {}, "conditions": { "options": { "version": 2, "leftValue": "", "caseSensitive": false, "typeValidation": "loose" }, "combinator": "and", "conditions": [ { "id": "has", "operator": { "type": "number", "operation": "gt" }, "leftValue": "={{ ($json.changedPages || []).length }}", "rightValue": 0 } ] } }, "position": [ 1520, 208 ] }, { "id": "format-list", "name": "Format Changes List", "type": "code", "params": { "jsCode": "const pages = $json.changedPages || [];\nlet newCount = 0, changedCount = 0;\nconst lines = [];\nfor (const p of pages) {\n const status = p.status || 'unknown';\n if (status === 'new') newCount++;\n else if (status === 'changed') changedCount++;\n lines.push(`- [${status.toUpperCase()}] ${p.title}\\n ${p.url}`);\n}\nconst previews = pages.slice(0, 5).map(p => `### ${p.url}\\n${(p.content_preview || '').slice(0, 400)}`).join('\\n\\n');\nreturn [{\n json: {\n totalChanged: pages.length,\n newCount,\n changedCount,\n changesList: lines.join('\\n'),\n previews,\n }\n}];" }, "position": [ 1824, 112 ] }, { "id": "gemini-summarize", "name": "Gemini Summarize Changes", "type": "llm", "params": { "modelId": { "__rl": true, "mode": "list", "value": "models/gemini-2.0-flash" }, "options": {}, "messages": { "values": [ { "content": "=Bạn là kỹ sư bảo trì n8n community node `n8n-nodes-zalo-platform`. Tài liệu chính thức của Zalo Bot Platform (https://bot.zapps.me/docs) vừa có thay đổi. Hãy phân tích và viết tóm tắt tiếng Việt có dấu (tối đa 250 từ), gồm:\n\n1. Liệt kê các thay đổi quan trọng nhất\n2. Đoán xem thay đổi liên quan endpoint nào (sendMessage, sendPhoto, sendSticker, sendChatAction, getUpdates, setWebhook, deleteWebhook, getMe, getWebhookInfo)\n3. Đánh giá ảnh hưởng tới node Zalo Bot hiện tại (cần update / cần thêm operation mới / không cần)\n4. Đề xuất hành động cụ thể (file/method nào cần sửa)\n\nThống kê: {{ $json.totalChanged }} trang ({{ $json.newCount }} mới, {{ $json.changedCount }} thay đổi)\n\nDanh sách:\n{{ $json.changesList }}\n\nNội dung 5 trang đầu:\n{{ $json.previews }}" } ] }, "provider": "google" }, "position": [ 2128, 112 ] }, { "id": "telegram-alert", "name": "Send Telegram Alert", "type": "integration", "params": { "text": "=🔔 Zalo Bot Docs Update Alert\n\n📚 Phát hiện {{ $('Format Changes List').item.json.totalChanged }} trang thay đổi tại bot.zapps.me/docs\n\n📊 Phân loại:\n• 🆕 New: {{ $('Format Changes List').item.json.newCount }}\n• ✏️ Changed: {{ $('Format Changes List').item.json.changedCount }}\n\n🤖 Phân tích Gemini:\n{{ $json.content.parts[0].text.toString().replace(/&/g,'&').replace(//g,'>') }}\n\n📋 Danh sách trang:\n

{{ $('Format Changes List').item.json.changesList.toString().replace(/&/g,'&').replace(//g,'>') }}

\n\nWorkflow: zalo-docs-watcher-001 | THE NEXOVA", "chatId": "123456789", "service": "telegram", "operation": "read", "additionalFields": { "parse_mode": "HTML", "appendAttribution": false } }, "position": [ 2432, 112 ] }, { "id": "no-op", "name": "No Changes Detected", "type": "passthrough", "params": { "mode": "noOp" }, "position": [ 1824, 320 ] } ] }

Track documentation changes with Firecrawl, Postgres, Gemini, and Telegram