fix: correct event handler registration in plugins
Fixed incorrect event handler registration in two plugins: - Statistics plugin was calling Step instead of Stop on StopEvent, preventing statistics from being printed at the end of execution. - Logs plugin was listening to StopEvent instead of StepEvent, causing it to only log once at the end instead of on each step.
This commit is contained in:
@@ -14,7 +14,7 @@ type Logs struct {
|
|||||||
|
|
||||||
func NewLogs(logger *slog.Logger, process *engine.Engine) *Logs {
|
func NewLogs(logger *slog.Logger, process *engine.Engine) *Logs {
|
||||||
plugin := &Logs{logger, process}
|
plugin := &Logs{logger, process}
|
||||||
process.On(engine.StopEvent, plugin.Step)
|
process.On(engine.StepEvent, plugin.Step)
|
||||||
|
|
||||||
return plugin
|
return plugin
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ func NewStatistics(process *engine.Engine) *Statistics {
|
|||||||
plugin := &Statistics{}
|
plugin := &Statistics{}
|
||||||
process.On(engine.StartEvent, plugin.Start)
|
process.On(engine.StartEvent, plugin.Start)
|
||||||
process.On(engine.StepEvent, plugin.Step)
|
process.On(engine.StepEvent, plugin.Step)
|
||||||
process.On(engine.StopEvent, plugin.Step)
|
process.On(engine.StopEvent, plugin.Stop)
|
||||||
|
|
||||||
return plugin
|
return plugin
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user