Fei Wu This workflow corresponds to n8n.io template #10181 — we link there as the canonical source.
This workflow follows the Chainllm → Google Gemini Chat recipe pattern — see all workflows that pair these two integrations.
The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"meta": {
"templateCredsSetupCompleted": true
},
"nodes": [
{
"id": "6e9022b0-adce-4dce-be2d-74819e6f9d8f",
"name": "Google Gemini Chat Model",
"type": "@n8n/n8n-nodes-langchain.lmChatGoogleGemini",
"position": [
1344,
368
],
"parameters": {
"options": {},
"modelName": "models/gemini-2.0-flash"
},
"credentials": {
"googlePalmApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "8f8bbc64-d508-40bf-beef-218dcc01f6e1",
"name": "extract relevant attribut from comments",
"type": "n8n-nodes-base.code",
"position": [
832,
224
],
"parameters": {
"jsCode": "// Extract Reddit comment information with full nested structure\n// Get all input items\nconst items = $input.all();\n\n// Array to store all extracted comments\nconst extractedData = [];\n\n// Recursive helper function to extract replies at all levels\nfunction extractReplies(repliesData) {\n if (!repliesData || typeof repliesData !== 'object') {\n return [];\n }\n \n // Reddit API returns replies in a nested structure\n const repliesArray = [];\n \n if (repliesData.data && repliesData.data.children) {\n for (const child of repliesData.data.children) {\n if (child.kind === 't1' && child.data) {\n const reply = child.data;\n \n // Recursively extract nested replies (children of this reply)\n const nestedReplies = reply.replies ? extractReplies(reply.replies) : [];\n \n repliesArray.push({\n body: reply.body,\n upvotes: reply.ups || reply.score || 0,\n author: reply.author || '[deleted]',\n created_utc: reply.created,\n replies: nestedReplies, // Include nested replies\n replies_count: nestedReplies.length\n });\n }\n }\n }\n \n return repliesArray;\n}\n\n// Loop through each input item\nfor (const item of items) {\n const comment = item.json;\n \n // Extract replies recursively\n const replies = comment.replies ? extractReplies(comment.replies) : [];\n \n // Extract required fields from each comment\n extractedData.push({\n body: comment.body,\n upvotes: comment.ups || comment.score || 0,\n replies: replies,\n replies_count: replies.length,\n author: comment.author || '[deleted]',\n created_utc: comment.created,\n });\n}\n\n// Return the extracted data\nreturn extractedData.map(item => ({ json: item }));"
},
"typeVersion": 2
},
{
"id": "af4f6458-f3cb-48af-8e02-d42ddb1dd7bc",
"name": "aggregate post and comment into a single text",
"type": "n8n-nodes-base.code",
"position": [
1072,
224
],
"parameters": {
"jsCode": "// n8n JavaScript Code to Extract and Aggregate Reddit Comments\nconst postData = $('Loop Over Every Posts').first().json;\nconst commentsData = $input.all();\n\n// Function to concatenate all nested comment text into a single string\nfunction concatenateComment(comment, indent = 0) {\n let result = '';\n const indentation = ' '.repeat(indent);\n \n // Add the current comment\n result += `${indentation}[${comment.upvotes} upvotes] ${comment.author || 'Unknown'}:\\n`;\n result += `${indentation}${comment.body}\\n`;\n \n // Recursively add all nested replies\n if (comment.replies && comment.replies.length > 0) {\n result += '\\n';\n for (const reply of comment.replies) {\n result += concatenateComment(reply, indent + 1);\n }\n }\n \n return result;\n}\n\n\n// Build the final aggregated text\nlet finalText = \"\" // concatenateComment(commentsData[0].json)\n\n// Add post title and description\nfinalText += `TITLE:\\n${postData.title}\\n\\n`;\nfinalText += `DESCRIPTION:\\n${postData.description}\\n\\n`;\nfinalText += `${'='.repeat(100)}\\n`;\nfinalText += `COMMENTS SECTION (${commentsData.length} comments)\\n`;\nfinalText += `${'='.repeat(100)}\\n\\n`;\n\n// Iterate over all comments and concatenate\nfor (let i = 0; i < commentsData.length; i++) {\n const comment = commentsData[i].json;\n \n finalText += `COMMENT ${i + 1}:\\n`;\n finalText += concatenateComment(comment);\n finalText += `\\n${'-'.repeat(100)}\\n\\n`;\n}\n\n// Return the final aggregated result\nreturn {\n json: {\n aggregated_text: finalText,\n }\n};"
},
"typeVersion": 2
},
{
"id": "55da0772-4345-4cb7-91f4-e27a5ecab116",
"name": "Structured Output Parser",
"type": "@n8n/n8n-nodes-langchain.outputParserStructured",
"position": [
1488,
400
],
"parameters": {
"jsonSchemaExample": "{\n\t\"summary\": \"result of the summary\",\n \"tags\": \"a list of the tags separated by comma\"\n}"
},
"typeVersion": 1.3
},
{
"id": "9d5f419a-80a2-4e68-9ab1-eb2aa580ecd4",
"name": "Google Gemini Chat Model1",
"type": "@n8n/n8n-nodes-langchain.lmChatGoogleGemini",
"position": [
16,
416
],
"parameters": {
"options": {},
"modelName": "models/gemini-2.0-flash"
},
"credentials": {
"googlePalmApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "dac2ac6e-612f-4a94-88a2-1a90348a05f9",
"name": "Wait (rate limiting)",
"type": "n8n-nodes-base.wait",
"position": [
2192,
224
],
"parameters": {},
"typeVersion": 1.1
},
{
"id": "f97e2920-5139-4179-82c7-2735c880aeb6",
"name": "Sticky Note",
"type": "n8n-nodes-base.stickyNote",
"position": [
-1344,
80
],
"parameters": {
"width": 368,
"height": 464,
"content": "## Get current reddit post from database"
},
"typeVersion": 1
},
{
"id": "93be6f34-652d-4f97-aef0-d7a614741c09",
"name": "Sticky Note1",
"type": "n8n-nodes-base.stickyNote",
"position": [
-960,
80
],
"parameters": {
"color": 5,
"width": 560,
"height": 464,
"content": "## Get the last 10 saved post (can be changed)\n- keep only relevant information about the post\n- keep only post from a list of subreddit (can be changed)\n- and remove those already saved in database"
},
"typeVersion": 1
},
{
"id": "7e5b3fc7-a09e-41d6-a00c-141779a5678a",
"name": "Sticky Note2",
"type": "n8n-nodes-base.stickyNote",
"position": [
-368,
80
],
"parameters": {
"color": 3,
"width": 320,
"height": 464,
"content": "## Process each post one by one"
},
"typeVersion": 1
},
{
"id": "0fc264ac-9c59-430e-bb4e-cc1ed75db4b7",
"name": "Sticky Note3",
"type": "n8n-nodes-base.stickyNote",
"position": [
-32,
80
],
"parameters": {
"color": 2,
"width": 528,
"height": 464,
"content": "## Check if a post satisfy a condition you want (can be changed)"
},
"typeVersion": 1
},
{
"id": "9cb9e6cc-b9b1-4919-89e0-6e1169731082",
"name": "Sticky Note4",
"type": "n8n-nodes-base.stickyNote",
"position": [
528,
80
],
"parameters": {
"width": 720,
"height": 464,
"content": "## Fetch all comments for a post and aggregate them all together with the post title and body into a single text body so a LLM can process the post content together with its comment"
},
"typeVersion": 1
},
{
"id": "0440fb77-5394-454e-bc44-6d9918e1b821",
"name": "Sticky Note5",
"type": "n8n-nodes-base.stickyNote",
"position": [
1296,
80
],
"parameters": {
"color": 3,
"width": 544,
"height": 464,
"content": "## Summarize the reddit post and its comments and prepare data to be inserted in supabase (can be changed)"
},
"typeVersion": 1
},
{
"id": "debac080-e6e3-4c76-8bec-d065613aab79",
"name": "Sticky Note6",
"type": "n8n-nodes-base.stickyNote",
"position": [
1888,
80
],
"parameters": {
"color": 4,
"width": 464,
"height": 464,
"content": "## Save in supabase and wait a bit to avoid rate limiting"
},
"typeVersion": 1
},
{
"id": "16ee10de-4617-470f-a0d0-6adacaaba375",
"name": "manual trigger when testing",
"type": "n8n-nodes-base.manualTrigger",
"position": [
-1520,
224
],
"parameters": {},
"typeVersion": 1
},
{
"id": "263dae2d-baf8-4390-8f9e-4023090302bc",
"name": "check once a day if new post are available",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
-1520,
48
],
"parameters": {
"rule": {
"interval": [
{}
]
}
},
"typeVersion": 1.2
},
{
"id": "6180a9ca-b5a1-4d57-86ef-6f17b16c4686",
"name": "Get post data from supabase",
"type": "n8n-nodes-base.supabase",
"position": [
-1312,
224
],
"parameters": {
"tableId": "reddit_posts",
"operation": "getAll",
"returnAll": true,
"filterType": "none"
},
"credentials": {
"supabaseApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "924cdc72-9c5c-44c6-a886-17b9626a5169",
"name": "and extract their reddit id",
"type": "n8n-nodes-base.code",
"position": [
-1120,
224
],
"parameters": {
"jsCode": "const items = $input.all();\nconst redditIds = items.map((item) => item?.json?.reddit_id);\nreturn { redditIds };\n"
},
"typeVersion": 2
},
{
"id": "f129a042-72fd-4d4f-b8e4-533b7d226ba8",
"name": "get saved post from reddit profile",
"type": "n8n-nodes-base.reddit",
"position": [
-928,
224
],
"parameters": {
"limit": 10,
"details": "saved",
"resource": "profile"
},
"credentials": {
"redditOAuth2Api": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "232786ac-2809-4534-b353-37263dccc03f",
"name": "extract relevant attribut and filter posts based on subreddit",
"type": "n8n-nodes-base.code",
"position": [
-752,
224
],
"parameters": {
"jsCode": "// Extract Reddit post information\n// Get all input items - each item contains a post\nconst items = $input.all();\n\n// Define accepted subreddits (exact matches)\nconst acceptedSubReddits = [];\n\n// Define keywords for soft filtering (case-insensitive)\nconst subredditKeywords = [];\n\n// Filter function\nconst isAcceptedSubreddit = (subreddit) => {\n const subredditLower = subreddit.toLowerCase();\n \n // Check for exact match\n if (acceptedSubReddits.includes(subredditLower)) {\n return true;\n }\n \n // Check if subreddit contains any of the keywords\n return subredditKeywords.some(keyword => subredditLower.includes(keyword));\n};\n\n// Process all posts and filter by subreddit\nconst extractedData = items\n .map(item => item.json) // Extract the json from each item\n .filter(post => isAcceptedSubreddit(post.subreddit)) // Filter by subreddit criteria\n .map(post => ({\n id: post.id,\n title: post.title,\n description: post.selftext || '',\n subreddit: post.subreddit,\n url: `https://reddit.com${post.permalink}`,\n upvotes: post.ups,\n num_comments: post.num_comments,\n post_date: new Date(post.created_utc * 1000).toISOString()\n }));\n\n// Return the extracted data\nreturn extractedData.map(item => ({ json: item }));"
},
"typeVersion": 2
},
{
"id": "5d76664a-5068-4a75-98ff-901ea34c21df",
"name": "further filtering existing posts wrt existing posts in database",
"type": "n8n-nodes-base.code",
"position": [
-544,
224
],
"parameters": {
"jsCode": "const newPosts = $input.all();\n\n// Extract reddit_ids from Supabase response\nconst savedRedditIds = $(\"and extract their reddit id\").first().json.redditIds\n\n// Filter out existing posts\nconst uniquePosts = newPosts.filter(item => {\n const postId = item.json.id;\n return !savedRedditIds.includes(postId);\n});\n\nreturn uniquePosts;"
},
"typeVersion": 2
},
{
"id": "9afcd5d7-6774-4aa9-9f5b-b2bd2b7ba3a7",
"name": "LLM1",
"type": "@n8n/n8n-nodes-langchain.chainLlm",
"position": [
16,
224
],
"parameters": {
"text": "=Does this reddit post {YOUR CONDITION}? Answer only with 'YES' or 'NO'\n\n=== REDDIT POST ===\ntitle: {{ $input.all()[0].json.title }}\n\n{{ $input.all()[0].json.description }}",
"batching": {},
"messages": {
"messageValues": [
{
"message": "{YOUR CUSTOM SYSTEM PROMPT}"
}
]
},
"promptType": "define",
"hasOutputParser": true
},
"typeVersion": 1.7
},
{
"id": "07a68c95-dd2d-41a9-a37d-cfa1768ab66a",
"name": "get all comments for the current post",
"type": "n8n-nodes-base.reddit",
"position": [
624,
224
],
"parameters": {
"postId": "={{ $('Loop Over Every Posts').first().json.id }}",
"resource": "postComment",
"operation": "getAll",
"returnAll": true,
"subreddit": "={{ $('Loop Over Every Posts').first().json.subreddit }}"
},
"credentials": {
"redditOAuth2Api": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "d10341d7-7e4b-4f13-a3a2-58d856b34ac5",
"name": "LLM2",
"type": "@n8n/n8n-nodes-langchain.chainLlm",
"position": [
1344,
224
],
"parameters": {
"text": "=summarize the following reddit post using its content and comments in less than 300 words. Assign to this post some tags when relevant, use tags from the following options: [{YOUR CUSTOM TAGS}]\n\n{{ $json.aggregated_text }}",
"batching": {},
"messages": {
"messageValues": [
{
"message": "{YOUR CUSTOM SYSTEM PROMPT}"
}
]
},
"promptType": "define",
"hasOutputParser": true
},
"typeVersion": 1.7
},
{
"id": "14148b67-c31b-4a79-942e-240a6e096d03",
"name": "prepare data to be inserted in supabase",
"type": "n8n-nodes-base.code",
"position": [
1648,
224
],
"parameters": {
"jsCode": "const postInfo = $('Loop Over Every Posts').first().json\nconst summary = $input.all()[0].json.output.summary || \"\"\nlet tags = $input.all()[0].json.output.tags || \"\"\ntags = tags.split(\",\")\n\nreturn {\n json: {\n reddit_id: postInfo.id,\n title: postInfo.title,\n url: postInfo.url,\n summary: summary,\n tags: tags,\n post_date: postInfo.post_date,\n upvotes: postInfo.upvotes,\n num_comments: postInfo.num_comments\n }\n}"
},
"typeVersion": 2
},
{
"id": "6b333271-11fe-470d-9d79-cb813f2851fd",
"name": "insert new reddit post",
"type": "n8n-nodes-base.supabase",
"position": [
1968,
224
],
"parameters": {
"tableId": "reddit_posts",
"dataToSend": "autoMapInputData"
},
"credentials": {
"supabaseApi": {
"name": "<your credential>"
}
},
"typeVersion": 1
},
{
"id": "33751e13-2123-4563-bf8a-af8d56ef3060",
"name": "Loop Over Every Posts",
"type": "n8n-nodes-base.splitInBatches",
"position": [
-256,
224
],
"parameters": {
"options": {}
},
"typeVersion": 3
},
{
"id": "c82a5220-6aa6-4785-9bad-f815d206a8ea",
"name": "If the condition is satisfied",
"type": "n8n-nodes-base.if",
"position": [
336,
224
],
"parameters": {
"options": {},
"conditions": {
"options": {
"version": 2,
"leftValue": "",
"caseSensitive": true,
"typeValidation": "strict"
},
"combinator": "and",
"conditions": [
{
"id": "1e45af06-4c0d-4c43-b9c7-066f046ec572",
"operator": {
"name": "filter.operator.equals",
"type": "string",
"operation": "equals"
},
"leftValue": "={{ $input.all()[0].json.text }}",
"rightValue": "YES"
}
]
}
},
"typeVersion": 2.2
}
],
"connections": {
"LLM1": {
"main": [
[
{
"node": "If the condition is satisfied",
"type": "main",
"index": 0
}
]
]
},
"LLM2": {
"main": [
[
{
"node": "prepare data to be inserted in supabase",
"type": "main",
"index": 0
}
]
]
},
"Wait (rate limiting)": {
"main": [
[
{
"node": "Loop Over Every Posts",
"type": "main",
"index": 0
}
]
]
},
"Loop Over Every Posts": {
"main": [
[],
[
{
"node": "LLM1",
"type": "main",
"index": 0
}
]
]
},
"insert new reddit post": {
"main": [
[
{
"node": "Wait (rate limiting)",
"type": "main",
"index": 0
}
]
]
},
"Google Gemini Chat Model": {
"ai_languageModel": [
[
{
"node": "LLM2",
"type": "ai_languageModel",
"index": 0
}
]
]
},
"Structured Output Parser": {
"ai_outputParser": [
[
{
"node": "LLM2",
"type": "ai_outputParser",
"index": 0
}
]
]
},
"Google Gemini Chat Model1": {
"ai_languageModel": [
[
{
"node": "LLM1",
"type": "ai_languageModel",
"index": 0
}
]
]
},
"Get post data from supabase": {
"main": [
[
{
"node": "and extract their reddit id",
"type": "main",
"index": 0
}
]
]
},
"and extract their reddit id": {
"main": [
[
{
"node": "get saved post from reddit profile",
"type": "main",
"index": 0
}
]
]
},
"manual trigger when testing": {
"main": [
[
{
"node": "Get post data from supabase",
"type": "main",
"index": 0
}
]
]
},
"If the condition is satisfied": {
"main": [
[
{
"node": "get all comments for the current post",
"type": "main",
"index": 0
}
],
[
{
"node": "Loop Over Every Posts",
"type": "main",
"index": 0
}
]
]
},
"get saved post from reddit profile": {
"main": [
[
{
"node": "extract relevant attribut and filter posts based on subreddit",
"type": "main",
"index": 0
}
]
]
},
"get all comments for the current post": {
"main": [
[
{
"node": "extract relevant attribut from comments",
"type": "main",
"index": 0
}
]
]
},
"extract relevant attribut from comments": {
"main": [
[
{
"node": "aggregate post and comment into a single text",
"type": "main",
"index": 0
}
]
]
},
"prepare data to be inserted in supabase": {
"main": [
[
{
"node": "insert new reddit post",
"type": "main",
"index": 0
}
]
]
},
"check once a day if new post are available": {
"main": [
[
{
"node": "Get post data from supabase",
"type": "main",
"index": 0
}
]
]
},
"aggregate post and comment into a single text": {
"main": [
[
{
"node": "LLM2",
"type": "main",
"index": 0
}
]
]
},
"extract relevant attribut and filter posts based on subreddit": {
"main": [
[
{
"node": "further filtering existing posts wrt existing posts in database",
"type": "main",
"index": 0
}
]
]
},
"further filtering existing posts wrt existing posts in database": {
"main": [
[
{
"node": "Loop Over Every Posts",
"type": "main",
"index": 0
}
]
]
}
}
}
Credentials you'll need
Each integration node will prompt for credentials when you import. We strip credential IDs before publishing — you'll add your own.
googlePalmApiredditOAuth2ApisupabaseApi
Pro
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
Perfect for content curators, researchers, developers, and community managers who want to build a structured database of valuable Reddit content without manual data entry. If you're tracking industry trends, gathering user feedback, or building a knowledge base from Reddit…
Source: https://n8n.io/workflows/10181/ — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
Content - Newsletter Agent. Uses formTrigger, chainLlm, outputParserStructured, httpRequest. Event-driven trigger; 91 nodes.
Form Trigger, Chain Llm, Output Parser Structured +8
Content - Newsletter Agent. Uses formTrigger, chainLlm, outputParserStructured, httpRequest. Event-driven trigger; 87 nodes.
Form Trigger, Chain Llm, Output Parser Structured +7
This template attempts to replicate OpenAI's DeepResearch feature which, at time of writing, is only available to their pro subscribers.
Output Parser Structured, OpenAI Chat, Form Trigger +8
My workflow 53. Uses formTrigger, httpRequest, lmChatOpenAi, form. Event-driven trigger; 74 nodes.
Form Trigger, HTTP Request, OpenAI Chat +15
Episode 23: UGC with nanobanana. Uses lmChatOpenAi, lmChatOllama, lmChatDeepSeek, lmChatOpenRouter. Event-driven trigger; 74 nodes.
OpenAI Chat, Ollama Chat, Lm Chat Deep Seek +12