January 22, 2026

Reddit to Gmail, newsletter drafts ready to send

Lisa Granqvist Partner Workflow Automation Expert

Get a free AI assessment → ⬇️ Use template

You start with “I’ll just grab a few good Reddit posts,” and suddenly it’s an hour later. You’ve got 12 tabs open, half-copied quotes, broken formatting, and that nagging feeling you missed the best comment in the thread.

Marketing managers building weekly updates feel it fast. A founder sending community insights to investors feels it too. So does a consultant who needs a quick brief before a client call. This Reddit Gmail automation turns threads into a clean HTML newsletter draft that lands in your inbox.

Below you’ll see exactly how the workflow pulls the right posts, summarizes the discussion, and produces a ready-to-send email you can tweak in minutes.

How This Automation Works

The full n8n workflow, from trigger to final output:

n8n Workflow Template: Reddit to Gmail, newsletter drafts ready to send

Click to explore

flowchart LR

    subgraph sg0["When clicking ‘Execute workflow’ Flow"]
        direction LR
        n0@{ icon: "mdi:play-circle", form: "rounded", label: "When clicking ‘Execute workf..", pos: "b", h: 48 }
        n1["<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/reddit.svg' width='40' height='40' /></div><br/>Get many posts"]
        n2@{ icon: "mdi:swap-vertical", form: "rounded", label: "Set topic of interest", pos: "b", h: 48 }
        n3@{ icon: "mdi:swap-vertical", form: "rounded", label: "Loop Over Items", pos: "b", h: 48 }
        n4@{ icon: "mdi:swap-vertical", form: "rounded", label: "post", pos: "b", h: 48 }
        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/merge.svg' width='40' height='40' /></div><br/>Merge"]
        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/>clean comments"]
        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/>merge comments"]
        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/>merge summaries"]
        n9@{ icon: "mdi:robot", form: "rounded", label: "create newsletter", pos: "b", h: 48 }
        n10@{ icon: "mdi:robot", form: "rounded", label: "Summarize post + comments", pos: "b", h: 48 }
        n11@{ icon: "mdi:robot", form: "rounded", label: "filter topic of interest", pos: "b", h: 48 }
        n12@{ icon: "mdi:message-outline", form: "rounded", label: "Send a message", pos: "b", h: 48 }
        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/code.svg' width='40' height='40' /></div><br/>Select Top 10 Post"]
        n14["<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/>String to Json"]
        n15@{ icon: "mdi:swap-horizontal", form: "rounded", label: "If topic of interest", pos: "b", h: 48 }
        n16["<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/reddit.svg' width='40' height='40' /></div><br/>Get post comments"]
        n4 --> n16
        n4 --> n5
        n5 --> n10
        n1 --> n13
        n14 --> n15
        n6 --> n7
        n7 --> n5
        n3 --> n8
        n3 --> n4
        n8 --> n9
        n16 --> n6
        n9 --> n12
        n13 --> n2
        n15 --> n3
        n2 --> n11
        n11 --> n14
        n10 --> n3
        n0 --> n1
    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 n9,n10,n11 ai
    class n15 decision
    class n6,n7,n8,n13,n14 code
    classDef customIcon fill:none,stroke:none
    class n1,n5,n6,n7,n8,n13,n14,n16 customIcon

The Problem: Reddit Curation Eats Your Best Work Time

Reddit is a goldmine, but turning it into something you can send is oddly exhausting. You’re scanning posts, checking upvotes, opening comment threads, copying chunks into a doc, then reformatting everything for email (which loves to break HTML in new and creative ways). And because it’s manual, it’s inconsistent. Some weeks you catch great insights. Other weeks you miss the one comment that would’ve made the whole newsletter worth reading. The mental load is the real tax, because you’re doing “content work” without actually creating anything.

It adds up fast. Here’s where the friction usually shows up.

Finding the top posts is not hard, but comparing recency, upvotes, and comments across tabs wastes about an hour on a busy subreddit.
Comment threads are where the value lives, yet pulling quotes and insights by hand is slow and you will miss context.
Once you paste into an email draft, formatting turns into cleanup work (spacing, headings, links, and weird line breaks).
Without a repeatable filter, your digest drifts off-topic, which means more editing and less trust from readers.

The Solution: Reddit Threads → A Polished HTML Newsletter in Gmail

This workflow turns Reddit browsing into a dependable newsletter drafting machine. You trigger it in n8n, it pulls fresh posts from a subreddit (the default is r/microsaas), and then ranks them to pick the top 10 using engagement and recency. Next, it applies your “topic of interest” using a lightweight AI true/false filter, so only posts that match your theme move forward. For each approved post, it fetches the comments, cleans them into a structured list, and summarizes the discussion into usable sections like main takeaways and memorable quotes. Finally, it generates a clean HTML newsletter (not Markdown) and sends it to you via Gmail as a draft-ready email you can skim, tweak, and send.

The workflow starts with a manual trigger and a Reddit pull. Then OpenAI helps with relevance checks and summarization, and Gmail delivers the finished HTML digest to your inbox with a subject like “Reddit Digest” (easy to rename). That’s it.

What You Get: Automation vs. Results

What This Workflow Automates

Results You’ll Get

Pulls new posts from your chosen subreddit and sort order.
Ranks and selects the top 10 posts using upvotes, comments, and recency.
Filters posts by your topic of interest using a quick AI relevance check.
Fetches comments, cleans them, summarizes them, and generates HTML for email.

Go from “Reddit browsing + formatting” to an inbox-ready draft in about 10 minutes of your time.
Send a digest that actually stays on-theme, instead of a random grab bag.
Get consistent sections per post (summary, insights, key learnings), which makes your newsletter easier to read.
Cut down on copy-paste mistakes like broken links and missing context.
Scale from occasional digests to daily or weekly sends without adding work.

Example: What This Looks Like

Say you send one weekly digest from a subreddit with a lot of activity. Manually, picking 10 posts (about 5 minutes each once you open comments, grab quotes, and clean formatting) is roughly 50 minutes, and the email formatting cleanup can easily add another 30 minutes. With this workflow, you trigger it once, let n8n process in the background for a bit, and you get a complete HTML draft in Gmail ready to edit and send. Most weeks that’s about an hour back, without sacrificing quality.

What You’ll Need

n8n instance (try n8n Cloud free)
Self-hosting option if you prefer (Hostinger works well)
Reddit OAuth2 to read posts and comments.
OpenAI API key for relevance filtering and summaries.
Gmail OAuth2 to deliver the HTML digest email.

Skill level: Intermediate. You’ll be connecting OAuth accounts and editing a few prompts and fields inside n8n.

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

How It Works

You trigger the run. The workflow uses a manual start right now, which is perfect while you’re testing. If you want a weekly newsletter, you can swap in a Cron trigger later.

Reddit posts get pulled and ranked. n8n fetches new posts from your target subreddit, then a ranking step selects the top 10 based on upvotes, comment count, and freshness.

AI keeps it on-topic. You define a “topic of interest” (like “growth tactics” or “first customers”), and OpenAI returns a simple true/false so irrelevant posts don’t waste your time or tokens.

Comments are cleaned, summarized, and turned into HTML. For each chosen post, the workflow pulls the comment thread, flattens it into a clean list, generates summaries and key learnings, and then composes a single HTML newsletter that Gmail sends to you.

You can easily modify the subreddit and the topic filter to match your niche based on your needs. See the full implementation guide below for customization options.

Step-by-Step Implementation Guide

Step 1: Configure the Manual Trigger

Start the workflow manually so you can validate the Reddit selection and AI outputs before automating.

Add or verify the Manual Start Trigger node as the first node in the workflow.
Connect Manual Start Trigger to Fetch Reddit Posts to begin data collection on demand.

Step 2: Connect Reddit Data Sources

Pull fresh content from Reddit and retrieve comment threads for each selected post.

Open Fetch Reddit Posts and set Operation to getAll.
Set Subreddit to microsaas and keep the category filter as new if present.
Credential Required: Connect your Reddit credentials in Fetch Reddit Posts.
Open Retrieve Post Comments and set Resource to postComment and Operation to getAll.
Map fields using expressions: set Limit to {{ $json.post.num_comments }}, Post ID to {{ $json.post.id }}, and Subreddit to {{ $json.post.subreddit }}.
Credential Required: Connect your Reddit credentials in Retrieve Post Comments.

Tip: If your subreddit is large, consider changing the category or limiting comment retrieval to avoid long runtimes.

Step 3: Set Up Post Selection and Topic Filtering

Rank posts, assign the focus topic, and use AI to filter posts by relevance.

In Pick Top Ten Posts, keep the JavaScript logic to sort by upvotes and comments; this node outputs the top 10 posts.
In Assign Focus Topic, set topic to Strategies and tactics to get new customer and set post to {{$json}}.
Open Evaluate Topic Relevance and select model gpt-4o-mini.
Credential Required: Connect your OpenAI credentials in Evaluate Topic Relevance.
In Parse Model Output, keep the parser logic to convert the AI response into JSON for downstream conditions.
Configure Branch on Relevance to evaluate {{ $json.topic_of_interest }} as true.

⚠️ Common Pitfall: If the AI returns non-JSON output, Parse Model Output will return an error object and the relevance check will fail. Keep the AI prompt strict about returning JSON only.

Step 4: Process Comments and Summaries (Parallel Branch)

After batching, the workflow captures each post and processes comments in parallel for summarization.

Confirm Iterate Post Batches is connected from Branch on Relevance to batch the relevant posts.
In Capture Post Payload, set post to {{ $json }} to carry the post object forward.
Capture Post Payload outputs to both Retrieve Post Comments and Merge Data Streams in parallel.
In Sanitize Comment List, keep the flattening logic that extracts comment fields and replies.
In Combine Comment Sets, keep the code that aggregates all comment items into a single list.
In Merge Data Streams, set Mode to combine and Combine By to combineByPosition.

Tip: The merge relies on item pairing. Avoid changing the pairing logic in Pick Top Ten Posts and Sanitize Comment List.

Step 5: Summarize Discussions and Compile the Newsletter

Use AI to summarize each discussion, aggregate summaries, and generate the HTML newsletter.

In Summarize Discussion, select model gpt-4o-mini and keep the prompts that reference {{ JSON.stringify($json.list) }} and {{ $json.post.topic }}.
Credential Required: Connect your OpenAI credentials in Summarize Discussion.
In Aggregate Summaries, keep the code that outputs a single item with a list array of summaries.
In Generate Newsletter HTML, select model gpt-4o-mini and keep the prompt that transforms {{ JSON.stringify($json.list) }} into HTML.
Credential Required: Connect your OpenAI credentials in Generate Newsletter HTML.

Step 6: Configure Email Delivery

Send the generated HTML newsletter to your inbox.

Open Dispatch Email and set Send To to your email address (replace [YOUR_EMAIL]).
Set Subject to Reddit Diggest.
Set Message to {{ $json.message.content }} to use the generated HTML body.
Credential Required: Connect your Gmail credentials in Dispatch Email.

Step 7: Test and Activate Your Workflow

Run the workflow end-to-end and confirm the newsletter is produced and emailed correctly.

Click Execute Workflow from Manual Start Trigger to run a manual test.
Verify Fetch Reddit Posts and Pick Top Ten Posts return items, and that Branch on Relevance passes only posts with topic_of_interest set to true.
Check that Generate Newsletter HTML outputs valid HTML and that Dispatch Email sends the message to your inbox.
When the output looks correct, toggle the workflow to Active for production use.

🔒

Unlock Full Step-by-Step Guide

Get the complete implementation guide + downloadable template

Common Gotchas

Reddit credentials can expire or need specific permissions. If things break, check your Reddit OAuth connection in n8n’s Credentials page first.
If you’re using Wait nodes or external rendering, processing 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 early or you’ll be editing outputs forever.

Frequently Asked Questions

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

About 30 minutes once your Reddit and Gmail accounts are ready.

Do I need coding skills to automate Reddit Gmail automation?

No. You’ll connect accounts, paste an API key, and edit a few plain-English prompts.

Is n8n free to use for this Reddit Gmail 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 a few cents per run depending on how much text gets summarized.

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 Gmail automation workflow for a different subreddit and newsletter tone?

Yes, and it’s the whole point. Change the subreddit in the “Fetch Reddit Posts” node, then rewrite the “Assign Focus Topic” text to match your niche. You can also swap the prompts in “Evaluate Topic Relevance,” “Summarize Discussion,” and “Generate Newsletter HTML” to match your voice (formal, punchy, friendly, whatever). If you want it scheduled, replace the Manual Trigger with a Cron trigger.

Why is my Reddit connection failing in this workflow?

Usually it’s expired Reddit OAuth credentials or a permission mismatch after a Reddit account change. Reconnect the Reddit credential in n8n and re-run the workflow. If it fails only on busy subreddits, you may be hitting rate limits, so reduce how many posts you fetch or slow the batch processing. Also check that the subreddit name is valid and public; private communities won’t return content unless the authenticated account has access.

How many posts can this Reddit Gmail automation handle?

In its default setup, it selects and processes 10 posts per run.

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

Often, yes, because this is more than a simple “Reddit to email” zap. You’re ranking items, looping through posts, fetching and cleaning comment threads, and generating structured HTML with AI, which is where n8n tends to feel less cramped. Zapier or Make can still do it, but you may end up juggling multiple scenarios or paying more once you add branching and higher volume. If you want complete control (including self-hosting), n8n is a strong choice. If you just want the simplest possible two-step automation, Zapier can be quicker. Talk to an automation expert if you want a quick recommendation based on your exact setup.

Once this is running, Reddit stops being a time sink and starts acting like a reliable content source. You get the draft. You keep the control.

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": "9a2e4245eb49ccbe6f004693696f8551ad9bea0cdd9366cb173bf5ed38852fac",
"templateId": null,
"templateCredsSetupCompleted": null
},
"name": "Automated Reddit Newsletter Builder",
"tags": [],
"nodes": [
{
"id": "flowpast-topbar-7709",
"name": "Flowpast Branding",
"type": "n8n-nodes-base.stickyNote",
"position": [
80,
30
],
"parameters": {
"color": 7,
"width": 1390,
"height": 80,
"content": "## Flowpast.com | Automation Workflow Library\n**\ud83d\udcd6 Full tutorial & setup guide:** flowpast.com"
},
"typeVersion": 1
},
{
"id": "4429a652-06ca-4abd-a864-06bdab7b4a51",
"name": "Manual Start Trigger",
"type": "n8n-nodes-base.manualTrigger",
"position": [
90,
160
],
"parameters": [],
"typeVersion": 1
},
{
"id": "325fd52f-9aff-4951-983a-302da65080c5",
"name": "Fetch Reddit Posts",
"type": "n8n-nodes-base.reddit",
"position": [
380,
130
],
"parameters": {
"filters": {
"category": "new"
},
"operation": "getAll",
"subreddit": "microsaas"
},
"typeVersion": 1
},
{
"id": "e0157069-7bd7-4dee-88f8-13a68ec0f5b6",
"name": "Pick Top Ten Posts",
"type": "n8n-nodes-base.code",
"position": [
720,
170
],
"parameters": {
"jsCode": "// n8n Code node (JavaScript)\n// Top 10 by ups; outputs only selected fields + pairedItem\n\n// Build a normalized list that remembers the source item index\nconst records = [];\nif (items.length === 1 && Array.isArray(items[0].json)) {\n  // Case: a single item with an array of posts inside\n  items[0].json.forEach((post, _idxInArray) => {\n    records.push({ data: post, src: 0 });\n  });\n} else {\n  // Case: one post per incoming item\n  items.forEach((it, idx) => {\n    records.push({ data: it.json || {}, src: idx });\n  });\n}\n\n// Sort with fallbacks\nconst sorted = records\n  .map(r => {\n    const j = r.data || {};\n    return {\n      ...r,\n      _ups: typeof j.ups === 'number' ? j.ups : (typeof j.score === 'number' ? j.score : 0),\n      _comments: typeof j.num_comments === 'number' ? j.num_comments : 0,\n      _created: typeof j.created_utc === 'number' ? j.created_utc : 0,\n    };\n  })\n  .sort((a, b) => {\n    if (b._ups !== a._ups) return b._ups - a._ups;\n    if (b._comments !== a._comments) return b._comments - a._comments;\n    return b._created - a._created;\n  });\n\n// Take top 10 and output minimal fields + pairedItem\nconst out = sorted.slice(0, 10).map((r, i) => {\n  const p = r.data || {};\n  return {\n    json: {\n      rank: i + 1,\n      id: p.id ?? null,\n      subreddit: p.subreddit ?? null,\n      title: p.title ?? null,\n      selftext: p.selftext ?? null,\n      url: p.permalink ? `https://www.reddit.com${p.permalink}` : null,\n      author: p.author ?? null,\n      ups: (typeof p.ups === 'number' ? p.ups : (typeof p.score === 'number' ? p.score : r._ups)),\n      num_comments: (typeof p.num_comments === 'number' ? p.num_comments : r._comments),\n      created_utc: (typeof p.created_utc === 'number' ? p.created_utc : r._created),\n    },\n    // \ud83d\udd39 This keeps items \"paired\" to their original source\n    pairedItem: { item: r.src },\n  };\n});\n\nreturn out;\n\n"
},
"typeVersion": 2
},
{
"id": "2e5d3135-709c-4000-9d23-5dee01bacb51",
"name": "Assign Focus Topic",
"type": "n8n-nodes-base.set",
"position": [
1000,
135
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "8fd840da-788a-4513-9523-66fa92f32850",
"name": "topic",
"type": "string",
"value": "Strategies and tactics to get new customer"
},
{
"id": "9ba01335-5307-4c37-bd21-7e887ce934cb",
"name": "post",
"type": "object",
"value": "={{$json}}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "3e9186aa-be58-4ae8-adcc-10dfd56768e0",
"name": "Evaluate Topic Relevance",
"type": "@n8n/n8n-nodes-langchain.openAi",
"position": [
1370,
155
],
"parameters": {
"modelId": {
"__rl": true,
"mode": "list",
"value": "gpt-4o-mini",
"cachedResultName": "GPT-4O-MINI"
},
"options": [],
"messages": {
"values": [
{
"role": "system",
"content": "You are an assistant that reviews Reddit posts.  \nYour task is to check if a given post is about a specific topic of interest.  \nAlways return the original JSON structure unchanged, but add one new field:  \n\"topic_of_interest\": true or false.  \n\n- If the post clearly relates to the requested topic, set it to true. You have to be very strict.  \n- If the relation is weak, unrelated, or ambiguous, set it to false.  \n- Do not remove or modify existing fields.  \n- Output must remain valid JSON.\n\n  topic is: {{ $json.topic }}"
},
{
"content": "=Here is a Reddit post in JSON format:\n\n{{JSON.stringify($json.post)}}\n\nPlease return the same JSON with two additional fields:\n\"topic\":{{ $json.topic }}\n\"topic_of_interest\": true or false\n\nReturn ONLY a valid JSON object, no prose, no markdown."
}
]
}
},
"typeVersion": 1.8
},
{
"id": "87bc320e-220a-4cc3-a4fa-40aa4484540a",
"name": "Parse Model Output",
"type": "n8n-nodes-base.code",
"position": [
1360,
310
],
"parameters": {
"jsCode": "// n8n Code node (JavaScript)\n// Parsea \"message.content\" del nodo OpenAI a JSON robustamente.\n// Soporta: JSON puro, bloque ```json ... ```, y string JSON escapado.\n\nfunction extractFromCodeFence(s) {\n  const m = s.match(/```(?:json)?\\s*([\\s\\S]*?)```/i);\n  return m ? m[1] : null;\n}\n\nfunction extractFirstJsonObject(s) {\n  // Busca el primer bloque {...} (simple pero \u00fatil como \u00faltimo recurso)\n  const start = s.indexOf('{');\n  const end = s.lastIndexOf('}');\n  if (start !== -1 && end !== -1 && end > start) {\n    return s.slice(start, end + 1);\n  }\n  return null;\n}\n\nfunction smartParse(text) {\n  let t = text ?? '';\n\n  // 1) Si viene dentro de code fences ```json ... ```\n  const fenced = extractFromCodeFence(t);\n  if (fenced) t = fenced;\n\n  t = t.trim();\n\n  // 2) Intento directo\n  try {\n    const v = JSON.parse(t);\n    // Si al parsear obtenemos un string (caso de JSON doblemente escapado), parsea otra vez\n    if (typeof v === 'string') {\n      try { return JSON.parse(v); } catch { return v; }\n    }\n    return v;\n  } catch {}\n\n  // 3) Extrae el primer bloque {...} y reintenta\n  const objText = extractFirstJsonObject(t);\n  if (objText) {\n    try { return JSON.parse(objText); } catch {}\n  }\n\n  // 4) Fallback: devuelve error con el raw para inspecci\u00f3n\n  return { error: 'Invalid JSON', raw: text };\n}\n\nreturn items.map((item) => {\n  const content =\n    item.json?.content ??\n    item.json?.message?.content ?? // estructura t\u00edpica del nodo \"Message a model\"\n    '';\n\n  const parsed = smartParse(String(content));\n\n  return {\n    json: parsed,\n    // Mant\u00e9n pairing si vienes encadenando nodos que lo requieren:\n    pairedItem: item.pairedItem ? item.pairedItem : undefined,\n  };\n});\n\n"
},
"typeVersion": 2
},
{
"id": "5f83b205-a863-4b2b-8083-4ba27ca698b5",
"name": "Branch on Relevance",
"type": "n8n-nodes-base.if",
"position": [
1030,
285
],
"parameters": {
"options": [],
"conditions": {
"options": {
"version": 2,
"leftValue": "",
"caseSensitive": true,
"typeValidation": "strict"
},
"combinator": "and",
"conditions": [
{
"id": "7d1039e0-2ae3-4935-b355-c60fbd9ffce5",
"operator": {
"type": "boolean",
"operation": "true",
"singleValue": true
},
"leftValue": "={{ $json.topic_of_interest }}",
"rightValue": ""
}
]
}
},
"typeVersion": 2.2
},
{
"id": "e2cf004a-d447-4750-a5ad-909646cb488c",
"name": "Iterate Post Batches",
"type": "n8n-nodes-base.splitInBatches",
"position": [
690,
330
],
"parameters": {
"options": []
},
"typeVersion": 3
},
{
"id": "201fb370-eddd-42f8-b2c9-af4d73b794ef",
"name": "Capture Post Payload",
"type": "n8n-nodes-base.set",
"position": [
390,
300
],
"parameters": {
"options": [],
"assignments": {
"assignments": [
{
"id": "747516e0-1d6e-4e36-aaee-70b36100d307",
"name": "post",
"type": "object",
"value": "={{ $json }}"
}
]
}
},
"typeVersion": 3.4
},
{
"id": "12fcb916-f819-48f7-b144-eb7c40176215",
"name": "Retrieve Post Comments",
"type": "n8n-nodes-base.reddit",
"position": [
80,
470
],
"parameters": {
"limit": "={{ $json.post.num_comments }}",
"postId": "={{ $json.post.id }}",
"resource": "postComment",
"operation": "getAll",
"subreddit": "={{ $json.post.subreddit }}"
},
"typeVersion": 1
},
{
"id": "b9ee93d4-6b58-4108-a58f-0ca35e18c6f9",
"name": "Sanitize Comment List",
"type": "n8n-nodes-base.code",
"position": [
410,
450
],
"parameters": {
"jsCode": "// n8n Code node (JavaScript) \u2014 v2 API\n// Simplifica un comentario de Reddit (y sus replies) a una lista plana con campos clave.\n// Devuelve 1 item por entrada con: post_id, post_url, subreddit, comments_count, comments[]\n\nfunction absPermalink(permalink) {\n  if (!permalink || typeof permalink !== 'string') return null;\n  return permalink.startsWith('http')\n    ? permalink\n    : `https://www.reddit.com${permalink}`;\n}\n\nfunction extractPostIdFromLinkId(link_id) {\n  // link_id suele ser \"t3_<postid>\"\n  if (typeof link_id !== 'string') return null;\n  const m = link_id.match(/^t3_(.+)$/i);\n  return m ? m[1] : null;\n}\n\nfunction walkComment(node, out, depth = 0) {\n  if (!node || typeof node !== 'object') return;\n\n  // El comentario suele ir en node.data si viene envuelto con { kind: \"t1\", data: {...} }\n  const c = node.data ? node.data : node;\n\n  // A\u00f1ade el comentario actual, si tiene cuerpo o al menos ID\n  const simplified = {\n    id: c.id ?? null,\n    author: c.author ?? null,\n    body: c.body ?? null,\n    ups: typeof c.ups === 'number' ? c.ups : (typeof c.score === 'number' ? c.score : 0),\n    created_utc: typeof c.created_utc === 'number' ? c.created_utc : null,\n    permalink: absPermalink(c.permalink),\n    parent_id: c.parent_id ?? null,\n    is_submitter: Boolean(c.is_submitter),\n    depth: typeof c.depth === 'number' ? c.depth : depth,\n  };\n\n  // Solo empuja si al menos hay id o body\n  if (simplified.id || simplified.body) {\n    out.push(simplified);\n  }\n\n  // Procesa replies: pueden ser \"\" o un Listing con data.children[]\n  const replies = c.replies;\n  if (replies && typeof replies === 'object' && replies.data && Array.isArray(replies.data.children)) {\n    for (const child of replies.data.children) {\n      walkComment(child, out, (simplified.depth ?? depth) + 1);\n    }\n  }\n}\n\nreturn items.map((it, idx) => {\n  const c = it.json || {};\n\n  // Obt\u00e9n post_id desde link_id (t3_<id>), si existe\n  const post_id = extractPostIdFromLinkId(c.link_id) ||\n                  (c.data ? extractPostIdFromLinkId(c.data.link_id) : null);\n\n  // URL del post (minimal) si tenemos post_id\n  const post_url = post_id ? `https://www.reddit.com/comments/${post_id}/` : null;\n\n  // Subreddit (intenta varias llaves por seguridad)\n  const subreddit = c.subreddit || c.subreddit_name_prefixed || (c.data ? c.data.subreddit : null) || null;\n\n  // Aplana el comentario ra\u00edz + sus replies\n  const flat = [];\n  walkComment(c, flat, typeof c.depth === 'number' ? c.depth : 0);\n\n  return {\n    json: {\n      post_id,\n      post_url,\n      subreddit,\n      comments_count: flat.length,\n      comments: flat,\n    },\n    pairedItem: { item: idx }, // conserva pairing con el item de entrada\n  };\n});\n"
},
"typeVersion": 2
},
{
"id": "abbd45d2-0911-4fed-9e3d-effbabe2a228",
"name": "Combine Comment Sets",
"type": "n8n-nodes-base.code",
"position": [
710,
485
],
"parameters": {
"jsCode": "// Crea un \u00fanico item con un array \"list\" que contiene los N items originales\nconst list = items.map(it => it.json);\n\n// Si solo quieres ciertos campos:\n// const list = items.map(it => ({ id: it.json.id, title: it.json.title, url: it.json.url }));\n\nreturn [\n  { json: { list } }\n];\n"
},
"typeVersion": 2
},
{
"id": "891b6023-fc8e-4a72-8e0a-0e3d196f0799",
"name": "Merge Data Streams",
"type": "n8n-nodes-base.merge",
"position": [
1040,
455
],
"parameters": {
"mode": "combine",
"options": [],
"combineBy": "combineByPosition"
},
"typeVersion": 3.2
},
{
"id": "9dead837-9957-4eb8-aad2-39b76e04016b",
"name": "Summarize Discussion",
"type": "@n8n/n8n-nodes-langchain.openAi",
"position": [
1365,
640
],
"parameters": {
"modelId": {
"__rl": true,
"mode": "list",
"value": "gpt-4o-mini",
"cachedResultName": "GPT-4O-MINI"
},
"options": [],
"messages": {
"values": [
{
"role": "system",
"content": "=You are an assistant that analyzes Reddit discussions. \nYour job is to extract main insights, lessons, and takeaways ONLY from the content provided (post + comments).\nYou must strictly stick to the Reddit content and never introduce external knowledge. \nAlways include clear attribution: mention the Reddit user and include the Reddit URL of the post or comment. \nYour answers must be written in fluent, concise, and insightful English, suitable for repurposing into a newsletter and podcast script. \nFocus only on the requested topic of interest, ignoring unrelated parts of the discussion.\n"
},
{
"content": "=Here is the Reddit discussion (post + comments) in JSON:\n\n{{ JSON.stringify($json.list) }}\n\nMy topic of interest is: {{ $json.post.topic }}\n`\nPlease analyze the discussion and output a JSON with the following structure:\n\n{\n  \"topic\": \"<the topic of interest>\",\n  \"main_post_summary\": \"<2-3 sentence summary of the original post, in your own words>\",\n  \"comments_insights\": [\n    {\n      \"insight\": \"<short summary of the comment\u2019s valuable point, always from the perspective of the topic of interest>\",\n      \"user\": \"<Reddit username>\",\n      \"url\": \"<permalink to comment or post>\"\n    }\n  ],\n  \"key_learnings\": [\n    \"<list of 3-5 concise takeaways relevant to the topic of interest, based ONLY on post and comments>\"\n  ]\n}\n"
}
]
}
},
"typeVersion": 1.8
},
{
"id": "8052a433-8cbb-4e0e-9aa4-8158e36e7537",
"name": "Aggregate Summaries",
"type": "n8n-nodes-base.code",
"position": [
1035,
660
],
"parameters": {
"jsCode": "// Crea un \u00fanico item con un array \"list\" que contiene los N items originales\nconst list = items.map(it => it.json);\n\n// Si solo quieres ciertos campos:\n// const list = items.map(it => ({ id: it.json.id, title: it.json.title, url: it.json.url }));\n\nreturn [\n  { json: { list } }\n];\n"
},
"typeVersion": 2
},
{
"id": "8c27e26c-9220-4af9-8415-7d23c5c37f9d",
"name": "Generate Newsletter HTML",
"type": "@n8n/n8n-nodes-langchain.openAi",
"position": [
690,
620
],
"parameters": {
"modelId": {
"__rl": true,
"mode": "list",
"value": "gpt-4o-mini",
"cachedResultName": "GPT-4O-MINI"
},
"options": [],
"messages": {
"values": [
{
"role": "=system",
"content": "=You are an editorial AI specialized in creating engaging newsletters from community discussions. \nYour role is not just to summarize, but to *curate and narrate* Reddit content so it feels fun, easy to read, and worth sharing.\n\nGOALS\n- Make the newsletter feel like a friendly, smart editor walking the reader through the highlights of Reddit.\n- Stay true to the source: everything must come from the JSON input (posts, comments, summaries).\n- Add flow, hooks, and personality \u2014 but never add outside facts.\n\nSTYLE\n- Warm, conversational, slightly witty.\n- Use simple words, short sentences, and a light narrative voice.\n- Structure content for skimming: headlines, bullets, quotes.\n- Sprinkle emojis thoughtfully to guide attention (\ud83d\ude80, \ud83d\udca1, \ud83c\udfaf, \ud83d\udd25, etc).\n- Always attribute quotes with username and link.\n\nOUTPUT\n- Return only valid HTML, suitable for an email newsletter.\n- No Markdown, no code fences.\n- Use <h1>, <h2>, <p>, <ul>, <li>, <blockquote>, and <a>.\n- Keep formatting clean, responsive, and email-friendly.\n\nCONSISTENCY\n- Every post should follow the same section format: \n  headline \u2192 short narrative \u2192 \u201cWhat we learned\u201d bullets \u2192 one quote \u2192 numbers line.\n- Smoothly skip elements if data is missing (never show \u201cUnknown\u201d).\n- Maintain a clear intro, outline, body sections, and energetic closing.\n\nYour priority: deliver an entertaining, easy-to-digest newsletter that makes the reader feel they just got the best of Reddit without doing the scrolling.\n"
},
{
"content": "=You are a creative newsletter editor. Your job is to turn a JSON array called \"list\" into an entertaining and easy-to-read HTML newsletter. \nThe newsletter must feel like a conversation with the reader, not like a dry report.\n\nSTYLE & TONE\n- Warm, engaging, slightly playful but professional.\n- Write like a smart curator who has read Reddit so the reader doesn\u2019t have to.\n- Use short sentences, catchy hooks, and occasional rhetorical questions.\n- Make the reader feel part of an insider community.\n- Avoid generic phrases (\u201cAuthor: Unknown\u201d, \u201cDate: Unknown\u201d). If data is missing, just skip it smoothly.\n\nSTRUCTURE\n1. **Header**: Big catchy title (\u201c\ud83d\ude80 Reddit Microsaas Weekly\u201d or similar), date, and a friendly short intro (2\u20133 sentences) that sets the mood.\n2. **Outline**: Quick bullets with the main stories (like teasers with emoji).\n3. **Main body**: For EACH summary in the list:\n   - Headline (H2) with a hooky title + link to Reddit post.\n   - One paragraph storytelling style summary (what happened, why it matters).\n   - \u201cWhat we learned\u201d section \u2192 3 key bullets, easy to skim.\n   - One spicy or emotional **quote from a comment**, styled as a blockquote, with attribution (username + link).\n   - A small \u201cBy the numbers\u201d line if ups or num_comments exist (\u25b2 X votes \u00b7 \ud83d\udcac Y comments).\n4. **Closing**: A short wrap-up with energy, like: \u201cThat\u2019s it for this week \u2014 what will YOU build next? Jump on Reddit and share your story.\u201d\n5. **Footer**: Disclaimer: \u201cAll content curated from Reddit. Click links for full threads.\u201d\n\nFORMATTING\n- Output only valid HTML (no Markdown, no code fences).\n- Use simple HTML tags: <h1>, <h2>, <p>, <ul>, <li>, <blockquote>, <a>.\n- Make it scannable: bold for emphasis, emoji for spice.\n- Newsletter must look good in email clients (inline styles optional but keep it simple).\n\nDATA HANDLING\n- Each item in \"list\" may contain: title, url, subreddit, author, created_utc, summary, key_learnings, comments_insights[], ups, num_comments.\n- If something is missing, don\u2019t mention it (no placeholders).\n- Always link headlines and quotes back to Reddit with <a> tags.\n\nNow transform this JSON input into the described HTML newsletter:.\n\n{{ JSON.stringify($json.list) }}"
}
]
}
},
"typeVersion": 1.8
},
{
"id": "72a3527f-30a1-40ff-8d74-5bd67c5881ce",
"name": "Dispatch Email",
"type": "n8n-nodes-base.gmail",
"position": [
390,
665
],
"webhookId": "38198233-bfff-4ad6-8feb-9e739f2ada23",
"parameters": {
"sendTo": "[YOUR_EMAIL]",
"message": "={{ $json.message.content }}",
"options": [],
"subject": "Reddit Diggest"
},
"typeVersion": 2.1
}
],
"active": false,
"pinData": [],
"settings": {
"executionOrder": "v1"
},
"versionId": null,
"connections": {
"Capture Post Payload": {
"main": [
[
{
"node": "Retrieve Post Comments",
"type": "main",
"index": 0
},
{
"node": "Merge Data Streams",
"type": "main",
"index": 0
}
]
]
},
"Merge Data Streams": {
"main": [
[
{
"node": "Summarize Discussion",
"type": "main",
"index": 0
}
]
]
},
"Fetch Reddit Posts": {
"main": [
[
{
"node": "Pick Top Ten Posts",
"type": "main",
"index": 0
}
]
]
},
"Parse Model Output": {
"main": [
[
{
"node": "Branch on Relevance",
"type": "main",
"index": 0
}
]
]
},
"Sanitize Comment List": {
"main": [
[
{
"node": "Combine Comment Sets",
"type": "main",
"index": 0
}
]
]
},
"Combine Comment Sets": {
"main": [
[
{
"node": "Merge Data Streams",
"type": "main",
"index": 1
}
]
]
},
"Iterate Post Batches": {
"main": [
[
{
"node": "Aggregate Summaries",
"type": "main",
"index": 0
}
],
[
{
"node": "Capture Post Payload",
"type": "main",
"index": 0
}
]
]
},
"Aggregate Summaries": {
"main": [
[
{
"node": "Generate Newsletter HTML",
"type": "main",
"index": 0
}
]
]
},
"Retrieve Post Comments": {
"main": [
[
{
"node": "Sanitize Comment List",
"type": "main",
"index": 0
}
]
]
},
"Generate Newsletter HTML": {
"main": [
[
{
"node": "Dispatch Email",
"type": "main",
"index": 0
}
]
]
},
"Pick Top Ten Posts": {
"main": [
[
{
"node": "Assign Focus Topic",
"type": "main",
"index": 0
}
]
]
},
"Branch on Relevance": {
"main": [
[
{
"node": "Iterate Post Batches",
"type": "main",
"index": 0
}
]
]
},
"Assign Focus Topic": {
"main": [
[
{
"node": "Evaluate Topic Relevance",
"type": "main",
"index": 0
}
]
]
},
"Evaluate Topic Relevance": {
"main": [
[
{
"node": "Parse Model Output",
"type": "main",
"index": 0
}
]
]
},
"Summarize Discussion": {
"main": [
[
{
"node": "Iterate Post Batches",
"type": "main",
"index": 0
}
]
]
},
"Manual Start Trigger": {
"main": [
[
{
"node": "Fetch Reddit Posts",
"type": "main",
"index": 0
}
]
]
}
}
}