January 22, 2026

YouTube + Telegram: competitor briefings that arrive

Lisa Granqvist Partner Workflow Automation Expert

Get a free AI assessment → ⬇️ Use template

Your competitors ship new messaging quietly. A YouTube video here, a “small” blog post there. And you only notice after a prospect repeats their talking points back to you on a sales call.

This is where YouTube Telegram briefings help most. Market researchers feel it first, but founders and content leads get dragged into the same scramble. You need the shift, the context, and the source link, without spending your mornings scrubbing timelines.

This n8n workflow monitors competitor YouTube channels and RSS feeds, pulls transcripts when needed, runs an AI analysis, then drops a clean briefing into Telegram and archives the full report in Notion. You’ll see what it does, what it replaces, and how to set it up without getting lost in the weeds.

How This Automation Works

The full n8n workflow, from trigger to final output:

n8n Workflow Template: YouTube + Telegram: competitor briefings that arrive

Click to explore

flowchart LR

    subgraph sg0["Schedule Flow"]
        direction LR
        n0@{ icon: "mdi:play-circle", form: "rounded", label: "Schedule Trigger", pos: "b", h: 48 }
        n1@{ icon: "mdi:cog", form: "rounded", label: "YouTube (Competitor A): Sear..", pos: "b", h: 48 }
        n2@{ icon: "mdi:swap-horizontal", form: "rounded", label: "Apify - Get Dataset Items", pos: "b", h: 48 }
        n3["<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/>Code - Normalize Apify Items"]
        n4["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/merge.svg' width='40' height='40' /></div><br/>Merge (YouTube) (Mode Append)"]
        n5@{ icon: "mdi:cog", form: "rounded", label: "YouTube (Competitor B): Sear..", pos: "b", h: 48 }
        n6@{ icon: "mdi:swap-horizontal", form: "rounded", label: "Apify - Run an Actor", pos: "b", h: 48 }
        n7@{ icon: "mdi:cog", form: "rounded", label: "RSS Feed (Competitor A): Tec..", pos: "b", h: 48 }
        n8@{ icon: "mdi:cog", form: "rounded", label: "RSS Feed (Competitor B): n8n..", pos: "b", h: 48 }
        n9["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/merge.svg' width='40' height='40' /></div><br/>Merge (RSS): Mode Append"]
        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/merge.svg' width='40' height='40' /></div><br/>Merge (All Data): Mode Append"]
        n11["<div style='background:#f5f5f5;padding:10px;border-radius:8px;display:inline-block;border:1px solid #e0e0e0'><img src='https://flowpast.com/wp-content/uploads/n8n-workflow-icons/code.svg' width='40' height='40' /></div><br/>Code (Data Prep)"]
        n12@{ icon: "mdi:robot", form: "rounded", label: "Google Gemini - Generate", 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/telegram.svg' width='40' height='40' /></div><br/>Telegram: Send Message"]
        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/>Code (Build Notion Blocks)"]
        n15["<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/>Notion - Create Database Page"]
        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/httprequest.dark.svg' width='40' height='40' /></div><br/>HTTP Request (Notion Append .."]
        n17["<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/>Code - Robust Parser (Gemini.."]
        n11 --> n12
        n0 --> n1
        n0 --> n5
        n0 --> n7
        n0 --> n8
        n6 --> n2
        n12 --> n17
        n9 --> n10
        n2 --> n3
        n14 --> n16
        n3 --> n10
        n10 --> n11
        n4 --> n6
        n15 --> n14
        n8 --> n9
        n17 --> n15
        n17 --> n13
        n7 --> n9
        n1 --> n4
        n5 --> n4
    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 n12 ai
    class n2,n6 decision
    class n15 database
    class n16 api
    class n3,n11,n14,n17 code
    classDef customIcon fill:none,stroke:none
    class n3,n4,n9,n10,n11,n13,n14,n15,n16,n17 customIcon

The Problem: Competitor updates are easy to miss

Keeping up with competitor messaging sounds simple until you try to do it consistently. You skim RSS headlines, open a few posts, and tell yourself you’ll “watch the video later.” Later rarely happens. Even when you do watch, the key claims are buried at minute 17, and the “real” shift is in tone, positioning, or what they’re suddenly not saying. Then you’re stuck summarizing it for the team, answering follow-up questions, and hunting down the link again when someone asks for proof. It’s exhausting. Honestly, it’s also avoidable.

The friction compounds. Here’s where it breaks down in real teams.

You end up tracking competitors in multiple places (YouTube, blogs, newsletters), so something always slips through.
Watching a single 20-minute video to find two meaningful minutes burns focus you needed for actual strategy work.
Manual summaries drift from person to person, which means your team debates the recap instead of the implication.
There’s no durable archive, so “What did they say last month?” becomes a time-wasting scavenger hunt.

The Solution: Automated briefings from YouTube + RSS

This workflow turns competitor monitoring into a recurring, structured output your team can rely on. On a schedule, n8n checks specific YouTube channels and RSS feeds you define. When it finds something new, it pulls the content into one combined “intelligence bundle.” For YouTube, it goes a level deeper than metadata by using Apify to fetch the full transcript, so the analysis is based on what was actually said. Then an AI model (Google Gemini in this template) reviews the consolidated text, identifies themes, positioning changes, tone, and likely intent, and produces a clear briefing. Finally, the workflow posts the executive summary to Telegram with source links, and stores the full report in Notion for long-term research and comparisons.

It starts with scheduled monitoring of your chosen channels and feeds. Next, transcripts and articles are merged and cleaned so the AI sees one coherent input. Then the workflow generates a structured summary and ships it to Telegram while also creating a Notion record you can search later.

What You Get: Automation vs. Results

What This Workflow Automates

Results You’ll Get

Checks competitor YouTube channels and RSS feeds on a schedule.
Pulls full YouTube transcripts via Apify so analysis isn’t guesswork.
Merges, normalizes, and prepares a single payload for AI analysis.
Sends a Telegram briefing and archives a full report in Notion automatically.

Save about 3 hours a week that would have gone to “keeping up.”
Catch positioning shifts early, while they’re still fresh and actionable.
Get consistent summaries in one format, which reduces internal back-and-forth.
Share source links fast, so stakeholders trust the briefing.
Build a searchable Notion history for quarterly strategy and messaging audits.

Example: What This Looks Like

Say you track 2 competitor YouTube channels and 2 RSS feeds, and you check each source three times a week. Manually, that’s maybe 10 minutes per source just to scan (about 2 hours weekly), plus another 30 minutes when a new video drops and you try to find the “important” parts (easily pushing it to about 3 hours). With this workflow, you spend about 5 minutes up front setting the sources, then your ongoing work is just reading the Telegram briefings. Most weeks, that’s a few minutes total, and you still get a full Notion archive for later.

What You’ll Need

n8n instance (try n8n Cloud free)
Self-hosting option if you prefer (Hostinger works well)
Apify to scrape YouTube transcripts.
Google Gemini to analyze messaging and positioning.
Telegram to deliver briefings to your team.
Notion to store full reports in a database.
YouTube Data API key (get it from Google Cloud Console).

Skill level: Intermediate. You’ll paste API keys, pick channel IDs and feed URLs, and do light editing of prompts.

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

How It Works

Scheduled monitoring kicks it off. On a set cadence, n8n checks your competitor YouTube channels and your chosen RSS feeds for anything new.

Content gets consolidated and cleaned. RSS items are merged together, YouTube items are merged together, then both streams combine into one input. A preparation step normalizes the data so summaries stay consistent across sources.

Transcript deep dive and AI analysis happens in the middle. New videos trigger an Apify actor that retrieves transcripts, then Google Gemini analyzes the combined content to extract messaging, intent, and strategic shifts (not just a bland recap).

Outputs go to Telegram and Notion. Telegram receives a concise, readable briefing with direct links. Notion gets the full report as formatted blocks, attached to a database record you can search and compare over time.

You can easily modify the analysis prompt to focus on pricing changes or feature launches based on your needs. See the full implementation guide below for customization options.

Step-by-Step Implementation Guide

Step 1: Configure the Schedule Trigger

This workflow starts on a daily schedule and then fans out to multiple sources in parallel.

Add the Scheduled Run Launcher node as your trigger.
Set Rule → Interval → Trigger At Hour to 8.
Confirm the parallel execution: Scheduled Run Launcher outputs to Fetch YouTube Rival A, Fetch YouTube Rival B, Read RSS Rival A, and Read RSS Rival B in parallel.

If you need a different daily time, adjust the Trigger At Hour value in Scheduled Run Launcher.

Step 2: Connect YouTube and RSS Inputs

Pull the latest competitor videos and RSS articles, then merge the streams.

In Fetch YouTube Rival A, set Resource to video and Limit to 3.
Set Filters → Channel ID to [YOUR_ID] and Filters → Published After to {{ new Date(Date.now() - 24*60*60*1000).toISOString() }}.
Credential Required: Connect your youTubeOAuth2Api credentials in Fetch YouTube Rival A.
Repeat the same settings in Fetch YouTube Rival B and connect youTubeOAuth2Api credentials there as well.
In Read RSS Rival A, set URL to [YOUR_RSS_URL].
In Read RSS Rival B, set URL to [YOUR_RSS_URL].
Confirm Fetch YouTube Rival A and Fetch YouTube Rival B both feed into Combine YouTube Streams.
Confirm Read RSS Rival A and Read RSS Rival B both feed into Combine RSS Streams.

⚠️ Common Pitfall: Replace all [YOUR_ID] and [YOUR_RSS_URL] placeholders before testing, or the workflow will return empty results.

Step 3: Configure Apify Transcript Enrichment and Merging

Use Apify to retrieve transcripts and normalize YouTube data alongside RSS content.

In Run Apify Actor, set Actor ID to [YOUR_ID].
Set Custom Body to { "videoUrls": ["{{'https://www.youtube.com/watch?v=' + $json.id.videoId}}"] }.
Credential Required: Connect your apifyOAuth2Api credentials in Run Apify Actor.
In Retrieve Apify Dataset, set Dataset ID to {{ $json.defaultDatasetId }}.
Credential Required: Connect your apifyOAuth2Api credentials in Retrieve Apify Dataset.
Keep Normalize Apify Results connected from Retrieve Apify Dataset to standardize transcripts and metadata.
Confirm Normalize Apify Results and Combine RSS Streams both feed into Merge Content Sources.

Step 4: Set Up Insight Processing and AI Generation

Build a compact context payload, generate insights via Gemini, and parse the JSON response.

Keep Prepare Insight Payload connected from Merge Content Sources to assemble the competitor context.
In Generate Gemini Insights, ensure JSON Output is enabled and Simplify is set to false.
Credential Required: Connect your googlePalmApi credentials in Generate Gemini Insights.
Verify the prompt in Generate Gemini Insights references {{ $json.competitorContext }} and the date from {{$node["Prepare Insight Payload"].json.date}}.
Keep Parse Gemini JSON connected to handle JSON parsing and Telegram HTML sanitization.
Confirm parallel execution: Parse Gemini JSON outputs to both Create Notion Record and Send Telegram Briefing in parallel.

The Prepare Insight Payload node uses workflow static data for deduplication. If you copy the workflow, run it once to initialize static data.

Step 5: Configure Output Destinations (Notion and Telegram)

Send the daily briefing to Telegram and store a structured report in Notion.

In Send Telegram Briefing, set Chat ID to [YOUR_ID] and Text to {{ $json.telegram_html }}.
Credential Required: Connect your telegramApi credentials in Send Telegram Briefing.
In Create Notion Record, set Database ID to [YOUR_ID].
Set Properties → date to {{ $json.meta.date }} and Properties → Name to {{ $json.report_title }}.
Credential Required: Connect your notionApi credentials in Create Notion Record.
Keep Assemble Notion Blocks connected to build the page content and then connect it to Append Notion Children.
In Append Notion Children, set URL to {{`https://api.notion.com/v1/blocks/${$node["Create Notion Record"].json.id}/children`}}.
Set JSON Body to {{ JSON.stringify({ children: $node["Assemble Notion Blocks"].json.children }) }} and keep the method as PATCH.
Credential Required: Connect your notionApi credentials in Append Notion Children.

⚠️ Common Pitfall: If Telegram messages fail, check that the HTML is valid and your Parse Gemini JSON node is not stripping required tags.

Step 6: Test and Activate Your Workflow

Run the workflow once to validate data flow, then activate it for daily automation.

Click Execute Workflow to run a manual test from Scheduled Run Launcher.
Confirm that Send Telegram Briefing posts a formatted HTML message with sources.
Verify a new page is created by Create Notion Record and enriched by Append Notion Children.
When successful, toggle Active to enable scheduled runs.

🔒

Unlock Full Step-by-Step Guide

Get the complete implementation guide + downloadable template

Common Gotchas

YouTube Data API credentials can expire or lack the right quota. If things break, check your Google Cloud Console API key and quota limits 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.
Apify runs can fail silently if the actor or dataset permissions aren’t right. Open the Apify run log and confirm the dataset actually contains transcripts before blaming the AI step.

Frequently Asked Questions

How long does it take to set up this YouTube Telegram briefings automation?

About an hour if you already have your API keys.

Do I need coding skills to automate YouTube competitor briefings?

No. You’ll mostly connect accounts and paste keys. The only “technical” part is copying channel IDs and a Notion database ID.

Is n8n free to use for this YouTube Telegram briefings 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 Apify usage and your Gemini API costs.

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 YouTube Telegram briefings workflow for pricing-change alerts?

Yes, and it’s mostly a prompt change. Update the instructions inside the “Generate Gemini Insights” node to prioritize pricing pages, packaging language, and upgrade paths, then adjust the “Parse Gemini JSON” mapping so Telegram shows a dedicated “Pricing signals” section. Many teams also tweak the “Prepare Insight Payload” code to include only the newest items each run, which keeps analysis focused.

Why is my Telegram connection failing in this workflow?

Usually it’s a revoked bot token or the bot not being added to the target chat. Regenerate the Telegram bot token in BotFather, update the credential in n8n, and confirm the chat ID is correct. Also check that the message formatting you’re sending is valid HTML, since Telegram is picky.

How many items can this YouTube Telegram briefings automation handle?

On a typical small-team setup, dozens of new posts and a handful of videos per day is fine.

Is this YouTube Telegram briefings automation better than using Zapier or Make?

Often, yes, because this is not a simple “new item → send message” zap. You’re merging sources, calling Apify, preparing payloads, parsing structured AI output, and writing formatted Notion blocks, which is the kind of multi-step logic that gets awkward (and expensive) on simpler tools. n8n also gives you the option to self-host, so you’re not paying per tiny step once volume grows. Zapier or Make can still be fine if you only want link-forwarding with a basic summary and no archive. If you’re unsure, Talk to an automation expert and describe your monitoring volume and team needs.

Once this is running, competitor monitoring stops being a background anxiety. You get the briefing, the link, and the archive, then you move on.

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": "",
"meta": {
"instanceId": "e1027c0000ff73721f13adf659144d984ec671f8eab36289ee8785cf6f248f14"
},
"name": "Automated Competitor Intelligence Pipeline",
"tags": [],
"nodes": [
{
"id": "flowpast-topbar-12161",
"name": "Flowpast Branding",
"type": "n8n-nodes-base.stickyNote",
"position": [
0,
20
],
"parameters": {
"color": 7,
"width": 1310,
"height": 80,
"content": "## Flowpast.com | Automation Workflow Library\n**\ud83d\udcd6 Full tutorial & setup guide:** flowpast.com"
},
"typeVersion": 1
},
{
"id": "871f2e3f-b311-4fb0-8c0f-430365aa3259",
"name": "Scheduled Run Launcher",
"type": "n8n-nodes-base.scheduleTrigger",
"position": [
1210,
200
],
"parameters": {
"rule": {
"interval": [
{
"triggerAtHour": 8
}
]
}
},
"typeVersion": 1.3
},
{
"id": "94f99a23-6074-4a45-ac2f-7c345f4b6ea0",
"name": "Fetch YouTube Rival A",
"type": "n8n-nodes-base.youTube",
"position": [
1015,
120
],
"parameters": {
"limit": 3,
"filters": {
"channelId": "[YOUR_ID]",
"publishedAfter": "={{ new Date(Date.now() - 24*60*60*1000).toISOString() }}"
},
"options": {
"order": "date"
},
"resource": "video"
},
"credentials": {
"youTubeOAuth2Api": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1
},
{
"id": "8f8876ba-5810-4a51-af01-d961546fc9bb",
"name": "Retrieve Apify Dataset",
"type": "@apify/n8n-nodes-apify.apify",
"position": [
420,
250
],
"parameters": {
"resource": "Datasets",
"datasetId": "={{ $json.defaultDatasetId }}",
"authentication": "apifyOAuth2Api"
},
"credentials": {
"apifyOAuth2Api": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1
},
{
"id": "ef9f0fb5-710b-4de5-9a52-4d623bda4cd4",
"name": "Normalize Apify Results",
"type": "n8n-nodes-base.code",
"position": [
210,
235
],
"parameters": {
"jsCode": "const ytNodeName = \"Combine YouTube Streams\";\n\nconst ytItems = $items(ytNodeName).map(i => i.json);\nconst apifyItems = $input.all();\n\nfunction getVideoIdFromUrl(url = \"\") {\n  try {\n    const u = new URL(url);\n    if (u.hostname.includes(\"youtube.com\")) return u.searchParams.get(\"v\");\n    if (u.hostname === \"youtu.be\") return u.pathname.replace(\"/\", \"\") || null;\n  } catch (e) {}\n  return null;\n}\n\nfunction pickYtVideoId(yt) {\n  return (\n    yt?.id?.videoId ||\n    yt?.videoId ||\n    yt?.snippet?.resourceId?.videoId ||\n    getVideoIdFromUrl(yt?.url) ||\n    null\n  );\n}\n\n// Build lookup from YT by videoId\nconst ytById = {};\nfor (const yt of ytItems) {\n  const vid = pickYtVideoId(yt);\n  if (vid) ytById[vid] = yt;\n}\n\n// Normalize Apify items, match YT by videoId (not by idx)\nreturn apifyItems.map(({ json: ap }) => {\n  const apVideoId =\n    ap?.id ||\n    getVideoIdFromUrl(ap?.url) ||\n    null;\n\n  const yt = apVideoId ? (ytById[apVideoId] || {}) : {};\n\n  const transcriptOnly = (ap?.transcript_only_text || \"\").toString().trim();\n  const fallbackDesc = (yt?.snippet?.description || yt?.description || \"\").toString().trim();\n  const content = (transcriptOnly || fallbackDesc).slice(0, 12000);\n\n  const title = ap?.title || yt?.snippet?.title || yt?.title || \"\";\n  const url = ap?.url || (apVideoId ? `https://www.youtube.com/watch?v=${apVideoId}` : \"\");\n  const publishedAt = yt?.snippet?.publishedAt || yt?.publishedAt || \"\";\n\n  return {\n    json: {\n      type: \"YT_TRANSCRIPT\",\n      videoId: apVideoId,\n      title,\n      url,\n      publishedAt,\n      content,\n      source: \"apify_best_youtube_transcripts_scraper\",\n      hasTranscript: Boolean(transcriptOnly),\n      // debug fields (optional, can be deleted)\n      _match: {\n        matchedBy: \"videoId\",\n        ytFound: Boolean(apVideoId && ytById[apVideoId]),\n      }\n    }\n  };\n});"
},
"typeVersion": 2
},
{
"id": "a34e7448-f0ed-4a78-b649-7d9bea1e810b",
"name": "Combine YouTube Streams",
"type": "n8n-nodes-base.merge",
"position": [
770,
240
],
"parameters": [],
"typeVersion": 3.2
},
{
"id": "c9ff9afd-a5de-4154-bf47-dcf2256d69d3",
"name": "Fetch YouTube Rival B",
"type": "n8n-nodes-base.youTube",
"position": [
1000,
320
],
"parameters": {
"limit": 3,
"filters": {
"channelId": "[YOUR_ID]",
"publishedAfter": "={{ new Date(Date.now() - 24*60*60*1000).toISOString() }}"
},
"options": {
"order": "date"
},
"resource": "video"
},
"credentials": {
"youTubeOAuth2Api": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1
},
{
"id": "74a46e76-53b4-416a-9023-6a1e0bb7849a",
"name": "Run Apify Actor",
"type": "@apify/n8n-nodes-apify.apify",
"position": [
590,
230
],
"parameters": {
"actorId": {
"__rl": true,
"mode": "list",
"value": "[YOUR_ID]",
"cachedResultUrl": "",
"cachedResultName": "Best Youtube Transcripts Scraper (scrape-creators/best-youtube-transcripts-scraper)"
},
"customBody": "={\n  \"videoUrls\": [\"{{'https://www.youtube.com/watch?v=' + $json.id.videoId}}\"]\n}",
"authentication": "apifyOAuth2Api"
},
"credentials": {
"apifyOAuth2Api": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1
},
{
"id": "9dc7cbf4-32a5-495e-9136-ed2cc967931f",
"name": "Read RSS Rival A",
"type": "n8n-nodes-base.rssFeedRead",
"position": [
1025,
500
],
"parameters": {
"url": "[YOUR_RSS_URL]",
"options": {
"ignoreSSL": true
}
},
"typeVersion": 1.2
},
{
"id": "c7cb3520-3d62-4676-b0cd-31115a13b4f7",
"name": "Read RSS Rival B",
"type": "n8n-nodes-base.rssFeedRead",
"position": [
995,
660
],
"parameters": {
"url": "[YOUR_RSS_URL]",
"options": {
"ignoreSSL": true
}
},
"typeVersion": 1.2
},
{
"id": "8227ba9d-9f2f-48df-a3a7-72d64a13db8a",
"name": "Combine RSS Streams",
"type": "n8n-nodes-base.merge",
"position": [
760,
560
],
"parameters": [],
"typeVersion": 3.2
},
{
"id": "a4ea4a59-d8aa-4fc9-b80b-6dae596ddc93",
"name": "Merge Content Sources",
"type": "n8n-nodes-base.merge",
"position": [
430,
390
],
"parameters": [],
"typeVersion": 3.2
},
{
"id": "b1936f26-0828-4bb5-b88a-6c1d328a7d99",
"name": "Prepare Insight Payload",
"type": "n8n-nodes-base.code",
"position": [
230,
390
],
"parameters": {
"jsCode": "function stripHtml(html = \"\") {\n  return html\n    .replace(/<script[\\s\\S]*?<\\/script>/gi, \"\")\n    .replace(/<style[\\s\\S]*?<\\/style>/gi, \"\")\n    .replace(/<\\/?[^>]+(>|$)/g, \" \")\n    .replace(/\\s+/g, \" \")\n    .trim();\n}\n\nfunction clip(text = \"\", max = 6000) {\n  const t = (text || \"\").toString().trim();\n  return t.length > max ? t.slice(0, max) + \"\u2026\" : t;\n}\n\nfunction toMs(x) {\n  const ms = Date.parse(x || \"\");\n  return Number.isNaN(ms) ? 0 : ms;\n}\n\n// FIX: The Node runtime code is missing this.getWorkflowStaticData()\nconst staticData =\n  (typeof getWorkflowStaticData === \"function\" && getWorkflowStaticData(\"global\")) ||\n  (typeof $getWorkflowStaticData === \"function\" && $getWorkflowStaticData(\"global\"));\n\nif (!staticData) throw new Error(\"Static Data API not available in this Code node runtime\");\n\nstaticData.seen = staticData.seen || {};\n\nconst now = new Date();\nconst nowIso = now.toISOString();\nconst SEEN_TTL_DAYS = 7;\nconst TTL_MS = SEEN_TTL_DAYS * 24 * 60 * 60 * 1000;\n\n// ===== Token control =====\nconst MAX_ITEMS_TOTAL = 8;           // Gemini limits purchases to a maximum of 8 items per day.\nconst MAX_YT_ITEMS = 2;              // Prioritize the two most recent videos\nconst RSS_HOT_POOL = 10;             // Top 10 hottest RSS posts\nconst MAX_CONTENT_RSS = 1400;        // A sharp cut to reduce the token price\nconst MAX_CONTENT_YT = 1800;         // transcript also cuts strongly\n\nfunction isRss(json) {\n  return Boolean(\n    json.link &&\n      (json.pubDate ||\n        json.isoDate ||\n        json.content ||\n        json.contentSnippet ||\n        json.description ||\n        json[\"content:encoded\"])\n  );\n}\n\nfunction competitorTagFromUrl(url = \"\") {\n  if (url.includes(\"techcrunch.com\")) return \"techcrunch\";\n  if (url.includes(\"n8n.io\")) return \"n8n\";\n  return \"unknown\";\n}\n\n// \u201cHot score\u201d heuristic for RSS: recency + keyword + source boost\nfunction rssHotScore(item) {\n  const ageMs = now.getTime() - toMs(item.publishedAt);\n  const ageHours = ageMs > 0 ? ageMs / (1000 * 60 * 60) : 9999;\n\n  // Recency score: 0..1 (highest new)\n  const recency = Math.max(0, 1 - ageHours / 48); // trong 48h \u0111\u1ea7u l\u00e0 quan tr\u1ecdng\n\n  const title = (item.title || \"\").toLowerCase();\n  const content = (item.content || \"\").toLowerCase();\n\n  // Keyword weight (depending on your domain, you can adjust it further)\n  const kw = [\n    { re: /\\b(ai|agent|llm|genai|rag)\\b/i, w: 0.30 },\n    { re: /\\b(robot|humanoid|automation)\\b/i, w: 0.25 },\n    { re: /\\b(hack|breach|cyber|security|ransom)\\b/i, w: 0.25 },\n    { re: /\\b(acquire|acquisition|merge|funding|raise|valuation|ipo)\\b/i, w: 0.20 },\n    { re: /\\b(nvidia|google|microsoft|meta|apple|openai|anthropic)\\b/i, w: 0.15 },\n    { re: /\\b(regulation|ban|lawsuit|court|policy)\\b/i, w: 0.15 },\n  ];\n\n  let kwScore = 0;\n  for (const k of kw) {\n    if (k.re.test(title) || k.re.test(content)) kwScore += k.w;\n  }\n\n  // Source boost: TechCrunch tends to be more \"market-moving\".\n  const sourceBoost = item.competitorTag === \"techcrunch\" ? 0.10 : 0.03;\n\n  // Penalty for the song \"stale / evergreen\" in the style of \"how to track santa ... 2022\"\n  const stalePenalty = /\\b(2020|2021|2022|2023)\\b/i.test(title) ? 0.25 : 0;\n\n  return recency + kwScore + sourceBoost - stalePenalty;\n}\n\nconst inputItems = $input.all();\n\n// --- Normalize each item into a common schema ---\nconst normalized = inputItems.map(({ json }) => {\n  if (!isRss(json)) {\n    const competitorTag = json.competitorTag || \"unknown\";\n    const videoId = json.videoId || json.id;\n    const url = json.url || (videoId ? `https://www.youtube.com/watch?v=${videoId}` : \"\");\n\n    return {\n      id: `yt:${videoId || url}`,\n      competitorTag,\n      sourceType: \"youtube\",\n      title: json.title || \"\",\n      url,\n      publishedAt: json.publishedAt || \"\",\n      content: clip(json.content || \"\", MAX_CONTENT_YT),\n    };\n  }\n\n  const title = json.title || \"\";\n  const url = json.link || \"\";\n  const publishedAt = json.isoDate || json.pubDate || \"\";\n  const rawContent =\n    json[\"content:encoded\"] ||\n    json.content ||\n    json.contentSnippet ||\n    json.description ||\n    \"\";\n\n  const competitorTag = competitorTagFromUrl(url);\n\n  return {\n    id: `rss:${url || title}`,\n    competitorTag,\n    sourceType: \"rss\",\n    title,\n    url,\n    publishedAt,\n    content: clip(stripHtml(rawContent), MAX_CONTENT_RSS),\n  };\n});\n\n// --- Dedup using staticData.seen with TTL ---\nconst fresh = [];\nfor (const item of normalized) {\n  const key = item.id;\n  const seenAt = staticData.seen[key];\n\n  if (seenAt) {\n    const seenMs = Date.parse(seenAt);\n    if (!Number.isNaN(seenMs) && Date.now() - seenMs < TTL_MS) continue;\n  }\n\n  staticData.seen[key] = nowIso;\n  fresh.push(item);\n}\n\n// --- Prune old keys ---\nfor (const [key, ts] of Object.entries(staticData.seen)) {\n  const ms = Date.parse(ts);\n  if (Number.isNaN(ms) || Date.now() - ms > TTL_MS) delete staticData.seen[key];\n}\n\nif (fresh.length === 0) {\n  return [{\n    json: {\n      competitorContext: `DATE=${nowIso.slice(0, 10)} | ITEMS=0\\nTASK=No new items in last 24h.`,\n      sources: [],\n      stats: { input: inputItems.length, normalized: normalized.length, fresh: 0 },\n      competitorTag: \"mixed\",\n      date: nowIso.slice(0, 10),\n    }\n  }];\n}\n\n// ===== Reduce items to control token size =====\n// Sort YT newest first\nconst yt = fresh\n  .filter(x => x.sourceType === \"youtube\")\n  .sort((a, b) => toMs(b.publishedAt) - toMs(a.publishedAt))\n  .slice(0, MAX_YT_ITEMS);\n\n// RSS: calculates the hot score -> gets the top 10 hottest topics.\nconst rssAll = fresh.filter(x => x.sourceType === \"rss\");\nconst rssHotTop10 = rssAll\n  .map(x => ({ ...x, _hotScore: rssHotScore(x) }))\n  .sort((a, b) => (b._hotScore || 0) - (a._hotScore || 0))\n  .slice(0, RSS_HOT_POOL)\n  .map(({ _hotScore, ...rest }) => rest);\n\n// Final list: prioritize YouTube (max 2), then fill in the top 10 hottest RSS feeds until you have 8.\nconst final = [...yt];\nfor (const r of rssHotTop10) {\n  if (final.length >= MAX_ITEMS_TOTAL) break;\n  final.push(r);\n}\n\n// If there is still a shortage (low RSS), fill from the remaining (YT/RSS) according to recency.\nif (final.length < MAX_ITEMS_TOTAL) {\n  const finalIds = new Set(final.map(x => x.id));\n  const remainder = fresh\n    .filter(x => !finalIds.has(x.id))\n    .sort((a, b) => toMs(b.publishedAt) - toMs(a.publishedAt));\n\n  for (const it of remainder) {\n    if (final.length >= MAX_ITEMS_TOTAL) break;\n    final.push(it);\n  }\n}\n\n// --- Build compact context (decrease token) ---\nconst lines = [];\nlines.push(`DATE=${nowIso.slice(0, 10)} | ITEMS=${final.length}`);\nlines.push(`TASK=insight>summary; detect positioning; propose 1 counter-tactic.`);\nlines.push(\"\");\n\nfinal.forEach((it, idx) => {\n  lines.push(`--#${idx + 1} ${it.sourceType.toUpperCase()} ${it.competitorTag}`);\n  if (it.publishedAt) lines.push(`P=${it.publishedAt}`);\n  lines.push(`T=${it.title}`);\n  lines.push(`U=${it.url}`);\n  lines.push(`C=${(it.content || \"\").replace(/\\s+/g, \" \").trim()}`);\n  lines.push(\"\");\n});\n\nconst competitorTags = Array.from(new Set(final.map(x => x.competitorTag))).filter(Boolean);\nconst pageCompetitorTag = competitorTags.length === 1 ? competitorTags[0] : \"mixed\";\n\nreturn [{\n  json: {\n    competitorContext: lines.join(\"\\n\"),\n    sources: final,\n    stats: { input: inputItems.length, normalized: normalized.length, fresh: final.length },\n    competitorTag: pageCompetitorTag,\n    date: nowIso.slice(0, 10),\n    // debug optional:\n    hotPool: {\n      rssCandidates: rssAll.length,\n      rssHotTop10: rssHotTop10.length,\n      ytPicked: yt.length,\n      final: final.length,\n    }\n  }\n}];"
},
"typeVersion": 2
},
{
"id": "dd74498e-fecc-4d59-9002-457c04bf37b1",
"name": "Generate Gemini Insights",
"type": "@n8n/n8n-nodes-langchain.googleGemini",
"position": [
90,
380
],
"parameters": {
"modelId": {
"__rl": true,
"mode": "list",
"value": "models/gemini-2.5-flash",
"cachedResultName": "models/gemini-2.5-flash"
},
"options": {
"temperature": 0.3,
"systemMessage": "You are a Competitor Intelligence Analyst."
},
"messages": {
"values": [
{
"content": "=Read this content (Blogs & Video Transcripts):\n\n{{ $json.competitorContext }}\n\nDeep Analysis:\n1) Core Message: What is the ONE main thing they want the audience to believe today?\n2) Hidden Strategy: Detect keywords or angles they are pushing (e.g., 'Cheap', 'Enterprise', 'AI-first').\n3) Counter-Tactic: Suggest 1 specific content angle for us to beat them.\n\nReturn STRICT JSON only (no markdown fences), schema:\n{\n  \"report_title\": \"Daily Intel: {{$node[\"Prepare Insight Payload\"].json.date}}\",\n  \"summary\": \"Short summary\",\n  \"strategy_markdown\": \"## Strategy\\n* Point 1\\n* Point 2\",\n  \"telegram_html\": \"<b>Title</b>...\"\n}\n\nConstraints:\n- telegram_html < 4000 chars. NO <br>, NO <ul>, NO <li>; use \\n and \u2022 bullets only; only tags allowed: <b>, <i>, <u>, <s>, <code>, <pre>.\n- Include source links at the bottom of telegram_html (use URLs from the context). No <br>, <ul>, <li>; use newline + bullet.\n- Focus on insights, not just summary"
}
]
},
"simplify": false,
"jsonOutput": true
},
"credentials": {
"googlePalmApi": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1
},
{
"id": "93d83705-5488-4d28-af76-9920c4eee683",
"name": "Send Telegram Briefing",
"type": "n8n-nodes-base.telegram",
"position": [
0,
150
],
"webhookId": "78785cc6-9b9b-4495-bca5-e42303cd0258",
"parameters": {
"text": "={{ $json.telegram_html }}",
"chatId": "[YOUR_ID]",
"additionalFields": {
"parse_mode": "HTML"
}
},
"credentials": {
"telegramApi": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 1.2
},
{
"id": "2e89d05d-3791-4464-81a9-288d4d806ce0",
"name": "Assemble Notion Blocks",
"type": "n8n-nodes-base.code",
"position": [
10,
520
],
"parameters": {
"jsCode": "function normalizeInline(s) {\n  let t = String(s ?? \"\");\n\n  // Convert basic HTML bold/italic to markdown\n  t = t.replace(/<\\/?b>/gi, \"**\");\n  t = t.replace(/<\\/?strong>/gi, \"**\");\n  t = t.replace(/<\\/?i>/gi, \"*\");\n  t = t.replace(/<\\/?em>/gi, \"*\");\n  t = t.replace(/<br\\s*\\/?>/gi, \"\\n\");\n\n  // Strip any remaining html tags\n  t = t.replace(/<[^>]+>/g, \"\");\n\n  return t;\n}\n\nfunction pushText(arr, content, annotations = {}, link = null) {\n  if (!content) return;\n  arr.push({\n    type: \"text\",\n    text: {\n      content,\n      ...(link ? { link: { url: link } } : {}),\n    },\n    annotations: {\n      bold: !!annotations.bold,\n      italic: !!annotations.italic,\n      strikethrough: !!annotations.strikethrough,\n      underline: !!annotations.underline,\n      code: !!annotations.code,\n      color: \"default\",\n    },\n  });\n}\n\n// Inline markdown parser: **bold**, *italic*, `code`, URLs\nfunction inlineToRichText(input) {\n  const s0 = normalizeInline(input);\n  const out = [];\n\n  const tokenRegex =\n    /(`[^`]+`)|(\\*\\*[^*]+\\*\\*)|(\\*[^*]+\\*)|(https?:\\/\\/[^\\s)>\"']+)/g;\n\n  let last = 0;\n  let m;\n  while ((m = tokenRegex.exec(s0)) !== null) {\n    if (m.index > last) pushText(out, s0.slice(last, m.index));\n\n    const tok = m[0];\n\n    if (tok.startsWith(\"`\") && tok.endsWith(\"`\")) {\n      pushText(out, tok.slice(1, -1), { code: true });\n    } else if (tok.startsWith(\"**\") && tok.endsWith(\"**\")) {\n      pushText(out, tok.slice(2, -2), { bold: true });\n    } else if (tok.startsWith(\"*\") && tok.endsWith(\"*\")) {\n      pushText(out, tok.slice(1, -1), { italic: true });\n    } else if (tok.startsWith(\"http\")) {\n      pushText(out, tok, {}, tok);\n    } else {\n      pushText(out, tok);\n    }\n\n    last = tokenRegex.lastIndex;\n  }\n\n  if (last < s0.length) pushText(out, s0.slice(last));\n\n  return out.filter(x => x?.text?.content?.length);\n}\n\nfunction heading2(text) {\n  return {\n    object: \"block\",\n    type: \"heading_2\",\n    heading_2: { rich_text: inlineToRichText(text) },\n  };\n}\n\nfunction divider() {\n  return { object: \"block\", type: \"divider\", divider: {} };\n}\n\nfunction paragraph(text) {\n  const t = String(text ?? \"\").trim();\n  if (!t) return null;\n  return {\n    object: \"block\",\n    type: \"paragraph\",\n    paragraph: { rich_text: inlineToRichText(t) },\n  };\n}\n\nfunction bullet(text) {\n  const t = String(text ?? \"\").trim();\n  if (!t) return null;\n  return {\n    object: \"block\",\n    type: \"bulleted_list_item\",\n    bulleted_list_item: { rich_text: inlineToRichText(t) },\n  };\n}\n\nfunction toggle(title, children = []) {\n  return {\n    object: \"block\",\n    type: \"toggle\",\n    toggle: {\n      rich_text: inlineToRichText(title),\n      children,\n    },\n  };\n}\n\nfunction extractUrls(text) {\n  const s = String(text ?? \"\");\n  const urls = s.match(/https?:\\/\\/[^\\s)>\"']+/g) || [];\n  const seen = new Set();\n  const out = [];\n  for (const u of urls) {\n    const clean = u.replace(/[.,;]+$/g, \"\");\n    if (!seen.has(clean)) {\n      seen.add(clean);\n      out.push(clean);\n    }\n  }\n  return out;\n}\n\nfunction mdToBlocks(md) {\n  const blocks = [];\n  const lines = String(md ?? \"\").split(/\\r?\\n/);\n\n  for (const raw of lines) {\n    const line = raw.trim();\n    if (!line) continue;\n\n    if (line.startsWith(\"## \")) {\n      blocks.push(heading2(line.replace(/^##\\s+/, \"\")));\n      continue;\n    }\n\n    if (line.startsWith(\"* \") || line.startsWith(\"- \")) {\n      blocks.push(bullet(line.replace(/^(\\*|\\-)\\s+/, \"\")));\n      continue;\n    }\n\n    blocks.push(paragraph(line));\n  }\n\n  return blocks.filter(Boolean);\n}\n\n// ===== Input =====\nconst rp = $node[\"Parse Gemini JSON\"].json;\nconst summary = rp.summary;\nconst strategyMd = rp.strategy_markdown;\nconst telegramHtml = rp.telegram_html;\n\n// ===== Build page content (WITH ALL 3 EMOJI OPTIONS) =====\nconst children = [];\n\n// Option #1: Emoji headings\nchildren.push(heading2(\"\ud83e\udde0 Summary\"));\nchildren.push(paragraph(summary || \"(no summary)\"));\nchildren.push(divider());\n\n// Strategy section\nconst strategyBlocks = mdToBlocks(strategyMd);\nchildren.push(heading2(\"\ud83e\udde9 Strategy\"));\n\n// Option #3: Emoji in toggle title\nchildren.push(toggle(\"\ud83d\udc47 Open strategy details\", strategyBlocks));\nchildren.push(divider());\n\n// Sources\nconst urls = extractUrls(telegramHtml);\nif (urls.length) {\n  children.push(heading2(\"\ud83d\udd17 Sources\"));\n\n  // Option #2: Emoji prefix for source bullets\n  for (const u of urls.slice(0, 30)) children.push(bullet(`\ud83d\udd17 ${u}`));\n}\n\nreturn [{ json: { children } }];"
},
"typeVersion": 2
},
{
"id": "37f4bff9-7a2c-4a39-a9cb-0b84e33dc403",
"name": "Create Notion Record",
"type": "n8n-nodes-base.notion",
"position": [
0,
330
],
"parameters": {
"simple": false,
"options": {
"iconType": "emoji"
},
"resource": "databasePage",
"databaseId": {
"__rl": true,
"mode": "id",
"value": "[YOUR_ID]"
},
"propertiesUi": {
"propertyValues": [
{
"key": "date|date",
"date": "={{ $json.meta.date }}",
"includeTime": false
},
{
"key": "Name|title",
"title": "={{ $json.report_title }}"
}
]
}
},
"credentials": {
"notionApi": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 2.2
},
{
"id": "ede0979a-12e6-431f-a7ea-52f7f8553c92",
"name": "Append Notion Children",
"type": "n8n-nodes-base.httpRequest",
"position": [
20,
690
],
"parameters": {
"url": "={{`https://api.notion.com/v1/blocks/${$node[\"Create Notion Record\"].json.id}/children`}}",
"method": "PATCH",
"options": [],
"jsonBody": "={{ JSON.stringify({ children: $node[\"Assemble Notion Blocks\"].json.children }) }}",
"sendBody": true,
"sendHeaders": true,
"specifyBody": "json",
"authentication": "predefinedCredentialType",
"headerParameters": {
"parameters": [
{
"name": "Notion-Version",
"value": "2022-06-28"
},
{
"name": "Content-Type",
"value": "application/json"
}
]
},
"nodeCredentialType": "notionApi"
},
"credentials": {
"notionApi": {
"id": "credential-id",
"name": ""
}
},
"typeVersion": 4.3
},
{
"id": "b7cdd909-272a-4c99-8db2-f4906eaba205",
"name": "Parse Gemini JSON",
"type": "n8n-nodes-base.code",
"position": [
80,
220
],
"parameters": {
"jsCode": "function extractJsonObject(text) {\n  const t = (text ?? \"\").toString().trim();\n  const s = t.indexOf(\"{\");\n  const e = t.lastIndexOf(\"}\");\n  if (s === -1 || e === -1 || e <= s) {\n    throw new Error(\"No JSON object found in Gemini output\");\n  }\n  return t.slice(s, e + 1);\n}\n\nfunction sanitizeTelegramHtml(html) {\n  let s = (html ?? \"\").toString();\n\n  // Telegram HTML DOES NOT support <br>, <ul>, <li>\n  s = s.replace(/<br\\s*\\/?>/gi, \"\\n\");\n  s = s.replace(/<\\/?ul[^>]*>/gi, \"\\n\");\n  s = s.replace(/<li[^>]*>\\s*/gi, \"\u2022 \");\n  s = s.replace(/<\\/li>\\s*/gi, \"\\n\");\n\n  // Convert links <a href=\"url\">text</a> => \"text: url\"\n  // (Telegram supports <a>, but Gemini often truncates mid-tag => easiest is to remove <a> entirely)\n  s = s.replace(\n    /<a\\s+[^>]*href\\s*=\\s*\"(.*?)\"[^>]*>(.*?)<\\/a>/gi,\n    (_, url, text) => {\n      const t = (text ?? \"\").replace(/<[^>]+>/g, \"\").trim();\n      return t ? `${t}: ${url}` : url;\n    }\n  );\n\n  // Remove ALL tags except Telegram-safe subset\n  // Allowed: b/strong, i/em, u/ins, s/strike/del, code, pre\n  s = s.replace(\n    /<(?!\\/?(b|strong|i|em|u|ins|s|strike|del|code|pre)\\b)[^>]*>/gi,\n    \"\"\n  );\n\n  // Normalize newlines\n  s = s.replace(/\\r\\n/g, \"\\n\");\n  s = s.replace(/\\n{3,}/g, \"\\n\\n\").trim();\n\n  // If Gemini left unbalanced tags, safest is to strip ALL remaining tags\n  // (Telegram will fail on unbalanced tags)\n  const openB = (s.match(/<b>/gi) || []).length;\n  const closeB = (s.match(/<\\/b>/gi) || []).length;\n  const openI = (s.match(/<i>/gi) || []).length;\n  const closeI = (s.match(/<\\/i>/gi) || []).length;\n  const openU = (s.match(/<u>/gi) || []).length;\n  const closeU = (s.match(/<\\/u>/gi) || []).length;\n\n  if (openB !== closeB || openI !== closeI || openU !== closeU) {\n    s = s.replace(/<[^>]+>/g, \"\");\n  }\n\n  return s;\n}\n\nfunction safeTruncate(text, limit = 3800) {\n  if (!text) return text;\n  if (text.length <= limit) return text;\n\n  // Cut near a newline to avoid ugly cut\n  const cut = text.slice(0, limit - 30);\n  const lastNl = cut.lastIndexOf(\"\\n\");\n  const out = (lastNl > 200 ? cut.slice(0, lastNl) : cut).trim();\n\n  return out + \"\\n\\n(\u2026truncated)\";\n}\n\n// ---- Read Gemini node output (robust paths) ----\nconst j = $json;\n\nconst candidatesText =\n  j?.candidates?.[0]?.content?.parts?.map(p => p.text).filter(Boolean).join(\"\\n\");\n\nconst possible =\n  candidatesText ||\n  j?.text ||\n  j?.output ||\n  j?.response ||\n  j?.data ||\n  j?.result ||\n  j?.content ||\n  j?.message ||\n  (typeof j === \"string\" ? j : \"\");\n\nconst raw = extractJsonObject(possible);\n\nlet parsed;\ntry {\n  parsed = JSON.parse(raw);\n} catch (err) {\n  throw new Error(`JSON.parse failed: ${err.message}\\nRAW_JSON:\\n${raw}`);\n}\n\n// ---- Sanitize + truncate for Telegram HTML parse mode ----\nparsed.telegram_html = safeTruncate(sanitizeTelegramHtml(parsed.telegram_html), 4000);\n\n// ---- Add meta (keep it the same) ----\nreturn [{\n  json: {\n    ...parsed,\n    meta: {\n      generatedAt: new Date().toISOString(),\n      competitorTag: $node[\"Prepare Insight Payload\"].json.competitorTag,\n      date: $node[\"Prepare Insight Payload\"].json.date,\n    }\n  }\n}];"
},
"typeVersion": 2
}
],
"active": false,
"pinData": [],
"settings": {
"executionOrder": "v1"
},
"versionId": "",
"connections": {
"Prepare Insight Payload": {
"main": [
[
{
"node": "Generate Gemini Insights",
"type": "main",
"index": 0
}
]
]
},
"Scheduled Run Launcher": {
"main": [
[
{
"node": "Fetch YouTube Rival A",
"type": "main",
"index": 0
},
{
"node": "Fetch YouTube Rival B",
"type": "main",
"index": 0
},
{
"node": "Read RSS Rival A",
"type": "main",
"index": 0
},
{
"node": "Read RSS Rival B",
"type": "main",
"index": 0
}
]
]
},
"Run Apify Actor": {
"main": [
[
{
"node": "Retrieve Apify Dataset",
"type": "main",
"index": 0
}
]
]
},
"Generate Gemini Insights": {
"main": [
[
{
"node": "Parse Gemini JSON",
"type": "main",
"index": 0
}
]
]
},
"Combine RSS Streams": {
"main": [
[
{
"node": "Merge Content Sources",
"type": "main",
"index": 1
}
]
]
},
"Retrieve Apify Dataset": {
"main": [
[
{
"node": "Normalize Apify Results",
"type": "main",
"index": 0
}
]
]
},
"Assemble Notion Blocks": {
"main": [
[
{
"node": "Append Notion Children",
"type": "main",
"index": 0
}
]
]
},
"Normalize Apify Results": {
"main": [
[
{
"node": "Merge Content Sources",
"type": "main",
"index": 0
}
]
]
},
"Merge Content Sources": {
"main": [
[
{
"node": "Prepare Insight Payload",
"type": "main",
"index": 0
}
]
]
},
"Combine YouTube Streams": {
"main": [
[
{
"node": "Run Apify Actor",
"type": "main",
"index": 0
}
]
]
},
"Create Notion Record": {
"main": [
[
{
"node": "Assemble Notion Blocks",
"type": "main",
"index": 0
}
]
]
},
"Read RSS Rival B": {
"main": [
[
{
"node": "Combine RSS Streams",
"type": "main",
"index": 1
}
]
]
},
"Parse Gemini JSON": {
"main": [
[
{
"node": "Create Notion Record",
"type": "main",
"index": 0
},
{
"node": "Send Telegram Briefing",
"type": "main",
"index": 0
}
]
]
},
"Read RSS Rival A": {
"main": [
[
{
"node": "Combine RSS Streams",
"type": "main",
"index": 0
}
]
]
},
"Fetch YouTube Rival A": {
"main": [
[
{
"node": "Combine YouTube Streams",
"type": "main",
"index": 0
}
]
]
},
"Fetch YouTube Rival B": {
"main": [
[
{
"node": "Combine YouTube Streams",
"type": "main",
"index": 1
}
]
]
}
}
}