fix(event): fix nil pointer

ncarlier · Apr 17, 2023 · 0a1e7f3 · 0a1e7f3
1 parent ff02508
commit 0a1e7f3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/pkg/event/dispatcher/dispatcher.go b/pkg/event/dispatcher/dispatcher.go
@@ -3,6 +3,8 @@ package dispatcher
 import (
 	"fmt"
 	"net/url"
+
+	"github.com/rs/zerolog/log"
 )
 
 // Dispatcher is the event dispatcher interface
@@ -22,6 +24,7 @@ func NewDispatcher(uri string) (Dispatcher, error) {
 
 	switch u.Scheme {
 	case "http", "https":
+		log.Info().Str("component", "event").Str("uri", u.Redacted()).Msg("using HTTP external event broker")
 		return newHTTPDispatcher(u)
 	default:
 		return nil, fmt.Errorf("unsupported event dispatcher: %s", u.Scheme)

diff --git a/pkg/service/event.go b/pkg/service/event.go
@@ -27,9 +27,11 @@ const (
 )
 
 func (reg *Registry) registerEventHandlers() {
-	reg.events.Subscribe(EventCreateUser, newExternalEventHandler(reg.dispatcher))
-	reg.events.Subscribe(EventUpdateUser, newExternalEventHandler(reg.dispatcher))
-	reg.events.Subscribe(EventDeleteUser, newExternalEventHandler(reg.dispatcher))
+	if reg.dispatcher != nil {
+		reg.events.Subscribe(EventCreateUser, newExternalEventHandler(reg.dispatcher))
+		reg.events.Subscribe(EventUpdateUser, newExternalEventHandler(reg.dispatcher))
+		reg.events.Subscribe(EventDeleteUser, newExternalEventHandler(reg.dispatcher))
+	}
 	reg.events.Subscribe(EventCreateArticle, newCreateArticleMetricEventHandler())
 	reg.events.Subscribe(EventCreateArticle, newNotificationEventHandler(reg))
 }