{ "edges": [ { "to": "80c7a7f6-84fe-4d81-be24-498bc4a0e87a", "from": "5e540b05-7780-41e7-aa16-88bf0a7cbedd", "toPort": "0", "fromPort": "0" }, { "to": "e44a28b9-0a58-4298-9213-ebe8f72c3871", "from": "80c7a7f6-84fe-4d81-be24-498bc4a0e87a", "toPort": "0", "fromPort": "0" }, { "to": "5e540b05-7780-41e7-aa16-88bf0a7cbedd", "from": "44403338-5ecd-4d8f-a423-4794ed804449", "toPort": "0", "fromPort": "0" }, { "to": "44403338-5ecd-4d8f-a423-4794ed804449", "from": "e0aa7c36-3e3b-4433-8fe9-2df2a24bbfda", "toPort": "0", "fromPort": "0" }, { "to": "856fee05-7dd2-4bbe-8580-b8e10986238e", "from": "e0aa7c36-3e3b-4433-8fe9-2df2a24bbfda", "toPort": "0", "fromPort": "0" }, { "to": "5e540b05-7780-41e7-aa16-88bf0a7cbedd", "from": "856fee05-7dd2-4bbe-8580-b8e10986238e", "toPort": "1", "fromPort": "0" }, { "to": "0c0c570b-35c1-4025-b039-02fbc3bc68e5", "from": "487352c5-339f-4210-8bb6-8aee9fef77e8", "toPort": "0", "fromPort": "0" }, { "to": "9ca1e3b4-a677-44f0-9f04-7fcf6d480dad", "from": "7a566c27-041c-4164-9d7b-be035c22a036", "toPort": "0", "fromPort": "0" }, { "to": "487352c5-339f-4210-8bb6-8aee9fef77e8", "from": "7a566c27-041c-4164-9d7b-be035c22a036", "toPort": "0", "fromPort": "0" }, { "to": "677fd5a7-a775-4c41-8250-70795d778306", "from": "7a566c27-041c-4164-9d7b-be035c22a036", "toPort": "0", "fromPort": "0" }, { "to": "a13b13c1-42c3-4f3e-97a5-c61611d51f4e", "from": "7a566c27-041c-4164-9d7b-be035c22a036", "toPort": "0", "fromPort": "0" }, { "to": "5c8edc2d-9950-40b3-b722-5d372f13cd04", "from": "e44a28b9-0a58-4298-9213-ebe8f72c3871", "toPort": "0", "fromPort": "0" }, { "to": "7a566c27-041c-4164-9d7b-be035c22a036", "from": "5c8edc2d-9950-40b3-b722-5d372f13cd04", "toPort": "0", "fromPort": "0" }, { "to": "ea3b55cb-bf55-4fea-a5db-4b5cc8f4b2d8", "from": "9ca1e3b4-a677-44f0-9f04-7fcf6d480dad", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "e0aa7c36-3e3b-4433-8fe9-2df2a24bbfda", "name": "Daily Schedule Trigger", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "hours", "hoursInterval": 24 } ] } }, "position": [ 736, 432 ] }, { "id": "44403338-5ecd-4d8f-a423-4794ed804449", "name": "Fetch Hacker News RSS", "type": "http", "params": { "url": "https://hnrss.org/newest?points=50&count=30", "options": { "timeout": 15000, "response": { "response": { "responseFormat": "text" } } } }, "position": [ 960, 336 ] }, { "id": "856fee05-7dd2-4bbe-8580-b8e10986238e", "name": "Fetch Product Hunt RSS", "type": "http", "params": { "url": "https://www.producthunt.com/feed", "options": { "timeout": 15000, "response": { "response": { "responseFormat": "text" } } } }, "position": [ 960, 528 ] }, { "id": "5e540b05-7780-41e7-aa16-88bf0a7cbedd", "name": "Wait for All Feeds", "type": "merge", "params": {}, "position": [ 1184, 432 ] }, { "id": "80c7a7f6-84fe-4d81-be24-498bc4a0e87a", "name": "Parse All RSS Feeds", "type": "code", "params": { "jsCode": "// Parse RSS/Atom feeds into normalized items\n// Grab data from each named feed node directly\n\nconst rawFeeds = [];\n\ntry {\n const hn = $('Fetch Hacker News RSS').all();\n for (const item of hn) {\n const str = typeof item.json === 'string' ? item.json : (item.json.data || JSON.stringify(item.json));\n rawFeeds.push({ name: 'hackernews', weight: 1.5, xml: str });\n }\n} catch(e) {}\n\ntry {\n const ph = $('Fetch Product Hunt RSS').all();\n for (const item of ph) {\n const str = typeof item.json === 'string' ? item.json : (item.json.data || JSON.stringify(item.json));\n rawFeeds.push({ name: 'producthunt', weight: 1.3, xml: str });\n }\n} catch(e) {}\n\nfunction extractItems(xml, sourceName, weight) {\n const items = [];\n if (!xml || xml.length < 50) return items;\n \n const itemRegex = /<(?:item|entry)[^>]*>([\\s\\S]*?)<\\/(?:item|entry)>/gi;\n let match;\n \n while ((match = itemRegex.exec(xml)) !== null) {\n const block = match[1];\n \n const getTag = (tag) => {\n const r = new RegExp(\n '<' + tag + '[^>]*><\\\\/' + tag + '>|' +\n '<' + tag + '[^>]*>([\\\\s\\\\S]*?)<\\\\/' + tag + '>',\n 'i'\n );\n const m = block.match(r);\n return m ? (m[1] || m[2] || '').trim() : '';\n };\n \n let link = getTag('link');\n if (!link) {\n const hrefMatch = block.match(/href=\"([^\"]+)\"/i);\n if (hrefMatch) link = hrefMatch[1];\n }\n \n const title = getTag('title').replace(/<[^>]+>/g, '').trim();\n const desc = getTag('description').replace(/<[^>]+>/g, '').substring(0, 300);\n const content = getTag('content').replace(/<[^>]+>/g, '').substring(0, 300) || desc;\n const pubDate = getTag('pubDate') || getTag('published') || getTag('updated') || '';\n \n if (!title) continue;\n \n items.push({\n source: sourceName,\n source_weight: weight,\n title: title,\n url: link,\n description: (content || desc).substring(0, 200),\n published: pubDate,\n raw_text: (title + ' ' + desc + ' ' + content).toLowerCase()\n });\n }\n \n return items;\n}\n\nlet allItems = [];\n\nfor (const feed of rawFeeds) {\n try {\n const items = extractItems(feed.xml, feed.name, feed.weight);\n allItems = allItems.concat(items);\n } catch(e) {}\n}\n\nif (allItems.length === 0) {\n return [{ json: { items: [], total_fetched: 0, feeds_processed: rawFeeds.length, error: 'No items parsed from any feed.' } }];\n}\n\nreturn [{ json: { items: allItems, total_fetched: allItems.length, feeds_processed: rawFeeds.length } }];" }, "position": [ 1408, 432 ] }, { "id": "e44a28b9-0a58-4298-9213-ebe8f72c3871", "name": "Score and Classify Signals", "type": "code", "params": { "jsCode": "const data = $input.first().json;\nconst items = data.items;\n\nif (!items || items.length === 0) {\n return [{ json: { scored_items: [], total_signals: 0, total_fetched: 0, error: 'No items to score' } }];\n}\n\n// ============================================\n// CUSTOMIZE YOUR KEYWORD GROUPS BELOW\n// Add, remove, or adjust keywords and weights\n// to match your industry and interests\n// ============================================\nconst keywordGroups = {\n 'ai_automation': {\n keywords: ['ai agent', 'ai automation', 'llm', 'gpt', 'claude', 'copilot', 'ai tool', 'artificial intelligence', 'machine learning', 'generative ai', 'ai-powered', 'langchain', 'rag'],\n weight: 2.0,\n category: 'AI & Automation'\n },\n 'no_code': {\n keywords: ['no-code', 'nocode', 'low-code', 'lowcode', 'n8n', 'zapier', 'make.com', 'automation platform', 'workflow automation', 'airtable'],\n weight: 1.8,\n category: 'No-Code / Low-Code'\n },\n 'saas_business': {\n keywords: ['saas', 'mrr', 'arr', 'churn', 'b2b saas', 'micro-saas', 'bootstrapped', 'indie hacker', 'recurring revenue', 'subscription'],\n weight: 1.5,\n category: 'SaaS & Business'\n },\n 'developer_tools': {\n keywords: ['developer tool', 'dev tool', 'api', 'sdk', 'open source', 'cli tool', 'developer experience', 'dx', 'devops', 'infrastructure'],\n weight: 1.3,\n category: 'Developer Tools'\n },\n 'marketing_growth': {\n keywords: ['seo', 'content marketing', 'growth hack', 'conversion', 'landing page', 'email marketing', 'organic traffic', 'product-led', 'plg', 'go-to-market'],\n weight: 1.4,\n category: 'Marketing & Growth'\n },\n 'pricing_monetization': {\n keywords: ['pricing', 'monetization', 'freemium', 'paywall', 'revenue model', 'billing', 'payment', 'stripe', 'pricing strategy'],\n weight: 1.6,\n category: 'Pricing & Monetization'\n },\n 'remote_productivity': {\n keywords: ['remote work', 'async', 'productivity', 'collaboration tool', 'project management', 'notion', 'obsidian', 'second brain', 'knowledge management'],\n weight: 1.1,\n category: 'Remote & Productivity'\n }\n};\n\nconst scoredItems = [];\n\nfor (const item of items) {\n const text = item.raw_text || '';\n let totalScore = 0;\n const matchedGroups = [];\n const matchedKeywords = [];\n \n for (const [groupId, group] of Object.entries(keywordGroups)) {\n let groupHits = 0;\n \n for (const kw of group.keywords) {\n if (text.includes(kw)) {\n groupHits++;\n matchedKeywords.push(kw);\n }\n }\n \n if (groupHits > 0) {\n const groupScore = groupHits * group.weight;\n totalScore += groupScore;\n matchedGroups.push({\n group: group.category,\n hits: groupHits,\n score: parseFloat(groupScore.toFixed(2))\n });\n }\n }\n \n totalScore = totalScore * (item.source_weight || 1);\n \n const titleText = (item.title || '').toLowerCase();\n let titleBonus = 0;\n for (const [groupId, group] of Object.entries(keywordGroups)) {\n for (const kw of group.keywords) {\n if (titleText.includes(kw)) {\n titleBonus += 1.5;\n }\n }\n }\n totalScore += titleBonus;\n \n if (totalScore > 0) {\n scoredItems.push({\n title: item.title,\n url: item.url,\n source: item.source,\n description: item.description,\n published: item.published,\n signal_score: parseFloat(totalScore.toFixed(2)),\n matched_groups: matchedGroups,\n matched_keywords: [...new Set(matchedKeywords)],\n primary_category: matchedGroups.length > 0 \n ? matchedGroups.sort((a, b) => b.score - a.score)[0].group \n : 'General',\n title_match: titleBonus > 0\n });\n }\n}\n\nscoredItems.sort((a, b) => b.signal_score - a.signal_score);\n\nreturn [{ json: { scored_items: scoredItems, total_signals: scoredItems.length, total_fetched: items.length } }];" }, "position": [ 1632, 432 ] }, { "id": "5c8edc2d-9950-40b3-b722-5d372f13cd04", "name": "Aggregate Signals into Themes", "type": "code", "params": { "jsCode": "const data = $input.first().json;\nconst items = data.scored_items || [];\n\nif (items.length === 0) {\n const today = new Date().toISOString().split('T')[0];\n return [{\n json: {\n date: today,\n themes: [],\n total_signals: 0,\n total_fetched: data.total_fetched || 0,\n top_items: [],\n note: 'No keyword matches found today.'\n }\n }];\n}\n\nconst themes = {};\n\nfor (const item of items) {\n const cat = item.primary_category;\n if (!themes[cat]) {\n themes[cat] = {\n category: cat,\n items: [],\n total_score: 0,\n source_diversity: new Set(),\n all_keywords: []\n };\n }\n themes[cat].items.push(item);\n themes[cat].total_score += item.signal_score;\n themes[cat].source_diversity.add(item.source);\n themes[cat].all_keywords.push(...(item.matched_keywords || []));\n}\n\nconst themeResults = [];\n\nfor (const [cat, theme] of Object.entries(themes)) {\n const itemCount = theme.items.length;\n const sourceDiversity = theme.source_diversity.size;\n const avgScore = theme.total_score / itemCount;\n \n const diversityBonus = 1 + (sourceDiversity - 1) * 0.3;\n const volumeBonus = 1 + Math.log2(Math.max(itemCount, 1)) * 0.2;\n const themeStrength = parseFloat((theme.total_score * diversityBonus * volumeBonus).toFixed(2));\n \n let signalLevel;\n if (themeStrength >= 30) signalLevel = 'VERY_STRONG';\n else if (themeStrength >= 15) signalLevel = 'STRONG';\n else if (themeStrength >= 8) signalLevel = 'MODERATE';\n else signalLevel = 'WEAK';\n \n const kwFreq = {};\n for (const kw of theme.all_keywords) {\n kwFreq[kw] = (kwFreq[kw] || 0) + 1;\n }\n const topKeywords = Object.entries(kwFreq)\n .sort((a, b) => b[1] - a[1])\n .slice(0, 5)\n .map(([kw, count]) => kw + ' (' + count + ')');\n \n themeResults.push({\n category: cat,\n signal_level: signalLevel,\n theme_strength: themeStrength,\n item_count: itemCount,\n sources: [...theme.source_diversity],\n source_count: sourceDiversity,\n avg_item_score: parseFloat(avgScore.toFixed(2)),\n top_keywords: topKeywords,\n top_items: theme.items\n .sort((a, b) => b.signal_score - a.signal_score)\n .slice(0, 5)\n .map(i => ({\n title: i.title,\n source: i.source,\n score: i.signal_score,\n url: i.url\n }))\n });\n}\n\nthemeResults.sort((a, b) => b.theme_strength - a.theme_strength);\n\nconst today = new Date().toISOString().split('T')[0];\n\nreturn [{\n json: {\n date: today,\n themes: themeResults,\n total_signals: data.total_signals,\n total_fetched: data.total_fetched,\n top_items: items.slice(0, 15).map(i => ({\n title: i.title,\n source: i.source,\n score: i.signal_score,\n category: i.primary_category,\n url: i.url\n }))\n }\n}];" }, "position": [ 1856, 432 ] }, { "id": "7a566c27-041c-4164-9d7b-be035c22a036", "name": "Build Intelligence Report", "type": "code", "params": { "jsCode": "const data = $input.first().json;\nconst themes = data.themes || [];\nconst topItems = data.top_items || [];\nconst today = data.date || new Date().toISOString().split('T')[0];\n\nif (themes.length === 0 && topItems.length === 0) {\n const report = 'SIGNAL INTELLIGENCE REPORT — ' + today + '\\n\\nSources scanned: ' + (data.total_fetched || 0) + ' items\\nNo matching signals found today.\\n\\nTip: Broaden keywords in the Score node, or add more RSS sources.';\n return [{\n json: {\n report: report,\n report_html: '

Signal Report — ' + today + '

No matching signals found today.

',\n date: today,\n themes: [],\n top_items: [],\n strong_theme_count: 0,\n total_signals: 0\n }\n }];\n}\n\nlet report = 'SIGNAL INTELLIGENCE REPORT — ' + today + '\\n';\nreport += 'Sources scanned: ' + data.total_fetched + ' items → ' + data.total_signals + ' signals detected\\n';\nreport += '━━━━━━━━━━━━━━━━━━━━━━━━━━\\n\\n';\nreport += 'THEME STRENGTH RANKING:\\n\\n';\n\nfor (const theme of themes) {\n report += theme.signal_level + ' ' + theme.category + '\\n';\n report += ' Strength: ' + theme.theme_strength + ' | Items: ' + theme.item_count + ' | Sources: ' + theme.sources.join(', ') + '\\n';\n report += ' Keywords: ' + theme.top_keywords.join(', ') + '\\n\\n';\n}\n\nreport += '━━━━━━━━━━━━━━━━━━━━━━━━━━\\n';\nreport += 'TOP 10 STRONGEST SIGNALS:\\n\\n';\n\nfor (let i = 0; i < Math.min(topItems.length, 10); i++) {\n const item = topItems[i];\n report += (i + 1) + '. ' + item.title + '\\n';\n report += ' Score: ' + item.score + ' | Source: ' + item.source + ' | Theme: ' + item.category + '\\n';\n if (item.url) report += ' ' + item.url + '\\n';\n report += '\\n';\n}\n\nconst strongThemes = themes.filter(t => t.theme_strength >= 15);\nif (strongThemes.length > 0) {\n report += '━━━━━━━━━━━━━━━━━━━━━━━━━━\\n';\n report += 'ACTION ITEMS — Strong signals detected:\\n\\n';\n for (const t of strongThemes) {\n report += '• ' + t.category + ' is surging across ' + t.source_count + ' sources. ';\n report += 'Top keyword: ' + (t.top_keywords[0] || 'n/a') + '. ';\n report += 'Consider creating content or building in this space.\\n';\n }\n}\n\nlet html = '

Signal Intelligence Report — ' + today + '

';\nhtml += '

Sources scanned: ' + data.total_fetched + ' items → ' + data.total_signals + ' signals

';\nhtml += '

Theme Strength

';\nhtml += '';\nfor (const theme of themes) {\n html += '';\n html += '';\n html += '';\n html += '';\n html += '';\n}\nhtml += '

Theme	Signal	Strength	Items	Sources
' + theme.category + '	' + theme.signal_level + '	' + theme.theme_strength + '	' + theme.item_count + '	' + theme.sources.join(', ') + '

';\nhtml += '

Top Signals

' + item.title + '
Score: ' + item.score + ' | ' + item.source + ' | ' + item.category;\n if (item.url) html += ' | Link';\n html += '

';\n\nreturn [{\n json: {\n report: report,\n report_html: html,\n date: today,\n themes: themes,\n top_items: topItems,\n strong_theme_count: strongThemes.length,\n total_signals: data.total_signals\n }\n}];" }, "position": [ 2080, 432 ] }, { "id": "9ca1e3b4-a677-44f0-9f04-7fcf6d480dad", "name": "Flatten Top Signals for Sheet", "type": "code", "params": { "jsCode": "const data = $input.first().json;\nconst items = data.top_items || [];\n\nif (items.length === 0) {\n return [{ json: { date: data.date, title: 'No signals detected', source: '-', score: 0, category: '-', url: '-' } }];\n}\n\nreturn items.map(item => ({\n json: {\n date: data.date,\n title: item.title || '',\n source: item.source || '',\n score: item.score || 0,\n category: item.category || '',\n url: item.url || ''\n }\n}));" }, "position": [ 2304, 336 ] }, { "id": "ea3b55cb-bf55-4fea-a5db-4b5cc8f4b2d8", "name": "Log Signals to Sheet", "type": "integration", "params": { "columns": { "value": { "date": "={{ $json.date }}", "category": "={{ $json.category }}" }, "schema": [ { "id": "date", "type": "string", "display": true, "required": false, "displayName": "date", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "category", "type": "string", "display": true, "required": false, "displayName": "category", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "signal_level", "type": "string", "display": true, "required": false, "displayName": "signal_level", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "theme_strength", "type": "string", "display": true, "required": false, "displayName": "theme_strength", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "item_count", "type": "string", "display": true, "required": false, "displayName": "item_count", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "sources", "type": "string", "display": true, "required": false, "displayName": "sources", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "top_keywords", "type": "string", "display": true, "required": false, "displayName": "top_keywords", "defaultMatch": false, "canBeUsedToMatch": true } ], "mappingMode": "autoMapInputData", "matchingColumns": [], "attemptToConvertTypes": false, "convertFieldsToString": true }, "options": {}, "service": "googleSheets", "operation": "append", "sheetName": { "__rl": true, "mode": "list", "value": "YOUR_SIGNALS_SHEET_GID", "cachedResultUrl": "YOUR_SIGNALS_SHEET_URL", "cachedResultName": "signal" }, "documentId": { "__rl": true, "mode": "list", "value": "YOUR_GOOGLE_SHEET_ID", "cachedResultUrl": "YOUR_GOOGLE_SHEET_URL", "cachedResultName": "Your Signal Tracking Sheet" } }, "position": [ 2528, 336 ] }, { "id": "a13b13c1-42c3-4f3e-97a5-c61611d51f4e", "name": "Post Report to Slack", "type": "integration", "params": { "text": "={{ $json.report }}", "service": "slack", "operation": "read", "otherOptions": {} }, "position": [ 2304, 528 ] }, { "id": "487352c5-339f-4210-8bb6-8aee9fef77e8", "name": "Prepare Themes for Sheet", "type": "code", "params": { "jsCode": "const data = $input.first().json;\nconst themes = data.themes || [];\n\nif (themes.length === 0) {\n return [{ json: { date: data.date, category: 'No themes', signal_level: '-', theme_strength: 0, item_count: 0, sources: '-', top_keywords: '-' } }];\n}\n\nreturn themes.map(theme => ({\n json: {\n date: data.date,\n category: theme.category,\n signal_level: theme.signal_level,\n theme_strength: theme.theme_strength,\n item_count: theme.item_count,\n sources: theme.sources.join(', '),\n top_keywords: theme.top_keywords.join(', ')\n }\n}));" }, "position": [ 2304, 144 ] }, { "id": "0c0c570b-35c1-4025-b039-02fbc3bc68e5", "name": "Log Themes to Sheet", "type": "integration", "params": { "columns": { "value": { "date": "={{ $json.date }}", "sources": "={{ $json.sources }}", "category": "={{ $json.category }}", "item_count": "={{ $json.item_count }}", "signal_level": "={{ $json.signal_level }}", "top_keywords": "={{ $json.top_keywords }}", "theme_strength": "={{ $json.theme_strength }}" }, "schema": [ { "id": "date", "type": "string", "required": false, "displayName": "date", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "category", "type": "string", "required": false, "displayName": "category", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "signal_level", "type": "string", "required": false, "displayName": "signal_level", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "theme_strength", "type": "string", "required": false, "displayName": "theme_strength", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "item_count", "type": "string", "required": false, "displayName": "item_count", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "sources", "type": "string", "required": false, "displayName": "sources", "defaultMatch": false, "canBeUsedToMatch": true }, { "id": "top_keywords", "type": "string", "required": false, "displayName": "top_keywords", "defaultMatch": false, "canBeUsedToMatch": true } ], "mappingMode": "defineBelow", "matchingColumns": [], "attemptToConvertTypes": false, "convertFieldsToString": true }, "options": {}, "service": "googleSheets", "operation": "append", "sheetName": { "__rl": true, "mode": "list", "value": "YOUR_THEMES_SHEET_GID", "cachedResultUrl": "YOUR_THEMES_SHEET_URL", "cachedResultName": "themes" }, "documentId": { "__rl": true, "mode": "list", "value": "YOUR_GOOGLE_SHEET_ID", "cachedResultUrl": "YOUR_GOOGLE_SHEET_URL", "cachedResultName": "Your Signal Tracking Sheet" } }, "position": [ 2528, 144 ] }, { "id": "677fd5a7-a775-4c41-8250-70795d778306", "name": "Email Daily Report", "type": "integration", "params": { "sendTo": "user@example.com", "message": "={{ $json.report_html }}", "options": {}, "service": "gmail", "subject": "=Signal Report — {{ $json.date }} | {{ $json.total_signals }} signals, {{ $json.strong_theme_count }} strong themes", "operation": "read" }, "position": [ 2304, 720 ] } ] }

Aggregate tech trend signals from RSS feeds into Google Sheets and Slack