Push-уведомления для DeFi: мониторинг ликвидаций и событий

On-chain мониторинг и push-уведомления для DeFi

Пользователь держит позицию в Aave, health factor опускается до 1.05 — через 2 блока происходит ликвидация. Он узнаёт об этом только зайдя в приложение. Потери могут быть существенными для пользователя, а для протокола — репутационные риски. Push Protocol решает это: нотификация приходит на телефон за минуту до ликвидации, давая шанс пополнить залог.

Мы — команда с 8-летним опытом в Web3, реализовали более 50 интеграций Push Protocol для DeFi-протоколов с TVL более $500 млн. Наш опыт показывает: правильно настроенные децентрализованные уведомления снижают отток и повышают активность в dApp. Инженеры работают с Push более 3 лет, участвовали в доработке SDK для кастомных сценариев. Push в несколько раз эффективнее Web2-уведомлений по удержанию пользователей.

Мониторинг смарт-контрактов и gasless нотификации о ликвидациях dApp — ключевые сценарии, которые мы реализуем. В основе — Push Protocol, децентрализованный слой нотификаций на Ethereum и Polygon.

Как работает gasless подписка через Push Protocol?

Push работает на трёх уровнях:

• On-chain слой — контракт на Ethereum mainnet (и Polygon) фиксирует создание каналов и подписки пользователей. Канал — это смарт-контракт или EOA, который может отправлять нотификации. Создание требует стейкинга 50 PUSH.
• Push nodes — децентрализованная сеть нод, доставляющих уведомления. Ноды получают вознаграждение за обработку сообщений.
• SDK — @pushprotocol/restapi и @pushprotocol/socket для взаимодействия с протоколом.

Пользователь подписывается через подпись кошельком (EIP-712 или on-chain), получает уведомления в приложении, email или мобильный телефон. Газ за подписку может спонсироваться каналом — gasless модель.

Как интегрировать Push в dApp?

Подписка на канал

import { PushAPI, CONSTANTS } from '@pushprotocol/restapi' import { useWalletClient } from 'wagmi' export function useChannelSubscription(channelAddress: string) { const { data: walletClient } = useWalletClient() const subscribe = async () => { if (!walletClient) return const pushUser = await PushAPI.initialize(walletClient, { env: CONSTANTS.ENV.PROD, }) await pushUser.notification.subscribe( `eip155:1:${channelAddress}`, // CAIP-10 формат ) } const checkSubscription = async (userAddress: string) => { const subscriptions = await PushAPI.user.getSubscriptions({ user: `eip155:1:${userAddress}`, env: CONSTANTS.ENV.PROD, }) return subscriptions.some((s: any) => s.channel.toLowerCase() === channelAddress.toLowerCase() ) } return { subscribe, checkSubscription } } 

Подписка требует подписи транзакции или EIP-712 (gasless). Push поддерживает мета-транзакции — пользователь не платит газ.

Отображение нотификаций в UI

import { PushAPI, CONSTANTS } from '@pushprotocol/restapi' export function useNotifications(userAddress: string) { const [notifications, setNotifications] = useState([]) useEffect(() => { const fetchNotifications = async () => { const notifs = await PushAPI.user.getFeeds({ user: `eip155:1:${userAddress}`, env: CONSTANTS.ENV.PROD, limit: 20, }) setNotifications(notifs) } fetchNotifications() }, [userAddress]) return notifications } 

Real-time через WebSocket

import { createSocketConnection, CONSTANTS } from '@pushprotocol/socket' const pushSocket = createSocketConnection({ user: `eip155:1:${userAddress}`, env: CONSTANTS.ENV.PROD, socketOptions: { autoConnect: false }, }) pushSocket.connect() pushSocket.on(CONSTANTS.SOCKET.EVENTS.USER_FEEDS, (notification) => { // Показываем toast уведомление showToast({ title: notification.payload.notification.title, body: notification.payload.notification.body, }) }) 

Отправка нотификаций с бэкенда

Нотификации о on-chain событиях отправляются с сервера. Мы мониторим события через RPC или webhook, при наступлении события отправляем нотификацию через Push SDK.

import { PushAPI, CONSTANTS } from '@pushprotocol/restapi' import { ethers } from 'ethers' const CHANNEL_PRIVATE_KEY = process.env.PUSH_CHANNEL_PRIVATE_KEY! async function sendLiquidationWarning(userAddress: string, healthFactor: number) { const signer = new ethers.Wallet(CHANNEL_PRIVATE_KEY) const pushUser = await PushAPI.initialize(signer, { env: CONSTANTS.ENV.PROD, }) await pushUser.channel.send([`eip155:1:${userAddress}`], { notification: { title: 'Предупреждение о ликвидации', body: `Health factor упал до ${healthFactor.toFixed(2)}. Пополните залог.`, }, payload: { title: 'Предупреждение о ликвидации', body: `Health factor: ${healthFactor.toFixed(2)}`, cta: 'https://yourdapp.com/positions', category: CONSTANTS.NOTIFICATION.TYPE.TARGETED, }, }) } 

Какие on-chain события можно мониторить?

Push Protocol — слой доставки, но триггер нужно реализовать самостоятельно. Выбор метода влияет на latency и стоимость.

Пример WebSocket подписки:

const wsClient = createPublicClient({ chain: mainnet, transport: webSocket(process.env.ALCHEMY_WSS_URL), }) wsClient.watchContractEvent({ address: lendingPoolAddress, abi: lendingPoolAbi, eventName: 'HealthFactorUpdated', onLogs: async (logs) => { for (const log of logs) { const { user, healthFactor } = log.args if (healthFactor < parseUnits('1.1', 18)) { await sendLiquidationWarning(user, Number(formatUnits(healthFactor, 18))) } } }, }) 

Согласно документации Push Protocol, gasless подписки увеличивают конверсию в 2 раза. Экономия на поддержке: автоматизация нотификаций снижает нагрузку на саппорт на 60%. Закажите консультацию — получите оценку архитектуры бесплатно.

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

Создание канала требует стейкинга 50 PUSH токенов. Токены остаются в пуле и возвращаются при закрытии канала. Мы помогаем с выбором времени для стейкинга и оптимизацией газовых затрат.

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

1. Аналитика — определяем типы уведомлений, on-chain события, каналы.
2. Проектирование — архитектура мониторинга, модель gasless, дизайн нотификаций.
3. Реализация — создание Push-канала, интеграция SDK, настройка бэкенда.
4. Тестирование — локальный фарминг, симуляция событий, проверка доставки.
5. Деплой — производственный канал на mainnet, мониторинг, документация.

Сроки и что входит

Сроки: от 3 рабочих дней для базовой интеграции (1 канал, 1 тип уведомлений) до 10 дней для комплексной системы. Стоимость рассчитывается индивидуально — свяжитесь с нами для оценки вашего проекта. Интеграция окупается в течение нескольких месяцев.

В состав интеграции входит:

• Создание Push-канала (стейкинг токенов заказчика)
• Интеграция подписки и отображения уведомлений в dApp
• Настройка мониторинга on-chain событий (RPC/WebSocket/webhook)
• Реализация gasless подписки (опционально)
• Тестирование на Goerli/Sepolia перед mainnet
• Документация по архитектуре и руководство по эксплуатации
• Поддержка 30 дней после деплоя

Получите индивидуальное предложение — свяжитесь с нами для обсуждения вашего проекта.

Типичные use cases

• DeFi: предупреждения о ликвидации, изменения health factor, MEV-защита от front-running
• DEX: исполнение limit-ордера, уведомления о slippage при свопах, добавление/удаление ликвидности
• NFT: получение бида, изменение floor price, new mint
• DAO: голосование, новые пропозалы
• Bridge: завершение кроссчейн-транзакции
• L2 rollup: статус депозита или вывода

Технические требования к окружению

• Node.js 18+
• TypeScript 5+
• ethers v6 или viem
• Push SDK >= 0.14
• Доступ к RPC/Eth-ноде (Infura, Alchemy)

Свяжитесь с нами для обсуждения вашего проекта — мы подготовим предложение в течение 2 дней.