Пишу веб приложение, которое уведомляет пользователя об изменениях произошедших в базе данных сайта. Веб сервер этого сайта отслеживает изменения и рассылает их всем подключенным клиентам. Мне нужно лишь принять изменение, обработать и отправить юзеру
Собственно проблема: измениться может запись о товаре, мне нужно уведомить лишь при изменении одного параметра - цены. На сервере реализованы атомарные сохранения - изменения летят в клиентов, при каждой введенной новой цифре.
Мне нужно реализовать механизм задержки перед отправкой по следующей схеме:
- получаю изменение по товару с id=1 -> жду какое-то время -> если новых изменений по конкретно этотму товару не было -> отправляю изменение
- если же изменения были -> обновляю таймер ожидания
*если товар другой, то для него запускается такая-же логика, но свой таймер
Основная логика приложения:
public static async Task Main()
{
// событие, которое висит на соединении и отлавливает уведомления от сервера
Connection.On<NotificationData>("Entity", async message=>
{
// здесь обработка уведомления
// ...
// результатом получаю id и разницу в цене
// в итоге я понимаю что изменилась цена и у какого товара (его id) она изменилась
var info = $"На товар c id = {id} цена выросла на {priceDiff} рублей"
await SendMessage(info)
// этим SendMessage() я как раз отправляю информацию пользователям
}
}
Посоветуйте, как лучше реализовать такую схему ожидания. О каких технологиях нужно почитать для этого? Я пока даже не знаю, что и где искать(