From 052213459b41b2f9c181a58b6ff760c2807bfe84 Mon Sep 17 00:00:00 2001
From: Joel Wetzell <git@jwetzell.com>
Date: Tue, 25 Nov 2025 06:45:06 -0600
Subject: [PATCH] reset interval on output

---
 interval.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/interval.go b/interval.go
index 369b9f8..dbe72f2 100644
--- a/interval.go
+++ b/interval.go
@@ -10,6 +10,7 @@ type Interval struct {
 	config   ModuleConfig
 	Duration uint32
 	router   *Router
+	ticker   *time.Ticker
 }
 
 func init() {
@@ -48,11 +49,11 @@ func (i *Interval) RegisterRouter(router *Router) {
 
 func (i *Interval) Run() error {
 	ticker := time.NewTicker(time.Millisecond * time.Duration(i.Duration))
+	i.ticker = ticker
 	defer ticker.Stop()
 	for {
 		select {
 		case <-i.router.Context.Done():
-			ticker.Stop()
 			slog.Debug("router context done in module", "id", i.config.Id)
 			return nil
 		case t := <-ticker.C:
@@ -65,5 +66,6 @@ func (i *Interval) Run() error {
 }
 
 func (i *Interval) Output(payload any) error {
-	return fmt.Errorf("interval output is not implemented")
+	i.ticker.Reset(time.Millisecond * time.Duration(i.Duration))
+	return nil
 }