Reddit RSS Migration Monitor

Name: Reddit RSS Migration Monitor
Author: CortexFlow

October 20, 2026 · Intermediate · Automation

↓ Download workflow JSON

Import in n8n: Workflows → ⋯ → Import from file, then add your credentials. Free download with a free account.

How it works

Reddit is killing RSS feeds on Nov 13, 2026 (and its public API ends March 2027), which will silently break every n8n workflow built on .rss monitoring. This is your migration kit:

STEP 1 — Bring your old RSS feeds — a daily 9 AM schedule trigger reads your old .rss URLs from CONFIG — RSS Migration. Parse Old RSS Feed URLs extracts the subreddit + search query from each URL (e.g. /r/n8n/search.rss?q=webhook → subreddit n8n, query webhook) and maps old RSS fields to their Reddit JSON equivalents: <title> → title, <link> → permalink, <pubDate> → created_utc, <guid> → post ID for dedupe.
STEP 2 — Fetch through a swappable source — IF — JSON Source Selector routes on json_source. With reddit_public (the default) it calls Reddit’s public .json API with a polite User-Agent: n8n-cortexflow-template/1.0 header — no API key needed. Set json_source to custom and it switches to Fetch Reddit — Custom JSON Source, which hits your custom_json_url (an Apify actor or any JSON proxy returning Reddit-shaped JSON) — ready-made for the March 2027 public-API shutdown.
STEP 3 — Normalize, dedupe, log NEW — Normalize Reddit Posts — RSS Field Map flattens the JSON and applies your watch_keywords, min_upvotes, and days_back freshness filters. Read Logged Post IDs → Filter New Posts Only drops already-seen post IDs, and the rest are appended to Google Sheets with status NEW.
STEP 4 — AI relevance scoring — an AI Agent reads each post against your business_description and returns a structured verdict via a Structured Output Parser: relevance_score (0–100), verdict (HIGHLY_RELEVANT / RELEVANT / LOW / IGNORE), why_relevant, and a suggested_action. The sheet flips to SCORED.
STEP 5 — Relevance gate — posts scoring at or above min_relevance_score pass IF — Relevance ≥ Threshold into Merge — Collect Alert Posts; below-threshold posts are first marked IGNORED in the sheet, then join the merge.
STEP 6 — Digest + heartbeat — Build Migration Digest assembles one Telegram digest — score, link, verdict, and why-it-matters per post. On days with nothing relevant it sends a 💓 heartbeat instead, so a silently broken source (rate limit, blocked endpoint, post-March-2027 API death) shows up as a missing message. The sent posts flip to SENT via Expand Sent URLs → Update Sheet — Status SENT.

Status flow in Sheets: NEW → SCORED → SENT (+ IGNORED for below-threshold posts)

How this differs from our Reddit Intent Lead Finder: that template hunts buying-intent conversations with search.json + intent keywords — this one is the migration path for your dying RSS feeds, with feed-URL migration, a swappable source, and a heartbeat so a broken source can’t go unnoticed.

Set up steps

You’ll need:

n8n (self-hosted or cloud)
Your old Reddit .rss feed URLs — grab them from your existing workflows before Nov 13, 2026
An OpenAI API key — platform.openai.com → API keys
Google Sheets OAuth2 credential — n8n Credentials → Google Sheets OAuth2 (sheets.google.com)
A Telegram bot — message @BotFather, send /newbot, copy the token; get your chat ID from @userinfobot

Steps:

Import the workflow — in n8n, Workflows → Import from File → select reddit-rss-migration-monitor.json.
CONFIG — RSS Migration — open the Set node and fill in:
- old_rss_feeds — one old .rss URL per line (e.g. https://www.reddit.com/r/n8n/new.rss or https://www.reddit.com/r/selfhosted/search.rss?q=automation&restrict_sr=on&sort=new)
- json_source — reddit_public today; switch to custom after March 2027 and paste your Apify/JSON-proxy endpoint into custom_json_url
- min_upvotes (5) and days_back (7) — engagement floor and freshness window
- watch_keywords — comma-separated terms that must appear in the title or body
- business_description — what you sell or monitor for (the AI prompt is built from this, so be specific)
- telegram_chat_id — where the digest and heartbeat land
CONFIG — Google Sheets — create a Google Sheet with a tab named RedditMonitor and these exact headers: Date | Post ID | Subreddit | Title | Post URL | Author | Upvotes | Comments | Created At | Relevance Score | Verdict | Why Relevant | Suggested Action | Status. Put the spreadsheet ID in spreadsheet_id, and select your Google Sheets credential in all five Sheets nodes (Read Logged Post IDs, Log Posts — Status NEW, Update Sheet — Status SCORED, Update Sheet — Status IGNORED, Update Sheet — Status SENT).
AI scoring — select your OpenAI credential in OpenAI Chat Model — Relevance Scoring (model is gpt-4o-mini by default), and set your min_relevance_score in CONFIG — AI Scoring.
Notifications — select your Telegram credential in Telegram — Send Digest, and activate the workflow. If the daily heartbeat ever stops arriving, your JSON source is broken — check the workflow’s execution log first.

Customize it

After March 2027 — point custom_json_url at an Apify actor run endpoint (e.g. their Reddit scraper) or any JSON proxy that returns Reddit-shaped JSON (data.children[].data), flip json_source to custom, done. No other node changes.
Tune the funnel — raise min_relevance_score to 75+ when volume is high, or loosen min_upvotes to 0 to catch fresh threads in slow subreddits.
More feeds — every .rss line becomes fetch specs; /r/<sub>/new.rss polls the newest posts, /r/<sub>/search.rss?q=... searches, /search.rss?q=... searches all of Reddit. Keep total lines under ~20 per run to stay polite.
Discord instead of Telegram — swap the Telegram node for a Discord webhook node and reformat the digest lines in Build Migration Digest.
Track replies — add a Replied column to the sheet; you already get suggested_action per post from the AI.
Migration audit — before Nov 13, run the workflow once manually and compare the fetched titles against your old RSS reader output: they should match post-for-post, proving the JSON replacement is faithful.

Workflow nodes

This workflow is built from 24 nodes. Here's what each one does:

#	Node	Type	What it does
1	`Daily 9AM Trigger`	Schedule Trigger	Starts the workflow automatically on a schedule.
2	`CONFIG — RSS Migration`	Set	Holds editable configuration values — fill in your own settings here before activating.
3	`Parse Old RSS Feed URLs`	Code	Runs custom JavaScript to transform, filter, or compute data between steps.
4	`IF — JSON Source Selector`	IF	Splits the flow into branches based on a condition.
5	`Fetch Reddit — Public JSON`	HTTP Request	Calls an external API or webhook endpoint.
6	`Fetch Reddit — Custom JSON Source`	HTTP Request	Calls an external API or webhook endpoint.
7	`Normalize Reddit Posts — RSS Field Map`	Code	Runs custom JavaScript to transform, filter, or compute data between steps.
8	`CONFIG — Google Sheets`	Set	Holds editable configuration values — fill in your own settings here before activating.
9	`Read Logged Post IDs`	Google Sheets	Reads from or writes to a Google Sheet — this workflow's log and state store.
10	`Filter New Posts Only`	Code	Runs custom JavaScript to transform, filter, or compute data between steps.
11	`Log Posts — Status NEW`	Google Sheets	Reads from or writes to a Google Sheet — this workflow's log and state store.
12	`CONFIG — AI Scoring`	Set	Holds editable configuration values — fill in your own settings here before activating.
13	`AI Agent — Score Relevance`	AI Agent	The AI brain — reasons over the task and calls tools to get it done.
14	`OpenAI Chat Model — Relevance Scoring`	OpenAI Chat Model	The language model powering the AI agent.
15	`Structured Output Parser — Relevance Score`	Structured Output Parser	Forces the AI to return clean, structured JSON instead of free text.
16	`Update Sheet — Status SCORED`	Google Sheets	Reads from or writes to a Google Sheet — this workflow's log and state store.
17	`IF — Relevance ≥ Threshold`	IF	Splits the flow into branches based on a condition.
18	`Update Sheet — Status IGNORED`	Google Sheets	Reads from or writes to a Google Sheet — this workflow's log and state store.
19	`Merge — Collect Alert Posts`	Merge	Combines the outputs of two or more branches back into one flow.
20	`Build Migration Digest`	Code	Runs custom JavaScript to transform, filter, or compute data between steps.
21	`CONFIG — Notifications`	Set	Holds editable configuration values — fill in your own settings here before activating.
22	`Telegram — Send Digest`	Telegram	Sends you a Telegram message or alert.
23	`Expand Sent URLs`	Code	Runs custom JavaScript to transform, filter, or compute data between steps.
24	`Update Sheet — Status SENT`	Google Sheets	Reads from or writes to a Google Sheet — this workflow's log and state store.

Setup instructions

1. Add your credentials

In n8n go to Credentials → New, create each credential below, then open the named node and select it:

Node	Credential to add
`Read Logged Post IDs`	Google Sheets OAuth2
`Log Posts — Status NEW`	Google Sheets OAuth2
`OpenAI Chat Model — Relevance Scoring`	OpenAI API
`Update Sheet — Status SCORED`	Google Sheets OAuth2
`Update Sheet — Status IGNORED`	Google Sheets OAuth2
`Telegram — Send Digest`	Telegram Bot API
`Update Sheet — Status SENT`	Google Sheets OAuth2

2. Fill in your config values

Open the config node listed below and replace each placeholder with your own value before activating the workflow:

Node	Field	What to paste
`CONFIG — RSS Migration`	`custom_json_url`	`PASTE_YOUR_JSON_PROXY_OR_APIFY_ENDPOINT` Your json proxy or apify endpoint
`CONFIG — RSS Migration`	`business_description`	`PASTE_YOUR_BUSINESS_DESCRIPTION` Your business description
`CONFIG — RSS Migration`	`telegram_chat_id`	`PASTE_YOUR_TELEGRAM_CHAT_ID` Your telegram chat id
`CONFIG — Google Sheets`	`spreadsheet_id`	`PASTE_YOUR_SPREADSHEET_ID` Your spreadsheet id
`CONFIG — AI Scoring`	`business_description`	`PASTE_YOUR_BUSINESS_DESCRIPTION` Your business description
`CONFIG — Notifications`	`telegram_chat_id`	`PASTE_YOUR_TELEGRAM_CHAT_ID` Your telegram chat id

How this workflow starts

Schedule Trigger: Runs every hours.

↓ Download reddit-rss-migration-monitor.json

← All templates