Get bots from Strapi, check Redis for active polling, enqueue new bots for long polling

Long polling daemon for many Telegram bots. Each bot runs its own continuous getUpdates loop and emits events to n8n immediately. Errors (e.g. 401/403) go to the second output (Error).

Send and manage Telegram messages, chats, and files via Grammy

Принимает или отклоняет заявку пользователя на вступление в канал/группу. Используется после событий chat_join_request от Long Polling Trigger.

Converts HTML to plain text and Telegram MessageEntity array for sendMessage/caption

Detects Telegram message type from publication (media, buttons, content). Outputs type, sendKind, media, caption, reply_markup for use with Telegram Multi Actions or send nodes.

Fetch a single bot by ID or search/list bots with filters, populate, pagination, sort, and field selection

Преобразует перечень условий QueryBuilder (массив { field, operator, value, date_limit? }) в готовый блок WHERE с уже подставленными значениями — одна SQL-строка. Операторы: ==, !=, >, <, between, in. Подставляйте в запрос как {{ $json.whereClause }}, Query Parameters не нужны.

Прибавляет заданное количество минут к дате и времени в формате ISO 8601. Результат возвращается в ISO и в виде timestamp.

Connect to the Error output of Telegram Long Polling Trigger (or any node that outputs botId + error). Sends each item to a Slack channel using the given token.

Calls Campaign API select-message: returns packed message (Content, Bot, Media, Button) by language, bot and cursor. Uses Strapi API credentials (same base URL).

Calls Campaign API to fetch campaigns, optionally limited by daily time window via GET /api/campaigns/by-time?from=HH:MM&to=HH:MM. Uses Strapi API credentials (same base URL).

Calls Campaign API to fetch campaigns for a given bot via GET /api/campaigns/by-bot?bot_external_id=... Uses Strapi API credentials (same base URL).

Calls Strapi push-planner API ready-schedules: returns list of publications ready for push within the given time window. Input: utcDateTime (ISO) and windowMinutes.

Insert or update a user in n8n_content_runner by tg_chat_id (from Telegram parsed: from_id, chat_id)

Insert or update a bot in n8n_content_runner by tg_bot_id

Find campaign linked to user+bot in user_bot_interactions and update it with Strapi params (strapi_campaign_id, strapi_segment_id, welcome_template_id, main_template_id). Campaign is created at Link time with empty fields.

Link user+bot (creates empty campaign), Get state, or Update state

Get user_bot_interactions state by tg_chat_id + tg_bot_id or by user_id + bot_id

Update only blocked_at in user_bot_interactions by tg_chat_id + tg_bot_id or user_id + bot_id

Update only is_active for a bot by tg_bot_id (bot must already exist)

From user state and branches (welcome/main), compute state_check, current/next message per branch, next planned times, and is_last_in_branch

Sends delivery status for push/scheduled messages back to Strapi push-planner API via /api/push-planner/delivery-callback. Uses Strapi API credentials (same base URL).

Send all Telegram content types (text, media, video note, sticker, location, poll, dice, etc.) via Grammy. Supports URL, file_id, and n8n binary. Optional Redis rate limit, retry on 429, separate output for 403 (user blocked bot).