feat(sse): adding info logs

This commit is contained in:
2025-04-22 16:51:46 +01:00
parent 526044d1e3
commit 3cd60d4dfc

View File

@ -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)