diff --git a/backend/events.go b/backend/events.go index b97628e..5af6841 100644 --- a/backend/events.go +++ b/backend/events.go @@ -99,6 +99,8 @@ func ListenProcessingImageStatus(db *sql.DB, eventManager *EventManager) { }) defer listener.Close() + logger := createLogger("Image Status 📊", os.Stdout) + if err := listener.Listen("new_processing_image_status"); err != nil { panic(err) } @@ -109,11 +111,14 @@ func ListenProcessingImageStatus(db *sql.DB, eventManager *EventManager) { stringUuid := data.Extra[0:36] status := data.Extra[36:] + logger.Info("Update", "id", stringUuid, "status", status) + imageListener, exists := eventManager.listeners[stringUuid] if !exists { continue } + logger.Info("Sending...") imageListener <- status close(imageListener)