fix: issues

This commit is contained in:
Rogee
2025-02-10 15:10:39 +08:00
parent eb13231e9e
commit 266c2c4767
8 changed files with 91 additions and 15 deletions

View File

@@ -0,0 +1,22 @@
package publishers
import (
"encoding/json"
"{{.ModuleName}}/app/events"
"{{.ModuleName}}/pkg/atom/contracts"
)
var _ contracts.EventPublisher = (*UserRegister)(nil)
type UserRegister struct {
ID int64 `json:"id"`
}
func (e *UserRegister) Marshal() ([]byte, error) {
return json.Marshal(e)
}
func (e *UserRegister) Topic() string {
return events.TopicUserRegister
}

View File

@@ -0,0 +1,46 @@
package subscribers
import (
"encoding/json"
"{{.ModuleName}}/app/events"
"{{.ModuleName}}/app/events/publishers"
"{{.ModuleName}}/pkg/atom/contracts"
"github.com/ThreeDotsLabs/watermill/message"
"github.com/sirupsen/logrus"
)
var _ contracts.EventHandler = (*UserRegister)(nil)
// @provider(event)
type UserRegister struct {
log *logrus.Entry `inject:"false"`
}
func (e *UserRegister) Prepare() error {
e.log = logrus.WithField("module", "events.subscribers.user_register")
return nil
}
// PublishToTopic implements contracts.EventHandler.
func (e *UserRegister) PublishToTopic() string {
return events.TopicProcessed
}
// Topic implements contracts.EventHandler.
func (e *UserRegister) Topic() string {
return events.TopicUserRegister
}
// Handler implements contracts.EventHandler.
func (e *UserRegister) Handler(msg *message.Message) ([]*message.Message, error) {
var payload publishers.UserRegister
err := json.Unmarshal(msg.Payload, &payload)
if err != nil {
return nil, err
}
e.log.Infof("received event %s", msg.Payload)
return nil, nil
}

View File

@@ -1,5 +1,6 @@
package events
const (
TopicProcessed = "event:processed"
TopicProcessed = "event:processed"
TopicUserRegister = "event:user_register"
)

View File

@@ -3,7 +3,7 @@ package event
import (
"context"
"{{.ModuleName}}/app/events"
"{{.ModuleName}}/app/events/subscribers"
"{{.ModuleName}}/app/service"
"{{.ModuleName}}/pkg/atom"
"{{.ModuleName}}/pkg/atom/container"
@@ -31,7 +31,7 @@ func Command() atom.Option {
atom.Providers(
defaultProviders().
With(
events.Provide,
subscribers.Provide,
),
),
)