chore(timers): one time schedule all timers

apps/timers/cmd/main.go

@@ -10,6 +10,7 @@ import (
 	"github.com/satont/twir/apps/timers/internal/repositories/channels"
 	"github.com/satont/twir/apps/timers/internal/repositories/streams"
 	"github.com/satont/twir/apps/timers/internal/repositories/timers"
+	"github.com/satont/twir/apps/timers/internal/s"
 	"github.com/satont/twir/apps/timers/internal/worker"
 	"github.com/satont/twir/apps/timers/internal/workflow"
 	cfg "github.com/satont/twir/libs/config"
@@ -43,6 +44,7 @@ func main() {
 		),
 		fx.NopLogger,
 		fx.Invoke(
+			s.New,
 			worker.New,
 			grpc_server.New,
 			func(l logger.Logger) {

apps/timers/internal/s/s.go

@@ -0,0 +1,19 @@
+package s
+
+import (
+	"context"
+
+	"github.com/satont/twir/apps/timers/internal/repositories/timers"
+	"github.com/satont/twir/apps/timers/internal/workflow"
+)
+
+func New(repository timers.Repository, w *workflow.Workflow) {
+	timers, err := repository.GetAll()
+	if err != nil {
+		return
+	}
+
+	for _, timer := range timers {
+		w.AddTimer(context.TODO(), timer.ID)
+	}
+}

apps/timers/internal/worker/worker.go

@@ -32,7 +32,7 @@ func New(opts Opts) error {
 	if err != nil {
 		return err
 	}
-
+	
 	temporalWorker := worker.New(c, shared.TimersWorkerTaskQueueName, worker.Options{})
 
 	temporalWorker.RegisterWorkflow(opts.Workflow.Flow)