foomo/sesamy-go
1
0
Fork 0
mirror of https://github.com/foomo/sesamy-go.git synced 2025-10-16 12:35:43 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

feat: add no publish handler

Browse Source
This commit is contained in:
Kevin Franklin Kim 2024-05-30 10:30:23 +02:00
parent 4921daa17e
commit 9c4ec4a25b
No known key found for this signature in database
4 changed files with 48 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
integration/watermill/gtag/messagehandler.go
View File

@ -8,7 +8,7 @@ import (
"github.com/pkg/errors"
)
func MessageHandler(handler func(payload *gtag.Payload, msg *message.Message) error) func(msg *message.Message) ([]*message.Message, error) {
func MessageHandler(handler func(payload *gtag.Payload, msg *message.Message) error) message.HandlerFunc {
return func(msg *message.Message) ([]*message.Message, error) {
var payload *gtag.Payload

23
integration/watermill/gtag/nopublishmessagehandler.go Normal file
View File

@ -0,0 +1,23 @@
package gtag
import (
"encoding/json"
"github.com/ThreeDotsLabs/watermill/message"
"github.com/foomo/sesamy-go/pkg/encoding/gtag"
"github.com/pkg/errors"
)
func NoPublishMessageHandler(handler func(payload *gtag.Payload, msg *message.Message) error) func(msg *message.Message) error {
return func(msg *message.Message) error {
var payload *gtag.Payload
// unmarshal payload
if err := json.Unmarshal(msg.Payload, &payload); err != nil {
return errors.Wrap(err, "failed to unmarshal payload")
}
// handle payload
return handler(payload, msg)
}
}

2
integration/watermill/mpv2/messagehandler.go
View File

@ -8,7 +8,7 @@ import (
"github.com/pkg/errors"
)
func MessageHandler(handler func(payload *mpv2.Payload[any], msg *message.Message) error) func(msg *message.Message) ([]*message.Message, error) {
func MessageHandler(handler func(payload *mpv2.Payload[any], msg *message.Message) error) message.HandlerFunc {
return func(msg *message.Message) ([]*message.Message, error) {
var payload *mpv2.Payload[any]

23
integration/watermill/mpv2/nopublishmessagehandler.go Normal file
View File

@ -0,0 +1,23 @@
package mpv2
import (
"encoding/json"
"github.com/ThreeDotsLabs/watermill/message"
"github.com/foomo/sesamy-go/pkg/encoding/mpv2"
"github.com/pkg/errors"
)
func NoPublishMessageHandler(handler func(payload *mpv2.Payload[any], msg *message.Message) error) message.NoPublishHandlerFunc {
return func(msg *message.Message) error {
var payload *mpv2.Payload[any]
// unmarshal payload
if err := json.Unmarshal(msg.Payload, &payload); err != nil {
return errors.Wrap(err, "failed to unmarshal payload")
}
// handle payload
return handler(payload, msg)
}
}