fix(timers): drop current response redis key on timer update

Author: Satont

apps/timers/internal/activity/activity.go

@@ -79,7 +79,7 @@ func (c *Activity) SendMessage(ctx context.Context, timerId string) (
 		return 0, nil
 	}
 
-	currentResponse, err := c.redis.Get(ctx, "timers:current_response:"+timerId).Int()
+	currentResponse, err := c.redis.Get(ctx, redis_keys.TimersCurrentResponse(timerId)).Int()
 	if err != nil && !errors.Is(err, redis.Nil) {
 		return currentResponse, err
 	}
@@ -133,7 +133,7 @@ func (c *Activity) SendMessage(ctx context.Context, timerId string) (
 		nextIndex = 0
 	}
 
-	err = c.redis.Set(ctx, "timers:current_response:"+timerId, nextIndex, 24*time.Hour).Err()
+	err = c.redis.Set(ctx, redis_keys.TimersCurrentResponse(timerId), nextIndex, 24*time.Hour).Err()
 	if err != nil {
 		return nextIndex, err
 	}

apps/timers/internal/bus-listener/bus-listener.go

@@ -3,15 +3,18 @@ package bus_listener
 import (
 	"context"
 
+	"github.com/redis/go-redis/v9"
 	"github.com/satont/twir/apps/timers/internal/workflow"
 	"github.com/satont/twir/libs/logger"
 	buscore "github.com/twirapp/twir/libs/bus-core"
 	"github.com/twirapp/twir/libs/bus-core/timers"
+	"github.com/twirapp/twir/libs/redis_keys"
 	"go.uber.org/fx"
 )
 
 type server struct {
 	workflow *workflow.Workflow
+	redis    *redis.Client
 }
 
 type Opts struct {
@@ -21,11 +24,13 @@ type Opts struct {
 	Logger   logger.Logger
 	Workflow *workflow.Workflow
 	Bus      *buscore.Bus
+	Redis    *redis.Client
 }
 
 func New(opts Opts) error {
 	s := &server{
 		workflow: opts.Workflow,
+		redis:    opts.Redis,
 	}
 
 	opts.Lc.Append(
@@ -49,6 +54,9 @@ func New(opts Opts) error {
 }
 
 func (c *server) addTimerToQueue(ctx context.Context, t timers.AddOrRemoveTimerRequest) struct{} {
+	c.redis.Del(ctx, redis_keys.TimersCurrentResponse(t.TimerID))
+
+	c.workflow.RemoveTimer(ctx, t.TimerID)
 	c.workflow.AddTimer(ctx, t.TimerID)
 
 	return struct{}{}

libs/redis_keys/timers.go

@@ -0,0 +1,5 @@
+package redis_keys
+
+func TimersCurrentResponse(timerId string) string {
+	return "timers:current_response:" + timerId
+}