From 234258be71e36652a424895b8130ea3d50422c55 Mon Sep 17 00:00:00 2001 From: Malte Bauch <malte.bauch@h-da.de> Date: Tue, 18 Feb 2025 18:50:09 +0100 Subject: [PATCH] Fix wrongly returned Event for NewKeyStoreEvent --- goKMS/kms/event/event.go | 6 +++--- goKMS/kms/store/kms-keystore.go | 5 ++--- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/goKMS/kms/event/event.go b/goKMS/kms/event/event.go index c0a32e8..2e89cf2 100644 --- a/goKMS/kms/event/event.go +++ b/goKMS/kms/event/event.go @@ -93,9 +93,9 @@ type KeyStoreEvent struct { Timestamp time.Time } -func NewKeyStoreEvent() *RouteEvent { - return &RouteEvent{ - EventTopic: ROUTE, +func NewKeyStoreEvent() *KeyStoreEvent { + return &KeyStoreEvent{ + EventTopic: KEY_STORE, Timestamp: time.Now(), } } diff --git a/goKMS/kms/store/kms-keystore.go b/goKMS/kms/store/kms-keystore.go index 73a0667..683c563 100644 --- a/goKMS/kms/store/kms-keystore.go +++ b/goKMS/kms/store/kms-keystore.go @@ -4,7 +4,6 @@ import ( "encoding/base64" "fmt" "sync" - "time" etsi14 "code.fbi.h-da.de/danet/quant/etsi014/go/rest/etsi/client" "code.fbi.h-da.de/danet/quant/goKMS/kms/event" @@ -70,7 +69,7 @@ func (ks *KmsKeyStore) AddKey(keyId uuid.UUID, keyToadd []byte) error { // publish to eventBus go func() { - err := ks.eventBus.Publish(&event.KeyStoreEvent{EventTopic: event.KEY_STORE, Timestamp: time.Now()}) + err := ks.eventBus.Publish(event.NewKeyStoreEvent()) if err != nil { fmt.Errorf("Publishing a key store update through the eventBus failed, err: %w", err) } @@ -115,7 +114,7 @@ func (ks *KmsKeyStore) DeleteKey(keyId uuid.UUID) { // publish to eventBus go func() { - err := ks.eventBus.Publish(&event.KeyStoreEvent{EventTopic: event.KEY_STORE, Timestamp: time.Now()}) + err := ks.eventBus.Publish(event.NewKeyStoreEvent()) if err != nil { fmt.Errorf("Publishing a key store update through the eventBus failed, err: %w", err) } -- GitLab