Trends Social Media - {{ $('Loop Over Reddit Queries').first().json.Query }}

{ "edges": [ { "to": "9000ea56-c59b-44de-93c3-c477013d0369", "from": "801f152f-3f86-4fb4-bf50-9226fb4b07ce", "toPort": "0", "fromPort": "0" }, { "to": "06bb249b-5562-4dd6-a6c3-d4c5229af21a", "from": "801f152f-3f86-4fb4-bf50-9226fb4b07ce", "toPort": "0", "fromPort": "0" }, { "to": "8253a240-ad37-4216-863d-3060e87fecae", "from": "d15af1fa-c841-4758-8e56-ac08281e101c", "toPort": "0", "fromPort": "0" }, { "to": "d15af1fa-c841-4758-8e56-ac08281e101c", "from": "5164bd2a-5164-4e78-86c6-4c8c59cfadd5", "toPort": "0", "fromPort": "0" }, { "to": "fa2a7763-4c96-4dfe-90b4-3a6576fe7a97", "from": "8253a240-ad37-4216-863d-3060e87fecae", "toPort": "0", "fromPort": "1" }, { "to": "8253a240-ad37-4216-863d-3060e87fecae", "from": "9000ea56-c59b-44de-93c3-c477013d0369", "toPort": "0", "fromPort": "0" }, { "to": "801f152f-3f86-4fb4-bf50-9226fb4b07ce", "from": "2abb82bf-b2bb-4e94-b5c4-055019dc04a9", "toPort": "0", "fromPort": "0" }, { "to": "2abb82bf-b2bb-4e94-b5c4-055019dc04a9", "from": "fa2a7763-4c96-4dfe-90b4-3a6576fe7a97", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "8253a240-ad37-4216-863d-3060e87fecae", "name": "Loop Over Reddit Queries", "type": "passthrough", "params": { "mode": "noOp", "options": {} }, "position": [ 1456, 1152 ] }, { "id": "2abb82bf-b2bb-4e94-b5c4-055019dc04a9", "name": "Sort Reddit Posts by Score", "type": "code", "params": { "jsCode": "// Code pour nœud Code n8n - Classement Reddit avec output simplifié\n\n// Récupérer les données d'entrée\nconst items = $input.all();\n\n// Filtrer uniquement les posts (exclure les commentaires)\nconst posts = items.filter(item => item.json.dataType === 'post');\n\n// Calculer le score pour chaque post\nconst postsWithScore = posts.map(item => {\n const post = item.json;\n \n // Calcul du score : 1 point par upvote + 2 points par commentaire\n const upvoteScore = (post.upVotes || 0) * 1;\n const commentScore = (post.numberOfComments || 0) * 2\n ;\n const totalScore = upvoteScore + commentScore;\n \n return {\n json: {\n url: post.url,\n title: post.title || \"Pas de titre\",\n body: post.body || \"Pas de contenu\",\n score: totalScore,\n // Données détaillées pour debug (optionnel)\n details: {\n upvotes: post.upVotes || 0,\n comments: post.numberOfComments || 0,\n community: post.communityName,\n timestamp: post.createdAt\n }\n }\n };\n});\n\n// Trier par score décroissant\nconst sortedPosts = postsWithScore.sort((a, b) => b.json.score - a.json.score);\n\n// Prendre les 10 meilleurs\nconst top10Posts = sortedPosts.slice(0, 10);\n\n// Ajouter un rang à chaque post\nconst rankedPosts = top10Posts.map((post, index) => ({\n json: {\n rank: index + 1,\n url: post.json.url,\n title: post.json.title,\n body: post.json.body,\n score: post.json.score\n }\n}));\n\n// Log pour debug\nconsole.log(`🏆 TOP 10 POSTS REDDIT - Score = (upvotes×1) + (commentaires×2)`);\nconsole.log(`────────────────────────────────────────────────────────────`);\n\nrankedPosts.forEach((post, index) => {\n const p = post.json;\n const shortTitle = p.title.length > 60 ? p.title.substring(0, 60) + '...' : p.title;\n const shortBody = p.body.length > 80 ? p.body.substring(0, 80) + '...' : p.body;\n \n console.log(`${p.rank}. Score: ${p.score}`);\n console.log(` URL: ${p.url}`);\n console.log(` Titre: \"${shortTitle}\"`);\n console.log(` Contenu: \"${shortBody}\"`);\n console.log(` ────────────────────────────────────────────────────────`);\n});\n\nconsole.log(`\\n📊 Analysé ${posts.length} posts au total`);\n\n// Retourner les résultats avec le format demandé\nreturn rankedPosts;" }, "position": [ 1920, 1152 ] }, { "id": "5164bd2a-5164-4e78-86c6-4c8c59cfadd5", "name": "Reddit Schedule Trigger", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ {} ] } }, "position": [ 976, 1152 ] }, { "id": "d15af1fa-c841-4758-8e56-ac08281e101c", "name": "Get Reddit Query Rows", "type": "passthrough", "params": { "mode": "noOp", "operation": "get", "returnAll": true, "dataTableId": { "__rl": true, "mode": "list", "value": "BYMzHVIbNU0mmvAZ", "cachedResultUrl": "/projects/oTpNUA7ZOCuhiQA0/datatables/BYMzHVIbNU0mmvAZ", "cachedResultName": "Query social media" } }, "position": [ 1184, 1152 ] }, { "id": "9000ea56-c59b-44de-93c3-c477013d0369", "name": "Send Reddit Report Email", "type": "integration", "params": { "sendTo": "user@example.com", "message": "=\n\n\n \n \n Trends Social Media - {{ $('Loop Over Reddit Queries').first().json.Query }}\n \n\n\n

\n \n \n\n \n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n

Hashtag	TikTok	Reddit	Instagram	Score Total
\n #{{ $('Loop Over Reddit Queries').first().json.Query }}\n	\n {{ $('Rank Reddit Posts1').all().filter(item => item.json.source === 'TikTok').reduce((sum, item) => sum + item.json.score, 0).toLocaleString('fr-FR') }}\n	\n {{ $('Rank Reddit Posts1').all().filter(item => item.json.source === 'Reddit').reduce((sum, item) => sum + item.json.score, 0).toLocaleString('fr-FR') }}\n	\n {{ $('Rank Reddit Posts1').all().filter(item => item.json.source === 'Instagram').reduce((sum, item) => sum + item.json.score, 0).toLocaleString('fr-FR') }}\n	\n {{ $('Rank Reddit Posts1').all().reduce((sum, item) => sum + item.json.score, 0).toLocaleString('fr-FR') }}\n

\n\n \n

#{{ $('Loop Over Reddit Queries').first().json.Query }}

\n \n \n \n \n \n \n \n \n \n \n \n \n \n {{ $('Rank Reddit Posts1').all().map(item => `\n \n \n \n \n \n \n \n \n `).join('') }}\n \n

Rang	Source	Auteur	Contenu	Score	Level
\n ${item.json.rank}\n	\n ${item.json.source}\n	\n ${item.json.author}\n	\n ${item.json.content} \n	\n ${item.json.score.toLocaleString('fr-FR')}\n	\n ${item.json.level}\n

\n\n \n \n

\n\n", "options": {}, "service": "gmail", "subject": "Social media monitoring", "operation": "read" }, "position": [ 2384, 1152 ] }, { "id": "06bb249b-5562-4dd6-a6c3-d4c5229af21a", "name": "Push Results to Data Table", "type": "passthrough", "params": { "mode": "noOp", "columns": { "value": { "url": "={{ $json.url }}", "Date": "={{ $now.toISO() }}", "rank": "={{ $json.rank }}", "level": "={{ $json.level }}", "score": "={{ $json.score }}", "author": "={{ $json.author }}", "source": "={{ $json.source }}", "content": "={{ $json.content }}", "keyword": "={{ $json.keyword }}" }, "schema": [ { "id": "rank", "type": "number", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "rank", "defaultMatch": false }, { "id": "keyword", "type": "string", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "keyword", "defaultMatch": false }, { "id": "source", "type": "string", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "source", "defaultMatch": false }, { "id": "author", "type": "string", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "author", "defaultMatch": false }, { "id": "content", "type": "string", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "content", "defaultMatch": false }, { "id": "score", "type": "number", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "score", "defaultMatch": false }, { "id": "level", "type": "string", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "level", "defaultMatch": false }, { "id": "url", "type": "string", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "url", "defaultMatch": false }, { "id": "Date", "type": "dateTime", "display": true, "removed": false, "readOnly": false, "required": false, "displayName": "Date", "defaultMatch": false } ], "mappingMode": "defineBelow", "matchingColumns": [], "attemptToConvertTypes": false, "convertFieldsToString": false }, "options": {}, "dataTableId": { "__rl": true, "mode": "list", "value": "75Jvx9ALCoEGcdwY", "cachedResultUrl": "/projects/oTpNUA7ZOCuhiQA0/datatables/75Jvx9ALCoEGcdwY", "cachedResultName": "Trend Social media" } }, "position": [ 2384, 1024 ] }, { "id": "fa2a7763-4c96-4dfe-90b4-3a6576fe7a97", "name": "Fetch Reddit Posts via Apify1", "type": "http", "params": { "url": "https://api.apify.com/v2/acts/trudax~reddit-scraper-lite/run-sync-get-dataset-items", "method": "POST", "options": {}, "jsonBody": "={\n \"searches\": [\"{{ $json.Query }}\"],\n \"searchPosts\": true,\n \"searchComments\": false,\n \"searchCommunities\": false,\n \"searchUsers\": false,\n \"sort\": \"top\",\n \"time\": \"month\",\n \"maxItems\": 50,\n \"maxPostCount\": 50,\n \"maxComments\": 1,\n \"scrollTimeout\": 40,\n \"proxy\": {\n \"useApifyProxy\": true,\n \"apifyProxyGroups\": [\"RESIDENTIAL\"]\n }\n}", "sendBody": true, "sendHeaders": true, "specifyBody": "json", "authentication": "predefinedCredentialType", "headerParameters": { "parameters": [ { "name": "Content-Type", "value": "application/json" } ] }, "nodeCredentialType": "apifyApi" }, "position": [ 1664, 1152 ] }, { "id": "801f152f-3f86-4fb4-bf50-9226fb4b07ce", "name": "Rank Reddit Posts1", "type": "code", "params": { "jsCode": "// Code pour nœud Code n8n - Classement Reddit\n// Récupérer le keyword dynamiquement\nconst keyword = $('Loop Over Reddit Queries').first().json.Query;\n\n// Récupérer les données du nœud précédent\nconst redditData = $('Sort Reddit Posts by Score').all();\n\nconsole.log(`📥 Récupération des données:`);\nconsole.log(`- Reddit: ${redditData.length} posts`);\n\n// Fonction pour déterminer le level basé sur le score\nfunction getLevel(score) {\n if (score >= 10000) return 'High';\n if (score >= 1000) return 'Medium';\n return 'Low';\n}\n\n// Fonction pour extraire le subreddit\nfunction getAuthor(item) {\n const redditMatch = item.url.match(/\\/r\\/([^\\/]+)/);\n return redditMatch ? `r/${redditMatch[1]}` : 'user_inconnu';\n}\n\n// Transformer les données Reddit\nconst redditPosts = redditData.map(item => ({\n json: {\n source: 'Reddit',\n keyword: keyword,\n author: getAuthor(item.json),\n content: (item.json.title || 'Pas de titre').substring(0, 50) + '...',\n score: item.json.score,\n level: getLevel(item.json.score),\n url: item.json.url,\n originalRank: item.json.rank\n }\n}));\n\n// Trier par score décroissant\nconst sortedPosts = redditPosts.sort((a, b) => b.json.score - a.json.score);\n\n// Ajouter le rang unifié\nconst rankedPosts = sortedPosts.map((post, index) => ({\n json: {\n ...post.json,\n rank: index + 1,\n date: new Date().toISOString().split('T')[0]\n }\n}));\n\n// Prendre le top 15\nconst topPosts = rankedPosts.slice(0, 15);\n\n// Statistiques par niveau\nconst stats = {\n total: topPosts.length,\n byLevel: {\n High: topPosts.filter(p => p.json.level === 'High').length,\n Medium: topPosts.filter(p => p.json.level === 'Medium').length,\n Low: topPosts.filter(p => p.json.level === 'Low').length\n }\n};\n\n// Log pour debug\nconsole.log(`🏆 TOP ${topPosts.length} POSTS REDDIT - Mot-clé: \"${keyword}\"`);\nconsole.log(`────────────────────────────────────────────────────────────────────────────────`);\n\ntopPosts.forEach((post) => {\n const p = post.json;\n console.log(`${p.rank}. ${p.author} - Score: ${p.score.toLocaleString()} (${p.level})`);\n console.log(` Contenu: \"${p.content}\"`);\n console.log(` URL: ${p.url}`);\n console.log(` ────────────────────────────────────────────────────────────────────────────`);\n});\n\nconsole.log(`\\n📊 STATISTIQUES:`);\nconsole.log(`Total: ${stats.total} posts`);\nconsole.log(`Par niveau: High(${stats.byLevel.High}) | Medium(${stats.byLevel.Medium}) | Low(${stats.byLevel.Low})`);\n\n// Retourner le classement\nreturn topPosts;" }, "position": [ 2144, 1152 ] } ] }

Monitor Reddit keyword trends and email reports with Apify