public_git
/
wg-portal
mirror of https://github.com/h44z/wg-portal.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

never publish pointer payloads on message bus (#411)

This commit is contained in:
Christoph 2025-04-21 16:42:35 +02:00
parent e2966d32ea
commit 059234d416
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/app/users/user_manager.go
View File

@ -82,7 +82,7 @@ func (m Manager) RegisterUser(ctx context.Context, user *domain.User) error {
return err return err
} }
m.bus.Publish(app.TopicUserRegistered, createdUser) m.bus.Publish(app.TopicUserRegistered, *createdUser)
return nil 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) return nil, fmt.Errorf("update failure: %w", err)
} }
m.bus.Publish(app.TopicUserUpdated, user) m.bus.Publish(app.TopicUserUpdated, *user)
m.bus.Publish(app.TopicUserApiEnabled, user) m.bus.Publish(app.TopicUserApiEnabled, *user)
return user, nil 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) return nil, fmt.Errorf("update failure: %w", err)
} }
m.bus.Publish(app.TopicUserUpdated, user) m.bus.Publish(app.TopicUserUpdated, *user)
m.bus.Publish(app.TopicUserApiDisabled, user) m.bus.Publish(app.TopicUserApiDisabled, *user)
return user, nil return user, nil
} }

2
internal/app/wireguard/wireguard.go
View File

@ -112,7 +112,7 @@ func (m Manager) connectToMessageBus() {
_ = m.bus.Subscribe(app.TopicUserDeleted, m.handleUserDeletedEvent) _ = 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 { if !m.cfg.Core.CreateDefaultPeerOnCreation {
return return
} }