January 22, 2026

Reddit to Notion, organized insights you can act on

Lisa Granqvist Partner Workflow Automation Expert

Get a free AI assessment → ⬇️ Use template

Reddit is amazing for raw market insight. It’s also a time sink that quietly wrecks your research process because everything ends up scattered in tabs, screenshots, and half-finished notes.

If you’re a marketer hunting for positioning angles, a founder trying to validate demand, or a consultant doing competitive intel, this Reddit Notion automation turns daily Reddit scanning into a clean, searchable database with scores, summaries, and even draft replies.

You’ll see exactly how the workflow finds posts, evaluates them with AI, saves them to Notion, and optionally emails you a digest so you never have to “keep up” manually again.

How This Automation Works

Here’s the complete workflow you’ll be setting up:

n8n Workflow Template: Reddit to Notion, organized insights you can act on

Click to explore

flowchart LR

    subgraph sg0["Schedule Flow"]
        direction LR
        n0@{ icon: "mdi:message-outline", form: "rounded", label: "Send a message", pos: "b", h: 48 }
        n1@{ icon: "mdi:swap-vertical", form: "rounded", label: "Define Keywords And Subreddits", pos: "b", h: 48 }
        n2@{ icon: "mdi:swap-vertical", form: "rounded", label: "Define Relevance Criteria", pos: "b", h: 48 }
        n3@{ icon: "mdi:swap-vertical", form: "rounded", label: "Define Instructions For Gene..", pos: "b", h: 48 }
        n4@{ icon: "mdi:play-circle", form: "rounded", label: "Schedule Trigger", pos: "b", h: 48 }
        n5@{ icon: "mdi:swap-vertical", form: "rounded", label: "Split Out Keywords", pos: "b", h: 48 }
        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/httprequest.dark.svg' width='40' height='40' /></div><br/>Search Reddit"]
        n7["<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/>Generate HTML Email"]
        n8["<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/>Combine Posts Into A Single .."]
        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/>Add Relevance Score And Comm.."]
        n10["<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/notion.dark.svg' width='40' height='40' /></div><br/>Add Each Post to Notion Data.."]
        n11@{ icon: "mdi:swap-horizontal", form: "rounded", label: "Filter Reddit Items With No ..", pos: "b", h: 48 }
        n12@{ icon: "mdi:cog", form: "rounded", label: "Aggregate Reddit Items", pos: "b", h: 48 }
        n13@{ icon: "mdi:swap-vertical", form: "rounded", label: "Split Out Posts", pos: "b", h: 48 }
        n14@{ icon: "mdi:cog", form: "rounded", label: "Aggregate Posts", pos: "b", h: 48 }
        n15@{ icon: "mdi:swap-vertical", form: "rounded", label: "Split Out Posts Into Items", pos: "b", h: 48 }
        n16@{ icon: "mdi:robot", form: "rounded", label: "Analyze Each Post", pos: "b", h: 48 }
        n6 --> n11
        n14 --> n7
        n14 --> n15
        n13 --> n16
        n4 --> n1
        n16 --> n9
        n5 --> n2
        n7 --> n0
        n12 --> n8
        n2 --> n3
        n15 --> n10
        n1 --> n5
        n8 --> n13
        n11 --> n12
        n3 --> n6
        n9 --> n14
    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 n4 trigger
    class n16 ai
    class n11 decision
    class n10 database
    class n6 api
    class n7,n8,n9 code
    classDef customIcon fill:none,stroke:none
    class n6,n7,n8,n9,n10 customIcon

Why This Matters: Reddit research gets messy fast

Manual Reddit monitoring usually starts with good intentions: you check a few subreddits, save a couple links, maybe paste quotes into a doc. Then real work happens. You miss posts for a week, come back, and can’t remember why you saved anything. Even worse, your team can’t reuse the research because it lives in one person’s browser history. The cost isn’t just time. It’s the inconsistent process, the lost context, and the fact that insights don’t compound over time because nothing is stored in a usable way.

It adds up fast.

Searching the same keywords repeatedly burns about 30 minutes a day, and you still miss the best threads because timing matters.
Saved posts don’t turn into decisions because there’s no relevance score or consistent summary to compare apples to apples.
Teams duplicate work since nobody knows what was already reviewed, which keywords were used, or what “good” looks like.
Reply ideas get written in the moment, then disappear, so engagement becomes sporadic instead of a repeatable playbook.

What You’ll Build: daily Reddit monitoring to a Notion insight hub

This workflow runs on a daily schedule and searches Reddit for posts that match the keywords you define. It can focus on specific subreddits or scan broadly, depending on how wide you want to cast the net. For each post it finds, it sends the content through an AI evaluation step (using GPT-5-Mini via the OpenAI Chat Model), which produces a relevance score and a structured summary you can actually act on. It also generates a suggested comment draft, guided by your own rules, so you’re not starting from a blank page. Finally, everything gets recorded into your Notion database, and if you want, the workflow builds a clean HTML digest and emails it to you through Gmail.

The workflow starts with your keyword and community settings, then queries Reddit through an HTTP request. Next, AI grades each post and adds notes. At the end, Notion becomes your single source of truth, with an optional Gmail summary so you can skim the highlights in minutes.

What You’re Building

What Gets Automated

What You’ll Achieve

Daily Reddit searches for your chosen keywords and subreddits.
Filtering and batching results so you only process real matches.
AI-based scoring, summarizing, and drafting suggested comments using your guidance.
Saving each post and its structured insight fields into Notion, plus an optional Gmail digest.

Cut a typical “morning Reddit scan” from about 30 minutes to a 5-minute review.
Get consistent relevance scoring so you can prioritize the right conversations.
Keep research centralized in Notion, which makes collaboration and handoffs painless.
Build a growing library of audience language, objections, and intent signals.
Move faster on engagement with ready-to-edit reply drafts tied to each post.

Expected Results

Say you track 10 keywords across 5 subreddits. Manually, you might spend about 3 minutes per keyword per subreddit to search, open posts, and decide what matters, which is roughly 2.5 hours for one full sweep. With this workflow, you spend maybe 10 minutes setting keywords and guidance once, then your daily routine becomes a quick skim: about 5 minutes reading the Gmail digest (or scanning Notion) while the AI handles scoring and summaries in the background. That’s about 2 hours back on days you would have done a deeper scan.

Before You Start

n8n instance (try n8n Cloud free)
Self-hosting option if you prefer (Hostinger works well)
Notion for storing posts, scores, and summaries
OpenAI to score posts and draft replies
OpenAI API key (get it from your OpenAI dashboard)

Skill level: Beginner. You will mostly paste credentials, edit a few text fields, and test one run.

Want someone to build this for you? Talk to an automation expert (free 15-minute consultation).

Step by Step

A daily schedule kicks things off. The workflow starts once per day using a Scheduled Automation Start trigger, so it runs in the background without you remembering to check anything.

Your search inputs get prepared. n8n loads the keywords and the communities you care about (subreddits or “all of Reddit”), then iterates through the list so each keyword gets queried consistently.

Reddit is queried and results are cleaned up. An HTTP Request searches the Reddit API, then empty responses are filtered out. From there, posts are aggregated and merged so the rest of the workflow has one tidy stream of items to work with.

AI evaluates each post. The OpenAI Chat Model step (GPT-5-Mini) produces a relevance score, a structured summary, and a suggested comment based on your relevance rules and comment guidance.

Insights get stored and optionally emailed. Each post is recorded in your Notion database, and if you enable notifications, the workflow builds an HTML summary and sends it via Gmail as a daily digest.

You can easily modify your keyword list to focus on one product line, one competitor, or one persona based on your needs. See the full implementation guide below for customization options.

Step-by-Step Implementation Guide

Step 1: Configure the Scheduled Automation Start

Set up the workflow trigger so your Reddit monitoring runs on a schedule.

Add the Scheduled Automation Start node and open its settings.
Configure the schedule under Rule to match your monitoring cadence (the workflow uses the default interval placeholder).
Connect Scheduled Automation Start to Set Keywords & Communities.

Step 2: Connect Reddit Search Inputs

Define keywords and subreddit scope, then iterate through each keyword for Reddit searches.

Open Set Keywords & Communities and set Mode to raw.
Paste the JSON in JSON Output exactly as shown: { "keywords": ["competitor","intelligence"], "search_all_subs": false, "subreddits": ["saas","solopreneur","b2bsaas","indiehackers"] }.
In Iterate Keyword List, set Field to Split Out to keywords.
Connect Set Keywords & Communities → Iterate Keyword List → Set Relevance Rules → Set Comment Guidance → Query Reddit API.

Step 3: Configure Reddit API Query and Filtering

Use the Reddit API endpoint and filter empty results before aggregation.

Open Query Reddit API and set URL to ={{ $("Set Keywords & Communities").item.json.search_all_subs ? "https://www.reddit.com/search.json" : "https://www.reddit.com/r/" + $("Set Keywords & Communities").item.json.subreddits.join("+") + "/search.json" }}.
Enable Send Query and add parameters: q = ={{ $('Iterate Keyword List').item.json.keywords }}, restrict_sr = on, sort = new, t = day.
In Filter Empty Reddit Results, keep the condition ={{ $json.data.dist }} not equals 0.
Connect Query Reddit API → Filter Empty Reddit Results → Aggregate Reddit Results → Merge Post Arrays → Expand Posts List.

Step 4: Set Up AI Relevance Scoring and Notes

Score each post and generate comments using AI, then aggregate enriched items.

In Set Relevance Rules, set RELEVANCE_CRITERIA to Discussions should be related to competitive intelligence..
In Set Comment Guidance, set COMMENT_INSTRUCTIONS to Acknowledge the challenges users face and offer clear, helpful solutions. Generate a brief comment and don't use em dash or hyphens..
Open Evaluate Post with AI and confirm JSON Output is enabled.
Credential Required: Connect your openAiApi credentials in Evaluate Post with AI.
Connect Expand Posts List → Evaluate Post with AI → Append AI Scores & Notes → Collect Posts Batch.

Collect Posts Batch outputs to both Build HTML Summary and Explode Posts to Items in parallel.

Step 5: Configure Output Destinations

Create the email summary and log each post in Notion.

In Build HTML Summary, keep the existing JavaScript to generate htmlEmail for the email body.
Open Dispatch Email Alert and set Send To to [YOUR_EMAIL], Subject to New Reddit Discussions Found, and Message to ={{ $json.htmlEmail }}.
Credential Required: Connect your gmailOAuth2 credentials in Dispatch Email Alert.
In Record Posts in Notion, set Resource to databasePage, Title to ={{ $json.data.title }}, and select your target database.
Credential Required: Connect your notionApi credentials in Record Posts in Notion.
Confirm the properties map to the expressions shown, including ={{ ($json.data.selftext || '').slice(0, 2000) }}, ={{ $json.relevanceScore }}, and ={{ `https://www.reddit.com${$json.data.permalink}` }}.

⚠️ Common Pitfall: If your Notion database property names don’t match the keys in Record Posts in Notion (e.g., Relevance Score or Generated Comment), records will fail to write.

Step 6: Test and Activate Your Workflow

Validate the flow end-to-end before enabling scheduled runs.

Click Execute Workflow to run a manual test from Scheduled Automation Start.
Confirm Evaluate Post with AI returns JSON with relevance_score and comment, and that Append AI Scores & Notes adds these fields to each post.
Verify Dispatch Email Alert sends an email containing the HTML summary and Record Posts in Notion creates new database entries.
When successful, switch the workflow to Active to begin scheduled monitoring.

🔒

Unlock Full Step-by-Step Guide

Get the complete implementation guide + downloadable template

Troubleshooting Tips

Notion credentials can expire or lack page/database access. If things break, check the integration is shared with the target database and the secret is still valid.
If you’re using Wait nodes or relying on Reddit responses during peak hours, processing times vary. Bump up the wait duration if downstream steps fail because they received empty or incomplete data.
OpenAI prompts are often too generic at first. Add your scoring rules and your brand voice early, otherwise you will waste time rewriting “fine” summaries and awkward comment drafts.

Quick Answers

What’s the setup time for this Reddit Notion automation?

About 30 minutes if your Notion database is ready.

Is coding required for this Reddit Notion automation?

No. You’ll connect accounts, paste an API key, and edit your keywords and prompts.

Is n8n free to use for this Reddit Notion automation 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 OpenAI API costs, which are usually only a few dollars a month at low volume.

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 modify this Reddit Notion automation workflow for different use cases?

Yes, and you should. Most people customize the “Set Keywords & Communities” node, then tweak “Set Relevance Rules” and “Set Comment Guidance” so the AI scores posts the way your team actually thinks. Common changes include adding competitor names, prioritizing “buying intent” phrases, and generating comments that fit your tone (helpful, contrarian, short, or detailed).

Why is my Notion connection failing in this workflow?

Usually it’s permission-related. Make sure the Notion integration is shared with the exact database you’re writing into, then double-check the integration secret in the Notion credentials inside n8n. If the database was duplicated or moved, the database ID can change, so the workflow may be pointing at the wrong place. Also watch for property mismatches: if your Notion table columns were renamed, the “Record Posts in Notion” step may fail until you remap fields.

What volume can this Reddit Notion automation workflow process?

On most setups, dozens to a few hundred posts per day is realistic, and self-hosting removes execution caps so your server becomes the main limit.

Is this Reddit Notion automation better than using Zapier or Make?

Often, yes, if you want richer logic. This workflow does batching, filtering, per-item AI evaluation, and then two different outputs (Notion plus an HTML email), and that kind of “branchy” flow can get expensive or awkward in Zapier. n8n also gives you a self-hosted option, which is useful when you want to run daily research without thinking about task limits. That said, Zapier or Make can be quicker for simple two-step alerts. If you want a recommendation based on your volume and tools, Talk to an automation expert.

Once this is running, your Reddit research stops being a daily chore and starts acting like an asset you can search, reuse, and build on. Honestly, it’s a relief.

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": "7ace5680044837a4c72076157e416f01cfa5a0c434b7a2ce0b00183ee12edf79",
"templateId": null,
"templateCredsSetupCompleted": null
},
"name": "Automated Reddit Insight Monitoring Flow",
"tags": [],
"nodes": [
{
"id": "flowpast-topbar-10877",
"name": "Flowpast Branding",
"type": "n8n-nodes-base.stickyNote",
"position": [
0,
20
],
"parameters": {
"color": 7,
"width": 1900,
"height": 80,
"content": "## Flowpast.com | Automation Workflow Library\n**\ud83d\udcd6 Full tutorial & setup guide:** flowpast.com"
},
"typeVersion": 1
},
{
"id": "ac7d73be-7fdb-4451-a29e-7f41f7d60cfe",
"name": "Dispatch Email Alert",
"type": "n8n-nodes-base.gmail",
"position": [
920,
795
],
"webhookId": "79db7ca5-4ca6-4148-aaea-09fff0751663",
"parameters": {
"sendTo": "[YOUR_EMAIL]",
"message": "={{ $json.htmlEmail }}",
"options": [],
"subject": "New Reddit Discussions Found"
},
"credentials": {
"gmailOAuth2": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 2.1
},
{
"id": "d5907ad8-26a5-47ca-8a67-529fef1da906",
"name": "Set Keywords & Communities",
"type": "n8n-nodes-base.set",
"position": [
1290,
135
],
"parameters": {
"mode": "raw",
"options": [],
"jsonOutput": "{\n  \"keywords\": [\n    \"competitor\",\n    \"intelligence\"\n  ],\n  \"search_all_subs\": false,\n  \"subreddits\": \n  [\n    \"saas\", \n    \"solopreneur\", \n    \"b2bsaas\", \n    \"indiehackers\"\n  ]\n}\n"
},
"typeVersion": 3.4
},
{
"id": "6448edd0-f5ba-438c-911b-d6bd3c1dae4f",
"name": "Set Relevance Rules",
"type": "n8n-nodes-base.set",
"position": [
400,
150
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "ada8880a-aacc-43b3-b309-0a2489c588df",
"name": "RELEVANCE_CRITERIA",
"type": "string",
"value": "Discussions should be related to competitive intelligence."
}
]
}
},
"typeVersion": 3.4
},
{
"id": "de0320b0-ce93-4b53-a3f0-94599cffbfb9",
"name": "Set Comment Guidance",
"type": "n8n-nodes-base.set",
"position": [
0,
335
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "933d9c72-1296-45bf-a453-ae4a27c398e4",
"name": "COMMENT_INSTRUCTIONS",
"type": "string",
"value": "Acknowledge the challenges users face and offer clear, helpful solutions. Generate a brief comment and don't use em dash or hyphens."
}
]
}
},
"typeVersion": 3.4
},
{
"id": "2aa8950e-1857-4216-9817-17e523fe7d4e",
"name": "Scheduled Automation Start",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
1810,
120
],
"parameters": {
"rule": {
"interval": [
[]
]
}
},
"typeVersion": 1.2
},
{
"id": "fafe3021-78a0-4599-86ad-e0b33f213ef6",
"name": "Iterate Keyword List",
"type": "n8n-nodes-base.splitOut",
"position": [
905,
160
],
"parameters": {
"options": [],
"fieldToSplitOut": "keywords"
},
"typeVersion": 1
},
{
"id": "4ebf2b56-4480-4579-af2e-d72c5f0c1efa",
"name": "Query Reddit API",
"type": "n8n-nodes-base.httpRequest",
"position": [
465,
375
],
"parameters": {
"url": "={{ $(\"Set Keywords & Communities\").item.json.search_all_subs\n\t? \"https://www.reddit.com/search.json\"\n\t: \"https://www.reddit.com/r/\" + $(\"Set Keywords & Communities\").item.json.subreddits.join(\"+\") + \"/search.json\"\n}}",
"options": [],
"sendQuery": true,
"queryParameters": {
"parameters": [
{
"name": "q",
"value": "={{ $('Iterate Keyword List').item.json.keywords }}"
},
{
"name": "restrict_sr",
"value": "on"
},
{
"name": "sort",
"value": "new"
},
{
"name": "t",
"value": "day"
}
]
}
},
"typeVersion": 4.2
},
{
"id": "c07aea1c-fdec-4c3c-a44d-50081b60326e",
"name": "Build HTML Summary",
"type": "n8n-nodes-base.code",
"position": [
405,
800
],
"parameters": {
"jsCode": "const keywords = $('Set Keywords & Communities').first().json.keywords.map(k => k.toLowerCase());\nconst subreddits = $('Set Keywords & Communities').first().json.subreddits;\nconst searchAllSubs = $('Set Keywords & Communities').first().json.search_all_subs;\nconst posts = $input.first().json.posts;\n\n// Convert subreddit list or show \"All Subreddits\"\nconst subList = searchAllSubs\n  ? 'All subreddits on Reddit'\n  : subreddits.map(s => `r/${s}`).join(', ');\n\n// Helper: highlight all keywords in a text\nfunction highlightAll(text, keywords) {\n  let result = text;\n  keywords.forEach(k => {\n    const re = new RegExp(`(${k})`, 'gi');\n    result = result.replace(re, '<span style=\"background-color:#ffeb3b; color:#111; font-weight:600;\">$1</span>');\n  });\n  return result;\n}\n\n// Helper: find first keyword occurrence and extract snippet\nfunction snippetAroundKeywords(text, keywords, radius = 120) {\n  const lower = text.toLowerCase();\n  let firstIndex = -1;\n  let matchedKeyword = null;\n\n  for (const k of keywords) {\n    const i = lower.indexOf(k);\n    if (i !== -1 && (firstIndex === -1 || i < firstIndex)) {\n      firstIndex = i;\n      matchedKeyword = k;\n    }\n  }\n\n  if (firstIndex === -1) return null;\n\n  const start = Math.max(0, firstIndex - radius);\n  const end = Math.min(text.length, firstIndex + matchedKeyword.length + radius);\n\n  let snippet = text.substring(start, end);\n  return highlightAll(snippet, keywords) + (end < text.length ? '...' : '');\n}\n\n// Start modern container\nlet htmlContent = `\n<div style=\"font-family: Inter, -apple-system, BlinkMacSystemFont, Segoe UI, Roboto, Helvetica, Arial; \n            max-width: 680px; margin: 0 auto; padding: 32px; \n            background-color: #f5f7fa; color: #2b2b2b;\">\n\n  <div style=\"text-align: center; margin-bottom: 28px;\">\n    <h2 style=\"font-size: 26px; font-weight: 700; color: #111; margin-bottom: 6px;\">\n      New Reddit Discussions Identified\n    </h2>\n    <div style=\"font-size: 15px; color: #444; margin-bottom: 4px;\">\n      Keywords tracked: <span style=\"font-weight: 600; color: #0066ff;\">${keywords.join(', ')}</span>\n    </div>\n    <div style=\"font-size: 13px; color: #666;\">\n      Checked across: <span style=\"color: #222;\">${subList}</span>\n    </div>\n  </div>\n`;\n\nposts.forEach(post => {\n  const data = post.data;\n  const relevance = post.relevanceScore;\n  const aiComment = post.generatedComment;\n\n  // Highlight keywords in title\n  let title = data.title;\n  const titleLower = title.toLowerCase();\n  keywords.forEach(k => {\n    if (titleLower.includes(k)) {\n      const re = new RegExp(`(${k})`, 'gi');\n      title = title.replace(re, '<span style=\"color:#ff5722; font-weight:700;\">$1</span>');\n    }\n  });\n\n  // Extract snippet from selftext\n  let snippet = '';\n  if (data.selftext) {\n    const extracted = snippetAroundKeywords(data.selftext, keywords);\n    snippet = extracted || data.selftext.substring(0, 180) + '...';\n  }\n\n  htmlContent += `\n    <div style=\"background-color: #ffffff; padding: 22px; margin-bottom: 22px;\n                border-radius: 14px; border: 1px solid #e4e7ec;\n                box-shadow: 0 3px 10px rgba(0,0,0,0.05);\">\n\n      <div style=\"font-size: 13px; color: #666; margin-bottom: 10px;\">\n        <span style=\"color: #ff4500; font-weight: 600;\">${data.subreddit_name_prefixed}</span>\n        \u2022 u/${data.author}\n      </div>\n\n      <a href=\"https://www.reddit.com${data.permalink}\" target=\"_blank\"\n        style=\"font-size: 18px; font-weight: 700; color: #1a73e8; line-height: 1.4; text-decoration: none;\">\n        ${title}\n      </a>\n\n      ${\n        snippet\n          ? `<p style=\"font-size: 14px; margin-top: 14px; line-height: 1.6; color:#333;\">\n               ${snippet}\n             </p>`\n          : ''\n      }\n\n      <div style=\"margin-top: 12px; font-size: 13px; color: #444;\">\n        Relevance score: <strong>${relevance}/10</strong>\n      </div>\n\n      ${\n        aiComment\n          ? `<div style=\"margin-top: 10px; padding: 12px; background: #f0f4ff; border-radius: 10px; font-size: 13px; line-height: 1.5; color: #333;\">\n               <strong>AI Generated Comment:</strong><br>${aiComment}\n             </div>`\n          : ''\n      }\n\n      <div style=\"margin-top: 16px; font-size: 12px; color: #777; padding-top: 10px; border-top: 1px solid #eee;\">\n        \ud83d\udc4d ${data.ups} \u2022 \ud83d\udcac ${data.num_comments} comments\n      </div>\n    </div>\n  `;\n});\n\nhtmlContent += `</div>`;\n\nreturn [\n  {\n    json: {\n      htmlEmail: htmlContent\n    },\n    pairedItem: 0\n  }\n];\n"
},
"typeVersion": 2
},
{
"id": "a4c3c234-1547-441e-a433-9881f1f41b0f",
"name": "Merge Post Arrays",
"type": "n8n-nodes-base.code",
"position": [
1760,
595
],
"parameters": {
"jsCode": "\n// Get the children array from the first input item\nconst children = $input.first().json.children;\n\n// Flatten all child arrays into a single array\nconst combinedPosts = children.flat();\n\n// Return combined posts in a single array\nreturn [{\n  json: {\n    posts: combinedPosts\n  },\n  pairedItem: 0\n}];"
},
"typeVersion": 2
},
{
"id": "0fdb3415-37db-4b57-8179-f674ddb9d90c",
"name": "Append AI Scores & Notes",
"type": "n8n-nodes-base.code",
"position": [
465,
595
],
"parameters": {
"jsCode": "const openAIMessages = $input.all();\nconst posts = $('Expand Posts List').all();\n\nreturn openAIMessages.map((msg, i) => ({\n  json: {\n    ...posts[i].json,\n    relevanceScore: msg.json.message.content.relevance_score,\n    generatedComment: msg.json.message.content.comment\n  },\n  pairedItem: i\n}));"
},
"typeVersion": 2
},
{
"id": "b6bf431b-c178-4b84-85fb-a5b79193f3d5",
"name": "Record Posts in Notion",
"type": "n8n-nodes-base.notion",
"position": [
1800,
800
],
"parameters": {
"title": "={{ $json.data.title }}",
"options": [],
"resource": "databasePage",
"databaseId": {
"__rl": true,
"mode": "list",
"value": "[YOUR_ID]",
"cachedResultUrl": "",
"cachedResultName": "Reddit Automation"
},
"propertiesUi": {
"propertyValues": [
{
"key": "Body|rich_text",
"textContent": "={{ ($json.data.selftext || '').slice(0, 2000) }}"
},
{
"key": "Relevance Score|number",
"numberValue": "={{ $json.relevanceScore }}"
},
{
"key": "Generated Comment|rich_text",
"textContent": "={{ $json.generatedComment }}"
},
{
"key": "Subreddit|select",
"selectValue": "={{ $json.data.subreddit }}"
},
{
"key": "Upvote Ratio|number",
"numberValue": "={{ $json.data.upvote_ratio }}"
},
{
"key": "Upvotes|number",
"numberValue": "={{ $json.data.ups }}"
},
{
"key": "Down Votes|number",
"numberValue": "={{ $json.data.downs }}"
},
{
"key": "Created At|date",
"date": "={{ new Date($json.data.created * 1000).toISOString() }}"
},
{
"key": "Post ID|rich_text",
"textContent": "={{ $json.data.id }}"
},
{
"key": "Author|rich_text",
"textContent": "={{ $json.data.author }}"
},
{
"key": "Link|url",
"urlValue": "={{ `https://www.reddit.com${$json.data.permalink}` }}"
}
]
}
},
"credentials": {
"notionApi": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 2.2
},
{
"id": "06869200-6a5f-470d-b141-a8c8b65944ab",
"name": "Filter Empty Reddit Results",
"type": "n8n-nodes-base.filter",
"position": [
855,
370
],
"parameters": {
"options": [],
"conditions": {
"options": {
"version": 2,
"leftValue": "",
"caseSensitive": true,
"typeValidation": "strict"
},
"combinator": "and",
"conditions": [
{
"id": "0da1a4b0-47ea-429b-92fc-28562eec5ec4",
"operator": {
"type": "number",
"operation": "notEquals"
},
"leftValue": "={{ $json.data.dist }}",
"rightValue": 0
}
]
}
},
"typeVersion": 2.2
},
{
"id": "70a03e4c-39c7-41b3-bd9d-eb2ecce6ff95",
"name": "Aggregate Reddit Results",
"type": "n8n-nodes-base.aggregate",
"position": [
1360,
350
],
"parameters": {
"options": [],
"fieldsToAggregate": {
"fieldToAggregate": [
{
"fieldToAggregate": "data.children"
}
]
}
},
"typeVersion": 1
},
{
"id": "8b38ccbe-71eb-443a-8647-5ead7884e8d4",
"name": "Expand Posts List",
"type": "n8n-nodes-base.splitOut",
"position": [
1350,
575
],
"parameters": {
"options": [],
"fieldToSplitOut": "posts"
},
"typeVersion": 1
},
{
"id": "f9ff8d99-95d1-42e3-999f-24c139997428",
"name": "Collect Posts Batch",
"type": "n8n-nodes-base.aggregate",
"position": [
10,
810
],
"parameters": {
"options": [],
"aggregate": "aggregateAllItemData",
"destinationFieldName": "posts"
},
"typeVersion": 1
},
{
"id": "ad631fbe-3668-46e5-b0e0-39f387af73a5",
"name": "Explode Posts to Items",
"type": "n8n-nodes-base.splitOut",
"position": [
1295,
825
],
"parameters": {
"options": [],
"fieldToSplitOut": "posts"
},
"typeVersion": 1
},
{
"id": "039c6035-b7fb-4639-a6d5-49261a53f028",
"name": "Evaluate Post with AI",
"type": "@n8n/n8n-nodes-langchain.openAi",
"position": [
840,
565
],
"parameters": {
"modelId": {
"__rl": true,
"mode": "list",
"value": "gpt-5-mini",
"cachedResultName": "GPT-5-MINI"
},
"options": [],
"messages": {
"values": [
{
"content": "=Analyze the following Reddit post and provide a relevance assessment and comment strictly in JSON format. Do not include any extra text outside the JSON. \n\nUse the provided Relevance Criteria to determine how relevant the post is to the topic and assign a relevance score from 1 (low) to 10 (high). \n\nThen, using the provided Comments Instructions, generate an appropriate comment for the post.\n\nOutput format:\n\n{\n  \"reasoning\": \"brief explanation of why this post is relevant or not according to the criteria\",\n  \"relevance_score\": <number from 1 to 10>,\n  \"comment\": \"comment generated based on the instructions\"\n}\n\nInputs:\n\nRelevance Criteria: {{ $('Set Relevance Rules').first().json.RELEVANCE_CRITERIA }}\n\nComments Instructions: {{ $('Set Comment Guidance').first().json.COMMENT_INSTRUCTIONS }}\n\nPost Title: {{ $json.data.title }}\n\nPost Body: {{ $json.data.selftext }}\n"
}
]
},
"jsonOutput": true
},
"credentials": {
"openAiApi": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1.8
}
],
"active": false,
"pinData": [],
"settings": {
"executionOrder": "v1"
},
"versionId": null,
"connections": {
"Query Reddit API": {
"main": [
[
{
"node": "Filter Empty Reddit Results",
"type": "main",
"index": 0
}
]
]
},
"Collect Posts Batch": {
"main": [
[
{
"node": "Build HTML Summary",
"type": "main",
"index": 0
},
{
"node": "Explode Posts to Items",
"type": "main",
"index": 0
}
]
]
},
"Expand Posts List": {
"main": [
[
{
"node": "Evaluate Post with AI",
"type": "main",
"index": 0
}
]
]
},
"Scheduled Automation Start": {
"main": [
[
{
"node": "Set Keywords & Communities",
"type": "main",
"index": 0
}
]
]
},
"Evaluate Post with AI": {
"main": [
[
{
"node": "Append AI Scores & Notes",
"type": "main",
"index": 0
}
]
]
},
"Iterate Keyword List": {
"main": [
[
{
"node": "Set Relevance Rules",
"type": "main",
"index": 0
}
]
]
},
"Build HTML Summary": {
"main": [
[
{
"node": "Dispatch Email Alert",
"type": "main",
"index": 0
}
]
]
},
"Aggregate Reddit Results": {
"main": [
[
{
"node": "Merge Post Arrays",
"type": "main",
"index": 0
}
]
]
},
"Set Relevance Rules": {
"main": [
[
{
"node": "Set Comment Guidance",
"type": "main",
"index": 0
}
]
]
},
"Explode Posts to Items": {
"main": [
[
{
"node": "Record Posts in Notion",
"type": "main",
"index": 0
}
]
]
},
"Set Keywords & Communities": {
"main": [
[
{
"node": "Iterate Keyword List",
"type": "main",
"index": 0
}
]
]
},
"Merge Post Arrays": {
"main": [
[
{
"node": "Expand Posts List",
"type": "main",
"index": 0
}
]
]
},
"Filter Empty Reddit Results": {
"main": [
[
{
"node": "Aggregate Reddit Results",
"type": "main",
"index": 0
}
]
]
},
"Set Comment Guidance": {
"main": [
[
{
"node": "Query Reddit API",
"type": "main",
"index": 0
}
]
]
},
"Append AI Scores & Notes": {
"main": [
[
{
"node": "Collect Posts Batch",
"type": "main",
"index": 0
}
]
]
}
}
}