add helper to read data

This commit is contained in:
mamor87 2025-09-17 07:55:38 +02:00
parent 1133202fa4
commit 7da7638ecd
3 changed files with 12 additions and 9 deletions

View File

@ -27,7 +27,6 @@ package main
import ( import (
"fmt" "fmt"
"sync"
"git.apihub24.de/admin/events" "git.apihub24.de/admin/events"
) )
@ -55,15 +54,14 @@ func main() {
nameSubscription := handler.Subscribe(NameEventType, func(event events.IEvent) { nameSubscription := handler.Subscribe(NameEventType, func(event events.IEvent) {
// read the Name Event Data // read the Name Event Data
var data NameEventData data, _ := events.ParseEventData[NameEventData](event)
_ = event.Data(&data)
// Publish the Greet Event // Publish the Greet Event
_ = handler.Publish(events.NewEvent(GreetEventType, GreetEventData{Greeting: fmt.Sprintf("Hello, %s", data.Name)})) _ = handler.Publish(events.NewEvent(GreetEventType, GreetEventData{Greeting: fmt.Sprintf("Hello, %s", data.Name)}))
}) })
greetSubscription := handler.Subscribe(GreetEventType, func(event events.IEvent) { greetSubscription := handler.Subscribe(GreetEventType, func(event events.IEvent) {
var data GreetEventData data, _ := events.ParseEventData[GreetEventData](event)
_ = event.Data(&data) println(fmt.Sprintf("%v", data))
}) })
// publish the Name Event // publish the Name Event
_ = handler.Publish(nameEvent) _ = handler.Publish(nameEvent)

7
helper.go Normal file
View File

@ -0,0 +1,7 @@
package events
func ParseEventData[T any](event IEvent) (T, error) {
var d T
err := event.Data(&d)
return d, err
}

View File

@ -29,8 +29,7 @@ func Test_EventHandler_ShouldHandleSubscriptions(t *testing.T) {
wg.Add(2) wg.Add(2)
handler.Subscribe(NameEventType, func(event events.IEvent) { handler.Subscribe(NameEventType, func(event events.IEvent) {
var data NameEventData data, err := events.ParseEventData[NameEventData](event)
err := event.Data(&data)
if err != nil { if err != nil {
t.Error(err) t.Error(err)
} }
@ -42,8 +41,7 @@ func Test_EventHandler_ShouldHandleSubscriptions(t *testing.T) {
}) })
handler.Subscribe(GreetEventType, func(event events.IEvent) { handler.Subscribe(GreetEventType, func(event events.IEvent) {
var data GreetEventData data, err := events.ParseEventData[GreetEventData](event)
err := event.Data(&data)
if err != nil { if err != nil {
t.Error(err) t.Error(err)
} }