Skip to content
Snippets Groups Projects
Verified Commit 234258be authored by Malte Bauch's avatar Malte Bauch
Browse files

Fix wrongly returned Event for NewKeyStoreEvent

parent 4a59230a
No related branches found
No related tags found
1 merge request!253Initialize AssignForwardingHandler and KeyStoreHandler
Pipeline #262494 failed
This commit is part of merge request !253. Comments created here will be created in the context of that merge request.
......@@ -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(),
}
}
......
......@@ -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)
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment