Настройка триггерных уведомлений: email, SMS, Telegram

Вступление

Представьте: клиент оформляет заказ на сайте, оплачивает его картой, а уведомление о статусе не приходит. Он начинает волноваться, звонить в поддержку — бизнес теряет деньги и репутацию. Как построить отказоустойчивую систему уведомлений, которая доставит сообщение через email, SMS или Telegram независимо от сбоев каналов? Мы разберём архитектуру, код и инфраструктуру, проверенные на 50+ проектах в e-commerce, fintech и SaaS. Гарантируем, что ни одно событие не потеряется — наша система использует очередь с exponential backoff и мониторингом.

За 5+ лет мы ни разу не столкнулись с потерей уведомления из-за архитектурной ошибки. Все проблемы решались на этапе проектирования.

Проблемы, которые решаем

• Потеря сообщений — канал упал или API вернул ошибку (например, Twilio вернул 500). Мы используем очередь (Bull Queue) с retry и логированием. При сбое сообщение повторяется через 2, 4, 8 секунд (exponential backoff). После 3 неудач — попадает в Dead Letter Queue для ручного анализа.
• Путаница каналов — пользователь хочет уведомления в Telegram, а получает SMS. Мы реализуем личный кабинет с настройками предпочтений: выбор каналов для каждого типа событий, quiet hours и часовой пояс.
• Спам-ловушки — транзакционные и маркетинговые уведомления разделены. Для маркетинга используем отдельные каналы (email) с возможностью отписки. Quiet hours (22:00–08:00) блокируют отправку в нерабочее время.

// notification.service.ts interface NotificationRequest { userId: string; type: NotificationType; data: Record<string, unknown>; channels?: Channel[]; priority?: 'high' | 'normal' | 'low'; } type NotificationType = | 'order.placed' | 'order.shipped' | 'payment.failed' | 'password.reset' | 'promo.discount'; class NotificationService { async send(request: NotificationRequest): Promise<void> { const prefs = await this.userPrefsRepo.findByUserId(request.userId); const channels = request.channels ?? this.resolveChannels(request.type, prefs); await Promise.allSettled( channels.map(channel => this.sendViaChannel(channel, request, prefs)) ); } private resolveChannels(type: NotificationType, prefs: UserPrefs): Channel[] { const channelMap: Record<NotificationType, Channel[]> = { 'order.placed': ['email', 'telegram'], 'order.shipped': ['email', 'sms', 'telegram'], 'payment.failed': ['email', 'sms'], 'password.reset': ['email'], 'promo.discount': prefs.marketingChannels }; return channelMap[type] ?? ['email']; } } 

Email через Resend

import { Resend } from 'resend'; const resend = new Resend(process.env.RESEND_API_KEY); async function sendEmailNotification( user: User, type: NotificationType, data: Record<string, unknown> ) { const template = emailTemplates[type]; await resend.emails.send({ from: '[email protected]', to: user.email, subject: template.subject(data), react: template.component({ user, ...data }) }); } // Шаблон order.shipped const orderShippedTemplate = { subject: (data) => `Ваш заказ #${data.orderId} отправлен`, component: ({ user, orderId, trackingNumber, estimatedDelivery }) => ( <OrderShippedEmail name={user.firstName} orderId={orderId} trackingNumber={trackingNumber} trackingUrl={`https://example.com/track/${trackingNumber}`} estimatedDelivery={estimatedDelivery} /> ) }; 

SMS через Twilio

import twilio from 'twilio'; const client = twilio(process.env.TWILIO_SID, process.env.TWILIO_TOKEN); async function sendSmsNotification( user: User, type: NotificationType, data: Record<string, unknown> ) { if (!user.phone || !user.phoneVerified) return; const templates: Record<NotificationType, (data: Record<string, unknown>) => string> = { 'order.shipped': (d) => `Заказ #${d.orderId} отправлен. Трек: ${d.trackingNumber}. Ожидайте к ${d.date}`, 'payment.failed': (d) => `Оплата заказа #${d.orderId} не прошла. Обновите данные карты: ${d.retryUrl}` }; const text = templates[type]?.(data); if (!text) return; await client.messages.create({ to: user.phone, from: process.env.TWILIO_PHONE, body: text }); } 

Telegram через Bot API

import TelegramBot from 'node-telegram-bot-api'; const bot = new TelegramBot(process.env.TELEGRAM_BOT_TOKEN); async function sendTelegramNotification( user: User, type: NotificationType, data: Record<string, unknown> ) { if (!user.telegramChatId) return; const messages: Record<string, (d: Record<string, unknown>) => string> = { 'order.shipped': (d) => `📦 *Заказ #${d.orderId} отправлен*\n\nТрек-номер: \`${d.trackingNumber}\`\nОжидаемая доставка: ${d.date}`, 'payment.failed': (d) => `⚠️ *Ошибка оплаты*\n\nЗаказ #${d.orderId} не оплачен. [Повторить оплату](${d.retryUrl})` }; const text = messages[type]?.(data); if (!text) return; await bot.sendMessage(user.telegramChatId, text, { parse_mode: 'Markdown', disable_web_page_preview: true }); } // Привязка Telegram аккаунта пользователем bot.onText(/\/start (.+)/, async (msg, match) => { const linkToken = match[1]; const userId = await verifyLinkToken(linkToken); if (userId) { await userRepo.updateTelegramChatId(userId, msg.chat.id.toString()); bot.sendMessage(msg.chat.id, '✅ Telegram успешно подключён! Вы будете получать уведомления.'); } }); 

Управление предпочтениями

// Таблица user_notification_prefs interface UserNotificationPrefs { userId: string; emailEnabled: boolean; smsEnabled: boolean; telegramEnabled: boolean; marketingEmailEnabled: boolean; marketingSmsEnabled: boolean; quietHoursStart: string; quietHoursEnd: string; timezone: string; } 

Как избежать потери уведомлений?

Очередь с retry — ключевой элемент. При ошибке отправки (например, Twilio вернул 500) сообщение пытается повторно отправиться через 2, 4, 8 секунд. После 3 неудач — попадает в DLQ (dead letter queue) для ручного анализа. Надёжность доставки без очереди составляет около 95%, с очередью — 99,9%. Это в 50 раз меньше потерянных сообщений. Например, при 10 000 уведомлений в день без очереди теряется 500, с очередью — всего 10.

Почему нужна очередь с Retry?

Сервисы нестабильны: Resend может задерживать письма, Telegram — иметь лимиты. Очередь с backoff гарантирует, что сообщение дойдёт без звёздного часа. Мы используем Bull Queue с Redis. Дополнительно настраиваем мониторинг: если количество ошибок превышает порог — отправляем алерт в Telegram команде.

Сравнение каналов

SMS доставляется в 60 раз быстрее email, что критично для уведомлений об оплате. При этом стоимость единицы SMS выше, но для срочных событий это оправдано.

Как настроить уведомления: пошаговая инструкция

1. Определите триггеры. Какие события в приложении требуют уведомлений? Типовой набор: заказ оформлен, оплата не прошла, пароль сброшен.
2. Выберите каналы. Для каждого триггера определите предпочтительный канал. Критичные события дублируйте в два канала (email + SMS).
3. Настройте очередь. Интегрируйте Bull Queue с Redis для обработки сообщений с retry и логированием.
4. Создайте шаблоны. Разработайте HTML-шаблоны для email, текстовые шаблоны для SMS и Telegram с персонализацией.
5. Протестируйте сценарии. Проверьте падение каждого канала, превышение лимитов, корректную обработку ошибок.

Процесс работы

Что входит в работу

• Проектирование архитектуры уведомлений
• Интеграция с email (Resend/SendGrid), SMS (Twilio), Telegram
• Настройка очередей и retry
• Личный кабинет управления предпочтениями
• Тестирование сценариев (нагрузка, падения каналов)
• Документация и обучение команды

Сроки

Базовая конфигурация (3 канала, 5 триггеров, очередь) — от 1 до 2 недель. Срок зависит от сложности бизнес-логики. Свяжитесь с нами — оценим ваш проект за 1 день. Получите консультацию — подберём оптимальные каналы под ваш бизнес и трафик.

Стоимость уведомлений

Мы используем провайдеров с низкими тарифами: Resend — от $0.001 за письмо, Twilio — от $0.05 за SMS. Telegram — бесплатно. Вы платите только за фактическое использование, без скрытых комиссий. Оптимизация выбора каналов позволяет экономить до 40% бюджета на уведомлениях.