/
event.go
47 lines (39 loc) · 1.03 KB
/
event.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
package app
import (
"github.com/ThreeDotsLabs/watermill/message"
"github.com/ThreeDotsLabs/watermill/message/router/middleware"
"github.com/elct9620/wvs/internal/db"
"github.com/elct9620/wvs/internal/subscriber"
)
type EventBusOption = func(*message.Router)
func ProvideEventBus(options ...EventBusOption) (*message.Router, error) {
router, err := message.NewRouter(message.RouterConfig{}, nil)
if err != nil {
return nil, err
}
router.AddMiddleware(
middleware.CorrelationID,
middleware.Retry{
MaxRetries: 3,
}.Middleware,
middleware.Recoverer,
)
for _, option := range options {
option(router)
}
return router, nil
}
func ProvideEventSubscribers(
database *db.Database,
databaseSubscribers []subscriber.DatabaseSubscriber,
) []EventBusOption {
watcher := database.Watch()
dbSubscriber := db.NewSubscriber(watcher)
return []EventBusOption{
func(router *message.Router) {
for _, s := range databaseSubscribers {
router.AddNoPublisherHandler(s.Name(), s.Topic(), dbSubscriber, s.Handler)
}
},
}
}