chore: rename events/consumers.go -> events/event_consumer.go

flanksource · Jul 25, 2023 · 6045e54 · 6045e54
1 parent 6f1cf3c
commit 6045e54
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 18 deletions.
diff --git a/events/consumers.go → events/event_consumer.go b/events/consumers.go → events/event_consumer.go
@@ -130,15 +130,14 @@ func (e *EventConsumer) listenToPostgresNotify(pgNotify chan bool) {
 		if err != nil {
 			return fmt.Errorf("error listening to database notifications: %v", err)
 		}
-		logger.Infof("listening to database notifications")
+		logger.Debugf("listening to database notifications")
 
 		for {
-			notification, err := conn.Conn().WaitForNotification(ctx)
+			_, err := conn.Conn().WaitForNotification(ctx)
 			if err != nil {
 				return fmt.Errorf("error listening to database notifications: %v", err)
 			}
 
-			logger.Tracef("Received database notification: %+v", notification)
 			pgNotify <- true
 		}
 	}
@@ -182,18 +181,3 @@ func (e *EventConsumer) Listen() {
 		}
 	}
 }
-
-func StartConsumers(gormDB *gorm.DB, config Config) {
-	allConsumers := []EventConsumer{
-		NewTeamConsumer(gormDB),
-		NewNotificationConsumer(gormDB),
-		NewResponderConsumer(gormDB),
-	}
-	if config.UpstreamPush.Valid() {
-		allConsumers = append(allConsumers, NewUpstreamPushConsumer(gormDB, config))
-	}
-
-	for _, c := range allConsumers {
-		go c.Listen()
-	}
-}
diff --git a/events/events.go b/events/events.go
@@ -4,6 +4,7 @@ import (
 	"time"
 
 	"github.com/flanksource/incident-commander/api"
+	"gorm.io/gorm"
 )
 
 const (
@@ -46,3 +47,18 @@ const (
 type Config struct {
 	UpstreamPush api.UpstreamConfig
 }
+
+func StartConsumers(gormDB *gorm.DB, config Config) {
+	allConsumers := []EventConsumer{
+		NewTeamConsumer(gormDB),
+		NewNotificationConsumer(gormDB),
+		NewResponderConsumer(gormDB),
+	}
+	if config.UpstreamPush.Valid() {
+		allConsumers = append(allConsumers, NewUpstreamPushConsumer(gormDB, config))
+	}
+
+	for _, c := range allConsumers {
+		go c.Listen()
+	}
+}