January 21, 2026

Reddit to Slack, a clean digest your team will read

Lisa Granqvist Partner Workflow Automation Expert

Get a free AI assessment → ⬇️ Use template

Your team keeps saying “we should watch Reddit for this,” then nobody does. Or worse, someone posts a raw link dump in Slack, it gets ignored, and you’re back to tab hopping and half-remembered threads.

This Reddit Slack digest problem hits marketing managers first, because timing matters. But founders and community leads feel it too. You want the signal, not the noise, and you want it where work already happens.

This workflow fetches top Reddit posts, cleans and deduplicates them, uses AI to rank what matters, then posts a readable digest into Slack (and optionally Telegram or Discord). You’ll see how it works, what you need, and where teams usually trip up.

How This Automation Works

The full n8n workflow, from trigger to final output:

n8n Workflow Template: Reddit to Slack, a clean digest your team will read

Click to explore

flowchart LR

    subgraph sg0["Scheduled Digest Flow"]
        direction LR
        n0@{ icon: "mdi:play-circle", form: "rounded", label: "Scheduled Digest Trigger", pos: "b", h: 48 }
        n1@{ icon: "mdi:swap-vertical", form: "rounded", label: "Settings Setup", pos: "b", h: 48 }
        n2@{ icon: "mdi:swap-vertical", form: "rounded", label: "Build Subreddit Array", pos: "b", h: 48 }
        n3@{ icon: "mdi:swap-vertical", form: "rounded", label: "Iterate Subreddit Items", pos: "b", h: 48 }
        n4["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/httprequest.dark.svg' width='40' height='40' /></div><br/>Retrieve Reddit Feed"]
        n5["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/code.svg' width='40' height='40' /></div><br/>Clean Post Records"]
        n6["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/code.svg' width='40' height='40' /></div><br/>Merge and Filter Posts"]
        n7@{ icon: "mdi:robot", form: "rounded", label: "AI Digest Curator", pos: "b", h: 48 }
        n8@{ icon: "mdi:brain", form: "rounded", label: "Gemini Chat Model", pos: "b", h: 48 }
        n9["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/code.svg' width='40' height='40' /></div><br/>Format Digest Output"]
        n10@{ icon: "mdi:swap-horizontal", form: "rounded", label: "Validate Digest Text", pos: "b", h: 48 }
        n11["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/telegram.svg' width='40' height='40' /></div><br/>Post to Telegram"]
        n12["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/discord.svg' width='40' height='40' /></div><br/>Dispatch to Discord"]
        n13["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/slack.svg' width='40' height='40' /></div><br/>Send Slack Update"]
        n10 --> n11
        n10 --> n12
        n10 --> n13
        n1 --> n2
        n8 -.-> n7
        n7 --> n9
        n5 --> n6
        n2 --> n3
        n6 --> n7
        n3 --> n4
        n4 --> n5
        n0 --> n1
        n9 --> n10
    end

    %% Styling
    classDef trigger fill:#e8f5e9,stroke:#388e3c,stroke-width:2px
    classDef ai fill:#e3f2fd,stroke:#1976d2,stroke-width:2px
    classDef aiModel fill:#e8eaf6,stroke:#3f51b5,stroke-width:2px
    classDef decision fill:#fff8e1,stroke:#f9a825,stroke-width:2px
    classDef database fill:#fce4ec,stroke:#c2185b,stroke-width:2px
    classDef api fill:#fff3e0,stroke:#e65100,stroke-width:2px
    classDef code fill:#f3e5f5,stroke:#7b1fa2,stroke-width:2px
    classDef disabled stroke-dasharray: 5 5,opacity: 0.5
    class n0 trigger
    class n7 ai
    class n8 aiModel
    class n10 decision
    class n4 api
    class n5,n6,n9 code
    classDef customIcon fill:none,stroke:none
    class n4,n5,n6,n9,n11,n12,n13 customIcon

The Problem: Reddit Research Turns Into Tab Chaos

Reddit is great for market intel. It’s also exhausting. You start with “just checking a few subreddits,” and suddenly you’re 30 tabs deep, pulling half-relevant posts into a doc, then trying to explain the context to your team in Slack. Even if you do the work, it’s messy: duplicates across subreddits, low-effort meme posts, and titles that don’t tell your team what the thread is actually about. After a week or two, people stop sharing because it’s too much effort to make it readable.

It adds up fast. Here’s where it breaks down.

Manually checking 6–10 subreddits can easily burn about 2 hours a week, and the cost is usually focus, not just time.
Low-quality posts and repeated links slip in, which means the digest gets ignored after a few noisy days.
“Just paste the links” creates zero shared understanding, so decisions still happen off gut feel.
When one person owns the habit, the whole “Reddit insights” pipeline dies the moment they get busy.

The Solution: An AI-Curated Reddit Digest Posted to Slack

This n8n workflow turns Reddit into a dependable, readable briefing inside Slack. It runs on a schedule (or on demand), pulls top posts from the subreddits you choose using Reddit’s public JSON feed, and then cleans the data so you’re not reviewing junk. Next, it removes duplicates and filters posts using simple rules like minimum upvotes plus your include/exclude keywords. After that, an AI agent ranks what’s left by relevance and generates a formatted digest that your team will actually scan. If the digest text looks valid, it posts the final update to Slack, with the same digest optionally going to Telegram or Discord if you want multiple destinations.

The workflow starts with a scheduled trigger and a settings block where you control subreddits, time filters, keywords, and post counts. Then it fetches, cleans, merges, and hands the shortlist to an AI model (Gemini, OpenAI, or Claude). Finally, the formatted digest is validated and delivered to Slack (plus other channels you enable).

What You Get: Automation vs. Results

What This Workflow Automates

Results You’ll Get

Fetches top posts from multiple subreddits via Reddit’s JSON API.
Cleans and normalizes post data so titles, links, and scores are consistent.
Removes duplicates and filters by upvotes plus your include/exclude keywords.
Uses an AI agent to rank relevance and generate a formatted digest, then posts to Slack (and optionally Telegram/Discord).

Most teams get about 2 hours back each week from not manually checking Reddit.
A digest that reads like a brief, not a link dump.
Less “random research” and more repeatable monitoring.
Fewer missed trends because the workflow runs on schedule.
Cleaner internal sharing, which means faster alignment and clearer next steps.

Example: What This Looks Like

Say you monitor 8 subreddits and you usually skim 15 posts per subreddit to find “the good stuff.” If you spend maybe 2 minutes per post including clicks and context switching, that’s about 4 hours of scanning per week. With this workflow, you set a schedule once and let it curate automatically: a minute to adjust settings when needed, a few minutes of AI processing, then the digest lands in Slack ready to read. For many teams, that’s roughly 3 hours back every week, without losing visibility.

What You’ll Need

n8n instance (try n8n Cloud free)
Self-hosting option if you prefer (Hostinger works well)
Slack for posting the digest to a channel
Google Gemini or OpenAI to rank and summarize posts
AI provider API key (get it from your provider’s developer console)

Skill level: Beginner. You’ll connect accounts, paste an API key, and edit a few settings like subreddit names and keywords.

Don’t want to set this up yourself? Talk to an automation expert (free 15-minute consultation).

How It Works

A scheduled run kicks things off. The workflow can run daily, weekly, or on whatever cadence you choose, so the digest becomes a habit without relying on someone remembering.

Your subreddit list is prepared and looped through. A settings node builds an array of subreddits, then the workflow iterates through them so you can monitor many communities without duplicating the whole automation.

Reddit posts are fetched, cleaned, and filtered. n8n pulls the top posts via HTTP Request, then code steps clean up the records, deduplicate overlaps, and apply simple rules like upvote thresholds and keyword includes/excludes.

AI curates what’s worth your team’s attention. The AI agent (paired with a Gemini/OpenAI chat model) ranks the remaining posts by relevance, then generates a concise digest. Another code step formats it so it looks good in chat.

The digest is validated and delivered. If the text passes a quick check (not empty, long enough to be useful), it gets posted to Slack. Telegram and Discord delivery nodes are also there if you want them.

You can easily modify the subreddit list to focus on a new product line or campaign based on your needs. See the full implementation guide below for customization options.

Step-by-Step Implementation Guide

Step 1: Configure the Schedule Trigger

Set up the workflow to run automatically on a daily schedule.

Add and open Scheduled Digest Trigger.
Set the Rule to a cron expression of 0 9 * * * to run daily at 9 AM.
Connect Scheduled Digest Trigger to Settings Setup.

Step 2: Connect Reddit Source Settings

Define subreddit inputs and configure the Reddit API request.

Open Settings Setup and add the following assignments: subreddits to AI_Agents,generativeAI,ArtificialInteligence,MachineLearning,OpenAI,ChatGPT, posts_per_subreddit to 25, time_filter to day, total_posts_in_digest to 10, digest_title to 🤖 AI Daily Digest, focus_keywords to AI agents, ChatGPT, LLM, machine learning, research, tool, breakthrough, exclude_keywords to crypto, NFT, political, spam, and min_upvotes to 10.
Open Build Subreddit Array and set subreddit_array to {{ $json.subreddits.split(',').map(s => s.trim()) }}.
Open Iterate Subreddit Items and set subreddit to {{ $json.subreddit_array[$itemIndex] }}.
Open Retrieve Reddit Feed and set URL to https://www.reddit.com/r/{{ $json.subreddit }}/top.json?t={{ $('Settings Setup').first().json.time_filter }}&limit={{ $('Settings Setup').first().json.posts_per_subreddit }}.
Enable Send Headers and add the header User-Agent with value n8n-reddit-automation/1.0.
Credential Required: Connect your httpHeaderAuth credentials in Retrieve Reddit Feed.

⚠️ Common Pitfall: Reddit blocks requests without a valid User-Agent header or proper auth configuration in Retrieve Reddit Feed.

Step 3: Clean and Merge Reddit Posts

Normalize data and apply filtering rules before sending to the AI curator.

Open Clean Post Records to ensure the JavaScript logic is intact for removing low-quality or removed posts and sorting by score.
Open Merge and Filter Posts and confirm the logic for deduplication and keyword filters is in place.
Verify the execution order: Retrieve Reddit Feed → Clean Post Records → Merge and Filter Posts.

Step 4: Set Up AI Digest Generation

Use Gemini to curate and format the digest from filtered posts.

Open AI Digest Curator and confirm the Text prompt is set to the provided long-form instruction text starting with You are an expert content curator for Reddit news digests....
Ensure Gemini Chat Model is connected as the language model for AI Digest Curator; credentials must be added to Gemini Chat Model, not the agent node.
Credential Required: Connect your Google Gemini credentials in Gemini Chat Model.
Open Format Digest Output and keep the code that extracts formatted_output and adds timestamp and digest_title.
Confirm the execution order: Merge and Filter Posts → AI Digest Curator → Format Digest Output → Validate Digest Text.

⚠️ Common Pitfall: If Gemini Chat Model credentials aren’t set, AI Digest Curator will fail without a clear error in the output.

Step 5: Configure Output Channels

Send the curated digest to Telegram, Discord, and Slack when it passes validation.

Open Validate Digest Text and verify the condition checks {{ $json.formatted_output }} is not empty.
Open Post to Telegram and set Text to {{ $json.formatted_output }} and Chat ID to {{ $('Settings Setup').first().json.telegram_chat_id || '[YOUR_ID]' }}.
Open Dispatch to Discord and set Content to {{ $json.formatted_output }} with Authentication set to webhook.
Open Send Slack Update and set Text to {{ $json.formatted_output }} and Select to channel.
Confirm parallel execution: Validate Digest Text outputs to both Post to Telegram and Dispatch to Discord and Send Slack Update in parallel.
Credential Required: Add Telegram credentials in Post to Telegram.
Credential Required: Add Discord webhook credentials in Dispatch to Discord.
Credential Required: Add Slack credentials in Send Slack Update.

⚠️ Common Pitfall: Leaving [YOUR_ID] in Post to Telegram or Send Slack Update will send nothing.

Step 6: Test & Activate

Validate the entire pipeline before enabling scheduled runs.

Click Execute Workflow to run a manual test from Scheduled Digest Trigger.
Check that Retrieve Reddit Feed returns JSON and Format Digest Output outputs a non-empty formatted_output.
Verify that Telegram, Discord, and Slack each receive the same formatted digest after Validate Digest Text passes.
When the test succeeds, switch the workflow to Active to allow scheduled execution.

🔒

Unlock Full Step-by-Step Guide

Get the complete implementation guide + downloadable template

Common Gotchas

Slack credentials can expire or need specific permissions. If things break, check the Slack app OAuth scopes and token status in your n8n credentials first.
If you’re using Wait nodes or external processing, run times vary. Bump up the wait duration if downstream nodes fail on empty responses.
Default prompts in AI nodes are generic. Add your brand voice and “what counts as relevant” early or you will be editing outputs forever.

Frequently Asked Questions

How long does it take to set up this Reddit Slack digest automation?

About 30 minutes if your Slack and AI accounts are ready.

Do I need coding skills to automate Reddit Slack digest delivery?

No. You’ll mostly paste credentials and edit the subreddit/keyword settings. The code nodes are already built for you.

Is n8n free to use for this Reddit Slack digest workflow?

Yes. n8n has a free self-hosted option and a free trial on n8n Cloud. Cloud plans start at $20/month for higher volume. You’ll also need to factor in AI API costs (Gemini has a free tier, and OpenAI usage is usually a few cents per digest).

Where can I host n8n to run this automation?

Two options: n8n Cloud (managed, easiest setup) or self-hosting on a VPS. For self-hosting, Hostinger VPS is affordable and handles n8n well. Self-hosting gives you unlimited executions but requires basic server management.

Can I customize this Reddit Slack digest automation for a weekly executive summary instead of a daily digest?

Yes, and it’s honestly one of the best ways to use it. Change the schedule in the Scheduled Digest Trigger, then adjust the AI Digest Curator prompt to produce a “top 5 themes + links” summary instead of individual post bullets. Many teams also tweak the upvote threshold in the filtering logic so the weekly brief stays tight. If you still want daily coverage, send daily digests to a private Slack channel and only post the weekly summary to your main team channel.

Why is my Slack connection failing in this workflow?

Usually it’s expired or missing OAuth permissions. Reconnect Slack in n8n credentials, confirm the app has access to the target channel, and make sure the channel still exists (it happens). If you’re posting to a private channel, the Slack app must be invited to that channel. Rate limiting is rare for one daily digest, but can show up if you test in rapid loops.

How many posts can this Reddit Slack digest automation handle?

A lot more than you’ll want to read, so you’ll usually cap it on purpose.

Is this Reddit Slack digest automation better than using Zapier or Make?

For this use case, n8n tends to fit better because you can do deduping, branching, and richer formatting without paying extra per “path,” and self-hosting avoids strict task limits. The AI agent approach is also easier to shape when you need ranking plus a clean digest format, not just a summary. Zapier or Make can still work if you only need a simple “fetch and post” flow, but you’ll often rebuild a lot of logic using extra steps. If you’re unsure, Talk to an automation expert and we’ll help you choose quickly.

Once this is running, Reddit stops being a guilty “I’ll check later” tab and turns into a clean briefing your team can act on. Set it up once, then let the workflow do the sorting.

Need Help Setting This Up?

Our automation experts can build and customize this workflow for your specific needs. Free 15-minute consultation—no commitment required.

Lisa Granqvist

Workflow Automation Expert

Expert in workflow automation and no-code tools.

{
"id": null,
"meta": {
"instanceId": "84f869f79d747214daa06a129b47a3878db590f816e7c9c004ac3172bc6b30b6",
"templateId": null,
"templateCredsSetupCompleted": null
},
"name": "Automated Reddit Digest Pipeline",
"tags": [],
"nodes": [
{
"id": "flowpast-topbar-10246",
"name": "Flowpast Branding",
"type": "n8n-nodes-base.stickyNote",
"position": [
0,
20
],
"parameters": {
"color": 7,
"width": 1060,
"height": 80,
"content": "## Flowpast.com | Automation Workflow Library\n**\ud83d\udcd6 Full tutorial & setup guide:** flowpast.com"
},
"typeVersion": 1
},
{
"id": "132efcb7-a0c6-4bca-8420-891971640e7f",
"name": "Scheduled Digest Trigger",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
960,
120
],
"parameters": {
"rule": {
"interval": [
{
"field": "cronExpression",
"expression": "0 9 * * *"
}
]
}
},
"typeVersion": 1.2
},
{
"id": "43f60c9c-e735-4e3c-907e-91cca5cd377f",
"name": "Settings Setup",
"type": "n8n-nodes-base.set",
"position": [
655,
205
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "subreddits",
"name": "subreddits",
"type": "string",
"value": "=AI_Agents,generativeAI,ArtificialInteligence,MachineLearning,OpenAI,ChatGPT"
},
{
"id": "posts_per_subreddit",
"name": "posts_per_subreddit",
"type": "number",
"value": 25
},
{
"id": "time_filter",
"name": "time_filter",
"type": "string",
"value": "day"
},
{
"id": "total_posts_in_digest",
"name": "total_posts_in_digest",
"type": "number",
"value": 10
},
{
"id": "digest_title",
"name": "digest_title",
"type": "string",
"value": "\ud83e\udd16 AI Daily Digest"
},
{
"id": "focus_keywords",
"name": "focus_keywords",
"type": "string",
"value": "AI agents, ChatGPT, LLM, machine learning, research, tool, breakthrough"
},
{
"id": "exclude_keywords",
"name": "exclude_keywords",
"type": "string",
"value": "crypto, NFT, political, spam"
},
{
"id": "min_upvotes",
"name": "min_upvotes",
"type": "number",
"value": 10
}
]
}
},
"typeVersion": 3.4
},
{
"id": "ced0b421-1f5b-4b47-93f8-1e69bc13f7da",
"name": "Build Subreddit Array",
"type": "n8n-nodes-base.set",
"position": [
490,
125
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "subreddit_array",
"name": "subreddit_array",
"type": "array",
"value": "={{ $json.subreddits.split(',').map(s => s.trim()) }}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "0efa91cf-0173-4d52-9e79-cd7fe40ae9a5",
"name": "Iterate Subreddit Items",
"type": "n8n-nodes-base.set",
"position": [
225,
210
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "subreddit",
"name": "subreddit",
"type": "string",
"value": "={{ $json.subreddit_array[$itemIndex] }}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "75139925-31fb-4999-8ae3-da18c84fea16",
"name": "Retrieve Reddit Feed",
"type": "n8n-nodes-base.httpRequest",
"position": [
50,
145
],
"parameters": {
"url": "=https://www.reddit.com/r/{{ $json.subreddit }}/top.json?t={{ $('Settings Setup').first().json.time_filter }}&limit={{ $('Settings Setup').first().json.posts_per_subreddit }}",
"options": {
"timeout": 30000,
"response": {
"response": {
"responseFormat": "json"
}
}
},
"sendHeaders": true,
"authentication": "genericCredentialType",
"genericAuthType": "httpHeaderAuth",
"headerParameters": {
"parameters": [
{
"name": "User-Agent",
"value": "n8n-reddit-automation/1.0"
}
]
}
},
"credentials": {
"httpHeaderAuth": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 4.2
},
{
"id": "351cd99a-2e3a-4be1-92f1-c3a782fd0a2b",
"name": "Clean Post Records",
"type": "n8n-nodes-base.code",
"position": [
0,
400
],
"parameters": {
"jsCode": "// Extract and clean Reddit posts from JSON response\nconst data = $input.first().json.data;\nconst configData = $('Settings Setup').first().json;\nconst minUpvotes = configData.min_upvotes || 0;\nconst currentSubreddit = $json.subreddit;\n\nif (!data || !data.children) {\n  return [{ json: { posts: [], error: 'No data found' } }];\n}\n\nconst posts = [];\n\nfor (const child of data.children) {\n  const post = child.data;\n  \n  // Skip if below minimum upvotes\n  if (post.ups < minUpvotes) continue;\n  \n  // Skip stickied posts (usually subreddit rules/announcements)\n  if (post.stickied) continue;\n  \n  // Skip removed/deleted posts\n  if (post.removed_by_category || post.selftext === '[removed]' || post.selftext === '[deleted]') continue;\n  \n  // Build clean post object\n  const cleanPost = {\n    id: post.id,\n    subreddit: currentSubreddit,\n    title: post.title.replace(/[\\r\\n]+/g, ' ').trim(),\n    url: post.url.startsWith('http') ? post.url : `https://www.reddit.com${post.permalink}`,\n    permalink: `https://www.reddit.com${post.permalink}`,\n    author: post.author,\n    upvotes: post.ups,\n    num_comments: post.num_comments,\n    created_utc: post.created_utc,\n    created_date: new Date(post.created_utc * 1000).toISOString(),\n    selftext: post.selftext ? post.selftext.substring(0, 500) : '',\n    is_self: post.is_self,\n    domain: post.domain,\n    score: post.score,\n    flair_text: post.link_flair_text || ''\n  };\n  \n  posts.push(cleanPost);\n}\n\n// Sort by score (upvotes)\nposts.sort((a, b) => b.score - a.score);\n\nreturn [{ json: { posts, subreddit: currentSubreddit, total_posts: posts.length } }];\n"
},
"typeVersion": 2
},
{
"id": "c2733e06-c5f5-48e0-8135-656dd108423b",
"name": "Merge and Filter Posts",
"type": "n8n-nodes-base.code",
"position": [
305,
320
],
"parameters": {
"jsCode": "// Aggregate posts from all subreddits and apply smart filtering\nconst allItems = $input.all();\nconst configData = $('Settings Setup').first().json;\n\n// Collect all posts from all subreddits\nconst allPosts = [];\nfor (const item of allItems) {\n  if (item.json.posts && Array.isArray(item.json.posts)) {\n    allPosts.push(...item.json.posts);\n  }\n}\n\n// Deduplicate by post ID\nconst uniquePosts = [];\nconst seenIds = new Set();\n\nfor (const post of allPosts) {\n  if (!seenIds.has(post.id)) {\n    seenIds.add(post.id);\n    uniquePosts.push(post);\n  }\n}\n\n// Apply keyword filtering if configured\nconst focusKeywords = configData.focus_keywords ? \n  configData.focus_keywords.toLowerCase().split(',').map(k => k.trim()) : [];\nconst excludeKeywords = configData.exclude_keywords ? \n  configData.exclude_keywords.toLowerCase().split(',').map(k => k.trim()) : [];\n\nconst filteredPosts = uniquePosts.filter(post => {\n  const searchText = `${post.title} ${post.selftext} ${post.flair_text}`.toLowerCase();\n  \n  // Check exclude keywords first\n  if (excludeKeywords.length > 0) {\n    for (const keyword of excludeKeywords) {\n      if (searchText.includes(keyword)) {\n        return false; // Exclude this post\n      }\n    }\n  }\n  \n  // If focus keywords are set, post must contain at least one\n  if (focusKeywords.length > 0) {\n    let hasKeyword = false;\n    for (const keyword of focusKeywords) {\n      if (searchText.includes(keyword)) {\n        hasKeyword = true;\n        break;\n      }\n    }\n    return hasKeyword;\n  }\n  \n  return true; // No filters or passed all filters\n});\n\n// Sort by score\nfilteredPosts.sort((a, b) => b.score - a.score);\n\nreturn [{ \n  json: { \n    all_posts: filteredPosts,\n    total_subreddits: allItems.length,\n    total_posts_fetched: allPosts.length,\n    total_unique_posts: uniquePosts.length,\n    total_filtered_posts: filteredPosts.length,\n    config: configData\n  } \n}];\n"
},
"typeVersion": 2
},
{
"id": "7d167036-16e2-48cf-ace9-7b63b40dc69d",
"name": "AI Digest Curator",
"type": "@n8n/n8n-nodes-langchain.agent",
"position": [
490,
415
],
"parameters": {
"text": "=You are an expert content curator for Reddit news digests. Your job is to analyze, rank, and format Reddit posts into a high-quality digest.\n\n## Context\n- Digest Title: {{ $json.config.digest_title }}\n- Target Audience: Tech-savvy users interested in {{ $json.config.focus_keywords }}\n- Total Posts Available: {{ $json.total_filtered_posts }}\n- Posts Needed: {{ $json.config.total_posts_in_digest }}\n\n## Your Task\n1. Review all provided Reddit posts\n2. Rank them by:\n   - Relevance to focus keywords: {{ $json.config.focus_keywords }}\n   - Quality and credibility of content\n   - Engagement (upvotes, comments)\n   - Uniqueness and value\n   - Recency and timeliness\n\n3. Select the TOP {{ $json.config.total_posts_in_digest }} most valuable posts\n\n4. Format them into a beautiful, scannable digest with this structure:\n\n```\n{{ $json.config.digest_title }}\n\ud83d\udcc5 {{ $now.format('MMMM DD, YYYY') }}\n\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\n\n[For each post, use this format:]\n\n1\ufe0f\u20e3 **[Post Title]**\n   \ud83d\udccd r/[subreddit] \u2022 \ud83d\udc4d [upvotes] \u2022 \ud83d\udcac [comments]\n   \n   [Write 1-2 sentences explaining why this post is valuable and what the key insight is]\n   \n   \ud83d\udd17 [Reddit URL]\n\n2\ufe0f\u20e3 **[Next Post Title]**\n   ...\n\n\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\n\ud83d\udca1 Curated by AI \u2022 {{ $json.total_filtered_posts }} posts analyzed\n```\n\n## Guidelines\n- Be concise but informative\n- Use emojis sparingly for visual hierarchy\n- Focus on WHY each post matters\n- Avoid jargon; explain technical terms\n- Keep summaries actionable\n- Number posts 1\ufe0f\u20e3 through \ud83d\udd1f\n\n## Reddit Posts Data\n{{ JSON.stringify($json.all_posts, null, 2) }}\n\n## Output\nProvide ONLY the formatted digest text, ready to send. No meta-commentary.",
"options": {
"systemMessage": "You are a professional content curator. You create concise, valuable, and engaging content digests. You understand what makes content worth reading and can identify signal from noise."
},
"promptType": "define",
"hasOutputParser": true
},
"typeVersion": 1.7
},
{
"id": "5610b7d3-4489-4314-8d57-40ac7a907c85",
"name": "Gemini Chat Model",
"type": "@n8n/n8n-nodes-langchain.lmChatGoogleGemini",
"position": [
525,
565
],
"parameters": {
"options": []
},
"typeVersion": 1
},
{
"id": "0e8207b0-4330-4e03-a155-fea83a88e8cd",
"name": "Format Digest Output",
"type": "n8n-nodes-base.code",
"position": [
775,
335
],
"parameters": {
"jsCode": "// Extract formatted output from AI response\nconst aiResponse = $input.first().json;\n\n// The AI agent returns output in different formats depending on the response\nlet formattedOutput = '';\n\nif (aiResponse.output) {\n  formattedOutput = aiResponse.output;\n} else if (aiResponse.text) {\n  formattedOutput = aiResponse.text;\n} else if (typeof aiResponse === 'string') {\n  formattedOutput = aiResponse;\n} else {\n  // Fallback: convert entire response to string\n  formattedOutput = JSON.stringify(aiResponse, null, 2);\n}\n\n// Clean up any extra whitespace\nformattedOutput = formattedOutput.trim();\n\nreturn [{ \n  json: { \n    formatted_output: formattedOutput,\n    timestamp: new Date().toISOString(),\n    digest_title: $('Settings Setup').first().json.digest_title\n  } \n}];\n"
},
"typeVersion": 2
},
{
"id": "fd16865d-a1f5-4085-89c8-e1193531bfcf",
"name": "Validate Digest Text",
"type": "n8n-nodes-base.if",
"position": [
950,
405
],
"parameters": {
"options": [],
"conditions": {
"options": {
"leftValue": "",
"caseSensitive": false
},
"combinator": "and",
"conditions": [
{
"id": "check-output",
"operator": {
"type": "string",
"operation": "notEmpty"
},
"leftValue": "={{ $json.formatted_output }}",
"rightValue": ""
}
]
}
},
"typeVersion": 2.1
},
{
"id": "ff981252-16c1-4307-810d-048106cb751e",
"name": "Post to Telegram",
"type": "n8n-nodes-base.telegram",
"position": [
960,
605
],
"webhookId": "503f1790-45aa-4f10-9565-63e0025a4ca7",
"parameters": {
"text": "={{ $json.formatted_output }}",
"chatId": "={{ $('Settings Setup').first().json.telegram_chat_id || '[YOUR_ID]' }}",
"additionalFields": {
"parse_mode": "Markdown"
}
},
"typeVersion": 1.2
},
{
"id": "5cc13e05-a01b-4bb5-b0d1-ed8e935c59f4",
"name": "Dispatch to Discord",
"type": "n8n-nodes-base.discord",
"position": [
790,
555
],
"webhookId": "f2cac624-a133-4201-a7eb-39328def4185",
"parameters": {
"content": "={{ $json.formatted_output }}",
"options": [],
"authentication": "webhook"
},
"typeVersion": 2
},
{
"id": "20df81d2-629c-46ce-b367-b1a21d32fc98",
"name": "Send Slack Update",
"type": "n8n-nodes-base.slack",
"position": [
550,
620
],
"webhookId": "088380b0-220c-4bfc-9287-b6ab72b62840",
"parameters": {
"text": "={{ $json.formatted_output }}",
"select": "channel",
"channelId": {
"__rl": true,
"mode": "list",
"value": "[YOUR_ID]"
},
"otherOptions": []
},
"typeVersion": 2.2
}
],
"active": false,
"pinData": [],
"settings": {
"executionOrder": "v1"
},
"versionId": null,
"connections": {
"Validate Digest Text": {
"main": [
[
{
"node": "Post to Telegram",
"type": "main",
"index": 0
},
{
"node": "Dispatch to Discord",
"type": "main",
"index": 0
},
{
"node": "Send Slack Update",
"type": "main",
"index": 0
}
]
]
},
"Settings Setup": {
"main": [
[
{
"node": "Build Subreddit Array",
"type": "main",
"index": 0
}
]
]
},
"Gemini Chat Model": {
"ai_languageModel": [
[
{
"node": "AI Digest Curator",
"type": "ai_languageModel",
"index": 0
}
]
]
},
"AI Digest Curator": {
"main": [
[
{
"node": "Format Digest Output",
"type": "main",
"index": 0
}
]
]
},
"Clean Post Records": {
"main": [
[
{
"node": "Merge and Filter Posts",
"type": "main",
"index": 0
}
]
]
},
"Build Subreddit Array": {
"main": [
[
{
"node": "Iterate Subreddit Items",
"type": "main",
"index": 0
}
]
]
},
"Merge and Filter Posts": {
"main": [
[
{
"node": "AI Digest Curator",
"type": "main",
"index": 0
}
]
]
},
"Iterate Subreddit Items": {
"main": [
[
{
"node": "Retrieve Reddit Feed",
"type": "main",
"index": 0
}
]
]
},
"Retrieve Reddit Feed": {
"main": [
[
{
"node": "Clean Post Records",
"type": "main",
"index": 0
}
]
]
},
"Scheduled Digest Trigger": {
"main": [
[
{
"node": "Settings Setup",
"type": "main",
"index": 0
}
]
]
},
"Format Digest Output": {
"main": [
[
{
"node": "Validate Digest Text",
"type": "main",
"index": 0
}
]
]
}
}
}