DB миграция: pg_notify триггер для webhook_updates

[plagness]

Phase 2: PostgreSQL LISTEN/NOTIFY триггер

Автоматическая нотификация при INSERT в webhook_updates для реалтайм стриминга.

Файлы

• db/init/18_realtime_notify.sql — новый

SQL

CREATE OR REPLACE FUNCTION notify_new_update() RETURNS TRIGGER AS $$
BEGIN
    PERFORM pg_notify('new_update', json_build_object(
        'id', NEW.id,
        'update_type', NEW.update_type,
        'chat_id', NEW.chat_id,
        'user_id', NEW.user_id,
        'update_id', NEW.update_id
    )::text);
    RETURN NEW;
END;
$$ LANGUAGE plpgsql;

CREATE TRIGGER trg_webhook_updates_notify
    AFTER INSERT ON webhook_updates
    FOR EACH ROW
    EXECUTE FUNCTION notify_new_update();

Контекст

Предпосылка для SSE стриминга. pg_notify работает с минимальным overhead (~100 байт per notification).