Setup marketting listeners

Author: AchoArnold

api/pkg/di/container.go

@@ -143,6 +143,8 @@ func NewContainer(projectID string, version string) (container *Container) {
 	container.RegisterDiscordRoutes()
 	container.RegisterDiscordListeners()
 
+	container.RegisterMarketingListeners()
+
 	// this has to be last since it registers the /* route
 	container.RegisterSwaggerRoutes()
 
@@ -1173,6 +1175,20 @@ func (container *Container) RegisterDiscordListeners() {
 	}
 }
 
+// RegisterMarketingListeners registers event listeners for listeners.MarketingListener
+func (container *Container) RegisterMarketingListeners() {
+	container.logger.Debug(fmt.Sprintf("registering listeners for %T", listeners.MarketingListener{}))
+	_, routes := listeners.NewMarketingListener(
+		container.Logger(),
+		container.Tracer(),
+		container.MarketingService(),
+	)
+
+	for event, handler := range routes {
+		container.EventDispatcher().Subscribe(event, handler)
+	}
+}
+
 // RegisterIntegration3CXListeners registers event listeners for listeners.Integration3CXListener
 func (container *Container) RegisterIntegration3CXListeners() {
 	container.logger.Debug(fmt.Sprintf("registering listeners for %T", listeners.Integration3CXListener{}))

api/pkg/listeners/marketing_listener.go

@@ -0,0 +1,54 @@
+package listeners
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/NdoleStudio/httpsms/pkg/events"
+	"github.com/NdoleStudio/httpsms/pkg/services"
+	"github.com/NdoleStudio/httpsms/pkg/telemetry"
+	cloudevents "github.com/cloudevents/sdk-go/v2"
+	"github.com/palantir/stacktrace"
+)
+
+// MarketingListener handled marketing events
+type MarketingListener struct {
+	logger  telemetry.Logger
+	tracer  telemetry.Tracer
+	service *services.MarketingService
+}
+
+// NewMarketingListener creates a new instance of MarketingListener
+func NewMarketingListener(
+	logger telemetry.Logger,
+	tracer telemetry.Tracer,
+	service *services.MarketingService,
+) (l *MarketingListener, routes map[string]events.EventListener) {
+	l = &MarketingListener{
+		logger:  logger.WithService(fmt.Sprintf("%T", l)),
+		tracer:  tracer,
+		service: service,
+	}
+
+	return l, map[string]events.EventListener{
+		events.UserAccountDeleted: l.onUserAccountDeleted,
+	}
+}
+
+func (listener *MarketingListener) onUserAccountDeleted(ctx context.Context, event cloudevents.Event) error {
+	ctx, span := listener.tracer.Start(ctx)
+	defer span.End()
+
+	var payload events.UserAccountDeletedPayload
+	if err := event.DataAs(&payload); err != nil {
+		msg := fmt.Sprintf("cannot decode [%s] into [%T]", event.Data(), payload)
+		return listener.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
+	}
+
+	if err := listener.service.DeleteUser(ctx, payload.UserID); err != nil {
+		msg := fmt.Sprintf("cannot delete [sendgrid contact] for user [%s] on [%s] event with ID [%s]", payload.UserID, event.Type(), event.ID())
+		return listener.tracer.WrapErrorSpan(span, stacktrace.Propagate(err, msg))
+	}
+
+	return nil
+}