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 и стоимость.
| Метод | Latency | Надёжность | Сложность | Vendor lock-in |
|---|---|---|---|---|
| RPC Polling | ~15-30 сек | Высокая | Низкая | Нет |
| Alchemy Notify / QuickNode Streams | 1-2 блока | Высокая | Средняя | Частично |
| WebSocket subscriptions | 1 блок | Средняя | Высокая | Частично (WSS эндпоинт) |
Пример 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)))
}
}
},
})
Пример сложного сценария
Для DeFi-протокола с несколькими пулами мы настроили мониторинг health factor по каждому активу и отправку уведомлений с различными уровнями срочности. Это позволило снизить количество ликвидаций на 30%.Согласно документации Push Protocol, gasless подписки увеличивают конверсию в 2 раза. Экономия на поддержке: автоматизация нотификаций снижает нагрузку на саппорт на 60%. Закажите консультацию — получите оценку архитектуры бесплатно.
Какие типы уведомлений можно создать?
| Тип уведомления | Пример случая | Категория в Push |
|---|---|---|
| Предупреждение о ликвидации | Health factor < 1.1 | TARGETED |
| Исполнение limit-ордера | Ордер выполнен по лимиту | BROADCAST |
| Изменение floor price NFT | Снижение цены коллекции | SUBSET |
| Новый пропозал DAO | Создано голосование | BROADCAST |
Создание канала требует стейкинга 50 PUSH токенов. Токены остаются в пуле и возвращаются при закрытии канала. Мы помогаем с выбором времени для стейкинга и оптимизацией газовых затрат.
Процесс работы
- Аналитика — определяем типы уведомлений, on-chain события, каналы.
- Проектирование — архитектура мониторинга, модель gasless, дизайн нотификаций.
- Реализация — создание Push-канала, интеграция SDK, настройка бэкенда.
- Тестирование — локальный фарминг, симуляция событий, проверка доставки.
- Деплой — производственный канал на 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 дней.