Fix notifying about new interactions

warp-contracts · Jun 5, 2023 · 052c007 · 052c007
1 parent 1461e5f
commit 052c007
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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 {