From 059234d41686d9c523805039f71e1f3f271d66d7 Mon Sep 17 00:00:00 2001 From: Christoph Date: Mon, 21 Apr 2025 16:42:35 +0200 Subject: [PATCH] never publish pointer payloads on message bus (#411) --- internal/app/users/user_manager.go | 10 +++++----- internal/app/wireguard/wireguard.go | 2 +- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/app/users/user_manager.go b/internal/app/users/user_manager.go index fd4d3a5..9511e32 100644 --- a/internal/app/users/user_manager.go +++ b/internal/app/users/user_manager.go @@ -82,7 +82,7 @@ func (m Manager) RegisterUser(ctx context.Context, user *domain.User) error { return err } - m.bus.Publish(app.TopicUserRegistered, createdUser) + m.bus.Publish(app.TopicUserRegistered, *createdUser) return nil } @@ -294,8 +294,8 @@ func (m Manager) ActivateApi(ctx context.Context, id domain.UserIdentifier) (*do return nil, fmt.Errorf("update failure: %w", err) } - m.bus.Publish(app.TopicUserUpdated, user) - m.bus.Publish(app.TopicUserApiEnabled, user) + m.bus.Publish(app.TopicUserUpdated, *user) + m.bus.Publish(app.TopicUserApiEnabled, *user) return user, nil } @@ -322,8 +322,8 @@ func (m Manager) DeactivateApi(ctx context.Context, id domain.UserIdentifier) (* return nil, fmt.Errorf("update failure: %w", err) } - m.bus.Publish(app.TopicUserUpdated, user) - m.bus.Publish(app.TopicUserApiDisabled, user) + m.bus.Publish(app.TopicUserUpdated, *user) + m.bus.Publish(app.TopicUserApiDisabled, *user) return user, nil } diff --git a/internal/app/wireguard/wireguard.go b/internal/app/wireguard/wireguard.go index e0673e3..46ded30 100644 --- a/internal/app/wireguard/wireguard.go +++ b/internal/app/wireguard/wireguard.go @@ -112,7 +112,7 @@ func (m Manager) connectToMessageBus() { _ = m.bus.Subscribe(app.TopicUserDeleted, m.handleUserDeletedEvent) } -func (m Manager) handleUserCreationEvent(user *domain.User) { +func (m Manager) handleUserCreationEvent(user domain.User) { if !m.cfg.Core.CreateDefaultPeerOnCreation { return }