From 052c007de9f858d2c8c6c6f3dfb949c594121a06 Mon Sep 17 00:00:00 2001 From: Jan Olszak Date: Mon, 5 Jun 2023 17:00:04 +0200 Subject: [PATCH] Fix notifying about new interactions --- .../model/sql_migrations/000460_interactions_notification.sql | 2 +- src/utils/streamer/streamer.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/utils/model/sql_migrations/000460_interactions_notification.sql b/src/utils/model/sql_migrations/000460_interactions_notification.sql index 22895c08..7522ef8a 100644 --- a/src/utils/model/sql_migrations/000460_interactions_notification.sql +++ b/src/utils/model/sql_migrations/000460_interactions_notification.sql @@ -23,7 +23,7 @@ BEGIN END IF; -- Neglect big interactions - SELECT pg_column_size(NEW.transaction) > 7950 INTO is_too_big; + SELECT pg_column_size(NEW.interaction) > 7950 INTO is_too_big; -- Skip if there's no forwarder listening SELECT EXISTS(SELECT pid FROM pg_stat_activity WHERE query='listen "interactions"') INTO is_forwarder_listening; diff --git a/src/utils/streamer/streamer.go b/src/utils/streamer/streamer.go index bd20f528..5addde0c 100644 --- a/src/utils/streamer/streamer.go +++ b/src/utils/streamer/streamer.go @@ -87,7 +87,7 @@ func (self *Streamer) Resume() (err error) { return } - self.Log.Info("Resume streamer") + self.Log.WithField("channel", self.channelName).Info("Resume streamer") err = self.connection.Listen(self.channelName) if err != nil {