From 4677e724ee754c75086f8832858dc254816bbc6c Mon Sep 17 00:00:00 2001
From: Philipp Heckel <pheckel@datto.com>
Date: Fri, 29 Oct 2021 08:29:27 -0400
Subject: [PATCH] Re-add "message" as event type

---
 server/message.go | 3 ++-
 server/server.go  | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/server/message.go b/server/message.go
index 514ebac1..eb9a4bfd 100644
--- a/server/message.go
+++ b/server/message.go
@@ -6,6 +6,7 @@ import "time"
 const (
 	openEvent      = "open"
 	keepaliveEvent = "keepalive"
+	messageEvent = "message"
 )
 
 // message represents a message published to a topic
@@ -39,5 +40,5 @@ func newKeepaliveMessage() *message {
 
 // newDefaultMessage is a convenience method to create a notification message
 func newDefaultMessage(msg string) *message {
-	return newMessage("", msg)
+	return newMessage(messageEvent, msg)
 }
diff --git a/server/server.go b/server/server.go
index 5e2369d8..caa6534a 100644
--- a/server/server.go
+++ b/server/server.go
@@ -219,7 +219,7 @@ func (s *Server) handleSubscribeSSE(w http.ResponseWriter, r *http.Request) erro
 		if err := json.NewEncoder(&buf).Encode(&msg); err != nil {
 			return "", err
 		}
-		if msg.Event != "" {
+		if msg.Event != messageEvent {
 			return fmt.Sprintf("event: %s\ndata: %s\n", msg.Event, buf.String()), nil // Browser's .onmessage() does not fire on this!
 		}
 		return fmt.Sprintf("data: %s\n", buf.String()), nil