Miroirs/jorge
1
0
Fork 0
mirror of https://github.com/facundoolano/jorge.git synced 2024-12-25 21:58:28 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

extract event broker instantiation

Browse source
This commit is contained in:
facundoolano 2024-03-06 11:25:52 -03:00
parent 0d62e10a02
commit 2d2db99441
1 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
commands/serve.go
View file

@ -34,7 +34,8 @@ func (cmd *Serve) Run(ctx *kong.Context) error {
} }
// watch for changes in src and layouts, and trigger a rebuild // watch for changes in src and layouts, and trigger a rebuild
watcher, broker, err := runWatcher(config) broker := newEventBroker()
watcher, err := runWatcher(config, broker)
if err != nil { if err != nil {
return err return err
} }
@ -83,14 +84,12 @@ func makeServerEventsHandler(broker *EventBroker) http.HandlerFunc {
// Sets up a watcher that will publish changes in the site source files // Sets up a watcher that will publish changes in the site source files
// to the returned event broker. // to the returned event broker.
func runWatcher(config *config.Config) (*fsnotify.Watcher, *EventBroker, error) { func runWatcher(config *config.Config, broker *EventBroker) (*fsnotify.Watcher, error) {
watcher, err := fsnotify.NewWatcher() watcher, err := fsnotify.NewWatcher()
if err != nil { if err != nil {
return nil, nil, err return nil, err
} }
broker := newEventBroker()
// the rebuild is handled after some delay to prevent bursts of events to trigger repeated rebuilds // the rebuild is handled after some delay to prevent bursts of events to trigger repeated rebuilds
// which can cause the browser to refresh while another unfinished build is in progress (refreshing to // which can cause the browser to refresh while another unfinished build is in progress (refreshing to
// a missing file). The initial build is done immediately. // a missing file). The initial build is done immediately.
@ -115,7 +114,7 @@ func runWatcher(config *config.Config) (*fsnotify.Watcher, *EventBroker, error)
} }
}() }()
return watcher, broker, err return watcher, err
} }
// React to source file change events by re-watching the source directories, // React to source file change events by re-watching the source directories,